/usr/bin/diffoscope --max-report-size 12345678 --max-diff-block-lines 128 --html unsigned/org.c_base.c_beam_29.apk.diffoscope.html --text unsigned/org.c_base.c_beam_29.apk.diffoscope.txt /home/fdroid/fdroiddata/tmp/org.c_base.c_beam_29.apk /home/fdroid/fdroiddata/tmp/sigcp_org.c_base.c_beam

⊟

1.5 MB

/home/fdroid/fdroiddata/tmp/org.c_base.c_beam_29.apk vs.

/home/fdroid/fdroiddata/tmp/sigcp_org.c_base.c_beam_29.apk ¶

⊟

7.18 KB

/usr/lib/android-sdk/build-tools/debian/apksigner verify --verbose --print-certs {} ¶

error from `/usr/lib/android-sdk/build-tools/debian/apksigner verify --verbose --print-certs {}` (b): DOES NOT VERIFY ERROR: SHA-1 digest of classes.dex does not match the digest specified in META-INF/MANIFEST.MF. Expected: <Ju9c67H8CSqw8hNNw4+o/Ngyqe0=>, actual: <qe6EsT64LImo7q8meJG/tIjizgY=>

⊟

1.2 MB

zipinfo -v {} ¶

Differences in extra fields detected; using output from zipinfo -v

⊟

142 B

filetype from file(1) ¶

⊟

124 KB

classes.dex ¶

⊟

124 KB

classes.jar ¶

⊟

14.9 KB

zipinfo {} ¶

⊟

61.2 KB

org/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG.class ¶

⊟

61.1 KB

procyon -ec {} ¶

⊟

1.39 KB

org/eclipse/paho/client/mqttv3/internal/ClientComms.class ¶

⊟

1.28 KB

procyon -ec {} ¶

⊟

1.15 KB

org/eclipse/paho/client/mqttv3/internal/ClientState.class ¶

⊟

1.04 KB

procyon -ec {} ¶

⊟

1.52 KB

org/eclipse/paho/client/mqttv3/internal/CommsCallback.class ¶

⊟

1.4 KB

procyon -ec {} ¶

⊟

763 B

org/eclipse/paho/client/mqttv3/internal/CommsReceiver.class ¶

⊟

645 B

procyon -ec {} ¶

⊟

748 B

org/eclipse/paho/client/mqttv3/internal/CommsSender.class ¶

⊟

634 B

procyon -ec {} ¶

⊟

802 B

org/eclipse/paho/client/mqttv3/internal/CommsTokenStore.class ¶

⊟

680 B

procyon -ec {} ¶

⊟

779 B

org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.class ¶

⊟

637 B

procyon -ec {} ¶

⊟

7.83 KB

org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.class ¶

⊟

7.7 KB

procyon -ec {} ¶

⊟

2.75 KB

org/eclipse/paho/client/mqttv3/internal/Token.class ¶

⊟

2.66 KB

procyon -ec {} ¶

⊟

12.1 KB

org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake.class ¶

⊟

11.9 KB

procyon -ec {} ¶

⊟

5.08 KB

org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.class ¶

⊟

4.94 KB

procyon -ec {} ¶

⊟

908 B

org/eclipse/paho/client/mqttv3/util/Strings.class ¶

⊟

810 B

procyon -ec {} ¶

⊟

4.28 KB

org/eclipse/paho/client/mqttv3/MqttAsyncClient.class ¶

⊟

4.18 KB

procyon -ec {} ¶

⊟

739 B

org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.class ¶

⊟

611 B

procyon -ec {} ¶

⊟

1.58 KB

org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.class ¶

⊟

1.45 KB

procyon -ec {} ¶

⊟

2.18 KB

org/eclipse/paho/client/mqttv3/logging/JSR47Logger.class ¶

⊟

2.07 KB

procyon -ec {} ¶

⊟

2.23 KB

org/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence.class ¶

⊟

2.09 KB

procyon -ec {} ¶

⊟

748 B

org/eclipse/paho/client/mqttv3/internal/wire/MqttSuback.class ¶

⊟

626 B

procyon -ec {} ¶

⊟

6.14 KB

smali/org/eclipse/paho/client/mqttv3/MqttAsyncClient.smali ¶

⊟

563 B

smali/org/eclipse/paho/client/mqttv3/internal/CommsTokenStore.smali ¶

⊟

14.0 KB

smali/org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.smali ¶

⊟

630 B

smali/org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.smali ¶

⊟

1.24 KB

smali/org/eclipse/paho/client/mqttv3/internal/Token.smali ¶

⊟

894 B

smali/org/eclipse/paho/client/mqttv3/internal/ClientState.smali ¶

⊟

27.3 KB

smali/org/eclipse/paho/client/mqttv3/internal/CommsSender.smali ¶

⊟

34.6 KB

smali/org/eclipse/paho/client/mqttv3/internal/CommsReceiver.smali ¶

⊟

61.5 KB

smali/org/eclipse/paho/client/mqttv3/internal/CommsCallback.smali ¶

⊟

2.33 KB

smali/org/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG.smali ¶

⊟

1.56 KB

smali/org/eclipse/paho/client/mqttv3/internal/ClientComms.smali ¶

⊟

844 B

smali/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake.smali ¶

⊟

12.9 KB

smali/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.smali ¶

⊟

966 B

smali/org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.smali ¶

⊟

2.08 KB

smali/org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.smali ¶

⊟

1.97 KB

smali/org/eclipse/paho/client/mqttv3/internal/wire/MqttSuback.smali ¶

⊟

6.33 KB

smali/org/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence.smali ¶

⊟

3.04 KB

smali/org/eclipse/paho/client/mqttv3/logging/JSR47Logger.smali ¶

⊟

1.31 KB

smali/org/eclipse/paho/client/mqttv3/util/Strings.smali ¶

+Verifies
+Verified·using·v1·scheme·(JAR·signing):·true
+Verified·using·v2·scheme·(APK·Signature·Scheme·v2):·false
+Verified·using·v3·scheme·(APK·Signature·Scheme·v3):·false
+Verified·using·v4·scheme·(APK·Signature·Scheme·v4):·false
+Verified·for·SourceStamp:·false
+Number·of·signers:·1
+Signer·#1·certificate·DN:·CN=FDroid,·OU=FDroid,·O=fdroid.org,·L=ORG,·ST=ORG,·C=UK
+Signer·#1·certificate·SHA-256·digest:·050223b597dd6d8940d498a178efb470bcbee2c3fc28bf2ece788ad79370a00b
+Signer·#1·certificate·SHA-1·digest:·48b47bfed373174fc96df617c4c44c49911615db
+Signer·#1·certificate·MD5·digest:·487d2e34bebceec8ab85ddd790f69115
+Signer·#1·key·algorithm:·RSA
+Signer·#1·key·size·(bits):·2048
+Signer·#1·public·key·SHA-256·digest:·4076c02cab667104baefc172ff62cfdcd8a05fe81c8c44e9e8521ca381f8cc13
+Signer·#1·public·key·SHA-1·digest:·8a3e5a2790bb9a201cc0e9e18012c014848c6064
+Signer·#1·public·key·MD5·digest:·fe1aa789a75011655f91a29584dc1562
+WARNING:·META-INF/android.arch.core_runtime.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/android.arch.lifecycle_livedata-core.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/android.arch.lifecycle_livedata.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/android.arch.lifecycle_runtime.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/android.arch.lifecycle_viewmodel.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.appcompat_appcompat.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.asynclayoutinflater_asynclayoutinflater.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.coordinatorlayout_coordinatorlayout.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.core_core.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.cursoradapter_cursoradapter.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.customview_customview.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.documentfile_documentfile.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.drawerlayout_drawerlayout.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.fragment_fragment.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.interpolator_interpolator.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.legacy_legacy-support-core-ui.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.legacy_legacy-support-core-utils.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.legacy_legacy-support-v4.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.loader_loader.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.localbroadcastmanager_localbroadcastmanager.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.media_media.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.print_print.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.slidingpanelayout_slidingpanelayout.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.swiperefreshlayout_swiperefreshlayout.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.vectordrawable_vectordrawable-animated.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.vectordrawable_vectordrawable.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.versionedparcelable_versionedparcelable.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/androidx.viewpager_viewpager.version·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.
+WARNING:·META-INF/services/org.eclipse.paho.client.mqttv3.spi.NetworkModuleFactory·not·protected·by·signature.·Unauthorized·modifications·to·this·JAR·entry·will·not·be·detected.·Delete·or·move·the·entry·outside·of·META-INF/.


Offset 1, 20838 lines modified		Offset 1, 16926 lines modified
1	There·is·no·zipfile·comment.	1	There·is·no·zipfile·comment.

2	End-of-central-directory·record:	2	End-of-central-directory·record:
3	-------------------------------	3	-------------------------------

4	··Zip·archive·file·size:···················4~~908520~~·(00000000004A~~E5E8~~h)	4	··Zip·archive·file·size:···················4884894·(00000000004A899Eh)
5	··Actual·end-cent-dir·record·offset:·······4908498·(00000000004A~~E5D2~~h)	5	··Actual·end-cent-dir·record·offset:·······4884872·(00000000004A8988h)
6	··Expected·end-cent-dir·record·offset:·····4908498·(00000000004A~~E5D2~~h)	6	··Expected·end-cent-dir·record·offset:·····4884872·(00000000004A8988h)
7	··(based·on·the·length·of·the·central·directory·and·its·expected·offset)	7	··(based·on·the·length·of·the·central·directory·and·its·expected·offset)

8	··This·zipfile·constitutes·the·sole·disk·of·a·single-part·archive;·its	8	··This·zipfile·constitutes·the·sole·disk·of·a·single-part·archive;·its
9	··central·directory·contains·558·entries.	9	··central·directory·contains·558·entries.
10	··The·central·directory·is·5~~9898~~·(000000000000~~E9FA~~h)·bytes·long,	10	··The·central·directory·is·54903·(000000000000D677h)·bytes·long,
11	··and·its·(expected)·offset·in·bytes·from·the·beginning·of·the·zipfile	11	··and·its·(expected)·offset·in·bytes·from·the·beginning·of·the·zipfile
12	··is·48~~48600~~·(000000000049~~FBD8~~h).	12	··is·4829969·(000000000049B311h).


13	Central·directory·entry·#1:	13	Central·directory·entry·#1:
14	---------------------------	14	---------------------------

15	··ME~~TA-INF/~~M~~ANIFEST~~.MF	15	··AndroidManifest.xml

16	··offset·of·local·header·from·start·of·archive:···0	16	··offset·of·local·header·from·start·of·archive:···0
17	··················································(0000000000000000h)·bytes	17	··················································(0000000000000000h)·bytes
18	··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT	18	··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT
19	··version·of·encoding·software:···················2.0	19	··version·of·encoding·software:···················0.0
20	··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT	20	··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT
21	··minimum·software·version·required·to·extract:···2.0	21	··minimum·software·version·required·to·extract:···0.0
22	··compression·method:·····························deflated	22	··compression·method:·····························deflated
23	··compression·sub-type·(deflation):···············normal	23	··compression·sub-type·(deflation):···············normal
24	··file·security·status:···························not·encrypted	24	··file·security·status:···························not·encrypted
25	··extended·local·header:··························yes	25	··extended·local·header:··························no
26	··file·last·modified·on·(DOS·date/time):··········~~2019~~·~~Jun~~·17·16:39:58	26	··file·last·modified·on·(DOS·date/time):··········1980·000·0·00:00:00
27	··32-bit·CRC·value·(hex):·························~~dc6840b5~~	27	··32-bit·CRC·value·(hex):·························978be522
28	··compressed·size:································1~~6739~~·bytes	28	··compressed·size:································2866·bytes
29	··uncompressed·size:······························~~56911~~·bytes	29	··uncompressed·size:······························14552·bytes
30	··length·of·filename:·····························20·characters	30	··length·of·filename:·····························19·characters
31	··length·of·extra·field:··························0·bytes	31	··length·of·extra·field:··························0·bytes
32	··length·of·file·comment:·························0·characters	32	··length·of·file·comment:·························0·characters
33	··disk·number·on·which·file·begins:···············disk·1	33	··disk·number·on·which·file·begins:···············disk·1
34	··apparent·file·type:·····························binary	34	··apparent·file·type:·····························binary
35	··non-MSDOS·external·file·attributes:·············000000·hex	35	··non-MSDOS·external·file·attributes:·············000000·hex
36	··MS-DOS·file·attributes·(00·hex):················none	36	··MS-DOS·file·attributes·(00·hex):················none

37	··There·is·no·file·comment.	37	··There·is·no·file·comment.

38	Central·directory·entry·#2:	38	Central·directory·entry·#2:
39	---------------------------	39	---------------------------

40	··There·are·an·extra·16·bytes·preceding·this·file.

41	··META-INF/C5413F71.SF

42	··offset·of·local·header·from·start·of·archive:···16805
43	··················································(00000000000041A5h)·bytes
44	··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT
45	··version·of·encoding·software:···················2.0
46	··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT
47	··minimum·software·version·required·to·extract:···2.0
48	··compression·method:·····························deflated
49	··compression·sub-type·(deflation):···············normal
50	··file·security·status:···························not·encrypted
51	··extended·local·header:··························yes
52	··file·last·modified·on·(DOS·date/time):··········2019·Jun·17·16:39:58
53	··32-bit·CRC·value·(hex):·························b187cabf
54	··compressed·size:································17688·bytes
55	··uncompressed·size:······························57014·bytes
56	··length·of·filename:·····························20·characters
57	··length·of·extra·field:··························0·bytes
58	··length·of·file·comment:·························0·characters
59	··disk·number·on·which·file·begins:···············disk·1
60	··apparent·file·type:·····························binary
61	··non-MSDOS·external·file·attributes:·············000000·hex
62	··MS-DOS·file·attributes·(00·hex):················none

63	··There·is·no·file·comment.

64	Central·directory·entry·#3:
65	---------------------------

66	··There·are·an·extra·16·bytes·preceding·this·file.

67	··META-INF/C5413F71.RSA

68	··offset·of·local·header·from·start·of·archive:···34559
69	··················································(00000000000086FFh)·bytes
70	··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT
71	··version·of·encoding·software:···················2.0
72	··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT
73	··minimum·software·version·required·to·extract:···2.0
74	··compression·method:·····························deflated
75	··compression·sub-type·(deflation):···············normal
76	··file·security·status:···························not·encrypted
77	··extended·local·header:··························yes
78	··file·last·modified·on·(DOS·date/time):··········2019·Jun·17·16:39:58
79	··32-bit·CRC·value·(hex):·························6dd51f75
80	··compressed·size:································1076·bytes
81	··uncompressed·size:······························1326·bytes
82	··length·of·filename:·····························21·characters
83	··length·of·extra·field:··························0·bytes
84	··length·of·file·comment:·························0·characters
85	··disk·number·on·which·file·begins:···············disk·1
86	··apparent·file·type:·····························binary
87	··non-MSDOS·external·file·attributes:·············000000·hex
88	··MS-DOS·file·attributes·(00·hex):················none

89	··There·is·no·file·comment.

90	Central·directory·entry·#4:
91	---------------------------

92	··There·are·an·extra·16·bytes·preceding·this·file.

93	··META-INF/android.arch.core_runtime.version	40	··META-INF/android.arch.core_runtime.version

94	··offset·of·local·header·from·start·of·archive:···3~~5702~~	41	··offset·of·local·header·from·start·of·archive:···2915
95	··················································(0000000000008B76h)·bytes	42	··················································(0000000000000B63h)·bytes
96	··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT	43	··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT
97	··version·of·encoding·software:···················1.0	44	··version·of·encoding·software:···················2.4
98	··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT	45	··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT
99	··minimum·software·version·required·to·extract:···1.0	46	··minimum·software·version·required·to·extract:···1.0
100	··compression·method:·····························none·(stored)	47	··compression·method:·····························none·(stored)
101	··file·security·status:···························not·encrypted	48	··file·security·status:···························not·encrypted
102	··extended·local·header:··························no	49	··extended·local·header:··························no
103	··file·last·modified·on·(DOS·date/time):··········1980·~~Jan~~·1·00:00:00	50	··file·last·modified·on·(DOS·date/time):··········1980·000·0·00:00:00
104	··file·last·modified·on·(UT·extra·field·modtime):·1979·Nov·30·00:00:00·local
105	··file·last·modified·on·(UT·extra·field·modtime):·1979·Nov·30·00:00:00·UTC
Max diff block lines reached; 1246462/1253668 bytes (99.43%) of diff not shown.


Offset 1, 1 lines modified		Offset 1, 1 lines modified
1	Zip·archive·data,·at·least·v2.0·to·extract	1	Zip·archive·data,·at·least·v0.0·to·extract


