irmd: Allow direct rbuff between local processes

This allows bypassing the IPCP for local processes that share the same
packet pool, lowering latency between processes to comparable levels
as Unix sockets (RTT in the order of a microsecond).

For local processes, no IPCPs are needed:

 $ irm b prog oping n oping
 $ oping -l
 Ouroboros ping server started.
 New flow 64.
 Received 64 bytes on fd 64.

The direct IPC can be disabled with the DISABLE_DIRECT_IPC build
flag. Note that this is needed for rumba 'local' experiments to
emulate network topologies. Without this flag all processes will just
communicate directly.

Signed-off-by: Dimitri Staessens <dimitri@ouroboros.rocks>
Signed-off-by: Sander Vrijders <sander@ouroboros.rocks>

1 files changed, 5 insertions, 9 deletions

diff --git a/src/irmd/reg/flow.h b/src/irmd/reg/flow.h
index d0078e1b..9a4046d3 100644
--- a/src/irmd/reg/flow.h
+++ b/src/irmd/reg/flow.h
@@ -31,6 +31,7 @@
 #include <ouroboros/ssm_rbuff.h>
 #include <ouroboros/utils.h>
 
+#include <stdbool.h>
 #include <sys/types.h>
 #include <time.h>
 
@@ -40,11 +41,14 @@ struct reg_flow {
         struct flow_info   info;
         int                response;
 
-        buffer_t           data;
+        buffer_t           req_data;
+        buffer_t           rsp_data;
         struct timespec    t0;
 
         char               name[NAME_SIZE + 1];
 
+        bool               direct;
+
         struct ssm_rbuff * n_rb;
         struct ssm_rbuff * n_1_rb;
 };
@@ -56,12 +60,4 @@ void              reg_flow_destroy(struct reg_flow * flow);
 int               reg_flow_update(struct reg_flow *  flow,
                                   struct flow_info * info);
 
-void              reg_flow_set_data(struct reg_flow * flow,
-                                    const buffer_t *  buf);
-
-void              reg_flow_get_data(struct reg_flow * flow,
-                                    buffer_t *        buf);
-
-void              reg_flow_free_data(struct reg_flow * flow);
-
 #endif /* OUROBOROS_IRMD_REG_FLOW_H */