Home
last modified time | relevance | path

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

1234

/external/jetty/src/java/org/eclipse/jetty/continuation/
DFauxContinuation.java54 private int _state=__HANDLING; field in FauxContinuation
116 switch(_state) in isSuspended()
160 switch(_state) in suspend()
165 _state=__SUSPENDING; in suspend()
178 throw new IllegalStateException(""+_state); in suspend()
193 switch(_state) in resume()
201 _state=__RESUMING; in resume()
211 _state=__UNSUSPENDING; in resume()
232 switch(_state) in complete()
238 _state=__COMPLETING; in complete()
[all …]
/external/jetty/src/java/org/eclipse/jetty/http/
DHttpParser.java80 protected int _state=STATE_START; field in HttpParser
145 return _state; in getState()
151 return _state > 0; in inContentState()
157 return _state < 0; in inHeaderState()
189 return _state == state; in isState()
202 if (!_persistent &&(_state==STATE_END || _state==STATE_START)) in setPersistent()
203 _state=STATE_SEEKING_EOF; in setPersistent()
214 if (_state==STATE_END) in parse()
216 if (_state!=STATE_START) in parse()
220 while (_state != STATE_END) in parse()
[all …]
DAbstractGenerator.java58 protected int _state = STATE_HEADER; field in AbstractGenerator
110 _state = STATE_HEADER; in reset()
145 if(_state>=STATE_FLUSHING) in resetBuffer()
206 return _state; in getState()
212 return _state == state; in isState()
218 return _state == STATE_END; in isComplete()
224 return _state == STATE_HEADER && _method==null && _status==0; in isIdle()
230 return _state != STATE_HEADER; in isCommitted()
285 if (_state != STATE_HEADER) in setVersion()
286 throw new IllegalStateException("STATE!=START "+_state); in setVersion()
[all …]
/external/jetty/src/java/org/eclipse/jetty/websocket/
DWebSocketParserD06.java62 private State _state; field in WebSocketParserD06
86 _state=State.START; in WebSocketParserD06()
123 while (available<(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
130 … throw new IllegalStateException("FULL: "+_state+" "+_bytesNeeded+">"+_buffer.capacity()); in parseNext()
152 while (_state!=State.DATA && available>=(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
154 switch (_state) in parseNext()
157 _state=_masked?State.MASK:State.OPCODE; in parseNext()
158 _bytesNeeded=_state.getNeeds(); in parseNext()
164 _state=State.OPCODE; in parseNext()
165 _bytesNeeded=_state.getNeeds(); in parseNext()
[all …]
DWebSocketParserD08.java61 private State _state; field in WebSocketParserD08
88 _state=State.START; in WebSocketParserD08()
143 while (available<(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
152 if (_fragmentFrames && _state==State.DATA) in parseNext()
175 … throw new IllegalStateException("FULL: "+_state+" "+_bytesNeeded+">"+_buffer.capacity()); in parseNext()
195 if (available<(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
201 while (_state!=State.DATA && available>=(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
203 switch (_state) in parseNext()
207 _state=_opcode==WebSocketConnectionD08.OP_CLOSE?State.SEEK_EOF:State.OPCODE; in parseNext()
208 _bytesNeeded=_state.getNeeds(); in parseNext()
[all …]
DWebSocketParserRFC6455.java61 private State _state; field in WebSocketParserRFC6455
88 _state=State.START; in WebSocketParserRFC6455()
143 while (available<(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
152 if (_fragmentFrames && _state==State.DATA) in parseNext()
175 … throw new IllegalStateException("FULL: "+_state+" "+_bytesNeeded+">"+_buffer.capacity()); in parseNext()
195 if (available<(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
201 while (_state!=State.DATA && available>=(_state==State.SKIP?1:_bytesNeeded)) in parseNext()
203 switch (_state) in parseNext()
207 … _state=_opcode==WebSocketConnectionRFC6455.OP_CLOSE?State.SEEK_EOF:State.OPCODE; in parseNext()
208 _bytesNeeded=_state.getNeeds(); in parseNext()
[all …]
DWebSocketParserD00.java50 private int _state; field in WebSocketParserD00
103 if (length == 0 || _state==STATE_DATA && length<_length) in parseNext()
133 switch (_state) in parseNext()
141 _state=STATE_LENGTH; in parseNext()
145 _state=STATE_SENTINEL_DATA; in parseNext()
154 _state=STATE_START; in parseNext()
173 _state=STATE_DATA; in parseNext()
184 _state=STATE_START; in parseNext()
/external/jetty/src/java/org/eclipse/jetty/server/
DAsyncContinuation.java90 private int _state; field in AsyncContinuation
103 _state=__IDLE; in AsyncContinuation()
216 switch(_state) in isSuspended()
235 switch(_state) in isSuspending()
252 switch(_state) in isDispatchable()
282 ((_state==__IDLE)?"IDLE": in getStatusString()
283 (_state==__DISPATCHED)?"DISPATCHED": in getStatusString()
284 (_state==__ASYNCSTARTED)?"ASYNCSTARTED": in getStatusString()
285 (_state==__ASYNCWAIT)?"ASYNCWAIT": in getStatusString()
286 (_state==__REDISPATCHING)?"REDISPATCHING": in getStatusString()
[all …]
/external/antlr/antlr-3.4/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/jetty/src/java/org/eclipse/jetty/util/component/
DAbstractLifeCycle.java43 private volatile int _state = __STOPPED; field in AbstractLifeCycle
61 if (_state == __STARTED || _state == __STARTING) in start()
86 if (_state == __STOPPING || _state == __STOPPED) in stop()
107 final int state = _state; in isRunning()
114 return _state == __STARTED; in isStarted()
119 return _state == __STARTING; in isStarting()
124 return _state == __STOPPING; in isStopping()
129 return _state == __STOPPED; in isStopped()
134 return _state == __FAILED; in isFailed()
149 switch(_state) in getState()
[all …]
/external/autotest/scheduler/
Dpidfile_monitor.py42 self._state = drone_manager.PidfileContents()
87 return self._state.process is not None
92 assert self._state.process is not None
93 return self._state.process
102 self._state = drone_manager.PidfileContents()
104 self._state = contents
110 'process': str(self._state.process),
114 self.on_lost_process(self._state.process)
123 if self._state.process is None:
127 if self._state.exit_status is None:
[all …]
/external/tpm2/generator/
Dextract_structures.py40 self._state = self.ANCHOR
66 if self._state != new_state:
67 self._state = new_state
99 if self._state == self.ANCHOR:
101 elif self._state == self.MAYBE_DONE:
106 elif self._state == self.TABLE_NAME:
108 elif tag == 'p' and self._state == self.TABLE_NAME and not self._title:
111 elif self._state == self.TABLE_NAME and tag == 'table':
125 elif self._state == self.MAYBE_DONE and tag == 'tr':
127 elif self._state == self.SKIP_HEADER and tag == 'tr':
[all …]
/external/lzma/CPP/7zip/Compress/
DLzmaDecoder.cpp35 LzmaDec_Construct(&_state); in CDecoder()
44 LzmaDec_Free(&_state, &g_Alloc); in ~CDecoder()
66 RINOK(SResToHRESULT(LzmaDec_Allocate(&_state, prop, size, &g_Alloc))); in SetDecoderProperties2()
78 LzmaDec_Init(&_state); in SetOutStreamSizeResume()
97 …SizeT next = (_state.dicBufSize - _state.dicPos < _outBufSize) ? _state.dicBufSize : (_state.dicPo… in CodeSpec()
106 SizeT dicPos = _state.dicPos; in CodeSpec()
123 …SRes res = LzmaDec_DecodeToDic(&_state, dicPos + curSize, _inBuf + _inPos, &inSizeProcessed, finis… in CodeSpec()
127 SizeT outSizeProcessed = _state.dicPos - dicPos; in CodeSpec()
133 if (res != 0 || _state.dicPos == next || finished || stopDecoding) in CodeSpec()
135 HRESULT res2 = WriteStream(outStream, _state.dic + _wrPos, _state.dicPos - _wrPos); in CodeSpec()
[all …]
DLzma2Decoder.cpp31 Lzma2Dec_Construct(&_state); in CDecoder()
40 Lzma2Dec_Free(&_state, &g_Alloc); in ~CDecoder()
47 RINOK(SResToHRESULT(Lzma2Dec_Allocate(&_state, prop[0], &g_Alloc))); in SetDecoderProperties2()
68 Lzma2Dec_Init(&_state); in SetOutStreamSize()
91 SizeT dicPos = _state.decoder.dicPos; in Code()
92 SizeT curSize = _state.decoder.dicBufSize - dicPos; in Code()
113 …SRes res = Lzma2Dec_DecodeToDic(&_state, dicPos + curSize, _inBuf + _inPos, &inSizeProcessed, fini… in Code()
117 SizeT outSizeProcessed = _state.decoder.dicPos - dicPos; in Code()
123 if (res != 0 || _state.decoder.dicPos == _state.decoder.dicBufSize || finished || stopDecoding) in Code()
125 HRESULT res2 = WriteStream(outStream, _state.decoder.dic, _state.decoder.dicPos); in Code()
[all …]
/external/jmdns/src/javax/jmdns/impl/
DDNSStatefulObject.java113 protected volatile DNSState _state; field in DNSStatefulObject.DefaultImplementation
123 _state = DNSState.PROBING_1; in DefaultImplementation()
145 if (this._task == null && this._state == state) { in associateWithTask()
148 if (this._task == null && this._state == state) { in associateWithTask()
181 return this._task == task && this._state == state; in isAssociatedWithTask()
198 this._state = state; in setState()
222 this.setState(this._state.advance()); in advanceState()
243 this.setState(this._state.revert()); in revertState()
316 return this._state.isProbing(); in isProbing()
324 return this._state.isAnnouncing(); in isAnnouncing()
[all …]
DHostInfo.java41 private final HostInfoState _state; field in HostInfo
123 this._state = new HostInfoState(dns); in HostInfo()
265 buf.append(_state); in toString()
288 return this._state.getDns(); in getDns()
296 return this._state.advanceState(task); in advanceState()
304 this._state.removeAssociationWithTask(task); in removeAssociationWithTask()
312 return this._state.revertState(); in revertState()
320 this._state.associateWithTask(task, state); in associateWithTask()
328 return this._state.isAssociatedWithTask(task, state); in isAssociatedWithTask()
336 return this._state.cancelState(); in cancelState()
[all …]
/external/jetty/src/java/org/eclipse/jetty/util/
DUtf8Appendable.java58 protected int _state = UTF8_ACCEPT; field in Utf8Appendable
96 _state = UTF8_ACCEPT; in reset()
147 if (b > 0 && _state == UTF8_ACCEPT) in appendByte()
155 _codep = _state == UTF8_ACCEPT ? (0xFF >> type) & i : (i & 0x3F) | (_codep << 6); in appendByte()
156 int next = TRANS_TABLE[_state + type]; in appendByte()
161 _state=next; in appendByte()
174 String reason = "byte "+TypeUtil.toHexString(b)+" in state "+(_state/12); in appendByte()
176 _state = UTF8_ACCEPT; in appendByte()
181 _state=next; in appendByte()
189 return _state == UTF8_ACCEPT; in isUtf8SequenceComplete()
[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/opencv3/3rdparty/openexr/Imath/
DImathRandom.h120 unsigned long int _state; variable
178 unsigned short int _state[3];
242 _state = (seed * 0xa5a573a5L) ^ 0x5a5a5a5aL; in init()
256 _state = 1664525L * _state + 1013904223L; in next()
265 return !!(_state & 2147483648UL); in nextb()
273 return _state & 0xffffffff; in nexti()
290 _state[0] = (unsigned short int) (seed & 0xFFFF); in init()
291 _state[1] = (unsigned short int) ((seed >> 16) & 0xFFFF); in init()
292 _state[2] = (unsigned short int) (seed & 0xFFFF); in init()
306 return Imath::nrand48 (_state) & 1; in nextb()
[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/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/jmdns/src/javax/jmdns/impl/constants/
DDNSState.java71 private final StateClass _state; field in DNSState
75 _state = state; in DNSState()
158 return _state == StateClass.probing; in isProbing()
167 return _state == StateClass.announcing; in isAnnouncing()
176 return _state == StateClass.announced; in isAnnounced()
185 return _state == StateClass.canceling; in isCanceling()
194 return _state == StateClass.canceled; in isCanceled()
203 return _state == StateClass.closing; in isClosing()
212 return _state == StateClass.closed; in isClosed()
/external/jetty/src/java/org/eclipse/jetty/io/nio/
DSelectChannelEndPoint.java71 private int _state; field in SelectChannelEndPoint
103 _state=STATE_UNDISPATCHED; in SelectChannelEndPoint()
178 if (_state<STATE_DISPATCHED) in schedule()
193 if (_state>=STATE_DISPATCHED) in schedule()
199 … if (_state>=STATE_DISPATCHED && !_selectSet.getManager().isDeferringInterestedOps0()) in schedule()
212 switch(_state) in asyncDispatch()
221 _state=STATE_ASYNC; in asyncDispatch()
232 if (_state<=STATE_UNDISPATCHED) in dispatch()
235 _state = STATE_NEEDS_DISPATCH; in dispatch()
238 _state = STATE_DISPATCHED; in dispatch()
[all …]
/external/autotest/client/cros/cellular/wardmodem/state_machines/
Dnetwork_operator_machine.py60 self._state['operator_index'] = self._default_operator_index
61 self._state['automatic_registration'] = 'TRUE'
62 self._state['access_technology'] = self._extract_technology(
110 operator_format = self._state['operator_format']
112 operator_index = self._state['operator_index']
114 if operator_index == self._state.INVALID_VALUE:
133 return self.TECHNOLOGY_CODE[self._state['access_technology']]
/external/opencv3/modules/videoio/src/cap_winrt/
DCaptureFrameGrabber.cpp56 reader->_state = State::Started; in __anon465aab420102()
62 : _state(State::Created)
74 if (_state == State::Started) in ~CaptureFrameGrabber()
98 if (_state == State::Started) in ShowCameraSettings()
109 if (_state != State::Started) in FinishAsync()
113 _state = State::Closing; in FinishAsync()
135 _state = State::Closed; in FinishAsync()
144 if (_state != State::Started) in GetFrameAsync()

1234