diff options
| author | Sander Vrijders <sander.vrijders@intec.ugent.be> | 2016-10-26 14:59:43 +0200 |
|---|---|---|
| committer | Sander Vrijders <sander.vrijders@intec.ugent.be> | 2016-10-26 15:10:28 +0200 |
| commit | 188aba280f7c5b80b868cb1527fce9d45702a196 (patch) | |
| tree | 5a0852a4832cc853d45e96f0087e7724c8b205a1 /src/lib | |
| parent | cc64e52dee3559128293a17a669e94acb48f9309 (diff) | |
| download | ouroboros-188aba280f7c5b80b868cb1527fce9d45702a196.tar.gz ouroboros-188aba280f7c5b80b868cb1527fce9d45702a196.zip | |
ipcpd: Add threadpool for main loop
This adds a threadpool for the main loop of the IPCPs. Before there
was a single thread handling each request, which could result in
starvation since performing name queries at the same time as enrolling
a normal IPCP was impossible.
Diffstat (limited to 'src/lib')
| -rw-r--r-- | src/lib/dev.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/lib/dev.c b/src/lib/dev.c index 94fbd394..55ee7572 100644 --- a/src/lib/dev.c +++ b/src/lib/dev.c @@ -489,9 +489,8 @@ int flow_alloc(char * dst_name, char * src_ae_name, struct qos_spec * qos) pthread_rwlock_unlock(&ai.data_lock); recv_msg = send_recv_irm_msg(&msg); - if (recv_msg == NULL) { + if (recv_msg == NULL) return -1; - } if (!recv_msg->has_api || !recv_msg->has_port_id) { irm_msg__free_unpacked(recv_msg, NULL); |