ipcpd: Fix some bugs for the normal split

1 files changed, 0 insertions, 11 deletions

diff --git a/src/ipcpd/normal/dt.c b/src/ipcpd/normal/dt.c
index 361af6b4..0816ec10 100644
--- a/src/ipcpd/normal/dt.c
+++ b/src/ipcpd/normal/dt.c
@@ -98,18 +98,13 @@ static int sdu_handler(int                  fd,
                         return 0;
                 }
 
-                pff_lock(dt.pff[qc]);
-
                 fd = pff_nhop(dt.pff[qc], dt_pci.dst_addr);
                 if (fd < 0) {
-                        pff_unlock(dt.pff[qc]);
                         log_err("No next hop for %" PRIu64, dt_pci.dst_addr);
                         ipcp_sdb_release(sdb);
                         return -1;
                 }
 
-                pff_unlock(dt.pff[qc]);
-
                 if (ipcp_flow_write(fd, sdb)) {
                         log_err("Failed to write SDU to fd %d.", fd);
                         ipcp_sdb_release(sdb);
@@ -136,7 +131,6 @@ static int sdu_handler(int                  fd,
                         ipcp_sdb_release(sdb);
                         return -1;
                 }
-
         }
 
         return 0;
@@ -279,17 +273,12 @@ int dt_write_sdu(uint64_t             dst_addr,
 
         assert(sdb);
 
-        pff_lock(dt.pff[qc]);
-
         fd = pff_nhop(dt.pff[qc], dst_addr);
         if (fd < 0) {
-                pff_unlock(dt.pff[qc]);
                 log_err("Could not get nhop for address %" PRIu64, dst_addr);
                 return -1;
         }
 
-        pff_unlock(dt.pff[qc]);
-
         dt_pci.dst_addr = dst_addr;
         dt_pci.qc = qc;
         dt_pci.pdu_type = pdu_type;