scottk/UltraGrid
1
0
Fork 0
mirror of https://github.com/outbackdingo/UltraGrid.git synced 2026-03-21 13:40:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Messaging: fixed a leak

Browse Source
This commit is contained in:
Martin Pulec
2017-06-07 15:06:40 +02:00
parent 4d67849e26
commit 63ea6d8bc6
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/messaging.cpp
View File

@@ -29,6 +29,9 @@ struct response {
namespace {
struct responder {
responder() : received_response(nullptr) {}
~responder() {
free_response(received_response);
}
static void receive_response(void *s, struct response *r) {
(*((shared_ptr<responder> *) s))->receive_response_real(r);
}
@@ -113,7 +116,9 @@ static struct response *send_message_common(struct module *root, const char *con
unique_lock<mutex> lk(responder->lock);
responder->cv.wait_for(lk, std::chrono::milliseconds(timeout_ms), [responder]{return responder->received_response != NULL;});
if (responder->received_response) {
return responder->received_response;
struct response *resp = responder->received_response;
responder->received_response = NULL;
return resp;
} else {
return new_response(RESPONSE_ACCEPTED, NULL);
}
@@ -149,7 +154,9 @@ static struct response *send_message_common(struct module *root, const char *con
unique_lock<mutex> lk(responder->lock);
responder->cv.wait_for(lk, std::chrono::milliseconds(timeout_ms), [responder]{return responder->received_response != NULL;});
if (responder->received_response) {
return responder->received_response;
struct response *resp = responder->received_response;
responder->received_response = NULL;
return resp;
} else {
return new_response(RESPONSE_ACCEPTED, NULL);
}