diff options
| author | dimitri staessens <dimitri.staessens@ugent.be> | 2017-03-31 12:40:46 +0000 |
|---|---|---|
| committer | Sander Vrijders <sander.vrijders@ugent.be> | 2017-03-31 12:40:46 +0000 |
| commit | e39e93447d8da3bf06b8f5aecd3daf41c0451f81 (patch) | |
| tree | 2a8bf2d55abe85660e3fd3b3bd97114d63107006 /src/lib/cdap_req.c | |
| parent | 02523d780b9c629a98e863b5218f054cde2f0426 (diff) | |
| parent | 9f33d70fc92d2f0f7b6058765049bfcb41e2cca9 (diff) | |
| download | ouroboros-e39e93447d8da3bf06b8f5aecd3daf41c0451f81.tar.gz ouroboros-e39e93447d8da3bf06b8f5aecd3daf41c0451f81.zip | |
Merged in dstaesse/ouroboros/be-cdap-cancel (pull request #442)
lib: Cancel outstanding CDAP requests on destroy
Diffstat (limited to 'src/lib/cdap_req.c')
| -rw-r--r-- | src/lib/cdap_req.c | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/src/lib/cdap_req.c b/src/lib/cdap_req.c index 0b77f266..df748058 100644 --- a/src/lib/cdap_req.c +++ b/src/lib/cdap_req.c @@ -175,3 +175,16 @@ void cdap_req_respond(struct cdap_req * creq, pthread_mutex_unlock(&creq->lock); } + + +void cdap_req_cancel(struct cdap_req * creq) +{ + assert(creq); + + pthread_mutex_lock(&creq->lock); + + creq->state = REQ_NULL; + pthread_cond_broadcast(&creq->cond); + + pthread_mutex_unlock(&creq->lock); +} |