| @@ -51,7 +51,7 class PlotData(Operation, Process): | |||||
| 51 | self.xrange = kwargs.get('xrange', 24) |
|
51 | self.xrange = kwargs.get('xrange', 24) | |
| 52 | self.ymin = kwargs.get('ymin', None) |
|
52 | self.ymin = kwargs.get('ymin', None) | |
| 53 | self.ymax = kwargs.get('ymax', None) |
|
53 | self.ymax = kwargs.get('ymax', None) | |
| 54 |
self.throttle_value = |
|
54 | self.throttle_value = 5 | |
| 55 | def fill_gaps(self, x_buffer, y_buffer, z_buffer): |
|
55 | def fill_gaps(self, x_buffer, y_buffer, z_buffer): | |
| 56 |
|
56 | |||
| 57 | if x_buffer.shape[0] < 2: |
|
57 | if x_buffer.shape[0] < 2: | |
| @@ -354,6 +354,8 class ReceiverData(ProcessingUnit, Process): | |||||
| 354 | if plottype == 'phase': |
|
354 | if plottype == 'phase': | |
| 355 | self.data[plottype][t] = self.dataOut.getCoherence(phase=True) |
|
355 | self.data[plottype][t] = self.dataOut.getCoherence(phase=True) | |
| 356 | if self.realtime: |
|
356 | if self.realtime: | |
|
|
357 | self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist()) | |||
|
|
358 | self.data_web['timestamp'] = t | |||
| 357 | if plottype == 'spc': |
|
359 | if plottype == 'spc': | |
| 358 | self.data_web[plottype] = roundFloats(decimate(self.data[plottype]).tolist()) |
|
360 | self.data_web[plottype] = roundFloats(decimate(self.data[plottype]).tolist()) | |
| 359 | else: |
|
361 | else: | |
| @@ -372,7 +374,8 class ReceiverData(ProcessingUnit, Process): | |||||
| 372 | self.sender = self.context.socket(zmq.PUB) |
|
374 | self.sender = self.context.socket(zmq.PUB) | |
| 373 | if self.realtime: |
|
375 | if self.realtime: | |
| 374 | self.sender_web = self.context.socket(zmq.PUB) |
|
376 | self.sender_web = self.context.socket(zmq.PUB) | |
| 375 |
self.sender_web. |
|
377 | self.sender_web.connect(self.plot_address) | |
|
|
378 | time.sleep(1) | |||
| 376 | self.sender.bind("ipc:///tmp/zmq.plots") |
|
379 | self.sender.bind("ipc:///tmp/zmq.plots") | |
| 377 |
|
380 | |||
| 378 | t = Thread(target=self.event_monitor, args=(monitor,)) |
|
381 | t = Thread(target=self.event_monitor, args=(monitor,)) | |
General Comments 0
You need to be logged in to leave comments.
Login now