updated slsdetector users for zmqport set up

This commit is contained in:
Dhanya Maliakal 2017-11-28 09:24:40 +01:00
parent c0a114345b
commit d1eab6f750

View File

@ -98,8 +98,13 @@ class slsDetectorUtils : public slsDetectorActions, public postProcessing {
* @returns receiver streaming out ZMQ port
*/
int setReceiverDataStreamingOutPort(int i) { \
if (i >= 0) { ostringstream ss; ss << i; string s = ss.str(); \
setNetworkParameter(RECEIVER_STREAMING_PORT, s);} \
if (i >= 0) { \
ostringstream ss; ss << i; string s = ss.str(); \
int prev_streaming = enableDataStreamingFromReceiver(); \
setNetworkParameter(RECEIVER_STREAMING_PORT, s); \
if (prev_streaming) { \
enableDataStreamingFromReceiver(0); \
enableDataStreamingFromReceiver(1);}} \
return atoi(getNetworkParameter(RECEIVER_STREAMING_PORT).c_str());}; \
/**
@ -109,8 +114,13 @@ class slsDetectorUtils : public slsDetectorActions, public postProcessing {
* @returns client streaming in ZMQ port
*/
int setClientDataStreamingInPort(int i){ \
if (i >= 0) { ostringstream ss; ss << i; string s = ss.str(); \
setNetworkParameter(CLIENT_STREAMING_PORT, s);} \
if (i >= 0) { \
ostringstream ss; ss << i; string s = ss.str(); \
int prev_streaming = enableDataStreamingToClient()(); \
setNetworkParameter(CLIENT_STREAMING_PORT, s); \
if (prev_streaming) { \
enableDataStreamingToClient(0); \
enableDataStreamingToClient(1);}} \
return atoi(getNetworkParameter(CLIENT_STREAMING_PORT).c_str());}; \