Offset 38, 15 lines modified		Offset 38, 15 lines modified
38	····private·static·final·byte·DISCONNECTING·=·2;	38	····private·static·final·byte·DISCONNECTING·=·2;
39	····public·static·String·VERSION·=·"${project.version}";	39	····public·static·String·VERSION·=·"${project.version}";
40	····private·final·String·CLASS_NAME;	40	····private·final·String·CLASS_NAME;
41	····private·CommsCallback·callback;	41	····private·CommsCallback·callback;
42	····private·IMqttAsyncClient·client;	42	····private·IMqttAsyncClient·client;
43	····private·ClientState·clientState;	43	····private·ClientState·clientState;
44	····private·boolean·closePending;	44	····private·boolean·closePending;
45	····private·Object·conLock;	45	····private·final·Object·conLock;
46	····private·MqttConnectOptions·conOptions;	46	····private·MqttConnectOptions·conOptions;
47	····private·byte·conState;	47	····private·byte·conState;
48	····private·DisconnectedMessageBuffer·disconnectedMessageBuffer;	48	····private·DisconnectedMessageBuffer·disconnectedMessageBuffer;
49	····private·ExecutorService·executorService;	49	····private·ExecutorService·executorService;
50	····private·final·Logger·log;	50	····private·final·Logger·log;
51	····private·int·networkModuleIndex;	51	····private·int·networkModuleIndex;
52	····private·NetworkModule[]·networkModules;	52	····private·NetworkModule[]·networkModules;
Offset 427, 15 lines modified		Offset 427, 15 lines modified
427	····}	427	····}
428	····	428	····
429	····public·Properties·getDebug()·{	429	····public·Properties·getDebug()·{
430	········final·Properties·properties·=·new·Properties();	430	········final·Properties·properties·=·new·Properties();
431	········properties.put("conState",·Integer.valueOf(this.conState));	431	········properties.put("conState",·Integer.valueOf(this.conState));
432	········properties.put("serverURI",·this.getClient().getServerURI());	432	········properties.put("serverURI",·this.getClient().getServerURI());
433	········properties.put("callback",·this.callback);	433	········properties.put("callback",·this.callback);
434	········properties.put("stoppingComms",·ne~~w·Boo~~lean(this.stoppingComms));	434	········properties.put("stoppingComms",·Boolean.valueOf(this.stoppingComms));
435	········return·properties;	435	········return·properties;
436	····}	436	····}
437	····	437	····
438	····public·long·getKeepAlive()·{	438	····public·long·getKeepAlive()·{
439	········return·this.clientState.getKeepAlive();	439	········return·this.clientState.getKeepAlive();
440	····}	440	····}
441	····	441	····


Offset 64, 18 lines modified		Offset 64, 18 lines modified
64	····private·Hashtable·outboundQoS1;	64	····private·Hashtable·outboundQoS1;
65	····private·Hashtable·outboundQoS2;	65	····private·Hashtable·outboundQoS2;
66	····private·volatile·Vector·pendingFlows;	66	····private·volatile·Vector·pendingFlows;
67	····private·volatile·Vector·pendingMessages;	67	····private·volatile·Vector·pendingMessages;
68	····private·MqttClientPersistence·persistence;	68	····private·MqttClientPersistence·persistence;
69	····private·MqttWireMessage·pingCommand;	69	····private·MqttWireMessage·pingCommand;
70	····private·int·pingOutstanding;	70	····private·int·pingOutstanding;
71	····private·Object·pingOutstandingLock;	71	····private·final·Object·pingOutstandingLock;
72	····private·MqttPingSender·pingSender;	72	····private·MqttPingSender·pingSender;
73	····private·Object·queueLock;	73	····private·final·Object·queueLock;
74	····private·Object·quiesceLock;	74	····private·final·Object·quiesceLock;
75	····private·boolean·quiescing;	75	····private·boolean·quiescing;
76	····private·CommsTokenStore·tokenStore;	76	····private·CommsTokenStore·tokenStore;
77	····	77	····
78	····protected·ClientState(final·MqttClientPersistence·persistence,·final·CommsTokenStore·tokenStore,·final·CommsCallback·callback,·final·ClientComms·clientComms,·final·MqttPingSender·pingSender)·{	78	····protected·ClientState(final·MqttClientPersistence·persistence,·final·CommsTokenStore·tokenStore,·final·CommsCallback·callback,·final·ClientComms·clientComms,·final·MqttPingSender·pingSender)·{
79	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·ClientState.CLASS_NAME);	79	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·ClientState.CLASS_NAME);
80	········this.nextMsgId·=·0;	80	········this.nextMsgId·=·0;
81	········this.clientComms·=·null;	81	········this.clientComms·=·null;


Offset 29, 26 lines modified		Offset 29, 26 lines modified
29	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsCallback";	29	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsCallback";
30	····private·static·final·int·INBOUND_QUEUE_SIZE·=·10;	30	····private·static·final·int·INBOUND_QUEUE_SIZE·=·10;
31	····private·Future·callbackFuture;	31	····private·Future·callbackFuture;
32	····private·Thread·callbackThread;	32	····private·Thread·callbackThread;
33	····private·Hashtable·callbacks;	33	····private·Hashtable·callbacks;
34	····private·ClientComms·clientComms;	34	····private·ClientComms·clientComms;
35	····private·ClientState·clientState;	35	····private·ClientState·clientState;
36	····private·Vector·completeQueue;	36	····private·final·Vector·completeQueue;
37	····private·CommsCallback$State·current_state;	37	····private·CommsCallback$State·current_state;
38	····private·Object·lifecycle;	38	····private·final·Object·lifecycle;
39	····private·final·Logger·log;	39	····private·final·Logger·log;
40	····private·boolean·manualAcks;	40	····private·boolean·manualAcks;
41	····private·Vector·messageQueue;	41	····private·final·Vector·messageQueue;
42	····private·MqttCallback·mqttCallback;	42	····private·MqttCallback·mqttCallback;
43	····private·MqttCallbackExtended·reconnectInternalCallback;	43	····private·MqttCallbackExtended·reconnectInternalCallback;
44	····private·Object·spaceAvailable;	44	····private·final·Object·spaceAvailable;
45	····private·CommsCallback$State·target_state;	45	····private·CommsCallback$State·target_state;
46	····private·String·threadName;	46	····private·String·threadName;
47	····private·Object·workAvailable;	47	····private·final·Object·workAvailable;
48	····	48	····
49	····CommsCallback(final·ClientComms·clientComms)·{	49	····CommsCallback(final·ClientComms·clientComms)·{
50	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·CommsCallback.CLASS_NAME);	50	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·CommsCallback.CLASS_NAME);
51	········this.current_state·=·CommsCallback$State.STOPPED;	51	········this.current_state·=·CommsCallback$State.STOPPED;
52	········this.target_state·=·CommsCallback$State.STOPPED;	52	········this.target_state·=·CommsCallback$State.STOPPED;
53	········this.lifecycle·=·new·Object();	53	········this.lifecycle·=·new·Object();
54	········this.workAvailable·=·new·Object();	54	········this.workAvailable·=·new·Object();


