| @@ -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: | |
| @@ -374,7 +374,8 class ReceiverData(ProcessingUnit, Process): | |||||
| 374 | self.sender = self.context.socket(zmq.PUB) |
|
374 | self.sender = self.context.socket(zmq.PUB) | |
| 375 | if self.realtime: |
|
375 | if self.realtime: | |
| 376 | self.sender_web = self.context.socket(zmq.PUB) |
|
376 | self.sender_web = self.context.socket(zmq.PUB) | |
| 377 |
self.sender_web. |
|
377 | self.sender_web.connect(self.plot_address) | |
|
|
378 | time.sleep(1) | |||
| 378 | self.sender.bind("ipc:///tmp/zmq.plots") |
|
379 | self.sender.bind("ipc:///tmp/zmq.plots") | |
| 379 |
|
380 | |||
| 380 | 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