summaryrefslogtreecommitdiff
path: root/src/pgm_sender.cpp
diff options
context:
space:
mode:
authormalosek <malosek@fastmq.com>2009-09-16 10:11:01 +0200
committermalosek <malosek@fastmq.com>2009-09-16 10:11:01 +0200
commit969522bbf55467b6f6e8113be28451d087060843 (patch)
tree6a78392b4f76bca99b54c1eb7d44550b4dee34c5 /src/pgm_sender.cpp
parent0381a78c0484012e760d61051f325c71136df17e (diff)
added OpenPGM receiver - ZMQ_SUB
Diffstat (limited to 'src/pgm_sender.cpp')
-rw-r--r--src/pgm_sender.cpp7
1 files changed, 1 insertions, 6 deletions
diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp
index 8e7a66b..9b1cef4 100644
--- a/src/pgm_sender.cpp
+++ b/src/pgm_sender.cpp
@@ -90,11 +90,6 @@ void zmq::pgm_sender_t::plug (i_inout *inout_)
set_pollout (handle);
inout = inout_;
-
- zmq_log (1, "plug: downlink_socket_fd %i, uplink_socket_fd %i, %s(%i)",
- downlink_socket_fd, uplink_socket_fd, __FILE__, __LINE__);
-
- std::cout << std::flush;
}
void zmq::pgm_sender_t::unplug ()
@@ -185,7 +180,7 @@ void zmq::pgm_sender_t::out_event ()
size_t zmq::pgm_sender_t::write_one_pkt_with_offset (unsigned char *data_,
size_t size_, uint16_t offset_)
{
- zmq_log (1, "data_size %i, first message offset %i, %s(%i)",
+ zmq_log (1, "data_size %i, first message offset %i, %s(%i)\n",
(int) size_, offset_, __FILE__, __LINE__);
std::cout << std::flush;