Home | History | Annotate | Download | only in 0.0.12

META-INF/
META-INF/MANIFEST.MF
com/
com/firebase/
com/firebase/tubesock/
com/firebase/tubesock/Base64.class
Base64.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.class
MessageBuilderFactory.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.class
MessageBuilderFactory.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.class
MessageBuilderFactory.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.class
MessageBuilderFactory.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.class
MessageBuilderFactory.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.class
MessageBuilderFactory.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.class
ThreadInitializer.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.class
WebSocket.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.class
WebSocket.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.class
WebSocket.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.class
WebSocket.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.class
WebSocket.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.class
WebSocketEventHandler.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.class
WebSocketException.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.class
WebSocketHandshake.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.class
WebSocketMessage.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.class
WebSocketReceiver.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.class
WebSocketWriter.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.class
WebSocketWriter.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