diff options
| author | malosek <malosek@fastmq.com> | 2009-09-29 13:56:19 +0200 |
|---|---|---|
| committer | malosek <malosek@fastmq.com> | 2009-09-29 13:56:19 +0200 |
| commit | 64e68e748607473befbcf2d96590d45dc7bc98db (patch) | |
| tree | b5397a6cbd98c63d6b5b8ffbcf4397327e227b55 /src/pgm_receiver.cpp | |
| parent | 39d915ded8ccb612ae1f9aaefcd93f349f4c8f4c (diff) | |
detecting data loss for PGM2 receiver
Diffstat (limited to 'src/pgm_receiver.cpp')
| -rw-r--r-- | src/pgm_receiver.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/pgm_receiver.cpp b/src/pgm_receiver.cpp index 7af6ed5..2ffb9ab 100644 --- a/src/pgm_receiver.cpp +++ b/src/pgm_receiver.cpp @@ -160,8 +160,13 @@ void zmq::pgm_receiver_t::in_event () peer_info_t peer_info = {false, NULL}; it = peers.insert (std::make_pair (*tsi, peer_info)).first; +#ifdef ZMQ_HAVE_OPENPGM1 zmq_log (1, "New peer TSI: %s, %s(%i).\n", pgm_print_tsi (tsi), __FILE__, __LINE__); +#elif ZMQ_HAVE_OPENPGM2 + zmq_log (1, "New peer TSI: %s, %s(%i).\n", pgm_tsi_print (tsi), + __FILE__, __LINE__); +#endif } // There is not beginning of the message in current APDU and we @@ -187,8 +192,13 @@ void zmq::pgm_receiver_t::in_event () it->second.decoder = new zmq_decoder_t; it->second.decoder->set_inout (inout); +#ifdef ZMQ_HAVE_OPENPGM1 zmq_log (1, "Peer %s joined into the stream, %s(%i)\n", pgm_print_tsi (tsi), __FILE__, __LINE__); +#elif ZMQ_HAVE_OPENPGM2 + zmq_log (1, "Peer %s joined into the stream, %s(%i)\n", + pgm_tsi_print (tsi), __FILE__, __LINE__); +#endif } if (nbytes > 0) { |