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=>
    
Offset 1, 45 lines modifiedOffset 0, 0 lines modified
1 Verifies 
2 Verified·using·v1·scheme·(JAR·signing):·true 
3 Verified·using·v2·scheme·(APK·Signature·Scheme·v2):·false 
4 Verified·using·v3·scheme·(APK·Signature·Scheme·v3):·false 
5 Verified·using·v4·scheme·(APK·Signature·Scheme·v4):·false 
6 Verified·for·SourceStamp:·false 
7 Number·of·signers:·1 
8 Signer·#1·certificate·DN:·CN=FDroid,·OU=FDroid,·O=fdroid.org,·L=ORG,·ST=ORG,·C=UK 
9 Signer·#1·certificate·SHA-256·digest:·050223b597dd6d8940d498a178efb470bcbee2c3fc28bf2ece788ad79370a00b 
10 Signer·#1·certificate·SHA-1·digest:·48b47bfed373174fc96df617c4c44c49911615db 
11 Signer·#1·certificate·MD5·digest:·487d2e34bebceec8ab85ddd790f69115 
12 Signer·#1·key·algorithm:·RSA 
13 Signer·#1·key·size·(bits):·2048 
14 Signer·#1·public·key·SHA-256·digest:·4076c02cab667104baefc172ff62cfdcd8a05fe81c8c44e9e8521ca381f8cc13 
15 Signer·#1·public·key·SHA-1·digest:·8a3e5a2790bb9a201cc0e9e18012c014848c6064 
16 Signer·#1·public·key·MD5·digest:·fe1aa789a75011655f91a29584dc1562 
17 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/. 
18 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/. 
19 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/. 
20 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/. 
21 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/. 
22 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/. 
23 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/. 
24 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/. 
25 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/. 
26 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/. 
27 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/. 
28 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/. 
29 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/. 
30 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/. 
31 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/. 
32 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/. 
33 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/. 
34 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/. 
35 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/. 
36 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/. 
37 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/. 
38 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/. 
39 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/. 
40 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/. 
41 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/. 
42 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/. 
43 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/. 
44 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/. 
45 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/. 
1.2 MB
zipinfo -v {}
Differences in extra fields detected; using output from zipinfo -v
    
Offset 1, 20838 lines modifiedOffset 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:···················4908520·(00000000004AE5E8h)4 ··Zip·archive·file·size:···················4884894·(00000000004A899Eh)
5 ··Actual·end-cent-dir·record·offset:·······4908498·(00000000004AE5D2h)5 ··Actual·end-cent-dir·record·offset:·······4884872·(00000000004A8988h)
6 ··Expected·end-cent-dir·record·offset:·····4908498·(00000000004AE5D2h)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;·its8 ··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·59898·(000000000000E9FAh)·bytes·long,10 ··The·central·directory·is·54903·(000000000000D677h)·bytes·long,
11 ··and·its·(expected)·offset·in·bytes·from·the·beginning·of·the·zipfile11 ··and·its·(expected)·offset·in·bytes·from·the·beginning·of·the·zipfile
12 ··is·4848600·(000000000049FBD8h).12 ··is·4829969·(000000000049B311h).
  
  
13 Central·directory·entry·#1:13 Central·directory·entry·#1:
14 ---------------------------14 ---------------------------
  
15 ··META-INF/MANIFEST.MF15 ··AndroidManifest.xml
  
16 ··offset·of·local·header·from·start·of·archive:···016 ··offset·of·local·header·from·start·of·archive:···0
17 ··················································(0000000000000000h)·bytes17 ··················································(0000000000000000h)·bytes
18 ··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT18 ··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT
19 ··version·of·encoding·software:···················2.019 ··version·of·encoding·software:···················0.0
20 ··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT20 ··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT
21 ··minimum·software·version·required·to·extract:···2.021 ··minimum·software·version·required·to·extract:···0.0
22 ··compression·method:·····························deflated22 ··compression·method:·····························deflated
23 ··compression·sub-type·(deflation):···············normal23 ··compression·sub-type·(deflation):···············normal
24 ··file·security·status:···························not·encrypted24 ··file·security·status:···························not·encrypted
25 ··extended·local·header:··························yes25 ··extended·local·header:··························no
26 ··file·last·modified·on·(DOS·date/time):··········2019·Jun·17·16:39:5826 ··file·last·modified·on·(DOS·date/time):··········1980·000·0·00:00:00
27 ··32-bit·CRC·value·(hex):·························dc6840b527 ··32-bit·CRC·value·(hex):·························978be522
28 ··compressed·size:································16739·bytes28 ··compressed·size:································2866·bytes
29 ··uncompressed·size:······························56911·bytes29 ··uncompressed·size:······························14552·bytes
30 ··length·of·filename:·····························20·characters30 ··length·of·filename:·····························19·characters
31 ··length·of·extra·field:··························0·bytes31 ··length·of·extra·field:··························0·bytes
32 ··length·of·file·comment:·························0·characters32 ··length·of·file·comment:·························0·characters
33 ··disk·number·on·which·file·begins:···············disk·133 ··disk·number·on·which·file·begins:···············disk·1
34 ··apparent·file·type:·····························binary34 ··apparent·file·type:·····························binary
35 ··non-MSDOS·external·file·attributes:·············000000·hex35 ··non-MSDOS·external·file·attributes:·············000000·hex
36 ··MS-DOS·file·attributes·(00·hex):················none36 ··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.version40 ··META-INF/android.arch.core_runtime.version
  
94 ··offset·of·local·header·from·start·of·archive:···3570241 ··offset·of·local·header·from·start·of·archive:···2915
95 ··················································(0000000000008B76h)·bytes42 ··················································(0000000000000B63h)·bytes
96 ··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT43 ··file·system·or·operating·system·of·origin:······MS-DOS,·OS/2·or·NT·FAT
97 ··version·of·encoding·software:···················1.044 ··version·of·encoding·software:···················2.4
98 ··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT45 ··minimum·file·system·compatibility·required:·····MS-DOS,·OS/2·or·NT·FAT
99 ··minimum·software·version·required·to·extract:···1.046 ··minimum·software·version·required·to·extract:···1.0
100 ··compression·method:·····························none·(stored)47 ··compression·method:·····························none·(stored)
101 ··file·security·status:···························not·encrypted48 ··file·security·status:···························not·encrypted
102 ··extended·local·header:··························no49 ··extended·local·header:··························no
103 ··file·last·modified·on·(DOS·date/time):··········1980·Jan·1·00:00:0050 ··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.
142 B
filetype from file(1)
    
Offset 1, 1 lines modifiedOffset 1, 1 lines modified
1 Zip·archive·data,·at·least·v2.0·to·extract1 Zip·archive·data,·at·least·v0.0·to·extract
124 KB
classes.dex
124 KB
classes.jar
14.9 KB
zipinfo {}
    
