From 541b1c5eeb5fe9f9aaa4aa6487852e5c59761139 Mon Sep 17 00:00:00 2001 From: Sander Vrijders Date: Mon, 18 Sep 2017 19:06:15 +0200 Subject: ipcpd, lib: Add flow down events This adds the flow down event to Ouroboros. In the shim-eth-llc, a netlink socket is opened which listens to device up/down events. For each event the flow is then adjusted with fccntl to notify the user the flow is down or back up again. In the normal IPCP an event is thrown if a write reports that the flow is down. --- include/ouroboros/errno.h | 1 + include/ouroboros/fccntl.h | 2 ++ include/ouroboros/shm_rbuff.h | 11 +++++++++-- 3 files changed, 12 insertions(+), 2 deletions(-) (limited to 'include') diff --git a/include/ouroboros/errno.h b/include/ouroboros/errno.h index 7cd58aa5..1710f7f8 100644 --- a/include/ouroboros/errno.h +++ b/include/ouroboros/errno.h @@ -30,5 +30,6 @@ #define EIRMD 1002 /* Failed to communicate with IRMD */ #define EIPCP 1003 /* Failed to communicate with IPCP */ #define EIPCPSTATE 1004 /* Target in wrong state */ +#define EFLOWDOWN 1005 /* Flow is down */ #endif /* OUROBOROS_ERRNO_H */ diff --git a/include/ouroboros/fccntl.h b/include/ouroboros/fccntl.h index d938439f..3bd09e65 100644 --- a/include/ouroboros/fccntl.h +++ b/include/ouroboros/fccntl.h @@ -33,6 +33,8 @@ #define FLOWFRDWR 00000002 /* Read-write flow */ #define FLOWFACCMODE 00000003 /* Access mask */ +#define FLOWFDOWN 00000004 /* Flow is down */ + #define FLOWFNONBLOCK 00004000 /* Non-blocking flow */ #define FLOWFDEFAULT 00000002 /* Default, blocking, rw */ diff --git a/include/ouroboros/shm_rbuff.h b/include/ouroboros/shm_rbuff.h index 55d03b41..af50aada 100644 --- a/include/ouroboros/shm_rbuff.h +++ b/include/ouroboros/shm_rbuff.h @@ -26,6 +26,12 @@ #include #include +#include + +#define ACL_RDWR 0000 +#define ACL_RDONLY 0001 +#define ACL_FLOWDOWN 0002 + struct shm_rbuff; struct shm_rbuff * shm_rbuff_create(pid_t api, @@ -38,9 +44,10 @@ void shm_rbuff_close(struct shm_rbuff * rb); void shm_rbuff_destroy(struct shm_rbuff * rb); -void shm_rbuff_block(struct shm_rbuff * rb); +void shm_rbuff_set_acl(struct shm_rbuff * rb, + uint32_t flags); -void shm_rbuff_unblock(struct shm_rbuff * rb); +uint32_t shm_rbuff_get_acl(struct shm_rbuff * rb); void shm_rbuff_fini(struct shm_rbuff * rb); -- cgit v1.2.3