generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-24 09:12:30 +02:00
Code Issues Projects Releases Wiki Activity

Fix several missing msg_t::close calls.

Browse Source 
I traced memory leaks found using AddressSanitizer down to these.
This commit is contained in:
Brian Silverman
2015-07-21 19:42:20 -07:00
parent 3f70aca749
commit 18791f2bfb
4 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tests/test_stream_disconnect.cpp
View File

@@ -91,6 +91,8 @@ int main(int, char**)
assert (rc != -1);
assert(zmq_msg_size (&peer_frame) > 0);
assert (has_more (sockets [SERVER]));
rc = zmq_msg_close (&peer_frame);
assert (rc == 0);
// Server: Grab the 2nd frame (actual payload).
zmq_msg_t data_frame;
@@ -99,6 +101,8 @@ int main(int, char**)
rc = zmq_msg_recv (&data_frame, sockets [SERVER], 0);
assert (rc != -1);
assert(zmq_msg_size (&data_frame) == 0);
rc = zmq_msg_close (&data_frame);
assert (rc == 0);
// Client: Grab the 1st frame (peer identity).
rc = zmq_msg_init (&peer_frame);
@@ -107,6 +111,8 @@ int main(int, char**)
assert (rc != -1);
assert(zmq_msg_size (&peer_frame) > 0);
assert (has_more (sockets [CLIENT]));
rc = zmq_msg_close (&peer_frame);
assert (rc == 0);
// Client: Grab the 2nd frame (actual payload).
rc = zmq_msg_init (&data_frame);
@@ -114,6 +120,8 @@ int main(int, char**)
rc = zmq_msg_recv (&data_frame, sockets [CLIENT], 0);
assert (rc != -1);
assert(zmq_msg_size (&data_frame) == 0);
rc = zmq_msg_close (&data_frame);
assert (rc == 0);
// Send initial message.
char blob_data [256];