sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-10 03:12:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add debug output to start and stop writing

Browse Source
This commit is contained in:
babic_a
2020-04-01 16:03:02 +02:00
parent 5d5fde82f8
commit 252482ac71
1 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/ZmqRecvModule.cpp
+19 -3
View File
@@ -70,11 +70,27 @@ void ZmqRecvModule::stop_recv()
void ZmqRecvModule::start_writing()
{
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ZmqRecvModule::start_writing]";
cout << " Enable writing." << endl;
#endif
is_writing_ = true;
}
void ZmqRecvModule::stop_writing()
{
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ZmqRecvModule::stop_writing]";
cout << " Enable writing." << endl;
#endif
is_writing_ = false;
}
@@ -105,7 +121,7 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ProcessManager::receive_zmq]";
cout << "[ZmqRecvModule::receive_thread]";
cout << " Processing FrameMetadata with frame_index ";
cout << frame_metadata->frame_index;
cout << " and frame_shape [" << frame_metadata->frame_shape[0];
@@ -140,7 +156,7 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ProcessManager::receive_zmq]";
cout << "[ZmqRecvModule::receive_thread]";
cout << " Compressed image from ";
cout << frame_metadata->frame_bytes_size << " bytes to ";
cout << compressed_size << " bytes." << endl;
@@ -155,7 +171,7 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ProcessManager::receive_zmq]";
cout << "[ZmqRecvModule::receive_thread]";
cout << " Receiver thread stopped." << endl;
#endif
}