public class WebSocketConnectionD00 extends AbstractConnection implements WebSocketConnection, WebSocket.FrameConnection
| Modifier and Type | Field and Description |
|---|---|
static byte |
LENGTH_FRAME |
static byte |
SENTINEL_FRAME |
_endp| Constructor and Description |
|---|
WebSocketConnectionD00(WebSocket websocket,
EndPoint endpoint,
WebSocketBuffers buffers,
long timestamp,
int maxIdleTime,
String protocol) |
| Modifier and Type | Method and Description |
|---|---|
byte |
binaryOpcode() |
void |
close()
Close the connection with normal close code.
|
void |
close(int code,
String message)
Close the connection with specific closeCode and message.
|
byte |
continuationOpcode() |
void |
disconnect() |
static byte[] |
doTheHixieHixieShake(long key1,
long key2,
byte[] key3) |
void |
fillBuffersFrom(Buffer buffer) |
byte |
finMask() |
WebSocket.Connection |
getConnection() |
List<Extension> |
getExtensions() |
int |
getMaxBinaryMessageSize()
Size in bytes of the maximum binary message to be received
|
int |
getMaxIdleTime() |
int |
getMaxTextMessageSize()
Size in characters of the maximum text message to be received
|
String |
getProtocol() |
Connection |
handle()
Handle the connection.
|
boolean |
isAllowFrameFragmentation() |
boolean |
isBinary(byte opcode) |
boolean |
isClose(byte opcode) |
boolean |
isContinuation(byte opcode) |
boolean |
isControl(byte opcode) |
boolean |
isIdle() |
boolean |
isMessageComplete(byte flags) |
boolean |
isMore(byte flags) |
boolean |
isOpen() |
boolean |
isPing(byte opcode) |
boolean |
isPong(byte opcode) |
boolean |
isSuspended()
The semantic of this method is to return true to indicate interest in further reads,
or false otherwise, but it is misnamed and should be really called
isReadInterested(). |
boolean |
isText(byte opcode) |
void |
onClose()
Called after the connection is closed
|
protected void |
onFrameHandshake() |
void |
onInputShutdown() |
protected void |
onWebsocketOpen() |
void |
sendControl(byte code,
byte[] content,
int offset,
int length)
Send a control frame
|
void |
sendFrame(byte flags,
byte opcode,
byte[] content,
int offset,
int length)
Send an arbitrary frame
|
void |
sendMessage(byte[] data,
int offset,
int length) |
void |
sendMessage(String content) |
void |
setAllowFrameFragmentation(boolean allowFragmentation)
Set if frames larger than the frame buffer are handled with local fragmentations
|
void |
setHixieKeys(String key1,
String key2) |
void |
setMaxBinaryMessageSize(int size) |
void |
setMaxIdleTime(int ms) |
void |
setMaxTextMessageSize(int size) |
void |
shutdown() |
byte |
textOpcode() |
getEndPoint, getTimeStamp, onIdleExpired, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetTimeStamp, onIdleExpiredpublic static final byte LENGTH_FRAME
public static final byte SENTINEL_FRAME
public WebSocketConnectionD00(WebSocket websocket, EndPoint endpoint, WebSocketBuffers buffers, long timestamp, int maxIdleTime, String protocol) throws IOException
IOExceptionpublic WebSocket.Connection getConnection()
getConnection in interface WebSocketConnectionpublic Connection handle() throws IOException
Connectionhandle in interface ConnectionIOException - if the handling of I/O operations failpublic void onInputShutdown()
throws IOException
onInputShutdown in interface AsyncConnectionIOExceptionpublic boolean isOpen()
isOpen in interface WebSocket.Connectionpublic boolean isIdle()
isIdle in interface ConnectionConnection.onIdleExpired(long)public boolean isSuspended()
ConnectionThe semantic of this method is to return true to indicate interest in further reads,
or false otherwise, but it is misnamed and should be really called isReadInterested().
isSuspended in interface Connectionpublic void onClose()
ConnectiononClose in interface Connectionpublic void sendMessage(String content) throws IOException
sendMessage in interface WebSocket.ConnectionIOExceptionpublic void sendMessage(byte[] data,
int offset,
int length)
throws IOException
sendMessage in interface WebSocket.ConnectionIOExceptionpublic boolean isMore(byte flags)
public void sendControl(byte code,
byte[] content,
int offset,
int length)
throws IOException
sendControl in interface WebSocket.FrameConnectionIOExceptionpublic void sendFrame(byte flags,
byte opcode,
byte[] content,
int offset,
int length)
throws IOException
WebSocket.FrameConnectionsendFrame in interface WebSocket.FrameConnectionIOExceptionpublic void close(int code,
String message)
WebSocket.Connectionclose in interface WebSocket.Connectioncode - The close code to send, or -1 for no close codemessage - The message to send or null for no messagepublic void disconnect()
disconnect in interface WebSocket.Connectionpublic void close()
WebSocket.Connectionclose in interface WebSocket.Connectionpublic void shutdown()
shutdown in interface WebSocketConnectionpublic void fillBuffersFrom(Buffer buffer)
fillBuffersFrom in interface WebSocketConnectionpublic static byte[] doTheHixieHixieShake(long key1,
long key2,
byte[] key3)
public void setMaxTextMessageSize(int size)
setMaxTextMessageSize in interface WebSocket.Connectionsize - size<0 No aggregation of frames to messages, >=0 max size of text frame aggregation buffer in characterspublic void setMaxIdleTime(int ms)
setMaxIdleTime in interface WebSocket.Connectionms - The time in ms that the connection can be idle before closingpublic void setMaxBinaryMessageSize(int size)
setMaxBinaryMessageSize in interface WebSocket.Connectionsize - size<0 no aggregation of binary frames, >=0 size of binary frame aggregation bufferpublic int getMaxTextMessageSize()
WebSocket.ConnectiongetMaxTextMessageSize in interface WebSocket.Connectionpublic int getMaxIdleTime()
getMaxIdleTime in interface WebSocket.Connectionpublic int getMaxBinaryMessageSize()
WebSocket.ConnectiongetMaxBinaryMessageSize in interface WebSocket.Connectionpublic String getProtocol()
getProtocol in interface WebSocket.Connectionprotected void onFrameHandshake()
protected void onWebsocketOpen()
public boolean isMessageComplete(byte flags)
isMessageComplete in interface WebSocket.FrameConnectionflags - The flags bytes of a framepublic byte binaryOpcode()
binaryOpcode in interface WebSocket.FrameConnectionpublic byte textOpcode()
textOpcode in interface WebSocket.FrameConnectionpublic boolean isControl(byte opcode)
isControl in interface WebSocket.FrameConnectionpublic boolean isText(byte opcode)
isText in interface WebSocket.FrameConnectionpublic boolean isBinary(byte opcode)
isBinary in interface WebSocket.FrameConnectionpublic boolean isContinuation(byte opcode)
isContinuation in interface WebSocket.FrameConnectionpublic boolean isClose(byte opcode)
isClose in interface WebSocket.FrameConnectionpublic boolean isPing(byte opcode)
isPing in interface WebSocket.FrameConnectionpublic boolean isPong(byte opcode)
isPong in interface WebSocket.FrameConnectionpublic List<Extension> getExtensions()
getExtensions in interface WebSocketConnectionpublic byte continuationOpcode()
continuationOpcode in interface WebSocket.FrameConnectionpublic byte finMask()
finMask in interface WebSocket.FrameConnectionpublic void setAllowFrameFragmentation(boolean allowFragmentation)
WebSocket.FrameConnectionsetAllowFrameFragmentation in interface WebSocket.FrameConnectionpublic boolean isAllowFrameFragmentation()
isAllowFrameFragmentation in interface WebSocket.FrameConnectionCopyright © 1995-2015 Mort Bay Consulting. All Rights Reserved.