| @@ -335,7 +335,6 class ReceiverData(ProcessingUnit, Process): | |||||
| 335 | self.sender.send_pyobj(data) |
|
335 | self.sender.send_pyobj(data) | |
| 336 |
|
336 | |||
| 337 | def update(self): |
|
337 | def update(self): | |
| 338 |
|
||||
| 339 | t = self.dataOut.ltctime |
|
338 | t = self.dataOut.ltctime | |
| 340 | self.data['times'].append(t) |
|
339 | self.data['times'].append(t) | |
| 341 | self.data['dataOut'] = self.dataOut |
|
340 | self.data['dataOut'] = self.dataOut | |
| @@ -356,7 +355,7 class ReceiverData(ProcessingUnit, Process): | |||||
| 356 | self.data[plottype][t] = self.dataOut.getCoherence(phase=True) |
|
355 | self.data[plottype][t] = self.dataOut.getCoherence(phase=True) | |
| 357 | if self.realtime: |
|
356 | if self.realtime: | |
| 358 | self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist()) |
|
357 | self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist()) | |
| 359 | self.data_web['time'] = t |
|
358 | self.data_web['timestamp'] = t | |
| 360 | self.data_web['interval'] = self.dataOut.getTimeInterval() |
|
359 | self.data_web['interval'] = self.dataOut.getTimeInterval() | |
| 361 | self.data_web['type'] = plottype |
|
360 | self.data_web['type'] = plottype | |
| 362 | def run(self): |
|
361 | def run(self): | |
| @@ -419,4 +418,3 class ReceiverData(ProcessingUnit, Process): | |||||
| 419 | sender_web_config.send_string(json.dumps(kwargs)) |
|
418 | sender_web_config.send_string(json.dumps(kwargs)) | |
| 420 | print kwargs |
|
419 | print kwargs | |
| 421 | self.isWebConfig = True |
|
420 | self.isWebConfig = True | |
| 422 |
|
||||
| @@ -61,6 +61,7 def fiber(cursor, skip, q, dt): | |||||
| 61 | opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other') |
|
61 | opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other') | |
| 62 | opObj12.addParameter(name='zeromq', value=1, format='int') |
|
62 | opObj12.addParameter(name='zeromq', value=1, format='int') | |
| 63 |
|
63 | |||
|
|
64 | ||||
| 64 | # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') |
|
65 | # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') | |
| 65 | # opObj13.addParameter(name='zeromq', value=1, format='int') |
|
66 | # opObj13.addParameter(name='zeromq', value=1, format='int') | |
| 66 | # opObj13.addParameter(name='server', value="juanca", format='str') |
|
67 | # opObj13.addParameter(name='server', value="juanca", format='str') | |
General Comments 0
You need to be logged in to leave comments.
Login now