diff options
| author | Sander Vrijders <[email protected]> | 2016-10-21 12:44:00 +0000 |
|---|---|---|
| committer | Sander Vrijders <[email protected]> | 2016-10-21 12:44:00 +0000 |
| commit | 482c44232d4deda3f89a7d85fbad99c1c64e80ec (patch) | |
| tree | f3fb790d93da3cbe198b0f0c58d9c7513b0eff23 /src/irmd/irm_flow.h | |
| parent | 680017a72c7a15b90f223bafcea80fd3e264e984 (diff) | |
| parent | 02976060919566d1a217b818ca8f33297700d56d (diff) | |
| download | ouroboros-482c44232d4deda3f89a7d85fbad99c1c64e80ec.tar.gz ouroboros-482c44232d4deda3f89a7d85fbad99c1c64e80ec.zip | |
Merged in dstaesse/ouroboros/be-demux (pull request #267)
lib: Demultiplex the fast path
Diffstat (limited to 'src/irmd/irm_flow.h')
| -rw-r--r-- | src/irmd/irm_flow.h | 20 |
1 files changed, 12 insertions, 8 deletions
diff --git a/src/irmd/irm_flow.h b/src/irmd/irm_flow.h index 5ec6d90e..507295bd 100644 --- a/src/irmd/irm_flow.h +++ b/src/irmd/irm_flow.h @@ -24,6 +24,7 @@ #define OUROBOROS_IRMD_IRM_FLOW_H #include <ouroboros/list.h> +#include <ouroboros/shm_rbuff.h> #include <sys/types.h> #include <pthread.h> @@ -38,18 +39,21 @@ enum flow_state { }; struct irm_flow { - struct list_head next; + struct list_head next; - int port_id; + int port_id; - pid_t n_api; - pid_t n_1_api; + pid_t n_api; + pid_t n_1_api; - struct timespec t0; + struct shm_rbuff * n_rb; + struct shm_rbuff * n_1_rb; - enum flow_state state; - pthread_cond_t state_cond; - pthread_mutex_t state_lock; + struct timespec t0; + + enum flow_state state; + pthread_cond_t state_cond; + pthread_mutex_t state_lock; }; struct irm_flow * irm_flow_create(); |