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