zmq buffering when acquire form command line, stopping sockets when command line acquire or receiver start, restarting sockets at change of port numbers and a refresh button for the same

slsDetectorGui/forms/form_tab_advanced.ui

@@ -1264,7 +1264,7 @@ An extension given by the modules serial number will be attached.
           </sizepolicy>
          </property>
          <property name="text">
-          <string>ZMQ Port TX:</string>
+          <string>ZMQ Port:</string>
          </property>
         </widget>
        </item>
@@ -1314,6 +1314,26 @@ An extension given by the modules serial number will be attached.
        </item>
       </layout>
      </widget>
+     <widget class="QPushButton" name="btnRestartStreaming">
+      <property name="geometry">
+       <rect>
+        <x>23</x>
+        <y>142</y>
+        <width>291</width>
+        <height>25</height>
+       </rect>
+      </property>
+      <property name="toolTip">
+       <string>Switching off and on the receiver data streaming from command line requires client sockets to be restarted as well.</string>
+      </property>
+      <property name="text">
+       <string>Restart Streaming (Receiver-&gt;GUI)</string>
+      </property>
+      <property name="icon">
+       <iconset resource="../include/icons.qrc">
+        <normaloff>:/icons/images/refresh.png</normaloff>:/icons/images/refresh.png</iconset>
+      </property>
+     </widget>
     </widget>
     <widget class="QWidget" name="gridLayoutWidget_7">
      <property name="geometry">
@@ -1625,7 +1645,7 @@ An extension given by the modules serial number will be attached.
          </sizepolicy>
         </property>
         <property name="text">
-         <string>ZMQ Port RX:</string>
+         <string>ZMQ Port (GUI):</string>
         </property>
        </widget>
       </item>

slsDetectorGui/include/qTabAdvanced.h

@@ -162,6 +162,10 @@ private slots:
 	 */
 	void SetReceiver();
 
+	/** Restart data streaming in receiver and gui
+	 */
+	void RestartStreaming();
+
 	/** Add ROI Input if the value changed in the last slot
 	 */
 	void AddROIInputSlot(){AddROIInput(1);};

slsDetectorGui/src/qDrawPlot.cpp

@@ -741,11 +741,20 @@ void* qDrawPlot::DataStartAcquireThread(void *this_pointer){
 	if(((qDrawPlot*)this_pointer)->myDet->setReceiverOnline() == slsDetectorDefs::ONLINE_FLAG) {
 
 		// if receiver data up streaming not on, switch it on
-		if (((qDrawPlot*)this_pointer)->myDet->enableDataStreamingFromReceiver() != 1)
+		if (((qDrawPlot*)this_pointer)->myDet->enableDataStreamingFromReceiver() != 1) {cprintf(GREEN,"receiver not on\n");
+			// switch on receiver
 			if (((qDrawPlot*)this_pointer)->myDet->enableDataStreamingFromReceiver(1) != 1) {
 				qDefs::checkErrorMessage(((qDrawPlot*)this_pointer)->myDet,"qDrawPlot::DataStartAcquireThread");
 				return this_pointer;
 			}
+			// switch off client
+			((qDrawPlot*)this_pointer)->myDet->enableDataStreamingToClient(0);
+			// switch on client
+			if (((qDrawPlot*)this_pointer)->myDet->enableDataStreamingToClient(1) != 1) {
+				qDefs::checkErrorMessage(((qDrawPlot*)this_pointer)->myDet,"qDrawPlot::DataStartAcquireThread");
+				return this_pointer;
+			}
+		}
 	}
 
 	((qDrawPlot*)this_pointer)->myDet->acquire(1);

slsDetectorGui/src/qTabAdvanced.cpp

@@ -79,6 +79,7 @@ void qTabAdvanced::SetupWidgetWindow(){
 		isAngular = true;
 		spinZmqPort->setEnabled(false);
 		spinZmqPort2->setEnabled(false);
+		btnRestartStreaming->setEnabled(false);
 		break;
 	case slsDetectorDefs::EIGER:
 		isEnergy = true;
@@ -280,6 +281,7 @@ void qTabAdvanced::Initialization(){
 		connect(dispUDPMAC,			SIGNAL(editingFinished()),	this, SLOT(SetNetworkParameters()));
 
 		connect(btnRxr,				SIGNAL(clicked()),			this, SLOT(SetReceiver()));
+		connect(btnRestartStreaming,SIGNAL(clicked()),			this, SLOT(RestartStreaming()));
 
 	}
 
@@ -729,12 +731,17 @@ void qTabAdvanced::SetRxrUDPPort(int port){
 
 void qTabAdvanced::SetCltZmqPort(int port){
 #ifdef VERBOSE
-	cout << "Setting Receiver UDP Port:" << port << endl;
+	cout << "Setting Client UDP Port:" << port << endl;
 #endif
 	 ostringstream ss; ss << port; string sport = ss.str();
 
 	disconnect(spinZmqPort,		SIGNAL(valueChanged(int)),	this,	SLOT(SetCltZmqPort(int)));
 	spinZmqPort->setValue(atoi(det->setClientStreamingPort(sport).c_str()));
+	myDet->enableDataStreamingFromReceiver(false);
+	myDet->enableDataStreamingToClient(false);
+
+	myDet->enableDataStreamingFromReceiver(true);
+	myDet->enableDataStreamingToClient(true);
 	qDefs::checkErrorMessage(det,"qTabAdvanced::SetCltZmqPort");
 	connect(spinZmqPort,		SIGNAL(valueChanged(int)),	this,	SLOT(SetCltZmqPort(int)));
 }
@@ -751,6 +758,11 @@ void qTabAdvanced::SetRxrZmqPort(int port){
 
 	disconnect(spinZmqPort2,		SIGNAL(valueChanged(int)),	this,	SLOT(SetRxrZmqPort(int)));
 	spinZmqPort2->setValue(atoi(det->setReceiverStreamingPort(sport).c_str()));
+	myDet->enableDataStreamingFromReceiver(false);
+	myDet->enableDataStreamingToClient(false);
+
+	myDet->enableDataStreamingFromReceiver(true);
+	myDet->enableDataStreamingToClient(true);
 	qDefs::checkErrorMessage(det,"qTabAdvanced::SetRxrZmqPort");
 	connect(spinZmqPort2,		SIGNAL(valueChanged(int)),	this,	SLOT(SetRxrZmqPort(int)));
 }
@@ -854,6 +866,23 @@ void qTabAdvanced::SetReceiver(){
 
 
 
+//-------------------------------------------------------------------------------------------------------------------------------------------------
+
+
+void qTabAdvanced::RestartStreaming(){
+#ifdef VERBOSE
+	cout << "Restarting Data Streaming in Receiver and Gui" << endl;
+#endif
+	disconnect(btnRestartStreaming,SIGNAL(clicked()),			this, SLOT(RestartStreaming()));
+	myDet->enableDataStreamingFromReceiver(false);
+	myDet->enableDataStreamingToClient(false);
+
+	myDet->enableDataStreamingFromReceiver(true);
+	myDet->enableDataStreamingToClient(true);
+	connect(btnRestartStreaming,SIGNAL(clicked()),			this, SLOT(RestartStreaming()));
+}
+
+
 //-------------------------------------------------------------------------------------------------------------------------------------------------