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

Add debug output to UdpReceiver

Browse Source
This commit is contained in:
babic_a
2020-04-15 16:46:42 +02:00
parent 3b30f7e544
commit c9a50b9e8f
1 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/receiver/UdpReceiver.cpp
+17 -1
View File
@@ -26,6 +26,15 @@ void UdpReceiver::bind(const uint16_t port, const size_t usec_timeout)
throw runtime_error("Cannot open socket.");
}
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[UdpReceiver::bind]";
cout << " port " << port;
cout << " usec_timeout " << usec_timeout << endl;
#endif
sockaddr_in server_address = {0};
server_address.sin_family = AF_INET;
server_address.sin_addr.s_addr = INADDR_ANY;
@@ -61,7 +70,14 @@ bool UdpReceiver::receive(void* buffer, size_t buffer_n_bytes)
}
if (data_len != buffer_n_bytes) {
cout << "Invalid packet length " << data_len << endl;
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[UdpReceiver::receive]";
cout << " Expected buffer_n_bytes " << buffer_n_bytes;
cout << " but got data_len " << data_len << endl;
#endif
return false;
}