META-INF/
META-INF/MANIFEST.MF
com/
com/firebase/
com/firebase/tubesock/
com/firebase/tubesock/Base64.classBase64.java
package com.firebase.tubesock
public com.firebase.tubesock.Base64 extends java.lang.Object {
private static final char[] CA
private static final int[] IA
public void ()
public static final char[] encodeToChar (byte[], boolean)
int i
int s
int d
int cc
int i
byte[] sArr
boolean lineSep
int sLen
int eLen
int cCnt
int dLen
char[] dArr
int left
public static final byte[] decode (char[])
int i
int i
int c
int j
int i
int s
int d
char[] sArr
int sLen
int sepCnt
int pad
int len
byte[] dArr
public static final byte[] decodeFast (char[])
int i
int cc
int eLen
int j
int r
int i
char[] sArr
int sLen
int sIx
int eIx
int pad
int cCnt
int sepCnt
int len
byte[] dArr
int d
public static final byte[] encodeToByte (byte[], boolean)
int i
int s
int d
int cc
int i
byte[] sArr
boolean lineSep
int sLen
int eLen
int cCnt
int dLen
byte[] dArr
int left
public static final byte[] decode (byte[])
int i
int i
int c
int j
int i
int s
int d
byte[] sArr
int sLen
int sepCnt
int pad
int len
byte[] dArr
public static final byte[] decodeFast (byte[])
int i
int cc
int eLen
int j
int r
int i
byte[] sArr
int sLen
int sIx
int eIx
int pad
int cCnt
int sepCnt
int len
byte[] dArr
int d
public static final java.lang.String encodeToString (byte[], boolean)
byte[] sArr
boolean lineSep
public static final byte[] decode (java.lang.String)
int i
int i
int c
int j
int i
int s
int d
String str
int sLen
int sepCnt
int pad
int len
byte[] dArr
public static final byte[] decodeFast (java.lang.String)
int i
int cc
int eLen
int j
int r
int i
String s
int sLen
int sIx
int eIx
int pad
int cCnt
int sepCnt
int len
byte[] dArr
int d
static void ()
int i
int iS
}
com/firebase/tubesock/MessageBuilderFactory$BinaryBuilder.classMessageBuilderFactory.java
package com.firebase.tubesock
com.firebase.tubesock.MessageBuilderFactory$BinaryBuilder extends java.lang.Object implements com.firebase.tubesock.MessageBuilderFactory$Builder {
private java.util.List pendingBytes
private int pendingByteCount
void ()
public boolean appendBytes (byte[])
byte[] bytes
public com.firebase.tubesock.WebSocketMessage toMessage ()
byte[] segment
int i
byte[] payload
int offset
}
com/firebase/tubesock/MessageBuilderFactory$Builder.classMessageBuilderFactory.java
package com.firebase.tubesock
abstract com.firebase.tubesock.MessageBuilderFactory$Builder extends java.lang.Object {
public abstract boolean appendBytes (byte[])
public abstract com.firebase.tubesock.WebSocketMessage toMessage ()
}
com/firebase/tubesock/MessageBuilderFactory$TextBuilder$1.classMessageBuilderFactory.java
package com.firebase.tubesock
final com.firebase.tubesock.MessageBuilderFactory$TextBuilder$1 extends java.lang.ThreadLocal {
void ()
protected java.nio.charset.CharsetDecoder initialValue ()
java.nio.charset.Charset utf8
java.nio.charset.CharsetDecoder decoder
protected volatile java.lang.Object initialValue ()
}
com/firebase/tubesock/MessageBuilderFactory$TextBuilder$2.classMessageBuilderFactory.java
package com.firebase.tubesock
final com.firebase.tubesock.MessageBuilderFactory$TextBuilder$2 extends java.lang.ThreadLocal {
void ()
protected java.nio.charset.CharsetEncoder initialValue ()
java.nio.charset.Charset utf8
java.nio.charset.CharsetEncoder encoder
protected volatile java.lang.Object initialValue ()
}
com/firebase/tubesock/MessageBuilderFactory$TextBuilder.classMessageBuilderFactory.java
package com.firebase.tubesock
com.firebase.tubesock.MessageBuilderFactory$TextBuilder extends java.lang.Object implements com.firebase.tubesock.MessageBuilderFactory$Builder {
private static ThreadLocal localDecoder
private static ThreadLocal localEncoder
private StringBuilder builder
private java.nio.ByteBuffer carryOver
void ()
public boolean appendBytes (byte[])
byte[] bytes
String nextFrame
public com.firebase.tubesock.WebSocketMessage toMessage ()
private java.lang.String decodeString (byte[])
java.nio.ByteBuffer input
java.nio.CharBuffer buf
String text
java.nio.charset.CharacterCodingException e
byte[] bytes
private java.lang.String decodeStringStreaming (byte[])
java.nio.CharBuffer o
java.nio.charset.CoderResult result
java.nio.ByteBuffer input
int bufSize
java.nio.CharBuffer output
java.nio.CharBuffer test
String text
java.nio.charset.CharacterCodingException e
byte[] bytes
private java.nio.ByteBuffer getBuffer (byte[])
java.nio.ByteBuffer buffer
byte[] bytes
static void ()
}
com/firebase/tubesock/MessageBuilderFactory.classMessageBuilderFactory.java
package com.firebase.tubesock
com.firebase.tubesock.MessageBuilderFactory extends java.lang.Object {
void ()
static com.firebase.tubesock.MessageBuilderFactory$Builder builder (byte)
byte opcode
}
com/firebase/tubesock/ThreadInitializer.classThreadInitializer.java
package com.firebase.tubesock
public abstract com.firebase.tubesock.ThreadInitializer extends java.lang.Object {
public abstract void setName (java.lang.Thread, java.lang.String)
}
com/firebase/tubesock/WebSocket$1.classWebSocket.java
package com.firebase.tubesock
final com.firebase.tubesock.WebSocket$1 extends java.lang.Object implements com.firebase.tubesock.ThreadInitializer {
void ()
public void setName (java.lang.Thread, java.lang.String)
Thread t
String name
}
com/firebase/tubesock/WebSocket$2.classWebSocket.java
package com.firebase.tubesock
com.firebase.tubesock.WebSocket$2 extends java.lang.Object implements java.lang.Runnable {
final com.firebase.tubesock.WebSocket this$0
void (com.firebase.tubesock.WebSocket)
public void run ()
}
com/firebase/tubesock/WebSocket$3.classWebSocket.java
package com.firebase.tubesock
com.firebase.tubesock.WebSocket$3 extends java.lang.Object {
static final int[] $SwitchMap$com$firebase$tubesock$WebSocket$State
static void ()
NoSuchFieldError ex
NoSuchFieldError ex
NoSuchFieldError ex
NoSuchFieldError ex
NoSuchFieldError ex
}
com/firebase/tubesock/WebSocket$State.classWebSocket.java
package com.firebase.tubesock
final com.firebase.tubesock.WebSocket$State extends java.lang.Enum {
public static final com.firebase.tubesock.WebSocket$State NONE
public static final com.firebase.tubesock.WebSocket$State CONNECTING
public static final com.firebase.tubesock.WebSocket$State CONNECTED
public static final com.firebase.tubesock.WebSocket$State DISCONNECTING
public static final com.firebase.tubesock.WebSocket$State DISCONNECTED
private static final com.firebase.tubesock.WebSocket$State[] $VALUES
public static com.firebase.tubesock.WebSocket$State[] values ()
public static com.firebase.tubesock.WebSocket$State valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
com/firebase/tubesock/WebSocket.classWebSocket.java
package com.firebase.tubesock
public com.firebase.tubesock.WebSocket extends java.lang.Object {
private static final String THREAD_BASE_NAME
private static final java.util.concurrent.atomic.AtomicInteger clientCount
private static final java.nio.charset.Charset UTF8
static final byte OPCODE_NONE
static final byte OPCODE_TEXT
static final byte OPCODE_BINARY
static final byte OPCODE_CLOSE
static final byte OPCODE_PING
static final byte OPCODE_PONG
private volatile com.firebase.tubesock.WebSocket$State state
private volatile java.net.Socket socket
private com.firebase.tubesock.WebSocketEventHandler eventHandler
private final java.net.URI url
private final com.firebase.tubesock.WebSocketReceiver receiver
private final com.firebase.tubesock.WebSocketWriter writer
private final com.firebase.tubesock.WebSocketHandshake handshake
private final int clientId
private final Thread innerThread
private static java.util.concurrent.ThreadFactory threadFactory
private static com.firebase.tubesock.ThreadInitializer intializer
static java.util.concurrent.ThreadFactory getThreadFactory ()
static com.firebase.tubesock.ThreadInitializer getIntializer ()
public static void setThreadFactory (java.util.concurrent.ThreadFactory, com.firebase.tubesock.ThreadInitializer)
java.util.concurrent.ThreadFactory threadFactory
com.firebase.tubesock.ThreadInitializer intializer
public void (java.net.URI)
java.net.URI url
public void (java.net.URI, java.lang.String)
java.net.URI url
String protocol
public void (java.net.URI, java.lang.String, java.util.Map)
java.net.URI url
String protocol
java.util.Map extraHeaders
public void setEventHandler (com.firebase.tubesock.WebSocketEventHandler)
com.firebase.tubesock.WebSocketEventHandler eventHandler
com.firebase.tubesock.WebSocketEventHandler getEventHandler ()
public synchronized void connect ()
public synchronized void send (java.lang.String)
String data
public synchronized void send (byte[])
byte[] data
synchronized void pong (byte[])
byte[] data
private synchronized void send (byte, byte[])
java.io.IOException e
byte opcode
byte[] data
void handleReceiverError (com.firebase.tubesock.WebSocketException)
com.firebase.tubesock.WebSocketException e
public synchronized void close ()
void onCloseOpReceived ()
private synchronized void closeSocket ()
java.io.IOException e
private void sendCloseHandshake ()
java.io.IOException e
private java.net.Socket createSocket ()
java.net.UnknownHostException uhe
java.io.IOException ioe
javax.net.SocketFactory factory
java.net.UnknownHostException uhe
java.io.IOException ioe
String scheme
String host
int port
java.net.Socket socket
private void verifyHost (javax.net.ssl.SSLSocket, java.lang.String) throws javax.net.ssl.SSLException
javax.net.ssl.SSLSocket socket
String host
java.security.cert.Certificate[] certs
java.security.cert.X509Certificate peerCert
org.apache.http.conn.ssl.StrictHostnameVerifier verifier
public void blockClose () throws java.lang.InterruptedException
private void runReader ()
java.io.IOException e
String line
String line
int b
String[] keyValue
String line
java.util.Iterator i$
java.net.Socket socket
java.io.DataInputStream input
java.io.OutputStream output
boolean handshakeComplete
int len
byte[] buffer
int pos
java.util.ArrayList handshakeLines
java.util.HashMap headers
com.firebase.tubesock.WebSocketException wse
java.io.IOException ioe
java.lang.Thread getInnerThread ()
static void access$000 (com.firebase.tubesock.WebSocket)
com.firebase.tubesock.WebSocket x0
static void ()
}
com/firebase/tubesock/WebSocketEventHandler.classWebSocketEventHandler.java
package com.firebase.tubesock
public abstract com.firebase.tubesock.WebSocketEventHandler extends java.lang.Object {
public abstract void onOpen ()
public abstract void onMessage (com.firebase.tubesock.WebSocketMessage)
public abstract void onClose ()
public abstract void onError (com.firebase.tubesock.WebSocketException)
public abstract void onLogMessage (java.lang.String)
}
com/firebase/tubesock/WebSocketException.classWebSocketException.java
package com.firebase.tubesock
public com.firebase.tubesock.WebSocketException extends java.lang.RuntimeException {
private static final long serialVersionUID
public void (java.lang.String)
String message
public void (java.lang.String, java.lang.Throwable)
String message
Throwable t
}
com/firebase/tubesock/WebSocketHandshake.classWebSocketHandshake.java
package com.firebase.tubesock
com.firebase.tubesock.WebSocketHandshake extends java.lang.Object {
private static final String WEBSOCKET_VERSION
private java.net.URI url
private String protocol
private String nonce
private java.util.Map extraHeaders
public void (java.net.URI, java.lang.String, java.util.Map)
java.net.URI url
String protocol
java.util.Map extraHeaders
public byte[] getHandshake ()
String fieldName
java.util.Iterator i$
String path
String query
String host
java.util.LinkedHashMap header
String handshake
byte[] handshakeBytes
private java.lang.String generateHeader (java.util.LinkedHashMap)
String fieldName
java.util.Iterator i$
java.util.LinkedHashMap headers
String header
private java.lang.String createNonce ()
int i
byte[] nonce
public void verifyServerStatusLine (java.lang.String)
String statusLine
int statusCode
public void verifyServerHandshakeHeaders (java.util.HashMap)
java.util.HashMap headers
private int rand (int, int)
int min
int max
int rand
}
com/firebase/tubesock/WebSocketMessage.classWebSocketMessage.java
package com.firebase.tubesock
public com.firebase.tubesock.WebSocketMessage extends java.lang.Object {
private byte[] byteMessage
private String stringMessage
private byte opcode
public void (byte[])
byte[] message
public void (java.lang.String)
String message
public boolean isText ()
public boolean isBinary ()
public byte[] getBytes ()
public java.lang.String getText ()
}
com/firebase/tubesock/WebSocketReceiver.classWebSocketReceiver.java
package com.firebase.tubesock
com.firebase.tubesock.WebSocketReceiver extends java.lang.Object {
private java.io.DataInputStream input
private com.firebase.tubesock.WebSocket websocket
private com.firebase.tubesock.WebSocketEventHandler eventHandler
private byte[] inputHeader
private com.firebase.tubesock.MessageBuilderFactory$Builder pendingBuilder
private volatile boolean stop
void (com.firebase.tubesock.WebSocket)
com.firebase.tubesock.WebSocket websocket
void setInput (java.io.DataInputStream)
java.io.DataInputStream input
void run ()
byte opcode
byte length
long payload_length
byte[] payload
int offset
boolean fin
boolean rsv
java.net.SocketTimeoutException sto
java.io.IOException ioe
com.firebase.tubesock.WebSocketException e
private void appendBytes (boolean, byte, byte[])
com.firebase.tubesock.WebSocketMessage message
boolean fin
byte opcode
byte[] data
private void handlePing (byte[])
byte[] payload
private long parseLong (byte[], int)
byte[] buffer
int offset
private int read (byte[], int, int) throws java.io.IOException
byte[] buffer
int offset
int length
void stopit ()
boolean isRunning ()
private void handleError (com.firebase.tubesock.WebSocketException)
com.firebase.tubesock.WebSocketException e
}
com/firebase/tubesock/WebSocketWriter$1.classWebSocketWriter.java
package com.firebase.tubesock
com.firebase.tubesock.WebSocketWriter$1 extends java.lang.Object implements java.lang.Runnable {
final com.firebase.tubesock.WebSocketWriter this$0
void (com.firebase.tubesock.WebSocketWriter)
public void run ()
}
com/firebase/tubesock/WebSocketWriter.classWebSocketWriter.java
package com.firebase.tubesock
com.firebase.tubesock.WebSocketWriter extends java.lang.Object {
private java.util.concurrent.BlockingQueue pendingBuffers
private final java.util.Random random
private volatile boolean stop
private boolean closeSent
private com.firebase.tubesock.WebSocket websocket
private java.nio.channels.WritableByteChannel channel
private final Thread innerThread
void (com.firebase.tubesock.WebSocket, java.lang.String, int)
com.firebase.tubesock.WebSocket websocket
String threadBaseName
int clientId
void setOutput (java.io.OutputStream)
java.io.OutputStream output
private java.nio.ByteBuffer frameInBuffer (byte, boolean, byte[]) throws java.io.IOException
int length_field
int length_field
int i
byte[] mask
byte opcode
boolean masking
byte[] data
int headerLength
int length
java.nio.ByteBuffer frame
byte fin
byte startByte
private byte[] generateMask ()
byte[] mask
synchronized void send (byte, boolean, byte[]) throws java.io.IOException
byte opcode
boolean masking
byte[] data
java.nio.ByteBuffer frame
private void writeMessage () throws java.lang.InterruptedException java.io.IOException
java.nio.ByteBuffer msg
void stopIt ()
private void handleError (com.firebase.tubesock.WebSocketException)
com.firebase.tubesock.WebSocketException e
private void runWriter ()
int i
java.io.IOException e
InterruptedException e
java.lang.Thread getInnerThread ()
static void access$000 (com.firebase.tubesock.WebSocketWriter)
com.firebase.tubesock.WebSocketWriter x0
}
META-INF/maven/
META-INF/maven/com.firebase/
META-INF/maven/com.firebase/tubesock/
META-INF/maven/com.firebase/tubesock/pom.xml
META-INF/maven/com.firebase/tubesock/pom.properties