diff options
| author | dimitri staessens <dimitri.staessens@intec.ugent.be> | 2016-10-07 15:25:22 +0200 |
|---|---|---|
| committer | dimitri staessens <dimitri.staessens@intec.ugent.be> | 2016-10-07 15:42:44 +0200 |
| commit | 71f10f5efab37f3df3d909d324cff2e098d21c85 (patch) | |
| tree | 90d6031870d02b557107b0bc2623a129c4b1d074 /src/ipcpd/ipcp.c | |
| parent | aa0eac4f93b80537d02123715842d594a8ff3aad (diff) | |
| download | ouroboros-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/ipcp.c')
| -rw-r--r-- | src/ipcpd/ipcp.c | 11 |
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; |