Home
last modified time | relevance | path

Searched refs:_state (Results 1 – 25 of 164) sorted by relevance

1234567

/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D_time.py83 self._state = state
89 with self._state.condition:
93 behaviors_at_time = self._state.times_to_behaviors.get(
100 self._state.times_to_behaviors.pop(self._time)
101 self._state.condition.notify_all()
106 with self._state.condition:
131 self._state = _State()
137 with self._state.condition:
140 delta = _process(self._state, now)
141 self._state.condition.notify_all()
[all …]
/external/antlr/runtime/Python3/antlr3/
Drecognizers.py162 self._state = state
182 if self._state is None:
186 self._state.following = []
187 self._state.errorRecovery = False
188 self._state.lastErrorIndex = -1
189 self._state.syntaxErrors = 0
191 self._state.backtracking = 0
192 if self._state.ruleMemo is not None:
193 self._state.ruleMemo = {}
213 self._state.errorRecovery = False
[all …]
/external/antlr/runtime/Python/antlr3/
Drecognizers.py163 self._state = state
183 if self._state is None:
187 self._state.following = []
188 self._state.errorRecovery = False
189 self._state.lastErrorIndex = -1
190 self._state.syntaxErrors = 0
192 self._state.backtracking = 0
193 if self._state.ruleMemo is not None:
194 self._state.ruleMemo = {}
214 self._state.errorRecovery = False
[all …]
/external/grpc-grpc/src/python/grpcio/grpc/
D_channel.py255 self._state = state
261 with self._state.condition:
262 if self._state.code is None:
267 self._state.cancelled = True
268 _abort(self._state, code, details)
269 self._state.condition.notify_all()
273 with self._state.condition:
274 return self._state.cancelled
277 with self._state.condition:
278 return self._state.code is None
[all …]
D_server.py218 self._state = state
222 with self._state.condition:
223 return self._state.client is not _CANCELLED and not self._state.statused
232 with self._state.condition:
233 if self._state.callbacks is None:
236 self._state.callbacks.append(callback)
240 with self._state.condition:
241 self._state.disable_next_compression = True
264 with self._state.condition:
265 if self._state.client is _CANCELLED:
[all …]
/external/mesa3d/src/gallium/tools/trace/
Ddump_state.py232 self._state = Struct()
233 self._state.scissors = []
234 self._state.viewports = []
235 self._state.vertex_buffers = []
236 self._state.vertex_elements = []
237 self._state.vs = Struct()
238 self._state.gs = Struct()
239 self._state.fs = Struct()
240 self._state.vs.shader = None
241 self._state.gs.shader = None
[all …]
/external/python/cpython3/Lib/concurrent/futures/
D_base.py164 f._state not in [CANCELLED_AND_NOTIFIED, FINISHED] for f in fs)
227 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
291 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
320 self._state = PENDING
335 if self._state == FINISHED:
340 _STATE_TO_DESCRIPTION_MAP[self._state],
346 _STATE_TO_DESCRIPTION_MAP[self._state],
351 _STATE_TO_DESCRIPTION_MAP[self._state])
360 if self._state in [RUNNING, FINISHED]:
363 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
[all …]
/external/python/cpython2/Lib/
Dfileinput.py80 _state = None variable
93 global _state
94 if _state and _state._file:
96 _state = FileInput(files, inplace, backup, bufsize, mode, openhook)
97 return _state
101 global _state
102 state = _state
103 _state = None
117 if not _state:
119 return _state.nextfile()
[all …]
/external/python/cpython3/Lib/
Dfileinput.py82 _state = None variable
91 global _state
92 if _state and _state._file:
94 _state = FileInput(files, inplace, backup, mode=mode, openhook=openhook)
95 return _state
99 global _state
100 state = _state
101 _state = None
115 if not _state:
117 return _state.nextfile()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DStateFlow.kt204 private val _state = atomic<Any?>(null) in compareAndSet() constant in kotlinx.coroutines.flow.StateFlowSlot
208 if (_state.value != null) return false // not free in compareAndSet()
209 _state.value = NONE // allocated in compareAndSet()
214 _state.value = null // free now in compareAndSet()
220 _state.loop { state -> in compareAndSet()
225 if (_state.compareAndSet(state, PENDING)) return in compareAndSet()
229 if (_state.compareAndSet(state, NONE)) { in compareAndSet()
238 fun takePending(): Boolean = _state.getAndSet(NONE)!!.let { state -> in compareAndSet()
245 assert { _state.value !is CancellableContinuationImpl<*> } // can be NONE or PENDING in compareAndSet()
246 … if (_state.compareAndSet(NONE, cont)) return@sc // installed continuation, waiting for pending in compareAndSet()
[all …]
/external/wpa_supplicant_8/src/utils/
Dstate_machine.h47 if (!global || sm->machine ## _state != machine ## _ ## state) { \
52 sm->machine ## _state = machine ## _ ## state;
65 #define SM_ENTRY_M(machine, _state, data) \ argument
66 if (!global || sm->data ## _ ## state != machine ## _ ## _state) { \
69 #machine " entering state " #_state); \
71 sm->data ## _ ## state = machine ## _ ## _state;
83 #define SM_ENTRY_MA(machine, _state, data) \ argument
84 if (!global || sm->data ## _ ## state != machine ## _ ## _state) { \
87 #machine " entering state " #_state, \
90 sm->data ## _ ## state = machine ## _ ## _state;
/external/python/futures/concurrent/futures/
D_base.py161 f._state not in [CANCELLED_AND_NOTIFIED, FINISHED] for f in fs)
224 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
292 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
321 self._state = PENDING
353 if self._state == FINISHED:
358 _STATE_TO_DESCRIPTION_MAP[self._state],
364 _STATE_TO_DESCRIPTION_MAP[self._state],
369 _STATE_TO_DESCRIPTION_MAP[self._state])
378 if self._state in [RUNNING, FINISHED]:
381 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/
DMutex.kt147 private val _state = atomic<Any?>(if (locked) EMPTY_LOCKED else EMPTY_UNLOCKED) in toString() constant
150 _state.loop { state -> in toString()
162 val state = _state.value in toString()
167 _state.loop { state -> in toString()
174 if (_state.compareAndSet(state, update)) return true in toString()
195 _state.loop { state -> in toString()
199 _state.compareAndSet(state, LockedQueue(state.locked)) in toString()
203 if (_state.compareAndSet(state, update)) { // locked in toString()
212 if (state.addLastIf(waiter) { _state.value === state }) { in toString()
232 when (val state = _state.value) { in toString()
[all …]
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel.py27 self._state = state
39 return _multi_callable.UnaryUnary(method, self._state)
45 return _multi_callable.UnaryStream(method, self._state)
51 return _multi_callable.StreamUnary(method, self._state)
57 return _multi_callable.StreamStream(method, self._state)
75 return _channel_rpc.unary_unary(self._state, method_descriptor)
78 return _channel_rpc.unary_stream(self._state, method_descriptor)
81 return _channel_rpc.stream_unary(self._state, method_descriptor)
84 return _channel_rpc.stream_stream(self._state, method_descriptor)
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DInterruptible.kt90 private val _state = atomic(WORKING) constant
99 _state.loop { state -> in setup()
102 WORKING -> if (_state.compareAndSet(state, WORKING)) return in setup()
114 _state.loop { state -> in clearInterrupt()
116 WORKING -> if (_state.compareAndSet(state, FINISHED)) { in clearInterrupt()
138 _state.loop { state -> in invoke()
142 if (_state.compareAndSet(state, INTERRUPTING)) { in invoke()
144 _state.value = INTERRUPTED in invoke()
/external/lzma/CPP/7zip/Compress/
DLzmaDecoder.cpp45 LzmaDec_Construct(&_state); in CDecoder()
50 LzmaDec_Free(&_state, &g_AlignedAlloc); // &_alloc.vt in ~CDecoder()
74 RINOK(SResToHRESULT(LzmaDec_Allocate(&_state, prop, size, &g_AlignedAlloc))) // &_alloc.vt in SetDecoderProperties2()
89 LzmaDec_Init(&_state); in SetOutStreamSizeResume()
122 SizeT wrPos = _state.dicPos; in CodeSpec()
133 const SizeT dicPos = _state.dicPos; in CodeSpec()
136 SizeT next = _state.dicBufSize; in CodeSpec()
157 …SRes res = LzmaDec_DecodeToDic(&_state, dicPos + size, _inBuf + _inPos, &inProcessed, finishMode, … in CodeSpec()
162 const SizeT outProcessed = _state.dicPos - dicPos; in CodeSpec()
175 HRESULT res2 = WriteStream(outStream, _state.dic + wrPos, _state.dicPos - wrPos); in CodeSpec()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DConflatedBroadcastChannel.kt41 _state.lazySet(State<E>(value, null)) in <lambda>()
44 private val _state = atomic<Any>(INITIAL_STATE) // State | Closed in <lambda>() constant
74 _state.loop { state -> in <lambda>()
90 public val valueOrNull: E? get() = when (val state = _state.value) { in <lambda>()
96 public override val isClosedForSend: Boolean get() = _state.value is Closed in <lambda>()
102 _state.loop { state -> in <lambda>()
112 if (_state.compareAndSet(state, update)) in <lambda>()
122 _state.loop { state -> in <lambda>()
127 if (_state.compareAndSet(state, update)) in <lambda>()
161 _state.loop { state -> in <lambda>()
[all …]
/external/flatbuffers/tests/FlatBuffers.Test/
DLcg.cs25 private uint _state; field in FlatBuffers.Test.Lcg
29 _state = InitialValue; in Lcg()
34 return (_state = 69069 * _state + 362437); in Next()
39 _state = InitialValue; in Reset()
/external/grpc-grpc/src/objective-c/RxLibrary/
DGRXBufferedPipe.m30 @synthesize state = _state;
38 _state = GRXWriterStateNotStarted;
72 if (_state == GRXWriterStateNotStarted || _state == GRXWriterStateFinished) {
79 if (_state == GRXWriterStatePaused) {
82 _state = newState;
85 if (_state == GRXWriterStateStarted) {
86 _state = newState;
91 if (_state == GRXWriterStatePaused) {
92 _state = newState;
104 _state = GRXWriterStateStarted;
DGRXImmediateWriter.m29 @synthesize state = _state;
40 _state = GRXWriterStateNotStarted;
87 if (_state == GRXWriterStatePaused || _state == GRXWriterStateFinished) {
95 _state = GRXWriterStateStarted;
101 _state = GRXWriterStateFinished;
111 if (_state == GRXWriterStateNotStarted || _state == GRXWriterStateFinished) {
117 _state = newState;
125 _state = newState;
128 if (_state == GRXWriterStatePaused) {
129 _state = newState;
/external/pigweed/pw_hdlc/py/pw_hdlc/
Ddecode.py111 self._state = _State.INTERFRAME
150 if self._state is _State.INTERFRAME:
155 self._state = _State.FRAME
156 elif self._state is _State.FRAME:
162 self._state = _State.FRAME
164 self._state = _State.FRAME_ESCAPE
167 elif self._state is _State.FRAME_ESCAPE:
170 self._state = _State.FRAME
172 self._state = _State.FRAME
175 self._state = _State.INTERFRAME
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/
DLockFreeTaskQueue.kt82 private val _state = atomic(0L) constant in LockFreeTaskQueueCore
91 val isEmpty: Boolean get() = _state.value.withState { head, tail -> head == tail } in head()
92 … val size: Int get() = _state.value.withState { head, tail -> (tail - head) and MAX_CAPACITY_MASK } in head()
95 _state.update { state -> in close()
105 _state.loop { state -> in addLast()
127 if (_state.compareAndSet(state, state.updateTail(newTail))) { in addLast()
133 … if (cur._state.value and FROZEN_MASK == 0L) break // all fine -- not frozen yet in addLast()
165 _state.loop { state -> in removeFirstOrNull()
180 if (_state.compareAndSet(state, state.updateHead(newHead))) { in removeFirstOrNull()
199 _state.loop { state -> in removeSlowPath()
[all …]
/external/jackson-databind/src/main/java/com/fasterxml/jackson/databind/
DMappingIterator.java103 protected int _state; field in MappingIterator
145 _state = STATE_CLOSED; in MappingIterator()
161 _state = STATE_MAY_HAVE_VALUE; in MappingIterator()
214 if (_state != STATE_CLOSED) { in close()
215 _state = STATE_CLOSED; in close()
234 switch (_state) { in hasNextValue()
246 _state = STATE_CLOSED; in hasNextValue()
253 _state = STATE_HAS_VALUE; in hasNextValue()
263 switch (_state) { in nextValue()
288 _state = nextState; in nextValue()
/external/python/cpython3/Lib/asyncio/
Dfutures.py49 _state = _PENDING variable in Future
152 if self._state != _PENDING:
154 self._state = _CANCELLED
175 return self._state == _CANCELLED
185 return self._state != _PENDING
194 if self._state == _CANCELLED:
197 if self._state != _FINISHED:
212 if self._state == _CANCELLED:
215 if self._state != _FINISHED:
227 if self._state != _PENDING:
[all …]
/external/python/cpython3/Lib/test/
Dtest_fileinput.py575 self._orig_state = fileinput._state
581 fileinput._state = self._orig_state
601 fileinput._state = instance
605 self.assertIs(instance, fileinput._state, "fileinput._state")
615 fileinput._state = instance
624 fileinput._state = None
643 self.assertIs(result, fileinput._state, "fileinput._state")
659 fileinput._state = None
661 self.assertIsNone(fileinput._state)
667 fileinput._state = instance
[all …]

1234567