Skip to content
Snippets Groups Projects
Commit 012b29f1 authored by Manuela Kuhn's avatar Manuela Kuhn
Browse files

konsistent naming of receiverLiveViewer

parent bc1d3c60
No related branches found
No related tags found
No related merge requests found
......@@ -2,7 +2,6 @@
targetDir = /space/projects/live-viewer/data/zmq_target
# Local ip to connect dataStream to
#dataStreamIp = 127.0.0.1
dataStreamIp = 0.0.0.0
# TCP port of data pipe"
dataStreamPort = 50100
......@@ -15,7 +14,7 @@ liveViewerPort = 50021
coordinatorExchangePort = 50020
# IP of dataStream-socket to send signals back to the sender
senderComIp = lsdma-lab04.desy.de
senderComIp = zitpcx19282.desy.de
# Port number of dataStream-socket to send signals back to the sender
senderComPort = 50000
# Time to wait for the sender to give a confirmation of the signal
......
No preview for this file type
......@@ -9,7 +9,7 @@ import json
import ConfigParser
import shared.helperScript as helperScript
from receiver_LiveViewer.FileReceiver import FileReceiver
from receiverLiveViewer.FileReceiver import FileReceiver
BASE_PATH = os.path.dirname ( os.path.dirname ( os.path.realpath ( __file__ ) ) )
CONFIG_PATH = BASE_PATH + os.sep + "conf"
......
......@@ -51,17 +51,25 @@ class Coordinator:
self.zmqContext = context or zmq.Context()
# create sockets
# create socket to exchange informations with FileReceiver
self.receiverExchangeSocket = self.zmqContext.socket(zmq.PAIR)
connectionStr = "tcp://" + self.receiverExchangeIp + ":%s" % self.receiverExchangePort
self.receiverExchangeSocket.bind(connectionStr)
self.log.debug("receiverExchangeSocket started (bind) for '" + connectionStr + "'")
try:
self.receiverExchangeSocket.bind(connectionStr)
self.log.debug("receiverExchangeSocket started (bind) for '" + connectionStr + "'")
except Exception as e:
self.log.error("Failed to start receiverExchangeSocket (bind): '" + connectionStr + "'")
self.log.debug("Error was:" + str(e))
# create socket for live viewer
self.liveViewerSocket = self.zmqContext.socket(zmq.REP)
connectionStr = "tcp://" + self.liveViewerIp + ":%s" % self.liveViewerPort
self.liveViewerSocket.bind(connectionStr)
self.log.debug("zmqLiveViewerSocket started (bind) for '" + connectionStr + "'")
try:
self.liveViewerSocket.bind(connectionStr)
self.log.debug("liveViewerSocket started (bind) for '" + connectionStr + "'")
except Exception as e:
self.log.error("Failed to start liveViewerSocket (bind): '" + connectionStr + "'")
self.log.debug("Error was:" + str(e))
self.poller = zmq.Poller()
self.poller.register(self.receiverExchangeSocket, zmq.POLLIN)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment