From d00df32e49af390adf863198b9e2a3154a8f7f84 Mon Sep 17 00:00:00 2001 From: Dhanya Maliakal Date: Tue, 21 Nov 2017 13:39:49 +0100 Subject: [PATCH] changing zmq rxr port should restart data streaming --- .../include/UDPStandardImplementation.h | 6 ++++++ .../src/UDPStandardImplementation.cpp | 13 ++++++++++++- 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/slsReceiverSoftware/include/UDPStandardImplementation.h b/slsReceiverSoftware/include/UDPStandardImplementation.h index 43b4ff5e6..791e6ce47 100644 --- a/slsReceiverSoftware/include/UDPStandardImplementation.h +++ b/slsReceiverSoftware/include/UDPStandardImplementation.h @@ -170,6 +170,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 6ec1144db..b8599b645 100644 --- a/slsReceiverSoftware/src/UDPStandardImplementation.cpp +++ b/slsReceiverSoftware/src/UDPStandardImplementation.cpp @@ -196,7 +196,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; @@ -571,6 +571,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