diff options
| author | Dimitri Staessens <dimitri.staessens@ugent.be> | 2018-06-15 12:44:27 +0200 |
|---|---|---|
| committer | Sander Vrijders <sander.vrijders@ugent.be> | 2018-06-15 12:52:09 +0200 |
| commit | 7e8d34cd8739e1e3dfb55b782e820f81e3a75d8a (patch) | |
| tree | b720072711d4e4853b15b76063b8eca8d1af18c6 | |
| parent | 4356a8dce299eb84cbafa2edd0bbd252a6a4c335 (diff) | |
| download | ouroboros-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>
| -rw-r--r-- | src/lib/dev.c | 8 |
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); |