summaryrefslogtreecommitdiff
path: root/src/lib/cdap_req.c
diff options
context:
space:
mode:
authordimitri staessens <[email protected]>2017-03-03 14:56:14 +0000
committerSander Vrijders <[email protected]>2017-03-03 14:56:14 +0000
commit6fc6701774f59288fe7306fa3e0a51fd460e2e01 (patch)
tree68a2bf098171299d2c30f9537c89b862edb0f996 /src/lib/cdap_req.c
parentd753cab1897e323b59923e2b0b11f550b087351c (diff)
parenta688b8a38d7eb9f42406eeb611717db737b0d257 (diff)
downloadouroboros-6fc6701774f59288fe7306fa3e0a51fd460e2e01.tar.gz
ouroboros-6fc6701774f59288fe7306fa3e0a51fd460e2e01.zip
Merged in dstaesse/ouroboros/be-cdap (pull request #398)
lib: Manage multiple flows with a single CDAP instance
Diffstat (limited to 'src/lib/cdap_req.c')
-rw-r--r--src/lib/cdap_req.c9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/lib/cdap_req.c b/src/lib/cdap_req.c
index a0348a14..b60e73ad 100644
--- a/src/lib/cdap_req.c
+++ b/src/lib/cdap_req.c
@@ -30,7 +30,8 @@
#include <stdlib.h>
#include <assert.h>
-struct cdap_req * cdap_req_create(cdap_key_t key)
+struct cdap_req * cdap_req_create(int fd,
+ cdap_key_t key)
{
struct cdap_req * creq = malloc(sizeof(*creq));
pthread_condattr_t cattr;
@@ -38,10 +39,10 @@ struct cdap_req * cdap_req_create(cdap_key_t key)
if (creq == NULL)
return NULL;
- creq->key = key;
+ creq->fd = fd;
+ creq->key = key;
creq->state = REQ_INIT;
-
- creq->response = -1;
+ creq->response = -1;
creq->data.data = NULL;
creq->data.len = 0;