##// END OF EJS Templates
Merge branch 'schain_mp' of http://jro-dev.igp.gob.pe/rhodecode/schain into schain_mp
jespinoza -
r917:ad02a447a4cb merge
parent child
Show More
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
@@ -0,0 +1,1
1 =: ERROR: cannot open `=' (No such file or directory)
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
1 NO CONTENT: new file 100644
NO CONTENT: new file 100644
@@ -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
@@ -355,11 +354,16 class ReceiverData(ProcessingUnit, Process):
355 if plottype == 'phase':
354 if plottype == 'phase':
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:
357 <<<<<<< HEAD
358 self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist())
359 self.data_web['timestamp'] = t
360 =======
358 if plottype == 'spc':
361 if plottype == 'spc':
359 self.data_web[plottype] = roundFloats(decimate(self.data[plottype]).tolist())
362 self.data_web[plottype] = roundFloats(decimate(self.data[plottype]).tolist())
360 else:
363 else:
361 self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist())
364 self.data_web[plottype] = roundFloats(decimate(self.data[plottype][t]).tolist())
362 self.data_web['time'] = t
365 self.data_web['time'] = t
366 >>>>>>> f65929d2cf32d4dddb2d5fa2a72f3970d4d51812
363 self.data_web['interval'] = self.dataOut.getTimeInterval()
367 self.data_web['interval'] = self.dataOut.getTimeInterval()
364 self.data_web['type'] = plottype
368 self.data_web['type'] = plottype
365
369
@@ -417,7 +421,11 class ReceiverData(ProcessingUnit, Process):
417 else:
421 else:
418 conf_address = self.plot_address + '.config'
422 conf_address = self.plot_address + '.config'
419 sender_web_config.bind(conf_address)
423 sender_web_config.bind(conf_address)
424 <<<<<<< HEAD
425
426 =======
420 time.sleep(1)
427 time.sleep(1)
428 >>>>>>> f65929d2cf32d4dddb2d5fa2a72f3970d4d51812
421 for kwargs in self.operationKwargs.values():
429 for kwargs in self.operationKwargs.values():
422 if 'plot' in kwargs:
430 if 'plot' in kwargs:
423 print '[Sending] Config data to web for {}'.format(kwargs['code'].upper())
431 print '[Sending] Config data to web for {}'.format(kwargs['code'].upper())
@@ -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