| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| AbstractExtension.java | 35 private WebSocketGenerator _outbound; field in class:AbstractExtension
79 _outbound=outgoing;
109 return _outbound.flush();
114 return _outbound.isBufferEmpty();
120 _outbound.addFrame(flags,opcode,content,offset,length);
|
| WebSocketConnectionD08.java | 84 private final WebSocketGenerator _outbound; field in class:WebSocketConnectionD08
155 _outbound=(_extensions==null||_extensions.size()==0)?_generator:extensions.get(extensions.size()-1);
222 if (_closedIn && _closedOut && _outbound.isBufferEmpty())
243 return _parser.isBufferEmpty() && _outbound.isBufferEmpty();
339 _outbound.addFrame((byte)FLAG_FIN,WebSocketConnectionD08.OP_CLOSE,bytes,0,bytes.length);
341 _outbound.flush();
367 if (!_outbound.isBufferEmpty() && _endp instanceof AsyncEndPoint)
397 _outbound.addFrame((byte)FLAG_FIN,WebSocketConnectionD08.OP_TEXT,data,0,data.length);
406 _outbound.addFrame((byte)FLAG_FIN,WebSocketConnectionD08.OP_BINARY,content,offset,length);
415 _outbound.addFrame(flags,opcode,content,offset,length)
[all...] |
| WebSocketConnectionRFC6455.java | 116 private final WebSocketGenerator _outbound; field in class:WebSocketConnectionRFC6455
187 _outbound=(_extensions==null||_extensions.size()==0)?_generator:extensions.get(extensions.size()-1);
254 if (_closedIn && _closedOut && _outbound.isBufferEmpty())
275 return _parser.isBufferEmpty() && _outbound.isBufferEmpty();
382 _outbound.addFrame((byte)FLAG_FIN,WebSocketConnectionRFC6455.OP_CLOSE,bytes,0,code>0?bytes.length:0);
383 _outbound.flush();
409 if (!_outbound.isBufferEmpty() && _endp instanceof AsyncEndPoint)
439 _outbound.addFrame((byte)FLAG_FIN,WebSocketConnectionRFC6455.OP_TEXT,data,0,data.length);
448 _outbound.addFrame((byte)FLAG_FIN,WebSocketConnectionRFC6455.OP_BINARY,content,offset,length);
457 _outbound.addFrame(flags,opcode,content,offset,length)
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/io/nio/ |
| SslConnection.java | 63 private NIOBuffer _outbound; field in class:SslConnection
148 _outbound=_buffers._out;
165 _outbound.length()==0 &&
169 _outbound=null;
337 if (_outbound.hasContent() && (flushed=_endp.flush(_outbound))>0)
347 _logger.debug("{} {} {} filled={}/{} flushed={}/{}",_session,this,_engine.getHandshakeStatus(),filled,_inbound.length(),flushed,_outbound.length());
363 if (toFlush.hasContent() && _outbound.space()>0 && wrap(toFlush))
411 if (_endp.isOpen() && _engine.isOutboundDone() && !_outbound.hasContent())
450 _outbound.compact()
[all...] |
| /prebuilts/tools/common/m2/repository/org/eclipse/jetty/jetty-websocket/8.1.14.v20131031/ |
| jetty-websocket-8.1.14.v20131031.jar | |
| /prebuilts/tools/common/m2/repository/org/eclipse/jetty/jetty-io/8.1.14.v20131031/ |
| jetty-io-8.1.14.v20131031.jar | |
