diff --git a/slsReceiverSoftware/include/UDPStandardImplementation.h b/slsReceiverSoftware/include/UDPStandardImplementation.h index ebf3cd115..cfa001307 100644 --- a/slsReceiverSoftware/include/UDPStandardImplementation.h +++ b/slsReceiverSoftware/include/UDPStandardImplementation.h @@ -184,6 +184,12 @@ class UDPStandardImplementation: private virtual slsReceiverDefs, public UDPBase */ void closeFiles(); + /** + * Set streaming port and restart sockets if streaming was enabled + * @param i streaming port + */ + void setStreamingPort(const uint32_t i); + private: diff --git a/slsReceiverSoftware/src/UDPStandardImplementation.cpp b/slsReceiverSoftware/src/UDPStandardImplementation.cpp index 52f9f2654..70b90dae4 100644 --- a/slsReceiverSoftware/src/UDPStandardImplementation.cpp +++ b/slsReceiverSoftware/src/UDPStandardImplementation.cpp @@ -206,7 +206,7 @@ int UDPStandardImplementation::setFrameToGuiFrequency(const uint32_t freq) { } -int UDPStandardImplementation::setDataStreamEnable(const bool enable) {\ +int UDPStandardImplementation::setDataStreamEnable(const bool enable) { if (dataStreamEnable != enable) { dataStreamEnable = enable; @@ -604,6 +604,17 @@ void UDPStandardImplementation::closeFiles() { } +void UDPStandardImplementation::setStreamingPort(const uint32_t i) { + streamingPort = i; + + FILE_LOG(logINFO) << "Streaming Port: " << streamingPort; + if (dataStreamEnable) { + setDataStreamEnable(false); + setDataStreamEnable(true); + } +} + + void UDPStandardImplementation::SetLocalNetworkParameters() { //to increase socket receiver buffer size and max length of input queue by changing kernel settings