diff options
| author | Sander Vrijders <sander.vrijders@ugent.be> | 2017-04-05 14:49:10 +0000 |
|---|---|---|
| committer | dimitri staessens <dimitri.staessens@ugent.be> | 2017-04-05 14:49:10 +0000 |
| commit | c6ad4f96f8bb2f1ee749e92308e7173523ddd0b8 (patch) | |
| tree | 040768e8cbb4fd274ad9a4854cad318fdccf0d17 /src/ipcpd/normal | |
| parent | 901a97a2a51ece0fd9991797b9764f60268962b3 (diff) | |
| parent | f309ed3048c0813262c2cf4c7db24befc1729b3a (diff) | |
| download | ouroboros-c6ad4f96f8bb2f1ee749e92308e7173523ddd0b8.tar.gz ouroboros-c6ad4f96f8bb2f1ee749e92308e7173523ddd0b8.zip | |
Merged in sandervrijders/ouroboros/be-fix-fmgr (pull request #463)
ipcpd: normal: Add missing else clause
Diffstat (limited to 'src/ipcpd/normal')
| -rw-r--r-- | src/ipcpd/normal/fmgr.c | 15 | ||||
| -rw-r--r-- | src/ipcpd/normal/pol/complete.c | 2 |
2 files changed, 7 insertions, 10 deletions
diff --git a/src/ipcpd/normal/fmgr.c b/src/ipcpd/normal/fmgr.c index 56f1e099..3191eac5 100644 --- a/src/ipcpd/normal/fmgr.c +++ b/src/ipcpd/normal/fmgr.c @@ -186,8 +186,6 @@ void * fmgr_nm1_sdu_reader(void * o) shm_pci_des(sdb, &pci); if (pci.dst_addr != ipcpi.dt_addr) { - log_dbg("PDU needs to be forwarded."); - if (pci.ttl == 0) { log_dbg("TTL was zero."); ipcp_flow_del(sdb); @@ -211,14 +209,13 @@ void * fmgr_nm1_sdu_reader(void * o) ipcp_flow_del(sdb); continue; } - } + } else { + shm_pci_shrink(sdb); - shm_pci_shrink(sdb); - - if (frct_nm1_post_sdu(&pci, sdb)) { - log_err("Failed to hand PDU to FRCT."); - ipcp_flow_del(sdb); - continue; + if (frct_nm1_post_sdu(&pci, sdb)) { + log_err("Failed to hand PDU to FRCT."); + continue; + } } } } diff --git a/src/ipcpd/normal/pol/complete.c b/src/ipcpd/normal/pol/complete.c index 1f3f6031..6c0be9ec 100644 --- a/src/ipcpd/normal/pol/complete.c +++ b/src/ipcpd/normal/pol/complete.c @@ -89,7 +89,7 @@ static void * allocator(void * o) /* FIXME: subscribe to members to keep the graph complete. */ len = rib_children("/" MEMBERS_NAME, &children); for (i = 0; i < len; ++i) { - if (strcmp(children[i], ipcpi.name) < 0) { + if (strcmp(children[i], ipcpi.name) != 0) { if (connmgr_alloc(complete->ae, children[i], &qs, |