@@ -229,7 +229,7 @@ def __init__(self, options):
229
229
230
230
# Watchdog variables
231
231
self .fem_tx_timeout = 5000
232
- self .daq_rx_timeout = 3
232
+ self .daq_rx_timeout = 4
233
233
234
234
# Store initialisation time
235
235
self .init_time = time .time ()
@@ -354,10 +354,10 @@ def check_daq_watchdog(self):
354
354
self .shutdown_processing ()
355
355
logging .warning ("DAQ processing timed out; Saw %s expected %s frames" %
356
356
(self .daq .frames_processed , self .daq .number_frames ))
357
- # self.fem._set_status_error("Processing timed out: {0:.2f} seconds \
358
- # (exceeded {1:.2f}); Expected {2} got {3} frames\
359
- # ".format(delta_time, self.daq_rx_timeout,
360
- # self.daq.number_frames, self.daq.frames_processed))
357
+ self .fem ._set_status_error ("Processing timed out: {0:.2f} seconds \
358
+ (exceeded {1:.2f}); Expected {2} got {3} frames\
359
+ " .format (delta_time , self .daq_rx_timeout ,
360
+ self .daq .number_frames , self .daq .frames_processed ))
361
361
self .fem ._set_status_message ("Processed frames, some packet(s) loss" )
362
362
363
363
def shutdown_processing (self ):
0 commit comments