|
@@
-206,7
+206,7
class Plot(Operation):
|
|
206
|
self.localtime = kwargs.pop('localtime', True)
|
|
206
|
self.localtime = kwargs.pop('localtime', True)
|
|
207
|
self.show = kwargs.get('show', True)
|
|
207
|
self.show = kwargs.get('show', True)
|
|
208
|
self.save = kwargs.get('save', False)
|
|
208
|
self.save = kwargs.get('save', False)
|
|
209
|
self.save_period = kwargs.get('save_period', 60)
|
|
209
|
self.save_period = kwargs.get('save_period', 0)
|
|
210
|
self.colormap = kwargs.get('colormap', self.colormap)
|
|
210
|
self.colormap = kwargs.get('colormap', self.colormap)
|
|
211
|
self.colormap_coh = kwargs.get('colormap_coh', 'jet')
|
|
211
|
self.colormap_coh = kwargs.get('colormap_coh', 'jet')
|
|
212
|
self.colormap_phase = kwargs.get('colormap_phase', 'RdBu_r')
|
|
212
|
self.colormap_phase = kwargs.get('colormap_phase', 'RdBu_r')
|
|
@@
-246,7
+246,7
class Plot(Operation):
|
|
246
|
self.save_code = kwargs.get('save_code', self.CODE)
|
|
246
|
self.save_code = kwargs.get('save_code', self.CODE)
|
|
247
|
self.throttle = kwargs.get('throttle', 0)
|
|
247
|
self.throttle = kwargs.get('throttle', 0)
|
|
248
|
self.exp_code = kwargs.get('exp_code', None)
|
|
248
|
self.exp_code = kwargs.get('exp_code', None)
|
|
249
|
self.plot_server = kwargs.get('plot_server', False)
|
|
249
|
self.server = kwargs.get('server', False)
|
|
250
|
self.sender_period = kwargs.get('sender_period', 60)
|
|
250
|
self.sender_period = kwargs.get('sender_period', 60)
|
|
251
|
self.tag = kwargs.get('tag', '')
|
|
251
|
self.tag = kwargs.get('tag', '')
|
|
252
|
self.height_index = kwargs.get('height_index', None)
|
|
252
|
self.height_index = kwargs.get('height_index', None)
|
|
@@
-254,11
+254,11
class Plot(Operation):
|
|
254
|
self.data = PlotterData(
|
|
254
|
self.data = PlotterData(
|
|
255
|
self.CODE, self.throttle, self.exp_code, self.localtime, self.buffering, snr=self.showSNR)
|
|
255
|
self.CODE, self.throttle, self.exp_code, self.localtime, self.buffering, snr=self.showSNR)
|
|
256
|
|
|
256
|
|
|
257
|
if self.plot_server:
|
|
257
|
if self.server:
|
|
258
|
if not self.plot_server.startswith('tcp://'):
|
|
258
|
if not self.server.startswith('tcp://'):
|
|
259
|
self.plot_server = 'tcp://{}'.format(self.plot_server)
|
|
259
|
self.server = 'tcp://{}'.format(self.server)
|
|
260
|
log.success(
|
|
260
|
log.success(
|
|
261
|
'Sending to server: {}'.format(self.plot_server),
|
|
261
|
'Sending to server: {}'.format(self.server),
|
|
262
|
self.name
|
|
262
|
self.name
|
|
263
|
)
|
|
263
|
)
|
|
264
|
|
|
264
|
|
|
@@
-475,14
+475,14
class Plot(Operation):
|
|
475
|
if self.save:
|
|
475
|
if self.save:
|
|
476
|
self.save_figure(n)
|
|
476
|
self.save_figure(n)
|
|
477
|
|
|
477
|
|
|
478
|
if self.plot_server:
|
|
478
|
if self.server:
|
|
479
|
self.send_to_server()
|
|
479
|
self.send_to_server()
|
|
480
|
|
|
480
|
|
|
481
|
def save_figure(self, n):
|
|
481
|
def save_figure(self, n):
|
|
482
|
'''
|
|
482
|
'''
|
|
483
|
'''
|
|
483
|
'''
|
|
484
|
|
|
484
|
|
|
485
|
if (self.data.tm - self.save_time) < self.sender_period:
|
|
485
|
if (self.data.tm - self.save_time) <= self.save_period:
|
|
486
|
return
|
|
486
|
return
|
|
487
|
|
|
487
|
|
|
488
|
self.save_time = self.data.tm
|
|
488
|
self.save_time = self.data.tm
|
|
@@
-575,7
+575,7
class Plot(Operation):
|
|
575
|
self.poll.unregister(self.socket)
|
|
575
|
self.poll.unregister(self.socket)
|
|
576
|
time.sleep(0.1)
|
|
576
|
time.sleep(0.1)
|
|
577
|
self.socket = self.context.socket(zmq.REQ)
|
|
577
|
self.socket = self.context.socket(zmq.REQ)
|
|
578
|
self.socket.connect(self.plot_server)
|
|
578
|
self.socket.connect(self.server)
|
|
579
|
self.poll.register(self.socket, zmq.POLLIN)
|
|
579
|
self.poll.register(self.socket, zmq.POLLIN)
|
|
580
|
break
|
|
580
|
break
|
|
581
|
|
|
581
|
|
|
@@
-614,17
+614,17
class Plot(Operation):
|
|
614
|
|
|
614
|
|
|
615
|
self.data.setup()
|
|
615
|
self.data.setup()
|
|
616
|
self.isConfig = True
|
|
616
|
self.isConfig = True
|
|
617
|
if self.plot_server:
|
|
617
|
if self.server:
|
|
618
|
self.context = zmq.Context()
|
|
618
|
self.context = zmq.Context()
|
|
619
|
self.socket = self.context.socket(zmq.REQ)
|
|
619
|
self.socket = self.context.socket(zmq.REQ)
|
|
620
|
self.socket.connect(self.plot_server)
|
|
620
|
self.socket.connect(self.server)
|
|
621
|
self.poll = zmq.Poller()
|
|
621
|
self.poll = zmq.Poller()
|
|
622
|
self.poll.register(self.socket, zmq.POLLIN)
|
|
622
|
self.poll.register(self.socket, zmq.POLLIN)
|
|
623
|
|
|
623
|
|
|
624
|
tm = getattr(dataOut, self.attr_time)
|
|
624
|
tm = getattr(dataOut, self.attr_time)
|
|
625
|
|
|
625
|
|
|
626
|
if self.data and 'time' in self.xaxis and (tm - self.tmin) >= self.xrange*60*60:
|
|
626
|
if self.data and 'time' in self.xaxis and (tm - self.tmin) >= self.xrange*60*60:
|
|
627
|
self.save_counter = self.save_period
|
|
627
|
self.save_time = tm
|
|
628
|
self.__plot()
|
|
628
|
self.__plot()
|
|
629
|
self.tmin += self.xrange*60*60
|
|
629
|
self.tmin += self.xrange*60*60
|
|
630
|
self.data.setup()
|
|
630
|
self.data.setup()
|
|
@@
-658,7
+658,7
class Plot(Operation):
|
|
658
|
def close(self):
|
|
658
|
def close(self):
|
|
659
|
|
|
659
|
|
|
660
|
if self.data and not self.data.flagNoData:
|
|
660
|
if self.data and not self.data.flagNoData:
|
|
661
|
self.save_counter = self.save_period
|
|
661
|
self.save_time = self.data.tm
|
|
662
|
self.__plot()
|
|
662
|
self.__plot()
|
|
663
|
if self.data and not self.data.flagNoData and self.pause:
|
|
663
|
if self.data and not self.data.flagNoData and self.pause:
|
|
664
|
figpause(10)
|
|
664
|
figpause(10)
|