Searched refs:is_alive (Results 1 – 10 of 10) sorted by relevance
178 self.assertFalse(worker.is_alive())187 self.assertFalse(worker.is_alive())206 self.assertFalse(worker.is_alive())219 self.assertFalse(worker.is_alive())283 self.assertRaises(NotImplementedError, obj.is_alive)
223 def is_alive(self): member in _WorkerConnection246 def is_alive(self): member in _InlineWorkerConnection292 def is_alive(self): member in _ThreadedWorkerConnection339 def is_alive(self): member in _MultiProcessWorkerConnection340 return self._proc.is_alive()
175 if not worker_state.wedged and worker_state.worker_connection.is_alive():177 assert not worker_state.worker_connection.is_alive()
63 def is_alive(self): member in QueueBubble69 if not self.is_alive():
69 bool is_alive; member129 SourceInfoList GetAllDeadOrAliveSources(bool is_alive) const { in GetAllDeadOrAliveSources() argument133 if (it->second.is_alive == is_alive) in GetAllDeadOrAliveSources()
43 is_alive(true) { in SourceInfo()210 info.is_alive = false; in OnAddEntry()269 DCHECK(!sources_.find(source_id)->second.is_alive); in AddToDeletionQueue()320 if (!info.is_alive) { in AdjustReferenceCountForSource()
193 thr->is_alive = true; in ThreadStart()210 thr->is_alive = false; in ThreadFinish()
278 bool is_alive; member
115 if (ctx == 0 && thr->is_alive) { in SigCtx()
299 Adds the cancel(), is_alive(), join(), and log_wedged_worker()333 is_alive().