summaryrefslogtreecommitdiff
path: root/src/ipcpd/normal/connmgr.c
diff options
context:
space:
mode:
authorSander Vrijders <sander.vrijders@ugent.be>2018-07-03 15:51:16 +0200
committerDimitri Staessens <dimitri.staessens@ugent.be>2018-07-04 16:16:41 +0200
commit301212fc967b51fd01e02c0dca8c9183db923b11 (patch)
tree4db76fb5977f0ecd34eb300a6375e1cf5d280497 /src/ipcpd/normal/connmgr.c
parentbedee0b0aac97fb195288ec81837e192cbb7b27c (diff)
downloadouroboros-301212fc967b51fd01e02c0dca8c9183db923b11.tar.gz
ouroboros-301212fc967b51fd01e02c0dca8c9183db923b11.zip
ipcpd: React to flow events actively
This adds the infrastructure to actively react to flow up, down and deallocated events. Signed-off-by: Sander Vrijders <sander.vrijders@ugent.be> Signed-off-by: Dimitri Staessens <dimitri.staessens@ugent.be>
Diffstat (limited to 'src/ipcpd/normal/connmgr.c')
-rw-r--r--src/ipcpd/normal/connmgr.c7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/ipcpd/normal/connmgr.c b/src/ipcpd/normal/connmgr.c
index 9530633b..bf07ebc4 100644
--- a/src/ipcpd/normal/connmgr.c
+++ b/src/ipcpd/normal/connmgr.c
@@ -193,7 +193,9 @@ static void handle_event(void * self,
(void) self;
- if (!(event == NOTIFY_DT_FLOW_UP || event == NOTIFY_DT_FLOW_DOWN))
+ if (!(event == NOTIFY_DT_FLOW_UP ||
+ event == NOTIFY_DT_FLOW_DOWN ||
+ event == NOTIFY_DT_FLOW_DEALLOC))
return;
if (get_conn_by_fd(*((int *) o), COMPID_DT, &conn))
@@ -206,6 +208,9 @@ static void handle_event(void * self,
case NOTIFY_DT_FLOW_DOWN:
notifier_event(NOTIFY_DT_CONN_DOWN, &conn);
break;
+ case NOTIFY_DT_FLOW_DEALLOC:
+ notifier_event(NOTIFY_DT_CONN_DEL, &conn);
+ break;
default:
break;
}