summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authormalosek <malosek@fastmq.com>2009-11-30 16:45:18 +0100
committermalosek <malosek@fastmq.com>2009-11-30 16:45:18 +0100
commit9ccf2b42cf932b4c29ea20cc9c6e3d5d8e7a62b4 (patch)
treeeef707a82b7323e55ef30c6a02fc846e1838679f /src
parent84585a9561b5e3bd39baa8d49b889455362334ea (diff)
minor tweaks in pgm code
Diffstat (limited to 'src')
-rw-r--r--src/pgm_sender.cpp4
-rw-r--r--src/pgm_socket.cpp2
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;