diff --git a/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py b/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py index a08018d0732ec724c3e3457c6faf2bdb99c9c536..7c3170e7a08633199af264756443a26b82a56596 100644 --- a/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py +++ b/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py @@ -366,7 +366,7 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): # xpcs_settings=self.xpcs_settings) # print("time_to_handle_list 0", time.perf_counter() - time_to_handle_list_0) - roi = self.xpcs_settings['qbin'] +''' roi = self.xpcs_settings['qbin'] self.runningstats_processing_memory, runningstats_output_dict = runningstats.process_detector_data_list( detector_data_list, roi, @@ -377,7 +377,7 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): if numPixelPerGainStage is not None: runningstats_output_dict['numPixelPerGainStage'] = numPixelPerGainStage - +''' # time_to_handle_list_1 = time.perf_counter() @@ -441,11 +441,12 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): output_hash = Hash() - if runningstats_output_dict is not None: + ''' + if runningstats_output_dict is not None: output_hash = self.make_dict_to_hash(runningstats_output_dict) #xpcs_output_hash = Hash("output_dict", xpcs_output_dict) ## XPCS ANALYSIS END - + ''' ####### # karabo output my_timestamp = Timestamp(Epochstamp(), Trainstamp(train_id)) @@ -457,7 +458,7 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): self.output.update(safeNDArray=True) # print("time_to_handle_list _5", time.perf_counter() - time_to_handle_list_5) - + ''' if runningstats_output_dict is not None: if 'numBins' in runningstats_output_dict and 'numBunches' in runningstats_output_dict: self.print_data_processing_update(runningstats_output_dict['numBins'], runningstats_output_dict['numBunches'], train_id) @@ -465,7 +466,7 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): self.print_data_processing_update(-1, -1, train_id) else: self.print_data_processing_update(-1, -1, train_id) - + ''' def on_matched_data(self, train_id, sources):