From a3d550ff972121641562d375f75bcf188fc7fe59 Mon Sep 17 00:00:00 2001
From: dimitri staessens <dimitri.staessens@ugent.be>
Date: Mon, 10 Apr 2017 13:42:55 +0200
Subject: dev: Return descriptive errors for flow_alloc

---
 src/lib/dev.c | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

(limited to 'src/lib/dev.c')

diff --git a/src/lib/dev.c b/src/lib/dev.c
index 7cd6fdce..433fb93b 100644
--- a/src/lib/dev.c
+++ b/src/lib/dev.c
@@ -421,7 +421,7 @@ int flow_accept(qosspec_t *             qs,
 
         if (!recv_msg->has_api || !recv_msg->has_port_id) {
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -EIRMD;
         }
 
         pthread_rwlock_rdlock(&ai.data_lock);
@@ -432,7 +432,7 @@ int flow_accept(qosspec_t *             qs,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -EBADF;
         }
 
         ai.flows[fd].rx_rb = shm_rbuff_open(ai.api, recv_msg->port_id);
@@ -441,7 +441,7 @@ int flow_accept(qosspec_t *             qs,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -ENOMEM;
         }
 
         ai.flows[fd].tx_rb = shm_rbuff_open(recv_msg->api, recv_msg->port_id);
@@ -451,7 +451,7 @@ int flow_accept(qosspec_t *             qs,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -ENOMEM;
         }
 
         ai.flows[fd].set = shm_flow_set_open(recv_msg->api);
@@ -461,7 +461,7 @@ int flow_accept(qosspec_t *             qs,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -ENOMEM;
         }
 
         ai.flows[fd].port_id = recv_msg->port_id;
@@ -530,7 +530,7 @@ int flow_alloc(const char *            dst_name,
 
         if (!recv_msg->has_api || !recv_msg->has_port_id) {
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -EIRMD;
         }
 
         pthread_rwlock_rdlock(&ai.data_lock);
@@ -541,7 +541,7 @@ int flow_alloc(const char *            dst_name,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -EBADF;
         }
 
         ai.flows[fd].rx_rb = shm_rbuff_open(ai.api, recv_msg->port_id);
@@ -550,7 +550,7 @@ int flow_alloc(const char *            dst_name,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -ENOMEM;
         }
 
         ai.flows[fd].tx_rb = shm_rbuff_open(recv_msg->api, recv_msg->port_id);
@@ -560,7 +560,7 @@ int flow_alloc(const char *            dst_name,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -ENOMEM;
         }
 
         ai.flows[fd].set = shm_flow_set_open(recv_msg->api);
@@ -570,7 +570,7 @@ int flow_alloc(const char *            dst_name,
                 pthread_rwlock_unlock(&ai.flows_lock);
                 pthread_rwlock_unlock(&ai.data_lock);
                 irm_msg__free_unpacked(recv_msg, NULL);
-                return -1;
+                return -ENOMEM;
         }
 
         ai.flows[fd].port_id = recv_msg->port_id;
-- 
cgit v1.2.3