Searched refs:drain_thread (Results 1 – 2 of 2) sorted by relevance
87 drain_thread = threading.Thread(target=self._drain_fn)88 drain_thread.daemon = True89 drain_thread.start()90 return drain_thread
528 static void test_iothread_common(enum drain_type drain_type, int drain_thread) in test_iothread_common() argument546 if (drain_type == BDRV_DRAIN_ALL && drain_thread != 0) { in test_iothread_common()564 if (drain_thread == 0) { in test_iothread_common()578 switch (drain_thread) { in test_iothread_common()