From e6db70354ce16d1498a59ad2e7a72660d86d0eda Mon Sep 17 00:00:00 2001 From: Dhanya Maliakal Date: Thu, 6 Oct 2016 15:50:11 +0200 Subject: [PATCH] thread starting if rxr closed and others --- .../src/UDPStandardImplementation.cpp | 18 +++++++++++------- 1 file changed, 11 insertions(+), 7 deletions(-) diff --git a/slsReceiverSoftware/src/UDPStandardImplementation.cpp b/slsReceiverSoftware/src/UDPStandardImplementation.cpp index 317eadd25..e4113089f 100644 --- a/slsReceiverSoftware/src/UDPStandardImplementation.cpp +++ b/slsReceiverSoftware/src/UDPStandardImplementation.cpp @@ -562,17 +562,21 @@ int UDPStandardImplementation::setFrameToGuiFrequency(const uint32_t freq){ uint32_t UDPStandardImplementation::setDataStreamEnable(const uint32_t enable){ FILE_LOG(logDEBUG) << __AT__ << " called"; + int oldvalue = dataStreamEnable; dataStreamEnable = enable; FILE_LOG(logINFO) << "Data Send to Gui: " << dataStreamEnable; - //data sockets have to be created again as the client ones are - if(zmqThreadStarted) - createDataCallbackThreads(true); - if(dataStreamEnable){ - numberofDataCallbackThreads = MAX_NUMBER_OF_LISTENING_THREADS; - if(createDataCallbackThreads() == FAIL){ - cprintf(BG_RED,"Error: Could not create data callback threads\n"); + if(oldvalue!=dataStreamEnable){ + //data sockets have to be created again as the client ones are + if(zmqThreadStarted) + createDataCallbackThreads(true); + + if(dataStreamEnable){ + numberofDataCallbackThreads = MAX_NUMBER_OF_LISTENING_THREADS; + if(createDataCallbackThreads() == FAIL){ + cprintf(BG_RED,"Error: Could not create data callback threads\n"); + } } }