| /external/jetty/src/java/org/eclipse/jetty/client/ |
| SelectConnector.java | 251 AsyncEndPoint _endp; field in class:SelectConnector.UpgradableEndPoint
257 _endp=endp;
262 AsyncHttpConnection connection = (AsyncHttpConnection)_endp.getConnection();
264 SslConnection sslConnection = new SslConnection(_engine,_endp);
265 _endp.setConnection(sslConnection);
267 _endp=sslConnection.getSslEndPoint();
276 return _endp.getConnection();
281 _endp.setConnection(connection);
286 _endp.shutdownOutput();
291 _endp.asyncDispatch()
[all...] |
| BlockingHttpConnection.java | 76 LOG.debug("onIdleExpired {}ms {} {}",idleForMs,this,_endp);
78 _endp.close();
86 _endp.close();
111 while (_endp.isOpen() && connection==this)
113 LOG.debug("open={} more={}",_endp.isOpen(),_parser.isMoreInBuffer());
196 _endp.flush();
233 LOG.debug("{}",_endp);
243 _endp.setMaxIdleTime((int)_destination.getHttpClient().getIdleTimeout());
261 Connection switched=exchange.onSwitchProtocol(_endp);
|
| AsyncHttpConnection.java | 71 LOG.debug("while open={} more={} progress={}",_endp.isOpen(),_parser.isMoreInBuffer(),progress);
142 _endp.flush();
185 LOG.debug("finally {} on {} progress={} {}",exchange,this,progress,_endp);
195 _endp.setMaxIdleTime((int)_destination.getHttpClient().getIdleTimeout());
213 Connection switched=exchange.onSwitchProtocol(_endp);
249 LOG.debug("unhandle {} on {}",_exchange,_endp);
258 _endp.shutdownOutput();
|
| AbstractHttpConnection.java | 117 if (!_endp.isOpen())
143 long endPointTimeout = _endp.getMaxIdleTime();
150 _endp.setMaxIdleTime(2 * (int)timeout);
275 _endp.close();
390 if (_endp.isInputShutdown() && _parser.isState(HttpParser.STATE_EOF_CONTENT))
394 String reason = _endp.isOpen()?(_endp.isInputShutdown()?"half closed: ":"local close: "):"closed: ";
400 if (_endp.isOpen())
402 _endp.close();
470 AggregateLifeCycle.dump(out,indent,Collections.singletonList(_endp));
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/io/ |
| AbstractConnection.java | 32 protected final EndPoint _endp; field in class:AbstractConnection
36 _endp=(EndPoint)endp;
42 _endp=(EndPoint)endp;
53 return _endp;
60 LOG.debug("onIdleExpired {}ms {} {}",idleForMs,this,_endp);
61 if (_endp.isInputShutdown() || _endp.isOutputShutdown())
62 _endp.close();
64 _endp.shutdownOutput();
72 _endp.close()
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/server/ |
| BlockingHttpConnection.java | 66 while (_endp.isOpen() && connection==this)
71 if (!_parser.isComplete() && !_endp.isInputShutdown())
78 if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown())
82 _endp.flush();
94 _endp.shutdownOutput();
113 if (!_generator.isPersistent() && !_endp.isOutputShutdown())
116 _endp.shutdownOutput();
121 if (_endp.isInputShutdown() && _generator.isIdle() && !_request.getAsyncContinuation().isSuspended())
124 _endp.close();
|
| AsyncHttpConnection.java | 86 if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown() && !_request.getAsyncContinuation().isAsyncStarted())
91 _endp.flush();
133 if (!_generator.isPersistent() && !_endp.isOutputShutdown())
136 _endp.shutdownOutput();
145 LOG.debug("Disabled read interest while writing response {}", _endp);
181 LOG.info("EndPoint making no progress: "+_total_no_progress+" "+_endp+" "+this);
184 LOG.warn("Closing EndPoint making no progress: "+_total_no_progress+" "+_endp+" "+this);
185 if (_endp instanceof SelectChannelEndPoint)
186 ((SelectChannelEndPoint)_endp).getChannel().close();
199 _endp.close()
[all...] |
| Request.java | 197 private EndPoint _endp; field in class:Request
665 return _endp == null?null:_endp.getLocalAddr();
754 if (_endp == null)
757 return _endp.getLocalHost();
759 String local = _endp.getLocalAddr();
771 return _endp == null?0:_endp.getLocalPort();
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| WebSocketGeneratorD00.java | 39 final private EndPoint _endp; field in class:WebSocketGeneratorD00
45 _endp=endp;
50 long blockFor=_endp.getMaxIdleTime();
138 if (!_endp.isOpen())
142 return _endp.flush(_buffer);
153 if (!_endp.isBlocking())
157 boolean ready = _endp.blockWritable(blockFor);
|
| WebSocketGeneratorD06.java | 38 final private EndPoint _endp; field in class:WebSocketGeneratorD06
48 _endp=endp;
55 _endp=endp;
63 long blockFor=_endp.getMaxIdleTime();
199 if (!_endp.isOpen())
203 return _endp.flush(_buffer);
214 if (!_endp.isBlocking())
218 boolean ready = _endp.blockWritable(blockFor);
|
| WebSocketGeneratorD08.java | 37 private final EndPoint _endp; field in class:WebSocketGeneratorD08
53 _endp = endp;
208 if (!_endp.isOpen())
213 int flushed = _buffer.hasContent() ? _endp.flush(_buffer) : 0;
215 _endp.shutdownOutput();
238 if (!_endp.isBlocking())
241 long end = now + _endp.getMaxIdleTime();
244 boolean ready = _endp.blockWritable(end - now);
|
| WebSocketGeneratorRFC6455.java | 41 private final EndPoint _endp; field in class:WebSocketGeneratorRFC6455
57 _endp = endp;
212 if (!_endp.isOpen())
217 int flushed = _buffer.hasContent() ? _endp.flush(_buffer) : 0;
219 _endp.shutdownOutput();
242 if (!_endp.isBlocking())
245 long end = now + _endp.getMaxIdleTime();
248 boolean ready = _endp.blockWritable(end - now);
|
| WebSocketConnectionD00.java | 59 _endp.setMaxIdleTime(maxIdleTime);
64 _generator = new WebSocketGeneratorD00(buffers, _endp);
104 while(_endp.isOpen())
112 _endp.flush(_hixieBytes);
114 _endp.flush();
119 int filled=_endp.fill(_hixieBytes);
122 _endp.flush();
123 _endp.close();
146 _endp.flush();
148 if (_endp instanceof AsyncEndPoint && ((AsyncEndPoint)_endp).hasProgressed()
[all...] |
| WebSocketConnectionRFC6455.java | 163 _endp.setMaxIdleTime(maxIdleTime);
170 _generator = new WebSocketGeneratorRFC6455(buffers, _endp,maskgen);
228 _endp.flush();
230 if (_endp instanceof AsyncEndPoint && ((AsyncEndPoint)_endp).hasProgressed())
238 if (_endp.isOpen())
239 _endp.close();
252 if (_endp.isOpen())
255 _endp.close();
256 else if (_endp.isInputShutdown() && !_closedIn
[all...] |
| WebSocketConnectionD08.java | 131 _endp.setMaxIdleTime(maxIdleTime);
138 _generator = new WebSocketGeneratorD08(buffers, _endp,maskgen);
196 _endp.flush();
198 if (_endp instanceof AsyncEndPoint && ((AsyncEndPoint)_endp).hasProgressed())
206 if (_endp.isOpen())
207 _endp.close();
220 if (_endp.isOpen())
223 _endp.close();
224 else if (_endp.isInputShutdown() && !_closedIn
[all...] |
| WebSocketConnectionD06.java | 114 _endp.setMaxIdleTime(maxIdleTime);
121 _generator = new WebSocketGeneratorD06(buffers, _endp,null);
152 _endp.close();
161 _endp.close();
171 if (_endp.isOpen())
174 _endp.close();
175 else if (_endp.isInputShutdown() && !_closedIn)
223 _endp.close();
244 _endp.close();
283 if (!_generator.isBufferEmpty() && _endp instanceof AsyncEndPoint
[all...] |
| WebSocketClientFactory.java | 355 private final AsyncEndPoint _endp; field in class:WebSocketClientFactory.HandshakeConnection
366 _endp = endpoint;
374 _parser = new HttpParser(buffers, _endp, new HttpParser.EventHandler()
382 _endp.close();
398 _endp.close();
406 _endp.close();
462 int flushed = _endp.flush(_handshake);
475 while (_endp.isOpen() && !_parser.isComplete())
483 if (_endp.isInputShutdown())
513 _endp.close()
[all...] |
| WebSocketParserD08.java | 58 private final EndPoint _endp; field in class:WebSocketParserD08
85 _endp=endp;
138 while(!progress && (!_endp.isInputShutdown()||_buffer.length()>0))
181 filled=_endp.isInputShutdown()?-1:_endp.fill(_buffer);
219 LOG.warn("Fragmented Control from "+_endp);
|
| WebSocketParserRFC6455.java | 58 private final EndPoint _endp; field in class:WebSocketParserRFC6455
85 _endp=endp;
138 while(!progress && (!_endp.isInputShutdown()||_buffer.length()>0))
181 filled=_endp.isInputShutdown()?-1:_endp.fill(_buffer);
219 LOG.warn("Fragmented Control from "+_endp);
|
| WebSocketParserD00.java | 48 private final EndPoint _endp; field in class:WebSocketParserD00
66 _endp=endp;
115 int filled=_endp.isOpen()?_endp.fill(_buffer):-1;
|
| WebSocketParserD06.java | 59 private final EndPoint _endp; field in class:WebSocketParserD06
83 _endp=endp;
135 int filled=_endp.isOpen()?_endp.fill(_buffer):-1;
|
| /external/jetty/src/java/org/eclipse/jetty/io/nio/ |
| SslConnection.java | 257 if (_endp.isOutputShutdown())
333 if (_inbound.space()>0 && (filled=_endp.fill(_inbound))>0)
337 if (_outbound.hasContent() && (flushed=_endp.flush(_outbound))>0)
342 _endp.close();
385 _endp.close();
395 _endp.close();
399 _endp.shutdownInput();
408 if (_endp.isOpen() && _endp.isInputShutdown() && !_inbound.hasContent())
411 if (_endp.isOpen() && _engine.isOutboundDone() && !_outbound.hasContent()
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/http/ |
| HttpGenerator.java | 135 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 && (_last || isCommitted() && _content.length()>1024))
332 int len = _endp.flush(_header);
813 if (_endp == null)
838 len = _endp.flush(_header, _buffer, null);
841 len = _endp.flush(_header, _content, null);
844 len = _endp.flush(_header)
[all...] |
| HttpParser.java | 66 private final EndPoint _endp; field in class:HttpParser
95 _endp=null;
115 _endp=endp;
[all...] |
| AbstractGenerator.java | 56 protected final EndPoint _endp; field in class:AbstractGenerator
92 this._endp = io;
104 return _endp.isOpen();
445 while (now<end && (content!=null && content.length()>0 ||buffer!=null && buffer.length()>0) && _endp.isOpen()&& !_endp.isOutputShutdown())
508 if (_endp.isBlocking())
516 _endp.close();
522 if (!_endp.blockWritable(maxIdleTime))
524 _endp.close();
|
