PK !*¬
¢ META-INF/MANIFEST.MF
|
PK !*'·Ð' / de/tavendo/autobahn/ByteBufferInputStream.classÊþº¾ 3 ? )de/tavendo/autobahn/ByteBufferInputStream java/io/InputStream ByteBufferInputStream.java mBuffer Ljava/nio/ByteBuffer; <init> (Ljava/nio/ByteBuffer;)V ()V
|
|
this +Lde/tavendo/autobahn/ByteBufferInputStream; buffer read ()I java/io/IOException java/nio/ByteBuffer hasRemaining ()Z
|
get ()B
|
([BII)I java/lang/NullPointerException !
|
" #java/lang/IndexOutOfBoundsException $
|
% remaining '
|
( java/lang/Math * min (II)I , -
|
+ . ([BII)Ljava/nio/ByteBuffer; 0
|
1 bytes [B off I len length Code LocalVariableTable LineNumberTable StackMapTable
|
Exceptions
|
SourceFile ! 9 F
|
*· *+µ ± :
|
|
; ) * + ! 9 S *´ ¶ ¬*´ ¶ ÿ~¬ : ; 5
|
6 8 < = ! 9 × M+Ç » "Y· #¿ +¾ d¤ » %Y· &¿ ¬*´ ¶ ) ¸ /6 ¬*´ + ¶ 2W¬ : 4 M M 3 4 M 5 6 M 7 6 7 8 6 ; . I J K L $ M ( N * Q 7 R < S > V J W <
|
ü = > PK !*^ 0 de/tavendo/autobahn/ByteBufferOutputStream.classÊþº¾ 3 n *de/tavendo/autobahn/ByteBufferOutputStream java/io/OutputStream ByteBufferOutputStream.java mInitialSize I mGrowSize mBuffer Ljava/nio/ByteBuffer; <init> ()V (II)V
|
this ,Lde/tavendo/autobahn/ByteBufferOutputStream;
|
java/nio/ByteBuffer allocateDirect (I)Ljava/nio/ByteBuffer;
|
|
clear ()Ljava/nio/Buffer; " #
|
$ initialSize growSize getBuffer ()Ljava/nio/ByteBuffer; flip * #
|
+ remaining ()I - .
|
/ expand (I)V capacity 3 .
|
4 position 6 .
|
7 put ,(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer; 9 :
|
; (I)Ljava/nio/Buffer; 6 =
|
> requestSize oldBuffer oldPosition newCapacity write java/io/IOException E 1 2
|
G (B)Ljava/nio/ByteBuffer; 9 I
|
J b ([BII)V ([BII)Ljava/nio/ByteBuffer; 9 N
|
O bytes [B off len ([B)V D M
|
V (Ljava/lang/String;)V UTF-8 Y java/lang/String [ getBytes (Ljava/lang/String;)[B ] ^
|
\ _ D U
|
a str Ljava/lang/String; crlf D 2
|
f Code LocalVariableTable LineNumberTable StackMapTable
|
Exceptions
|
SourceFile !
|
h 7 * · ± i j
|
. / h t "*· *µ * µ **´ ¸ µ !*´ !¶ %W± i " " & " ' j 7 8 9 : ; ! < ( ) h / *´ !° i j D * # h 2 *´ !¶ ,° i j K " # h 2 *´ !¶ %° i j R - . h 2 *´ !¶ 0¬ i j Y ! 1 2 h Ñ P*´ !¶ 5¤ G*´ !M*´ !¶ 8>*´ l`*´ h6*¸ µ !,¶ %W*´ !¶ %W*´ !,¶ <W*´ ! ¶ ?W± i 4 P P @ ? A
|
7 B ' ( C j *
|
c e f g ' h 0 i 5 j = k F l O n k û O ! D 2 h t +*´ !¶ 8`*´ !¶ 5¤ **´ !¶ 5`¶ H*´ !¶ KW± i + + L j x y { * | k l F ! D M h ,*´ !¶ 8 `*´ !¶ 5¤ **´ !¶ 5 `¶ H*´ !+ ¶ PW± i * , , Q R , S , T j + k l F ! D U h A *++¾¶ W± i Q R j
|
l F ! D X h C *+Z¶ `¶ b± i c d j
|
£
|
¤ l F ! e h ? * ¶ g*
|
¶ g± i j ¬ ® l F m PK !*1 ! de/tavendo/autobahn/Doxygen.classÊþº¾ 3 de/tavendo/autobahn/Doxygen java/lang/Object Doxygen.java <init> ()V
|
this Lde/tavendo/autobahn/Doxygen; Code LocalVariableTable LineNumberTable
|
SourceFile / *· ±
|
S PK !*¶@=[÷ ÷ 5 de/tavendo/autobahn/NoCopyByteArrayOutputStream.classÊþº¾ 3 % /de/tavendo/autobahn/NoCopyByteArrayOutputStream java/io/ByteArrayOutputStream NoCopyByteArrayOutputStream.java <init> ()V
|
this 1Lde/tavendo/autobahn/NoCopyByteArrayOutputStream; (I)V
|
size I getInputStream ()Ljava/io/InputStream; java/io/ByteArrayInputStream buf [B count ([BII)V
|
getByteArray ()[B Code LocalVariableTable LineNumberTable
|
SourceFile ! ! 3 *· ± "
|
#
|
# $ ! > *· ± "
|
#
|
, - ! ; » Y*´ *´ · ° "
|
# 5 ! / *´ ° "
|
# @ $ PK !*YT1 # de/tavendo/autobahn/PrefixMap.classÊþº¾ 3 e de/tavendo/autobahn/PrefixMap java/lang/Object PrefixMap.java mPrefixes Ljava/util/HashMap; 9Ljava/util/HashMap<Ljava/lang/String;Ljava/lang/String;>; mUris <init> ()V
|
|
java/util/HashMap
|
this Lde/tavendo/autobahn/PrefixMap; set '(Ljava/lang/String;Ljava/lang/String;)V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
|
prefix Ljava/lang/String; uri get &(Ljava/lang/String;)Ljava/lang/String; &(Ljava/lang/Object;)Ljava/lang/Object; "
|
# java/lang/String % remove containsKey (Ljava/lang/Object;)Z ( )
|
* ' "
|
, clear .
|
/ resolve indexOf (I)I 2 3
|
& 4 substring (II)Ljava/lang/String; 6 7
|
& 8 java/lang/StringBuilder : valueOf &(Ljava/lang/Object;)Ljava/lang/String; < =
|
& > (Ljava/lang/String;)V
|
@
|
; A (I)Ljava/lang/String; 6 C
|
& D append -(Ljava/lang/String;)Ljava/lang/StringBuilder; F G
|
; H toString ()Ljava/lang/String; J K
|
; L curie i I resolveOrPass 1 !
|
R
|
curieOrUri u shrink length ()I W X
|
& Y (C)Ljava/lang/StringBuilder; F [
|
; \ p Signature Code LocalVariableTable LineNumberTable StackMapTable
|
SourceFile ! _ _
|
` Q *· *» Y· µ *» Y· µ ± a b " $ % " ` [ *´ +,¶ W*´ ,+¶ W± a b .
|
/ 0 ! ` @ *´ +¶ $À &° a b 9 ' ! ` -*´ +¶ + #*´ +¶ $À &M*´ +¶ -W*´ ,¶ -W,°° a - - b E F G H ) I + K c + . ` A *´ ¶ 0*´ ¶ 0± a b S T U 1 ! ` ª B+:¶ 5= 8+ ¶ 9N*´ -¶ + &» ;Y*´ -¶ $À &¸ ?· B+ `¶ E¶ I¶ M°° a * B B N ; O P . b ^ _ ` a b @ e c ü @ Q ! ` f *+¶ SM,Æ ,°+° a T U b p q
|
r t c ü & V ! ` É G+¶ Z=§ <+ ¶ 9N*´ -¶ $À &:Æ » ;Y¸ ?· B:¶ ]+ ¶ E¶ I¶ M°ÿ ÿÆ+° a 4 G G @ O P / U " ^ b !
> E c ü ý 5 & &ù d PK !*ÌC7KT T ' de/tavendo/autobahn/Utf8Validator.classÊþº¾ 3 3 !de/tavendo/autobahn/Utf8Validator java/lang/Object Utf8Validator.java DFA [I ACCEPT I REJECT mState mPos <init> ()V
|
reset
|
this #Lde/tavendo/autobahn/Utf8Validator; position ()I isValid ()Z validate ([BII)Z " data [B off len i ([B)Z !
|
* <clinit> ConstantValue Code LocalVariableTable LineNumberTable StackMapTable
|
SourceFile ! -
|
- . ; *· *¶ ± / 0 @ A B . = *µ *µ ± / 0 I J
|
K . / *´ ¬ / 0 V . > *´ ¬¬ / 0 ` 1 ! . Í Q 6§ :*² # *´ x`² # ÿ+3~.`.µ *´ *Y´ `µ ¬ `¡ÿÄ*Y´ `µ ¬ / 4 Q Q $ % Q & Q ' B ( 0 " l m % n - o 8 p : l E s O t 1 ü 3 ) . = *++¾¶ +¬ / $ % 0 ~ , . Þ ¼
|
Y OY OY OY OY OY
OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY OY ¡OY ¢OY £OY ¤OY ¥OY ¦OY §OY ¨OY ©OY ªOY «OY ¬OY OY ®OY ¯OY °OY ±OY ²OY ³OY ´OY µOY ¶OY ·OY ¸OY ¹OY ºOY »OY ¼OY ½OY ¾OY ¿OY ÀOY ÁOY ÂOY ÃOY ÄOY ÅOY ÆOY ÇOY ÈOY ÉOY ÊOY ËOY ÌOY ÍOY ÎOY ÏOY ÐOY ÑOY ÒOY ÓOY ÔOY ÕOY ÖOY ×OY ØOY ÙOY ÚOY ÛOY ÜOY ÝOY ÞOY ßOY à
|
OY áOY âOY ãOY äOY åOY æOY çOY èOY éOY êOY ëOY ìOY íOY îOY ïOY ð OY ñOY òOY óOY ôOY õOY öOY ÷OY øOY ùOY úOY ûOY üOY ýOY þOY ÿOYOYOYOYOYOYOYOYOY OY
|
OY OY OY OYOYOYOYOYOYOYOYOYOYOYOYOYOYOY OY OY OY OY OY"OY#OY$OY%OY&OY(OY*OY+OY,OY-OY.OY/OY0OY1OY2OY3OY4OY5OY6OY7OY8OY9OY:OY;OY<OY=OY>OY?OY@OYAOYBOYCOYDOYEOYFOYGOYHOYIOYJOYKOYLOYMOYNOYOOYPOYQOYROYSOYTOYUOYVOYWOYXOYYOYZOY[OY\OY]OY^OY_OY`OYaOYbOYcOYdOYeOYfOYgOYhOYiOYjOYkOYlOYmOYnOYoOYpOYqOYrOYsOYtOYuOYvOYwOYxOYyOYzOY{OY|OY}OY~OYOYOYOYOYOYOY
OYOYOYOYOYOYOYOYOYOYO³ #± 0 6 % * Ù +¹ ,{ -Ü .K /¨ 0V 1 2Ö 3 % 7 2 PK !*Bí£) ) Z de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification.classÊþº¾ 3 I Tde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification hLjava/lang/Enum<Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification;>; java/lang/Enum WebSocket.java 9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver de/tavendo/autobahn/WebSocket WebSocketConnectionObserver WebSocketCloseNotification NORMAL VLde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification; CANNOT_CONNECT CONNECTION_LOST PROTOCOL_ERROR INTERNAL_ERROR SERVER_ERROR RECONNECT ENUM$VALUES W[Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification; <init> (Ljava/lang/String;I)V
|
this values Y()[Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification; java/lang/System arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V " #
|
! $ valueOf j(Ljava/lang/String;)Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification; 5(Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Enum; & (
|
) <clinit> ()V
|
/ 2 5 8 ; > A Code LocalVariableTable LineNumberTable Signature
|
SourceFile InnerClasses@1 @ @ @ @ @ @ @ C 1 *+ · ± D E C . ² YK*¾Y<½ YM¸ %,° E & ' C "
|
*¸ *À ° E + , C Ä » Y-· .³ 0» Y1· .³ 3» Y4· .³ 6» Y7· .³ 9» Y:· .³ <» Y=· .³ ?» Y@· .³ B½ Y² 0SY² 3SY² 6SY² 9SY² <SY² ?SY² BS³ ± E " ' 4 A N \ F G H
|
@PK !*Vv v ? de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver.classÊþº¾ 3 9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver java/lang/Object WebSocket.java de/tavendo/autobahn/WebSocket WebSocketConnectionObserver Tde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification WebSocketCloseNotification onOpen ()V onClose k(Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification;Ljava/lang/String;)V onTextMessage (Ljava/lang/String;)V onRawTextMessage ([B)V onBinaryMessage
|
SourceFile InnerClasses
|
@PK !*Cw ~ # de/tavendo/autobahn/WebSocket.classÊþº¾ 3 de/tavendo/autobahn/WebSocket java/lang/Object WebSocket.java 9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver WebSocketConnectionObserver UTF8_ENCODING Ljava/lang/String; UTF-8 connect L(Ljava/net/URI;Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;)V &de/tavendo/autobahn/WebSocketException r(Ljava/net/URI;Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;Lde/tavendo/autobahn/WebSocketOptions;)V
|
disconnect ()V isConnected ()Z sendBinaryMessage ([B)V sendRawTextMessage sendTextMessage (Ljava/lang/String;)V ConstantValue
|
Exceptions
|
SourceFile InnerClasses
|
|
PK !*Ã\Öj / de/tavendo/autobahn/WebSocketConnection$1.classÊþº¾ 3 1 )de/tavendo/autobahn/WebSocketConnection$1 java/lang/Object java/lang/Runnable WebSocketConnection.java 'de/tavendo/autobahn/WebSocketConnection failConnection k(Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification;Ljava/lang/String;)V
|
9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver de/tavendo/autobahn/WebSocket WebSocketConnectionObserver Tde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification WebSocketCloseNotification 4de/tavendo/autobahn/WebSocketConnection$SocketThread SocketThread this$0 )Lde/tavendo/autobahn/WebSocketConnection; <init> ,(Lde/tavendo/autobahn/WebSocketConnection;)V ()V
|
this +Lde/tavendo/autobahn/WebSocketConnection$1; run access$2 a(Lde/tavendo/autobahn/WebSocketConnection;)Lde/tavendo/autobahn/WebSocketConnection$SocketThread; $ %
|
& stopConnection (
|
) Code LocalVariableTable LineNumberTable
|
SourceFile EnclosingMethod InnerClasses + 8
|
*+µ *· ± ,
|
! " -
|
y # + 9 *´ ¸ '¶ *± , ! " -
|
}
|
~ . / 0 " @ PK !*¢~½/p p / de/tavendo/autobahn/WebSocketConnection$2.classÊþº¾ 3 0 )de/tavendo/autobahn/WebSocketConnection$2 java/lang/Object java/lang/Runnable WebSocketConnection.java 'de/tavendo/autobahn/WebSocketConnection failConnection k(Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification;Ljava/lang/String;)V
|
9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver de/tavendo/autobahn/WebSocket WebSocketConnectionObserver Tde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification WebSocketCloseNotification this$0 )Lde/tavendo/autobahn/WebSocketConnection; <init> ,(Lde/tavendo/autobahn/WebSocketConnection;)V ()V
|
this +Lde/tavendo/autobahn/WebSocketConnection$2; run android/os/Looper ! myLooper ()Landroid/os/Looper; # $
|
" % quit '
|
" ( Code LocalVariableTable LineNumberTable
|
SourceFile EnclosingMethod InnerClasses * 8
|
*+µ *· ± +
|
,
|
* 5 ¸ &¶ )± + ,
|
- . / @ PK !*RÀ / de/tavendo/autobahn/WebSocketConnection$3.classÊþº¾ 3 ( )de/tavendo/autobahn/WebSocketConnection$3 java/lang/Object java/lang/Runnable WebSocketConnection.java 'de/tavendo/autobahn/WebSocketConnection connect ()V
|
4de/tavendo/autobahn/WebSocketConnection$SocketThread SocketThread this$0 )Lde/tavendo/autobahn/WebSocketConnection; <init> ,(Lde/tavendo/autobahn/WebSocketConnection;)V
|
this +Lde/tavendo/autobahn/WebSocketConnection$3; run access$2 a(Lde/tavendo/autobahn/WebSocketConnection;)Lde/tavendo/autobahn/WebSocketConnection$SocketThread;
|
startConnection
|
Code LocalVariableTable LineNumberTable
|
SourceFile EnclosingMethod InnerClasses " 8
|
*+µ *· ± #
|
$
|
Ð " 9 *´ ¸ ¶ !± # $
|
Ô
|
Õ % & ' PK !*I
|
þm m / de/tavendo/autobahn/WebSocketConnection$4.classÊþº¾ 3 . )de/tavendo/autobahn/WebSocketConnection$4 java/lang/Object java/lang/Runnable WebSocketConnection.java 'de/tavendo/autobahn/WebSocketConnection scheduleReconnect ()Z
|
this$0 )Lde/tavendo/autobahn/WebSocketConnection; <init> ,(Lde/tavendo/autobahn/WebSocketConnection;)V ()V
|
this +Lde/tavendo/autobahn/WebSocketConnection$4; run access$0 ()Ljava/lang/String;
|
WebSocket reconnecting... android/util/Log d '(Ljava/lang/String;Ljava/lang/String;)I ! "
|
# reconnect %
|
& Code LocalVariableTable LineNumberTable
|
SourceFile EnclosingMethod InnerClasses ( 8
|
*+µ *· ± )
|
*
|
( D ¸ ¸ $W*´ ¶ 'W± ) *
|
+ , -
|
PK !*Ë_ : de/tavendo/autobahn/WebSocketConnection$SocketThread.classÊþº¾ 3 4de/tavendo/autobahn/WebSocketConnection$SocketThread java/lang/Thread WebSocketConnection.java 'de/tavendo/autobahn/WebSocketConnection SocketThread WS_CONNECTOR Ljava/lang/String; WebSocketConnector mWebSocketURI Ljava/net/URI; mSocket Ljava/net/Socket; mFailureMessage mHandler Landroid/os/Handler; <init> 7(Ljava/net/URI;Lde/tavendo/autobahn/WebSocketOptions;)V ()V
|
|
setName (Ljava/lang/String;)V
|
! this 6Lde/tavendo/autobahn/WebSocketConnection$SocketThread; uri options &Lde/tavendo/autobahn/WebSocketOptions; run android/os/Looper ) prepare +
|
* , android/os/Handler .
|
/ 1 java/lang/Object 3 notifyAll 5
|
4 6 java/lang/Throwable 8 loop :
|
* ; access$0 ()Ljava/lang/String; = >
|
? SocketThread exited. A android/util/Log C d '(Ljava/lang/String;Ljava/lang/String;)I E F
|
D G startConnection java/io/IOException J java/net/URI L getHost N >
|
M O getPort ()I Q R
|
M S getScheme U >
|
M V wss X java/lang/String Z equals (Ljava/lang/Object;)Z \ ]
|
[ ^ equalsIgnoreCase (Ljava/lang/String;)Z ` a
|
[ b 'android/net/SSLCertificateSocketFactory d
|
getDefault ()Ljavax/net/SocketFactory; f g
|
e h javax/net/SocketFactory j
|
k h createSocket &(Ljava/lang/String;I)Ljava/net/Socket; m n
|
k o getLocalizedMessage q >
|
K r host port I factory Ljavax/net/SocketFactory; e Ljava/io/IOException; stopConnection java/net/Socket | close ~
|
}
|
getHandler ()Landroid/os/Handler; getSocket ()Ljava/net/Socket; getFailureMessage ConstantValue Code LocalVariableTable LineNumberTable StackMapTable
|
SourceFile InnerClasses !
|
|
l *· *µ *µ * ¶ *+µ "± # $ % & ' ¼ µ ¶ ½ ¿ À ( +¸ -*» /Y· 0µ 2*YLÂ*¶ 7+ç +ÿ¸ <¸ @B¸ HW± + # $ " Æ Ç È É È Ì !Í *Î ÿ 9 I l q*´ "¶ PL*´ "¶ T= *´ "¶ WY¶ _
|
»=§ P=N*´ "¶ WY¶ c
|
¸ iN§ ¸ lN*-+ ¶ pµ § L*+¶ sµ *YLÂ*¶ 7+ç +ÿ± T W K d j m m o m 4 q # $ L t
|
D u v 0 $ w x X y z N Ô Õ × Ø $Ù (Ú +Û .ß 0à ?á Câ Fã Jç Tè Xé `ì dí hì pï C ý + [ü ÿ [ k ÿ Kü 4ÿ 9 { r *´ ¶ *µ § L*+¶ sµ ± K # $ y z ó ô õ ö ø O K / *´ 2° # $ û / *´ ° # $ þ
> / *´ ° # $
|
PK !*Ü¢j ; de/tavendo/autobahn/WebSocketConnection$ThreadHandler.classÊþº¾ 3 / 5de/tavendo/autobahn/WebSocketConnection$ThreadHandler android/os/Handler WebSocketConnection.java 'de/tavendo/autobahn/WebSocketConnection ThreadHandler mWebSocketConnection Ljava/lang/ref/WeakReference; HLjava/lang/ref/WeakReference<Lde/tavendo/autobahn/WebSocketConnection;>; <init> ,(Lde/tavendo/autobahn/WebSocketConnection;)V ()V
|
java/lang/ref/WeakReference (Ljava/lang/Object;)V
|
|
this 7Lde/tavendo/autobahn/WebSocketConnection$ThreadHandler; webSocketConnection )Lde/tavendo/autobahn/WebSocketConnection; handleMessage (Landroid/os/Message;)V get ()Ljava/lang/Object;
|
access$1 @(Lde/tavendo/autobahn/WebSocketConnection;Landroid/os/Message;)V " #
|
$ message Landroid/os/Message; Signature Code LocalVariableTable LineNumberTable StackMapTable
|
SourceFile InnerClasses
|
( ) M *· *» Y+· µ ± * + ) m *´ ¶ !À M,Æ ,+¸ %± * & '
|
+ , ü - .
|
|
PK !*8/n2 2 - de/tavendo/autobahn/WebSocketConnection.classÊþº¾ 3 'de/tavendo/autobahn/WebSocketConnection java/lang/Object de/tavendo/autobahn/WebSocket WebSocketConnection.java 9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver WebSocketConnectionObserver Tde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification WebSocketCloseNotification )de/tavendo/autobahn/WebSocketConnection$1 )de/tavendo/autobahn/WebSocketConnection$2 )de/tavendo/autobahn/WebSocketConnection$3 )de/tavendo/autobahn/WebSocketConnection$4 4de/tavendo/autobahn/WebSocketConnection$SocketThread SocketThread 5de/tavendo/autobahn/WebSocketConnection$ThreadHandler ThreadHandler 2de/tavendo/autobahn/WebSocketMessage$BinaryMessage $de/tavendo/autobahn/WebSocketMessage BinaryMessage 4de/tavendo/autobahn/WebSocketMessage$ClientHandshake ! ClientHandshake *de/tavendo/autobahn/WebSocketMessage$Close $ Close 3de/tavendo/autobahn/WebSocketMessage$ConnectionLost ' ConnectionLost *de/tavendo/autobahn/WebSocketMessage$Error * Error )de/tavendo/autobahn/WebSocketMessage$Ping - Ping )de/tavendo/autobahn/WebSocketMessage$Pong 0 Pong 6de/tavendo/autobahn/WebSocketMessage$ProtocolViolation 3 ProtocolViolation )de/tavendo/autobahn/WebSocketMessage$Quit 6 Quit 3de/tavendo/autobahn/WebSocketMessage$RawTextMessage 9 RawTextMessage 0de/tavendo/autobahn/WebSocketMessage$ServerError < ServerError 4de/tavendo/autobahn/WebSocketMessage$ServerHandshake ? ServerHandshake 0de/tavendo/autobahn/WebSocketMessage$TextMessage B TextMessage TAG Ljava/lang/String; WS_URI_SCHEME ws H WSS_URI_SCHEME wss K WS_WRITER WebSocketWriter N WS_READER WebSocketReader Q mHandler Landroid/os/Handler; mWebSocketReader %Lde/tavendo/autobahn/WebSocketReader; mWebSocketWriter %Lde/tavendo/autobahn/WebSocketWriter; mSocket Ljava/net/Socket; mSocketThread 6Lde/tavendo/autobahn/WebSocketConnection$SocketThread; mWebSocketURI Ljava/net/URI; mWebSocketSubprotocols [Ljava/lang/String; mWebSocketConnectionObserver Ljava/lang/ref/WeakReference; ZLjava/lang/ref/WeakReference<Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;>; mWebSocketOptions &Lde/tavendo/autobahn/WebSocketOptions; mPreviousConnection Z <init> ()V h i
|
j f g l E F n WebSocket connection created. p android/util/Log r d '(Ljava/lang/String;Ljava/lang/String;)I t u
|
s v ,(Lde/tavendo/autobahn/WebSocketConnection;)V h x
|
y S T { this )Lde/tavendo/autobahn/WebSocketConnection; sendTextMessage (Ljava/lang/String;)V W X h
|
C #de/tavendo/autobahn/WebSocketWriter
forward (Ljava/lang/Object;)V
|
payload sendRawTextMessage ([B)V h
|
: [B sendBinaryMessage
|
isConnected ()Z Y Z java/net/Socket
|
isClosed
|
failConnection k(Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification;Ljava/lang/String;)V java/lang/InterruptedException java/lang/StringBuilder ¢ fail connection [code = ¤
|
£ append -(Ljava/lang/Object;)Ljava/lang/StringBuilder; § ¨
|
£ © , reason = « -(Ljava/lang/String;)Ljava/lang/StringBuilder; §
|
£ ® toString ()Ljava/lang/String; ° ±
|
£ ² U V ´ #de/tavendo/autobahn/WebSocketReader ¶ quit ¸ i
|
· ¹ join » i
|
· ¼ Dcom/google/devtools/build/android/desugar/runtime/ThrowableExtension ¾ printStackTrace (Ljava/lang/Throwable;)V À Á
|
¿ Â mReader already NULL Ä
|
7 j
|
¼ mWriter already NULL È [ \ Ê
|
getHandler ()Landroid/os/Handler; Ì Í
|
Î
|
y android/os/Handler Ñ post (Ljava/lang/Runnable;)Z Ó Ô
|
Ò Õ mTransportChannel already NULL ×
|
y onClose Ú
|
Û worker threads stopped Ý code VLde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification; reason e Ljava/lang/InterruptedException; connect L(Ljava/net/URI;Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;)V &de/tavendo/autobahn/WebSocketException æ $de/tavendo/autobahn/WebSocketOptions è
|
é j r(Ljava/net/URI;Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;Lde/tavendo/autobahn/WebSocketOptions;)V ä ë
|
ì webSocketURI connectionObserver ;Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;
(Ljava/net/URI;[Ljava/lang/String;Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver;Lde/tavendo/autobahn/WebSocketOptions;)V ä ñ
|
ò options
|
already connected ö
|
ç WebSockets URI null. ù ] ^ û java/net/URI ý getScheme ÿ ±
|
þ java/lang/String equals (Ljava/lang/Object;)Z
|
%unsupported scheme for WebSockets URI _ `
|
java/lang/ref/WeakReference h
|
a b )(Lde/tavendo/autobahn/WebSocketOptions;)V h
|
é d e ä i
|
subprotocols
|
disconnect isAlive
|
|
% j 5Could not send WebSocket Close .. writer already null reconnect java/lang/Exception" 7(Ljava/net/URI;Lde/tavendo/autobahn/WebSocketOptions;)V h$
|
% start ' i
|
( wait * i
|
+ java/lang/Throwable-
|
y getSocket ()Ljava/net/Socket; 01
|
2 CANNOT_CONNECT 4 à 5 getFailureMessage 7 ±
|
8 createReader : i
|
; createWriter = i
|
> 2(Ljava/net/URI;Ljava/net/URI;[Ljava/lang/String;)V h@
|
"A INTERNAL_ERROR C à D getLocalizedMessage F ±
|
#G &could not connect to WebSockets serverI clientHandshake 6Lde/tavendo/autobahn/WebSocketMessage$ClientHandshake; Ljava/lang/Exception; scheduleReconnect getReconnectInterval ()I OP
|
éQ WebSocket reconnection scheduledS
|
y postDelayed (Ljava/lang/Runnable;J)Z VW
|
ÒX interval I shouldReconnect CONNECTION_LOST ] à ^ N
|
` get ()Ljava/lang/Object; bc
|
d RECONNECT f à g Û WebSocketObserver nullj reconnecting webSocketObserver processAppMessage message Ljava/lang/Object; `(Landroid/os/Handler;Ljava/net/Socket;Lde/tavendo/autobahn/WebSocketOptions;Ljava/lang/String;)V hq
|
r
|
( %WebSocket writer created and started.u
|
·r
|
·( %WebSocket reader created and started.y handleMessage (Landroid/os/Message;)V android/os/Message} obj p ~ mPayload F C onTextMessage
6could not call onTextMessage() .. handler already NULL : onRawTextMessage 9could not call onRawTextMessage() .. handler already NULL onBinaryMessage 8could not call onBinaryMessage() .. handler already NULL WebSockets Ping received
|
1 j . 1 WebSockets Pong received WebSockets Close received ( getCode P
|
%¡ (I)Ljava/lang/StringBuilder; §£
|
£¤ - ¦ getReason ¨ ±
|
%© )« (I)V h
|
%® opening handshake received° mSuccess ² g @³ onOpen µ i ¶ /could not call onOpen() .. handler already NULL¸ WebSockets connection lostº
|
¼ PROTOCOL_ERROR ¾ à ¿ WebSockets protocol violationÁ WebSockets internal error (Ã
|
mException ÅM +Æ
|
# ² SERVER_ERROR É à Ê Server error Ì mStatusCode Î[ =Ï (Ñ mStatusMessage Ó F =Ô n
|
Ö Landroid/os/Message; textMessage 2Lde/tavendo/autobahn/WebSocketMessage$TextMessage; rawTextMessage 5Lde/tavendo/autobahn/WebSocketMessage$RawTextMessage; binaryMessage 4Lde/tavendo/autobahn/WebSocketMessage$BinaryMessage; ping +Lde/tavendo/autobahn/WebSocketMessage$Ping; pong +Lde/tavendo/autobahn/WebSocketMessage$Pong; close ,Lde/tavendo/autobahn/WebSocketMessage$Close; serverHandshake 6Lde/tavendo/autobahn/WebSocketMessage$ServerHandshake; error ,Lde/tavendo/autobahn/WebSocketMessage$Error; 2Lde/tavendo/autobahn/WebSocketMessage$ServerError; access$0 access$1 @(Lde/tavendo/autobahn/WebSocketConnection;Landroid/os/Message;)V {|
|
í access$2 a(Lde/tavendo/autobahn/WebSocketConnection;)Lde/tavendo/autobahn/WebSocketConnection$SocketThread; <clinit> java/lang/Classò getName ô ±
|
óõ ConstantValue Signature Code LocalVariableTable LineNumberTable StackMapTable
|
Exceptions
|
SourceFile InnerClasses ! E F G F ÷ I J F ÷ L M F ÷ O P F ÷ R S T U V W X Y Z [ \ ] ^ _ ` a b ø c d e f g h i ù Y *· k*µ m² oq¸ wW*» Y*· zµ |± ú } ~ û = 9 > @ A ù H *´ » CY+· ¶ ± ú } ~ F û
|
H I ù H *´ » :Y+· ¶ ± ú } ~ û
|
M N ù H *´ » Y+· ¶ ± ú } ~ û
|
R S ù R *´ Æ *´ ¶ *´ ¶ ¬¬ ú } ~ û Xü ù ² o» £Y¥· ¦+¶ ª¬¶ ¯,¶ ¯¶ ³¸ wW*´ µÆ *´ µ¶ º*´ µ¶ ½§ N-¸ ç ² oŸ wW*´ Æ #*´ » 7Y· ƶ *´ ¶ ǧ N-¸ ç ² oɸ wW*´ Æ *´ ˶ Ï» Y*· ж ÖW§ ² oظ wW*´ ˶ Ï» Y*· Ù¶ ÖW*+,· ܲ oÞ¸ wW± . 5 8 ¡ ^ e h ¡ ú 4  } ~ Â ß à  á F 9 â ã i â ã û ^ ^ ` ' a . d 5 e 9 f = h @ i I l P m ^ p e q i r m t p u y x y ² ¸ Á ü x ¡^ ¡ ä å ù P *+,» éY· ê¶ í± ú } ~ î ^ ï ð û
|
ý ç ä ë ù U *+,-¶ ó± ú * } ~ î ^ ï ð ô e û
|
ý ç ä ñ ù ù p*¶ õ » çY÷· ø¿+Ç » çYú· ø¿*+µ ü*´ ü¶I¶ *´ ü¶L¶ » çY · ø¿*,µ *» Y-·µ*» éY·µ*·± ú 4 p } ~ p î ^ p ` p ï ð p ô e û 2 ¡ £ $ ¤ B ¥ M ¨ R © ^ ª k ¬ o ®ü -ý ç i ù z 2*´ Æ *´ ¶ *´ » %Y· ¶ § ² o ¸ wW*µ m± ú 2 } ~ û ± ² ³ " ´ , · 1 ¸ü " ! ù U *¶ õ *´ üÆ *·¬¬ ú } ~ û ¿ À Á Ãü ä i ù ñ Ì*» Y*´ ü*´·&µ Ë*´ ˶)*´ ËYLÂ*´ ˶,§ M+ç +ÿ*´ ˶ Ï» Y*·/¶ ÖW*´ ËYLÂ*´ ˶,§ M+ç +ÿ**´ ˶3µ *´ Ç *²6*´ ˶9· ܧ J*´ ¶ 6*¶<*¶?» "Y*´ ü*´ ·BL*´ +¶ § L*²E+¶H· ܧ *²6J· ܱ ! ( + ¡ ! . 1 1 3 1 N U X ¡ N [ ^ ^ ` ^ ¯ ²# ú Ì } ~ § KL ³ âM û b Ç É Ê ! Ì ( Í , Ê 4 Ð G Ø N Ú U Û Y Ø a ß l á s â ã å æ è § é ¯ ê ³ ë ¾ í Á î Ë ðü M ÿ + ¡ D.c ¡ D."ÿ - #ÿ ÿ N ù È L*´¶R<*´ Æ *´ ¶ *´ m § = ² oT¸ wW*´ |» Y*·U
¶YW ¬ ú L } ~ DZ[ * "\ g û 2 þ ÿ ! ÿ * . 8 D F J ü ü (@ü Ú ù
|
Y>+²6¥
|
+²_¦ *¶a>*´¶eÀ :Æ + ²h,¹i § #+,¹i § :¸ ç ² ok¸ wW± & A D# ú > Y } ~ Y ß à Y á F Wl g ! 8m ð F âM û : ! & *! 5" 8# A% F& K( N) X+ü ü ü " K# n ù 5 ± ú } ~ op û 1 = i ù Á E*» Y*´ |*´ *´O·sµ *´ ¶t*´ YLÂ*´ ¶,§ M+ç +ÿ² ov¸ wW± ' . 1 ¡ ' 4 7 7 9 7 ú E } ~ û " 8 9 ; '= .> 2; :B DCü ÿ 1 ¡ D. : i ù Á E*» ·Y*´ |*´ *´R·wµ µ*´ µ¶x*´ µYLÂ*´ µ¶,§ M+ç +ÿ² oz¸ wW± ' . 1 ¡ ' 4 7 7 9 7 ú E } ~ û " K L N 'P .Q 2N :U DVü ÿ 1 · ¡ D. {| ù N*´¶eÀ M+´Á C )+´À CN,Æ ,-´¹ §"² o¸ wW§+´Á : )+´À :N,Æ ,-´¹ §ò² o¸ wW§å+´Á )+´À N,Æ ,-´¹ §Â² o¸ wW§µ+´Á . 3+´À .N² o¸ wW» 1Y·:-´µ*´ ¶ §{+´Á 1 )+´À 1N² o» £Y· ¦-´¶ ª¶ ³¸ wW§K+´Á % M+´À %N² o» £Y· ¦-¶¢¶¥§¶ ¯-¶ª¶ ¯¬¶ ¯¶ ³¸ wW*´ » %Yè·¯¶ § ÷+´Á @ ;+´À @N² o±¸ wW-´´ Ô,Æ ,¹· § ² o¹¸ wW*µ m§ µ+´Á ( *²_»·½§ +´Á 4 *²À·½§ +´Á + 2+´À +N*²E» £YÄ· ¦-´Ç¶È¶ ¯¬¶ ¯¶ ³·½§ N+´Á = <+´À =N*²Ë» £YÍ· ¦-´Ð¶¥Ò¶ ¯-´Õ¶ ¯¬¶ ¯¶ ³·½§ *+´¶×± ú N } ~ NoØ Cm ð ÙÚ M ÛÜ } ÝÞ %ßà À áâ ç áâ ?ãä k -åæ Û $çè .çé û Ú 6 Y [ \ ^ !_ +` .a 8d Ee Mg Qh [i ^j hm un }p q r s v ¥w x ·z À{ É| Ò~ ß çEVcku|¥¯¼Æ Ó¡Û¢ÿ¤ ¥¦B¨E©M¬ü 6 ý . Cú ü " :ú ü " ú 9/û Sü / @ ú 8û Bê ± ù ² o° û %ëì ù *+·î± û Xïð ù *´ Ë° û 1 ñ i ù % ¶ö³ o± û
|
% ) þ ÿ ª
|
@
|
" # % & ( ) + , . / 1 2 4 5 7 8 : ; = > @ A C D PK !* Aìl) ) 4 de/tavendo/autobahn/WebSocketConnectionHandler.classÊþº¾ 3 ' .de/tavendo/autobahn/WebSocketConnectionHandler java/lang/Object 9de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver WebSocketConnectionHandler.java de/tavendo/autobahn/WebSocket WebSocketConnectionObserver Tde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification WebSocketCloseNotification <init> ()V
|
this 0Lde/tavendo/autobahn/WebSocketConnectionHandler; onOpen onClose k(Lde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification;Ljava/lang/String;)V code VLde/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification; reason Ljava/lang/String; onTextMessage (Ljava/lang/String;)V payload onRawTextMessage ([B)V [B onBinaryMessage Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses ! " / *· ± # $ " + ± # $ " ? ± # $ * " 5 ± # $ 3 " 5 ± # $ < ! " 5 ± # $ D % &
|
@PK !*ëî+ºl l , de/tavendo/autobahn/WebSocketException.classÊþº¾ 3 &de/tavendo/autobahn/WebSocketException java/lang/Exception WebSocketException.java serialVersionUID J <init> (Ljava/lang/String;)V
|
|
this (Lde/tavendo/autobahn/WebSocketException; message Ljava/lang/String; *(Ljava/lang/String;Ljava/lang/Throwable;)V
|
|
t Ljava/lang/Throwable; ConstantValue Code LocalVariableTable LineNumberTable
|
SourceFile !
|
> *+· ±
|
|
I *+,· ±
|
PK !*Ì
|
X® . de/tavendo/autobahn/WebSocketFrameHeader.classÊþº¾ 3 C (de/tavendo/autobahn/WebSocketFrameHeader java/lang/Object WebSocketFrameHeader.java mOpcode I mFin Z mReserved
|
mHeaderLen mPayloadLen mTotalLen mMask [B <init> ()V
|
this *Lde/tavendo/autobahn/WebSocketFrameHeader; getOpcode ()I setOpcode (I)V opcode isFin ()Z setFin (Z)V fin getReserved
|
% setReserved reserved getHeaderLength * setHeaderLength headerLength getPayloadLength / setPayloadLength payloadLength getTotalLength 4 setTotalLen totalLength getMask ()[B : setMask ([B)V mask Code LocalVariableTable LineNumberTable
|
SourceFile !
|
? / *· ± @ A ? / *´ ¬ @ A ? > *µ ± @ A
|
? / *´ ¬ @ A ! " ? > *µ ± @ # A
|
$ ? / *´ &¬ @ A ' ? > *µ &± @ ( A
|
) ? / *´ +¬ @ A , ? > *µ +± @ - A
|
" # . ? / *´ 0¬ @ A % 1 ? > *µ 0± @ 2 A
|
( ) 3 ? / *´ 5¬ @ A + 6 ? > *µ 5± @ 7 A
|
. / 8 9 ? / *´ ;° @ A 1 < = ? > *+µ ;± @ > A
|
4 5 B PK !*ä à' ' 8 de/tavendo/autobahn/WebSocketMessage$BinaryMessage.classÊþº¾ 3 2de/tavendo/autobahn/WebSocketMessage$BinaryMessage ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage BinaryMessage Message mPayload [B <init> ([B)V ()V
|
|
this 4Lde/tavendo/autobahn/WebSocketMessage$BinaryMessage; payload Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
F
|
*· *+µ ±
|
|
PK !*úåõs s : de/tavendo/autobahn/WebSocketMessage$ClientHandshake.classÊþº¾ 3 * 4de/tavendo/autobahn/WebSocketMessage$ClientHandshake ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage ClientHandshake Message mURI Ljava/net/URI; mOrigin mSubprotocols [Ljava/lang/String; <init> (Ljava/net/URI;)V ()V
|
|
this 6Lde/tavendo/autobahn/WebSocketMessage$ClientHandshake; uri 2(Ljava/net/URI;Ljava/net/URI;[Ljava/lang/String;)V origin subprotocols getURI ()Ljava/net/URI; getOrigin getSubprotocols ()[Ljava/lang/String; Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
% X *· *+µ *µ *µ ± & ' > ? @ A B % l *· *+µ *,µ *-µ ± & * ' D E F G H ! % / *´ ° & ' M " ! % / *´ ° & ' P # $ % / *´ ° & ' S ( ) PK !*r 04Ì Ì 0 de/tavendo/autobahn/WebSocketMessage$Close.classÊþº¾ 3 % *de/tavendo/autobahn/WebSocketMessage$Close ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Close Message mCode I mReason Ljava/lang/String; <init> ()V
|
|
this ,Lde/tavendo/autobahn/WebSocketMessage$Close; (I)V code (ILjava/lang/String;)V reason getCode ()I getReason ()Ljava/lang/String; Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
G *· *óµ *µ ± ! " § ¨ © ª O *· *µ *µ ± ! " ¬ ® ¯ Y *· *µ *,µ ± ! " ± ² ³ ´ / *´ ¬ ! " ¸ / *´ ° ! " » # $ PK !* ö ß ß 9 de/tavendo/autobahn/WebSocketMessage$ConnectionLost.classÊþº¾ 3 3de/tavendo/autobahn/WebSocketMessage$ConnectionLost ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage ConnectionLost Message <init> ()V
|
|
this 5Lde/tavendo/autobahn/WebSocketMessage$ConnectionLost; Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
/ *· ± a PK !*èÎÕ1 1 0 de/tavendo/autobahn/WebSocketMessage$Error.classÊþº¾ 3 *de/tavendo/autobahn/WebSocketMessage$Error ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Error Message
|
mException Ljava/lang/Exception; <init> (Ljava/lang/Exception;)V ()V
|
|
this ,Lde/tavendo/autobahn/WebSocketMessage$Error; e Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
F
|
*· *+µ ±
|
|
~ PK !*Dc` 2 de/tavendo/autobahn/WebSocketMessage$Message.classÊþº¾ 3 ,de/tavendo/autobahn/WebSocketMessage$Message java/lang/Object WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message <init> ()V
|
|
this .Lde/tavendo/autobahn/WebSocketMessage$Message; Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
/ *· ± /
|
PK !*o ãV V / de/tavendo/autobahn/WebSocketMessage$Ping.classÊþº¾ 3 )de/tavendo/autobahn/WebSocketMessage$Ping ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message Ping mPayload [B <init> ()V
|
|
this +Lde/tavendo/autobahn/WebSocketMessage$Ping; ([B)V payload Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
<
|
*· *µ ±
|
Ä Å Æ F
|
*· *+µ ±
|
|
È É Ê PK !*`V V / de/tavendo/autobahn/WebSocketMessage$Pong.classÊþº¾ 3 )de/tavendo/autobahn/WebSocketMessage$Pong ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message Pong mPayload [B <init> ()V
|
|
this +Lde/tavendo/autobahn/WebSocketMessage$Pong; ([B)V payload Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
<
|
*· *µ ±
|
Ò Ó Ô F
|
*· *+µ ±
|
|
Ö × Ø PK !*À48{ { < de/tavendo/autobahn/WebSocketMessage$ProtocolViolation.classÊþº¾ 3 6de/tavendo/autobahn/WebSocketMessage$ProtocolViolation ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message ProtocolViolation
|
mException (Lde/tavendo/autobahn/WebSocketException; <init> +(Lde/tavendo/autobahn/WebSocketException;)V ()V
|
|
this 8Lde/tavendo/autobahn/WebSocketMessage$ProtocolViolation; e Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
F
|
*· *+µ ±
|
|
t u v PK !*mb¥Á Á / de/tavendo/autobahn/WebSocketMessage$Quit.classÊþº¾ 3 )de/tavendo/autobahn/WebSocketMessage$Quit ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message Quit <init> ()V
|
|
this +Lde/tavendo/autobahn/WebSocketMessage$Quit; Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
/ *· ± 3 PK !*@,©b* * 9 de/tavendo/autobahn/WebSocketMessage$RawTextMessage.classÊþº¾ 3 3de/tavendo/autobahn/WebSocketMessage$RawTextMessage ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message RawTextMessage mPayload [B <init> ([B)V ()V
|
|
this 5Lde/tavendo/autobahn/WebSocketMessage$RawTextMessage; payload Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
F
|
*· *+µ ±
|
|
PK !*gQ¼ 6 de/tavendo/autobahn/WebSocketMessage$ServerError.classÊþº¾ 3 0de/tavendo/autobahn/WebSocketMessage$ServerError ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message ServerError mStatusCode I mStatusMessage Ljava/lang/String; <init> (ILjava/lang/String;)V ()V
|
|
this 2Lde/tavendo/autobahn/WebSocketMessage$ServerError;
|
statusCode statusMessage Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
Y *· *µ *,µ ± h i j k PK !*üÞM9+ + : de/tavendo/autobahn/WebSocketMessage$ServerHandshake.classÊþº¾ 3 4de/tavendo/autobahn/WebSocketMessage$ServerHandshake ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message ServerHandshake mSuccess Z <init> (Z)V ()V
|
|
this 6Lde/tavendo/autobahn/WebSocketMessage$ServerHandshake; success Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
F
|
*· *µ ±
|
|
[ \ ] PK !*Õ§ÍA A 6 de/tavendo/autobahn/WebSocketMessage$TextMessage.classÊþº¾ 3 0de/tavendo/autobahn/WebSocketMessage$TextMessage ,de/tavendo/autobahn/WebSocketMessage$Message WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage Message TextMessage mPayload Ljava/lang/String; <init> (Ljava/lang/String;)V ()V
|
|
this 2Lde/tavendo/autobahn/WebSocketMessage$TextMessage; payload Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
F
|
*· *+µ ±
|
|
PK !*¡«ÿ ÿ = de/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode.classÊþº¾ 3 0 7de/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode java/lang/Object WebSocketMessage.java $de/tavendo/autobahn/WebSocketMessage WebSocketCloseCode NORMAL I è ENDPOINT_GOING_AWAY é ENDPOINT_PROTOCOL_ERROR ê ENDPOINT_UNSUPPORTED_DATA_TYPE ë RESERVED ì RESERVED_NO_STATUS í RESERVED_NO_CLOSING_HANDSHAKE î ENDPOINT_BAD_DATA ï POLICY_VIOLATION ð MESSAGE_TOO_BIG ñ ENDPOINT_NEEDS_EXTENSION ò UNEXPECTED_CONDITION ó RESERVED_TLS_REQUIRED ÷ <init> ()V $ %
|
& this 9Lde/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode; ConstantValue Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses !
|
*
|
*
|
*
|
*
|
*
|
*
|
*
|
*
|
*
|
*
|
*
|
* ! "
|
* # $ % + / *· '± , ( ) - . /
|
PK !*/oµ´ ´ * de/tavendo/autobahn/WebSocketMessage.classÊþº¾ 3 > $de/tavendo/autobahn/WebSocketMessage java/lang/Object WebSocketMessage.java 2de/tavendo/autobahn/WebSocketMessage$BinaryMessage BinaryMessage 4de/tavendo/autobahn/WebSocketMessage$ClientHandshake ClientHandshake *de/tavendo/autobahn/WebSocketMessage$Close Close 3de/tavendo/autobahn/WebSocketMessage$ConnectionLost ConnectionLost *de/tavendo/autobahn/WebSocketMessage$Error Error ,de/tavendo/autobahn/WebSocketMessage$Message Message )de/tavendo/autobahn/WebSocketMessage$Ping Ping )de/tavendo/autobahn/WebSocketMessage$Pong Pong 6de/tavendo/autobahn/WebSocketMessage$ProtocolViolation ProtocolViolation )de/tavendo/autobahn/WebSocketMessage$Quit ! Quit 3de/tavendo/autobahn/WebSocketMessage$RawTextMessage $ RawTextMessage 0de/tavendo/autobahn/WebSocketMessage$ServerError ' ServerError 4de/tavendo/autobahn/WebSocketMessage$ServerHandshake * ServerHandshake 0de/tavendo/autobahn/WebSocketMessage$TextMessage - TextMessage 7de/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode 0 WebSocketCloseCode <init> ()V 3 4
|
5 this &Lde/tavendo/autobahn/WebSocketMessage; Code LocalVariableTable LineNumberTable
|
SourceFile InnerClasses ! 3 4 9 / *· 6± : 7 8 ; < = z
|
" # % & ( ) + , . / 1 2 PK !*,::±S S * de/tavendo/autobahn/WebSocketOptions.classÊþº¾ 3 K $de/tavendo/autobahn/WebSocketOptions java/lang/Object WebSocketOptions.java mMaxFramePayloadSize I mMaxMessagePayloadSize mReceiveTextMessagesRaw Z mTcpNoDelay mSocketReceiveTimeout mSocketConnectTimeout mValidateIncomingUtf8 mMaskClientFrames mReconnectInterval <init> ()V
|
|
|
|
"
|
$ & this &Lde/tavendo/autobahn/WebSocketOptions; )(Lde/tavendo/autobahn/WebSocketOptions;)V other setReceiveTextMessagesRaw (Z)V enabled getReceiveTextMessagesRaw ()Z setMaxFramePayloadSize (I)V size getMaxFramePayloadSize ()I setMaxMessagePayloadSize getMaxMessagePayloadSize setTcpNoDelay getTcpNoDelay setSocketReceiveTimeout timeoutMs getSocketReceiveTimeout setSocketConnectTimeout getSocketConnectTimeout setValidateIncomingUtf8 getValidateIncomingUtf8 setMaskClientFrames getMaskClientFrames setReconnectInterval reconnectInterval getReconnectInterval Code LocalVariableTable LineNumberTable StackMapTable
|
SourceFile !
|
|
|
|
F 8*· *µ *µ *µ *µ * ȵ *pµ !*µ #*µ %*µ '± G 8 ( ) H . , .
|
/ 0 1 2 ! 3 ( 4 - 5 2 6 7 7 * F © M*· *+´ µ *+´ µ *+´ µ *+´ µ *+´ µ *+´ !µ !*+´ #µ #*+´ %µ %*+´ 'µ '± G M ( ) M + ) H . > @ A B C $ D , E 4 F < G D H L I , - F > *µ ± G ( ) .
|
H
|
T U / 0 F / *´ ¬ G ( ) H ^ 1 2 F j *µ *´ *´ ¢ **´ µ ± G ( ) 3 H j k l m p I 4 5 F / *´ ¬ G ( ) H y 6 2 F j *µ *´ *´ ¢ **´ µ ± G ( ) 3 H
I 7 5 F / *´ ¬ G ( ) H 8 - F > *µ ± G ( ) .
|
H
|
9 0 F / *´ ¬ G ( ) H ¨ : 2 F O
|
*µ ± G
|
( )
|
; H ´ µ · I < 5 F / *´ ¬ G ( ) H ¿ = 2 F O
|
*µ !± G
|
( )
|
; H Ì Í Ï I > 5 F / *´ !¬ G ( ) H × ? - F > *µ #± G ( ) .
|
H
|
ã ä @ 0 F / *´ #¬ G ( ) H ì A - F > *µ %± G ( ) .
|
H
|
ù ú B 0 F / *´ %¬ G ( ) H C 2 F > *µ '± G ( ) D H
|
E 5 F / *´ '¬ G ( ) H J PK !*?×N2 2 5 de/tavendo/autobahn/WebSocketReader$ReaderState.classÊþº¾ 3 : /de/tavendo/autobahn/WebSocketReader$ReaderState CLjava/lang/Enum<Lde/tavendo/autobahn/WebSocketReader$ReaderState;>; java/lang/Enum WebSocketReader.java #de/tavendo/autobahn/WebSocketReader ReaderState STATE_CLOSED 1Lde/tavendo/autobahn/WebSocketReader$ReaderState; STATE_CONNECTING STATE_CLOSING
|
STATE_OPEN ENUM$VALUES 2[Lde/tavendo/autobahn/WebSocketReader$ReaderState; <init> (Ljava/lang/String;I)V
|
this values 4()[Lde/tavendo/autobahn/WebSocketReader$ReaderState; java/lang/System arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V
|
valueOf E(Ljava/lang/String;)Lde/tavendo/autobahn/WebSocketReader$ReaderState; 5(Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Enum; "
|
# <clinit> ()V
|
|
|
) , / 2 Code LocalVariableTable LineNumberTable Signature
|
SourceFile InnerClasses@0 @
|
@ @ @ 4 1 *+ · ± 5 6 , 4 . ² YK*¾Y<½ YM¸ ,° 6 ! 4 "
|
*¸ $À ° 6 % & 4 | T» Y'· (³ *» Y+· (³ -» Y.· (³ 0» Y1· (³ 3½ Y² *SY² -SY² 0SY² 3S³ ± 6 - . / ' 0 4 , 7 8 9
|
@PK !*¥=~L4 L4 ) de/tavendo/autobahn/WebSocketReader.classÊþº¾ 33 #de/tavendo/autobahn/WebSocketReader java/lang/Thread WebSocketReader.java 2de/tavendo/autobahn/WebSocketMessage$BinaryMessage $de/tavendo/autobahn/WebSocketMessage BinaryMessage *de/tavendo/autobahn/WebSocketMessage$Close Close 3de/tavendo/autobahn/WebSocketMessage$ConnectionLost ConnectionLost *de/tavendo/autobahn/WebSocketMessage$Error Error )de/tavendo/autobahn/WebSocketMessage$Ping Ping )de/tavendo/autobahn/WebSocketMessage$Pong Pong 6de/tavendo/autobahn/WebSocketMessage$ProtocolViolation ProtocolViolation 3de/tavendo/autobahn/WebSocketMessage$RawTextMessage RawTextMessage 0de/tavendo/autobahn/WebSocketMessage$ServerError ServerError 4de/tavendo/autobahn/WebSocketMessage$ServerHandshake # ServerHandshake 0de/tavendo/autobahn/WebSocketMessage$TextMessage & TextMessage /de/tavendo/autobahn/WebSocketReader$ReaderState ) ReaderState TAG Ljava/lang/String; mWebSocketConnectionHandler Landroid/os/Handler; mSocket Ljava/net/Socket; mInputStream Ljava/io/InputStream; mWebSocketOptions &Lde/tavendo/autobahn/WebSocketOptions; mStopped Z mNetworkBuffer [B mApplicationBuffer Ljava/nio/ByteBuffer; mMessagePayload 1Lde/tavendo/autobahn/NoCopyByteArrayOutputStream; mState 1Lde/tavendo/autobahn/WebSocketReader$ReaderState; mInsideMessage mMessageOpcode I mFrameHeader *Lde/tavendo/autobahn/WebSocketFrameHeader; mUTF8Validator #Lde/tavendo/autobahn/Utf8Validator; =$SWITCH_TABLE$de$tavendo$autobahn$WebSocketReader$ReaderState [I <init> `(Landroid/os/Handler;Ljava/net/Socket;Lde/tavendo/autobahn/WebSocketOptions;Ljava/lang/String;)V (Ljava/lang/String;)V I K
|
L 6 7 N @ 7 P !de/tavendo/autobahn/Utf8Validator R ()V I T
|
S U E F W . / Y 0 1 [ 4 5 ] 8 9 _ $de/tavendo/autobahn/WebSocketOptions a getMaxFramePayloadSize ()I c d
|
b e java/nio/ByteBuffer g allocateDirect (I)Ljava/nio/ByteBuffer; i j
|
h k : ; m /de/tavendo/autobahn/NoCopyByteArrayOutputStream o getMaxMessagePayloadSize q d
|
b r (I)V I t
|
p u < = w C D y STATE_CONNECTING { ? * | > ? ~ , - WebSocket reader created. android/util/Log d '(Ljava/lang/String;Ljava/lang/String;)I
|
this %Lde/tavendo/autobahn/WebSocketReader; master socket options
|
threadName quit notify (Ljava/lang/Object;)V android/os/Handler obtainMessage ()Landroid/os/Message;
|
android/os/Message obj Ljava/lang/Object; sendMessage (Landroid/os/Message;)Z ¡
|
¢ message msg Landroid/os/Message; processData ()Z java/lang/Exception © position « d
|
h ¬ get (I)B ® ¯
|
h ° &de/tavendo/autobahn/WebSocketException ² $RSV != 0 and no extension negotiated ´
|
³ L masked server frame · fragmented control frame ¹ .control frame with payload length > 125 octets » java/lang/StringBuilder ½ $control frame using reserved opcode ¿
|
¾ L append (I)Ljava/lang/StringBuilder; Â Ã
|
¾ Ä toString ()Ljava/lang/String; Æ Ç
|
¾ È /received close control frame with payload len 1 Ê !data frame using reserved opcode Ì ;received continuation data frame outside fragmented message Î Dreceived non-continuation data frame while inside fragmented message Ð logic error Ò
|
ª L ~ =invalid data frame length (not using minimal length encoding) × "invalid data frame length (> 2^63) Ù frame payload too large Ý (de/tavendo/autobahn/WebSocketFrameHeader ß
|
à U setOpcode â t
|
à ã setFin (Z)V å æ
|
à ç setReserved é t
|
à ê setPayloadLength ì t
|
à í setHeaderLength ï t
|
à ð getHeaderLength ò d
|
à ó getPayloadLength õ d
|
à ö setTotalLen ø t
|
à ù 9 setMask ([B)V ü ý
|
à þ getTotalLength d
|
à (I)Ljava/nio/Buffer; «
|
h ([BII)Ljava/nio/ByteBuffer; ®
|
h limit
|
h
|
compact ()Ljava/nio/ByteBuffer;
|
h getOpcode d
|
à invalid close code java/lang/System arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V
|
validate ([B)Z
|
S isValid ¨
|
S !invalid close reasons (not UTF-8)" java/lang/String$ UTF-8& ([BLjava/lang/String;)V I(
|
%) onClose (ILjava/lang/String;)V +,
|
- onPing / ý
|
0 onPong 2 ý
|
3 A B 5 getValidateIncomingUtf8 7 ¨
|
b8 reset : T
|
S; size = d
|
p> message payload too large@ %invalid UTF-8 in text message payloadB write D ý
|
pE isFin G ¨
|
àH :UTF-8 text message payload ended within Unicode code pointJ getReceiveTextMessagesRaw L ¨
|
bM toByteArray ()[B OP
|
pQ onRawTextMessage S ý
|
T onTextMessage V K
|
W onBinaryMessage Y ý
|
Z
|
p; b0 B fin rsv opcode b1 masked payload_len1 mask_len
|
header_len i payload_len J mask j framePayload oldPosition code reason ra val s onHandshake I æ
|
$t
|
v success I,
|
y I ý
|
{ payload
|
{
|
' L
|
{
|
{ processHandshake $java/io/UnsupportedEncodingException parseHTTPStatus ()Landroid/util/Pair;
|
android/util/Pair first java/lang/Integer intValue d
|
second
|
!y
|
STATE_OPEN ? * STATE_CLOSED ? * s æ
|
res pos serverError status :Landroid/util/Pair<Ljava/lang/Integer;Ljava/lang/String;>; Landroid/util/Pair; Status: %d (%s)¥ java/lang/Object§ valueOf (I)Ljava/lang/Integer; ©ª
|
« format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; ®
|
%¯ w ±
|
² '(Ljava/lang/Object;Ljava/lang/Object;)V I´
|
µ beg end
|
statusCode digit eol statusMessageLength statusBuf statusMessage consumeData ()[I GÀ
|
Á ordinal à d
|
*Ä § ¨
|
Æ ¨
|
È run java/io/IOExceptionË java/net/SocketExceptionÍ notifyAll Ï T
|
¨Ð java/lang/ThrowableÒ java/net/SocketÔ getInputStream ()Ljava/io/InputStream; Ö×
|
ÕØ java/io/InputStreamÚ getLocalizedMessage Ü Ç
|
ÌÝ e ß
|
à 2 3 â WebSocker reader running.ä clear ()Ljava/nio/Buffer; æç
|
hè read ([B)I êë
|
Ûì put î
|
hï ¿ ¨
|
ñ run() : ConnectionLostó
|
U WebSocketReader read() failed.ö run() : WebSocketException (ø
|
³ È -(Ljava/lang/String;)Ljava/lang/StringBuilder; Âû
|
¾ü )þ +(Lde/tavendo/autobahn/WebSocketException;)V I
|
run() : SocketException (
|
Î È run() : IOException (
|
Ì È run() : Exception (
|
ª È (Ljava/lang/Exception;)V I
|
WebSocket reader ended. inputStream Ljava/io/IOException; bytesRead (Lde/tavendo/autobahn/WebSocketException; Ljava/net/SocketException; Ljava/lang/Exception; java/lang/NoSuchFieldError G H H values 4()[Lde/tavendo/autobahn/WebSocketReader$ReaderState;
|
* STATE_CLOSING ? *! <clinit> java/lang/Class$ getCanonicalName & Ç
|
%' Code LocalVariableTable LineNumberTable StackMapTable
|
Exceptions LocalVariableTypeTable Signature <()Landroid/util/Pair<Ljava/lang/Integer;Ljava/lang/String;>;
|
SourceFile InnerClasses ! , - . / 0 1 2 3 4 5 B 6 7 8 9 : ; < = > ? @ 7 A B C D E F
|
G H I J ) ì f*· M*µ O*µ Q*» SY· Vµ X*+µ Z*,µ \*-µ ^* ¼µ `*-¶ f`¸ lµ n*» pY-¶ s· vµ x*µ z*² }µ ² ¸ W± * 4 f f / f 1 f 5 f - + : Q 8 A E S U % V * X 3 Y A Z P \ U ] \ _ e ` T ) A *µ O² ¸ W± * + h j k ) a *´ Z¶ M,+µ *´ Z,¶ £W± * ¤ ¥ ¦ + v w x y § ¨ )
|
Q [*´ zÇx*´ n¶ ¡k*´ n¶ ±< ~ § =p~z>~6*´ n¶ ±6 ~ § 6~6 » ³Yµ· ¶¿ » ³Y¸· ¶¿¤ g » ³Yº· ¶¿}¤ » ³Y¼· ¶¿ * #
|
» ³Y» ¾YÀ· Á¶ Ŷ É· ¶¿ i c» ³YË· ¶¿ ( " » ³Y» ¾YÍ· Á¶ Ŷ É· ¶¿*´ Q » ³YÏ· ¶¿*´ Q » ³YÑ· ¶¿ § 66 ~¢ `6 § .~ `6 §
|
`6 § » ªYÓ· Ô¿*´ n¶ ¡ð6
|
7 ~ ? ÿ*´ n
|
¶ ±~x ÿ*´ n
|
`¶ ±~
7 Õ » ³YØ· ¶¿
|
§ Ý Ñ *´ n
|
`¶ ±~ » ³YÚ· ¶¿ ÿ*´ n
|
`¶ ±~8x ÿ*´ n
|
`¶ ±~0x ÿ*´ n
|
`¶ ±~(x ÿ*´ n
|
`¶ ±~ x ÿ*´ n
|
`¶ ±~x ÿ*´ n
|
`¶ ±~x ÿ*´ n
|
`¶ ±~x ÿ*´ n
|
`¶ ±~
7 Û » ³YØ· ¶¿
|
§
7 *´ ^¶ f
» ³YÞ· ¶¿*» àY· áµ z*´ z¶ ä*´ z ¶ è*´ z ¶ ë*´ z ¶ î*´ z ¶ ñ*´ z*´ z¶ ô*´ z¶ ÷`¶ ú <¼: 6§
|
ÿ*´ n
|
`¶ ±~T¡ÿä*´ z ¶ ÿ
|
§ *´ z¶ ÿ*´ z¶ ÷ *´ n¶ *´ z¶¢ ¬¬¬¬*´ n¶ *´ z¶¡ÏL*´ n¶ =*´ z¶ ÷ -*´ z¶ ÷¼L*´ n*´ z¶ ô¶W*´ n+*´ z¶ ÷¶W*´ n*´ z¶¶W*´ n ¶ W*´ n¶W*´ z¶¤@*´ z¶ í>:*´ z¶ ÷¡ æ+3 ÿ~ h+3 ÿ~`> è¡ W è¡ I ·£ B è ; é 4 ê - ë & ï ð ñ ò
|
ó
|
¡ » ³Y» ¾Y· Á ¶ Ŷ É· ¶¿*´ z¶ ÷¤ S*´ z¶ ÷d¼:+*´ z¶ ÷d¸» SY· V:¶ W¶! » ³Y#· ¶¿»%Y'·*:* ¶.§G*´ z¶ *+¶1§3*´ z¶
|
*+¶4§ » ªYÓ· Ô¿*´ Q ,*µ Q**´ z¶µ6*´6 *´ ^¶9
|
*´ X¶<+Æ R*´ x¶?+¾`*´ ^¶ s¤ » ³YA· ¶¿*´6 #*´ ^¶9 *´ X+¶ » ³YC· ¶¿*´ x+¶F*´ z¶I *´6 T*´ ^¶9 *´ X¶! » ³YK· ¶¿*´ ^¶N **´ x¶R¶U§ =»%Y*´ x¶R'·*N*-¶X§ #*´6 **´ x¶R¶[§ » ªYÓ· Ô¿*µ Q*´ x¶\*µ z*´ n¶ ¬¬¬ * Ô [ _]^ )Q_ 7 0J` B 6Da B @:b^ P*c 7 W#d B A9e B D6f B êg B
|
çhi 1j 9 "k B Êl 9 Âm B øn B
|
õo - µ Cp 9 Ï )q F r - + n
) 0 6 @ P W [ e j t { ¡ £ ¯ ¤ È ¦ Õ § ß « ð ¬ ® ¯ ±+ ²5 ¶A ·D ¹K ºQ »[ ¼a ½k ¾r ¿u Á Å È É Ê Ë» ÌÄ ÍÎ ÏÑ ÐÛ Ñí Ò÷ Ô Õ Ô Ö. Ô/ ×A ÔB ØT ÔU Ùg Ôh Ú{ Ô| Û Ô Ü Ý£ ߦ à© á® å¼ æÆ êÑ ëÚ ìâ íê îô ïý ð ò ó ô# õ9 ôB ÷K ùN úQ ûY ÿxz |¡«ºË Ú ã ë!÷$&'
|
),)-0.>/}026¨8µ9Æ;Ï<×=ß>ê@øDÿFHJ"L'N*Q4W;Y@ZK[]\d`hc|dh¤i¯m·qÁsÉvÝwè{ò~ý "-0:?FKY¡, 8ü '@ÿ $ @ý -)@ý ý N"û «ý \ ûù ù ÿ ý N ûý ±ý L û Sÿ û% ù /"'0 ù - ª s æ ) E *» $Y·u¶w± * x 7 +
|
® ¯ +, ) P *» Y,·z¶w± * n B o - +
|
· ¸ / ý ) E *» Y+·|¶w± * } 9 +
|
 à 2 ý ) E *» Y+·~¶w± * } 9 +
|
Í Î V K ) E *» 'Y+·¶w± * } - +
|
Û Ü S ý ) E *» Y+·¶w± * } 9 +
|
é ê Y ý ) E *» Y+·¶w± * } 9 +
|
ô õ ¨ ) 9 %<*´ n¶ d=§*´ n `¶ ± *´ n `¶ ±
|
ò*´ n `¶ ± ã*´ n `¶ ±
|
Ô*´ n¶ >6*´ n¶ ±H b*´ n¶ ±T U*´ n¶ ±T H*´ n¶ ±P ;*·:´À¶,¡ $*» !Y´À¶´À%·¶w6*´ n `¶W*´ n ¶ W*´ n¶W *´ n¶ § <*²µ § <*²µ *µ O* § ¶§
|
ÿ þï¬ * > % # 7 B S Ém B V Æ¡ 7 2¢¤ . 2¢£ + z ý þ ÿ - < K S
|
V c p } ¡ ¿ Â Í Ö Þ ã ó ú! ý" ÿ#$ '( þ#+, , ý ý ².@
|
I ÿ ù -
) ü ü<§ *´ n¶ ± § *´ n¶ ¡ÿå`=§ *´ n ¶ ± § *´ n¶ ¡ÿå>6§ *´ n`¶ ±0d6
|
h> `>` ¡ÿÞ 6§ *´ n¶ ± § *´ n¶ ¡ÿã d6¼:*´ n ¶W*´ n¶W»%Y'·*:² ¦½¨Y ¸¬SYS¸°¸³W»Y ¸¬·¶° * f
|
ü ú· B ' Õ¸ B M ¯¹ B P (g B c
|
º B ~ ~» B § U¼ B O½ 9 Ñ +¾ - + b 1 2 1 #5 *6 :5 H9 K: M; S< c= h> m; xA {C D C ¡F §G H ¶I ÃJ ÑK îL, ü
|
ü
|
ý
|
- / 0 ¿ ¨ ) | 6¸Â*´ ¶Å.ª ) " $ *·Ç¬¬*·É¬¬ * 6 + T (W -Y /[ 4], (- ª Ê T ) ò l*YLÂ*¶Ñ+ç +ÿL*´ \¶ÙL§ M² ,¶Þ¸áW±*+µã² å¸ W*´ n¶éW§*´ã*´ `¶í= *´ n*´ ` ¶ðW*·òÿü§ ñ ² ô¸ W*» Y·õ¶w*µ O§ ϲ ÷¸áW§ ÂM² » ¾Yù· Á,¶ú¶ýÿ¶ý¶ ɸ W*» Y,·¶w§ M² » ¾Y· Á,¶¶ýÿ¶ý¶ ɸ W*» Y·õ¶w§ aM² » ¾Y· Á,¶¶ýÿ¶ý¶ ɸ W*» Y·õ¶w§ 1M² » ¾Y
|
· Á,¶ ¶ýÿ¶ý¶ ɸ W*» Y,·¶w*´ Oþæ² ¸ W±
|
Ì D ³ D ÌÎ D üÌ D , ª * R l Z 3 ß P H B -ß Í ,ß ý ,ß - -ß + % g h g k m n o )p *s /u 9v Ax D{ P| T} b~ i q {
½ Ì Í î ü ý ,-NZxa k¡, H ÿ Óÿ Û Ì ü !ÿ Û ³pÎoÌo ª- GÀ ) « J²YÆ °W¸ ¾¼
|
K*²¶ÅO§ W*²"¶ÅO§ W*² }¶ÅO§ W*²¶ÅO§ W*Y³° & ) * 3 6 7 @ C + ), # Hÿ K K K # T ) ! ¶(³ ± + * 1 2 b
|
! " $ % ' ( * +@PK !*Y²z9 9 7 de/tavendo/autobahn/WebSocketWriter$ThreadHandler.classÊþº¾ 3 . 1de/tavendo/autobahn/WebSocketWriter$ThreadHandler android/os/Handler WebSocketWriter.java #de/tavendo/autobahn/WebSocketWriter ThreadHandler mWebSocketWriterReference Ljava/lang/ref/WeakReference; DLjava/lang/ref/WeakReference<Lde/tavendo/autobahn/WebSocketWriter;>; <init> ((Lde/tavendo/autobahn/WebSocketWriter;)V ()V
|
java/lang/ref/WeakReference (Ljava/lang/Object;)V
|
|
this 3Lde/tavendo/autobahn/WebSocketWriter$ThreadHandler; webSocketWriter %Lde/tavendo/autobahn/WebSocketWriter; handleMessage (Landroid/os/Message;)V get ()Ljava/lang/Object;
|
writeMessageToBuffer "
|
# message Landroid/os/Message; Signature Code LocalVariableTable LineNumberTable StackMapTable
|
SourceFile InnerClasses
|
' ( M *· *» Y+· µ ± ) * À Â Ã ( m *´ ¶ !À M,Æ ,+¶ $± ) % &
|
* É Ê Ë Í + ü , -
|
|
PK !*góN( ( ) de/tavendo/autobahn/WebSocketWriter.classÊþº¾ 3¼ #de/tavendo/autobahn/WebSocketWriter java/lang/Thread WebSocketWriter.java 2de/tavendo/autobahn/WebSocketMessage$BinaryMessage $de/tavendo/autobahn/WebSocketMessage BinaryMessage 4de/tavendo/autobahn/WebSocketMessage$ClientHandshake ClientHandshake *de/tavendo/autobahn/WebSocketMessage$Close Close 3de/tavendo/autobahn/WebSocketMessage$ConnectionLost ConnectionLost *de/tavendo/autobahn/WebSocketMessage$Error Error )de/tavendo/autobahn/WebSocketMessage$Ping Ping )de/tavendo/autobahn/WebSocketMessage$Pong Pong )de/tavendo/autobahn/WebSocketMessage$Quit Quit 3de/tavendo/autobahn/WebSocketMessage$RawTextMessage RawTextMessage 0de/tavendo/autobahn/WebSocketMessage$TextMessage # TextMessage 1de/tavendo/autobahn/WebSocketWriter$ThreadHandler & ThreadHandler TAG Ljava/lang/String; WEB_SOCKETS_VERSION I CRLF
|
/ mRandom Ljava/util/Random; mWebSocketConnectionHandler Landroid/os/Handler; mWebSocketOptions &Lde/tavendo/autobahn/WebSocketOptions; mApplicationBuffer Ljava/nio/ByteBuffer; mSocket Ljava/net/Socket; mOutputStream Ljava/io/OutputStream; mHandler <init> `(Landroid/os/Handler;Ljava/net/Socket;Lde/tavendo/autobahn/WebSocketOptions;Ljava/lang/String;)V (Ljava/lang/String;)V > @
|
A java/util/Random C ()V > E
|
D F 1 2 H 3 4 J 5 6 L 9 : N $de/tavendo/autobahn/WebSocketOptions P getMaxFramePayloadSize ()I R S
|
Q T java/nio/ByteBuffer V allocate (I)Ljava/nio/ByteBuffer; X Y
|
W Z 7 8 \ ) * ^ WebSocket writer created. ` android/util/Log b d '(Ljava/lang/String;Ljava/lang/String;)I d e
|
c f this %Lde/tavendo/autobahn/WebSocketWriter; master socket options
|
threadName forward (Ljava/lang/Object;)V = 4 p android/os/Handler r obtainMessage ()Landroid/os/Message; t u
|
s v android/os/Message x obj Ljava/lang/Object; z { y | sendMessage (Landroid/os/Message;)Z ~
|
s message msg Landroid/os/Message; notify newHandshakeKey ()Ljava/lang/String; nextBytes ([B)V
|
D android/util/Base64 encodeToString ([BI)Ljava/lang/String;
|
ba [B newFrameMask ()[B sendClientHandshake 9(Lde/tavendo/autobahn/WebSocketMessage$ClientHandshake;)V java/io/IOException getURI ()Ljava/net/URI;
|
java/net/URI getPath
|
¡ java/lang/String £ length ¥ S
|
¤ ¦ / ¨ getQuery ª
|
« java/lang/StringBuilder valueOf &(Ljava/lang/Object;)Ljava/lang/String; ¯ °
|
¤ ±
|
® A ? ´ append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ¶ ·
|
® ¸ toString º
|
® » GET ½ HTTP/1.1 ¿ getBytes Á
|
¤ Â put ([B)Ljava/nio/ByteBuffer; Ä Å
|
W Æ Host: È getHost Ê
|
Ë Upgrade: WebSocket
|
Í Connection: Upgrade
|
Ï Sec-WebSocket-Key: Ñ
|
Ó Origin: https://www.google.com
|
Õ getSubprotocols ()[Ljava/lang/String; × Ø
|
Ù Sec-WebSocket-Protocol: Û , Ý Sec-WebSocket-Version: 13
|
ß 6Lde/tavendo/autobahn/WebSocketMessage$ClientHandshake; path query i sendClose /(Lde/tavendo/autobahn/WebSocketMessage$Close;)V &de/tavendo/autobahn/WebSocketException ç getCode é S
|
ê getReason ì
|
í UTF-8 ï (Ljava/lang/String;)[B Á ñ
|
¤ ò close payload exceeds 125 octets õ
|
è A sendFrame (IZ[B)V ø ù
|
ú ,Lde/tavendo/autobahn/WebSocketMessage$Close; payload pReason sendPing .(Lde/tavendo/autobahn/WebSocketMessage$Ping;)V mPayload ping payload exceeds 125 octets +Lde/tavendo/autobahn/WebSocketMessage$Ping; sendPong .(Lde/tavendo/autobahn/WebSocketMessage$Pong;)V pong payload exceeds 125 octets
|
+Lde/tavendo/autobahn/WebSocketMessage$Pong; sendBinaryMessage 7(Lde/tavendo/autobahn/WebSocketMessage$BinaryMessage;)V getMaxMessagePayloadSize S
|
Q %message payload exceeds payload limit 4Lde/tavendo/autobahn/WebSocketMessage$BinaryMessage; sendTextMessage 5(Lde/tavendo/autobahn/WebSocketMessage$TextMessage;)V * $ 2Lde/tavendo/autobahn/WebSocketMessage$TextMessage; sendRawTextMessage 8(Lde/tavendo/autobahn/WebSocketMessage$RawTextMessage;)V ! 5Lde/tavendo/autobahn/WebSocketMessage$RawTextMessage; (IZ[BII)V ø
|
opcode fin Z (B)Ljava/nio/ByteBuffer; Ä%
|
W& getMaskClientFrames ()Z ()
|
Q* } ÿÿ ÿ
|
2 ([BII)Ljava/nio/ByteBuffer; Ä4
|
W5 offset b0 B b1 len J mask processMessage
|
?
|
A
|
C ÿ
|
E
|
G å æ
|
I
|
K android/os/LooperM myLooper ()Landroid/os/Looper; OP
|
NQ quit S E
|
NT WebSocket writer ended.V processAppMessage X o
|
Y writeMessageToBuffer (Landroid/os/Message;)V java/net/SocketException] java/lang/Exception_ clear ()Ljava/nio/Buffer; ab
|
Wc > o
|
e flip gb
|
Wh ; < j array l
|
Wm position o S
|
Wp limit r S
|
Ws java/io/OutputStreamu write ([BII)V wx
|
vy run() : SocketException ({
|
^ » )~ e e
|
c
|
F
o
|
run() : IOException (
|
» (Ljava/lang/Exception;)V >
|
Ljava/net/SocketException; Ljava/io/IOException; Ljava/lang/Exception; +unknown message received by WebSocketWriter run java/net/Socket getOutputStream ()Ljava/io/OutputStream;
|
getLocalizedMessage
|
prepare E
|
N ((Lde/tavendo/autobahn/WebSocketWriter;)V >
|
' WebSocker writer running.¡ java/lang/Object£ notifyAll ¥ E
|
¤¦ java/lang/Throwable¨ loop ª E
|
N« outputStream <clinit> java/lang/Class¯ getCanonicalName ±
|
°² ConstantValue Code LocalVariableTable LineNumberTable StackMapTable
|
Exceptions
|
SourceFile InnerClasses !
|
) * + , ´ - . * ´ 0 1 2 3 4 5 6 7 8 9 : ; < = 4 > ? µ ¦ 8*· B*» DY· Gµ I*+µ K*-µ M*,µ O*-¶ U`¸ [µ ]² _a¸ gW± ¶ 4 8 h i 8 j 4 8 k : 8 l 6 8 m * · " F 1 H I J L . N 7 O n o µ a *´ q¶ wM,+µ }*´ q,¶ W± ¶ h i { · ] ^ _ `
o µ a *´ K¶ wM,+µ }*´ K,¶ W± ¶ h i { · i j k l µ O ¼L*´ I+¶ +¸ ° ¶ h i · u v w µ J ¼L*´ I+¶ +° ¶ h i
|
· µ L+¶ ¶ ¢M,Æ
|
,¶ § ©M+¶ ¶ ¬N-Æ "-¶ § » ®Y,¸ ²· ³µ¶ ¹-¶ ¹¶ ¼M*´ ]» ®Y¾· ³,¶ ¹À¶ ¹0¶ ¹¶ ¼¶ ö ÇW*´ ]» ®YÉ· ³+¶ ¶ ̶ ¹0¶ ¹¶ ¼¶ ö ÇW*´ ]ζ ö ÇW*´ ]ж ö ÇW*´ ]» ®YÒ· ³*· Ô¶ ¹0¶ ¹¶ ¼¶ ö ÇW*´ ]Ö¶ ö ÇW+¶ ÚÆ W+¶ Ú¾ O*´ ]ܶ ö ÇW6§ %*´ ]+¶ Ú2¶ ö ÇW*´ ]Þ¶ ö ÇW+¶ Ú¾¡ÿ×*´ ]0¶ ö ÇW*´ ]චö ÇW*´ ]0¶ ö ÇW± ¶ 4 L h i L á D â * . ã * õ / ä , · Z ) A f ¦ É Ö å ¡ ò ¢ ø £
|
¤ ¢$ ¦1 ©> ªK «¸ ü ¤ü * ¤ü ¶!ú ¹ å æ µ \ +¶ ë M+¶ îÆ ;+¶ î¶ § 1+¶ îð¶ óN-¾`¼M6§ ,`-3T-¾¡ÿï§ ¼M,Æ ,¾}¤ » èYö· ÷¿,+¶ ëz ÿ~T,+¶ ë ÿ~T*,¶ û§ *¶ û± ¶ 4 h i ü { ý $ ! þ . ä , · J ² ³ µ ¶ $ · + ¸ 1 ¹ ; ¸ E » H ¼ L ¿ W À a à p Ä | Æ Ç È Ê¸ 0 þ 1 ô ô ÿ ÿ ô ú %¹ è ÿ µ q (+´Æ +´¾}¤ » èY· ÷¿* +´¶ û± ¶ ( h i ( · Ñ Ò Ô ' Õ¸ ¹ è µ q (+´ Æ +´ ¾}¤ » èY · ÷¿*
|
+´ ¶ û± ¶ ( h i ( · Ý Þ à ' Ḡ¹ è µ n %+´¾*´ M¶¤ » èY· ÷¿*+´¶ û± ¶ % h i % · è é ë $ ì¸ ¹ è µ
)+´ð¶ óM,¾*´ M¶¤ » èY· ÷¿*,¶ û± ¶ ) h i )
|
ý · ó
|
ô õ ! ÷ ( ø¸ ü ! ô¹ è µ n %+´ ¾*´ M¶¤ » èY· ÷¿*+´ ¶ û± ¶ % h i % · ÿ $¸ ¹ è ø ù µ } -Æ * --¾¶!§ * ¶!± ¶ * h i " , #$ ý · ¸ ¹ ø µ ¬6 66*´ ]¶'W6*´ M¶+ 6
7, 6*´ ]¶'W§ Ò. <~6*´ ]¶'W*´ ]¼Y{0TY0T¶ ÇW§ 6*´ ]¶'W*´ ]¼Y8{0TY0{0TY({0TY {0TY{0TY{0TY{0TY0T¶ ÇW:
|
*´ M¶+ 9*·3:
|
*´ ]
|
3¶'W*´ ]
|
3¶'W*´ ]
|
3¶'W*´ ]
|
3¶'W >*´ M¶+ '6 § - `\3
|
p3T
ÿå*´ ]-¶6W± ¶ p ¬ h i ¬" , ¬#$ ¬ ý ¬7 , ¬ ¥ , ©89 $:9 7u;< ) =
|
} ! ä , · ª * # $ % ' ( !+ $, .- 20 73 @4 J5 T6 `7 h8 r9 : ; ¡< «= Ã> Ñ? ß@ íA ûB
|
CD"=&G)H3J9KELQM]NiQpRzUVUY«[¸ #
|
ü ü "ü $û Aû ü B ôü ú ¹ > o µ / +Á $ *+À $·@§ +Á ! *+À !·B§ |+Á *+À ·D§ j+Á *+À ·F§ X+Á *+À ·H§ F+Á *+À ·J§ 4+Á *+À ·L§ "+Á ¸R¶U² _W¸ gW§ *+¶Z± ¶ h i { · R g h i j !k +l 3m =n Eo Op Wq ar is st {u
v x y z |¸ ¹ è [\ µ E *´ ]¶dW*+´ }¶f*´ ]¶iW*´k*´ ]¶n*´ ]¶q*´ ]¶t¶z§ eM² _» ®Y|· ³,¶}¶ ¹¶ ¹¶ ¼¸W*» Y··
§ 5M² _» ®Y· ³,¶¶ ¹¶ ¹¶ ¼¸W§ M*» Y,··
± 4 7^ 4 g 4 ` ¶ 4 h i 8 , h ! · 2 4
8 Y g h ¸ w^o d` X o µ ? » èY· ÷¿ ¶ h i { · ¹ è E µ þ KL*´ O¶L§ M² _,¶¸W*+µk¸*» 'Y*· µ q*YM² _¢¸ gW*¶§,ç ,ÿ¸¬±
|
1 A D D F D ¶ K h i I < · 6 ¢
|
£ ¤ § © !« - 1® ;° ? G³ J´¸ ' ÿ v ÿ * v © ® E µ % ¶³³ _± ·
|
, / º » Z
|
! " $ % ' (
|
PK !*¬
¢ ¤ META-INF/MANIFEST.MFPK !*'·Ð' / ¤4 de/tavendo/autobahn/ByteBufferInputStream.classPK !*^ 0 ¤ de/tavendo/autobahn/ByteBufferOutputStream.classPK !*1 ! ¤ de/tavendo/autobahn/Doxygen.classPK !*¶@=[÷ ÷ 5 ¤` de/tavendo/autobahn/NoCopyByteArrayOutputStream.classPK !*YT1 # ¤ª de/tavendo/autobahn/PrefixMap.classPK !*ÌC7KT T ' ¤ù de/tavendo/autobahn/Utf8Validator.classPK !*Bí£) ) Z ¤( de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification.classPK !*Vv v ? ¤30 de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver.classPK !*Cw ~ # ¤3 de/tavendo/autobahn/WebSocket.classPK !*Ã\Öj / ¤_6 de/tavendo/autobahn/WebSocketConnection$1.classPK !*¢~½/p p / ¤°; de/tavendo/autobahn/WebSocketConnection$2.classPK !*RÀ / ¤m@ de/tavendo/autobahn/WebSocketConnection$3.classPK !*I
|
þm m / ¤CD de/tavendo/autobahn/WebSocketConnection$4.classPK !*Ë_ : ¤ýG de/tavendo/autobahn/WebSocketConnection$SocketThread.classPK !*Ü¢j ; ¤nS de/tavendo/autobahn/WebSocketConnection$ThreadHandler.classPK !*8/n2 2 - ¤RX de/tavendo/autobahn/WebSocketConnection.classPK !* Aìl) ) 4 ¤® de/tavendo/autobahn/WebSocketConnectionHandler.classPK !*ëî+ºl l , ¤) de/tavendo/autobahn/WebSocketException.classPK !*Ì
|
X® . ¤ß de/tavendo/autobahn/WebSocketFrameHeader.classPK !*ä à' ' 8 ¤? de/tavendo/autobahn/WebSocketMessage$BinaryMessage.classPK !*úåõs s : ¤¼ de/tavendo/autobahn/WebSocketMessage$ClientHandshake.classPK !*r 04Ì Ì 0 ¤¡ de/tavendo/autobahn/WebSocketMessage$Close.classPK !* ö ß ß 9 ¤¡¥ de/tavendo/autobahn/WebSocketMessage$ConnectionLost.classPK !*èÎÕ1 1 0 ¤×§ de/tavendo/autobahn/WebSocketMessage$Error.classPK !*Dc` 2 ¤Vª de/tavendo/autobahn/WebSocketMessage$Message.classPK !*o ãV V / ¤B¬ de/tavendo/autobahn/WebSocketMessage$Ping.classPK !*`V V / ¤å® de/tavendo/autobahn/WebSocketMessage$Pong.classPK !*À48{ { < ¤± de/tavendo/autobahn/WebSocketMessage$ProtocolViolation.classPK !*mb¥Á Á / ¤]´ de/tavendo/autobahn/WebSocketMessage$Quit.classPK !*@,©b* * 9 ¤k¶ de/tavendo/autobahn/WebSocketMessage$RawTextMessage.classPK !*gQ¼ 6 ¤ì¸ de/tavendo/autobahn/WebSocketMessage$ServerError.classPK !*üÞM9+ + : ¤Ò» de/tavendo/autobahn/WebSocketMessage$ServerHandshake.classPK !*Õ§ÍA A 6 ¤U¾ de/tavendo/autobahn/WebSocketMessage$TextMessage.classPK !*¡«ÿ ÿ = ¤êÀ de/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode.classPK !*/oµ´ ´ * ¤DÅ de/tavendo/autobahn/WebSocketMessage.classPK !*,::±S S * ¤@Ë de/tavendo/autobahn/WebSocketOptions.classPK !*?×N2 2 5 ¤ÛÖ de/tavendo/autobahn/WebSocketReader$ReaderState.classPK !*¥=~L4 L4 ) ¤`Ü de/tavendo/autobahn/WebSocketReader.classPK !*Y²z9 9 7 ¤ó de/tavendo/autobahn/WebSocketWriter$ThreadHandler.classPK !*góN( ( ) ¤ de/tavendo/autobahn/WebSocketWriter.classPK ) ) M Ù=
|
