summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorDimitri Staessens <dimitri.staessens@ugent.be>2018-06-15 12:44:27 +0200
committerSander Vrijders <sander.vrijders@ugent.be>2018-06-15 12:52:09 +0200
commit7e8d34cd8739e1e3dfb55b782e820f81e3a75d8a (patch)
treeb720072711d4e4853b15b76063b8eca8d1af18c6 /src
parent4356a8dce299eb84cbafa2edd0bbd252a6a4c335 (diff)
downloadouroboros-7e8d34cd8739e1e3dfb55b782e820f81e3a75d8a.tar.gz
ouroboros-7e8d34cd8739e1e3dfb55b782e820f81e3a75d8a.zip
lib: Mark flows down on fini
This will mark flows down when they are finalized. Signed-off-by: Dimitri Staessens <dimitri.staessens@ugent.be> Signed-off-by: Sander Vrijders <sander.vrijders@ugent.be>
Diffstat (limited to 'src')
-rw-r--r--src/lib/dev.c8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/lib/dev.c b/src/lib/dev.c
index ee82bbaa..7e01d601 100644
--- a/src/lib/dev.c
+++ b/src/lib/dev.c
@@ -242,11 +242,15 @@ static void flow_fini(int fd)
bmp_release(ai.fds, fd);
}
- if (ai.flows[fd].rx_rb != NULL)
+ if (ai.flows[fd].rx_rb != NULL) {
+ shm_rbuff_set_acl(ai.flows[fd].rx_rb, ACL_FLOWDOWN);
shm_rbuff_close(ai.flows[fd].rx_rb);
+ }
- if (ai.flows[fd].tx_rb != NULL)
+ if (ai.flows[fd].tx_rb != NULL) {
+ shm_rbuff_set_acl(ai.flows[fd].tx_rb, ACL_FLOWDOWN);
shm_rbuff_close(ai.flows[fd].tx_rb);
+ }
if (ai.flows[fd].set != NULL)
shm_flow_set_close(ai.flows[fd].set);