From c1986e58e2ba62cac6f15c36151e838c29da8d98 Mon Sep 17 00:00:00 2001 From: "dale.wilson" Date: Thu, 17 Jun 2010 15:11:54 +0000 Subject: [PATCH] Thu Jun 17 15:09:43 UTC 2010 Dale Wilson * src/Communication/MulticastReceiver.h: * src/Communication/TCPReceiver.h: Provide direct access to the sockets inside the *Receivers for special purpose needs. Until the encoder work is complete this can be used to send to the TCP counterpary. The multicast method is there only for completeness. --- ChangeLog | 9 +++++++++ src/Communication/MulticastReceiver.h | 7 +++++++ src/Communication/TCPReceiver.h | 6 ++++++ 3 files changed, 22 insertions(+) diff --git a/ChangeLog b/ChangeLog index dcac9bfe..4441e431 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,3 +1,12 @@ +Thu Jun 17 15:09:43 UTC 2010 Dale Wilson + + * src/Communication/MulticastReceiver.h: + * src/Communication/TCPReceiver.h: + Provide direct access to the sockets inside the *Receivers + for special purpose needs. Until the encoder work is complete + this can be used to send to the TCP counterpary. The multicast + method is there only for completeness. + Fri Jun 11 17:37:28 UTC 2010 Dale Wilson * src/Messages/MessageFormatter.h: diff --git a/src/Communication/MulticastReceiver.h b/src/Communication/MulticastReceiver.h index 50209aa5..0e340d32 100644 --- a/src/Communication/MulticastReceiver.h +++ b/src/Communication/MulticastReceiver.h @@ -140,6 +140,13 @@ namespace QuickFAST } } + /// Provide direct access to the internal asio socket. + boost::asio::ip::udp::socket & socket() + { + return socket_; + } + + private: bool fillBuffer(LinkedBuffer * buffer, boost::mutex::scoped_lock& lock) diff --git a/src/Communication/TCPReceiver.h b/src/Communication/TCPReceiver.h index bee000c8..f830a18f 100644 --- a/src/Communication/TCPReceiver.h +++ b/src/Communication/TCPReceiver.h @@ -97,6 +97,12 @@ namespace QuickFAST catch(...){} } + /// Provide direct access to the internal asio socket. + boost::asio::ip::tcp::socket & socket() + { + return socket_; + } + private: bool fillBuffer(LinkedBuffer * buffer, boost::mutex::scoped_lock& lock)