/third_party/backends/backend/ |
H A D | hp-handle.c | 81 sig_atomic_t cancelled; member 161 this->cancelled = 0; in hp_handle_startReader() 221 this->cancelled = 0; in hp_handle_stopScan() 385 if (this->cancelled) in sanei_hp_handle_saneoption() 387 DBG(1, "sanei_hp_handle_saneoption: cancelled. Stop scan\n"); in sanei_hp_handle_saneoption() 401 if (this->cancelled) in sanei_hp_handle_control() 403 DBG(1, "sanei_hp_handle_control: cancelled. Stop scan\n"); in sanei_hp_handle_control() 430 if (this->cancelled) in sanei_hp_handle_getParameters() 432 DBG(1, "sanei_hp_handle_getParameters: cancelled. Stop scan\n"); in sanei_hp_handle_getParameters() 669 if (this->cancelled) in sanei_hp_handle_read() [all...] |
H A D | canon_pp.h | 100 SANE_Bool cancelled; member
|
H A D | as6e.h | 98 SANE_Bool cancelled; member
|
H A D | sm3840.h | 93 SANE_Bool cancelled; member
|
/third_party/python/Lib/asyncio/ |
H A D | futures.py | 127 """Create the CancelledError to raise if the Future is cancelled. 149 If the future is already done or cancelled, return False. Otherwise, 150 change the future's state to cancelled, schedule the callbacks and 175 def cancelled(self): member in Future 176 """Return True if the future was cancelled.""" 185 future was cancelled. 192 If the future has been cancelled, raises CancelledError. If the 210 the future is done. If the future has been cancelled, raises 312 """Helper setting the result only if the future was not cancelled.""" 313 if fut.cancelled() [all...] |
H A D | locks.py | 100 all(w.cancelled() for w in self._waiters))): 152 # either take the lock, or, if it was cancelled and lock wasn't 273 # Must reacquire lock even if wait is cancelled 274 cancelled = False 280 cancelled = True 282 if cancelled: 362 any(not w.cancelled() for w in (self._waiters or ()))) 391 if not fut.cancelled():
|
H A D | tasks.py | 159 cancelled, this returns an empty list. If the coroutine was 197 task will be cancelled: the exception might be caught and 202 Immediately after this method is called, Task.cancelled() will 203 not return True (unless the task was already cancelled). A 204 task will be marked as cancelled when the wrapped coroutine 272 # Task is cancelled right before coro stops. 435 If the wait is cancelled, the task is also cancelled. 514 return_when == FIRST_EXCEPTION and (not f.cancelled() and 694 cancelled [all...] |
H A D | base_subprocess.py | 188 if waiter is not None and not waiter.cancelled(): 191 if waiter is not None and not waiter.cancelled(): 247 if not waiter.cancelled():
|
H A D | queues.py | 59 # Wake up the next waiter (if any) that isn't cancelled. 130 if not self.full() and not putter.cancelled(): 168 if not self.empty() and not getter.cancelled():
|
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_timeouts.py | 34 cancelled = False 43 cancelled = True 45 self.assertTrue(cancelled) 51 cancelled = False 57 cancelled = True 59 self.assertTrue(cancelled) 164 self.assertFalse(task.cancelled()) 254 await asyncio.sleep(1) # work which will be cancelled 265 await asyncio.sleep(1) # work which will be cancelled
|
H A D | test_futures.py | 48 def cancelled(self): member in DuckFuture 57 self.assertFalse(self.cancelled()) 63 self.assertFalse(self.cancelled()) 142 self.assertFalse(f.cancelled()) 145 self.assertTrue(f.cancelled()) 219 self.assertFalse(fut.cancelled()) 246 self.assertTrue(f.cancelled()) 259 self.assertFalse(f.cancelled()) 277 self.assertFalse(f.cancelled()) 324 self.assertEqual(repr(f_cancelled), f'<{self.cls.__name__} cancelled>') [all...] |
H A D | test_tasks.py | 357 # test cancelled Task 363 "<Task cancelled name='TestTask' %s>" % coro) 534 self.assertFalse(t.cancelled()) # Task is still not complete 540 self.assertFalse(t.cancelled()) # Task is still not complete 545 self.assertFalse(t.cancelled()) # Task is still not complete 548 self.assertTrue(t.cancelled()) # Finally, task complete 553 self.assertTrue(t.cancelled()) 645 self.assertFalse(structured_block_finished) # it was cancelled 681 self.assertTrue(t.cancelled()) 768 raise ValueError("cancelled") fro [all...] |
H A D | test_waitfor.py | 120 # it should have been cancelled due to the timeout 121 self.assertTrue(fut.cancelled()) 145 # it should have been cancelled due to the timeout 146 self.assertTrue(fut.cancelled()) 284 self.assertTrue(task.cancelled())
|
H A D | test_taskgroups.py | 85 self.assertTrue(t1.cancelled()) 123 self.assertTrue(t2.cancelled()) 127 # are cancelled and the errors are gathered into an EG. 284 self.assertTrue(t1.cancelled()) 285 self.assertTrue(t2.cancelled()) 313 self.assertTrue(t1.cancelled()) 314 self.assertTrue(t2.cancelled())
|
/third_party/node/deps/uv/src/ |
H A D | threadpool.c | 100 to run, that means it's cancelled => Start over. */ in worker() 275 int cancelled; in uv__work_cancel() local 280 cancelled = !QUEUE_EMPTY(&w->wq) && w->work != NULL; in uv__work_cancel() 281 if (cancelled) in uv__work_cancel() 287 if (!cancelled) in uv__work_cancel()
|
/third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/jsonrpc2/ |
H A D | handler.go | 33 // Cancel is invoked for cancelled outgoing requests. 35 // be in the cancelled state, so you must do it with the background context 38 // cancelled set to true, and should not attempt to cancel the message. 39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool 99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
|
/third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/protocol/ |
H A D | protocol.go | 26 // RequestCancelledError should be used when a request is cancelled early. 56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) bool { 57 if cancelled {
|
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/ |
H A D | handler.go | 33 // Cancel is invoked for cancelled outgoing requests. 35 // be in the cancelled state, so you must do it with the background context 38 // cancelled set to true, and should not attempt to cancel the message. 39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool 99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
|
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/protocol/ |
H A D | protocol.go | 26 // RequestCancelledError should be used when a request is cancelled early. 56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) bool { 57 if cancelled {
|
/third_party/spirv-tools/utils/vscode/src/lsp/jsonrpc2/ |
H A D | handler.go | 33 // Cancel is invoked for cancelled outgoing requests. 35 // be in the cancelled state, so you must do it with the background context 38 // cancelled set to true, and should not attempt to cancel the message. 39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool 99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
|
/third_party/spirv-tools/utils/vscode/src/lsp/protocol/ |
H A D | protocol.go | 26 // RequestCancelledError should be used when a request is cancelled early. 56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) bool { 57 if cancelled {
|
/third_party/python/Lib/unittest/test/ |
H A D | test_async_case.py | 378 cancelled = False 382 nonlocal cancelled 386 cancelled = True 394 self.assertTrue(cancelled)
|
/third_party/python/Lib/test/ |
H A D | test_concurrent_futures.py | 360 # guarantee that *some* were cancelled. With few workers, many of 361 # the submitted futures should have been cancelled. 362 cancelled = [fut for fut in fs if fut.cancelled()] 363 self.assertGreater(len(cancelled), 20) 366 # Use "not fut.cancelled()" instead of "fut.done()" to include futures 368 others = [fut for fut in fs if not fut.cancelled()] 373 # Similar to the number of cancelled futures, we can't guarantee the 985 # ident='second' is cancelled as a result of raising a TimeoutError 986 # ident='third' is cancelled becaus [all...] |
/third_party/libuv/src/ |
H A D | threadpool.c | 385 to run, that means it's cancelled => Start over. */ in worker() 597 int cancelled; in uv__work_cancel() local 609 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL; in uv__work_cancel() 610 if (cancelled) in uv__work_cancel() 617 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL in uv__work_cancel() 622 if (!cancelled) { in uv__work_cancel()
|
/third_party/node/deps/v8/src/tasks/ |
H A D | operations-barrier.h | 100 bool cancelled() const { return cancelled_; } in cancelled() function in v8::internal::OperationsBarrier
|