generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-01-19 08:46:44 +01:00
Code Issues Projects Releases Wiki Activity

minor tweaks in pgm code

Browse Source
This commit is contained in:
malosek 2009-11-30 16:45:18 +01:00
parent 84585a9561
commit 9ccf2b42cf
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/pgm_sender.cpp
View File

@ -130,8 +130,12 @@ void zmq::pgm_sender_t::revive ()
zmq::pgm_sender_t::~pgm_sender_t () zmq::pgm_sender_t::~pgm_sender_t ()
{ {
zmq_log (4, "pgm_sender_t destructor, %s(%i)\n",
__FILE__, __LINE__);
if (out_buffer) { if (out_buffer) {
pgm_socket.free_buffer (out_buffer); pgm_socket.free_buffer (out_buffer);
out_buffer = NULL;
} }
} }

2
src/pgm_socket.cpp
View File

@ -358,7 +358,7 @@ int zmq::pgm_socket_t::open_transport (void)
// Sender transport. // Sender transport.
} else { } else {
// Set transport->can_recv = FALSE, waiting_pipe wont not be read. // Set transport->can_recv = FALSE, waiting_pipe will not be read.
rc = pgm_transport_set_send_only (g_transport, TRUE); rc = pgm_transport_set_send_only (g_transport, TRUE);
if (rc != pgm_ok) { if (rc != pgm_ok) {
errno = EINVAL; errno = EINVAL;