Offset 1, 8 lines modifiedOffset 1, 8 lines modified
1 Zip·file·size:·10426696·bytes,·number·of·entries:·51711 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.class2 ?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.class3 ?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.class4 ?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.class5 ?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.class6 ?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.class7 ?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.class8 ?rwxrwxr-x··2.0·unx······188·b-·stor·80-Jan-01·00:00·android/arch/core/internal/SafeIterableMap$SupportRemove.class
Offset 1557, 17 lines modifiedOffset 1557, 17 lines modified
1557 ?rwxrwxr-x··2.0·unx·····2620·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttException.class1557 ?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.class1558 ?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.class1559 ?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.class1560 ?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.class1561 ?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.class1562 ?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.class1563 ?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.class1564 ?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.class1565 ?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.class1566 ?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.class1567 ?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.class1568 ?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.class1569 ?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.class1570 ?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.class1571 ?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.class1572 ?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.class1573 ?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 modifiedOffset 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.class1575 ?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.class1576 ?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.class1577 ?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.class1578 ?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.class1579 ?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.class1580 ?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.class1581 ?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·····4630·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.class1582 ?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.class1583 ?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.class1584 ?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.class1585 ?rwxrwxr-x··2.0·unx·····1736·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/security/SimpleBase64Encoder.class
1586 ?rwxrwxr-x··2.0·unx·····1112·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/Base64$Base64Encoder.class1586 ?rwxrwxr-x··2.0·unx·····1112·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/Base64$Base64Encoder.class
1587 ?rwxrwxr-x··2.0·unx······986·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/Base64.class1587 ?rwxrwxr-x··2.0·unx······986·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/Base64.class
1588 ?rwxrwxr-x··2.0·unx·····1422·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/ExtendedByteArrayOutputStream.class1588 ?rwxrwxr-x··2.0·unx·····1422·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/ExtendedByteArrayOutputStream.class
1589 ?rwxrwxr-x··2.0·unx······256·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/HandshakeFailedException.class1589 ?rwxrwxr-x··2.0·unx······256·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/HandshakeFailedException.class
1590 ?rwxrwxr-x··2.0·unx·····3086·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketFrame.class1590 ?rwxrwxr-x··2.0·unx·····3086·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketFrame.class
1591 ?rwxrwxr-x··2.0·unx·····6294·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake.class1591 ?rwxrwxr-x··2.0·unx·····6263·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake.class
1592 ?rwxrwxr-x··2.0·unx·····3146·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.class1592 ?rwxrwxr-x··2.0·unx·····3371·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.class
1593 ?rwxrwxr-x··2.0·unx······469·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/CountingInputStream.class1593 ?rwxrwxr-x··2.0·unx······469·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/CountingInputStream.class
1594 ?rwxrwxr-x··2.0·unx·····3453·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream.class1594 ?rwxrwxr-x··2.0·unx·····3453·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttInputStream.class
1595 ?rwxrwxr-x··2.0·unx·····1977·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream.class1595 ?rwxrwxr-x··2.0·unx·····1977·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttOutputStream.class
1596 ?rwxrwxr-x··2.0·unx·····8573·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage.class1596 ?rwxrwxr-x··2.0·unx·····8573·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage.class
1597 ?rwxrwxr-x··2.0·unx······636·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MultiByteArrayInputStream.class1597 ?rwxrwxr-x··2.0·unx······636·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MultiByteArrayInputStream.class
1598 ?rwxrwxr-x··2.0·unx······399·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MultiByteInteger.class1598 ?rwxrwxr-x··2.0·unx······399·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MultiByteInteger.class
1599 ?rwxrwxr-x··2.0·unx·····1197·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/Logger.class1599 ?rwxrwxr-x··2.0·unx·····1197·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/Logger.class
1600 ?rwxrwxr-x··2.0·unx·····2488·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/LoggerFactory.class1600 ?rwxrwxr-x··2.0·unx·····2488·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/LoggerFactory.class
1601 ?rwxrwxr-x··2.0·unx·····2487·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/SimpleLogFormatter.class1601 ?rwxrwxr-x··2.0·unx·····2487·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/SimpleLogFormatter.class
1602 ?rwxrwxr-x··2.0·unx······484·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/PersistanceFileFilter.class1602 ?rwxrwxr-x··2.0·unx······484·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/PersistanceFileFilter.class
1603 ?rwxrwxr-x··2.0·unx······444·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/PersistanceFileNameFilter.class1603 ?rwxrwxr-x··2.0·unx······444·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/PersistanceFileNameFilter.class
1604 ?rwxrwxr-x··2.0·unx······375·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/spi/NetworkModuleFactory.class1604 ?rwxrwxr-x··2.0·unx······375·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/spi/NetworkModuleFactory.class
1605 ?rwxrwxr-x··2.0·unx·······99·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/spi/package-info.class1605 ?rwxrwxr-x··2.0·unx·······99·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/spi/package-info.class
1606 ?rwxrwxr-x··2.0·unx·····4215·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/util/Debug.class1606 ?rwxrwxr-x··2.0·unx·····4215·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/util/Debug.class
1607 ?rwxrwxr-x··2.0·unx·····1660·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/util/Strings.class1607 ?rwxrwxr-x··2.0·unx·····1657·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/util/Strings.class
1608 ?rwxrwxr-x··2.0·unx·····2141·b-·stor·80-Jan-01·00:00·org/spongycastle/LICENSE.class1608 ?rwxrwxr-x··2.0·unx·····2141·b-·stor·80-Jan-01·00:00·org/spongycastle/LICENSE.class
1609 ?rwxrwxr-x··2.0·unx·······84·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Choice.class1609 ?rwxrwxr-x··2.0·unx·······84·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Choice.class
1610 ?rwxrwxr-x··2.0·unx······155·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Encodable.class1610 ?rwxrwxr-x··2.0·unx······155·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Encodable.class
1611 ?rwxrwxr-x··2.0·unx······884·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1EncodableVector.class1611 ?rwxrwxr-x··2.0·unx······884·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1EncodableVector.class
1612 ?rwxrwxr-x··2.0·unx······197·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Encoding.class1612 ?rwxrwxr-x··2.0·unx······197·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Encoding.class
1613 ?rwxrwxr-x··2.0·unx······372·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Exception.class1613 ?rwxrwxr-x··2.0·unx······372·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Exception.class
1614 ?rwxrwxr-x··2.0·unx······289·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Generator.class1614 ?rwxrwxr-x··2.0·unx······289·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Generator.class
Offset 2960, 15 lines modifiedOffset 2960, 15 lines modified
2960 ?rwxrwxr-x··2.0·unx······558·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttConnection$2.class2960 ?rwxrwxr-x··2.0·unx······558·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttConnection$2.class
2961 ?rwxrwxr-x··2.0·unx·····1777·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttConnection$MqttConnectionListener.class2961 ?rwxrwxr-x··2.0·unx·····1777·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttConnection$MqttConnectionListener.class
2962 ?rwxrwxr-x··2.0·unx····10676·b-·defN·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttService.class2962 ?rwxrwxr-x··2.0·unx····10676·b-·defN·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttService.class
2963 ?rwxrwxr-x··2.0·unx·····3555·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttTokenAndroid.class2963 ?rwxrwxr-x··2.0·unx·····3555·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/MqttTokenAndroid.class
2964 ?rwxrwxr-x··2.0·unx·····1404·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/ParcelableMqttMessage.class2964 ?rwxrwxr-x··2.0·unx·····1404·b-·stor·80-Jan-01·00:00·org/eclipse/paho/android/service/ParcelableMqttMessage.class
2965 ?rwxrwxr-x··2.0·unx······220·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/IMqttDeliveryToken.class2965 ?rwxrwxr-x··2.0·unx······220·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/IMqttDeliveryToken.class
2966 ?rwxrwxr-x··2.0·unx·····3210·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttAsyncClient$MqttReconnectActionListener.class2966 ?rwxrwxr-x··2.0·unx·····3210·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttAsyncClient$MqttReconnectActionListener.class
2967 ?rwxrwxr-x··2.0·unx····19897·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttAsyncClient.class2967 ?rwxrwxr-x··2.0·unx····19879·b-·defN·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttAsyncClient.class
2968 ?rwxrwxr-x··2.0·unx······205·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttCallbackExtended.class2968 ?rwxrwxr-x··2.0·unx······205·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttCallbackExtended.class
2969 ?rwxrwxr-x··2.0·unx·····7205·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttClient.class2969 ?rwxrwxr-x··2.0·unx·····7205·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttClient.class
2970 ?rwxrwxr-x··2.0·unx······500·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttPersistenceException.class2970 ?rwxrwxr-x··2.0·unx······500·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttPersistenceException.class
2971 ?rwxrwxr-x··2.0·unx······401·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttSecurityException.class2971 ?rwxrwxr-x··2.0·unx······401·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttSecurityException.class
2972 ?rwxrwxr-x··2.0·unx·····1647·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttToken.class2972 ?rwxrwxr-x··2.0·unx·····1647·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/MqttToken.class
2973 ?rwxrwxr-x··2.0·unx·····3070·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/ScheduledExecutorPingSender.class2973 ?rwxrwxr-x··2.0·unx·····3070·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/ScheduledExecutorPingSender.class
2974 ?rwxrwxr-x··2.0·unx·····2593·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/TimerPingSender.class2974 ?rwxrwxr-x··2.0·unx·····2593·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/TimerPingSender.class
Offset 2984, 18 lines modifiedOffset 2984, 18 lines modified
2984 ?rwxrwxr-x··2.0·unx······668·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttAck.class2984 ?rwxrwxr-x··2.0·unx······668·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttAck.class
2985 ?rwxrwxr-x··2.0·unx·····3235·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttConnect.class2985 ?rwxrwxr-x··2.0·unx·····3235·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttConnect.class
2986 ?rwxrwxr-x··2.0·unx······568·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttDisconnect.class2986 ?rwxrwxr-x··2.0·unx······568·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttDisconnect.class
2987 ?rwxrwxr-x··2.0·unx······886·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPersistableWireMessage.class2987 ?rwxrwxr-x··2.0·unx······886·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPersistableWireMessage.class
2988 ?rwxrwxr-x··2.0·unx······565·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPingReq.class2988 ?rwxrwxr-x··2.0·unx······565·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPingReq.class
2989 ?rwxrwxr-x··2.0·unx······411·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttReceivedMessage.class2989 ?rwxrwxr-x··2.0·unx······411·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttReceivedMessage.class
2990 ?rwxrwxr-x··2.0·unx·····2657·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.class2990 ?rwxrwxr-x··2.0·unx·····2657·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.class
2991 ?rwxrwxr-x··2.0·unx·····2244·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.class2991 ?rwxrwxr-x··2.0·unx·····2232·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.class
2992 ?rwxrwxr-x··2.0·unx·····4605·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/JSR47Logger.class2992 ?rwxrwxr-x··2.0·unx·····4596·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/logging/JSR47Logger.class
2993 ?rwxrwxr-x··2.0·unx·····1326·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/MemoryPersistence.class2993 ?rwxrwxr-x··2.0·unx·····1326·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/MemoryPersistence.class
2994 ?rwxrwxr-x··2.0·unx·····5854·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence.class2994 ?rwxrwxr-x··2.0·unx·····5838·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence.class
2995 ?rwxrwxr-x··2.0·unx······260·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1ApplicationSpecificParser.class2995 ?rwxrwxr-x··2.0·unx······260·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1ApplicationSpecificParser.class
2996 ?rwxrwxr-x··2.0·unx·····7427·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1InputStream.class2996 ?rwxrwxr-x··2.0·unx·····7427·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1InputStream.class
2997 ?rwxrwxr-x··2.0·unx·····1233·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Object.class2997 ?rwxrwxr-x··2.0·unx·····1233·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Object.class
2998 ?rwxrwxr-x··2.0·unx······240·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1OctetStringParser.class2998 ?rwxrwxr-x··2.0·unx······240·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1OctetStringParser.class
2999 ?rwxrwxr-x··2.0·unx······478·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1OutputStream$ImplicitOutputStream.class2999 ?rwxrwxr-x··2.0·unx······478·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1OutputStream$ImplicitOutputStream.class
3000 ?rwxrwxr-x··2.0·unx······249·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1SequenceParser.class3000 ?rwxrwxr-x··2.0·unx······249·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1SequenceParser.class
3001 ?rwxrwxr-x··2.0·unx······244·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1SetParser.class3001 ?rwxrwxr-x··2.0·unx······244·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1SetParser.class
Offset 4042, 15 lines modifiedOffset 4042, 15 lines modified
4042 ?rwxrwxr-x··2.0·unx·····1330·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttConnack.class4042 ?rwxrwxr-x··2.0·unx·····1330·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttConnack.class
4043 ?rwxrwxr-x··2.0·unx······468·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPingResp.class4043 ?rwxrwxr-x··2.0·unx······468·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPingResp.class
4044 ?rwxrwxr-x··2.0·unx······777·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubAck.class4044 ?rwxrwxr-x··2.0·unx······777·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubAck.class
4045 ?rwxrwxr-x··2.0·unx······781·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubComp.class4045 ?rwxrwxr-x··2.0·unx······781·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubComp.class
4046 ?rwxrwxr-x··2.0·unx······733·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubRec.class4046 ?rwxrwxr-x··2.0·unx······733·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubRec.class
4047 ?rwxrwxr-x··2.0·unx·····1268·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubRel.class4047 ?rwxrwxr-x··2.0·unx·····1268·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPubRel.class
4048 ?rwxrwxr-x··2.0·unx·····3940·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPublish.class4048 ?rwxrwxr-x··2.0·unx·····3940·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttPublish.class
4049 ?rwxrwxr-x··2.0·unx·····1012·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttSuback.class4049 ?rwxrwxr-x··2.0·unx·····1008·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttSuback.class
4050 ?rwxrwxr-x··2.0·unx······514·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubAck.class4050 ?rwxrwxr-x··2.0·unx······514·b-·stor·80-Jan-01·00:00·org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubAck.class
4051 ?rwxrwxr-x··2.0·unx·····1052·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Primitive.class4051 ?rwxrwxr-x··2.0·unx·····1052·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Primitive.class
4052 ?rwxrwxr-x··2.0·unx·····1036·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Sequence$1.class4052 ?rwxrwxr-x··2.0·unx·····1036·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Sequence$1.class
4053 ?rwxrwxr-x··2.0·unx·····1011·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Set$1.class4053 ?rwxrwxr-x··2.0·unx·····1011·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/ASN1Set$1.class
4054 ?rwxrwxr-x··2.0·unx·····1073·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/BERApplicationSpecificParser.class4054 ?rwxrwxr-x··2.0·unx·····1073·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/BERApplicationSpecificParser.class
4055 ?rwxrwxr-x··2.0·unx······635·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/BEROctetStringGenerator.class4055 ?rwxrwxr-x··2.0·unx······635·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/BEROctetStringGenerator.class
4056 ?rwxrwxr-x··2.0·unx·····1196·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/BEROctetStringParser.class4056 ?rwxrwxr-x··2.0·unx·····1196·b-·stor·80-Jan-01·00:00·org/spongycastle/asn1/BEROctetStringParser.class
Offset 5166, 8 lines modifiedOffset 5166, 8 lines modified
5166 ?rwxrwxr-x··2.0·unx·····3732·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/ClampActivity.class5166 ?rwxrwxr-x··2.0·unx·····3732·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/ClampActivity.class
5167 ?rwxrwxr-x··2.0·unx·····3730·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/ComActivity.class5167 ?rwxrwxr-x··2.0·unx·····3730·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/ComActivity.class
5168 ?rwxrwxr-x··2.0·unx·····3319·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/CoreActivity.class5168 ?rwxrwxr-x··2.0·unx·····3319·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/CoreActivity.class
5169 ?rwxrwxr-x··2.0·unx·····6295·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/CreactivActivity.class5169 ?rwxrwxr-x··2.0·unx·····6295·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/CreactivActivity.class
5170 ?rwxrwxr-x··2.0·unx·····4264·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/CultureActivity.class5170 ?rwxrwxr-x··2.0·unx·····4264·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/CultureActivity.class
5171 ?rwxrwxr-x··2.0·unx·····6591·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/MainActivity.class5171 ?rwxrwxr-x··2.0·unx·····6591·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/MainActivity.class
5172 ?rwxrwxr-x··2.0·unx·····5480·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/MissionActivity.class5172 ?rwxrwxr-x··2.0·unx·····5480·b-·stor·80-Jan-01·00:00·org/c_base/c_beam/activity/MissionActivity.class
5173 5171·files,·10824621·bytes·uncompressed,·9451532·bytes·compressed:··12.7%5173 5171·files,·10825068·bytes·uncompressed,·9451973·bytes·compressed:··12.7%
Max diff block lines reached; -1/15226 bytes (-0.01%) of diff not shown.
61.2 KB
org/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG.class
61.1 KB
procyon -ec {}
    
