Loading scripts/pyivastest/IvasModeRunner.py +10 −7 Original line number Diff line number Diff line Loading @@ -1591,15 +1591,18 @@ class IvasModeRunner(IvasModeCollector.IvasModeCollector): pass with self.dec_queue["condition"]: if not self.dec_queue["dec_entries"]: dec_queue_empty = len(self.dec_queue["dec_entries"]) == 0 all_encoded = self.dec_queue["all_encoded"] all_modes_done = self.stats["num_modes"] == self.stats["num_modes_finished"] if all_encoded and all_modes_done: if dec_queue_empty and all_encoded and all_modes_done: self.dec_queue["condition"].notify() break else: self.dec_queue["condition"].wait(1) while self.dec_queue["dec_entries"] != []: # can not reuse dec_queue_empty here, since there might be new items after waiting while len(self.dec_queue["dec_entries"]) != 0: config = self.dec_queue["dec_entries"].pop(0) tasks_dec.append(executor.submit(self.ivas_dec_thread, config)) Loading Loading
scripts/pyivastest/IvasModeRunner.py +10 −7 Original line number Diff line number Diff line Loading @@ -1591,15 +1591,18 @@ class IvasModeRunner(IvasModeCollector.IvasModeCollector): pass with self.dec_queue["condition"]: if not self.dec_queue["dec_entries"]: dec_queue_empty = len(self.dec_queue["dec_entries"]) == 0 all_encoded = self.dec_queue["all_encoded"] all_modes_done = self.stats["num_modes"] == self.stats["num_modes_finished"] if all_encoded and all_modes_done: if dec_queue_empty and all_encoded and all_modes_done: self.dec_queue["condition"].notify() break else: self.dec_queue["condition"].wait(1) while self.dec_queue["dec_entries"] != []: # can not reuse dec_queue_empty here, since there might be new items after waiting while len(self.dec_queue["dec_entries"]) != 0: config = self.dec_queue["dec_entries"].pop(0) tasks_dec.append(executor.submit(self.ivas_dec_thread, config)) Loading