Home
last modified time | relevance | path

Searched refs:is_alive (Results 1 - 25 of 32) sorted by relevance

12

/third_party/python/Lib/test/support/
H A Dthreading_helper.py113 if thread.is_alive():
143 started = [t for t in started if t.is_alive()]
150 started = [t for t in started if t.is_alive()]
/third_party/python/Lib/multiprocessing/dummy/
H A D__init__.py55 if self._start_called and not self.is_alive():
71 if not p.is_alive():
/third_party/python/Lib/test/test_importlib/
H A Dthreaded_import_hangers.py42 if t.is_alive():
/third_party/python/Lib/
H A Dthreading.py907 def _reset_internal_locks(self, is_alive):
911 if is_alive:
929 self.is_alive() # easy way to get ._is_stopped set when appropriate
1045 # After calling ._stop(), .is_alive() returns False and .join() returns
1051 # and .is_alive(). Any number of threads _may_ call ._stop()
1090 is_alive() after join() to decide whether a timeout happened -- if the
1185 def is_alive(self): member in Thread
1436 def is_alive(self): member in _DummyThread
H A Dsocketserver.py658 self[:] = (thread for thread in self if thread.is_alive())
H A Dsubprocess.py1627 if self.stdout_thread.is_alive():
1631 if self.stderr_thread.is_alive():
/third_party/python/Lib/test/libregrtest/
H A Druntest_mp.py154 if self.is_alive():
348 if not self.is_alive():
413 while any(worker.is_alive() for worker in self.workers):
/third_party/python/Lib/multiprocessing/
H A Dprocess.py153 def is_alive(self): member in BaseProcess
376 def is_alive(self): member in _ParentProcess
H A Dresource_sharer.py100 if self._thread.is_alive():
H A Dpool.py676 while task_handler.is_alive() and inqueue._reader.poll():
697 if (not result_handler.is_alive()) and (len(cache) != 0):
729 if p.is_alive():
H A Dmanagers.py620 if not self._process.is_alive():
665 if process.is_alive():
677 if process.is_alive():
683 if process.is_alive():
/third_party/python/Lib/test/
H A Dtest_poll.py225 self.assertTrue(poll_thread.is_alive())
230 self.assertFalse(poll_thread.is_alive())
H A Dtest_threading.py190 self.assertFalse(t.is_alive())
254 self.assertTrue(threading._active[tid].is_alive())
593 # Try hard to trigger #18418: is_alive() could sometimes be True on
606 os._exit(11 if t.is_alive() else 10)
755 self.assertTrue(t.is_alive())
764 # But is_alive() is still True: we hold _tstate_lock now, which
765 # prevents is_alive() from knowing the thread's end-of-life C code
767 self.assertTrue(t.is_alive())
768 # Let is_alive() find out the C code is done.
770 self.assertFalse(t.is_alive())
[all...]
H A D_test_multiprocessing.py96 # (join() and is_alive(), the support function can be reused
254 self.assertTrue(current.is_alive())
376 wconn.send("alive" if parent_process().is_alive() else "not alive")
378 wconn.send("alive" if parent_process().is_alive() else "not alive")
394 self.assertEqual(p.is_alive(), False)
403 self.assertEqual(p.is_alive(), True)
416 self.assertEqual(p.is_alive(), False)
458 self.assertEqual(p.is_alive(), True)
466 self.assertEqual(p.is_alive(), True)
470 self.assertEqual(p.is_alive(), Tru
5530 def is_alive(self): global() member in TestPoolNotLeakOnFailure.test_release_unused_processes.FailingForkProcess
[all...]
/third_party/skia/third_party/externals/abseil-cpp/absl/base/internal/
H A Dexception_safety_testing.h111 bool is_alive; member
132 if (tracked_address.is_alive) { in ~ConstructorTracker()
144 if (tracked_address.is_alive) { in ObjectConstructed()
162 if (!tracked_address.is_alive) { in ObjectDestructed()
167 tracked_address.is_alive = false; in ObjectDestructed()
/third_party/curl/lib/
H A Dcfilters.h200 Curl_cft_conn_is_alive *is_alive; /* FALSE if conn is dead, Jim! */ member
H A Dcfilters.c112 cf->next->cft->is_alive(cf->next, data, input_pending) : in Curl_cf_def_conn_is_alive()
641 cf->cft->is_alive(cf, data, input_pending); in Curl_conn_is_alive()
/third_party/python/Lib/asyncio/
H A Dunix_events.py1371 if thread.is_alive() and not thread.daemon]
1383 if thread.is_alive()]
/third_party/skia/third_party/externals/angle2/src/tests/
H A Dcapture_replay_tests.py192 return any([worker.is_alive() for worker in self.workers])
197 if worker.is_alive():
/third_party/python/Lib/concurrent/futures/
H A Dprocess.py557 return sum(p.is_alive() for p in self.processes.values())
/third_party/python/Lib/lib2to3/
H A Drefactor.py712 if p.is_alive():
/third_party/littlefs/scripts/
H A Dbench.py977 while any(r.is_alive() for r in runners):
/third_party/curl/lib/vquic/
H A Dcurl_ngtcp2.c2290 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in cf_ngtcp2_conn_is_alive()
2301 CURL_TRC_CF(data, cf, "is_alive, progress ingress -> %d", result); in cf_ngtcp2_conn_is_alive()
H A Dcurl_osslq.c2060 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in cf_osslq_conn_is_alive()
2071 CURL_TRC_CF(data, cf, "is_alive, progress ingress -> %d", result); in cf_osslq_conn_is_alive()
H A Dcurl_quiche.c1505 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in cf_quiche_conn_is_alive()

Completed in 36 milliseconds

12