Offset 34, 273 lines modifiedOffset 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·<·outstandingDelTokens.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·MqttToken·conToken·=·this.conToken;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·NetworkModule[]·access$5·=·ClientComms.access$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·ClientComms·this$4·=·this.this$0;58 ················································final·NetworkModule[]·access$5·=·ClientComms.access$4(this$3);
59 ················································try·{59 ················································try·{
60 ····················································final·NetworkModule·networkModule·=·access$5[ClientComms.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;
65 ····························································try·{66 ····························································try·{
66 ································································final·ClientComms·clientComms·=·this.clientComms; 
67 ································································try·{67 ································································try·{
68 ····································································final·ClientComms·this$6·=·this.this$0;68 ····································································final·ClientComms·clientComms·=·this.clientComms;
69 ····································································try·{69 ····································································try·{
70 ········································································final·ClientState·access$6·=·ClientComms.access$6(this$6);70 ········································································final·ClientComms·this$6·=·this.this$0;
71 ········································································try·{71 ········································································try·{
72 ············································································final·ClientComms·this$7·=·this.this$0;72 ············································································final·ClientState·access$6·=·ClientComms.access$6(this$6);
73 ············································································try·{73 ············································································try·{
74 ················································································final·CommsTokenStore·access$7·=·ClientComms.access$3(this$7);74 ················································································final·ClientComms·this$7·=·this.this$0;
75 ················································································try·{75 ················································································try·{
76 ····················································································final·CommsReceiver·commsReceiver·=·new·CommsReceiver(clientComms,·access$6,·access$7,·networkModule.getInputStream()); 
77 ····················································································final·ClientComms·clientComms2·=·this$5;76 ····················································································final·CommsTokenStore·access$7·=·ClientComms.access$3(this$7);
78 ····················································································try·{77 ····················································································try·{
79 ························································································ClientComms.access$7(clientComms2,·commsReceiver);78 ························································································final·CommsReceiver·commsReceiver·=·new·CommsReceiver(clientComms,·access$6,·access$7,·networkModule.getInputStream());
80 ························································································final·ClientComms·this$8·=·this.this$0;79 ························································································final·ClientComms·clientComms2·=·this$5;
81 ························································································try·{80 ························································································try·{
 81 ····························································································ClientComms.access$7(clientComms2,·commsReceiver);
82 ····························································································final·CommsReceiver·access$8·=·ClientComms.access$8(this$8);82 ····························································································final·ClientComms·this$8·=·this.this$0;
83 ····························································································try·{83 ····························································································try·{
84 ································································································final·StringBuilder·sb·=·new·StringBuilder("MQTT·Rec:·"); 
85 ································································································final·ClientComms·this$9·=·this.this$0;84 ································································································final·CommsReceiver·access$8·=·ClientComms.access$8(this$8);
86 ································································································try·{85 ································································································try·{
 86 ····································································································final·StringBuilder·sb·=·new·StringBuilder("MQTT·Rec:·");
87 ····································································································final·IMqttAsyncClient·client·=·this$9.getClient();87 ····································································································final·ClientComms·this$9·=·this.this$0;
88 ····································································································try·{88 ····································································································try·{
89 ········································································································sb.append(client.getClientId());89 ········································································································final·IMqttAsyncClient·client·=·this$9.getClient();
90 ········································································································final·String·string·=·sb.toString(); 
91 ········································································································try·{90 ········································································································try·{
 91 ············································································································sb.append(client.getClientId());
92 ············································································································final·ClientComms·this$10·=·this.this$0;92 ············································································································final·String·string·=·sb.toString();
93 ············································································································try·{93 ············································································································try·{
94 ················································································································access$8.start(string,·ClientComms.access$0(this$10)); 
95 ················································································································final·ClientComms·this$11·=·this.this$0;94 ················································································································final·ClientComms·this$10·=·this.this$0;
96 ················································································································try·{95 ················································································································try·{
 96 ····················································································································access$8.start(string,·ClientComms.access$0(this$10));
 97 ····················································································································final·ClientComms·this$11·=·this.this$0;
97 ····················································································································try·{98 ····················································································································try·{
98 ························································································································final·ClientComms·clientComms3·=·this.clientComms; 
99 ························································································································try·{99 ························································································································try·{
100 ····························································································································final·ClientComms·this$12·=·this.this$0;100 ····························································································································final·ClientComms·clientComms3·=·this.clientComms;
101 ····························································································································try·{101 ····························································································································try·{
102 ································································································································final·ClientState·access$9·=·ClientComms.access$6(this$12);102 ································································································································final·ClientComms·this$12·=·this.this$0;
103 ································································································································try·{103 ································································································································try·{
104 ····································································································································final·ClientComms·this$13·=·this.this$0;104 ····································································································································final·ClientState·access$9·=·ClientComms.access$6(this$12);
105 ····································································································································try·{105 ····································································································································try·{
106 ········································································································································final·CommsTokenStore·access$10·=·ClientComms.access$3(this$13);106 ········································································································································final·ClientComms·this$13·=·this.this$0;
107 ········································································································································try·{107 ········································································································································try·{
108 ············································································································································final·CommsSender·commsSender·=·new·CommsSender(clientComms3,·access$9,·access$10,·networkModule.getOutputStream()); 
109 ············································································································································final·ClientComms·clientComms4·=·this$11;108 ············································································································································final·CommsTokenStore·access$10·=·ClientComms.access$3(this$13);
110 ············································································································································try·{109 ············································································································································try·{
111 ················································································································································ClientComms.access$9(clientComms4,·commsSender);110 ················································································································································final·CommsSender·commsSender·=·new·CommsSender(clientComms3,·access$9,·access$10,·networkModule.getOutputStream());
112 ················································································································································final·ClientComms·this$14·=·this.this$0;111 ················································································································································final·ClientComms·clientComms4·=·this$11;
113 ················································································································································try·{112 ················································································································································try·{
 113 ····················································································································································ClientComms.access$9(clientComms4,·commsSender);
114 ····················································································································································final·CommsSender·access$11·=·ClientComms.access$10(this$14);114 ····················································································································································final·ClientComms·this$14·=·this.this$0;
115 ····················································································································································try·{115 ····················································································································································try·{
116 ························································································································································final·StringBuilder·sb2·=·new·StringBuilder("MQTT·Snd:·"); 
117 ························································································································································final·ClientComms·this$15·=·this.this$0;116 ························································································································································final·CommsSender·access$11·=·ClientComms.access$10(this$14);
118 ························································································································································try·{117 ························································································································································try·{
 118 ····························································································································································final·StringBuilder·sb2·=·new·StringBuilder("MQTT·Snd:·");
119 ····························································································································································final·IMqttAsyncClient·client2·=·this$15.getClient();119 ····························································································································································final·ClientComms·this$15·=·this.this$0;
120 ····························································································································································try·{120 ····························································································································································try·{
121 ································································································································································sb2.append(client2.getClientId());121 ································································································································································final·IMqttAsyncClient·client2·=·this$15.getClient();
122 ································································································································································final·String·string2·=·sb2.toString(); 
123 ································································································································································try·{122 ································································································································································try·{
124 ····································································································································································final·ClientComms·this$16·=·this.this$0;123 ····································································································································································sb2.append(client2.getClientId());
 124 ····································································································································································final·String·string2·=·sb2.toString();
125 ····································································································································································try·{125 ····································································································································································try·{
126 ········································································································································································access$11.start(string2,·ClientComms.access$0(this$16)); 
127 ········································································································································································final·ClientComms·this$17·=·this.this$0;126 ········································································································································································final·ClientComms·this$16·=·this.this$0;
128 ········································································································································································try·{127 ········································································································································································try·{
129 ············································································································································································final·CommsCallback·access$12·=·ClientComms.access$11(this$17);128 ············································································································································································access$11.start(string2,·ClientComms.access$0(this$16));
 129 ············································································································································································final·ClientComms·this$17·=·this.this$0;
130 ············································································································································································try·{130 ············································································································································································try·{
131 ················································································································································································final·StringBuilder·sb3·=·new·StringBuilder("MQTT·Call:·"); 
132 ················································································································································································final·ClientComms·this$18·=·this.this$0;131 ················································································································································································final·CommsCallback·access$12·=·ClientComms.access$11(this$17);
133 ················································································································································································try·{132 ················································································································································································try·{
 133 ····················································································································································································final·StringBuilder·sb3·=·new·StringBuilder("MQTT·Call:·");
134 ····················································································································································································final·IMqttAsyncClient·client3·=·this$18.getClient();134 ····················································································································································································final·ClientComms·this$18·=·this.this$0;
135 ····················································································································································································try·{135 ····················································································································································································try·{
136 ························································································································································································sb3.append(client3.getClientId());136 ························································································································································································final·IMqttAsyncClient·client3·=·this$18.getClient();
137 ························································································································································································final·String·string3·=·sb3.toString(); 
138 ························································································································································································try·{137 ························································································································································································try·{
139 ····························································································································································································final·ClientComms·this$19·=·this.this$0;138 ····························································································································································································sb3.append(client3.getClientId());
 139 ····························································································································································································final·String·string3·=·sb3.toString();
140 ····························································································································································································try·{140 ····························································································································································································try·{
141 ································································································································································································access$12.start(string3,·ClientComms.access$0(this$19)); 
142 ································································································································································································final·ClientComms·this$20·=·this.this$0;141 ································································································································································································final·ClientComms·this$19·=·this.this$0;
Max diff block lines reached; 38580/62552 bytes (61.68%) of diff not shown.
1.39 KB
org/eclipse/paho/client/mqttv3/internal/ClientComms.class
1.28 KB
procyon -ec {}
    
Offset 38, 15 lines modifiedOffset 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 modifiedOffset 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",·new·Boolean(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 ····
1.15 KB
org/eclipse/paho/client/mqttv3/internal/ClientState.class
1.04 KB
procyon -ec {}
    
Offset 64, 18 lines modifiedOffset 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;
1.52 KB
org/eclipse/paho/client/mqttv3/internal/CommsCallback.class
1.4 KB
procyon -ec {}
    
Offset 29, 26 lines modifiedOffset 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();
763 B
org/eclipse/paho/client/mqttv3/internal/CommsReceiver.class
645 B
procyon -ec {}
    
Offset 11, 15 lines modifiedOffset 11, 15 lines modified
11 public·class·CommsReceiver·implements·Runnable11 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 ····
748 B
org/eclipse/paho/client/mqttv3/internal/CommsSender.class
634 B
procyon -ec {}
    
Offset 13, 15 lines modifiedOffset 13, 15 lines modified
  
13 public·class·CommsSender·implements·Runnable13 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;
802 B
org/eclipse/paho/client/mqttv3/internal/CommsTokenStore.class
680 B
procyon -ec {}
    
Offset 14, 15 lines modifiedOffset 14, 15 lines modified
  
14 public·class·CommsTokenStore14 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;
779 B
org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.class
637 B
procyon -ec {}
    
Offset 9, 15 lines modifiedOffset 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·Runnable12 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)·{
7.83 KB
org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.class
7.7 KB
procyon -ec {}
    
Offset 120, 88 lines modifiedOffset 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 ························································final·StringBuilder·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 }
2.75 KB
org/eclipse/paho/client/mqttv3/internal/Token.class
2.66 KB
procyon -ec {}
    
Offset 22, 17 lines modifiedOffset 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 modifiedOffset 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]·=·new·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)·{
12.1 KB
org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake.class
11.9 KB
procyon -ec {}
    
Offset 148, 28 lines modifiedOffset 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_0313:·{155 ····················································Label_0295:·{
156 ························································if·(port·==·n·||·this.port·==·443)·{156 ························································if·(port·==·n)·{
157 ····························································break·Label_0313;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 modifiedOffset 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)·{
192 ····················································································break·Label_0550;192 ····················································································break·Label_0532;
193 ················································································}193 ················································································}
194 ················································································final·Properties·customWebSocketHeaders·=·this.customWebSocketHeaders;194 ················································································final·Properties·customWebSocketHeaders·=·this.customWebSocketHeaders;
195 ················································································try·{195 ················································································try·{
196 ····················································································final·Set<Object>·keySet·=·customWebSocketHeaders.keySet();196 ····················································································final·Set<Object>·keySet·=·customWebSocketHeaders.keySet();
197 ····················································································try·{197 ····················································································try·{
198 ························································································final·Iterator<String>·iterator·=·keySet.iterator();198 ························································································final·Iterator<String>·iterator·=·keySet.iterator();
199 ························································································try·{199 ························································································try·{
200 ····························································································while·(true)·{200 ····························································································while·(true)·{
201 ································································································if·(!iterator.hasNext())·{201 ································································································if·(!iterator.hasNext())·{
202 ····································································································break·Label_0550;202 ····································································································break·Label_0532;
203 ································································································}203 ································································································}
204 ································································································final·String·next·=·iterator.next();204 ································································································final·String·next·=·iterator.next();
205 ································································································try·{205 ································································································try·{
206 ····································································································final·String·s5·=·(String)next;206 ····································································································final·String·s5·=·(String)next;
207 ····································································································try·{207 ····································································································try·{
208 ········································································································final·String·property·=·this.customWebSocketHeaders.getProperty(s5);208 ········································································································final·String·property·=·this.customWebSocketHeaders.getProperty(s5);
209 ········································································································try·{209 ········································································································try·{
Offset 214, 39 lines modifiedOffset 214, 40 lines modified
214 ················································································································try·{214 ················································································································try·{
215 ····················································································································sb13.append(property);215 ····················································································································sb13.append(property);
216 ····················································································································final·StringBuilder·sb14·=·sb12;216 ····················································································································final·StringBuilder·sb14·=·sb12;
217 ····················································································································try·{217 ····················································································································try·{
218 ························································································································sb14.append(s2);218 ························································································································sb14.append(s2);
219 ························································································································printWriter.print(sb12.toString());219 ························································································································printWriter.print(sb12.toString());
220 ························································································································continue;220 ························································································································continue;
221 ························································································································s·=·uri.getUserInfo(); 
222 ························································································································//·iftrue(Label_0602:,·s·==·null) 
223 ························································································································final·StringBuilder·sb15·=·new·StringBuilder("Authorization:·Basic·");221 ························································································································final·StringBuilder·sb15·=·new·StringBuilder("Authorization:·Basic·");
224 ························································································································s·=·Base64.encode(s);222 ························································································································s·=·Base64.encode(s);
225 ························································································································sb15.append(s);223 ························································································································sb15.append(s);
226 ························································································································final·StringBuilder·sb16·=·sb15;224 ························································································································final·StringBuilder·sb16·=·sb15;
227 ························································································································try·{225 ························································································································try·{
228 ····························································································································sb16.append(s2);226 ····························································································································sb16.append(s2);
229 ····························································································································s·=·sb15.toString();227 ····························································································································s·=·sb15.toString();
230 ····························································································································printWriter.print(s);228 ····························································································································printWriter.print(s);
231 ····························································································································final·PrintWriter·printWriter2;229 ····························································································································final·PrintWriter·printWriter2;
232 ····························································································································Label_0602:·{230 ····························································································································Label_0584:·{
233 ································································································································printWriter2·=·printWriter;231 ································································································································printWriter2·=·printWriter;
234 ····························································································································}232 ····························································································································}
235 ····························································································································try·{233 ····························································································································try·{
236 ································································································································printWriter2.print(s2);234 ································································································································printWriter2.print(s2);
237 ································································································································printWriter.flush();235 ································································································································printWriter.flush();
 236 ································································································································return;
238 ····························································································································}237 ····························································································································}
239 ····························································································································catch·(URISyntaxException·ex)·{238 ····························································································································catch·(URISyntaxException·ex)·{
240 ································································································································s·=·ex.getMessage();239 ································································································································s·=·ex.getMessage();
241 ································································································································throw·new·IllegalStateException(s);240 ································································································································throw·new·IllegalStateException(s);
242 ····························································································································}241 ····························································································································}
243 ························································································································}242 ························································································································}
244 ························································································································catch·(URISyntaxException·ex2)·{}243 ························································································································catch·(URISyntaxException·ex2)·{}
 244 ························································································································s·=·uri.getUserInfo();
245 ····················································································································}245 ····················································································································}
 246 ····················································································································//·iftrue(Label_0584:,·s·==·null)
246 ····················································································································catch·(URISyntaxException·ex3)·{}247 ····················································································································catch·(URISyntaxException·ex3)·{}
247 ················································································································}248 ················································································································}
248 ················································································································catch·(URISyntaxException·ex4)·{}249 ················································································································catch·(URISyntaxException·ex4)·{}
249 ············································································································}250 ············································································································}
250 ············································································································catch·(URISyntaxException·ex5)·{}251 ············································································································catch·(URISyntaxException·ex5)·{}
251 ········································································································}252 ········································································································}
252 ········································································································catch·(URISyntaxException·ex6)·{}253 ········································································································catch·(URISyntaxException·ex6)·{}
5.08 KB
org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.class
4.94 KB
procyon -ec {}
    
Offset 1, 22 lines modifiedOffset 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·Runnable9 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 modifiedOffset 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 modifiedOffset 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 ································································//·iftrue(Label_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;
908 B
org/eclipse/paho/client/mqttv3/util/Strings.class
810 B
procyon -ec {}
    
Offset 58, 17 lines modifiedOffset 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·||·array[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)·{
4.28 KB
org/eclipse/paho/client/mqttv3/MqttAsyncClient.class
4.18 KB
procyon -ec {}
    
Offset 28, 15 lines modifiedOffset 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 modifiedOffset 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 modifiedOffset 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()),·new·Integer(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 modifiedOffset 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 modifiedOffset 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());
739 B
org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.class
611 B
procyon -ec {}
    
Offset 58, 15 lines modifiedOffset 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 ····
1.58 KB
org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.class
1.45 KB
procyon -ec {}
    
Offset 65, 29 lines modifiedOffset 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 ····
2.18 KB
org/eclipse/paho/client/mqttv3/logging/JSR47Logger.class
2.07 KB
procyon -ec {}
    
Offset 26, 26 lines modifiedOffset 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·(handlers[i]·instanceof·MemoryHandler)·{35 ················if·(handler·instanceof·MemoryHandler)·{
35 ····················final·Handler·handler·=·handlers[i]; 
36 ····················//·monitorenter(handler)36 ····················synchronized·(handler)·{
37 ····················final·Handler[]·array·=·handlers; 
38 ····················try·{ 
39 ························((MemoryHandler)array[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 modifiedOffset 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.indexOf(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());
2.23 KB
org/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence.class
2.09 KB
procyon -ec {}
    
Offset 60, 30 lines modifiedOffset 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,·listFiles[i].getName().substring(0,·listFiles[i].getName().length()·-·4));69 ················final·File·file2·=·new·File(parent,·file.getName().substring(0,·file.getName().length()·-·4));
69 ················if·(!listFiles[i].renameTo(file))·{70 ················if·(!file.renameTo(file2))·{
70 ····················file.delete();71 ····················file2.delete();
71 ····················listFiles[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 modifiedOffset 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)·{
748 B
org/eclipse/paho/client/mqttv3/internal/wire/MqttSuback.class
626 B
procyon -ec {}
    
Offset 32, 14 lines modifiedOffset 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 ········for·(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 }
6.14 KB
smali/org/eclipse/paho/client/mqttv3/MqttAsyncClient.smali
    
Offset 25, 15 lines modifiedOffset 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·=·0x7530L27 .field·private·static·final·QUIESCE_TIMEOUT:J·=·0x7530L
  
28 .field·private·static·clientLock:Ljava/lang/Object;·=·null28 .field·private·static·final·clientLock:Ljava/lang/Object;
  
29 .field·private·static·reconnectDelay:I·=·0x3e829 .field·private·static·reconnectDelay:I·=·0x3e8
  
  
30 #·instance·fields30 #·instance·fields
31 .field·private·clientId:Ljava/lang/String;31 .field·private·clientId:Ljava/lang/String;
  
Offset 1153, 21 lines modifiedOffset 1153, 21 lines modified
  
1153 ····const/4·v9,·0x01153 ····const/4·v9,·0x0
  
1154 ····aput-object·v3,·v2,·v91154 ····aput-object·v3,·v2,·v9
  
1155 ····const/4·v3,·0x11155 ····const/4·v3,·0x1
  
1156 ····new-instance·v5,·Ljava/lang/Integer; 
  
1157 ····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getConnectionTimeout()I1156 ····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getConnectionTimeout()I
  
1158 ····move-result·v61157 ····move-result·v5
  
1159 ····invoke-direct·{v5,·v6},·Ljava/lang/Integer;-><init>(I)V1158 ····invoke-static·{v5},·Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
  
 1159 ····move-result-object·v5
  
1160 ····aput-object·v5,·v2,·v31160 ····aput-object·v5,·v2,·v3
  
1161 ····const/4·v3,·0x21161 ····const/4·v3,·0x2
  
1162 ····.line·6211162 ····.line·621
1163 ····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getKeepAliveInterval()I1163 ····invoke-virtual·{v4},·Lorg/eclipse/paho/client/mqttv3/MqttConnectOptions;->getKeepAliveInterval()I
Offset 2359, 59 lines modifiedOffset 2359, 58 lines modified
  
2359 ····move-result-object·p12359 ····move-result-object·p1
  
2360 ····return-object·p12360 ····return-object·p1
2361 .end·method2361 .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·32363 ····.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·annotation2368 ····.end·annotation
  
2369 ····.line·9262369 ····.line·926
2370 ····array-length·v0,·p12370 ····array-length·v0,·p1
  
2371 ····array-length·v1,·p22371 ····array-length·v1,·p2
  
2372 ····if-ne·v0,·v1,·:cond_12372 ····if-ne·v0,·v1,·:cond_1
  
2373 ····const/4·v0,·0x0 
  
2374 ····.line·9312373 ····.line·931
2375 ····:goto_0 
2376 ····array-length·v1,·p12374 ····array-length·v0,·p1
  
 2375 ····const/4·v1,·0x0
  
 2376 ····:goto_0
2377 ····if-lt·v0,·v1,·:cond_02377 ····if-lt·v1,·v0,·:cond_0
  
2378 ····.line·9372378 ····.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·p12380 ····move-result-object·p1
  
2381 ····return-object·p12381 ····return-object·p1
  
2382 ····.line·9332382 ····.line·931
2383 ····:cond_02383 ····:cond_0
2384 ····aget-object·v1,·p1,·v02384 ····aget-object·v2,·p1,·v1
  
2385 ····const/4·v2,·0x12385 ····const/4·v3,·0x1
  
 2386 ····.line·933
2386 ····invoke-static·{v1,·v2},·Lorg/eclipse/paho/client/mqttv3/MqttTopic;->validate(Ljava/lang/String;Z)V2387 ····invoke-static·{v2,·v3},·Lorg/eclipse/paho/client/mqttv3/MqttTopic;->validate(Ljava/lang/String;Z)V
  
2387 ····.line·9342388 ····.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;)V2390 ····invoke-virtual·{v3,·v2},·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->removeMessageListener(Ljava/lang/String;)V
  
2391 ····add-int/lit8·v0,·v0,·0x12391 ····add-int/lit8·v1,·v1,·0x1
  
2392 ····goto·:goto_02392 ····goto·:goto_0
  
2393 ····.line·9272393 ····.line·927
2394 ····:cond_12394 ····:cond_1
2395 ····new-instance·p1,·Ljava/lang/IllegalArgumentException;2395 ····new-instance·p1,·Ljava/lang/IllegalArgumentException;
  
Offset 2464, 25 lines modifiedOffset 2463, 25 lines modified
  
2464 ····return-object·p12463 ····return-object·p1
  
2465 ····:catch_02464 ····:catch_0
2466 ····move-exception·p22465 ····move-exception·p2
  
2467 ····.line·10312466 ····.line·1031
2468 ····:goto_1 
2469 ····array-length·p3,·p12467 ····array-length·p3,·p1
  
 2468 ····:goto_1
2470 ····if-ge·v0,·p3,·:cond_12469 ····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,·v02470 ····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;)V2473 ····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.
563 B
smali/org/eclipse/paho/client/mqttv3/internal/CommsTokenStore.smali
    
Offset 10, 15 lines modifiedOffset 10, 15 lines modified
10 #·instance·fields10 #·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·methods15 #·direct·methods
16 .method·static·constructor·<clinit>()V16 .method·static·constructor·<clinit>()V
17 ····.locals·017 ····.locals·0
  
18 ····return-void18 ····return-void
14.0 KB
smali/org/eclipse/paho/client/mqttv3/internal/NetworkModuleService.smali
    
Offset 25, 150 lines modifiedOffset 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·methods26 #·direct·methods
27 .method·static·constructor·<clinit>()V27 .method·static·constructor·<clinit>()V
28 ····.locals·228 ····.locals·2
  
29 ····.line·3529 ····.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·v032 ····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·3434 ····.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·v036 ····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·3738 ····.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·v142 ····move-result-object·v1
  
43 ····.line·3643 ····.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·v045 ····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·4048 ····.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·v050 ····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-void52 ····return-void
53 .end·method53 .end·method
  
54 .method·private·constructor·<init>()V54 .method·private·constructor·<init>()V
55 ····.locals·055 ····.locals·0
  
56 ····.line·4556 ····.line·47
57 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V57 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V
  
58 ····return-void58 ····return-void
59 .end·method59 .end·method
  
60 .method·public·static·applyRFC3986AuthorityPatch(Ljava/net/URI;)V60 .method·public·static·applyRFC3986AuthorityPatch(Ljava/net/URI;)V
61 ····.locals·361 ····.locals·3
  
62 ····if-eqz·p0,·:cond_262 ····if-eqz·p0,·:cond_2
  
63 ····.line·12363 ····.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·v065 ····move-result-object·v0
  
66 ····if-nez·v0,·:cond_266 ····if-nez·v0,·:cond_2
  
67 ····.line·12467 ····.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·v069 ····move-result-object·v0
  
70 ····if-eqz·v0,·:cond_270 ····if-eqz·v0,·:cond_2
  
71 ····.line·12571 ····.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·v073 ····move-result-object·v0
  
74 ····invoke-virtual·{v0},·Ljava/lang/String;->isEmpty()Z74 ····invoke-virtual·{v0},·Ljava/lang/String;->isEmpty()Z
  
75 ····move-result·v075 ····move-result·v0
  
76 ····if-eqz·v0,·:cond_076 ····if-eqz·v0,·:cond_0
  
77 ····goto·:goto_177 ····goto·:goto_1
  
78 ····.line·12978 ····.line·131
79 ····:cond_079 ····: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·v182 ····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·v084 ····move-result-object·v0
  
85 ····.line·13085 ····.line·132
86 ····invoke-virtual·{v0},·Ljava/util/regex/Matcher;->find()Z86 ····invoke-virtual·{v0},·Ljava/util/regex/Matcher;->find()Z
  
87 ····move-result·v187 ····move-result·v1
  
88 ····if-eqz·v1,·:cond_288 ····if-eqz·v1,·:cond_2
  
89 ····const/4·v1,·0x289 ····const/4·v1,·0x2
  
90 ····.line·13190 ····.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·v192 ····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;)V94 ····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,·0x395 ····const/4·v1,·0x3
  
96 ····.line·13296 ····.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.
630 B
smali/org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.smali
    
Offset 5, 15 lines modifiedOffset 5, 15 lines modified
5 #·interfaces5 #·interfaces
6 .implements·Ljava/lang/Runnable;6 .implements·Ljava/lang/Runnable;
  
  
7 #·instance·fields7 #·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 ············">;"
1.24 KB
smali/org/eclipse/paho/client/mqttv3/internal/Token.smali
    
Offset 26, 19 lines modifiedOffset 26, 19 lines modified
  
26 .field·private·notified:Z26 .field·private·notified:Z
  
27 .field·private·pendingComplete:Z27 .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:Z30 .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·methods34 #·direct·methods
Offset 1190, 17 lines modifiedOffset 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·v111191 ····move-result-object·v11
  
1192 ····aput-object·v11,·v10,·v71192 ····aput-object·v11,·v10,·v7
  
1193 ····new-instance·v11,·Ljava/lang/Long;1193 ····invoke-static·{p1,·p2},·Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
  
1194 ····invoke-direct·{v11,·p1,·p2},·Ljava/lang/Long;-><init>(J)V1194 ····move-result-object·v11
  
1195 ····aput-object·v11,·v10,·v81195 ····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;)V1196 ····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,·v21197 ····cmp-long·v1,·p1,·v2
  
894 B
smali/org/eclipse/paho/client/mqttv3/internal/ClientState.smali
    
Offset 62, 21 lines modifiedOffset 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:I64 .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:Z69 .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·methods71 #·direct·methods
27.3 KB
smali/org/eclipse/paho/client/mqttv3/internal/CommsSender.smali
    
Offset 21, 15 lines modifiedOffset 21, 15 lines modified
21 #·instance·fields21 #·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 modifiedOffset 55, 76 lines modified
  
55 ····return-void55 ····return-void
56 .end·method56 .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;)V57 .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·258 ····.locals·2
  
59 ····.line·5259 ····.line·53
60 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V60 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V
  
61 ····.line·3561 ····.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·v065 ····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·3967 ····.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·4070 ····.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·4173 ····.line·42
74 ····new-instance·v0,·Ljava/lang/Object;74 ····new-instance·v0,·Ljava/lang/Object;
  
75 ····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V75 ····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,·0x077 ····const/4·v0,·0x0
  
78 ····.line·4278 ····.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·4680 ····.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·4882 ····.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·4984 ····.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·5386 ····.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;)V88 ····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·5490 ····.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·5592 ····.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·5694 ····.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·5796 ····.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·p199 ····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 modifiedOffset 135, 98 lines modified
  
135 ····return-void135 ····return-void
136 .end·method136 .end·method
  
137 .method·private·handleRunException(Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;Ljava/lang/Exception;)V137 .method·private·handleRunException(Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttWireMessage;Ljava/lang/Exception;)V
138 ····.locals·6138 ····.locals·6
  
139 ····.line·190139 ····.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,·0x0144 ····const/4·v4,·0x0
  
145 ····move-object·v5,·p2145 ····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;)V146 ····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·192147 ····.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_0149 ····if-nez·p1,·:cond_0
  
150 ····.line·193150 ····.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,·0x7d6d152 ····const/16·v0,·0x7d6d
  
153 ····invoke-direct·{p1,·v0,·p2},·Lorg/eclipse/paho/client/mqttv3/MqttException;-><init>(ILjava/lang/Throwable;)V153 ····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.
34.6 KB
smali/org/eclipse/paho/client/mqttv3/internal/CommsReceiver.smali
    
Offset 23, 15 lines modifiedOffset 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 modifiedOffset 55, 76 lines modified
  
55 ····return-void55 ····return-void
56 .end·method56 .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;)V57 .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·258 ····.locals·2
  
59 ····.line·5459 ····.line·55
60 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V60 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V
  
61 ····.line·3961 ····.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·v065 ····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·4267 ····.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·4370 ····.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·4473 ····.line·45
74 ····new-instance·v0,·Ljava/lang/Object;74 ····new-instance·v0,·Ljava/lang/Object;
  
75 ····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V75 ····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,·0x077 ····const/4·v0,·0x0
  
78 ····.line·4878 ····.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·4980 ····.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·5182 ····.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·5284 ····.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·5586 ····.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;)V88 ····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·5690 ····.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·5792 ····.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·5894 ····.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·5996 ····.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·p199 ····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 modifiedOffset 137, 35 lines modified
137 .end·method137 .end·method
  
  
138 #·virtual·methods138 #·virtual·methods
139 .method·public·isReceiving()Z139 .method·public·isReceiving()Z
140 ····.locals·3140 ····.locals·3
  
141 ····.line·228141 ····.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·v0143 ····monitor-enter·v0
  
144 ····.line·229144 ····.line·230
145 ····:try_start_0145 ····: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_0148 ····if-ne·v1,·v2,·:cond_0
  
149 ····const/4·v1,·0x1149 ····const/4·v1,·0x1
  
150 ····goto·:goto_0150 ····goto·:goto_0
  
151 ····:cond_0151 ····:cond_0
152 ····const/4·v1,·0x0152 ····const/4·v1,·0x0
  
153 ····.line·228153 ····.line·229
154 ····:goto_0154 ····:goto_0
155 ····monitor-exit·v0155 ····monitor-exit·v0
  
156 ····return·v1156 ····return·v1
  
157 ····:catchall_0157 ····:catchall_0
Max diff block lines reached; 29819/35291 bytes (84.49%) of diff not shown.
61.5 KB
smali/org/eclipse/paho/client/mqttv3/internal/CommsCallback.smali
    
Offset 43, 142 lines modifiedOffset 43, 142 lines modified
43 ····.end·annotation43 ····.end·annotation
44 .end·field44 .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·annotation54 ····.end·annotation
55 .end·field55 .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:Z59 .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·annotation67 ····.end·annotation
68 .end·field68 .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·methods75 #·direct·methods
76 .method·static·constructor·<clinit>()V76 .method·static·constructor·<clinit>()V
77 ····.locals·077 ····.locals·0
  
78 ····return-void78 ····return-void
79 .end·method79 .end·method
  
80 .method·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;)V80 .method·constructor·<init>(Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;)V
81 ····.locals·281 ····.locals·2
  
82 ····.line·7382 ····.line·74
83 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V83 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V
  
84 ····.line·5084 ····.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·v088 ····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·6190 ····.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·6293 ····.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·6396 ····.line·64
97 ····new-instance·v0,·Ljava/lang/Object;97 ····new-instance·v0,·Ljava/lang/Object;
  
98 ····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V98 ····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·68100 ····.line·69
101 ····new-instance·v0,·Ljava/lang/Object;101 ····new-instance·v0,·Ljava/lang/Object;
  
102 ····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V102 ····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·69104 ····.line·70
105 ····new-instance·v0,·Ljava/lang/Object;105 ····new-instance·v0,·Ljava/lang/Object;
  
106 ····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V106 ····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,·0x0108 ····const/4·v0,·0x0
  
109 ····.line·71109 ····.line·72
110 ····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->manualAcks:Z110 ····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/CommsCallback;->manualAcks:Z
  
111 ····.line·74111 ····.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·75113 ····.line·76
114 ····new-instance·v0,·Ljava/util/Vector;114 ····new-instance·v0,·Ljava/util/Vector;
  
115 ····const/16·v1,·0xa115 ····const/16·v1,·0xa
  
116 ····invoke-direct·{v0,·v1},·Ljava/util/Vector;-><init>(I)V116 ····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·76118 ····.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)V120 ····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.
2.33 KB
smali/org/eclipse/paho/client/mqttv3/internal/ClientComms$ConnectBG.smali
    
Offset 121, 21 lines modifiedOffset 121, 21 lines modified
  
121 ····move-result-object·v1121 ····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·v1123 ····move-result-object·v1
  
124 ····const/4·v2,·0x0 
  
125 ····.line·711124 ····.line·711
126 ····:goto_0 
127 ····array-length·v3,·v1125 ····array-length·v2,·v1
  
 126 ····const/4·v3,·0x0
  
 127 ····:goto_0
128 ····if-lt·v2,·v3,·:cond_0128 ····if-lt·v3,·v2,·:cond_0
  
129 ····.line·716129 ····.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·v1132 ····move-result-object·v1
Offset 336, 26 lines modifiedOffset 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;)V337 ····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_1338 ····goto·:goto_1
  
339 ····.line·712339 ····.line·711
340 ····:cond_0340 ····:cond_0
341 ····aget-object·v3,·v1,·v2341 ····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;)V344 ····invoke-virtual·{v4,·v0},·Lorg/eclipse/paho/client/mqttv3/internal/Token;->setException(Lorg/eclipse/paho/client/mqttv3/MqttException;)V
344 ····:try_end_0345 ····:try_end_0
345 ····.catch·Lorg/eclipse/paho/client/mqttv3/MqttException;·{:try_start_0·..·:try_end_0}·:catch_1346 ····.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_0347 ····.catch·Ljava/lang/Exception;·{:try_start_0·..·:try_end_0}·:catch_0
  
347 ····add-int/lit8·v2,·v2,·0x1348 ····add-int/lit8·v3,·v3,·0x1
  
348 ····goto/16·:goto_0349 ····goto/16·:goto_0
  
349 ····:catch_0350 ····:catch_0
350 ····move-exception·v0351 ····move-exception·v0
  
351 ····.line·735352 ····.line·735
1.56 KB
smali/org/eclipse/paho/client/mqttv3/internal/ClientComms.smali
    
Offset 36, 15 lines modifiedOffset 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:Z38 .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:B41 .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 modifiedOffset 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·6701603 ····.line·670
1604 ····new-instance·v1,·Ljava/lang/Boolean;1604 ····iget-boolean·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->stoppingComms:Z
  
1605 ····iget-boolean·v2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/ClientComms;->stoppingComms:Z1605 ····invoke-static·{v1},·Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
  
1606 ····invoke-direct·{v1,·v2},·Ljava/lang/Boolean;-><init>(Z)V1606 ····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·v01609 ····return-object·v0
1610 .end·method1610 .end·method
844 B
smali/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketHandshake.smali
    
Offset 464, 22 lines modifiedOffset 464, 16 lines modified
  
464 ····const/16·v4,·0x50464 ····const/16·v4,·0x50
  
465 ····const-string·v5,·"Host:·"465 ····const-string·v5,·"Host:·"
  
466 ····if-eq·v1,·v4,·:cond_1466 ····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·103467 ····.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;)V470 ····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;
12.9 KB
smali/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver.smali
    
Offset 9, 15 lines modifiedOffset 9, 15 lines modified
9 #·static·fields9 #·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·fields11 #·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 modifiedOffset 39, 70 lines modified
39 ····.locals·239 ····.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·annotation44 ····.end·annotation
  
45 ····.line·3945 ····.line·40
46 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V46 ····invoke-direct·{p0},·Ljava/lang/Object;-><init>()V
  
47 ····.line·2947 ····.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·v051 ····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,·0x053 ····const/4·v0,·0x0
  
54 ····.line·3154 ····.line·32
55 ····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z55 ····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z
  
56 ····.line·3256 ····.line·33
57 ····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->stopping:Z57 ····iput-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->stopping:Z
  
58 ····.line·3358 ····.line·34
59 ····new-instance·v0,·Ljava/lang/Object;59 ····new-instance·v0,·Ljava/lang/Object;
  
60 ····invoke-direct·{v0},·Ljava/lang/Object;-><init>()V60 ····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,·0x062 ····const/4·v0,·0x0
  
63 ····.line·3563 ····.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·4065 ····.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·4167 ····.line·42
68 ····new-instance·p1,·Ljava/io/PipedOutputStream;68 ····new-instance·p1,·Ljava/io/PipedOutputStream;
  
69 ····invoke-direct·{p1},·Ljava/io/PipedOutputStream;-><init>()V69 ····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·4271 ····.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;)V73 ····invoke-virtual·{p2,·p1},·Ljava/io/PipedInputStream;->connect(Ljava/io/PipedOutputStream;)V
  
74 ····return-void74 ····return-void
75 .end·method75 .end·method
  
76 .method·private·closeOutputStream()V76 .method·private·closeOutputStream()V
77 ····.locals·177 ····.locals·1
  
78 ····.line·12778 ····.line·129
79 ····:try_start_079 ····: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()V81 ····invoke-virtual·{v0},·Ljava/io/PipedOutputStream;->close()V
82 ····:try_end_082 ····:try_end_0
83 ····.catch·Ljava/io/IOException;·{:try_start_0·..·:try_end_0}·:catch_083 ····.catch·Ljava/io/IOException;·{:try_start_0·..·:try_end_0}·:catch_0
  
Offset 111, 58 lines modifiedOffset 111, 58 lines modified
111 .end·method111 .end·method
  
  
112 #·virtual·methods112 #·virtual·methods
113 .method·public·isReceiving()Z113 .method·public·isReceiving()Z
114 ····.locals·1114 ····.locals·1
  
115 ····.line·143115 ····.line·145
116 ····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->receiving:Z116 ····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->receiving:Z
  
117 ····return·v0117 ····return·v0
118 .end·method118 .end·method
  
119 .method·public·isRunning()Z119 .method·public·isRunning()Z
120 ····.locals·1120 ····.locals·1
  
121 ····.line·134121 ····.line·136
122 ····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z122 ····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z
  
123 ····return·v0123 ····return·v0
124 .end·method124 .end·method
  
125 .method·public·run()V125 .method·public·run()V
126 ····.locals·5126 ····.locals·5
  
127 ····.line·98127 ····.line·99
128 ····:goto_0128 ····:goto_0
129 ····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z129 ····iget-boolean·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/websocket/WebSocketReceiver;->running:Z
  
130 ····if-eqz·v0,·:cond_5130 ····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_0132 ····if-nez·v0,·:cond_0
  
133 ····goto·:goto_4133 ····goto·:goto_4
  
134 ····.line·101134 ····.line·102
135 ····:cond_0135 ····:cond_0
136 ····:try_start_0136 ····:try_start_0
Max diff block lines reached; 8663/13003 bytes (66.62%) of diff not shown.
966 B
smali/org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.smali
    
Offset 147, 31 lines modifiedOffset 147, 31 lines modified
147 ····if-ne·v0,·v1,·:cond_1147 ····if-ne·v0,·v1,·:cond_1
  
148 ····.line·86148 ····.line·86
149 ····array-length·p1,·p1149 ····array-length·p1,·p1
  
150 ····iput·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe;->count:I150 ····iput·p1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe;->count:I
  
151 ····const/4·p1,·0x0 
  
152 ····.line·88151 ····.line·88
153 ····:goto_0 
154 ····array-length·v0,·p2152 ····array-length·p1,·p2
  
 153 ····const/4·v0,·0x0
  
 154 ····:goto_0
155 ····if-lt·p1,·v0,·:cond_0155 ····if-lt·v0,·p1,·:cond_0
  
156 ····return-void156 ····return-void
  
157 ····.line·89 
158 ····:cond_0157 ····:cond_0
159 ····aget·v0,·p2,·p1158 ····aget·v1,·p2,·v0
  
 159 ····.line·89
160 ····invoke-static·{v0},·Lorg/eclipse/paho/client/mqttv3/MqttMessage;->validateQos(I)V160 ····invoke-static·{v1},·Lorg/eclipse/paho/client/mqttv3/MqttMessage;->validateQos(I)V
  
161 ····add-int/lit8·p1,·p1,·0x1161 ····add-int/lit8·v0,·v0,·0x1
  
162 ····goto·:goto_0162 ····goto·:goto_0
  
163 ····.line·83163 ····.line·83
164 ····:cond_1164 ····:cond_1
165 ····new-instance·p1,·Ljava/lang/IllegalArgumentException;165 ····new-instance·p1,·Ljava/lang/IllegalArgumentException;
  
2.08 KB
smali/org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.smali
    
Offset 126, 15 lines modifiedOffset 126, 15 lines modified
  
126 ····int-to-byte·v0,·v0126 ····int-to-byte·v0,·v0
  
127 ····return·v0127 ····return·v0
128 .end·method128 .end·method
  
129 .method·public·getPayload()[B129 .method·public·getPayload()[B
130 ····.locals·4130 ····.locals·6
131 ····.annotation·system·Ldalvik/annotation/Throws;131 ····.annotation·system·Ldalvik/annotation/Throws;
132 ········value·=·{132 ········value·=·{
133 ············Lorg/eclipse/paho/client/mqttv3/MqttException;133 ············Lorg/eclipse/paho/client/mqttv3/MqttException;
134 ········}134 ········}
135 ····.end·annotation135 ····.end·annotation
  
136 ····.line·111136 ····.line·111
Offset 144, 45 lines modifiedOffset 144, 44 lines modified
144 ····invoke-direct·{v0},·Ljava/io/ByteArrayOutputStream;-><init>()V144 ····invoke-direct·{v0},·Ljava/io/ByteArrayOutputStream;-><init>()V
  
145 ····.line·112145 ····.line·112
146 ····new-instance·v1,·Ljava/io/DataOutputStream;146 ····new-instance·v1,·Ljava/io/DataOutputStream;
  
147 ····invoke-direct·{v1,·v0},·Ljava/io/DataOutputStream;-><init>(Ljava/io/OutputStream;)V147 ····invoke-direct·{v1,·v0},·Ljava/io/DataOutputStream;-><init>(Ljava/io/OutputStream;)V
  
148 ····const/4·v2,·0x0 
  
149 ····.line·113148 ····.line·113
150 ····:goto_0 
151 ····iget-object·v3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe;->names:[Ljava/lang/String;149 ····iget-object·v2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe;->names:[Ljava/lang/String;
  
152 ····array-length·v3,·v3150 ····array-length·v3,·v2
  
 151 ····const/4·v4,·0x0
  
 152 ····:goto_0
153 ····if-lt·v2,·v3,·:cond_0153 ····if-lt·v4,·v3,·:cond_0
  
154 ····.line·116154 ····.line·116
155 ····invoke-virtual·{v1},·Ljava/io/DataOutputStream;->flush()V155 ····invoke-virtual·{v1},·Ljava/io/DataOutputStream;->flush()V
  
156 ····.line·117156 ····.line·117
157 ····invoke-virtual·{v0},·Ljava/io/ByteArrayOutputStream;->toByteArray()[B157 ····invoke-virtual·{v0},·Ljava/io/ByteArrayOutputStream;->toByteArray()[B
  
158 ····move-result-object·v0158 ····move-result-object·v0
  
159 ····return-object·v0159 ····return-object·v0
  
160 ····.line·114160 ····.line·113
161 ····:cond_0161 ····:cond_0
162 ····iget-object·v3,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe;->names:[Ljava/lang/String;162 ····aget-object·v5,·v2,·v4
  
 163 ····.line·114
163 ····aget-object·v3,·v3,·v2 
  
164 ····invoke-static·{v1,·v3},·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe;->encodeUTF8(Ljava/io/DataOutputStream;Ljava/lang/String;)V164 ····invoke-static·{v1,·v5},·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe;->encodeUTF8(Ljava/io/DataOutputStream;Ljava/lang/String;)V
165 ····:try_end_0165 ····:try_end_0
166 ····.catch·Ljava/io/IOException;·{:try_start_0·..·:try_end_0}·:catch_0166 ····.catch·Ljava/io/IOException;·{:try_start_0·..·:try_end_0}·:catch_0
  
167 ····add-int/lit8·v2,·v2,·0x1167 ····add-int/lit8·v4,·v4,·0x1
  
168 ····goto·:goto_0168 ····goto·:goto_0
  
169 ····:catch_0169 ····:catch_0
170 ····move-exception·v0170 ····move-exception·v0
  
171 ····.line·119171 ····.line·119
1.97 KB
smali/org/eclipse/paho/client/mqttv3/internal/wire/MqttSuback.smali
    
Offset 104, 15 lines modifiedOffset 104, 15 lines modified
104 ····.line·50104 ····.line·50
105 ····new-array·v0,·v0,·[B105 ····new-array·v0,·v0,·[B
  
106 ····return-object·v0106 ····return-object·v0
107 .end·method107 .end·method
  
108 .method·public·toString()Ljava/lang/String;108 .method·public·toString()Ljava/lang/String;
109 ····.locals·3109 ····.locals·6
  
110 ····.line·54110 ····.line·54
111 ····new-instance·v0,·Ljava/lang/StringBuffer;111 ····new-instance·v0,·Ljava/lang/StringBuffer;
  
112 ····invoke-direct·{v0},·Ljava/lang/StringBuffer;-><init>()V112 ····invoke-direct·{v0},·Ljava/lang/StringBuffer;-><init>()V
  
113 ····.line·55113 ····.line·55
Offset 122, 40 lines modifiedOffset 122, 39 lines modified
  
122 ····invoke-virtual·{v0,·v1},·Ljava/lang/StringBuffer;->append(Ljava/lang/String;)Ljava/lang/StringBuffer;122 ····invoke-virtual·{v0,·v1},·Ljava/lang/StringBuffer;->append(Ljava/lang/String;)Ljava/lang/StringBuffer;
  
123 ····const-string·v1,·"·granted·Qos"123 ····const-string·v1,·"·granted·Qos"
  
124 ····invoke-virtual·{v0,·v1},·Ljava/lang/StringBuffer;->append(Ljava/lang/String;)Ljava/lang/StringBuffer;124 ····invoke-virtual·{v0,·v1},·Ljava/lang/StringBuffer;->append(Ljava/lang/String;)Ljava/lang/StringBuffer;
  
125 ····const/4·v1,·0x0 
  
126 ····.line·56125 ····.line·56
127 ····:goto_0 
128 ····iget-object·v2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSuback;->grantedQos:[I126 ····iget-object·v1,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSuback;->grantedQos:[I
  
129 ····array-length·v2,·v2127 ····array-length·v2,·v1
  
 128 ····const/4·v3,·0x0
  
 129 ····:goto_0
130 ····if-lt·v1,·v2,·:cond_0130 ····if-lt·v3,·v2,·:cond_0
  
131 ····.line·59131 ····.line·59
132 ····invoke-virtual·{v0},·Ljava/lang/StringBuffer;->toString()Ljava/lang/String;132 ····invoke-virtual·{v0},·Ljava/lang/StringBuffer;->toString()Ljava/lang/String;
  
133 ····move-result-object·v0133 ····move-result-object·v0
  
134 ····return-object·v0134 ····return-object·v0
  
 135 ····.line·56
135 ····:cond_0136 ····:cond_0
 137 ····aget·v4,·v1,·v3
136 ····const-string·v2,·"·" 
  
137 ····.line·57 
138 ····invoke-virtual·{v0,·v2},·Ljava/lang/StringBuffer;->append(Ljava/lang/String;)Ljava/lang/StringBuffer; 
  
139 ····iget-object·v2,·p0,·Lorg/eclipse/paho/client/mqttv3/internal/wire/MqttSuback;->grantedQos:[I138 ····const-string·v5,·"·"
  
140 ····aget·v2,·v2,·v1139 ····.line·57
 140 ····invoke-virtual·{v0,·v5},·Ljava/lang/StringBuffer;->append(Ljava/lang/String;)Ljava/lang/StringBuffer;
  
141 ····invoke-virtual·{v0,·v2},·Ljava/lang/StringBuffer;->append(I)Ljava/lang/StringBuffer;141 ····invoke-virtual·{v0,·v4},·Ljava/lang/StringBuffer;->append(I)Ljava/lang/StringBuffer;
  
142 ····add-int/lit8·v1,·v1,·0x1142 ····add-int/lit8·v3,·v3,·0x1
  
143 ····goto·:goto_0143 ····goto·:goto_0
144 .end·method144 .end·method
6.33 KB
smali/org/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence.smali
    
Offset 168, 15 lines modifiedOffset 168, 15 lines modified
168 ····:cond_0168 ····:cond_0
169 ····const/4·p1,·0x1169 ····const/4·p1,·0x1
  
170 ····return·p1170 ····return·p1
171 .end·method171 .end·method
  
172 .method·private·restoreBackups(Ljava/io/File;)V172 .method·private·restoreBackups(Ljava/io/File;)V
173 ····.locals·6173 ····.locals·8
174 ····.annotation·system·Ldalvik/annotation/Throws;174 ····.annotation·system·Ldalvik/annotation/Throws;
175 ········value·=·{175 ········value·=·{
176 ············Lorg/eclipse/paho/client/mqttv3/MqttPersistenceException;176 ············Lorg/eclipse/paho/client/mqttv3/MqttPersistenceException;
177 ········}177 ········}
178 ····.end·annotation178 ····.end·annotation
  
179 ····.line·277179 ····.line·277
Offset 188, 73 lines modifiedOffset 188, 67 lines modified
  
188 ····invoke-virtual·{p1,·v0},·Ljava/io/File;->listFiles(Ljava/io/FileFilter;)[Ljava/io/File;188 ····invoke-virtual·{p1,·v0},·Ljava/io/File;->listFiles(Ljava/io/FileFilter;)[Ljava/io/File;
  
189 ····move-result-object·v0189 ····move-result-object·v0
  
190 ····if-eqz·v0,·:cond_2190 ····if-eqz·v0,·:cond_2
  
191 ····const/4·v1,·0x0191 ····.line·283
 192 ····array-length·v1,·v0
  
192 ····const/4·v2,·0x0193 ····const/4·v2,·0x0
  
 194 ····const/4·v3,·0x0
193 ····.line·283 
194 ····:goto_0 
195 ····array-length·v3,·v0 
  
 195 ····:goto_0
196 ····if-lt·v2,·v3,·:cond_0196 ····if-lt·v3,·v1,·:cond_0
  
197 ····return-void197 ····return-void
  
198 ····.line·284 
199 ····:cond_0198 ····:cond_0
200 ····new-instance·v3,·Ljava/io/File;199 ····aget-object·v4,·v0,·v3
  
201 ····aget-object·v4,·v0,·v2200 ····.line·284
 201 ····new-instance·v5,·Ljava/io/File;
  
202 ····invoke-virtual·{v4},·Ljava/io/File;->getName()Ljava/lang/String;202 ····invoke-virtual·{v4},·Ljava/io/File;->getName()Ljava/lang/String;
  
203 ····move-result-object·v4203 ····move-result-object·v6
  
204 ····aget-object·v5,·v0,·v2204 ····invoke-virtual·{v4},·Ljava/io/File;->getName()Ljava/lang/String;
  
205 ····invoke-virtual·{v5},·Ljava/io/File;->getName()Ljava/lang/String;205 ····move-result-object·v7
  
206 ····move-result-object·v5206 ····invoke-virtual·{v7},·Ljava/lang/String;->length()I
  
207 ····invoke-virtual·{v5},·Ljava/lang/String;->length()I207 ····move-result·v7
  
208 ····move-result·v5208 ····add-int/lit8·v7,·v7,·-0x4
  
209 ····add-int/lit8·v5,·v5,·-0x4209 ····invoke-virtual·{v6,·v2,·v7},·Ljava/lang/String;->substring(II)Ljava/lang/String;
  
210 ····invoke-virtual·{v4,·v1,·v5},·Ljava/lang/String;->substring(II)Ljava/lang/String;210 ····move-result-object·v6
  
211 ····move-result-object·v4 
  
212 ····invoke-direct·{v3,·p1,·v4},·Ljava/io/File;-><init>(Ljava/io/File;Ljava/lang/String;)V211 ····invoke-direct·{v5,·p1,·v6},·Ljava/io/File;-><init>(Ljava/io/File;Ljava/lang/String;)V
  
213 ····.line·285212 ····.line·285
214 ····aget-object·v4,·v0,·v2 
  
215 ····invoke-virtual·{v4,·v3},·Ljava/io/File;->renameTo(Ljava/io/File;)Z213 ····invoke-virtual·{v4,·v5},·Ljava/io/File;->renameTo(Ljava/io/File;)Z
  
216 ····move-result·v4214 ····move-result·v6
  
217 ····if-nez·v4,·:cond_1215 ····if-nez·v6,·:cond_1
  
218 ····.line·287216 ····.line·287
219 ····invoke-virtual·{v3},·Ljava/io/File;->delete()Z217 ····invoke-virtual·{v5},·Ljava/io/File;->delete()Z
  
220 ····.line·288218 ····.line·288
221 ····aget-object·v4,·v0,·v2 
  
222 ····invoke-virtual·{v4,·v3},·Ljava/io/File;->renameTo(Ljava/io/File;)Z219 ····invoke-virtual·{v4,·v5},·Ljava/io/File;->renameTo(Ljava/io/File;)Z
  
223 ····:cond_1220 ····:cond_1
224 ····add-int/lit8·v2,·v2,·0x1221 ····add-int/lit8·v3,·v3,·0x1
  
225 ····goto·:goto_0222 ····goto·:goto_0
  
226 ····.line·280223 ····.line·280
227 ····:cond_2224 ····:cond_2
228 ····new-instance·p1,·Lorg/eclipse/paho/client/mqttv3/MqttPersistenceException;225 ····new-instance·p1,·Lorg/eclipse/paho/client/mqttv3/MqttPersistenceException;
  
Offset 262, 51 lines modifiedOffset 256, 52 lines modified
  
262 ····throw·p1256 ····throw·p1
263 .end·method257 .end·method
  
  
264 #·virtual·methods258 #·virtual·methods
265 .method·public·clear()V259 .method·public·clear()V
266 ····.locals·3260 ····.locals·4
267 ····.annotation·system·Ldalvik/annotation/Throws;261 ····.annotation·system·Ldalvik/annotation/Throws;
268 ········value·=·{262 ········value·=·{
269 ············Lorg/eclipse/paho/client/mqttv3/MqttPersistenceException;263 ············Lorg/eclipse/paho/client/mqttv3/MqttPersistenceException;
270 ········}264 ········}
271 ····.end·annotation265 ····.end·annotation
  
272 ····.line·300266 ····.line·300
273 ····invoke-direct·{p0},·Lorg/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence;->checkIsOpen()V267 ····invoke-direct·{p0},·Lorg/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence;->checkIsOpen()V
  
274 ····.line·301268 ····.line·301
275 ····invoke-direct·{p0},·Lorg/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence;->getFiles()[Ljava/io/File;269 ····invoke-direct·{p0},·Lorg/eclipse/paho/client/mqttv3/persist/MqttDefaultFilePersistence;->getFiles()[Ljava/io/File;
  
276 ····move-result-object·v0270 ····move-result-object·v0
  
277 ····const/4·v1,·0x0 
  
278 ····.line·302271 ····.line·302
279 ····:goto_0 
280 ····array-length·v2,·v0272 ····array-length·v1,·v0
  
 273 ····const/4·v2,·0x0
  
 274 ····:goto_0
281 ····if-lt·v1,·v2,·:cond_0275 ····if-lt·v2,·v1,·:cond_0
  
Max diff block lines reached; 2779/6333 bytes (43.88%) of diff not shown.
3.04 KB
smali/org/eclipse/paho/client/mqttv3/logging/JSR47Logger.smali
    
Offset 47, 79 lines modifiedOffset 47, 78 lines modified
47 ····.line·4147 ····.line·41
48 ····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/logging/JSR47Logger;->loggerName:Ljava/lang/String;48 ····iput-object·v0,·p0,·Lorg/eclipse/paho/client/mqttv3/logging/JSR47Logger;->loggerName:Ljava/lang/String;
  
49 ····return-void49 ····return-void
50 .end·method50 .end·method
  
51 .method·protected·static·dumpMemoryTrace47(Ljava/util/logging/Logger;)V51 .method·protected·static·dumpMemoryTrace47(Ljava/util/logging/Logger;)V
52 ····.locals·352 ····.locals·5
  
53 ····if-eqz·p0,·:cond_253 ····if-eqz·p0,·:cond_2
  
54 ····.line·26354 ····.line·263
55 ····invoke-virtual·{p0},·Ljava/util/logging/Logger;->getHandlers()[Ljava/util/logging/Handler;55 ····invoke-virtual·{p0},·Ljava/util/logging/Logger;->getHandlers()[Ljava/util/logging/Handler;
  
56 ····move-result-object·v056 ····move-result-object·v0
  
57 ····const/4·v1,·0x0 
  
58 ····.line·26557 ····.line·265
59 ····:goto_0 
60 ····array-length·v2,·v058 ····array-length·v1,·v0
  
 59 ····const/4·v2,·0x0
  
 60 ····:goto_0
61 ····if-lt·v1,·v2,·:cond_061 ····if-lt·v2,·v1,·:cond_0
  
62 ····.line·27462 ····.line·274
63 ····invoke-virtual·{p0},·Ljava/util/logging/Logger;->getParent()Ljava/util/logging/Logger;63 ····invoke-virtual·{p0},·Ljava/util/logging/Logger;->getParent()Ljava/util/logging/Logger;
  
64 ····move-result-object·p064 ····move-result-object·p0
  
65 ····invoke-static·{p0},·Lorg/eclipse/paho/client/mqttv3/logging/JSR47Logger;->dumpMemoryTrace47(Ljava/util/logging/Logger;)V65 ····invoke-static·{p0},·Lorg/eclipse/paho/client/mqttv3/logging/JSR47Logger;->dumpMemoryTrace47(Ljava/util/logging/Logger;)V
  
66 ····goto·:goto_166 ····goto·:goto_1
  
67 ····.line·26667 ····.line·265
68 ····:cond_068 ····:cond_0
69 ····aget-object·v2,·v0,·v169 ····aget-object·v3,·v0,·v2
  
 70 ····.line·266
70 ····instance-of·v2,·v2,·Ljava/util/logging/MemoryHandler;71 ····instance-of·v4,·v3,·Ljava/util/logging/MemoryHandler;
  
71 ····if-eqz·v2,·:cond_172 ····if-eqz·v4,·:cond_1
  
72 ····.line·26773 ····.line·267
73 ····aget-object·v2,·v0,·v1 
  
74 ····monitor-enter·v274 ····monitor-enter·v3
  
75 ····.line·26875 ····.line·268
76 ····:try_start_076 ····:try_start_0
77 ····aget-object·p0,·v0,·v177 ····move-object·p0,·v3
  
78 ····check-cast·p0,·Ljava/util/logging/MemoryHandler;78 ····check-cast·p0,·Ljava/util/logging/MemoryHandler;
  
79 ····.line·26979 ····.line·269
80 ····invoke-virtual·{p0},·Ljava/util/logging/MemoryHandler;->push()V80 ····invoke-virtual·{p0},·Ljava/util/logging/MemoryHandler;->push()V
  
81 ····.line·27081 ····.line·270
82 ····monitor-exit·v282 ····monitor-exit·v3
  
83 ····return-void83 ····return-void
  
84 ····:catchall_084 ····:catchall_0
85 ····move-exception·p085 ····move-exception·p0
  
86 ····.line·26786 ····.line·267
87 ····monitor-exit·v287 ····monitor-exit·v3
88 ····:try_end_088 ····:try_end_0
89 ····.catchall·{:try_start_0·..·:try_end_0}·:catchall_089 ····.catchall·{:try_start_0·..·:try_end_0}·:catchall_0
  
90 ····throw·p090 ····throw·p0
  
91 ····:cond_191 ····:cond_1
92 ····add-int/lit8·v1,·v1,·0x192 ····add-int/lit8·v2,·v2,·0x1
  
93 ····goto·:goto_093 ····goto·:goto_0
  
94 ····:cond_294 ····:cond_2
95 ····:goto_195 ····:goto_1
96 ····return-void96 ····return-void
97 .end·method97 .end·method
Offset 136, 26 lines modifiedOffset 135, 24 lines modified
136 ····.catch·Ljava/util/MissingResourceException;·{:try_start_0·..·:try_end_0}·:catch_0135 ····.catch·Ljava/util/MissingResourceException;·{:try_start_0·..·:try_end_0}·:catch_0
  
137 ····:catch_0136 ····:catch_0
138 ····return-object·p2137 ····return-object·p2
139 .end·method138 .end·method
  
140 .method·private·logToJsr47(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/ResourceBundle;Ljava/lang/String;[Ljava/lang/Object;Ljava/lang/Throwable;)V139 .method·private·logToJsr47(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/ResourceBundle;Ljava/lang/String;[Ljava/lang/Object;Ljava/lang/Throwable;)V
141 ····.locals·1140 ····.locals·0
  
142 ····const-string·p4,·"====="141 ····const-string·p4,·"====="
  
143 ····.line·193142 ····.line·193
144 ····invoke-virtual·{p6,·p4},·Ljava/lang/String;->indexOf(Ljava/lang/String;)I143 ····invoke-virtual·{p6,·p4},·Ljava/lang/String;->contains(Ljava/lang/CharSequence;)Z
  
145 ····move-result·p4144 ····move-result·p4
  
146 ····const/4·v0,·-0x1 
  
147 ····if-ne·p4,·v0,·:cond_0145 ····if-nez·p4,·:cond_0
  
148 ····.line·194146 ····.line·194
149 ····invoke-direct·{p0,·p5,·p6},·Lorg/eclipse/paho/client/mqttv3/logging/JSR47Logger;->getResourceMessage(Ljava/util/ResourceBundle;Ljava/lang/String;)Ljava/lang/String;147 ····invoke-direct·{p0,·p5,·p6},·Lorg/eclipse/paho/client/mqttv3/logging/JSR47Logger;->getResourceMessage(Ljava/util/ResourceBundle;Ljava/lang/String;)Ljava/lang/String;
  
150 ····move-result-object·p4148 ····move-result-object·p4
  
151 ····invoke-static·{p4,·p7},·Ljava/text/MessageFormat;->format(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;149 ····invoke-static·{p4,·p7},·Ljava/text/MessageFormat;->format(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
1.31 KB
smali/org/eclipse/paho/client/mqttv3/util/Strings.smali
    
Offset 191, 15 lines modifiedOffset 191, 15 lines modified
  
191 ····:cond_2191 ····:cond_2
192 ····:goto_1192 ····:goto_1
193 ····return·v1193 ····return·v1
194 .end·method194 .end·method
  
195 .method·public·static·equalsAny(Ljava/lang/CharSequence;[Ljava/lang/CharSequence;)Z195 .method·public·static·equalsAny(Ljava/lang/CharSequence;[Ljava/lang/CharSequence;)Z
196 ····.locals·5196 ····.locals·6
  
197 ····const/4·v0,·0x1197 ····const/4·v0,·0x1
  
198 ····const/4·v1,·0x0198 ····const/4·v1,·0x0
  
199 ····if-nez·p0,·:cond_0199 ····if-nez·p0,·:cond_0
  
Offset 211, 46 lines modifiedOffset 211, 46 lines modified
  
211 ····:cond_0211 ····:cond_0
212 ····const/4·v2,·0x0212 ····const/4·v2,·0x0
  
213 ····:goto_0213 ····:goto_0
214 ····if-eqz·p1,·:cond_3214 ····if-eqz·p1,·:cond_3
  
 215 ····.line·39
 216 ····array-length·v3,·p1
  
215 ····move·v3,·v2217 ····move·v4,·v2
  
216 ····const/4·v2,·0x0218 ····const/4·v2,·0x0
  
217 ····.line·39 
218 ····:goto_1219 ····:goto_1
219 ····array-length·v4,·p1220 ····if-lt·v2,·v3,·:cond_1
  
220 ····if-lt·v2,·v4,·:cond_1 
  
221 ····move·v2,·v3221 ····move·v2,·v4
  
222 ····goto·:goto_3222 ····goto·:goto_3
  
223 ····:cond_1223 ····:cond_1
224 ····if-nez·v3,·:cond_2224 ····aget-object·v5,·p1,·v2
  
 225 ····if-nez·v4,·:cond_2
225 ····.line·40 
226 ····aget-object·v3,·p1,·v2 
  
 226 ····.line·40
227 ····invoke-virtual·{v3,·p0},·Ljava/lang/Object;->equals(Ljava/lang/Object;)Z227 ····invoke-virtual·{v5,·p0},·Ljava/lang/Object;->equals(Ljava/lang/Object;)Z
  
228 ····move-result·v3228 ····move-result·v4
  
229 ····if-nez·v3,·:cond_2229 ····if-nez·v4,·:cond_2
  
230 ····const/4·v3,·0x0230 ····const/4·v4,·0x0
  
231 ····goto·:goto_2231 ····goto·:goto_2
  
232 ····:cond_2232 ····:cond_2
233 ····const/4·v3,·0x1233 ····const/4·v4,·0x1
  
234 ····:goto_2234 ····:goto_2
235 ····add-int/lit8·v2,·v2,·0x1235 ····add-int/lit8·v2,·v2,·0x1
  
236 ····goto·:goto_1236 ····goto·:goto_1
  
237 ····:cond_3237 ····:cond_3