lib: API for accepting flows with QoS

5 files changed, 12 insertions, 5 deletions

diff --git a/src/ipcpd/normal/fmgr.c b/src/ipcpd/normal/fmgr.c
index 46c72691..b5ae40dd 100644
--- a/src/ipcpd/normal/fmgr.c
+++ b/src/ipcpd/normal/fmgr.c
@@ -125,6 +125,7 @@ static void * fmgr_nm1_acceptor(void * o)
 {
         int    fd;
         char * ae_name;
+        struct qos_spec qs;
 
         (void) o;
 
@@ -140,7 +141,7 @@ static void * fmgr_nm1_acceptor(void * o)
 
                 pthread_rwlock_unlock(&ipcpi.state_lock);
 
-                fd = flow_accept(&ae_name);
+                fd = flow_accept(&ae_name, &qs);
                 if (fd < 0) {
                         LOG_ERR("Failed to accept flow.");
                         continue;
diff --git a/src/lib/dev.c b/src/lib/dev.c
index 94fbd394..7fc2e6b3 100644
--- a/src/lib/dev.c
+++ b/src/lib/dev.c
@@ -134,6 +134,7 @@ struct flow {
         struct shm_flow_set * set;
         int                   port_id;
         int                   oflags;
+        enum qos_cube         qos;
 
         pid_t                 api;
 
@@ -315,12 +316,14 @@ void ap_fini()
 }
 
 
-int flow_accept(char ** ae_name)
+int flow_accept(char ** ae_name, struct qos_spec * qos)
 {
         irm_msg_t msg = IRM_MSG__INIT;
         irm_msg_t * recv_msg = NULL;
         int fd = -1;
 
+        (void) qos;
+
         msg.code    = IRM_MSG_CODE__IRM_FLOW_ACCEPT;
         msg.has_api = true;
 
diff --git a/src/tools/cbr/cbr_server.c b/src/tools/cbr/cbr_server.c
index f1c342d1..eb45a2c6 100644
--- a/src/tools/cbr/cbr_server.c
+++ b/src/tools/cbr/cbr_server.c
@@ -155,6 +155,7 @@ void * listener(void * o)
 {
         int client_fd = 0;
         int response = 0;
+        struct qos_spec qs;
 
         (void) o;
 
@@ -162,7 +163,7 @@ void * listener(void * o)
                server_settings.interval, server_settings.timeout);
 
         while (true) {
-                client_fd = flow_accept(NULL);
+                client_fd = flow_accept(NULL, &qs);
                 if (client_fd < 0) {
                         printf("Failed to accept flow.\n");
                         break;
diff --git a/src/tools/echo/echo_server.c b/src/tools/echo/echo_server.c
index 070f0ce3..09575364 100644
--- a/src/tools/echo/echo_server.c
+++ b/src/tools/echo/echo_server.c
@@ -40,6 +40,7 @@ int server_main(void)
         int    client_fd = 0;
         char   buf[BUF_SIZE];
         ssize_t count = 0;
+        struct qos_spec qs;
 
         printf("Starting the server.\n");
 
@@ -50,7 +51,7 @@ int server_main(void)
         }
 
         while (true) {
-                client_fd = flow_accept(NULL);
+                client_fd = flow_accept(NULL, &qs);
                 if (client_fd < 0) {
                         printf("Failed to accept flow.\n");
                         break;
diff --git a/src/tools/oping/oping_server.c b/src/tools/oping/oping_server.c
index 720e71b6..8d7ab1db 100644
--- a/src/tools/oping/oping_server.c
+++ b/src/tools/oping/oping_server.c
@@ -115,13 +115,14 @@ void * accept_thread(void * o)
 {
         int fd = 0;
         struct timespec now = {0, 0};
+        struct qos_spec qs;
 
         (void) o;
 
         printf("Ouroboros ping server started.\n");
 
         while (true) {
-                fd = flow_accept(NULL);
+                fd = flow_accept(NULL, &qs);
                 if (fd < 0) {
                         printf("Failed to accept flow.\n");
                         break;