Searched refs:_endp (Results 1 - 25 of 29) sorted by relevance

12

/external/jetty/src/java/org/eclipse/jetty/io/
H A DAbstractConnection.java32 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
[all...]
/external/jetty/src/java/org/eclipse/jetty/client/
H A DSelectConnector.java251 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
[all...]
H A DBlockingHttpConnection.java76 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);
H A DAsyncHttpConnection.java71 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();
H A DAbstractHttpConnection.java117 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/server/
H A DBlockingHttpConnection.java66 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();
H A DAsyncHttpConnection.java86 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
[all...]
H A DRequest.java197 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();
943 return _endp == null?null:_endp
[all...]
/external/jetty/src/java/org/eclipse/jetty/websocket/
H A DWebSocketConnectionD00.java59 _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 instanceo
[all...]
H A DWebSocketGeneratorD00.java39 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);
H A DWebSocketGeneratorD06.java38 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);
H A DWebSocketConnectionRFC6455.java163 _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
[all...]
H A DWebSocketConnectionD08.java131 _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
[all...]
H A DWebSocketConnectionD06.java114 _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 instanceo
[all...]
H A DWebSocketGeneratorD08.java37 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);
H A DWebSocketGeneratorRFC6455.java41 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);
H A DWebSocketClientFactory.java355 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
[all...]
H A DWebSocketParserD00.java48 private final EndPoint _endp; field in class:WebSocketParserD00
66 _endp=endp;
115 int filled=_endp.isOpen()?_endp.fill(_buffer):-1;
H A DWebSocketParserD08.java58 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);
H A DWebSocketParserRFC6455.java58 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);
H A DWebSocketParserD06.java59 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/
H A DSslConnection.java257 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
[all...]
/external/jetty/src/java/org/eclipse/jetty/http/
H A DAbstractGenerator.java56 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();
H A DHttpParser.java66 private final EndPoint _endp; field in class:HttpParser
95 _endp=null;
115 _endp=endp;
968 _endp.close();
977 _endp.close();
1026 if (_endp != null )
1037 LOG.warn("HttpParser Full for {} ",_endp);
1044 int filled = _endp.fill(_buffer);
1062 _state=_persistent?STATE_START:(_endp.isInputShutdown()?STATE_END:STATE_SEEKING_EOF);
1190 while(_contentView.length() == 0 && !(isState(HttpParser.STATE_END)||isState(HttpParser.STATE_SEEKING_EOF)) && _endp!
[all...]
H A 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 && (_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
[all...]

Completed in 1470 milliseconds

12