From 16ec75e22901e84084851d7c42a9c351c1595945 2017-05-03 18:38:17 From: José Chávez Date: 2017-05-03 18:38:17 Subject: [PATCH] merged --- diff --git a/schainpy/model/graphics/jroplot_data.py b/schainpy/model/graphics/jroplot_data.py index 9d592e4..8a017cb 100644 --- a/schainpy/model/graphics/jroplot_data.py +++ b/schainpy/model/graphics/jroplot_data.py @@ -51,7 +51,7 @@ class PlotData(Operation, Process): self.xrange = kwargs.get('xrange', 24) self.ymin = kwargs.get('ymin', None) self.ymax = kwargs.get('ymax', None) - self.throttle_value = 1 + self.throttle_value = 5 def fill_gaps(self, x_buffer, y_buffer, z_buffer): if x_buffer.shape[0] < 2: diff --git a/schainpy/model/utils/jroutils_publish.py b/schainpy/model/utils/jroutils_publish.py index f999865..0fcbca4 100644 --- a/schainpy/model/utils/jroutils_publish.py +++ b/schainpy/model/utils/jroutils_publish.py @@ -354,6 +354,8 @@ class ReceiverData(ProcessingUnit, Process): if plottype == 'phase': self.data[plottype][t] = self.dataOut.getCoherence(phase=True) if self.realtime: + self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist()) + self.data_web['timestamp'] = t if plottype == 'spc': self.data_web[plottype] = roundFloats(decimate(self.data[plottype]).tolist()) else: @@ -372,7 +374,8 @@ class ReceiverData(ProcessingUnit, Process): self.sender = self.context.socket(zmq.PUB) if self.realtime: self.sender_web = self.context.socket(zmq.PUB) - self.sender_web.bind(self.plot_address) + self.sender_web.connect(self.plot_address) + time.sleep(1) self.sender.bind("ipc:///tmp/zmq.plots") t = Thread(target=self.event_monitor, args=(monitor,))