diff options
| -rw-r--r-- | src/pgm_sender.cpp | 4 | ||||
| -rw-r--r-- | src/pgm_socket.cpp | 2 |
2 files changed, 5 insertions, 1 deletions
diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp index 4fb6d2b..0a958c5 100644 --- a/src/pgm_sender.cpp +++ b/src/pgm_sender.cpp @@ -130,8 +130,12 @@ void zmq::pgm_sender_t::revive () zmq::pgm_sender_t::~pgm_sender_t () { + zmq_log (4, "pgm_sender_t destructor, %s(%i)\n", + __FILE__, __LINE__); + if (out_buffer) { pgm_socket.free_buffer (out_buffer); + out_buffer = NULL; } } diff --git a/src/pgm_socket.cpp b/src/pgm_socket.cpp index e1def56..1f773d8 100644 --- a/src/pgm_socket.cpp +++ b/src/pgm_socket.cpp @@ -358,7 +358,7 @@ int zmq::pgm_socket_t::open_transport (void) // Sender transport. } 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); if (rc != pgm_ok) { errno = EINVAL; |