Home
last modified time | relevance | path

Searched refs:WebSocketConnectionRFC6455 (Results 1 – 10 of 10) sorted by relevance

/external/jetty/src/java/org/eclipse/jetty/websocket/
DWebSocketConnectionRFC6455.java68 public class WebSocketConnectionRFC6455 extends AbstractConnection implements WebSocketConnection class
70 private static final Logger LOG = Log.getLogger(WebSocketConnectionRFC6455.class);
148 …public WebSocketConnectionRFC6455(WebSocket websocket, EndPoint endpoint, WebSocketBuffers buffers… in WebSocketConnectionRFC6455() method in WebSocketConnectionRFC6455
155 …public WebSocketConnectionRFC6455(WebSocket websocket, EndPoint endpoint, WebSocketBuffers buffers… in WebSocketConnectionRFC6455() method in WebSocketConnectionRFC6455
282 …closeOut(WebSocketConnectionRFC6455.CLOSE_NORMAL,"Idle for "+idleForMs+"ms > "+_endp.getMaxIdleTim… in onIdleExpired()
299 _closeCode=WebSocketConnectionRFC6455.CLOSE_NO_CLOSE; in onClose()
302 _webSocket.onClose(WebSocketConnectionRFC6455.CLOSE_NO_CLOSE,"closed"); in onClose()
369 …if (code < 0 || (code == WebSocketConnectionRFC6455.CLOSE_NO_CODE) || (code == WebSocketConnection… in closeOut()
370 || (code == WebSocketConnectionRFC6455.CLOSE_FAILED_TLS_HANDSHAKE)) in closeOut()
376 code = WebSocketConnectionRFC6455.CLOSE_NORMAL; in closeOut()
[all …]
DWebSocketParserRFC6455.java169 … _handler.onFrame((byte)(_flags&(0xff^WebSocketConnectionRFC6455.FLAG_FIN)), _opcode, data); in parseNext()
171 _opcode=WebSocketConnectionRFC6455.OP_CONTINUATION; in parseNext()
207 … _state=_opcode==WebSocketConnectionRFC6455.OP_CLOSE?State.SEEK_EOF:State.OPCODE; in parseNext()
217 …if (WebSocketConnectionRFC6455.isControlFrame(_opcode)&&!WebSocketConnectionRFC6455.isLastFrame(_f… in parseNext()
220 … _handler.close(WebSocketConnectionRFC6455.CLOSE_PROTOCOL,"Fragmented control"); in parseNext()
262 …_handler.close(WebSocketConnectionRFC6455.CLOSE_POLICY_VIOLATION,"frame size "+_length+">"+_buffer… in parseNext()
281 …_handler.close(WebSocketConnectionRFC6455.CLOSE_POLICY_VIOLATION,"frame size "+_length+">"+_buffer… in parseNext()
331 _handler.close(WebSocketConnectionRFC6455.CLOSE_PROTOCOL,"Not masked"); in parseNext()
DWebSocketFactory.java88 this(acceptor, 64 * 1024, WebSocketConnectionRFC6455.VERSION); in WebSocketFactory()
93 this(acceptor, bufferSize, WebSocketConnectionRFC6455.VERSION); in WebSocketFactory()
100 _minVersion=WebSocketConnectionRFC6455.VERSION; in WebSocketFactory()
280 case WebSocketConnectionRFC6455.VERSION: // RFC 6455 Version in upgrade()
282 …initExtensions(extensions_requested, 8 - WebSocketConnectionRFC6455.OP_EXT_DATA, 16 - WebSocketCon… in upgrade()
DWebSocketGeneratorRFC6455.java81 if (opcode == WebSocketConnectionRFC6455.OP_CLOSE) in addFrame()
89 boolean last = WebSocketConnectionRFC6455.isLastFrame(flags); in addFrame()
95 opcode = _opsent ? WebSocketConnectionRFC6455.OP_CONTINUATION : opcode; in addFrame()
DWebSocketClient.java460 … closeChannel(channel,WebSocketConnectionRFC6455.CLOSE_PROTOCOL,ex.getMessage()); in handshakeFailed()
462 … closeChannel(channel,WebSocketConnectionRFC6455.CLOSE_NO_CLOSE,ex.getMessage()); in handshakeFailed()
528 closeChannel(channel,WebSocketConnectionRFC6455.CLOSE_NO_CLOSE,"cancelled"); in cancel()
588 closeChannel(channel,WebSocketConnectionRFC6455.CLOSE_NO_CLOSE,"timeout"); in get()
DWebSocketClientFactory.java436 …request.append("Sec-WebSocket-Version: ").append(WebSocketConnectionRFC6455.VERSION).append("\r\n"… in handshake()
494 else if (!WebSocketConnectionRFC6455.hashKey(_key).equals(_accept)) in handle()
529 WebSocketConnectionRFC6455.VERSION, in newWebSocketConnection()
557 private static class WebSocketClientConnection extends WebSocketConnectionRFC6455
DWebSocketServletConnectionRFC6455.java28 public class WebSocketServletConnectionRFC6455 extends WebSocketConnectionRFC6455 implements WebSoc…
DDeflateFrameExtension.java108 getConnection().close(WebSocketConnectionRFC6455.CLOSE_BAD_PAYLOAD,e.toString()); in onFrame()
DWebSocketGeneratorD08.java77 if (opcode == WebSocketConnectionRFC6455.OP_CLOSE) in addFrame()
DWebSocketConnectionD08.java774 … errorClose(WebSocketConnectionRFC6455.CLOSE_SERVER_ERROR,"Internal Server Error: "+e); in onFrame()