Home
last modified time | relevance | path

Searched refs:_cancelled (Results 1 – 16 of 16) sorted by relevance

/external/grpc-grpc/src/python/grpcio/grpc/beta/
Dutilities.py36 self._cancelled = False
43 if self._cancelled:
59 if (not self._cancelled and
76 self._cancelled = True
92 return self._cancelled
96 return not self._cancelled and not self._matured
100 return self._cancelled or self._matured
116 if not self._cancelled and not self._matured:
128 if not self._cancelled and not self._matured:
D_server_adaptations.py110 self._cancelled = False
130 self._cancelled = True
136 if self._cancelled:
148 if self._cancelled:
/external/grpc-grpc/src/python/grpcio/grpc/
D_utilities.py67 self._cancelled = False
74 if self._cancelled:
90 if (not self._cancelled and
107 self._cancelled = True
123 return self._cancelled
127 return not self._cancelled and not self._matured
131 return self._cancelled or self._matured
147 if not self._cancelled and not self._matured:
159 if not self._cancelled and not self._matured:
/external/python/cpython3/Lib/asyncio/
Devents.py38 self._cancelled = False
48 if self._cancelled:
65 if not self._cancelled:
66 self._cancelled = True
76 return self._cancelled
113 pos = 2 if self._cancelled else 1
145 self._cancelled == other._cancelled)
149 if not self._cancelled:
Dbase_events.py1806 if handle._cancelled:
1837 if handle._cancelled:
1847 while self._scheduled and self._scheduled[0]._cancelled:
1882 if handle._cancelled:
Dselector_events.py595 if reader._cancelled:
600 if writer._cancelled:
Dunix_events.py138 if handle._cancelled:
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D_time.py86 self._cancelled = False
90 if self._cancelled:
102 self._cancelled = True
107 return self._cancelled
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DChannelUndeliveredElementTest.kt117 private val _cancelled = atomic(false) in <lambda>() constant in kotlinx.coroutines.channels.ChannelUndeliveredElementTest.Resource
120 get() = _cancelled.value in <lambda>()
123 check(!_cancelled.getAndSet(true)) { "Already cancelled" } in <lambda>()
/external/rust/crates/grpcio-sys/grpc/tools/run_tests/python_utils/
Djobset.py428 self._cancelled = False
494 self._cancelled = True
532 if self._cancelled:
538 self._cancelled = True
/external/grpc-grpc/tools/run_tests/python_utils/
Djobset.py413 self._cancelled = False
475 self._cancelled = True
512 if self._cancelled: return True
516 self._cancelled = True
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Doperation.pyx.pxi244 self._cancelled = bool(self._c_cancelled)
247 return self._cancelled
Doperation.pxd.pxi107 cdef object _cancelled
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_selector_events.py336 reader._cancelled = False
359 writer._cancelled = False
Dtest_tasks.py1820 self.assertFalse(handle._cancelled)
1824 self.assertTrue(handle._cancelled)
Dtest_base_events.py473 self.assertTrue(all([not x._cancelled for x in self.loop._scheduled]))