diff --git a/selftests/unit/test_utils_env.py b/selftests/unit/test_utils_env.py index e54cddc2c8a..4ef301076a8 100644 --- a/selftests/unit/test_utils_env.py +++ b/selftests/unit/test_utils_env.py @@ -206,7 +206,7 @@ def _update_env(env, key, value): key = "%s" % utils_misc.generate_random_string(length=10) value = "%s" % utils_misc.generate_random_string(length=10) _update_env(env, key, value) - if termination_event.isSet(): + if termination_event.is_set(): break changing_thread = threading.Thread(target=update_env, diff --git a/virttest/env_process.py b/virttest/env_process.py index d820e91b504..08128e73c41 100644 --- a/virttest/env_process.py +++ b/virttest/env_process.py @@ -2026,7 +2026,7 @@ def _take_screendumps(test, params, env): os.unlink(temp_filename) if _screendump_thread_termination_event is not None: - if _screendump_thread_termination_event.isSet(): + if _screendump_thread_termination_event.is_set(): _screendump_thread_termination_event = None break _screendump_thread_termination_event.wait(delay) @@ -2141,7 +2141,7 @@ def report_result(status, cmd, results): cmd_details[cmd]['counter'][vm.instance] += 1 if _vm_info_thread_termination_event is not None: - if _vm_info_thread_termination_event.isSet(): + if _vm_info_thread_termination_event.is_set(): _vm_info_thread_termination_event = None for cmd in cmds: report_result("Thread quit", cmd, diff --git a/virttest/qemu_virtio_port.py b/virttest/qemu_virtio_port.py index 42069ed0459..84014adf800 100644 --- a/virttest/qemu_virtio_port.py +++ b/virttest/qemu_virtio_port.py @@ -505,11 +505,11 @@ def __init__(self, port, data, exit_event, quiet=False): self.ret_code = 1 # sets to 0 when finish properly def run(self): - LOG.debug("ThSend %s: run", self.getName()) + LOG.debug("ThSend %s: run", self.name) try: - while not self.exitevent.isSet(): + while not self.exitevent.is_set(): self.idx += self.port.send(self.data) - LOG.debug("ThSend %s: exit(%d)", self.getName(), self.idx) + LOG.debug("ThSend %s: exit(%d)", self.name, self.idx) except Exception as ints: if not self.quiet: raise ints @@ -548,12 +548,12 @@ def __init__(self, port, exit_event, queues, blocklen=1024, self.reduced_set = reduced_set def run(self): - LOG.debug("ThSendCheck %s: run", self.getName()) - _err_msg_exception = ('ThSendCheck ' + str(self.getName()) + ': Got ' + LOG.debug("ThSendCheck %s: run", self.name) + _err_msg_exception = ('ThSendCheck ' + str(self.name) + ': Got ' 'exception %s, continuing') - _err_msg_disconnect = ('ThSendCheck ' + str(self.getName()) + ': Port ' + _err_msg_disconnect = ('ThSendCheck ' + str(self.name) + ': Port ' 'disconnected, waiting for new port.') - _err_msg_reconnect = ('ThSendCheck ' + str(self.getName()) + ': Port ' + _err_msg_reconnect = ('ThSendCheck ' + str(self.name) + ': Port ' 'reconnected, continuing.') too_much_data = False if self.reduced_set: @@ -562,11 +562,11 @@ def run(self): else: rand_a = 0 rand_b = 255 - while not self.exitevent.isSet(): + while not self.exitevent.is_set(): # FIXME: workaround the problem with qemu-kvm stall when too # much data is sent without receiving for queue in self.queues: - while not self.exitevent.isSet() and len(queue) > 1048576: + while not self.exitevent.is_set() and len(queue) > 1048576: too_much_data = True time.sleep(0.1) try: @@ -576,11 +576,11 @@ def run(self): if self.migrate_event is None: raise exceptions.TestFail("ThSendCheck %s: Broken pipe. If this" " is expected behavior set migrate_event " - "to support reconnection." % self.getName()) + "to support reconnection." % self.name) if self.port.sock is None: LOG.debug(_err_msg_disconnect) while self.port.sock is None: - if self.exitevent.isSet(): + if self.exitevent.is_set(): break time.sleep(0.1) LOG.debug(_err_msg_reconnect) @@ -597,7 +597,7 @@ def run(self): for queue in self.queues: queue.append(char) target = self.idx + self.blocklen - while not self.exitevent.isSet() and self.idx < target: + while not self.exitevent.is_set() and self.idx < target: try: idx = self.port.sock.send(buf) except socket.timeout: @@ -611,20 +611,20 @@ def run(self): raise exceptions.TestFail("ThSendCheck %s: Broken " "pipe. If this is expected behavior " "set migrate_event to support " - "reconnection." % self.getName()) + "reconnection." % self.name) LOG.debug("ThSendCheck %s: Broken pipe " - ", reconnecting. ", self.getName()) + ", reconnecting. ", self.name) attempt = 10 while (attempt > 1 and - not self.exitevent.isSet()): + not self.exitevent.is_set()): # Wait until main thread sets the new self.port - while not (self.exitevent.isSet() or + while not (self.exitevent.is_set() or self.migrate_event.wait(1)): pass - if self.exitevent.isSet(): + if self.exitevent.is_set(): break LOG.debug("ThSendCheck %s: Broken pipe resumed" - ", reconnecting...", self.getName()) + ", reconnecting...", self.name) self.port.sock = False self.port.open() try: @@ -636,7 +636,7 @@ def run(self): attempt = 0 buf = buf[idx:] self.idx += idx - LOG.debug("ThSendCheck %s: exit(%d)", self.getName(), self.idx) + LOG.debug("ThSendCheck %s: exit(%d)", self.name, self.idx) if too_much_data: LOG.error("ThSendCheck: working around the 'too_much_data' bug") self.ret_code = 0 @@ -666,16 +666,16 @@ def __init__(self, port, event, blocklen=1024, quiet=False): self.ret_code = 1 # sets to 0 when finish properly def run(self): - LOG.debug("ThRecv %s: run", self.getName()) + LOG.debug("ThRecv %s: run", self.name) try: - while not self.exitevent.isSet(): + while not self.exitevent.is_set(): # TODO: Workaround, it didn't work with select :-/ try: self.idx += len(self.port.recv(self.blocklen)) except socket.timeout: pass self.port.settimeout(self._port_timeout) - LOG.debug("ThRecv %s: exit(%d)", self.getName(), self.idx) + LOG.debug("ThRecv %s: exit(%d)", self.name, self.idx) except Exception as ints: if not self.quiet: raise ints @@ -727,7 +727,7 @@ def reload_loss_idx(self): if self.sendidx >= 0: self.minsendidx = min(self.minsendidx, self.sendidx) LOG.debug("ThRecvCheck %s: Previous data loss was %d.", - self.getName(), (self.sendlen - self.sendidx)) + self.name, (self.sendlen - self.sendidx)) self.sendidx = self.sendlen def run(self): @@ -738,7 +738,7 @@ def run(self): self.run_normal() else: LOG.error('ThRecvCheck %s: Unsupported debug mode, using ' - 'normal mode.', self.getName()) + 'normal mode.', self.name) self.run_normal() def run_normal(self): @@ -748,18 +748,18 @@ def run_normal(self): after host socket reconnection or you can overwrite this value from other thread. """ - LOG.debug("ThRecvCheck %s: run", self.getName()) + LOG.debug("ThRecvCheck %s: run", self.name) _err_msg_missing_migrate_ev = ("ThRecvCheck %s: Broken pipe. If " "this is expected behavior set migrate_event to " - "support reconnection." % self.getName()) - _err_msg_exception = ('ThRecvCheck ' + str(self.getName()) + ': Got ' + "support reconnection." % self.name) + _err_msg_exception = ('ThRecvCheck ' + str(self.name) + ': Got ' 'exception %s, continuing') - _err_msg_disconnect = ('ThRecvCheck ' + str(self.getName()) + ': Port ' + _err_msg_disconnect = ('ThRecvCheck ' + str(self.name) + ': Port ' 'disconnected, waiting for new port.') - _err_msg_reconnect = ('ThRecvCheck ' + str(self.getName()) + ': Port ' + _err_msg_reconnect = ('ThRecvCheck ' + str(self.name) + ': Port ' 'reconnected, continuing.') attempt = 10 - while not self.exitevent.isSet(): + while not self.exitevent.is_set(): try: ret = select.select([self.port.sock], [], [], 1.0) except Exception as inst: @@ -767,14 +767,14 @@ def run_normal(self): if self.port.sock is None: LOG.debug(_err_msg_disconnect) while self.port.sock is None: - if self.exitevent.isSet(): + if self.exitevent.is_set(): break time.sleep(0.1) LOG.debug(_err_msg_reconnect) else: LOG.debug(_err_msg_exception, inst) continue - if ret[0] and (not self.exitevent.isSet()): + if ret[0] and (not self.exitevent.is_set()): try: buf = self.port.sock.recv(self.blocklen) except Exception as inst: @@ -782,7 +782,7 @@ def run_normal(self): if self.port.sock is None: LOG.debug(_err_msg_disconnect) while self.port.sock is None: - if self.exitevent.isSet(): + if self.exitevent.is_set(): break time.sleep(0.1) LOG.debug(_err_msg_reconnect) @@ -808,14 +808,14 @@ def run_normal(self): LOG.error("ThRecvCheck %s: " "Failed to recv %dth " "character", - self.getName(), self.idx) + self.name, self.idx) LOG.error("ThRecvCheck %s: " "%s != %s", - self.getName(), + self.name, repr(char), repr(_char)) LOG.error("ThRecvCheck %s: " "Recv = %s", - self.getName(), repr(buf)) + self.name, repr(buf)) # sender might change the buff :-( time.sleep(1) _char = b"" @@ -824,14 +824,14 @@ def run_normal(self): _char += b' ' LOG.error("ThRecvCheck %s: " "Queue = %s", - self.getName(), repr(_char)) + self.name, repr(_char)) LOG.info("ThRecvCheck %s: " "MaxSendIDX = %d", - self.getName(), + self.name, (self.sendlen - self.sendidx)) raise exceptions.TestFail("ThRecvCheck %s: " "incorrect data" % - self.getName()) + self.name) attempt = 10 else: # ! buf # Broken socket @@ -842,16 +842,16 @@ def run_normal(self): raise exceptions.TestFail( _err_msg_missing_migrate_ev) LOG.debug("ThRecvCheck %s: Broken pipe " - ", reconnecting. ", self.getName()) + ", reconnecting. ", self.name) self.reload_loss_idx() # Wait until main thread sets the new self.port - while not (self.exitevent.isSet() or + while not (self.exitevent.is_set() or self.migrate_event.wait(1)): pass - if self.exitevent.isSet(): + if self.exitevent.is_set(): break LOG.debug("ThRecvCheck %s: Broken pipe resumed, " - "reconnecting...", self.getName()) + "reconnecting...", self.name) self.port.sock = False self.port.open() @@ -860,9 +860,9 @@ def run_normal(self): if (self.sendlen - self.minsendidx): LOG.error("ThRecvCheck %s: Data loss occurred during socket" "reconnection. Maximal loss was %d per one " - "migration.", self.getName(), + "migration.", self.name, (self.sendlen - self.minsendidx)) - LOG.debug("ThRecvCheck %s: exit(%d)", self.getName(), self.idx) + LOG.debug("ThRecvCheck %s: exit(%d)", self.name, self.idx) self.ret_code = 0 def run_debug(self): @@ -875,14 +875,14 @@ def run_debug(self): Unlike normal run this one supports booth - loss and duplications. It's not friendly to data corruption. """ - LOG.debug("ThRecvCheck %s: run", self.getName()) + LOG.debug("ThRecvCheck %s: run", self.name) attempt = 10 max_loss = 0 sum_loss = 0 verif_buf = deque(maxlen=max(self.blocklen, self.sendlen)) - while not self.exitevent.isSet(): + while not self.exitevent.is_set(): ret = select.select([self.port.sock], [], [], 1.0) - if ret[0] and (not self.exitevent.isSet()): + if ret[0] and (not self.exitevent.is_set()): buf = self.port.sock.recv(self.blocklen) if buf: # Compare the received data with the control data @@ -895,7 +895,7 @@ def run_debug(self): else: # Detect the duplicated/lost characters. LOG.debug("ThRecvCheck %s: fail to receive " - "%dth character.", self.getName(), + "%dth character.", self.name, self.idx) buf = buf[idx_char:] for i in xrange(100): @@ -908,9 +908,9 @@ def run_debug(self): LOG.debug("ThRecvCheck %s: sendidx was " "lowered as there is not enough " "data after 1s. Using sendidx=" - "%s.", self.getName(), sendidx) + "%s.", self.name, sendidx) for _ in xrange(sendidx // self.blocklen): - if self.exitevent.isSet(): + if self.exitevent.is_set(): break buf += self.port.sock.recv(self.blocklen) queue = _char @@ -935,7 +935,7 @@ def run_debug(self): max_loss = max(max_loss, offset_a) sum_loss += offset_a LOG.debug("ThRecvCheck %s: DUP %s (out of " - "%s)", self.getName(), offset_a, + "%s)", self.name, offset_a, sendidx) buf = buf[offset_a + 1:] for _ in xrange(len(buf)): @@ -946,7 +946,7 @@ def run_debug(self): max_loss = max(max_loss, offset_b) sum_loss += offset_b LOG.debug("ThRecvCheck %s: LOST %s (out of" - " %s)", self.getName(), offset_b, + " %s)", self.name, offset_b, sendidx) # Pop-out the lost characters from verif_queue # (first one is already out) @@ -965,7 +965,7 @@ def run_debug(self): LOG.error("ThRecvCheck %s: mismatched data" ":\nverified: ..%s\nreceived: " "%s\nsent: %s", - self.getName(), repr(verif), + self.name, repr(verif), repr(buf), repr(queue)) raise exceptions.TestFail("Recv and sendqueue " "don't match with any offset.") @@ -982,18 +982,18 @@ def run_debug(self): raise exceptions.TestFail("ThRecvCheck %s: Broken pipe." " If this is expected behavior set migrate" "_event to support reconnection." % - self.getName()) + self.name) LOG.debug("ThRecvCheck %s: Broken pipe " - ", reconnecting. ", self.getName()) + ", reconnecting. ", self.name) self.reload_loss_idx() # Wait until main thread sets the new self.port - while not (self.exitevent.isSet() or + while not (self.exitevent.is_set() or self.migrate_event.wait(1)): pass - if self.exitevent.isSet(): + if self.exitevent.is_set(): break LOG.debug("ThRecvCheck %s: Broken pipe resumed, " - "reconnecting...", self.getName()) + "reconnecting...", self.name) self.port.sock = False self.port.open() @@ -1002,11 +1002,11 @@ def run_debug(self): if (self.sendlen - self.minsendidx): LOG.debug("ThRecvCheck %s: Data loss occurred during socket" "reconnection. Maximal loss was %d per one " - "migration.", self.getName(), + "migration.", self.name, (self.sendlen - self.minsendidx)) if sum_loss > 0: LOG.debug("ThRecvCheck %s: Data offset detected, cumulative " - "err: %d, max err: %d(%d)", self.getName(), sum_loss, + "err: %d, max err: %d(%d)", self.name, sum_loss, max_loss, float(max_loss) / self.blocklen) - LOG.debug("ThRecvCheck %s: exit(%d)", self.getName(), self.idx) + LOG.debug("ThRecvCheck %s: exit(%d)", self.name, self.idx) self.ret_code = 0 diff --git a/virttest/shared/scripts/virtio_console_guest.py b/virttest/shared/scripts/virtio_console_guest.py index c7fb706ada9..b029be0440f 100755 --- a/virttest/shared/scripts/virtio_console_guest.py +++ b/virttest/shared/scripts/virtio_console_guest.py @@ -380,7 +380,7 @@ def _none_mode(self): """ Read and write to device in blocking mode """ - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): data = b"" for desc in self.in_files: data += os.read(desc, self.cachesize) @@ -402,7 +402,7 @@ def _poll_mode(self): for fd in self.out_files: po.register(fd, select.POLLOUT) - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): data = b"" t_out = self.out_files @@ -412,7 +412,7 @@ def _poll_mode(self): if data != b"": while ((len(t_out) != len(readyf)) and not - self.exit_thread.isSet()): + self.exit_thread.is_set()): readyf = po.poll(1.0) for desc in t_out: os.write(desc, data) @@ -421,7 +421,7 @@ def _select_mode(self): """ Read and write to device in selecting mode. """ - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): ret = select.select(self.in_files, [], [], 1.0) data = b"" if ret[0] != []: @@ -430,7 +430,7 @@ def _select_mode(self): if data != b"": ret = select.select([], self.out_files, [], 1.0) while ((len(self.out_files) != len(ret[1])) and not - self.exit_thread.isSet()): + self.exit_thread.is_set()): ret = select.select([], self.out_files, [], 1.0) for desc in ret[1]: os.write(desc, data) @@ -443,10 +443,10 @@ def _reconnect_none_mode(self): """ # TODO: Remove port unplugging after failure from guest_worker # when bz796048 is resolved. - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): data = b"" for i in range(len(self.in_files)): - if self.exit_thread.isSet(): + if self.exit_thread.is_set(): break desc = self.in_files[i] try: @@ -473,7 +473,7 @@ def _reconnect_none_mode(self): name = item[0] break virt.close(name) - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): try: desc = virt._open([name])[0] sys.stdout.write("PASS: Opened %s\n" @@ -484,13 +484,13 @@ def _reconnect_none_mode(self): self.in_files[self.in_files.index(_desc)] = desc if data != b"": for i in range(len(self.out_files)): - if self.exit_thread.isSet(): + if self.exit_thread.is_set(): break desc = self.out_files[i] written = False while not written: try: - if self.exit_thread.isSet(): + if self.exit_thread.is_set(): break os.write(desc, data) written = True @@ -518,7 +518,7 @@ def _reconnect_none_mode(self): name = item[0] break virt.close(name) - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): try: desc = virt._open([name])[0] sys.stdout.write("PASS: Opened " @@ -561,7 +561,7 @@ def __init__(self, port, event, length): self.data.append(random.randrange(sys.maxsize)) def run(self): - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): os.write(self.port, self.data) def _open(self, in_files): @@ -860,7 +860,7 @@ def exit_threads(self): """ self.exit_thread.set() for th in self.threads: - print("join %s" % th.getName()) + print("join %s" % th.name) th.join() self.exit_thread.clear() @@ -1144,7 +1144,7 @@ def _none_mode(self): Read and write to device in blocking mode """ data = "" - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): data = "" for desc in self.in_files: ret, _data = win32file.ReadFile(desc, self.cachesize) @@ -1185,7 +1185,7 @@ def __init__(self, port, event, length): self.data.append(random.randrange(sys.maxint)) def run(self): - while not self.exit_thread.isSet(): + while not self.exit_thread.is_set(): if win32file.WriteFile(self.port, self.data)[0]: msg = "Error occurred while sending data." print("FAIL: " + msg) @@ -1297,8 +1297,8 @@ def is_alive(): """ Check is only main thread is alive and if guest react. """ - if ((os_linux and (threading.activeCount() == 2)) or - ((not os_linux) and (threading.activeCount() == 1))): + if ((os_linux and (threading.active_count() == 2)) or + ((not os_linux) and (threading.active_count() == 1))): print("PASS: Guest is ok no thread alive") else: threads = "" diff --git a/virttest/tests/unattended_install.py b/virttest/tests/unattended_install.py index 74616d26630..686308a69fa 100644 --- a/virttest/tests/unattended_install.py +++ b/virttest/tests/unattended_install.py @@ -86,7 +86,7 @@ def terminate_auto_content_server_thread(): if _url_auto_content_server_thread_event is None: return False - if _url_auto_content_server_thread_event.isSet(): + if _url_auto_content_server_thread_event.is_set(): return True return False @@ -100,7 +100,7 @@ def terminate_unattended_server_thread(): if _unattended_server_thread_event is None: return False - if _unattended_server_thread_event.isSet(): + if _unattended_server_thread_event.is_set(): return True return False @@ -1163,7 +1163,7 @@ def terminate_syslog_server_thread(): if _syslog_server_thread_event is None: return False - if _syslog_server_thread_event.isSet(): + if _syslog_server_thread_event.is_set(): return True return False