WebSocket |
Connectable.call() |
|
private void |
WebSocket.changeStateOnConnect() |
|
protected abstract byte[] |
PerMessageCompressionExtension.compress(byte[] plain) |
Compress the plain message.
|
protected byte[] |
PerMessageDeflateExtension.compress(byte[] plain) |
|
private int |
PerMessageDeflateExtension.computeWindowSize(java.lang.String key,
java.lang.String value) |
|
java.net.Socket |
SocketConnector.connect() |
|
WebSocket |
WebSocket.connect() |
Connect to the server, send an opening handshake to the server,
receive the response and then start threads to communicate with
the server.
|
private void |
SocketConnector.connectSocket() |
|
protected abstract byte[] |
PerMessageCompressionExtension.decompress(byte[] compressed) |
Decompress the compressed message.
|
protected byte[] |
PerMessageDeflateExtension.decompress(byte[] compressed) |
|
private void |
SocketConnector.doConnect() |
|
private void |
WritingThread.doFlush() |
|
private int |
PerMessageDeflateExtension.extractMaxWindowBits(java.lang.String key,
java.lang.String value) |
|
private long |
WritingThread.flushIfLongInterval(long lastFlushAt) |
|
java.net.Socket |
SocketConnector.getConnectedSocket() |
|
java.net.Socket |
WebSocket.getConnectedSocket() |
Get the raw socket which this WebSocket uses internally.
|
private void |
SocketConnector.handshake() |
Perform proxy handshake and optionally SSL handshake.
|
private WebSocketInputStream |
WebSocket.openInputStream(java.net.Socket socket) |
Open the input stream of the WebSocket connection.
|
private WebSocketOutputStream |
WebSocket.openOutputStream(java.net.Socket socket) |
Open the output stream of the WebSocket connection.
|
(package private) void |
WebSocketInputStream.readBytes(byte[] buffer,
int length) |
|
WebSocketFrame |
WebSocketInputStream.readFrame() |
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
HandshakeReader.readHandshake(WebSocketInputStream input,
java.lang.String key) |
|
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
WebSocket.readHandshake(WebSocketInputStream input,
java.lang.String key) |
Receive an opening handshake response from the WebSocket server.
|
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
HandshakeReader.readHttpHeaders(WebSocketInputStream input) |
|
private byte[] |
WebSocketInputStream.readPayload(long payloadLength,
boolean mask,
byte[] maskingKey) |
|
private StatusLine |
HandshakeReader.readStatusLine(WebSocketInputStream input) |
Read a status line from an HTTP server.
|
private java.net.InetAddress[] |
SocketConnector.resolveHostname() |
|
private void |
WritingThread.sendFrame(WebSocketFrame frame) |
|
private void |
WritingThread.sendFrames(boolean last) |
|
private void |
SocketConnector.setSoTimeout(int timeout) |
|
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
WebSocket.shakeHands(java.net.Socket socket) |
Perform the opening handshake.
|
(package private) void |
PerMessageDeflateExtension.validate() |
|
(package private) void |
WebSocketExtension.validate() |
Validate this instance.
|
private void |
HandshakeReader.validateAccept(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers,
java.lang.String key) |
Validate the value of Sec-WebSocket-Accept header.
|
private void |
HandshakeReader.validateConnection(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers) |
Validate the value of Connection header.
|
private void |
HandshakeReader.validateExtensionCombination(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers,
java.util.List<WebSocketExtension> extensions) |
|
private void |
HandshakeReader.validateExtensions(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers) |
Validate the value of Sec-WebSocket-Extensions header.
|
private void |
PerMessageDeflateExtension.validateParameter(java.lang.String key,
java.lang.String value) |
|
private void |
HandshakeReader.validateProtocol(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers) |
Validate the value of Sec-WebSocket-Protocol header.
|
private void |
HandshakeReader.validateStatusLine(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers,
WebSocketInputStream input) |
Validate the status line.
|
private void |
HandshakeReader.validateUpgrade(StatusLine statusLine,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers) |
Validate the value of Upgrade header.
|
private void |
ReadingThread.verifyFrame(WebSocketFrame frame) |
|
private void |
ReadingThread.verifyFrameFragmentation(WebSocketFrame frame) |
|
private void |
ReadingThread.verifyFrameMask(WebSocketFrame frame) |
Ensure that the given frame is not masked.
|
private void |
ReadingThread.verifyFrameOpcode(WebSocketFrame frame) |
Ensure that the opcode of the give frame is a known one.
|
private void |
ReadingThread.verifyFrameSize(WebSocketFrame frame) |
|
private void |
ReadingThread.verifyReservedBit1(WebSocketFrame frame) |
Verify the RSV1 bit of a frame.
|
private boolean |
ReadingThread.verifyReservedBit1ForPMCE(WebSocketFrame frame) |
Verify the RSV1 bit of a frame using the rule described in RFC 7692.
|
private void |
ReadingThread.verifyReservedBit2(WebSocketFrame frame) |
Verify the RSV2 bit of a frame.
|
private void |
ReadingThread.verifyReservedBit3(WebSocketFrame frame) |
Verify the RSV3 bit of a frame.
|
private void |
ReadingThread.verifyReservedBits(WebSocketFrame frame) |
|
private void |
WebSocket.writeHandshake(WebSocketOutputStream output,
java.lang.String key) |
Send an opening handshake request to the WebSocket server.
|