Merge pull request #272 from odin-detector/217_fr_recvbuf

Restore set/get of SO_RCVBUF socket option in frame receiver UDP RX thread
odin-detector · Mar 19, 2021 · 7a03f48 · 7a03f48
2 parents a036e6f + a6cb3c6
commit 7a03f48
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/frameReceiver/src/FrameReceiverUDPRxThread.cpp b/frameReceiver/src/FrameReceiverUDPRxThread.cpp
@@ -49,7 +49,7 @@ void FrameReceiverUDPRxThread::run_specific_service(void)
     }
 
     // Set the socket receive buffer size
-    if (setsockopt(recv_socket, SOL_SOCKET, SO_REUSEADDR, &config_.rx_recv_buffer_size_, sizeof(config_.rx_recv_buffer_size_)) < 0)
+    if (setsockopt(recv_socket, SOL_SOCKET, SO_RCVBUF, &config_.rx_recv_buffer_size_, sizeof(config_.rx_recv_buffer_size_)) < 0)
     {
       std::stringstream ss;
       ss << "RX channel failed to set receive socket buffer size for port " << rx_port << " : " << strerror(errno);
@@ -60,8 +60,8 @@ void FrameReceiverUDPRxThread::run_specific_service(void)
     // Read it back and display
     int buffer_size;
     socklen_t len = sizeof(buffer_size);
-    getsockopt(recv_socket, SOL_SOCKET, SO_REUSEADDR, &buffer_size, &len);
-    LOG4CXX_DEBUG_LEVEL(1, logger_, "RX thread receive buffer size for port " << rx_port << " is " << buffer_size);
+    getsockopt(recv_socket, SOL_SOCKET, SO_RCVBUF, &buffer_size, &len);
+    LOG4CXX_DEBUG_LEVEL(1, logger_, "RX thread receive buffer size for port " << rx_port << " is " << buffer_size / 2);
 
     // Bind the socket to the specified port
     struct sockaddr_in recv_addr;