sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-23 11:50:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

Added copy constructor to ZmqReceiver

Browse Source
This commit is contained in:
babic_a
2019-04-02 12:12:17 +02:00
parent 724ac2101e
commit e33d78f683
2 changed files with 24 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/ZmqReceiver.cpp
+21
View File
@@ -62,6 +62,27 @@ ZmqReceiver::ZmqReceiver(const std::string& connect_address, const int n_io_thre
message_data = zmq::message_t(config::zmq_buffer_size_data);
}
ZmqReceiver::ZmqReceiver(const ZmqReceiver& other) :
connect_address(other.connect_address), n_io_threads(other.n_io_threads),
receive_timeout(other.receive_timeout), receiver(NULL), header_values_type(other.header_values_type)
{
#ifdef DEBUG_OUTPUT
using namespace date;
cout << "[" << std::chrono::system_clock::now() << "]";
cout << "[ZmqReceiver::ZmqReceiver] Creating ZMQ receiver with";
cout << " connect_address " << connect_address;
cout << " n_io_threads " << n_io_threads;
cout << " receive_timeout " << receive_timeout;
cout << endl;
#endif
message_header = zmq::message_t(config::zmq_buffer_size_header);
message_data = zmq::message_t(config::zmq_buffer_size_data);
}
void ZmqReceiver::connect()
{
#ifdef DEBUG_OUTPUT
lib/src/ZmqReceiver.hpp
+3 -1
View File
@@ -51,6 +51,8 @@ class ZmqReceiver
ZmqReceiver(const std::string& connect_address, const int n_io_threads, const int receive_timeout,
std::shared_ptr<std::unordered_map<std::string, HeaderDataType>> header_values_type=NULL);
ZmqReceiver(const ZmqReceiver& other);
virtual ~ZmqReceiver(){};
void connect();
@@ -63,4 +65,4 @@ class ZmqReceiver
};
#endif
#endif