Offset 11, 15 lines modified		Offset 11, 15 lines modified
11	public·class·CommsReceiver·implements·Runnable	11	public·class·CommsReceiver·implements·Runnable
12	{	12	{
13	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsReceiver";	13	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsReceiver";
14	····private·ClientComms·clientComms;	14	····private·ClientComms·clientComms;
15	····private·ClientState·clientState;	15	····private·ClientState·clientState;
16	····private·CommsReceiver$State·current_state;	16	····private·CommsReceiver$State·current_state;
17	····private·MqttInputStream·in;	17	····private·MqttInputStream·in;
18	····private·Object·lifecycle;	18	····private·final·Object·lifecycle;
19	····private·Logger·log;	19	····private·Logger·log;
20	····private·Thread·recThread;	20	····private·Thread·recThread;
21	····private·Future·receiverFuture;	21	····private·Future·receiverFuture;
22	····private·CommsReceiver$State·target_state;	22	····private·CommsReceiver$State·target_state;
23	····private·String·threadName;	23	····private·String·threadName;
24	····private·CommsTokenStore·tokenStore;	24	····private·CommsTokenStore·tokenStore;
25	····	25	····


Offset 13, 15 lines modified		Offset 13, 15 lines modified

13	public·class·CommsSender·implements·Runnable	13	public·class·CommsSender·implements·Runnable
14	{	14	{
15	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsSender";	15	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsSender";
16	····private·ClientComms·clientComms;	16	····private·ClientComms·clientComms;
17	····private·ClientState·clientState;	17	····private·ClientState·clientState;
18	····private·CommsSender$State·current_state;	18	····private·CommsSender$State·current_state;
19	····private·Object·lifecycle;	19	····private·final·Object·lifecycle;
20	····private·Logger·log;	20	····private·Logger·log;
21	····private·MqttOutputStream·out;	21	····private·MqttOutputStream·out;
22	····private·Thread·sendThread;	22	····private·Thread·sendThread;
23	····private·Future·senderFuture;	23	····private·Future·senderFuture;
24	····private·CommsSender$State·target_state;	24	····private·CommsSender$State·target_state;
25	····private·String·threadName;	25	····private·String·threadName;
26	····private·CommsTokenStore·tokenStore;	26	····private·CommsTokenStore·tokenStore;


Offset 14, 15 lines modified		Offset 14, 15 lines modified

14	public·class·CommsTokenStore	14	public·class·CommsTokenStore
15	{	15	{
16	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsTokenStore";	16	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.CommsTokenStore";
17	····private·MqttException·closedResponse;	17	····private·MqttException·closedResponse;
18	····private·Logger·log;	18	····private·Logger·log;
19	····private·String·logContext;	19	····private·String·logContext;
20	····private·Hashtable·tokens;	20	····private·final·Hashtable·tokens;
21	····	21	····
22	····public·CommsTokenStore(final·String·s)·{	22	····public·CommsTokenStore(final·String·s)·{
23	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·CommsTokenStore.CLASS_NAME);	23	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·CommsTokenStore.CLASS_NAME);
24	········this.closedResponse·=·null;	24	········this.closedResponse·=·null;
25	········this.log.setResourceName(s);	25	········this.log.setResourceName(s);
26	········this.tokens·=·new·Hashtable();	26	········this.tokens·=·new·Hashtable();
27	········this.logContext·=·s;	27	········this.logContext·=·s;


Offset 9, 15 lines modified		Offset 9, 15 lines modified
9	import·org.eclipse.paho.client.mqttv3.logging.Logger;	9	import·org.eclipse.paho.client.mqttv3.logging.Logger;
10	import·org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions;	10	import·org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions;
11	import·java.util.ArrayList;	11	import·java.util.ArrayList;

12	public·class·DisconnectedMessageBuffer·implements·Runnable	12	public·class·DisconnectedMessageBuffer·implements·Runnable
13	{	13	{
14	····private·final·String·CLASS_NAME;	14	····private·final·String·CLASS_NAME;
15	····private·Object·bufLock;	15	····private·final·Object·bufLock;
16	····private·ArrayList·buffer;	16	····private·ArrayList·buffer;
17	····private·DisconnectedBufferOptions·bufferOpts;	17	····private·DisconnectedBufferOptions·bufferOpts;
18	····private·IDisconnectedBufferCallback·callback;	18	····private·IDisconnectedBufferCallback·callback;
19	····private·Logger·log;	19	····private·Logger·log;
20	····private·int·mycount;	20	····private·int·mycount;
21	····	21	····
22	····public·DisconnectedMessageBuffer(final·DisconnectedBufferOptions·bufferOpts)·{	22	····public·DisconnectedMessageBuffer(final·DisconnectedBufferOptions·bufferOpts)·{


Offset 120, 88 lines modified		Offset 120, 88 lines modified
120	········final·String·name·=·NetworkModuleService.class.getName();	120	········final·String·name·=·NetworkModuleService.class.getName();
121	········final·Object[]·array·=·new·Object[accessible];	121	········final·Object[]·array·=·new·Object[accessible];
122	········array[0]·=·obj.toString();	122	········array[0]·=·obj.toString();
123	········log.warning(name,·"setURIField",·"115",·array,·(Throwable)ex);	123	········log.warning(name,·"setURIField",·"115",·array,·(Throwable)ex);
124	····}	124	····}
125	····	125	····
126	····public·static·void·validateURI(String·string)·{	126	····public·static·void·validateURI(String·string)·{
127	········final·String·s·=·~~"\""~~;	127	········final·Class<NetworkModuleService>·clazz·=·NetworkModuleService.class;
		128	········//·monitorenter(clazz)
128	········try·{	129	········try·{
129	············final·URI·uri·=·new·URI(string);	130	············final·URI·uri·=·new·URI(string);
130	············final·String·scheme·=·uri.getScheme();	131	············final·String·scheme·=·uri.getScheme();
131	············Label_0176:·{	132	············Label_0183:·{
132	················if·(scheme·==·null·\|\|·scheme.isEmpty())·{	133	················if·(scheme·==·null·\|\|·scheme.isEmpty())·{
133	····················break·Label_0176;	134	····················break·Label_0183;
134	················}	135	················}
135	················final·String·lowerCase·=·scheme.toLowerCase();	136	················final·String·lowerCase·=·scheme.toLowerCase();
136	················try·{	137	················try·{
137	····················final·ServiceLoader·factory_SERVICE_LOADER·=·NetworkModuleService.FACTORY_SERVICE_LOADER;	138	····················final·ServiceLoader·factory_SERVICE_LOADER·=·NetworkModuleService.FACTORY_SERVICE_LOADER;
138	····················try·{	139	····················try·{
139	························final·Iterator<NetworkModuleFactory>·iterator·=·factory_SERVICE_LOADER.iterator();	140	························final·Iterator<NetworkModuleFactory>·iterator·=·factory_SERVICE_LOADER.iterator();
140	························try·{	141	························try·{
141	····························while·(true)·{	142	····························while·(true)·{
142	································Label_0112:·{	143	································Label_0116:·{
143	····································if·(!iterator.hasNext())·{	144	····································if·(!iterator.hasNext())·{
144	········································break·Label_0112;	145	········································break·Label_0116;
145	····································}	146	····································}
146	····································final·NetworkModuleFactory·next·=·iterator.next();	147	····································final·NetworkModuleFactory·next·=·iterator.next();
147	····································try·{	148	····································try·{
148	········································final·NetworkModuleFactory·networkModuleFactory·=·(NetworkModuleFactory)next;	149	········································final·NetworkModuleFactory·networkModuleFactory·=·(NetworkModuleFactory)next;
149	········································try·{	150	········································try·{
150	············································if·(networkModuleFactory.getSupportedUriSchemes().contains(lowerCase))·{	151	············································if·(networkModuleFactory.getSupportedUriSchemes().contains(lowerCase))·{
151	················································networkModuleFactory.validateURI(uri);	152	················································networkModuleFactory.validateURI(uri);
		153	················································//·monitorexit(clazz)
152	················································return;	154	················································return;
153	············································}	155	············································}
154	············································continue;	156	············································continue;
155	············································try·{	157	············································try·{
156	················································final·StringBuilder·sb2;	158	················································final·StringBuilder·sb2;
157	················································final·StringBuilder·sb·=·sb2·=·new·StringBuilder("no·NetworkModule·installed·for·scheme·\"");	159	················································final·StringBuilder·sb·=·sb2·=·new·StringBuilder("no·NetworkModule·installed·for·scheme·\"");
158	················································try·{	160	················································try·{
159	····················································sb2.append(lowerCase);	161	····················································sb2.append(lowerCase);
160	····················································sb.append("\"·of·URI·\"");	162	····················································sb.append("\"·of·URI·\"");
161	····················································final·StringBuilder·sb3·=·sb;	163	····················································final·StringBuilder·sb3·=·sb;
162	····················································try·{	164	····················································try·{
163	························································sb3.append(string);	165	························································sb3.append(string);
164	························································~~fin~~a~~l·Stri~~n~~gBuil~~d~~er·sb4·=·sb~~;	166	························································sb.append("\"");
		167	························································throw·new·IllegalArgumentException(sb.toString());
165	························································try·{	168	························································try·{
		169	····························································final·StringBuilder·sb4·=·new·StringBuilder("missing·scheme·in·broker·URI:·");
166	····························································sb4.append(s);
167	····························································throw·new·IllegalArgumentException(sb.toString());
168	····························································try·{	170	····························································try·{
169	································································final·StringBuilder·sb5·=·new·StringBuilder("missing·scheme·in·broker·URI:·");
170	································································try·{
171	································································~~····~~sb5.append(string);	171	································································sb4.append(string);
172	································································~~····~~throw·new·IllegalArgumentException(sb5.toString());	172	································································throw·new·IllegalArgumentException(sb4.toString());
173	····························································~~····~~}	173	····························································}
174	····························································~~····~~catch·(URISyntaxException·cause)·{	174	····························································catch·(URISyntaxException·cause)·{
175	································································~~····~~final·StringBuilder·sb6·=·new·StringBuilder("Can't·parse·string·to·URI·\"");	175	································································final·StringBuilder·sb5·=·new·StringBuilder("Can't·parse·string·to·URI·\"");
176	································································~~····~~sb6.append(string);	176	································································sb5.append(string);
		177	································································string·=·"\"";
177	································································~~····~~sb6.append(s);	178	································································sb5.append(string);
178	································································~~····~~string·=·sb6.toString();	179	································································string·=·sb5.toString();
179	································································~~····~~throw·new·IllegalArgumentException(string,·cause);	180	································································throw·new·IllegalArgumentException(string,·cause);
180	································································}
181	····························································}	181	····························································}
182	····························································catch·(URISyntaxException·ex)·{}
183	························································}	182	························································}
184	························································catch·(URISyntaxException·ex2)·{}	183	························································catch·(URISyntaxException·ex)·{}
185	····················································}	184	····················································}
186	····················································catch·(URISyntaxException·ex3)·{}	185	····················································catch·(URISyntaxException·ex2)·{}
187	················································}	186	················································}
188	················································catch·(URISyntaxException·ex4)·{}	187	················································catch·(URISyntaxException·ex3)·{}
189	············································}	188	············································}
190	············································catch·(URISyntaxException·ex5)·{}	189	············································catch·(URISyntaxException·ex4)·{}
191	········································}	190	········································}
192	········································catch·(URISyntaxException·ex6)·{}	191	········································catch·(URISyntaxException·ex5)·{}
193	····································}	192	····································}
194	····································catch·(URISyntaxException·ex7)·{}	193	····································catch·(URISyntaxException·ex6)·{}
195	································}	194	································}
196	····························}	195	····························}
197	························}	196	························}
198	························catch·(URISyntaxException·ex8)·{}	197	························catch·(URISyntaxException·ex7)·{}
199	····················}	198	····················}
200	····················catch·(URISyntaxException·ex9)·{}	199	····················catch·(URISyntaxException·ex8)·{}
201	················}	200	················}
202	················catch·(URISyntaxException·ex10)·{}	201	················catch·(URISyntaxException·ex9)·{}
203	············}	202	············}
204	········}	203	········}
205	········catch·(URISyntaxException·ex11)·{}	204	········catch·(URISyntaxException·ex10)·{}
206	····}	205	····}
		206	····//·monitorexit(clazz)
207	}	207	}


Offset 22, 17 lines modified		Offset 22, 17 lines modified
22	····private·String·key;	22	····private·String·key;
23	····private·Logger·log;	23	····private·Logger·log;
24	····protected·MqttMessage·message;	24	····protected·MqttMessage·message;
25	····private·int·messageID;	25	····private·int·messageID;
26	····private·boolean·notified;	26	····private·boolean·notified;
27	····private·boolean·pendingComplete;	27	····private·boolean·pendingComplete;
28	····private·MqttWireMessage·response;	28	····private·MqttWireMessage·response;
29	····private·Object·responseLock;	29	····private·final·Object·responseLock;
30	····private·boolean·sent;	30	····private·boolean·sent;
31	····private·Object·sentLock;	31	····private·final·Object·sentLock;
32	····private·String[]·topics;	32	····private·String[]·topics;
33	····private·Object·userContext;	33	····private·Object·userContext;
34	····	34	····
35	····public·Token(final·String·resourceName)·{	35	····public·Token(final·String·resourceName)·{
36	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·Token.CLASS_NAME);	36	········this.log·=·LoggerFactory.getLogger("org.eclipse.paho.client.mqttv3.internal.nls.logcat",·Token.CLASS_NAME);
37	········this.completed·=·false;	37	········this.completed·=·false;
38	········this.pendingComplete·=·false;	38	········this.pendingComplete·=·false;
Offset 334, 35 lines modified		Offset 334, 35 lines modified
334	················s3·=·"true";	334	················s3·=·"true";
335	············}	335	············}
336	············array[n4]·=·s3;	336	············array[n4]·=·s3;
337	············array[5]·=·this.response;	337	············array[5]·=·this.response;
338	············array[6]·=·this;	338	············array[6]·=·this;
339	············log.fine(class_NAME,·s,·s2,·array,·(Throwable)this.exception);	339	············log.fine(class_NAME,·s,·s2,·array,·(Throwable)this.exception);
340	············while·(true)·{	340	············while·(true)·{
341	················Label_0384:·{	341	················Label_0379:·{
342	····················if·(this.completed)·{	342	····················if·(this.completed)·{
343	························break·Label_0384;	343	························break·Label_0379;
344	····················}	344	····················}
345	····················final·MqttException·exception·=·this.exception;	345	····················final·MqttException·exception·=·this.exception;
346	····················final·long·n5·=·0L;	346	····················final·long·n5·=·0L;
347	····················if·(exception·==·null)·{}	347	····················if·(exception·==·null)·{}
348	····················try·{	348	····················try·{
349	························final·Logger·log2·=·this.log;	349	························final·Logger·log2·=·this.log;
350	························try·{	350	························try·{
351	····························final·String·class_NAME2·=·Token.CLASS_NAME;	351	····························final·String·class_NAME2·=·Token.CLASS_NAME;
352	····························final·String·s4·=·"waitForResponse";	352	····························final·String·s4·=·"waitForResponse";
353	····························final·String·s5·=·"408";	353	····························final·String·s5·=·"408";
354	····························final·Object[]·array2·=·new·Object[n3];	354	····························final·Object[]·array2·=·new·Object[n3];
355	····························try·{	355	····························try·{
356	································array2[0]·=·this.getKey();	356	································array2[0]·=·this.getKey();
357	································array2[n2]·=·n~~ew·Long~~(n);	357	································array2[n2]·=·Long.valueOf(n);
358	································log2.fine(class_NAME2,·s4,·s5,·array2);	358	································log2.fine(class_NAME2,·s4,·s5,·array2);
359	································Label_0316:·{	359	································Label_0311:·{
360	····································if·(n·>·n5)·{	360	····································if·(n·>·n5)·{
361	········································break·Label_0316;	361	········································break·Label_0311;
362	····································}	362	····································}
363	····································final·Object·responseLock2·=·this.responseLock;	363	····································final·Object·responseLock2·=·this.responseLock;
364	····································try·{	364	····································try·{
365	········································responseLock2.wait();	365	········································responseLock2.wait();
366	········································this.responseLock.wait(n);	366	········································this.responseLock.wait(n);
367	····································}	367	····································}
368	····································catch·(InterruptedException·ex)·{	368	····································catch·(InterruptedException·ex)·{


Offset 1, 22 lines modified		Offset 1, 23 lines modified

1	package·org.eclipse.paho.client.mqttv3.internal.websocket;	1	package·org.eclipse.paho.client.mqttv3.internal.websocket;

		2	import·java.net.SocketTimeoutException;
2	import·java.io.IOException;	3	import·java.io.IOException;
3	import·org.eclipse.paho.client.mqttv3.logging.LoggerFactory;	4	import·org.eclipse.paho.client.mqttv3.logging.LoggerFactory;
4	import·java.io.PipedInputStream;	5	import·java.io.PipedInputStream;
5	import·java.io.PipedOutputStream;	6	import·java.io.PipedOutputStream;
6	import·org.eclipse.paho.client.mqttv3.logging.Logger;	7	import·org.eclipse.paho.client.mqttv3.logging.Logger;
7	import·java.io.InputStream;	8	import·java.io.InputStream;

8	public·class·WebSocketReceiver·implements·Runnable	9	public·class·WebSocketReceiver·implements·Runnable
9	{	10	{
10	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketReceiver";	11	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketReceiver";
11	····private·InputStream·input;	12	····private·InputStream·input;
12	····private·Object·lifecycle;	13	····private·final·Object·lifecycle;
13	····private·Logger·log;	14	····private·Logger·log;
14	····private·PipedOutputStream·pipedOutputStream;	15	····private·PipedOutputStream·pipedOutputStream;
15	····private·Thread·receiverThread;	16	····private·Thread·receiverThread;
16	····private·volatile·boolean·receiving;	17	····private·volatile·boolean·receiving;
17	····private·boolean·running;	18	····private·boolean·running;
18	····private·boolean·stopping;	19	····private·boolean·stopping;
19	····	20	····
Offset 48, 18 lines modified		Offset 49, 15 lines modified
48	····public·boolean·isRunning()·{	49	····public·boolean·isRunning()·{
49	········return·this.running;	50	········return·this.running;
50	····}	51	····}
51	····	52	····
52	····public·void·run()·{	53	····public·void·run()·{
53	····Label_0000:	54	····Label_0000:
54	········while·(true)·{	55	········while·(true)·{
55	············while·(true)·{
56	·············~~···if~~·(!this.running·\|\|·this.input·==·null)·{	56	············while·(this.running·&&·this.input·!=·null)·{
57	····················return;
58	················}
59	············Label_0208_Outer:	57	············Label_0208_Outer:
60	················while·(true)·{	58	················while·(true)·{
61	····················while·(true)·{	59	····················while·(true)·{
62	························try·{	60	························try·{
63	····························final·Logger·log·=·this.log;	61	····························final·Logger·log·=·this.log;
64	····························try·{	62	····························try·{
65	································log.fine(WebSocketReceiver.CLASS_NAME,·"run",·"852");	63	································log.fine(WebSocketReceiver.CLASS_NAME,·"run",·"852");
Offset 91, 41 lines modified		Offset 89, 48 lines modified
91	····································································++n;	89	····································································++n;
92	····································································continue·Label_0208_Outer;	90	····································································continue·Label_0208_Outer;
93	····································································this.stop();	91	····································································this.stop();
94	····································································continue·Label_0000;	92	····································································continue·Label_0000;
95	····································································Label_0194:·{	93	····································································Label_0194:·{
96	········································································throw·new·IOException("Server·sent·a·WebSocket·Frame·with·the·Stop·OpCode");	94	········································································throw·new·IOException("Server·sent·a·WebSocket·Frame·with·the·Stop·OpCode");
97	····································································}	95	····································································}
		96	····································································//·iftrue(Label_0194:,·!this.stopping)
98	····································································this.receiving·=·false;	97	····································································this.receiving·=·false;
99	····································································continue·Label_0000;
100	································································}	98	································································}
101	································································~~//·~~ift~~rue~~(~~Lab~~e~~l_0194:,·!this.stopping)~~	99	································································catch·(SocketTimeoutException·ex)·{}
102	································································catch·(IOException·ex)·{}	100	································································catch·(IOException·ex2)·{}
103	····························································}	101	····························································}
104	························································}	102	························································}
		103	························································catch·(SocketTimeoutException·ex3)·{}
105	························································catch·(IOException·ex2)·{}	104	························································catch·(IOException·ex4)·{}
106	····················································}	105	····················································}
107	················································}	106	················································}
		107	················································catch·(SocketTimeoutException·ex5)·{}
108	················································catch·(IOException·ex3)·{}	108	················································catch·(IOException·ex6)·{}
109	············································}	109	············································}
110	········································}	110	········································}
111	····································}	111	····································}
		112	····································catch·(SocketTimeoutException·ex7)·{}
112	····································catch·(IOException·ex4)·{}	113	····································catch·(IOException·ex8)·{}
113	································}	114	································}
		115	································catch·(SocketTimeoutException·ex9)·{}
114	································catch·(IOException·ex5)·{}	116	································catch·(IOException·ex10)·{}
115	····························}	117	····························}
		118	····························catch·(SocketTimeoutException·ex11)·{}
116	····························catch·(IOException·ex6)·{}	119	····························catch·(IOException·ex12)·{}
117	························}	120	························}
		121	························catch·(SocketTimeoutException·ex13)·{}
118	························catch·(IOException·ex7)·{}	122	························catch·(IOException·ex14)·{}
119	························continue;	123	························continue;
120	····················}	124	····················}
121	················}	125	················}
122	············}	126	············}
123	············break;	127	············break;
124	········}	128	········}
		129	········goto·Label_0219;
125	····}	130	····}
126	····	131	····
127	····public·void·start(final·String·name)·{	132	····public·void·start(final·String·name)·{
128	········this.log.fine(WebSocketReceiver.CLASS_NAME,·"start",·"855");	133	········this.log.fine(WebSocketReceiver.CLASS_NAME,·"start",·"855");
129	········synchronized·(this.lifecycle)·{	134	········synchronized·(this.lifecycle)·{
130	············if·(!this.running)·{	135	············if·(!this.running)·{
131	················this.running·=·true;	136	················this.running·=·true;


Offset 1, 8 lines modified		Offset 1, 8 lines modified
1	Zip·file·size:·1042~~6696~~·bytes,·number·of·entries:·5171	1	Zip·file·size:·10427137·bytes,·number·of·entries:·5171
2	?rwxrwxr-x··2.0·unx······134·b-·stor·80-Jan-01·00:00·android/arch/core/R.class	2	?rwxrwxr-x··2.0·unx······134·b-·stor·80-Jan-01·00:00·android/arch/core/R.class
3	?rwxrwxr-x··2.0·unx······419·b-·stor·80-Jan-01·00:00·android/arch/core/executor/ArchTaskExecutor$1.class	3	?rwxrwxr-x··2.0·unx······419·b-·stor·80-Jan-01·00:00·android/arch/core/executor/ArchTaskExecutor$1.class
4	?rwxrwxr-x··2.0·unx······418·b-·stor·80-Jan-01·00:00·android/arch/core/executor/ArchTaskExecutor$2.class	4	?rwxrwxr-x··2.0·unx······418·b-·stor·80-Jan-01·00:00·android/arch/core/executor/ArchTaskExecutor$2.class
5	?rwxrwxr-x··2.0·unx······394·b-·stor·80-Jan-01·00:00·android/arch/core/executor/TaskExecutor.class	5	?rwxrwxr-x··2.0·unx······394·b-·stor·80-Jan-01·00:00·android/arch/core/executor/TaskExecutor.class
6	?rwxrwxr-x··2.0·unx·······96·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$1.class	6	?rwxrwxr-x··2.0·unx·······96·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$1.class
7	?rwxrwxr-x··2.0·unx·····1154·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$Entry.class	7	?rwxrwxr-x··2.0·unx·····1154·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$Entry.class
8	?rwxrwxr-x··2.0·unx······188·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$SupportRemove.class	8	?rwxrwxr-x··2.0·unx······188·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$SupportRemove.class
Offset 1557, 17 lines modified		Offset 1557, 17 lines modified
1557	?rwxrwxr-x··2.0·unx·····2620·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttException.class	1557	?rwxrwxr-x··2.0·unx·····2620·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttException.class
1558	?rwxrwxr-x··2.0·unx·····1475·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttMessage.class	1558	?rwxrwxr-x··2.0·unx·····1475·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttMessage.class
1559	?rwxrwxr-x··2.0·unx······268·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttPersistable.class	1559	?rwxrwxr-x··2.0·unx······268·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttPersistable.class
1560	?rwxrwxr-x··2.0·unx······234·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttPingSender.class	1560	?rwxrwxr-x··2.0·unx······234·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttPingSender.class
1561	?rwxrwxr-x··2.0·unx·····4777·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttTopic.class	1561	?rwxrwxr-x··2.0·unx·····4777·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttTopic.class
1562	?rwxrwxr-x··2.0·unx·····1949·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/ScheduledExecutorPingSender$PingRunnable.class	1562	?rwxrwxr-x··2.0·unx·····1949·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/ScheduledExecutorPingSender$PingRunnable.class
1563	?rwxrwxr-x··2.0·unx·····1404·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/TimerPingSender$PingTask.class	1563	?rwxrwxr-x··2.0·unx·····1404·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/TimerPingSender$PingTask.class
1564	?rwxrwxr-x··2.0·unx·····7187·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG.class	1564	?rwxrwxr-x··2.0·unx·····7188·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG.class
1565	?rwxrwxr-x··2.0·unx·····3650·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientComms$DisconnectBG.class	1565	?rwxrwxr-x··2.0·unx·····3650·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientComms$DisconnectBG.class
1566	?rwxrwxr-x··2.0·unx····20711·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientComms.class	1566	?rwxrwxr-x··2.0·unx····20730·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientComms.class
1567	?rwxrwxr-x··2.0·unx····27443·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientState.class	1567	?rwxrwxr-x··2.0·unx····27443·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ClientState.class
1568	?rwxrwxr-x··2.0·unx·····1008·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsCallback$State.class	1568	?rwxrwxr-x··2.0·unx·····1008·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsCallback$State.class
1569	?rwxrwxr-x··2.0·unx····12101·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsCallback.class	1569	?rwxrwxr-x··2.0·unx····12101·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsCallback.class
1570	?rwxrwxr-x··2.0·unx·····1074·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsReceiver$State.class	1570	?rwxrwxr-x··2.0·unx·····1074·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsReceiver$State.class
1571	?rwxrwxr-x··2.0·unx·····7196·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsReceiver.class	1571	?rwxrwxr-x··2.0·unx·····7196·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsReceiver.class
1572	?rwxrwxr-x··2.0·unx······997·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsSender$State.class	1572	?rwxrwxr-x··2.0·unx······997·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsSender$State.class
1573	?rwxrwxr-x··2.0·unx·····6522·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsSender.class	1573	?rwxrwxr-x··2.0·unx·····6522·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/CommsSender.class
Offset 1575, 40 lines modified		Offset 1575, 40 lines modified
1575	?rwxrwxr-x··2.0·unx······195·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/DestinationProvider.class	1575	?rwxrwxr-x··2.0·unx······195·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/DestinationProvider.class
1576	?rwxrwxr-x··2.0·unx·····3343·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.class	1576	?rwxrwxr-x··2.0·unx·····3343·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.class
1577	?rwxrwxr-x··2.0·unx·····1045·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ExceptionHelper.class	1577	?rwxrwxr-x··2.0·unx·····1045·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/ExceptionHelper.class
1578	?rwxrwxr-x··2.0·unx·····2018·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/FileLock.class	1578	?rwxrwxr-x··2.0·unx·····2018·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/FileLock.class
1579	?rwxrwxr-x··2.0·unx······206·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/IDisconnectedBufferCallback.class	1579	?rwxrwxr-x··2.0·unx······206·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/IDisconnectedBufferCallback.class
1580	?rwxrwxr-x··2.0·unx······987·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/MessageCatalog.class	1580	?rwxrwxr-x··2.0·unx······987·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/MessageCatalog.class
1581	?rwxrwxr-x··2.0·unx······292·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/NetworkModule.class	1581	?rwxrwxr-x··2.0·unx······292·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/NetworkModule.class
1582	?rwxrwxr-x··2.0·unx·····4~~630~~·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.class	1582	?rwxrwxr-x··2.0·unx·····4956·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.class
1583	?rwxrwxr-x··2.0·unx·····8261·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/Token.class	1583	?rwxrwxr-x··2.0·unx·····8230·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/Token.class
1584	?rwxrwxr-x··2.0·unx····16280·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/security/SSLSocketFactoryFactory.class	1584	?rwxrwxr-x··2.0·unx····16280·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/security/SSLSocketFactoryFactory.class
1585	?rwxrwxr-x··2.0·unx·····1736·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/security/SimpleBase64Encoder.class	1585	?rwxrwxr-x··2.0·unx·····1736·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/security/SimpleBase64Encoder.class


Offset 34, 273 lines modified		Offset 34, 278 lines modified
34	········MqttException·mqttException·=·null;	34	········MqttException·mqttException·=·null;
35	········try·{	35	········try·{
36	············final·ClientComms·this$0·=·this.this$0;	36	············final·ClientComms·this$0·=·this.this$0;
37	············try·{	37	············try·{
38	················final·CommsTokenStore·access$3·=·ClientComms.access$3(this$0);	38	················final·CommsTokenStore·access$3·=·ClientComms.access$3(this$0);
39	················try·{	39	················try·{
40	····················final·MqttDeliveryToken[]·outstandingDelTokens·=·access$3.getOutstandingDelTokens();	40	····················final·MqttDeliveryToken[]·outstandingDelTokens·=·access$3.getOutstandingDelTokens();
		41	····················try·{
		42	························final·int·length·=·outstandingDelTokens.length;
41	····················int·n·=·0;	43	························int·n·=·0;
42	····················while·(true)·{	44	························while·(true)·{
43	························Label_0542:·{	45	····························Label_0543:·{
44	····························if·(n·<·~~outstan~~di~~ngDelTokens.~~length)·{	46	································if·(n·<·length)·{
45	································break·Label_0542;	47	····································break·Label_0543;
46	····························}	48	································}
47	····························final·ClientComms·this$2·=·this.this$0;	49	································final·ClientComms·this$2·=·this.this$0;
48	····························try·{
49	································final·CommsTokenStore·access$4·=·ClientComms.access$3(this$2);
50	································try·{	50	································try·{
51	····································final·~~Mqtt~~Token·co~~nTok~~en·=·this.c~~onToken~~;	51	····································final·CommsTokenStore·access$4·=·ClientComms.access$3(this$2);
52	····································try·{	52	····································try·{
		53	········································final·MqttToken·conToken·=·this.conToken;
53	········································access$4.saveToken(conToken,·(MqttWireMessage)this.conPacket);
54	········································final·ClientComms·this$3·=·this.this$0;
55	········································try·{	54	········································try·{
56	············································~~final·NetworkM~~o~~dule[]·acc~~e~~ss$5·=·Cl~~i~~entComms.acce~~s~~s$4(this$3~~);	55	············································access$4.saveToken(conToken,·(MqttWireMessage)this.conPacket);
		56	············································final·ClientComms·this$3·=·this.this$0;
57	············································try·{	57	············································try·{
58	················································final·~~ClientC~~o~~mms~~·~~thi~~s$4·=·this.this$0;	58	················································final·NetworkModule[]·access$5·=·ClientComms.access$4(this$3);
59	················································try·{	59	················································try·{
60	····················································final·~~NetworkMod~~ule·net~~work~~Mo~~dule·=~~·ac~~ces~~s$~~5[Clien~~tComms.~~access$5(~~this$4)];	60	····················································final·ClientComms·this$4·=·this.this$0;
61	····················································try·{	61	····················································try·{
		62	························································final·NetworkModule·networkModule·=·access$5[ClientComms.access$5(this$4)];
62	························································networkModule.start();
63	························································final·ClientComms·this$5·=·this.this$0;
64	························································try·{	63	························································try·{
		64	····························································networkModule.start();
		65	····························································final·ClientComms·this$5·=·this.this$0;


Offset 148, 28 lines modified		Offset 148, 28 lines modified
148	················································final·StringBuilder·sb4·=·sb2;	148	················································final·StringBuilder·sb4·=·sb2;
149	················································try·{	149	················································try·{
150	····················································sb4.append(s2);	150	····················································sb4.append(s2);
151	····················································printWriter.print(sb2.toString());	151	····················································printWriter.print(sb2.toString());
152	····················································final·int·port·=·this.port;	152	····················································final·int·port·=·this.port;
153	····················································final·int·n·=·80;	153	····················································final·int·n·=·80;
154	····················································final·String·s4·=·"Host:·";	154	····················································final·String·s4·=·"Host:·";
155	····················································Label_0~~313~~:·{	155	····················································Label_0295:·{
156	························································if·(port·==·n~~·\|\|·this.port·==·443~~)·{	156	························································if·(port·==·n)·{
157	····························································break·Label_0~~313~~;	157	····························································break·Label_0295;
158	························································}	158	························································}
159	························································final·StringBuilder·sb5·=·new·StringBuilder(s4);	159	························································final·StringBuilder·sb5·=·new·StringBuilder(s4);
160	························································sb5.append(this.host);	160	························································sb5.append(this.host);
161	························································sb5.append(":");	161	························································sb5.append(":");
162	························································sb5.append(this.port);	162	························································sb5.append(this.port);
163	························································final·StringBuilder·sb6·=·sb5;	163	························································final·StringBuilder·sb6·=·sb5;
164	························································try·{	164	························································try·{
165	····························································sb6.append(s2);	165	····························································sb6.append(s2);
166	····························································printWriter.print(sb5.toString());	166	····························································printWriter.print(sb5.toString());
167	····························································Label_0353:·{	167	····························································Label_0335:·{
168	································································break·Label_0353;	168	································································break·Label_0335;
169	································································final·StringBuilder·sb7·=·new·StringBuilder(s4);	169	································································final·StringBuilder·sb7·=·new·StringBuilder(s4);
170	································································sb7.append(this.host);	170	································································sb7.append(this.host);
171	································································final·StringBuilder·sb8·=·sb7;	171	································································final·StringBuilder·sb8·=·sb7;
172	································································try·{	172	································································try·{
173	····································································sb8.append(s2);	173	····································································sb8.append(s2);
174	····································································printWriter.print(sb7.toString());	174	····································································printWriter.print(sb7.toString());
175	····································································printWriter.print("Upgrade:·websocket\r\n");	175	····································································printWriter.print("Upgrade:·websocket\r\n");
Offset 183, 27 lines modified		Offset 183, 27 lines modified
183	············································································sb11.append(s2);	183	············································································sb11.append(s2);
184	············································································s·=·sb9.toString();	184	············································································s·=·sb9.toString();
185	············································································printWriter.print(s);	185	············································································printWriter.print(s);
186	············································································s·=·"Sec-WebSocket-Protocol:·mqtt\r\n";	186	············································································s·=·"Sec-WebSocket-Protocol:·mqtt\r\n";
187	············································································printWriter.print(s);	187	············································································printWriter.print(s);
188	············································································s·=·"Sec-WebSocket-Version:·13\r\n";	188	············································································s·=·"Sec-WebSocket-Version:·13\r\n";
189	············································································printWriter.print(s);	189	············································································printWriter.print(s);
190	············································································Label_0550:·{	190	············································································Label_0532:·{
191	················································································if·(this.customWebSocketHeaders·==·null)·{	191	················································································if·(this.customWebSocketHeaders·==·null)·{


Offset 58, 17 lines modified		Offset 58, 19 lines modified
58	········}	58	········}
59	········return·0;	59	········return·0;
60	····}	60	····}
61	····	61	····
62	····public·static·boolean·equalsAny(final·CharSequence·obj,·final·CharSequence[]·array)·{	62	····public·static·boolean·equalsAny(final·CharSequence·obj,·final·CharSequence[]·array)·{
63	········boolean·b·=·obj·==·null·&&·array·==·null;	63	········boolean·b·=·obj·==·null·&&·array·==·null;
64	········if·(array·!=·null)·{	64	········if·(array·!=·null)·{
		65	············final·int·length·=·array.length;
65	············boolean·b2·=·b;	66	············boolean·b2·=·b;
66	············for·(int·i·=·0;·i·<·~~array.~~length;·++i)·{	67	············for·(int·i·=·0;·i·<·length;·++i)·{
		68	················final·CharSequence·charSequence·=·array[i];
67	················b2·=·(b2·\|\|·ar~~ray[i]~~.equals(obj));	69	················b2·=·(b2·\|\|·charSequence.equals(obj));
68	············}	70	············}
69	············b·=·b2;	71	············b·=·b2;
70	········}	72	········}
71	········return·b;	73	········return·b;
72	····}	74	····}
73	····	75	····
74	····private·static·int·indexOf(final·CharSequence·charSequence,·final·CharSequence·charSequence2,·final·int·fromIndex)·{	76	····private·static·int·indexOf(final·CharSequence·charSequence,·final·CharSequence·charSequence2,·final·int·fromIndex)·{


Offset 28, 15 lines modified		Offset 28, 15 lines modified
28	{	28	{
29	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.MqttAsyncClient";	29	····private·static·final·String·CLASS_NAME·=·"org.eclipse.paho.client.mqttv3.MqttAsyncClient";
30	····private·static·final·String·CLIENT_ID_PREFIX·=·"paho";	30	····private·static·final·String·CLIENT_ID_PREFIX·=·"paho";
31	····private·static·final·long·DISCONNECT_TIMEOUT·=·10000L;	31	····private·static·final·long·DISCONNECT_TIMEOUT·=·10000L;
32	····private·static·final·char·MAX_HIGH_SURROGATE·=·'\udbff';	32	····private·static·final·char·MAX_HIGH_SURROGATE·=·'\udbff';
33	····private·static·final·char·MIN_HIGH_SURROGATE·=·'\ud800';	33	····private·static·final·char·MIN_HIGH_SURROGATE·=·'\ud800';
34	····private·static·final·long·QUIESCE_TIMEOUT·=·30000L;	34	····private·static·final·long·QUIESCE_TIMEOUT·=·30000L;
35	····private·static·Object·clientLock;	35	····private·static·final·Object·clientLock;
36	····private·static·int·reconnectDelay·=·1000;	36	····private·static·int·reconnectDelay·=·1000;
37	····private·String·clientId;	37	····private·String·clientId;
38	····protected·ClientComms·comms;	38	····protected·ClientComms·comms;
39	····private·MqttConnectOptions·connOpts;	39	····private·MqttConnectOptions·connOpts;
40	····private·ScheduledExecutorService·executorService;	40	····private·ScheduledExecutorService·executorService;
41	····private·Logger·log;	41	····private·Logger·log;
42	····private·MqttCallback·mqttCallback;	42	····private·MqttCallback·mqttCallback;
Offset 44, 15 lines modified		Offset 44, 15 lines modified
44	····private·Timer·reconnectTimer;	44	····private·Timer·reconnectTimer;
45	····private·boolean·reconnecting;	45	····private·boolean·reconnecting;
46	····private·String·serverURI;	46	····private·String·serverURI;
47	····private·Hashtable·topics;	47	····private·Hashtable·topics;
48	····private·Object·userContext;	48	····private·Object·userContext;
49	····	49	····
50	····static·{	50	····static·{
51	········~~MqttAsyncClient.~~clientLock·=·new·Object();	51	········clientLock·=·new·Object();
52	····}	52	····}
53	····	53	····
54	····public·MqttAsyncClient(final·String·s,·final·String·s2)·{	54	····public·MqttAsyncClient(final·String·s,·final·String·s2)·{
55	········this(s,·s2,·(MqttClientPersistence)new·MqttDefaultFilePersistence());	55	········this(s,·s2,·(MqttClientPersistence)new·MqttDefaultFilePersistence());
56	····}	56	····}
57	····	57	····
58	····public·MqttAsyncClient(final·String·s,·final·String·s2,·final·MqttClientPersistence·mqttClientPersistence)·{	58	····public·MqttAsyncClient(final·String·s,·final·String·s2,·final·MqttClientPersistence·mqttClientPersistence)·{
Offset 260, 15 lines modified		Offset 260, 15 lines modified
260	············}	260	············}
261	············final·MqttConnectOptions·mqttConnectOptions·=·connOpts;	261	············final·MqttConnectOptions·mqttConnectOptions·=·connOpts;
262	············this.connOpts·=·connOpts;	262	············this.connOpts·=·connOpts;
263	············this.userContext·=·userContext;	263	············this.userContext·=·userContext;
264	············final·boolean·automaticReconnect·=·connOpts.isAutomaticReconnect();	264	············final·boolean·automaticReconnect·=·connOpts.isAutomaticReconnect();
265	············final·Logger·log·=·this.log;	265	············final·Logger·log·=·this.log;
266	············final·String·class_NAME·=·MqttAsyncClient.CLASS_NAME;	266	············final·String·class_NAME·=·MqttAsyncClient.CLASS_NAME;
267	············final·Object[]·array·=·{·Boolean.valueOf(connOpts.isCleanSession()),·ne~~w·Integ~~er(connOpts.getConnectionTimeout()),·Integer.valueOf(connOpts.getKeepAliveInterval()),·connOpts.getUserName(),·null,·null,·null,·null·};	267	············final·Object[]·array·=·{·Boolean.valueOf(connOpts.isCleanSession()),·Integer.valueOf(connOpts.getConnectionTimeout()),·Integer.valueOf(connOpts.getKeepAliveInterval()),·connOpts.getUserName(),·null,·null,·null,·null·};
268	············final·int·n·=·4;	268	············final·int·n·=·4;
269	············final·char[]·password·=·connOpts.getPassword();	269	············final·char[]·password·=·connOpts.getPassword();
270	············String·s·=·"[null]";	270	············String·s·=·"[null]";
271	············final·String·s2·=·"[notnull]";	271	············final·String·s2·=·"[notnull]";
272	············String·s3;	272	············String·s3;
273	············if·(password·==·null)·{	273	············if·(password·==·null)·{
274	················s3·=·s;	274	················s3·=·s;
Offset 549, 17 lines modified		Offset 549, 18 lines modified
549	····	549	····
550	····public·IMqttToken·subscribe(final·String[]·array,·final·int[]·array2)·{	550	····public·IMqttToken·subscribe(final·String[]·array,·final·int[]·array2)·{
551	········return·this.subscribe(array,·array2,·null,·null);	551	········return·this.subscribe(array,·array2,·null,·null);
552	····}	552	····}
553	····	553	····
554	····public·IMqttToken·subscribe(final·String[]·array,·final·int[]·array2,·final·Object·o,·final·IMqttActionListener·mqttActionListener)·{	554	····public·IMqttToken·subscribe(final·String[]·array,·final·int[]·array2,·final·Object·o,·final·IMqttActionListener·mqttActionListener)·{
555	········if·(array.length·==·array2.length)·{	555	········if·(array.length·==·array2.length)·{
556	············for·(int·i·=·0;·i·<·~~array.~~length;·++i)·{	556	············for·(int·length·=·array.length,·i·=·0;·i·<·length;·++i)·{
		557	················final·String·s·=·array[i];
557	················MqttTopic.validate(~~array[i~~],·true);	558	················MqttTopic.validate(s,·true);
558	················this.comms.removeMessageListener(~~array[i~~]);	559	················this.comms.removeMessageListener(s);
559	············}	560	············}
560	············return·this.subscribeBase(array,·array2,·o,·mqttActionListener);	561	············return·this.subscribeBase(array,·array2,·o,·mqttActionListener);
561	········}	562	········}
562	········throw·new·IllegalArgumentException();	563	········throw·new·IllegalArgumentException();
563	····}	564	····}
564	····	565	····
565	····public·IMqttToken·subscribe(final·String[]·array,·final·int[]·array2,·final·Object·o,·final·IMqttActionListener·mqttActionListener,·final·IMqttMessageListener[]·array3)·{	566	····public·IMqttToken·subscribe(final·String[]·array,·final·int[]·array2,·final·Object·o,·final·IMqttActionListener·mqttActionListener,·final·IMqttMessageListener[]·array3)·{
Offset 628, 15 lines modified		Offset 629, 15 lines modified
628	············final·Logger·log·=·this.log;	629	············final·Logger·log·=·this.log;
629	············final·String·class_NAME·=·MqttAsyncClient.CLASS_NAME;	630	············final·String·class_NAME·=·MqttAsyncClient.CLASS_NAME;
630	············final·Object[]·array·=·{·s2,·null,·null·};	631	············final·Object[]·array·=·{·s2,·null,·null·};
631	············array[n]·=·userContext;	632	············array[n]·=·userContext;
632	············array[2]·=·actionCallback;	633	············array[2]·=·actionCallback;
633	············log.fine(class_NAME,·s,·"107",·array);	634	············log.fine(class_NAME,·s,·"107",·array);
634	········}	635	········}
635	········for·(int·k·=·0;·k·<·~~topics.~~length;·++k)·{	636	········for·(int·length·=·topics.length,·k·=·0;·k·<·length;·++k)·{
636	············MqttTopic.validate(topics[k],·(boolean)(n·!=·0));	637	············MqttTopic.validate(topics[k],·(boolean)(n·!=·0));
637	········}	638	········}
638	········while·(i·<·topics.length)·{	639	········while·(i·<·topics.length)·{
639	············this.comms.removeMessageListener(topics[i]);	640	············this.comms.removeMessageListener(topics[i]);
640	············++i;	641	············++i;
641	········}	642	········}
642	········final·MqttToken·mqttToken·=·new·MqttToken(this.getClientId());	643	········final·MqttToken·mqttToken·=·new·MqttToken(this.getClientId());


Offset 58, 15 lines modified		Offset 58, 15 lines modified
58	········if·(array·==·null·\|\|·array2·==·null)·{	58	········if·(array·==·null·\|\|·array2·==·null)·{
59	············throw·new·IllegalArgumentException();	59	············throw·new·IllegalArgumentException();
60	········}	60	········}
61	········this.names·=·array.clone();	61	········this.names·=·array.clone();
62	········this.qos·=·array2.clone();	62	········this.qos·=·array2.clone();
63	········if·(this.names.length·==·this.qos.length)·{	63	········if·(this.names.length·==·this.qos.length)·{
64	············this.count·=·array.length;	64	············this.count·=·array.length;
65	············for·(int·i·=·0;·i·<·~~array2.~~length;·++i)·{	65	············for·(int·length·=·array2.length,·i·=·0;·i·<·length;·++i)·{
66	················MqttMessage.validateQos(array2[i]);	66	················MqttMessage.validateQos(array2[i]);
67	············}	67	············}
68	············return;	68	············return;
69	········}	69	········}
70	········throw·new·IllegalArgumentException();	70	········throw·new·IllegalArgumentException();
71	····}	71	····}
72	····	72	····


Offset 65, 29 lines modified		Offset 65, 24 lines modified
65	····}	65	····}
66	····	66	····
67	····public·byte[]·getPayload()·{	67	····public·byte[]·getPayload()·{
68	········try·{	68	········try·{
69	············try·{	69	············try·{
70	················final·ByteArrayOutputStream·out·=·new·ByteArrayOutputStream();	70	················final·ByteArrayOutputStream·out·=·new·ByteArrayOutputStream();
71	················final·DataOutputStream·dataOutputStream·=·new·DataOutputStream(out);	71	················final·DataOutputStream·dataOutputStream·=·new·DataOutputStream(out);
72	················int·n·=·0;
73	················while·(true)·{
74	················~~····~~final·String[]·names·=·this.names;	72	················final·String[]·names·=·this.names;
75	················~~····~~try·{	73	················try·{
		74	····················for·(int·length·=·names.length,·i·=·0;·i·<·length;·++i)·{
76	························if·(n·>=·names.length)·{
77	····························dataOutputStream.flush();
78	····························return·out.toByteArray();
79	························}
80	························encodeUTF8(dataOutputStream,·~~this.~~names[n]);	75	························encodeUTF8(dataOutputStream,·names[i]);
81	························++n;
82	························continue;
83	····················}
84	····················catch·(IOException·ex)·{
85	························throw·new·MqttException((Throwable)ex);
86	····················}	76	····················}
		77	····················dataOutputStream.flush();
		78	····················return·out.toByteArray();
		79	················}
		80	················catch·(IOException·ex)·{
		81	····················throw·new·MqttException((Throwable)ex);
87	················}	82	················}
88	············}	83	············}
89	············catch·(IOException·ex2)·{}	84	············catch·(IOException·ex2)·{}
90	········}	85	········}
91	········catch·(IOException·ex3)·{}	86	········catch·(IOException·ex3)·{}
92	····}	87	····}
93	····	88	····


Offset 26, 26 lines modified		Offset 26, 21 lines modified
26	········this.resourceName·=·null;	26	········this.resourceName·=·null;
27	········this.loggerName·=·null;	27	········this.loggerName·=·null;
28	····}	28	····}
29	····	29	····
30	····protected·static·void·dumpMemoryTrace47(java.util.logging.Logger·parent)·{	30	····protected·static·void·dumpMemoryTrace47(java.util.logging.Logger·parent)·{
31	········if·(parent·!=·null)·{	31	········if·(parent·!=·null)·{
32	············final·Handler[]·handlers·=·parent.getHandlers();	32	············final·Handler[]·handlers·=·parent.getHandlers();
33	············for·(int·i·~~=·0;·i~~·<·handlers.length;·++i)·{	33	············for·(int·length·=·handlers.length,·i·=·0;·i·<·length;·++i)·{
		34	················final·Handler·handler·=·handlers[i];
34	················if·(handler~~s[i]~~·instanceof·MemoryHandler)·{	35	················if·(handler·instanceof·MemoryHandler)·{
35	····················final·Handler·handler·=·handlers[i];
36	····················~~//·m~~onitorenter(handler)	36	····················synchronized·(handler)·{
37	····················final·Handler[]·array·=·handlers;
38	····················try·{
39	························((MemoryHandler)a~~rray[i]~~).push();	37	························((MemoryHandler)handler).push();
40	························return;	38	························return;
41	····················}	39	····················}
42	····················finally·{
43	····················}
44	····················//·monitorexit(handler)
45	················}	40	················}
46	············}	41	············}
47	············parent·=·parent.getParent();	42	············parent·=·parent.getParent();
48	············dumpMemoryTrace47(parent);	43	············dumpMemoryTrace47(parent);
49	········}	44	········}
50	····}	45	····}
51	····	46	····
Offset 57, 15 lines modified		Offset 52, 15 lines modified
57	········catch·(MissingResourceException·ex)·{	52	········catch·(MissingResourceException·ex)·{
58	············return·string;	53	············return·string;
59	········}	54	········}
60	····}	55	····}
61	····	56	····
62	····private·void·logToJsr47(final·Level·level,·final·String·sourceClassName,·final·String·sourceMethodName,·String·resourceMessage,·final·ResourceBundle·resourceBundle,·String·format,·final·Object[]·arguments,·final·Throwable·thrown)·{	57	····private·void·logToJsr47(final·Level·level,·final·String·sourceClassName,·final·String·sourceMethodName,·String·resourceMessage,·final·ResourceBundle·resourceBundle,·String·format,·final·Object[]·arguments,·final·Throwable·thrown)·{
63	········resourceMessage·=·"=====";	58	········resourceMessage·=·"=====";
64	········if·(format.in~~dexOf~~(resourceMessage)~~·==·-1~~)·{	59	········if·(!format.contains(resourceMessage))·{
65	············resourceMessage·=·this.getResourceMessage(resourceBundle,·format);	60	············resourceMessage·=·this.getResourceMessage(resourceBundle,·format);
66	············format·=·MessageFormat.format(resourceMessage,·arguments);	61	············format·=·MessageFormat.format(resourceMessage,·arguments);
67	········}	62	········}
68	········final·StringBuilder·sb·=·new·StringBuilder(String.valueOf(this.resourceName));	63	········final·StringBuilder·sb·=·new·StringBuilder(String.valueOf(this.resourceName));
69	········sb.append(":·");	64	········sb.append(":·");
70	········sb.append(format);	65	········sb.append(format);
71	········final·LogRecord·record·=·new·LogRecord(level,·sb.toString());	66	········final·LogRecord·record·=·new·LogRecord(level,·sb.toString());


Offset 60, 30 lines modified		Offset 60, 31 lines modified
60	····private·boolean·isSafeChar(final·char·ch)·{	60	····private·boolean·isSafeChar(final·char·ch)·{
61	········return·Character.isJavaIdentifierPart(ch)·\|\|·ch·==·'-';	61	········return·Character.isJavaIdentifierPart(ch)·\|\|·ch·==·'-';
62	····}	62	····}
63	····	63	····
64	····private·void·restoreBackups(final·File·parent)·{	64	····private·void·restoreBackups(final·File·parent)·{
65	········final·File[]·listFiles·=·parent.listFiles((FileFilter)new·PersistanceFileFilter(".bup"));	65	········final·File[]·listFiles·=·parent.listFiles((FileFilter)new·PersistanceFileFilter(".bup"));
66	········if·(listFiles·!=·null)·{	66	········if·(listFiles·!=·null)·{
67	············for·(int·i·~~=·0;·i~~·<·listFiles.length;·++i)·{	67	············for·(int·length·=·listFiles.length,·i·=·0;·i·<·length;·++i)·{
		68	················final·File·file·=·listFiles[i];
68	················final·File·file·=·new·File(parent,·~~list~~File~~s[i]~~.getName().substring(0,·~~list~~File~~s[i]~~.getName().length()·-·4));	69	················final·File·file2·=·new·File(parent,·file.getName().substring(0,·file.getName().length()·-·4));
69	················if·(!~~list~~File~~s[i]~~.renameTo(file))·{	70	················if·(!file.renameTo(file2))·{
70	····················file.delete();	71	····················file2.delete();
71	····················~~list~~File~~s[i]~~.renameTo(file);	72	····················file.renameTo(file2);
72	················}	73	················}
73	············}	74	············}
74	············return;	75	············return;
75	········}	76	········}
76	········throw·new·MqttPersistenceException();	77	········throw·new·MqttPersistenceException();
77	····}	78	····}
78	····	79	····
79	····public·void·clear()·{	80	····public·void·clear()·{
80	········this.checkIsOpen();	81	········this.checkIsOpen();
81	········final·File[]·files·=·this.getFiles();	82	········final·File[]·files·=·this.getFiles();
82	········for·(int·i·=·0;·i·<·~~files.~~length;·++i)·{	83	········for·(int·length·=·files.length,·i·=·0;·i·<·length;·++i)·{
83	············files[i].delete();	84	············files[i].delete();
84	········}	85	········}
85	········this.clientDir.delete();	86	········this.clientDir.delete();
86	····}	87	····}
87	····	88	····
88	····public·void·close()·{	89	····public·void·close()·{
89	········synchronized·(this)·{	90	········synchronized·(this)·{
Offset 148, 15 lines modified		Offset 149, 15 lines modified
148	········catch·(IOException·ex6)·{}	149	········catch·(IOException·ex6)·{}
149	····}	150	····}
150	····	151	····
151	····public·Enumeration·keys()·{	152	····public·Enumeration·keys()·{
152	········this.checkIsOpen();	153	········this.checkIsOpen();
153	········final·File[]·files·=·this.getFiles();	154	········final·File[]·files·=·this.getFiles();
154	········final·Vector·vector·=·new·Vector<String>(files.length);	155	········final·Vector·vector·=·new·Vector<String>(files.length);
155	········for·(int·i·=·0;·i·<·~~files.~~length;·++i)·{	156	········for·(int·length·=·files.length,·i·=·0;·i·<·length;·++i)·{
156	············final·String·name·=·files[i].getName();	157	············final·String·name·=·files[i].getName();
157	············vector.addElement(name.substring(0,·name.length()·-·4));	158	············vector.addElement(name.substring(0,·name.length()·-·4));
158	········}	159	········}
159	········return·vector.elements();	160	········return·vector.elements();
160	····}	161	····}
161	····	162	····
162	····public·void·open(final·String·p0,·final·String·p1)·{	163	····public·void·open(final·String·p0,·final·String·p1)·{


Offset 32, 14 lines modified		Offset 32, 16 lines modified
32	········return·new·byte[0];	32	········return·new·byte[0];
33	····}	33	····}
34	····	34	····
35	····public·String·toString()·{	35	····public·String·toString()·{
36	········final·StringBuffer·sb·=·new·StringBuffer();	36	········final·StringBuffer·sb·=·new·StringBuffer();
37	········sb.append(super.toString());	37	········sb.append(super.toString());
38	········sb.append("·granted·Qos");	38	········sb.append("·granted·Qos");
39	········f~~or·(~~int·~~i·=·0;·i~~·<·this.grantedQos~~.length~~;~~·++i)·{~~	39	········final·int[]·grantedQos·=·this.grantedQos;
		40	········for·(int·length·=·grantedQos.length,·i·=·0;·i·<·length;·++i)·{
		41	············final·int·j·=·grantedQos[i];
40	············sb.append("·");	42	············sb.append("·");
41	············sb.append(~~this.grantedQos[i~~]);	43	············sb.append(j);
42	········}	44	········}
43	········return·sb.toString();	45	········return·sb.toString();
44	····}	46	····}
45	}	47	}


Offset 25, 15 lines modified		Offset 25, 15 lines modified

25	.field·private·static·final·MAX_HIGH_SURROGATE:C·=·'\udbff'	25	.field·private·static·final·MAX_HIGH_SURROGATE:C·=·'\udbff'

26	.field·private·static·final·MIN_HIGH_SURROGATE:C·=·'\ud800'	26	.field·private·static·final·MIN_HIGH_SURROGATE:C·=·'\ud800'

27	.field·private·static·final·QUIESCE_TIMEOUT:J·=·0x7530L	27	.field·private·static·final·QUIESCE_TIMEOUT:J·=·0x7530L

28	.field·private·static·clientLock:Ljava/lang/Object;~~·=·null~~	28	.field·private·static·final·clientLock:Ljava/lang/Object;

29	.field·private·static·reconnectDelay:I·=·0x3e8	29	.field·private·static·reconnectDelay:I·=·0x3e8


30	#·instance·fields	30	#·instance·fields
31	.field·private·clientId:Ljava/lang/String;	31	.field·private·clientId:Ljava/lang/String;

Offset 1153, 21 lines modified		Offset 1153, 21 lines modified

1153	····const/4·v9,·0x0	1153	····const/4·v9,·0x0

1154	····aput-object·v3,·v2,·v9	1154	····aput-object·v3,·v2,·v9

1155	····const/4·v3,·0x1	1155	····const/4·v3,·0x1

1156	····new-instance·v5,·Ljava/lang/Integer;

1157	····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getConnectionTimeout()I	1156	····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getConnectionTimeout()I

1158	····move-result·v6	1157	····move-result·v5

1159	····invoke-~~direct~~·{v5~~,·v6~~},·Ljava/lang/Integer;->~~<init>~~(I)V	1158	····invoke-static·{v5},·Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

		1159	····move-result-object·v5

1160	····aput-object·v5,·v2,·v3	1160	····aput-object·v5,·v2,·v3

1161	····const/4·v3,·0x2	1161	····const/4·v3,·0x2

1162	····.line·621	1162	····.line·621
1163	····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getKeepAliveInterval()I	1163	····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getKeepAliveInterval()I
Offset 2359, 59 lines modified		Offset 2359, 58 lines modified

2359	····move-result-object·p1	2359	····move-result-object·p1

2360	····return-object·p1	2360	····return-object·p1
2361	.end·method	2361	.end·method

2362	.method·public·subscribe([Ljava/lang/String;[ILjava/lang/Object;Lorg/eclipse/paho/client/mqttv3/IMqttActionListener;)Lorg/eclipse/paho/client/mqttv3/IMqttToken;	2362	.method·public·subscribe([Ljava/lang/String;[ILjava/lang/Object;Lorg/eclipse/paho/client/mqttv3/IMqttActionListener;)Lorg/eclipse/paho/client/mqttv3/IMqttToken;
2363	····.locals·3	2363	····.locals·4
2364	····.annotation·system·Ldalvik/annotation/Throws;	2364	····.annotation·system·Ldalvik/annotation/Throws;
2365	········value·=·{	2365	········value·=·{
2366	············Lorg/eclipse/paho/client/mqttv3/MqttException;	2366	············Lorg/eclipse/paho/client/mqttv3/MqttException;
2367	········}	2367	········}
2368	····.end·annotation	2368	····.end·annotation

2369	····.line·926	2369	····.line·926
2370	····array-length·v0,·p1	2370	····array-length·v0,·p1

2371	····array-length·v1,·p2	2371	····array-length·v1,·p2

2372	····if-ne·v0,·v1,·:cond_1	2372	····if-ne·v0,·v1,·:cond_1

2373	····const/4·v0,·0x0

2374	····.line·931	2373	····.line·931
2375	····:goto_0
2376	····array-length·v1,·p1	2374	····array-length·v0,·p1

		2375	····const/4·v1,·0x0

		2376	····:goto_0
2377	····if-lt·v0,·v1,·:cond_0	2377	····if-lt·v1,·v0,·:cond_0

2378	····.line·937	2378	····.line·937
2379	····invoke-direct·{p0,·p1,·p2,·p3,·p4},·Lorg/eclipse/paho/client/mqttv3/MqttAsyncClient;->subscribeBase([Ljava/lang/String;[ILjava/lang/Object;Lorg/eclipse/paho/client/mqttv3/IMqttActionListener;)Lorg/eclipse/paho/client/mqttv3/IMqttToken;	2379	····invoke-direct·{p0,·p1,·p2,·p3,·p4},·Lorg/eclipse/paho/client/mqttv3/MqttAsyncClient;->subscribeBase([Ljava/lang/String;[ILjava/lang/Object;Lorg/eclipse/paho/client/mqttv3/IMqttActionListener;)Lorg/eclipse/paho/client/mqttv3/IMqttToken;

2380	····move-result-object·p1	2380	····move-result-object·p1

2381	····return-object·p1	2381	····return-object·p1

2382	····.line·933	2382	····.line·931
2383	····:cond_0	2383	····:cond_0
2384	····aget-object·v1,·p1,·v0	2384	····aget-object·v2,·p1,·v1

2385	····const/4·v2,·0x1	2385	····const/4·v3,·0x1

		2386	····.line·933
2386	····invoke-static·{v1,·v2},·Lorg/eclipse/paho/client/mqttv3/MqttTopic;->validate(Ljava/lang/String;Z)V	2387	····invoke-static·{v2,·v3},·Lorg/eclipse/paho/client/mqttv3/MqttTopic;->validate(Ljava/lang/String;Z)V

2387	····.line·934	2388	····.line·934
2388	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/MqttAsyncClient;->comms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	2389	····iget-object·v3,·p0,·Lorg/eclipse/paho/client/mqttv3/MqttAsyncClient;->comms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

2389	····aget-object·v2,·p1,·v0

2390	····invoke-virtual·{v1,·v2},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->removeMessageListener(Ljava/lang/String;)V	2390	····invoke-virtual·{v3,·v2},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->removeMessageListener(Ljava/lang/String;)V

2391	····add-int/lit8·v0,·v0,·0x1	2391	····add-int/lit8·v1,·v1,·0x1

2392	····goto·:goto_0	2392	····goto·:goto_0

2393	····.line·927	2393	····.line·927
2394	····:cond_1	2394	····:cond_1
2395	····new-instance·p1,·Ljava/lang/IllegalArgumentException;	2395	····new-instance·p1,·Ljava/lang/IllegalArgumentException;

Offset 2464, 25 lines modified		Offset 2463, 25 lines modified

2464	····return-object·p1	2463	····return-object·p1

2465	····:catch_0	2464	····:catch_0
2466	····move-exception·p2	2465	····move-exception·p2

2467	····.line·1031	2466	····.line·1031
2468	····:goto_1
2469	····array-length·p3,·p1	2467	····array-length·p3,·p1

		2468	····:goto_1
2470	····if-ge·v0,·p3,·:cond_1	2469	····if-ge·v0,·p3,·:cond_1

2471	····.line·1032
2472	····iget-object·p3,·p0,·Lorg/eclipse/paho/client/mqttv3/MqttAsyncClient;->comms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

2473	····aget-object·p4,·p1,·v0	2470	····aget-object·p4,·p1,·v0

		2471	····.line·1032
		2472	····iget-object·p5,·p0,·Lorg/eclipse/paho/client/mqttv3/MqttAsyncClient;->comms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

2474	····invoke-virtual·{p3,·p4},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->removeMessageListener(Ljava/lang/String;)V	2473	····invoke-virtual·{p5,·p4},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->removeMessageListener(Ljava/lang/String;)V

Max diff block lines reached; 2120/6176 bytes (34.33%) of diff not shown.


Offset 10, 15 lines modified		Offset 10, 15 lines modified
10	#·instance·fields	10	#·instance·fields
11	.field·private·closedResponse:Lorg/eclipse/paho/client/mqttv3/MqttException;	11	.field·private·closedResponse:Lorg/eclipse/paho/client/mqttv3/MqttException;

12	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	12	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

13	.field·private·logContext:Ljava/lang/String;	13	.field·private·logContext:Ljava/lang/String;

14	.field·private·tokens:Ljava/util/Hashtable;	14	.field·private·final·tokens:Ljava/util/Hashtable;


15	#·direct·methods	15	#·direct·methods
16	.method·static·constructor·<clinit>()V	16	.method·static·constructor·<clinit>()V
17	····.locals·0	17	····.locals·0

18	····return-void	18	····return-void


Offset 25, 150 lines modified		Offset 25, 150 lines modified
25	.field·private·static·LOG:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	25	.field·private·static·LOG:Lorg/eclipse/paho/client/mqttv3/logging/Logger;


26	#·direct·methods	26	#·direct·methods
27	.method·static·constructor·<clinit>()V	27	.method·static·constructor·<clinit>()V
28	····.locals·2	28	····.locals·2

29	····.line·35	29	····.line·37
30	····const-class·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;	30	····const-class·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;

31	····invoke-virtual·{v0},·Ljava/lang/Class;->getSimpleName()Ljava/lang/String;	31	····invoke-virtual·{v0},·Ljava/lang/Class;->getSimpleName()Ljava/lang/String;

32	····move-result-object·v0	32	····move-result-object·v0

33	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"	33	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"

34	····.line·34	34	····.line·36
35	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;	35	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;

36	····move-result-object·v0	36	····move-result-object·v0

37	····sput-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->LOG:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	37	····sput-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->LOG:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

38	····.line·37	38	····.line·39
39	····const-class·v0,·Lorg/eclipse/paho/client/mqttv3/spi/NetworkModuleFactory;	39	····const-class·v0,·Lorg/eclipse/paho/client/mqttv3/spi/NetworkModuleFactory;

40	····const-class·v1,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;	40	····const-class·v1,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;

41	····invoke-virtual·{v1},·Ljava/lang/Class;->getClassLoader()Ljava/lang/ClassLoader;	41	····invoke-virtual·{v1},·Ljava/lang/Class;->getClassLoader()Ljava/lang/ClassLoader;

42	····move-result-object·v1	42	····move-result-object·v1

43	····.line·36	43	····.line·38
44	····invoke-static·{v0,·v1},·Ljava/util/ServiceLoader;->load(Ljava/lang/Class;Ljava/lang/ClassLoader;)Ljava/util/ServiceLoader;	44	····invoke-static·{v0,·v1},·Ljava/util/ServiceLoader;->load(Ljava/lang/Class;Ljava/lang/ClassLoader;)Ljava/util/ServiceLoader;

45	····move-result-object·v0	45	····move-result-object·v0

46	····sput-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->FACTORY_SERVICE_LOADER:Ljava/util/ServiceLoader;	46	····sput-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->FACTORY_SERVICE_LOADER:Ljava/util/ServiceLoader;

47	····const-string·v0,·"((.+)@)?([^:]*)(:(\\d+))?"	47	····const-string·v0,·"((.+)@)?([^:]*)(:(\\d+))?"

48	····.line·40	48	····.line·42
49	····invoke-static·{v0},·Ljava/util/regex/Pattern;->compile(Ljava/lang/String;)Ljava/util/regex/Pattern;	49	····invoke-static·{v0},·Ljava/util/regex/Pattern;->compile(Ljava/lang/String;)Ljava/util/regex/Pattern;

50	····move-result-object·v0	50	····move-result-object·v0

51	····sput-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->AUTHORITY_PATTERN:Ljava/util/regex/Pattern;	51	····sput-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->AUTHORITY_PATTERN:Ljava/util/regex/Pattern;

52	····return-void	52	····return-void
53	.end·method	53	.end·method

54	.method·private·constructor·<init>()V	54	.method·private·constructor·<init>()V
55	····.locals·0	55	····.locals·0

56	····.line·45	56	····.line·47
57	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V	57	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V

58	····return-void	58	····return-void
59	.end·method	59	.end·method

60	.method·public·static·applyRFC3986AuthorityPatch(Ljava/net/URI;)V	60	.method·public·static·applyRFC3986AuthorityPatch(Ljava/net/URI;)V
61	····.locals·3	61	····.locals·3

62	····if-eqz·p0,·:cond_2	62	····if-eqz·p0,·:cond_2

63	····.line·123	63	····.line·125
64	····invoke-virtual·{p0},·Ljava/net/URI;->getHost()Ljava/lang/String;	64	····invoke-virtual·{p0},·Ljava/net/URI;->getHost()Ljava/lang/String;

65	····move-result-object·v0	65	····move-result-object·v0

66	····if-nez·v0,·:cond_2	66	····if-nez·v0,·:cond_2

67	····.line·124	67	····.line·126
68	····invoke-virtual·{p0},·Ljava/net/URI;->getAuthority()Ljava/lang/String;	68	····invoke-virtual·{p0},·Ljava/net/URI;->getAuthority()Ljava/lang/String;

69	····move-result-object·v0	69	····move-result-object·v0

70	····if-eqz·v0,·:cond_2	70	····if-eqz·v0,·:cond_2

71	····.line·125	71	····.line·127
72	····invoke-virtual·{p0},·Ljava/net/URI;->getAuthority()Ljava/lang/String;	72	····invoke-virtual·{p0},·Ljava/net/URI;->getAuthority()Ljava/lang/String;

73	····move-result-object·v0	73	····move-result-object·v0

74	····invoke-virtual·{v0},·Ljava/lang/String;->isEmpty()Z	74	····invoke-virtual·{v0},·Ljava/lang/String;->isEmpty()Z

75	····move-result·v0	75	····move-result·v0

76	····if-eqz·v0,·:cond_0	76	····if-eqz·v0,·:cond_0

77	····goto·:goto_1	77	····goto·:goto_1

78	····.line·129	78	····.line·131
79	····:cond_0	79	····:cond_0
80	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->AUTHORITY_PATTERN:Ljava/util/regex/Pattern;	80	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->AUTHORITY_PATTERN:Ljava/util/regex/Pattern;

81	····invoke-virtual·{p0},·Ljava/net/URI;->getAuthority()Ljava/lang/String;	81	····invoke-virtual·{p0},·Ljava/net/URI;->getAuthority()Ljava/lang/String;

82	····move-result-object·v1	82	····move-result-object·v1

83	····invoke-virtual·{v0,·v1},·Ljava/util/regex/Pattern;->matcher(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;	83	····invoke-virtual·{v0,·v1},·Ljava/util/regex/Pattern;->matcher(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;

84	····move-result-object·v0	84	····move-result-object·v0

85	····.line·130	85	····.line·132
86	····invoke-virtual·{v0},·Ljava/util/regex/Matcher;->find()Z	86	····invoke-virtual·{v0},·Ljava/util/regex/Matcher;->find()Z

87	····move-result·v1	87	····move-result·v1

88	····if-eqz·v1,·:cond_2	88	····if-eqz·v1,·:cond_2

89	····const/4·v1,·0x2	89	····const/4·v1,·0x2

90	····.line·131	90	····.line·133
91	····invoke-virtual·{v0,·v1},·Ljava/util/regex/Matcher;->group(I)Ljava/lang/String;	91	····invoke-virtual·{v0,·v1},·Ljava/util/regex/Matcher;->group(I)Ljava/lang/String;

92	····move-result-object·v1	92	····move-result-object·v1

93	····const-string·v2,·"userInfo"	93	····const-string·v2,·"userInfo"

94	····invoke-static·{p0,·v2,·v1},·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->setURIField(Ljava/net/URI;Ljava/lang/String;Ljava/lang/Object;)V	94	····invoke-static·{p0,·v2,·v1},·Lorg/eclipse/paho/client/mqttv3/internal/NetworkModuleService;->setURIField(Ljava/net/URI;Ljava/lang/String;Ljava/lang/Object;)V

95	····const/4·v1,·0x3	95	····const/4·v1,·0x3

96	····.line·132	96	····.line·134
97	····invoke-virtual·{v0,·v1},·Ljava/util/regex/Matcher;->group(I)Ljava/lang/String;	97	····invoke-virtual·{v0,·v1},·Ljava/util/regex/Matcher;->group(I)Ljava/lang/String;

Max diff block lines reached; 10396/14230 bytes (73.06%) of diff not shown.


Offset 5, 15 lines modified		Offset 5, 15 lines modified
5	#·interfaces	5	#·interfaces
6	.implements·Ljava/lang/Runnable;	6	.implements·Ljava/lang/Runnable;


7	#·instance·fields	7	#·instance·fields
8	.field·private·final·CLASS_NAME:Ljava/lang/String;	8	.field·private·final·CLASS_NAME:Ljava/lang/String;

9	.field·private·bufLock:Ljava/lang/Object;	9	.field·private·final·bufLock:Ljava/lang/Object;

10	.field·private·buffer:Ljava/util/ArrayList;	10	.field·private·buffer:Ljava/util/ArrayList;
11	····.annotation·system·Ldalvik/annotation/Signature;	11	····.annotation·system·Ldalvik/annotation/Signature;
12	········value·=·{	12	········value·=·{
13	············"Ljava/util/ArrayList<",	13	············"Ljava/util/ArrayList<",
14	············"Lorg/eclipse/paho/client/mqttv3/BufferedMessage;",	14	············"Lorg/eclipse/paho/client/mqttv3/BufferedMessage;",
15	············">;"	15	············">;"


Offset 26, 19 lines modified		Offset 26, 19 lines modified

26	.field·private·notified:Z	26	.field·private·notified:Z

27	.field·private·pendingComplete:Z	27	.field·private·pendingComplete:Z

28	.field·private·response:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;	28	.field·private·response:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;

29	.field·private·responseLock:Ljava/lang/Object;	29	.field·private·final·responseLock:Ljava/lang/Object;

30	.field·private·sent:Z	30	.field·private·sent:Z

31	.field·private·sentLock:Ljava/lang/Object;	31	.field·private·final·sentLock:Ljava/lang/Object;

32	.field·private·topics:[Ljava/lang/String;	32	.field·private·topics:[Ljava/lang/String;

33	.field·private·userContext:Ljava/lang/Object;	33	.field·private·userContext:Ljava/lang/Object;


34	#·direct·methods	34	#·direct·methods
Offset 1190, 17 lines modified		Offset 1190, 17 lines modified

1190	····invoke-virtual·{p0},·Lorg/eclipse/paho/client/mqttv3/internal/Token;->getKey()Ljava/lang/String;	1190	····invoke-virtual·{p0},·Lorg/eclipse/paho/client/mqttv3/internal/Token;->getKey()Ljava/lang/String;

1191	····move-result-object·v11	1191	····move-result-object·v11

1192	····aput-object·v11,·v10,·v7	1192	····aput-object·v11,·v10,·v7

1193	····n~~ew-in~~stance·~~v11~~,·Ljava/lang/Long;	1193	····invoke-static·{p1,·p2},·Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;

1194	····invoke-dire~~ct·{v11,·p1,·p2},·Ljav~~a/l~~ang/Long~~;-~~><ini~~t>~~(J)V~~	1194	····move-result-object·v11

1195	····aput-object·v11,·v10,·v8	1195	····aput-object·v11,·v10,·v8

1196	····invoke-interface·{v1,·v4,·v5,·v6,·v10},·Lorg/eclipse/paho/client/mqttv3/logging/Logger;->fine(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/Object;)V	1196	····invoke-interface·{v1,·v4,·v5,·v6,·v10},·Lorg/eclipse/paho/client/mqttv3/logging/Logger;->fine(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/Object;)V

1197	····cmp-long·v1,·p1,·v2	1197	····cmp-long·v1,·p1,·v2


Offset 62, 21 lines modified		Offset 62, 21 lines modified

62	.field·private·persistence:Lorg/eclipse/paho/client/mqttv3/MqttClientPersistence;	62	.field·private·persistence:Lorg/eclipse/paho/client/mqttv3/MqttClientPersistence;

63	.field·private·pingCommand:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;	63	.field·private·pingCommand:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;

64	.field·private·pingOutstanding:I	64	.field·private·pingOutstanding:I

65	.field·private·pingOutstandingLock:Ljava/lang/Object;	65	.field·private·final·pingOutstandingLock:Ljava/lang/Object;

66	.field·private·pingSender:Lorg/eclipse/paho/client/mqttv3/MqttPingSender;	66	.field·private·pingSender:Lorg/eclipse/paho/client/mqttv3/MqttPingSender;

67	.field·private·queueLock:Ljava/lang/Object;	67	.field·private·final·queueLock:Ljava/lang/Object;

68	.field·private·quiesceLock:Ljava/lang/Object;	68	.field·private·final·quiesceLock:Ljava/lang/Object;

69	.field·private·quiescing:Z	69	.field·private·quiescing:Z

70	.field·private·tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;	70	.field·private·tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;


71	#·direct·methods	71	#·direct·methods


Offset 21, 15 lines modified		Offset 21, 15 lines modified
21	#·instance·fields	21	#·instance·fields
22	.field·private·clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	22	.field·private·clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

23	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	23	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

24	.field·private·current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;	24	.field·private·current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;

25	.field·private·lifecycle:Ljava/lang/Object;	25	.field·private·final·lifecycle:Ljava/lang/Object;

26	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	26	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

27	.field·private·out:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;	27	.field·private·out:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;

28	.field·private·sendThread:Ljava/lang/Thread;	28	.field·private·sendThread:Ljava/lang/Thread;

Offset 55, 76 lines modified		Offset 55, 76 lines modified

55	····return-void	55	····return-void
56	.end·method	56	.end·method

57	.method·public·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;Ljava/io/OutputStream;)V	57	.method·public·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;Ljava/io/OutputStream;)V
58	····.locals·2	58	····.locals·2

59	····.line·52	59	····.line·53
60	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V	60	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V

61	····.line·35	61	····.line·35
62	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->CLASS_NAME:Ljava/lang/String;	62	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->CLASS_NAME:Ljava/lang/String;

63	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"	63	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"

64	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;	64	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;

65	····move-result-object·v0	65	····move-result-object·v0

66	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	66	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

67	····.line·39	67	····.line·40
68	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;	68	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;

69	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;	69	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;

70	····.line·40	70	····.line·41
71	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;	71	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;

72	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;	72	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsSender$State;

73	····.line·41	73	····.line·42
74	····new-instance·v0,·Ljava/lang/Object;	74	····new-instance·v0,·Ljava/lang/Object;

75	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V	75	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V

76	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->lifecycle:Ljava/lang/Object;	76	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->lifecycle:Ljava/lang/Object;

77	····const/4·v0,·0x0	77	····const/4·v0,·0x0

78	····.line·42	78	····.line·43
79	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->sendThread:Ljava/lang/Thread;	79	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->sendThread:Ljava/lang/Thread;

80	····.line·46	80	····.line·47
81	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	81	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

82	····.line·48	82	····.line·49
83	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	83	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

84	····.line·49	84	····.line·50
85	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;	85	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;

86	····.line·53	86	····.line·54
87	····new-instance·v0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;	87	····new-instance·v0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;

88	····invoke-direct·{v0,·p2,·p4},·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;-><init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Ljava/io/OutputStream;)V	88	····invoke-direct·{v0,·p2,·p4},·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;-><init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Ljava/io/OutputStream;)V

89	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->out:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;	89	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->out:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream;

90	····.line·54	90	····.line·55
91	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	91	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

92	····.line·55	92	····.line·56
93	····iput-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	93	····iput-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

94	····.line·56	94	····.line·57
95	····iput-object·p3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;	95	····iput-object·p3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;

96	····.line·57	96	····.line·58
97	····iget-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	97	····iget-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

98	····invoke-virtual·{p1},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->getClient()Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;	98	····invoke-virtual·{p1},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->getClient()Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;

99	····move-result-object·p1	99	····move-result-object·p1

100	····invoke-interface·{p1},·Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;->getClientId()Ljava/lang/String;	100	····invoke-interface·{p1},·Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;->getClientId()Ljava/lang/String;
Offset 135, 98 lines modified		Offset 135, 98 lines modified

135	····return-void	135	····return-void
136	.end·method	136	.end·method

137	.method·private·handleRunException(Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;Ljava/lang/Exception;)V	137	.method·private·handleRunException(Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;Ljava/lang/Exception;)V
138	····.locals·6	138	····.locals·6

139	····.line·190	139	····.line·191
140	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	140	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

141	····sget-object·v1,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->CLASS_NAME:Ljava/lang/String;	141	····sget-object·v1,·Lorg/eclipse/paho/client/mqttv3/internal/CommsSender;->CLASS_NAME:Ljava/lang/String;

142	····const-string·v2,·"handleRunException"	142	····const-string·v2,·"handleRunException"

143	····const-string·v3,·"804"	143	····const-string·v3,·"804"

144	····const/4·v4,·0x0	144	····const/4·v4,·0x0

145	····move-object·v5,·p2	145	····move-object·v5,·p2

146	····invoke-interface/range·{v0·..·v5},·Lorg/eclipse/paho/client/mqttv3/logging/Logger;->fine(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/Object;Ljava/lang/Throwable;)V	146	····invoke-interface/range·{v0·..·v5},·Lorg/eclipse/paho/client/mqttv3/logging/Logger;->fine(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/Object;Ljava/lang/Throwable;)V

147	····.line·192	147	····.line·193
148	····instance-of·p1,·p2,·Lorg/eclipse/paho/client/mqttv3/MqttException;	148	····instance-of·p1,·p2,·Lorg/eclipse/paho/client/mqttv3/MqttException;

149	····if-nez·p1,·:cond_0	149	····if-nez·p1,·:cond_0

150	····.line·193	150	····.line·194
151	····new-instance·p1,·Lorg/eclipse/paho/client/mqttv3/MqttException;	151	····new-instance·p1,·Lorg/eclipse/paho/client/mqttv3/MqttException;

152	····const/16·v0,·0x7d6d	152	····const/16·v0,·0x7d6d

153	····invoke-direct·{p1,·v0,·p2},·Lorg/eclipse/paho/client/mqttv3/MqttException;-><init>(ILjava/lang/Throwable;)V	153	····invoke-direct·{p1,·v0,·p2},·Lorg/eclipse/paho/client/mqttv3/MqttException;-><init>(ILjava/lang/Throwable;)V

Max diff block lines reached; 22085/27816 bytes (79.40%) of diff not shown.


Offset 23, 15 lines modified		Offset 23, 15 lines modified

23	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	23	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

24	.field·private·current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	24	.field·private·current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

25	.field·private·in:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;	25	.field·private·in:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;

26	.field·private·lifecycle:Ljava/lang/Object;	26	.field·private·final·lifecycle:Ljava/lang/Object;

27	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	27	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

28	.field·private·recThread:Ljava/lang/Thread;	28	.field·private·recThread:Ljava/lang/Thread;

29	.field·private·receiverFuture:Ljava/util/concurrent/Future;	29	.field·private·receiverFuture:Ljava/util/concurrent/Future;
30	····.annotation·system·Ldalvik/annotation/Signature;	30	····.annotation·system·Ldalvik/annotation/Signature;
Offset 55, 76 lines modified		Offset 55, 76 lines modified

55	····return-void	55	····return-void
56	.end·method	56	.end·method

57	.method·public·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;Ljava/io/InputStream;)V	57	.method·public·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;Ljava/io/InputStream;)V
58	····.locals·2	58	····.locals·2

59	····.line·54	59	····.line·55
60	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V	60	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V

61	····.line·39	61	····.line·39
62	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->CLASS_NAME:Ljava/lang/String;	62	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->CLASS_NAME:Ljava/lang/String;

63	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"	63	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"

64	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;	64	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;

65	····move-result-object·v0	65	····move-result-object·v0

66	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	66	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

67	····.line·42	67	····.line·43
68	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	68	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

69	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	69	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

70	····.line·43	70	····.line·44
71	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	71	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

72	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	72	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

73	····.line·44	73	····.line·45
74	····new-instance·v0,·Ljava/lang/Object;	74	····new-instance·v0,·Ljava/lang/Object;

75	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V	75	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V

76	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->lifecycle:Ljava/lang/Object;	76	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->lifecycle:Ljava/lang/Object;

77	····const/4·v0,·0x0	77	····const/4·v0,·0x0

78	····.line·48	78	····.line·49
79	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	79	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

80	····.line·49	80	····.line·50
81	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	81	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

82	····.line·51	82	····.line·52
83	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;	83	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;

84	····.line·52	84	····.line·53
85	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->recThread:Ljava/lang/Thread;	85	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->recThread:Ljava/lang/Thread;

86	····.line·55	86	····.line·56
87	····new-instance·v0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;	87	····new-instance·v0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;

88	····invoke-direct·{v0,·p2,·p4},·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;-><init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Ljava/io/InputStream;)V	88	····invoke-direct·{v0,·p2,·p4},·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;-><init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientState;Ljava/io/InputStream;)V

89	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->in:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;	89	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->in:Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream;

90	····.line·56	90	····.line·57
91	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	91	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

92	····.line·57	92	····.line·58
93	····iput-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	93	····iput-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

94	····.line·58	94	····.line·59
95	····iput-object·p3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;	95	····iput-object·p3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->tokenStore:Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;

96	····.line·59	96	····.line·60
97	····iget-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	97	····iget-object·p2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

98	····invoke-virtual·{p1},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->getClient()Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;	98	····invoke-virtual·{p1},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->getClient()Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;

99	····move-result-object·p1	99	····move-result-object·p1

100	····invoke-interface·{p1},·Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;->getClientId()Ljava/lang/String;	100	····invoke-interface·{p1},·Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;->getClientId()Ljava/lang/String;
Offset 137, 35 lines modified		Offset 137, 35 lines modified
137	.end·method	137	.end·method


138	#·virtual·methods	138	#·virtual·methods
139	.method·public·isReceiving()Z	139	.method·public·isReceiving()Z
140	····.locals·3	140	····.locals·3

141	····.line·228	141	····.line·229
142	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->lifecycle:Ljava/lang/Object;	142	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->lifecycle:Ljava/lang/Object;

143	····monitor-enter·v0	143	····monitor-enter·v0

144	····.line·229	144	····.line·230
145	····:try_start_0	145	····:try_start_0
146	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	146	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

147	····sget-object·v2,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;->RECEIVING:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;	147	····sget-object·v2,·Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;->RECEIVING:Lorg/eclipse/paho/client/mqttv3/internal/CommsReceiver$State;

148	····if-ne·v1,·v2,·:cond_0	148	····if-ne·v1,·v2,·:cond_0

149	····const/4·v1,·0x1	149	····const/4·v1,·0x1

150	····goto·:goto_0	150	····goto·:goto_0

151	····:cond_0	151	····:cond_0
152	····const/4·v1,·0x0	152	····const/4·v1,·0x0

153	····.line·228	153	····.line·229
154	····:goto_0	154	····:goto_0
155	····monitor-exit·v0	155	····monitor-exit·v0

156	····return·v1	156	····return·v1

157	····:catchall_0	157	····:catchall_0
Max diff block lines reached; 29819/35291 bytes (84.49%) of diff not shown.


Offset 43, 142 lines modified		Offset 43, 142 lines modified
43	····.end·annotation	43	····.end·annotation
44	.end·field	44	.end·field

45	.field·private·clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	45	.field·private·clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

46	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	46	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

47	.field·private·completeQueue:Ljava/util/Vector;	47	.field·private·final·completeQueue:Ljava/util/Vector;
48	····.annotation·system·Ldalvik/annotation/Signature;	48	····.annotation·system·Ldalvik/annotation/Signature;
49	········value·=·{	49	········value·=·{
50	············"Ljava/util/Vector<",	50	············"Ljava/util/Vector<",
51	············"Lorg/eclipse/paho/client/mqttv3/MqttToken;",	51	············"Lorg/eclipse/paho/client/mqttv3/MqttToken;",
52	············">;"	52	············">;"
53	········}	53	········}
54	····.end·annotation	54	····.end·annotation
55	.end·field	55	.end·field

56	.field·private·current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;	56	.field·private·current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;

57	.field·private·lifecycle:Ljava/lang/Object;	57	.field·private·final·lifecycle:Ljava/lang/Object;

58	.field·private·final·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	58	.field·private·final·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

59	.field·private·manualAcks:Z	59	.field·private·manualAcks:Z

60	.field·private·messageQueue:Ljava/util/Vector;	60	.field·private·final·messageQueue:Ljava/util/Vector;
61	····.annotation·system·Ldalvik/annotation/Signature;	61	····.annotation·system·Ldalvik/annotation/Signature;
62	········value·=·{	62	········value·=·{
63	············"Ljava/util/Vector<",	63	············"Ljava/util/Vector<",
64	············"Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;",	64	············"Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;",
65	············">;"	65	············">;"
66	········}	66	········}
67	····.end·annotation	67	····.end·annotation
68	.end·field	68	.end·field

69	.field·private·mqttCallback:Lorg/eclipse/paho/client/mqttv3/MqttCallback;	69	.field·private·mqttCallback:Lorg/eclipse/paho/client/mqttv3/MqttCallback;

70	.field·private·reconnectInternalCallback:Lorg/eclipse/paho/client/mqttv3/MqttCallbackExtended;	70	.field·private·reconnectInternalCallback:Lorg/eclipse/paho/client/mqttv3/MqttCallbackExtended;

71	.field·private·spaceAvailable:Ljava/lang/Object;	71	.field·private·final·spaceAvailable:Ljava/lang/Object;

72	.field·private·target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;	72	.field·private·target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;

73	.field·private·threadName:Ljava/lang/String;	73	.field·private·threadName:Ljava/lang/String;

74	.field·private·workAvailable:Ljava/lang/Object;	74	.field·private·final·workAvailable:Ljava/lang/Object;


75	#·direct·methods	75	#·direct·methods
76	.method·static·constructor·<clinit>()V	76	.method·static·constructor·<clinit>()V
77	····.locals·0	77	····.locals·0

78	····return-void	78	····return-void
79	.end·method	79	.end·method

80	.method·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;)V	80	.method·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;)V
81	····.locals·2	81	····.locals·2

82	····.line·73	82	····.line·74
83	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V	83	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V

84	····.line·50	84	····.line·50
85	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->CLASS_NAME:Ljava/lang/String;	85	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->CLASS_NAME:Ljava/lang/String;

86	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"	86	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"

87	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;	87	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;

88	····move-result-object·v0	88	····move-result-object·v0

89	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	89	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

90	····.line·61	90	····.line·62
91	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;	91	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;

92	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;	92	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->current_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;

93	····.line·62	93	····.line·63
94	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;	94	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;->STOPPED:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;

95	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;	95	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->target_state:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback$State;

96	····.line·63	96	····.line·64
97	····new-instance·v0,·Ljava/lang/Object;	97	····new-instance·v0,·Ljava/lang/Object;

98	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V	98	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V

99	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->lifecycle:Ljava/lang/Object;	99	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->lifecycle:Ljava/lang/Object;

100	····.line·68	100	····.line·69
101	····new-instance·v0,·Ljava/lang/Object;	101	····new-instance·v0,·Ljava/lang/Object;

102	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V	102	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V

103	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->workAvailable:Ljava/lang/Object;	103	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->workAvailable:Ljava/lang/Object;

104	····.line·69	104	····.line·70
105	····new-instance·v0,·Ljava/lang/Object;	105	····new-instance·v0,·Ljava/lang/Object;

106	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V	106	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V

107	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->spaceAvailable:Ljava/lang/Object;	107	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->spaceAvailable:Ljava/lang/Object;

108	····const/4·v0,·0x0	108	····const/4·v0,·0x0

109	····.line·71	109	····.line·72
110	····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->manualAcks:Z	110	····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->manualAcks:Z

111	····.line·74	111	····.line·75
112	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	112	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->clientComms:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

113	····.line·75	113	····.line·76
114	····new-instance·v0,·Ljava/util/Vector;	114	····new-instance·v0,·Ljava/util/Vector;

115	····const/16·v1,·0xa	115	····const/16·v1,·0xa

116	····invoke-direct·{v0,·v1},·Ljava/util/Vector;-><init>(I)V	116	····invoke-direct·{v0,·v1},·Ljava/util/Vector;-><init>(I)V

117	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->messageQueue:Ljava/util/Vector;	117	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->messageQueue:Ljava/util/Vector;

118	····.line·76	118	····.line·77
119	····new-instance·v0,·Ljava/util/Vector;	119	····new-instance·v0,·Ljava/util/Vector;

120	····invoke-direct·{v0,·v1},·Ljava/util/Vector;-><init>(I)V	120	····invoke-direct·{v0,·v1},·Ljava/util/Vector;-><init>(I)V

121	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->completeQueue:Ljava/util/Vector;	121	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->completeQueue:Ljava/util/Vector;

Max diff block lines reached; 57913/62839 bytes (92.16%) of diff not shown.


Offset 121, 21 lines modified		Offset 121, 21 lines modified

121	····move-result-object·v1	121	····move-result-object·v1

122	····invoke-virtual·{v1},·Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;->getOutstandingDelTokens()[Lorg/eclipse/paho/client/mqttv3/MqttDeliveryToken;	122	····invoke-virtual·{v1},·Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;->getOutstandingDelTokens()[Lorg/eclipse/paho/client/mqttv3/MqttDeliveryToken;

123	····move-result-object·v1	123	····move-result-object·v1

124	····const/4·v2,·0x0

125	····.line·711	124	····.line·711
126	····:goto_0
127	····array-length·v3,·v1	125	····array-length·v2,·v1

		126	····const/4·v3,·0x0

		127	····:goto_0
128	····if-lt·v2,·v3,·:cond_0	128	····if-lt·v3,·v2,·:cond_0

129	····.line·716	129	····.line·716
130	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG;->this$0:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;	130	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG;->this$0:Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;

131	····invoke-static·{v1},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->access$3(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;)Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;	131	····invoke-static·{v1},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->access$3(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;)Lorg/eclipse/paho/client/mqttv3/internal/CommsTokenStore;

132	····move-result-object·v1	132	····move-result-object·v1
Offset 336, 26 lines modified		Offset 336, 27 lines modified

336	····iget-object·v3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG;->conToken:Lorg/eclipse/paho/client/mqttv3/MqttToken;	336	····iget-object·v3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG;->conToken:Lorg/eclipse/paho/client/mqttv3/MqttToken;

337	····invoke-virtual·{v1,·v2,·v3},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->internalSend(Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;Lorg/eclipse/paho/client/mqttv3/MqttToken;)V	337	····invoke-virtual·{v1,·v2,·v3},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->internalSend(Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;Lorg/eclipse/paho/client/mqttv3/MqttToken;)V

338	····goto·:goto_1	338	····goto·:goto_1

339	····.line·712	339	····.line·711
340	····:cond_0	340	····:cond_0
341	····aget-object·v3,·v1,·v2	341	····aget-object·v4,·v1,·v3

		342	····.line·712
342	····iget-object·v3,·v3,·Lorg/eclipse/paho/client/mqttv3/MqttDeliveryToken;->internalTok:Lorg/eclipse/paho/client/mqttv3/internal/Token;	343	····iget-object·v4,·v4,·Lorg/eclipse/paho/client/mqttv3/MqttDeliveryToken;->internalTok:Lorg/eclipse/paho/client/mqttv3/internal/Token;

343	····invoke-virtual·{v3,·v0},·Lorg/eclipse/paho/client/mqttv3/internal/Token;->setException(Lorg/eclipse/paho/client/mqttv3/MqttException;)V	344	····invoke-virtual·{v4,·v0},·Lorg/eclipse/paho/client/mqttv3/internal/Token;->setException(Lorg/eclipse/paho/client/mqttv3/MqttException;)V
344	····:try_end_0	345	····:try_end_0
345	····.catch·Lorg/eclipse/paho/client/mqttv3/MqttException;·{:try_start_0·..·:try_end_0}·:catch_1	346	····.catch·Lorg/eclipse/paho/client/mqttv3/MqttException;·{:try_start_0·..·:try_end_0}·:catch_1
346	····.catch·Ljava/lang/Exception;·{:try_start_0·..·:try_end_0}·:catch_0	347	····.catch·Ljava/lang/Exception;·{:try_start_0·..·:try_end_0}·:catch_0

347	····add-int/lit8·v2,·v2,·0x1	348	····add-int/lit8·v3,·v3,·0x1

348	····goto/16·:goto_0	349	····goto/16·:goto_0

349	····:catch_0	350	····:catch_0
350	····move-exception·v0	351	····move-exception·v0

351	····.line·735	352	····.line·735


Offset 36, 15 lines modified		Offset 36, 15 lines modified

36	.field·private·client:Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;	36	.field·private·client:Lorg/eclipse/paho/client/mqttv3/IMqttAsyncClient;

37	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;	37	.field·private·clientState:Lorg/eclipse/paho/client/mqttv3/internal/ClientState;

38	.field·private·closePending:Z	38	.field·private·closePending:Z

39	.field·private·conLock:Ljava/lang/Object;	39	.field·private·final·conLock:Ljava/lang/Object;

40	.field·private·conOptions:Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;	40	.field·private·conOptions:Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;

41	.field·private·conState:B	41	.field·private·conState:B

42	.field·private·disconnectedMessageBuffer:Lorg/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer;	42	.field·private·disconnectedMessageBuffer:Lorg/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer;

Offset 1600, 19 lines modified		Offset 1600, 19 lines modified
1600	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->callback:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;	1600	····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->callback:Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;

1601	····const-string·v2,·"callback"	1601	····const-string·v2,·"callback"

1602	····invoke-virtual·{v0,·v2,·v1},·Ljava/util/Properties;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;	1602	····invoke-virtual·{v0,·v2,·v1},·Ljava/util/Properties;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

1603	····.line·670	1603	····.line·670
1604	····new-~~inst~~ance·v1,·Ljava/lang/~~Bool~~ean;	1604	····iget-boolean·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->stoppingComms:Z

1605	····ig~~et-boole~~a~~n·v2,·p0~~,·L~~org/eclipse/~~paho/client/mq~~ttv3/i~~n~~tern~~a~~l/C~~lien~~tComms;->stoppingC~~o~~mms:Z~~	1605	····invoke-static·{v1},·Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;

1606	····invoke-dire~~ct·{v1,·v2},·Ljav~~a/l~~ang~~/Boole~~an;-><in~~it>(~~Z)V~~	1606	····move-result-object·v1

1607	····const-string·v2,·"stoppingComms"	1607	····const-string·v2,·"stoppingComms"

1608	····invoke-virtual·{v0,·v2,·v1},·Ljava/util/Properties;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;	1608	····invoke-virtual·{v0,·v2,·v1},·Ljava/util/Properties;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

1609	····return-object·v0	1609	····return-object·v0
1610	.end·method	1610	.end·method


Offset 464, 22 lines modified		Offset 464, 16 lines modified

464	····const/16·v4,·0x50	464	····const/16·v4,·0x50

465	····const-string·v5,·"Host:·"	465	····const-string·v5,·"Host:·"

466	····if-eq·v1,·v4,·:cond_1	466	····if-eq·v1,·v4,·:cond_1

467	····:try_start_1
468	····iget·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake;->port:I

469	····const/16·v4,·0x1bb

470	····if-eq·v1,·v4,·:cond_1

471	····.line·103	467	····.line·103
		468	····:try_start_1
472	····new-instance·v1,·Ljava/lang/StringBuilder;	469	····new-instance·v1,·Ljava/lang/StringBuilder;

473	····invoke-direct·{v1,·v5},·Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V	470	····invoke-direct·{v1,·v5},·Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V

474	····iget-object·v4,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake;->host:Ljava/lang/String;	471	····iget-object·v4,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake;->host:Ljava/lang/String;

475	····invoke-virtual·{v1,·v4},·Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;	472	····invoke-virtual·{v1,·v4},·Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;


Offset 9, 15 lines modified		Offset 9, 15 lines modified
9	#·static·fields	9	#·static·fields
10	.field·private·static·final·CLASS_NAME:Ljava/lang/String;·=·"org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketReceiver"	10	.field·private·static·final·CLASS_NAME:Ljava/lang/String;·=·"org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketReceiver"


11	#·instance·fields	11	#·instance·fields
12	.field·private·input:Ljava/io/InputStream;	12	.field·private·input:Ljava/io/InputStream;

13	.field·private·lifecycle:Ljava/lang/Object;	13	.field·private·final·lifecycle:Ljava/lang/Object;

14	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	14	.field·private·log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

15	.field·private·pipedOutputStream:Ljava/io/PipedOutputStream;	15	.field·private·pipedOutputStream:Ljava/io/PipedOutputStream;

16	.field·private·receiverThread:Ljava/lang/Thread;	16	.field·private·receiverThread:Ljava/lang/Thread;

Offset 39, 70 lines modified		Offset 39, 70 lines modified
39	····.locals·2	39	····.locals·2
40	····.annotation·system·Ldalvik/annotation/Throws;	40	····.annotation·system·Ldalvik/annotation/Throws;
41	········value·=·{	41	········value·=·{
42	············Ljava/io/IOException;	42	············Ljava/io/IOException;
43	········}	43	········}
44	····.end·annotation	44	····.end·annotation

45	····.line·39	45	····.line·40
46	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V	46	····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V

47	····.line·29	47	····.line·30
48	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->CLASS_NAME:Ljava/lang/String;	48	····sget-object·v0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->CLASS_NAME:Ljava/lang/String;

49	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"	49	····const-string·v1,·"org.eclipse.paho.client.mqttv3.internal.nls.logcat"

50	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;	50	····invoke-static·{v1,·v0},·Lorg/eclipse/paho/client/mqttv3/logging/LoggerFactory;->getLogger(Ljava/lang/String;Ljava/lang/String;)Lorg/eclipse/paho/client/mqttv3/logging/Logger;

51	····move-result-object·v0	51	····move-result-object·v0

52	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;	52	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->log:Lorg/eclipse/paho/client/mqttv3/logging/Logger;

53	····const/4·v0,·0x0	53	····const/4·v0,·0x0

54	····.line·31	54	····.line·32
55	····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z	55	····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z

56	····.line·32	56	····.line·33
57	····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->stopping:Z	57	····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->stopping:Z

58	····.line·33	58	····.line·34
59	····new-instance·v0,·Ljava/lang/Object;	59	····new-instance·v0,·Ljava/lang/Object;

60	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V	60	····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V

61	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->lifecycle:Ljava/lang/Object;	61	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->lifecycle:Ljava/lang/Object;

62	····const/4·v0,·0x0	62	····const/4·v0,·0x0

63	····.line·35	63	····.line·36
64	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->receiverThread:Ljava/lang/Thread;	64	····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->receiverThread:Ljava/lang/Thread;

65	····.line·40	65	····.line·41
66	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->input:Ljava/io/InputStream;	66	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->input:Ljava/io/InputStream;

67	····.line·41	67	····.line·42
68	····new-instance·p1,·Ljava/io/PipedOutputStream;	68	····new-instance·p1,·Ljava/io/PipedOutputStream;

69	····invoke-direct·{p1},·Ljava/io/PipedOutputStream;-><init>()V	69	····invoke-direct·{p1},·Ljava/io/PipedOutputStream;-><init>()V

70	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->pipedOutputStream:Ljava/io/PipedOutputStream;	70	····iput-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->pipedOutputStream:Ljava/io/PipedOutputStream;

71	····.line·42	71	····.line·43
72	····iget-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->pipedOutputStream:Ljava/io/PipedOutputStream;	72	····iget-object·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->pipedOutputStream:Ljava/io/PipedOutputStream;

73	····invoke-virtual·{p2,·p1},·Ljava/io/PipedInputStream;->connect(Ljava/io/PipedOutputStream;)V	73	····invoke-virtual·{p2,·p1},·Ljava/io/PipedInputStream;->connect(Ljava/io/PipedOutputStream;)V

74	····return-void	74	····return-void
75	.end·method	75	.end·method

76	.method·private·closeOutputStream()V	76	.method·private·closeOutputStream()V
77	····.locals·1	77	····.locals·1

78	····.line·127	78	····.line·129
79	····:try_start_0	79	····:try_start_0
80	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->pipedOutputStream:Ljava/io/PipedOutputStream;	80	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->pipedOutputStream:Ljava/io/PipedOutputStream;

81	····invoke-virtual·{v0},·Ljava/io/PipedOutputStream;->close()V	81	····invoke-virtual·{v0},·Ljava/io/PipedOutputStream;->close()V
82	····:try_end_0	82	····:try_end_0
83	····.catch·Ljava/io/IOException;·{:try_start_0·..·:try_end_0}·:catch_0	83	····.catch·Ljava/io/IOException;·{:try_start_0·..·:try_end_0}·:catch_0

Offset 111, 58 lines modified		Offset 111, 58 lines modified
111	.end·method	111	.end·method


112	#·virtual·methods	112	#·virtual·methods
113	.method·public·isReceiving()Z	113	.method·public·isReceiving()Z
114	····.locals·1	114	····.locals·1

115	····.line·143	115	····.line·145
116	····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->receiving:Z	116	····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->receiving:Z

117	····return·v0	117	····return·v0
118	.end·method	118	.end·method

119	.method·public·isRunning()Z	119	.method·public·isRunning()Z
120	····.locals·1	120	····.locals·1

121	····.line·134	121	····.line·136
122	····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z	122	····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z

123	····return·v0	123	····return·v0
124	.end·method	124	.end·method

125	.method·public·run()V	125	.method·public·run()V
126	····.locals·5	126	····.locals·5

127	····.line·98	127	····.line·99
128	····:goto_0	128	····:goto_0
129	····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z	129	····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z

130	····if-eqz·v0,·:cond_5	130	····if-eqz·v0,·:cond_5

131	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->input:Ljava/io/InputStream;	131	····iget-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->input:Ljava/io/InputStream;

132	····if-nez·v0,·:cond_0	132	····if-nez·v0,·:cond_0

133	····goto·:goto_4	133	····goto·:goto_4

134	····.line·101	134	····.line·102
135	····:cond_0	135	····:cond_0
136	····:try_start_0	136	····:try_start_0
Max diff block lines reached; 8663/13003 bytes (66.62%) of diff not shown.


Offset 147, 31 lines modified		Offset 147, 31 lines modified
147	····if-ne·v0,·v1,·:cond_1	147	····if-ne·v0,·v1,·:cond_1

148	····.line·86	148	····.line·86
149	····array-length·p1,·p1	149	····array-length·p1,·p1

150	····iput·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe;->count:I	150	····iput·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe;->count:I

151	····const/4·p1,·0x0

152	····.line·88	151	····.line·88
153	····:goto_0
154	····array-length·v0,·p2	152	····array-length·p1,·p2

		153	····const/4·v0,·0x0

		154	····:goto_0
155	····if-lt·p1,·v0,·:cond_0	155	····if-lt·v0,·p1,·:cond_0

156	····return-void	156	····return-void

157	····.line·89
158	····:cond_0	157	····:cond_0
159	····aget·v0,·p2,·p1	158	····aget·v1,·p2,·v0

		159	····.line·89
160	····invoke-static·{v0},·Lorg/eclipse/paho/client/mqttv3/MqttMessage;->validateQos(I)V	160	····invoke-static·{v1},·Lorg/eclipse/paho/client/mqttv3/MqttMessage;->validateQos(I)V

161	····add-int/lit8·p1,·p1,·0x1	161	····add-int/lit8·v0,·v0,·0x1

162	····goto·:goto_0	162	····goto·:goto_0

163	····.line·83	163	····.line·83
164	····:cond_1	164	····:cond_1
165	····new-instance·p1,·Ljava/lang/IllegalArgumentException;	165	····new-instance·p1,·Ljava/lang/IllegalArgumentException;