summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSander Vrijders <sander.vrijders@ugent.be>2018-06-15 12:52:15 +0200
committerSander Vrijders <sander.vrijders@ugent.be>2018-06-15 12:52:15 +0200
commitaea32291530c2dbec84ff424a8c7f224bd1b13d7 (patch)
tree7be9b5077258b78f791e6c135e002f73d0d8f344
parent9b7cbda6a873acbee0bf66f3080efa7ab7d4e5ad (diff)
parent7e8d34cd8739e1e3dfb55b782e820f81e3a75d8a (diff)
downloadouroboros-aea32291530c2dbec84ff424a8c7f224bd1b13d7.tar.gz
ouroboros-aea32291530c2dbec84ff424a8c7f224bd1b13d7.zip
Merge branch 'testing' into be
-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 8417d63b..9eade797 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);