summaryrefslogtreecommitdiff
path: root/src/ipcpd
diff options
context:
space:
mode:
authordimitri staessens <dimitri.staessens@intec.ugent.be>2016-10-07 15:25:22 +0200
committerdimitri staessens <dimitri.staessens@intec.ugent.be>2016-10-07 15:42:44 +0200
commit71f10f5efab37f3df3d909d324cff2e098d21c85 (patch)
tree90d6031870d02b557107b0bc2623a129c4b1d074 /src/ipcpd
parentaa0eac4f93b80537d02123715842d594a8ff3aad (diff)
downloadouroboros-71f10f5efab37f3df3d909d324cff2e098d21c85.tar.gz
ouroboros-71f10f5efab37f3df3d909d324cff2e098d21c85.zip
lib, dev: Add asynchronous deallocation
Flow deallocation from the application will immediately return (void call). The IRMd will not send a reply message.
Diffstat (limited to 'src/ipcpd')
-rw-r--r--src/ipcpd/ipcp.c11
1 files changed, 7 insertions, 4 deletions
diff --git a/src/ipcpd/ipcp.c b/src/ipcpd/ipcp.c
index db72b88d..a9f80ee7 100644
--- a/src/ipcpd/ipcp.c
+++ b/src/ipcpd/ipcp.c
@@ -313,7 +313,8 @@ void * ipcp_main_loop(void * o)
}
fd = np1_flow_alloc(msg->api, msg->port_id);
if (fd < 0) {
- LOG_ERR("Could not get fd for flow.");
+ LOG_ERR("Could not get fd for port_id. %d",
+ msg->port_id);
ret_msg.has_result = true;
ret_msg.result = -1;
break;
@@ -326,7 +327,7 @@ void * ipcp_main_loop(void * o)
msg->src_ae_name,
msg->qos_cube);
if (ret_msg.result < 0) {
- LOG_DBG("Deallocating failed flow on port_id %d.",
+ LOG_DBG("Deallocate failed on port_id %d.",
msg->port_id);
flow_dealloc(fd);
}
@@ -340,7 +341,8 @@ void * ipcp_main_loop(void * o)
if (!msg->response) {
fd = np1_flow_resp(msg->api, msg->port_id);
if (fd < 0) {
- LOG_ERR("Could not get fd for flow.");
+ LOG_ERR("Could not get fd for port_id %d.",
+ msg->port_id);
ret_msg.has_result = true;
ret_msg.result = -1;
break;
@@ -359,7 +361,8 @@ void * ipcp_main_loop(void * o)
fd = np1_flow_dealloc(msg->port_id);
if (fd < 0) {
- LOG_ERR("Could not get fd for flow.");
+ LOG_ERR("Could not deallocate port_id %d.",
+ msg->port_id);
ret_msg.has_result = true;
ret_msg.result = -1;
break;