Home
last modified time | relevance | path

Searched refs:_endp (Results 1 – 25 of 28) sorted by relevance

12

/external/jetty/src/java/org/eclipse/jetty/client/
DSelectConnector.java251 AsyncEndPoint _endp; field in SelectConnector.UpgradableEndPoint
257 _endp=endp; in UpgradableEndPoint()
262 AsyncHttpConnection connection = (AsyncHttpConnection)_endp.getConnection(); in upgrade()
264 SslConnection sslConnection = new SslConnection(_engine,_endp); in upgrade()
265 _endp.setConnection(sslConnection); in upgrade()
267 _endp=sslConnection.getSslEndPoint(); in upgrade()
276 return _endp.getConnection(); in getConnection()
281 _endp.setConnection(connection); in setConnection()
286 _endp.shutdownOutput(); in shutdownOutput()
291 _endp.asyncDispatch(); in dispatch()
[all …]
DBlockingHttpConnection.java76 LOG.debug("onIdleExpired {}ms {} {}",idleForMs,this,_endp); in onIdleExpired()
78 _endp.close(); in onIdleExpired()
86 _endp.close(); in onIdleExpired()
111 while (_endp.isOpen() && connection==this) in handle()
113 LOG.debug("open={} more={}",_endp.isOpen(),_parser.isMoreInBuffer()); in handle()
196 _endp.flush(); in handle()
233 LOG.debug("{}",_endp); in handle()
243 … _endp.setMaxIdleTime((int)_destination.getHttpClient().getIdleTimeout()); in handle()
261 Connection switched=exchange.onSwitchProtocol(_endp); in handle()
DAsyncHttpConnection.java71 … LOG.debug("while open={} more={} progress={}",_endp.isOpen(),_parser.isMoreInBuffer(),progress); in handle()
142 _endp.flush(); in handle()
185 LOG.debug("finally {} on {} progress={} {}",exchange,this,progress,_endp); in handle()
195 … _endp.setMaxIdleTime((int)_destination.getHttpClient().getIdleTimeout()); in handle()
213 Connection switched=exchange.onSwitchProtocol(_endp); in handle()
249 LOG.debug("unhandle {} on {}",_exchange,_endp); in handle()
258 _endp.shutdownOutput(); in onInputShutdown()
DAbstractHttpConnection.java117 if (!_endp.isOpen()) in send()
143 long endPointTimeout = _endp.getMaxIdleTime(); in adjustIdleTimeout()
150 _endp.setMaxIdleTime(2 * (int)timeout); in adjustIdleTimeout()
275 _endp.close(); in startResponse()
390 if (_endp.isInputShutdown() && _parser.isState(HttpParser.STATE_EOF_CONTENT)) in close()
394 …String reason = _endp.isOpen()?(_endp.isInputShutdown()?"half closed: ":"local close: "):"closed: … in close()
400 if (_endp.isOpen()) in close()
402 _endp.close(); in close()
470 AggregateLifeCycle.dump(out,indent,Collections.singletonList(_endp)); in dump()
/external/jetty/src/java/org/eclipse/jetty/io/
DAbstractConnection.java32 protected final EndPoint _endp; field in AbstractConnection
36 _endp=(EndPoint)endp; in AbstractConnection()
42 _endp=(EndPoint)endp; in AbstractConnection()
53 return _endp; in getEndPoint()
60 LOG.debug("onIdleExpired {}ms {} {}",idleForMs,this,_endp); in onIdleExpired()
61 if (_endp.isInputShutdown() || _endp.isOutputShutdown()) in onIdleExpired()
62 _endp.close(); in onIdleExpired()
64 _endp.shutdownOutput(); in onIdleExpired()
72 _endp.close(); in onIdleExpired()
/external/jetty/src/java/org/eclipse/jetty/websocket/
DWebSocketConnectionD00.java59 _endp.setMaxIdleTime(maxIdleTime); in WebSocketConnectionD00()
64 _generator = new WebSocketGeneratorD00(buffers, _endp); in WebSocketConnectionD00()
104 while(_endp.isOpen()) in handle()
112 _endp.flush(_hixieBytes); in handle()
114 _endp.flush(); in handle()
119 int filled=_endp.fill(_hixieBytes); in handle()
122 _endp.flush(); in handle()
123 _endp.close(); in handle()
146 _endp.flush(); in handle()
148 if (_endp instanceof AsyncEndPoint && ((AsyncEndPoint)_endp).hasProgressed()) in handle()
[all …]
DWebSocketConnectionD08.java131 _endp.setMaxIdleTime(maxIdleTime); in WebSocketConnectionD08()
138 _generator = new WebSocketGeneratorD08(buffers, _endp,maskgen); in WebSocketConnectionD08()
196 _endp.flush(); in handle()
198 if (_endp instanceof AsyncEndPoint && ((AsyncEndPoint)_endp).hasProgressed()) in handle()
206 if (_endp.isOpen()) in handle()
207 _endp.close(); in handle()
220 if (_endp.isOpen()) in handle()
223 _endp.close(); in handle()
224 else if (_endp.isInputShutdown() && !_closedIn) in handle()
237 _endp.close(); in onInputShutdown()
[all …]
DWebSocketConnectionRFC6455.java163 _endp.setMaxIdleTime(maxIdleTime); in WebSocketConnectionRFC6455()
170 _generator = new WebSocketGeneratorRFC6455(buffers, _endp,maskgen); in WebSocketConnectionRFC6455()
228 _endp.flush(); in handle()
230 if (_endp instanceof AsyncEndPoint && ((AsyncEndPoint)_endp).hasProgressed()) in handle()
238 if (_endp.isOpen()) in handle()
239 _endp.close(); in handle()
252 if (_endp.isOpen()) in handle()
255 _endp.close(); in handle()
256 else if (_endp.isInputShutdown() && !_closedIn) in handle()
269 _endp.close(); in onInputShutdown()
[all …]
DWebSocketConnectionD06.java114 _endp.setMaxIdleTime(maxIdleTime); in WebSocketConnectionD06()
121 _generator = new WebSocketGeneratorD06(buffers, _endp,null); in WebSocketConnectionD06()
152 _endp.close(); in handle()
161 _endp.close(); in handle()
171 if (_endp.isOpen()) in handle()
174 _endp.close(); in handle()
175 else if (_endp.isInputShutdown() && !_closedIn) in handle()
223 _endp.close(); in closeIn()
244 _endp.close(); in closeOut()
283 if (!_generator.isBufferEmpty() && _endp instanceof AsyncEndPoint) in checkWriteable()
[all …]
DWebSocketGeneratorD06.java38 final private EndPoint _endp; field in WebSocketGeneratorD06
48 _endp=endp; in WebSocketGeneratorD06()
55 _endp=endp; in WebSocketGeneratorD06()
63 long blockFor=_endp.getMaxIdleTime(); in addFrame()
199 if (!_endp.isOpen()) in flushBuffer()
203 return _endp.flush(_buffer); in flushBuffer()
214 if (!_endp.isBlocking()) in expelBuffer()
218 boolean ready = _endp.blockWritable(blockFor); in expelBuffer()
DWebSocketGeneratorD00.java39 final private EndPoint _endp; field in WebSocketGeneratorD00
45 _endp=endp; in WebSocketGeneratorD00()
50 long blockFor=_endp.getMaxIdleTime(); in addFrame()
138 if (!_endp.isOpen())
142 return _endp.flush(_buffer);
153 if (!_endp.isBlocking())
157 boolean ready = _endp.blockWritable(blockFor);
DWebSocketGeneratorRFC6455.java41 private final EndPoint _endp; field in WebSocketGeneratorRFC6455
57 _endp = endp; in WebSocketGeneratorRFC6455()
212 if (!_endp.isOpen()) in flushBuffer()
217 int flushed = _buffer.hasContent() ? _endp.flush(_buffer) : 0; in flushBuffer()
219 _endp.shutdownOutput(); in flushBuffer()
242 if (!_endp.isBlocking()) in flush()
245 long end = now + _endp.getMaxIdleTime(); in flush()
248 boolean ready = _endp.blockWritable(end - now); in flush()
DWebSocketGeneratorD08.java37 private final EndPoint _endp; field in WebSocketGeneratorD08
53 _endp = endp; in WebSocketGeneratorD08()
208 if (!_endp.isOpen()) in flushBuffer()
213 int flushed = _buffer.hasContent() ? _endp.flush(_buffer) : 0; in flushBuffer()
215 _endp.shutdownOutput(); in flushBuffer()
238 if (!_endp.isBlocking()) in flush()
241 long end = now + _endp.getMaxIdleTime(); in flush()
244 boolean ready = _endp.blockWritable(end - now); in flush()
DWebSocketClientFactory.java355 private final AsyncEndPoint _endp; field in WebSocketClientFactory.HandshakeConnection
366 _endp = endpoint; in HandshakeConnection()
374 _parser = new HttpParser(buffers, _endp, new HttpParser.EventHandler() in HandshakeConnection()
382 _endp.close(); in HandshakeConnection()
398 _endp.close(); in HandshakeConnection()
406 _endp.close(); in HandshakeConnection()
462 int flushed = _endp.flush(_handshake); in handshake()
475 while (_endp.isOpen() && !_parser.isComplete()) in handle()
483 if (_endp.isInputShutdown()) in handle()
513 _endp.close(); in handle()
[all …]
DWebSocketParserD00.java48 private final EndPoint _endp; field in WebSocketParserD00
66 _endp=endp; in WebSocketParserD00()
115 int filled=_endp.isOpen()?_endp.fill(_buffer):-1; in parseNext()
DWebSocketParserRFC6455.java58 private final EndPoint _endp; field in WebSocketParserRFC6455
85 _endp=endp; in WebSocketParserRFC6455()
138 while(!progress && (!_endp.isInputShutdown()||_buffer.length()>0)) in parseNext()
181 filled=_endp.isInputShutdown()?-1:_endp.fill(_buffer); in parseNext()
219 LOG.warn("Fragmented Control from "+_endp); in parseNext()
DWebSocketParserD08.java58 private final EndPoint _endp; field in WebSocketParserD08
85 _endp=endp; in WebSocketParserD08()
138 while(!progress && (!_endp.isInputShutdown()||_buffer.length()>0)) in parseNext()
181 filled=_endp.isInputShutdown()?-1:_endp.fill(_buffer); in parseNext()
219 LOG.warn("Fragmented Control from "+_endp); in parseNext()
DWebSocketParserD06.java59 private final EndPoint _endp; field in WebSocketParserD06
83 _endp=endp; in WebSocketParserD06()
135 int filled=_endp.isOpen()?_endp.fill(_buffer):-1; in parseNext()
/external/jetty/src/java/org/eclipse/jetty/server/
DAsyncHttpConnection.java86 …if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown() && !_request… in handle()
91 _endp.flush(); in handle()
133 if (!_generator.isPersistent() && !_endp.isOutputShutdown()) in handle()
136 _endp.shutdownOutput(); in handle()
145 LOG.debug("Disabled read interest while writing response {}", _endp); in handle()
181 LOG.info("EndPoint making no progress: "+_total_no_progress+" "+_endp+" "+this); in handle()
184 … LOG.warn("Closing EndPoint making no progress: "+_total_no_progress+" "+_endp+" "+this); in handle()
185 if (_endp instanceof SelectChannelEndPoint) in handle()
186 ((SelectChannelEndPoint)_endp).getChannel().close(); in handle()
199 _endp.close(); in onInputShutdown()
[all …]
DBlockingHttpConnection.java66 while (_endp.isOpen() && connection==this) in handle()
71 if (!_parser.isComplete() && !_endp.isInputShutdown()) in handle()
78 … if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown()) in handle()
82 _endp.flush(); in handle()
94 _endp.shutdownOutput(); in handle()
113 if (!_generator.isPersistent() && !_endp.isOutputShutdown()) in handle()
116 _endp.shutdownOutput(); in handle()
121 …if (_endp.isInputShutdown() && _generator.isIdle() && !_request.getAsyncContinuation().isSuspended… in handle()
124 _endp.close(); in handle()
DRequest.java197 private EndPoint _endp; field in Request
665 return _endp == null?null:_endp.getLocalAddr(); in getLocalAddr()
754 if (_endp == null) in getLocalName()
757 return _endp.getLocalHost(); in getLocalName()
759 String local = _endp.getLocalAddr(); in getLocalName()
771 return _endp == null?0:_endp.getLocalPort(); in getLocalPort()
943 return _endp == null?null:_endp.getRemoteAddr(); in getRemoteAddr()
958 return _endp == null?null:_endp.getRemoteHost(); in getRemoteHost()
969 return _endp == null?0:_endp.getRemotePort(); in getRemotePort()
1196 _port = _endp == null?0:_endp.getLocalPort(); in getServerPort()
[all …]
/external/jetty/src/java/org/eclipse/jetty/io/nio/
DSslConnection.java257 if (_endp.isOutputShutdown()) in onIdleExpired()
333 if (_inbound.space()>0 && (filled=_endp.fill(_inbound))>0) in process()
337 if (_outbound.hasContent() && (flushed=_endp.flush(_outbound))>0) in process()
342 _endp.close(); in process()
385 _endp.close(); in process()
395 _endp.close(); in process()
399 _endp.shutdownInput(); in process()
408 if (_endp.isOpen() && _endp.isInputShutdown() && !_inbound.hasContent()) in process()
411 if (_endp.isOpen() && _engine.isOutboundDone() && !_outbound.hasContent()) in process()
412 _endp.shutdownOutput(); in process()
[all …]
/external/jetty/src/java/org/eclipse/jetty/http/
DAbstractGenerator.java56 protected final EndPoint _endp; field in AbstractGenerator
92 this._endp = io; in AbstractGenerator()
104 return _endp.isOpen(); in isOpen()
445 …ll && content.length()>0 ||buffer!=null && buffer.length()>0) && _endp.isOpen()&& !_endp.isOutputS… in flush()
508 if (_endp.isBlocking()) in blockForOutput()
516 _endp.close(); in blockForOutput()
522 if (!_endp.blockWritable(maxIdleTime)) in blockForOutput()
524 _endp.close(); in blockForOutput()
DHttpParser.java66 private final EndPoint _endp; field in HttpParser
95 _endp=null; in HttpParser()
115 _endp=endp; in HttpParser()
968 _endp.close(); in parseNext()
977 _endp.close(); in parseNext()
1026 if (_endp != null ) in fill()
1037 LOG.warn("HttpParser Full for {} ",_endp); in fill()
1044 int filled = _endp.fill(_buffer); in fill()
1062 _state=_persistent?STATE_START:(_endp.isInputShutdown()?STATE_END:STATE_SEEKING_EOF); in reset()
1190 …ate(HttpParser.STATE_END)||isState(HttpParser.STATE_SEEKING_EOF)) && _endp!=null && _endp.isOpen()) in blockForContent()
[all …]
DHttpGenerator.java135 if (_persistent!=null && !_persistent && _endp!=null && !_endp.isOutputShutdown())
139 _endp.shutdownOutput();
189 if (_endp.isOutputShutdown())
223 …else if (_endp != null && (_buffer==null || _buffer.length()==0) && _content.length() > 0 && (_las…
332 int len = _endp.flush(_header); in send1xx()
813 if (_endp == null) in flushBuffer()
838 len = _endp.flush(_header, _buffer, null); in flushBuffer()
841 len = _endp.flush(_header, _content, null); in flushBuffer()
844 len = _endp.flush(_header); in flushBuffer()
847 len = _endp.flush(_buffer, _content, null); in flushBuffer()
[all …]

12