META-INF/MANIFEST.MF
de/tavendo/autobahn/ByteBufferInputStream.classByteBufferInputStream.java
package de.tavendo.autobahn
public de.tavendo.autobahn.ByteBufferInputStream extends java.io.InputStream {
private final java.nio.ByteBuffer mBuffer
public void (java.nio.ByteBuffer)
java.nio.ByteBuffer buffer
public synchronized int read () throws java.io.IOException
public synchronized int read (byte[], int, int) throws java.io.IOException
byte[] bytes
int off
int len
int length
}
de/tavendo/autobahn/ByteBufferOutputStream.classByteBufferOutputStream.java
package de.tavendo.autobahn
public de.tavendo.autobahn.ByteBufferOutputStream extends java.io.OutputStream {
private final int mInitialSize
private final int mGrowSize
private java.nio.ByteBuffer mBuffer
public void ()
public void (int, int)
int initialSize
int growSize
public java.nio.ByteBuffer getBuffer ()
public java.nio.Buffer flip ()
public java.nio.Buffer clear ()
public int remaining ()
public synchronized void expand (int)
int requestSize
java.nio.ByteBuffer oldBuffer
int oldPosition
int newCapacity
public synchronized void write (int) throws java.io.IOException
int b
public synchronized void write (byte[], int, int) throws java.io.IOException
byte[] bytes
int off
int len
public synchronized void write (byte[]) throws java.io.IOException
byte[] bytes
public synchronized void write (java.lang.String) throws java.io.IOException
String str
public synchronized void crlf () throws java.io.IOException
}
de/tavendo/autobahn/Doxygen.classDoxygen.java
package de.tavendo.autobahn
abstract de.tavendo.autobahn.Doxygen extends java.lang.Object {
void ()
}
de/tavendo/autobahn/NoCopyByteArrayOutputStream.classNoCopyByteArrayOutputStream.java
package de.tavendo.autobahn
public de.tavendo.autobahn.NoCopyByteArrayOutputStream extends java.io.ByteArrayOutputStream {
public void ()
public void (int)
int size
public java.io.InputStream getInputStream ()
public byte[] getByteArray ()
}
de/tavendo/autobahn/PrefixMap.classPrefixMap.java
package de.tavendo.autobahn
public de.tavendo.autobahn.PrefixMap extends java.lang.Object {
private final java.util.HashMap mPrefixes
private final java.util.HashMap mUris
public void ()
public void set (java.lang.String, java.lang.String)
String prefix
String uri
public java.lang.String get (java.lang.String)
String prefix
public java.lang.String remove (java.lang.String)
String prefix
String uri
public void clear ()
public java.lang.String resolve (java.lang.String)
String curie
int i
String prefix
public java.lang.String resolveOrPass (java.lang.String)
String curieOrUri
String u
public java.lang.String shrink (java.lang.String)
String uri
int i
String u
String p
}
de/tavendo/autobahn/Utf8Validator.classUtf8Validator.java
package de.tavendo.autobahn
public de.tavendo.autobahn.Utf8Validator extends java.lang.Object {
private static final int[] DFA
private static final int ACCEPT
private static final int REJECT
private int mState
private int mPos
static void ()
public void ()
public void reset ()
public int position ()
public boolean isValid ()
public boolean validate (byte[], int, int)
byte[] data
int off
int len
int i
public boolean validate (byte[])
byte[] data
}
de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification.classWebSocket.java
package de.tavendo.autobahn
public final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification extends java.lang.Enum {
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification NORMAL
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification CANNOT_CONNECT
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification CONNECTION_LOST
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification PROTOCOL_ERROR
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification INTERNAL_ERROR
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification SERVER_ERROR
public static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification RECONNECT
private static final de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification[] ENUM$VALUES
static void ()
private void (java.lang.String, int)
public static de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification[] values ()
public static de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification valueOf (java.lang.String)
}
de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver.classWebSocket.java
package de.tavendo.autobahn
public abstract de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver extends java.lang.Object {
public abstract void onOpen ()
public abstract void onClose (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String)
public abstract void onTextMessage (java.lang.String)
public abstract void onRawTextMessage (byte[])
public abstract void onBinaryMessage (byte[])
}
de/tavendo/autobahn/WebSocket.classWebSocket.java
package de.tavendo.autobahn
public abstract de.tavendo.autobahn.WebSocket extends java.lang.Object {
public static final String UTF8_ENCODING
public abstract void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver) throws de.tavendo.autobahn.WebSocketException
public abstract void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver, de.tavendo.autobahn.WebSocketOptions) throws de.tavendo.autobahn.WebSocketException
public abstract void disconnect ()
public abstract boolean isConnected ()
public abstract void sendBinaryMessage (byte[])
public abstract void sendRawTextMessage (byte[])
public abstract void sendTextMessage (java.lang.String)
}
de/tavendo/autobahn/WebSocketConnection$1.classWebSocketConnection.java
package de.tavendo.autobahn
de.tavendo.autobahn.WebSocketConnection$1 extends java.lang.Object implements java.lang.Runnable {
final de.tavendo.autobahn.WebSocketConnection this$0
void (de.tavendo.autobahn.WebSocketConnection)
public void run ()
}
de/tavendo/autobahn/WebSocketConnection$2.classWebSocketConnection.java
package de.tavendo.autobahn
de.tavendo.autobahn.WebSocketConnection$2 extends java.lang.Object implements java.lang.Runnable {
final de.tavendo.autobahn.WebSocketConnection this$0
void (de.tavendo.autobahn.WebSocketConnection)
public void run ()
}
de/tavendo/autobahn/WebSocketConnection$3.classWebSocketConnection.java
package de.tavendo.autobahn
de.tavendo.autobahn.WebSocketConnection$3 extends java.lang.Object implements java.lang.Runnable {
final de.tavendo.autobahn.WebSocketConnection this$0
void (de.tavendo.autobahn.WebSocketConnection)
public void run ()
}
de/tavendo/autobahn/WebSocketConnection$4.classWebSocketConnection.java
package de.tavendo.autobahn
de.tavendo.autobahn.WebSocketConnection$4 extends java.lang.Object implements java.lang.Runnable {
final de.tavendo.autobahn.WebSocketConnection this$0
void (de.tavendo.autobahn.WebSocketConnection)
public void run ()
}
de/tavendo/autobahn/WebSocketConnection$SocketThread.classWebSocketConnection.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketConnection$SocketThread extends java.lang.Thread {
private static final String WS_CONNECTOR
private final java.net.URI mWebSocketURI
private java.net.Socket mSocket
private String mFailureMessage
private android.os.Handler mHandler
public void (java.net.URI, de.tavendo.autobahn.WebSocketOptions)
java.net.URI uri
de.tavendo.autobahn.WebSocketOptions options
public void run ()
public void startConnection ()
String host
int port
javax.net.SocketFactory factory
java.io.IOException e
public void stopConnection ()
java.io.IOException e
public android.os.Handler getHandler ()
public java.net.Socket getSocket ()
public java.lang.String getFailureMessage ()
}
de/tavendo/autobahn/WebSocketConnection$ThreadHandler.classWebSocketConnection.java
package de.tavendo.autobahn
de.tavendo.autobahn.WebSocketConnection$ThreadHandler extends android.os.Handler {
private final java.lang.ref.WeakReference mWebSocketConnection
public void (de.tavendo.autobahn.WebSocketConnection)
de.tavendo.autobahn.WebSocketConnection webSocketConnection
public void handleMessage (android.os.Message)
android.os.Message message
de.tavendo.autobahn.WebSocketConnection webSocketConnection
}
de/tavendo/autobahn/WebSocketConnection.classWebSocketConnection.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketConnection extends java.lang.Object implements de.tavendo.autobahn.WebSocket {
private static final String TAG
private static final String WS_URI_SCHEME
private static final String WSS_URI_SCHEME
private static final String WS_WRITER
private static final String WS_READER
private final android.os.Handler mHandler
private de.tavendo.autobahn.WebSocketReader mWebSocketReader
private de.tavendo.autobahn.WebSocketWriter mWebSocketWriter
private java.net.Socket mSocket
private de.tavendo.autobahn.WebSocketConnection$SocketThread mSocketThread
private java.net.URI mWebSocketURI
private String[] mWebSocketSubprotocols
private java.lang.ref.WeakReference mWebSocketConnectionObserver
private de.tavendo.autobahn.WebSocketOptions mWebSocketOptions
private boolean mPreviousConnection
static void ()
public void ()
public void sendTextMessage (java.lang.String)
String payload
public void sendRawTextMessage (byte[])
byte[] payload
public void sendBinaryMessage (byte[])
byte[] payload
public boolean isConnected ()
private void failConnection (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String)
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification code
String reason
InterruptedException e
InterruptedException e
public void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver) throws de.tavendo.autobahn.WebSocketException
java.net.URI webSocketURI
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver connectionObserver
public void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver, de.tavendo.autobahn.WebSocketOptions) throws de.tavendo.autobahn.WebSocketException
java.net.URI webSocketURI
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver connectionObserver
de.tavendo.autobahn.WebSocketOptions options
public void connect (java.net.URI, java.lang.String[], de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver, de.tavendo.autobahn.WebSocketOptions) throws de.tavendo.autobahn.WebSocketException
java.net.URI webSocketURI
String[] subprotocols
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver connectionObserver
de.tavendo.autobahn.WebSocketOptions options
public void disconnect ()
public boolean reconnect ()
private void connect ()
de.tavendo.autobahn.WebSocketMessage$ClientHandshake clientHandshake
Exception e
protected boolean scheduleReconnect ()
int interval
boolean shouldReconnect
private void onClose (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String)
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification code
String reason
boolean reconnecting
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver webSocketObserver
Exception e
protected void processAppMessage (java.lang.Object)
Object message
protected void createWriter ()
protected void createReader ()
private void handleMessage (android.os.Message)
android.os.Message message
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver webSocketObserver
de.tavendo.autobahn.WebSocketMessage$TextMessage textMessage
de.tavendo.autobahn.WebSocketMessage$RawTextMessage rawTextMessage
de.tavendo.autobahn.WebSocketMessage$BinaryMessage binaryMessage
de.tavendo.autobahn.WebSocketMessage$Ping ping
de.tavendo.autobahn.WebSocketMessage$Pong pong
de.tavendo.autobahn.WebSocketMessage$Pong pong
de.tavendo.autobahn.WebSocketMessage$Close close
de.tavendo.autobahn.WebSocketMessage$ServerHandshake serverHandshake
de.tavendo.autobahn.WebSocketMessage$Error error
de.tavendo.autobahn.WebSocketMessage$ServerError error
static java.lang.String access$0 ()
static void access$1 (de.tavendo.autobahn.WebSocketConnection, android.os.Message)
static de.tavendo.autobahn.WebSocketConnection$SocketThread access$2 (de.tavendo.autobahn.WebSocketConnection)
}
de/tavendo/autobahn/WebSocketConnectionHandler.classWebSocketConnectionHandler.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketConnectionHandler extends java.lang.Object implements de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver {
public void ()
public void onOpen ()
public void onClose (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String)
de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification code
String reason
public void onTextMessage (java.lang.String)
String payload
public void onRawTextMessage (byte[])
byte[] payload
public void onBinaryMessage (byte[])
byte[] payload
}
de/tavendo/autobahn/WebSocketException.classWebSocketException.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketException extends java.lang.Exception {
private static final long serialVersionUID
public void (java.lang.String)
String message
public void (java.lang.String, java.lang.Throwable)
String message
Throwable t
}
de/tavendo/autobahn/WebSocketFrameHeader.classWebSocketFrameHeader.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketFrameHeader extends java.lang.Object {
private int mOpcode
private boolean mFin
private int mReserved
private int mHeaderLen
private int mPayloadLen
private int mTotalLen
private byte[] mMask
public void ()
public int getOpcode ()
public void setOpcode (int)
int opcode
public boolean isFin ()
public void setFin (boolean)
boolean fin
public int getReserved ()
public void setReserved (int)
int reserved
public int getHeaderLength ()
public void setHeaderLength (int)
int headerLength
public int getPayloadLength ()
public void setPayloadLength (int)
int payloadLength
public int getTotalLength ()
public void setTotalLen (int)
int totalLength
public byte[] getMask ()
public void setMask (byte[])
byte[] mask
}
de/tavendo/autobahn/WebSocketMessage$BinaryMessage.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$BinaryMessage extends de.tavendo.autobahn.WebSocketMessage$Message {
public byte[] mPayload
void (byte[])
byte[] payload
}
de/tavendo/autobahn/WebSocketMessage$ClientHandshake.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$ClientHandshake extends de.tavendo.autobahn.WebSocketMessage$Message {
private final java.net.URI mURI
private final java.net.URI mOrigin
private final String[] mSubprotocols
void (java.net.URI)
java.net.URI uri
void (java.net.URI, java.net.URI, java.lang.String[])
java.net.URI uri
java.net.URI origin
String[] subprotocols
public java.net.URI getURI ()
public java.net.URI getOrigin ()
public java.lang.String[] getSubprotocols ()
}
de/tavendo/autobahn/WebSocketMessage$Close.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$Close extends de.tavendo.autobahn.WebSocketMessage$Message {
private int mCode
private String mReason
void ()
void (int)
int code
void (int, java.lang.String)
int code
String reason
public int getCode ()
public java.lang.String getReason ()
}
de/tavendo/autobahn/WebSocketMessage$ConnectionLost.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$ConnectionLost extends de.tavendo.autobahn.WebSocketMessage$Message {
public void ()
}
de/tavendo/autobahn/WebSocketMessage$Error.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$Error extends de.tavendo.autobahn.WebSocketMessage$Message {
public Exception mException
public void (java.lang.Exception)
Exception e
}
de/tavendo/autobahn/WebSocketMessage$Message.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$Message extends java.lang.Object {
public void ()
}
de/tavendo/autobahn/WebSocketMessage$Ping.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$Ping extends de.tavendo.autobahn.WebSocketMessage$Message {
public byte[] mPayload
void ()
void (byte[])
byte[] payload
}
de/tavendo/autobahn/WebSocketMessage$Pong.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$Pong extends de.tavendo.autobahn.WebSocketMessage$Message {
public byte[] mPayload
void ()
void (byte[])
byte[] payload
}
de/tavendo/autobahn/WebSocketMessage$ProtocolViolation.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$ProtocolViolation extends de.tavendo.autobahn.WebSocketMessage$Message {
public de.tavendo.autobahn.WebSocketException mException
public void (de.tavendo.autobahn.WebSocketException)
de.tavendo.autobahn.WebSocketException e
}
de/tavendo/autobahn/WebSocketMessage$Quit.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$Quit extends de.tavendo.autobahn.WebSocketMessage$Message {
public void ()
}
de/tavendo/autobahn/WebSocketMessage$RawTextMessage.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$RawTextMessage extends de.tavendo.autobahn.WebSocketMessage$Message {
public byte[] mPayload
void (byte[])
byte[] payload
}
de/tavendo/autobahn/WebSocketMessage$ServerError.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$ServerError extends de.tavendo.autobahn.WebSocketMessage$Message {
public int mStatusCode
public String mStatusMessage
public void (int, java.lang.String)
int statusCode
String statusMessage
}
de/tavendo/autobahn/WebSocketMessage$ServerHandshake.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$ServerHandshake extends de.tavendo.autobahn.WebSocketMessage$Message {
public boolean mSuccess
public void (boolean)
boolean success
}
de/tavendo/autobahn/WebSocketMessage$TextMessage.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$TextMessage extends de.tavendo.autobahn.WebSocketMessage$Message {
public String mPayload
void (java.lang.String)
String payload
}
de/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage$WebSocketCloseCode extends java.lang.Object {
public static final int NORMAL
public static final int ENDPOINT_GOING_AWAY
public static final int ENDPOINT_PROTOCOL_ERROR
public static final int ENDPOINT_UNSUPPORTED_DATA_TYPE
public static final int RESERVED
public static final int RESERVED_NO_STATUS
public static final int RESERVED_NO_CLOSING_HANDSHAKE
public static final int ENDPOINT_BAD_DATA
public static final int POLICY_VIOLATION
public static final int MESSAGE_TOO_BIG
public static final int ENDPOINT_NEEDS_EXTENSION
public static final int UNEXPECTED_CONDITION
public static final int RESERVED_TLS_REQUIRED
public void ()
}
de/tavendo/autobahn/WebSocketMessage.classWebSocketMessage.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketMessage extends java.lang.Object {
public void ()
}
de/tavendo/autobahn/WebSocketOptions.classWebSocketOptions.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketOptions extends java.lang.Object {
private int mMaxFramePayloadSize
private int mMaxMessagePayloadSize
private boolean mReceiveTextMessagesRaw
private boolean mTcpNoDelay
private int mSocketReceiveTimeout
private int mSocketConnectTimeout
private boolean mValidateIncomingUtf8
private boolean mMaskClientFrames
private int mReconnectInterval
public void ()
public void (de.tavendo.autobahn.WebSocketOptions)
de.tavendo.autobahn.WebSocketOptions other
public void setReceiveTextMessagesRaw (boolean)
boolean enabled
public boolean getReceiveTextMessagesRaw ()
public void setMaxFramePayloadSize (int)
int size
public int getMaxFramePayloadSize ()
public void setMaxMessagePayloadSize (int)
int size
public int getMaxMessagePayloadSize ()
public void setTcpNoDelay (boolean)
boolean enabled
public boolean getTcpNoDelay ()
public void setSocketReceiveTimeout (int)
int timeoutMs
public int getSocketReceiveTimeout ()
public void setSocketConnectTimeout (int)
int timeoutMs
public int getSocketConnectTimeout ()
public void setValidateIncomingUtf8 (boolean)
boolean enabled
public boolean getValidateIncomingUtf8 ()
public void setMaskClientFrames (boolean)
boolean enabled
public boolean getMaskClientFrames ()
public void setReconnectInterval (int)
int reconnectInterval
public int getReconnectInterval ()
}
de/tavendo/autobahn/WebSocketReader$ReaderState.classWebSocketReader.java
package de.tavendo.autobahn
final de.tavendo.autobahn.WebSocketReader$ReaderState extends java.lang.Enum {
public static final de.tavendo.autobahn.WebSocketReader$ReaderState STATE_CLOSED
public static final de.tavendo.autobahn.WebSocketReader$ReaderState STATE_CONNECTING
public static final de.tavendo.autobahn.WebSocketReader$ReaderState STATE_CLOSING
public static final de.tavendo.autobahn.WebSocketReader$ReaderState STATE_OPEN
private static final de.tavendo.autobahn.WebSocketReader$ReaderState[] ENUM$VALUES
static void ()
private void (java.lang.String, int)
public static de.tavendo.autobahn.WebSocketReader$ReaderState[] values ()
public static de.tavendo.autobahn.WebSocketReader$ReaderState valueOf (java.lang.String)
}
de/tavendo/autobahn/WebSocketReader.classWebSocketReader.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketReader extends java.lang.Thread {
private static final String TAG
private final android.os.Handler mWebSocketConnectionHandler
private final java.net.Socket mSocket
private java.io.InputStream mInputStream
private final de.tavendo.autobahn.WebSocketOptions mWebSocketOptions
private volatile boolean mStopped
private final byte[] mNetworkBuffer
private final java.nio.ByteBuffer mApplicationBuffer
private de.tavendo.autobahn.NoCopyByteArrayOutputStream mMessagePayload
private de.tavendo.autobahn.WebSocketReader$ReaderState mState
private boolean mInsideMessage
private int mMessageOpcode
private de.tavendo.autobahn.WebSocketFrameHeader mFrameHeader
private de.tavendo.autobahn.Utf8Validator mUTF8Validator
private static int[] $SWITCH_TABLE$de$tavendo$autobahn$WebSocketReader$ReaderState
static void ()
public void (android.os.Handler, java.net.Socket, de.tavendo.autobahn.WebSocketOptions, java.lang.String)
android.os.Handler master
java.net.Socket socket
de.tavendo.autobahn.WebSocketOptions options
String threadName
public void quit ()
protected void notify (java.lang.Object)
Object message
android.os.Message msg
private boolean processData () throws java.lang.Exception
byte b0
boolean fin
int rsv
int opcode
byte b1
boolean masked
int payload_len1
int mask_len
int header_len
int i
long payload_len
byte[] mask
int j
byte[] framePayload
int oldPosition
int code
String reason
byte[] ra
de.tavendo.autobahn.Utf8Validator val
String s
protected void onHandshake (boolean)
boolean success
protected void onClose (int, java.lang.String)
int code
String reason
protected void onPing (byte[])
byte[] payload
protected void onPong (byte[])
byte[] payload
protected void onTextMessage (java.lang.String)
String payload
protected void onRawTextMessage (byte[])
byte[] payload
protected void onBinaryMessage (byte[])
byte[] payload
private boolean processHandshake () throws java.io.UnsupportedEncodingException
boolean res
int pos
int oldPosition
boolean serverError
android.util.Pair status
private android.util.Pair parseHTTPStatus () throws java.io.UnsupportedEncodingException
int beg
int end
int statusCode
int i
int digit
int eol
int statusMessageLength
byte[] statusBuf
String statusMessage
private boolean consumeData () throws java.lang.Exception
public void run ()
java.io.InputStream inputStream
java.io.IOException e
int bytesRead
de.tavendo.autobahn.WebSocketException e
java.net.SocketException e
java.io.IOException e
Exception e
static int[] $SWITCH_TABLE$de$tavendo$autobahn$WebSocketReader$ReaderState ()
}
de/tavendo/autobahn/WebSocketWriter$ThreadHandler.classWebSocketWriter.java
package de.tavendo.autobahn
de.tavendo.autobahn.WebSocketWriter$ThreadHandler extends android.os.Handler {
private final java.lang.ref.WeakReference mWebSocketWriterReference
public void (de.tavendo.autobahn.WebSocketWriter)
de.tavendo.autobahn.WebSocketWriter webSocketWriter
public void handleMessage (android.os.Message)
android.os.Message message
de.tavendo.autobahn.WebSocketWriter webSocketWriter
}
de/tavendo/autobahn/WebSocketWriter.classWebSocketWriter.java
package de.tavendo.autobahn
public de.tavendo.autobahn.WebSocketWriter extends java.lang.Thread {
private static final String TAG
private static final int WEB_SOCKETS_VERSION
private static final String CRLF
private final java.util.Random mRandom
private final android.os.Handler mWebSocketConnectionHandler
private final de.tavendo.autobahn.WebSocketOptions mWebSocketOptions
private final java.nio.ByteBuffer mApplicationBuffer
private final java.net.Socket mSocket
private java.io.OutputStream mOutputStream
private android.os.Handler mHandler
static void ()
public void (android.os.Handler, java.net.Socket, de.tavendo.autobahn.WebSocketOptions, java.lang.String)
android.os.Handler master
java.net.Socket socket
de.tavendo.autobahn.WebSocketOptions options
String threadName
public void forward (java.lang.Object)
Object message
android.os.Message msg
private void notify (java.lang.Object)
Object message
android.os.Message msg
private java.lang.String newHandshakeKey ()
byte[] ba
private byte[] newFrameMask ()
byte[] ba
private void sendClientHandshake (de.tavendo.autobahn.WebSocketMessage$ClientHandshake) throws java.io.IOException
de.tavendo.autobahn.WebSocketMessage$ClientHandshake message
String path
String query
int i
private void sendClose (de.tavendo.autobahn.WebSocketMessage$Close) throws java.io.IOException de.tavendo.autobahn.WebSocketException
de.tavendo.autobahn.WebSocketMessage$Close message
byte[] payload
byte[] pReason
int i
private void sendPing (de.tavendo.autobahn.WebSocketMessage$Ping) throws java.io.IOException de.tavendo.autobahn.WebSocketException
de.tavendo.autobahn.WebSocketMessage$Ping message
private void sendPong (de.tavendo.autobahn.WebSocketMessage$Pong) throws java.io.IOException de.tavendo.autobahn.WebSocketException
de.tavendo.autobahn.WebSocketMessage$Pong message
private void sendBinaryMessage (de.tavendo.autobahn.WebSocketMessage$BinaryMessage) throws java.io.IOException de.tavendo.autobahn.WebSocketException
de.tavendo.autobahn.WebSocketMessage$BinaryMessage message
private void sendTextMessage (de.tavendo.autobahn.WebSocketMessage$TextMessage) throws java.io.IOException de.tavendo.autobahn.WebSocketException
de.tavendo.autobahn.WebSocketMessage$TextMessage message
byte[] payload
private void sendRawTextMessage (de.tavendo.autobahn.WebSocketMessage$RawTextMessage) throws java.io.IOException de.tavendo.autobahn.WebSocketException
de.tavendo.autobahn.WebSocketMessage$RawTextMessage message
protected void sendFrame (int, boolean, byte[]) throws java.io.IOException
int opcode
boolean fin
byte[] payload
protected void sendFrame (int, boolean, byte[], int, int) throws java.io.IOException
int opcode
boolean fin
byte[] payload
int offset
int length
byte b0
byte b1
long len
byte[] mask
int i
protected void processMessage (java.lang.Object) throws java.io.IOException de.tavendo.autobahn.WebSocketException
Object msg
public void writeMessageToBuffer (android.os.Message)
android.os.Message message
java.net.SocketException e
java.io.IOException e
Exception e
protected void processAppMessage (java.lang.Object) throws de.tavendo.autobahn.WebSocketException java.io.IOException
Object msg
public void run ()
java.io.OutputStream outputStream
java.io.IOException e
}