Home
last modified time | relevance | path

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

12345

/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/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/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/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.py231 self._state = Struct()
232 self._state.scissors = []
233 self._state.viewports = []
234 self._state.vertex_buffers = []
235 self._state.vertex_elements = []
236 self._state.vs = Struct()
237 self._state.gs = Struct()
238 self._state.fs = Struct()
239 self._state.vs.shader = None
240 self._state.gs.shader = None
[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.py81 _state = None variable
91 global _state
92 if _state and _state._file:
94 _state = FileInput(files, inplace, backup, bufsize, mode, openhook)
95 return _state
99 global _state
100 state = _state
101 _state = None
115 if not _state:
117 return _state.nextfile()
[all …]
/external/autotest/scheduler/
Dpidfile_monitor.py50 self._state = drone_manager.PidfileContents()
95 return self._state.process is not None
100 assert self._state.process is not None
101 return self._state.process
110 self._state = drone_manager.PidfileContents()
112 self._state = contents
116 self.on_lost_process(self._state.process)
125 if self._state.process is None:
129 if self._state.exit_status is None:
131 if self._drone_manager.is_process_running(self._state.process):
[all …]
/external/python/cpython3/Lib/concurrent/futures/
D_base.py159 f._state not in [CANCELLED_AND_NOTIFIED, FINISHED] for f in fs)
222 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
286 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
315 self._state = PENDING
330 if self._state == FINISHED:
335 _STATE_TO_DESCRIPTION_MAP[self._state],
341 _STATE_TO_DESCRIPTION_MAP[self._state],
346 _STATE_TO_DESCRIPTION_MAP[self._state])
355 if self._state in [RUNNING, FINISHED]:
358 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
[all …]
/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/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/toolchain-utils/automation/common/
Dstate_machine.py25 self._state = initial_state
28 self.timeline.AddEvent(self._state)
31 return self._state
37 return self._state == value
43 return to_state in self.state_machine.get(self._state, [])
47 'Transition from %s to %s not possible' % (self._state, new_state)
49 self._state = new_state
51 self.timeline.AddEvent(self._state)
53 if self._state in self.final_states:
/external/webrtc/webrtc/modules/rtp_rtcp/source/
Drtcp_utility.cc57 _state(ParseState::State_TopLevel), in RTCPParserV2()
104 switch (_state) in Iterate()
555 _state = ParseState::State_ReportBlockItem; in ParseRR()
610 _state = ParseState::State_ReportBlockItem; in ParseSR()
614 _state = ParseState::State_TopLevel; in ParseSR()
627 _state = ParseState::State_TopLevel; in ParseReportBlockItem()
698 _state = ParseState::State_ExtendedJitterItem; in ParseIJ()
709 _state = ParseState::State_TopLevel; in ParseIJItem()
731 _state = ParseState::State_TopLevel; in ParseSDES()
738 _state = ParseState::State_SDESChunk; in ParseSDES()
[all …]
/external/webrtc/webrtc/modules/video_coding/
Dframe_buffer.cc23 : _state(kStateEmpty), _nackCount(0), _latestPacketTimeMs(-1) {} in VCMFrameBuffer()
29 _state(rhs._state), in VCMFrameBuffer()
93 if (kStateEmpty == _state) { in InsertPacket()
200 _state = kStateEmpty; in Reset()
206 if (_state == state) { in SetState()
212 assert(_state == kStateEmpty); in SetState()
218 assert(_state == kStateEmpty || _state == kStateIncomplete || in SetState()
219 _state == kStateDecodable); in SetState()
229 assert(_state == kStateEmpty || _state == kStateIncomplete); in SetState()
232 _state = state; in SetState()
[all …]
/external/tensorflow/tensorflow/contrib/recurrent/python/ops/
Drecurrent.py309 self._state = state0
330 fwd_sig = [self._theta, self._state, self._inputs]
343 _AssertIsCompatible(state1, self._state)
359 self._theta, self._state, self._inputs, self._state, self._extras
370 state1, extras = _Pack(fwd, [self._state, self._extras])
391 self._theta, self._state, self._inputs, self._max_input_length,
398 [self._state, self._state, self._extras])
406 [self._state, self._state, self._extras])
415 self._theta, self._state, self._inputs, self._max_input_length,
444 [self._theta, self._state, self._inputs, self._state, self._extras])
[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/python/cpython3/Lib/asyncio/
Dfutures.py52 _state = _PENDING variable in Future
131 if self._state != _PENDING:
133 self._state = _CANCELLED
153 return self._state == _CANCELLED
163 return self._state != _PENDING
172 if self._state == _CANCELLED:
174 if self._state != _FINISHED:
189 if self._state == _CANCELLED:
191 if self._state != _FINISHED:
203 if self._state != _PENDING:
[all …]
/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/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/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/python/cpython3/Lib/test/
Dtest_fileinput.py565 self._orig_state = fileinput._state
571 fileinput._state = self._orig_state
591 fileinput._state = instance
595 self.assertIs(instance, fileinput._state, "fileinput._state")
605 fileinput._state = instance
614 fileinput._state = None
635 self.assertIs(result, fileinput._state, "fileinput._state")
652 fileinput._state = None
654 self.assertIsNone(fileinput._state)
660 fileinput._state = instance
[all …]
/external/python/cpython2/Lib/multiprocessing/
Dpool.py143 self._state = RUN
168 self._worker_handler._state = RUN
178 self._task_handler._state = RUN
186 self._result_handler._state = RUN
245 assert self._state == RUN
252 assert self._state == RUN
259 assert self._state == RUN
277 assert self._state == RUN
295 assert self._state == RUN
304 assert self._state == RUN
[all …]
/external/python/cpython3/Lib/multiprocessing/
Dpool.py161 self._state = RUN
183 self._worker_handler._state = RUN
193 self._task_handler._state = RUN
201 self._result_handler._state = RUN
301 if self._state != RUN:
331 if self._state != RUN:
361 if self._state != RUN:
380 if self._state != RUN:
411 while thread._state == RUN or (pool._cache and thread._state != TERMINATE):
427 if thread._state:
[all …]

12345