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

Yield instead of sleep in case of no msg

Browse Source
This commit is contained in:
babic_a
2020-05-04 18:06:13 +02:00
parent 16847f48b8
commit 11b5bde2dc
2 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-buffer/src/UdpReceiver.cpp
+11 -11
View File
@@ -51,16 +51,16 @@ void UdpReceiver::bind(const uint16_t port, const size_t usec_timeout)
throw runtime_error("Cannot bind socket.");
}
struct timeval udp_socket_timeout;
udp_socket_timeout.tv_sec = 0;
udp_socket_timeout.tv_usec = usec_timeout;
setsockopt(
socket_fd_,
SOL_SOCKET,
SO_RCVTIMEO,
(const char*)&udp_socket_timeout,
sizeof(struct timeval));
// struct timeval udp_socket_timeout;
// udp_socket_timeout.tv_sec = 0;
// udp_socket_timeout.tv_usec = usec_timeout;
//
// setsockopt(
// socket_fd_,
// SOL_SOCKET,
// SO_RCVTIMEO,
// (const char*)&udp_socket_timeout,
// sizeof(struct timeval));
}
int UdpReceiver::receive_many(mmsghdr* msgs, const size_t n_msgs)
@@ -70,7 +70,7 @@ int UdpReceiver::receive_many(mmsghdr* msgs, const size_t n_msgs)
bool UdpReceiver::receive(void* buffer, size_t buffer_n_bytes)
{
auto data_len = recv(socket_fd_, buffer, buffer_n_bytes, 0);
auto data_len = recv(socket_fd_, buffer, buffer_n_bytes, MSG_DONTWAIT);
if (data_len < 0) {
return false;