diff options
| author | dimitri staessens <[email protected]> | 2017-03-29 07:37:20 +0000 |
|---|---|---|
| committer | Sander Vrijders <[email protected]> | 2017-03-29 07:37:20 +0000 |
| commit | 99b9bd5273e6f7bbbaf4973ef15977ac7056b02d (patch) | |
| tree | e37cdffce783b846311df03d34df994a946f8597 /src/lib/cdap_req.c | |
| parent | b8ad2438385f7c60630d38524ad0c4c13b53b80a (diff) | |
| parent | b09a2719a7820cef58a251ccb2ce286754114a0a (diff) | |
| download | ouroboros-99b9bd5273e6f7bbbaf4973ef15977ac7056b02d.tar.gz ouroboros-99b9bd5273e6f7bbbaf4973ef15977ac7056b02d.zip | |
Merged in dstaesse/ouroboros/be-cdap-fix (pull request #429)
lib: Revise handling CDAP messages
Diffstat (limited to 'src/lib/cdap_req.c')
| -rw-r--r-- | src/lib/cdap_req.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/lib/cdap_req.c b/src/lib/cdap_req.c index b60e73ad..0b77f266 100644 --- a/src/lib/cdap_req.c +++ b/src/lib/cdap_req.c @@ -30,8 +30,9 @@ #include <stdlib.h> #include <assert.h> -struct cdap_req * cdap_req_create(int fd, - cdap_key_t key) +struct cdap_req * cdap_req_create(int fd, + invoke_id_t iid, + cdap_key_t key) { struct cdap_req * creq = malloc(sizeof(*creq)); pthread_condattr_t cattr; @@ -40,6 +41,7 @@ struct cdap_req * cdap_req_create(int fd, return NULL; creq->fd = fd; + creq->iid = iid; creq->key = key; creq->state = REQ_INIT; creq->response = -1; |