'初始化'

admin

2021-06-29 0a03971cf8b1ca89f171946ecce8e8e6435b9ec5

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
Êþº¾4
g
¹º
¹    »¼
¹    ½¾    ¿À
Á    Ã
ÄÅ
ÆÇ    ÈÉ
Ê    Ë
ÄÌ    Í
ÎÏ    Р   Ñ    ÒÓÔÕ
ÖÓ×Ø
¹Ù
ÚÛ
Ü
ÁÝ
ÞÓß
à
áÓâ
ãäå
*¹æçèéèê
Çëìí
1î
ïð
ñ
ò
Äó
ôõ
Æóö    ÷øùúû
=üÓý
þ
Îÿ    



Ó


 
 


    
 
 
I

Î

 
 

    





=


 
ã

 



logger
Lorg/slf4j/Logger;
appId
Ljava/lang/String;
option
(Lcom/huawei/push/messaging/HuaweiOption;
appsLock
Ljava/lang/Object;
    instances
Ljava/util/Map;
    Signature
HLjava/util/Map<Ljava/lang/String;Lcom/huawei/push/messaging/HuaweiApp;>;
services
LLjava/util/Map<Ljava/lang/String;Lcom/huawei/push/messaging/HuaweiService;>;
tokenRefresher
*Lcom/huawei/push/messaging/TokenRefresher;
scheduledExecutor
/Ljava/util/concurrent/ScheduledExecutorService;
 threadManager
)Lcom/huawei/push/messaging/ThreadManager;
    executors

HuaweiExecutors
InnerClasses
9Lcom/huawei/push/messaging/ThreadManager$HuaweiExecutors;
deleted
+Ljava/util/concurrent/atomic/AtomicBoolean;
lock
<init>
+(Lcom/huawei/push/messaging/HuaweiOption;)V
Code
LineNumberTable
LocalVariableTable
this
%Lcom/huawei/push/messaging/HuaweiApp;
 StackMapTableÕ

    getOption
*()Lcom/huawei/push/messaging/HuaweiOption;
getAppId
()Ljava/lang/String;
getInstance
O(Lcom/huawei/push/messaging/HuaweiOption;)Lcom/huawei/push/messaging/HuaweiApp;
app
¾

 initializeApp
getApps
()Ljava/util/List;
9()Ljava/util/List<Lcom/huawei/push/messaging/HuaweiApp;>;
getAllAppIds
    allAppIds
Ljava/util/Set;
sortedIdList
Ljava/util/List;
LocalVariableTypeTable
#Ljava/util/Set<Ljava/lang/String;>;
$Ljava/util/List<Ljava/lang/String;>;


&()Ljava/util/List<Ljava/lang/String;>;
delete
()V

e
Ljava/io/IOException;
service
)Lcom/huawei/push/messaging/HuaweiService;
valueChanged

Zö
checkNotDeleted
errorMessage
singleScheduledExecutorService
1()Ljava/util/concurrent/ScheduledExecutorService;
getThreadFactory
&()Ljava/util/concurrent/ThreadFactory;
getScheduledExecutorService
schedule
>(Ljava/lang/Runnable;JJ)Ljava/util/concurrent/ScheduledFuture;
runnable
Ljava/lang/Runnable;
initialDelay

J
period
A(Ljava/lang/Runnable;JJ)Ljava/util/concurrent/ScheduledFuture<*>;

addService
,(Lcom/huawei/push/messaging/HuaweiService;)V

getService
=(Ljava/lang/String;)Lcom/huawei/push/messaging/HuaweiService;
id
startTokenRefresher
clearInstancesForTest
<clinit>

SourceFile
HuaweiApp.javat˜
java/util/HashMapda
)java/util/concurrent/atomic/AtomicBooleanqr
java/lang/Objects_
HuaweiOption must not be null

 
!\]

"
#
$€Z[
(com/huawei/push/messaging/TokenRefreshert
%fg
&
'jk
(
)
*lp^_`a
+
,
-
#com/huawei/push/messaging/HuaweiAppˆƒ
.
/
java/lang/StringBuilder
HuaweiApp with id 
0
1
 already exists!
2
3
!tu
4
5´˜‚ƒ
6
7
8
9
:
java/util/HashSet
;
<
=

>
?
@
A

B
/
java/util/ArrayListt
C
D
E
F
G
H~
I
J
K
L˜
java/io/IOExceptionXY
Fail to close httpClient
M
N
O
'com/huawei/push/messaging/HuaweiService
P˜
Q˜
R˜
S
Thi
U
V˜
W
-
!HuaweiApp with id {0} was deleted
X
Y
Z
,
? ˜
1com/huawei/push/messaging/HuaweiScheduledExecutor¤¥
huawei-scheduled-workert
[¢£¦£
\
]
^
_
`
a
service already exists
b˜
<
c—˜
d
e
f
7com/huawei/push/messaging/ThreadManager$HuaweiExecutors
&com/huawei/push/messaging/HuaweiOption
java/lang/String
java/lang/Throwable
 java/util/Set
java/util/Iterator
#com/huawei/push/util/ValidatorUtils
 checkArgument
(ZLjava/lang/Object;)V
 getCredential
.()Lcom/huawei/push/messaging/HuaweiCredential;
*com/huawei/push/messaging/HuaweiCredential
((Lcom/huawei/push/messaging/HuaweiApp;)V
getThreadManager
+()Lcom/huawei/push/messaging/ThreadManager;
'com/huawei/push/messaging/ThreadManager
getHuaweiExecutors
`(Lcom/huawei/push/messaging/HuaweiApp;)Lcom/huawei/push/messaging/ThreadManager$HuaweiExecutors;
 java/util/Map
get
&(Ljava/lang/Object;)Ljava/lang/Object;
containsKey
(Ljava/lang/Object;)Z
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString

checkState
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
values
()Ljava/util/Collection;
'com/google/common/collect/ImmutableList
copyOf
A(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableList;
java/util/Collection
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
add
(Ljava/util/Collection;)V
java/util/Collections
sort
(Ljava/util/List;)V
 compareAndSet
(ZZ)Z
 getHttpClient
3()Lorg/apache/http/impl/client/CloseableHttpClient;
/org/apache/http/impl/client/CloseableHttpClient
close
org/slf4j/Logger
debug
(Ljava/lang/String;)V
destroy
clear
stop
releaseHuaweiExecutors
a(Lcom/huawei/push/messaging/HuaweiApp;Lcom/huawei/push/messaging/ThreadManager$HuaweiExecutors;)V
-java/util/concurrent/ScheduledExecutorService
shutdown
remove
java/text/MessageFormat
format
9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
9(Ljava/util/concurrent/ThreadFactory;Ljava/lang/String;)V
java/util/concurrent/TimeUnit
MILLISECONDS
Ljava/util/concurrent/TimeUnit;
scheduleWithFixedDelay
](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
getId
start
2()Lcom/google/common/collect/UnmodifiableIterator;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!XYZ[\]^_`a
bcda
befgBhijklpqrs_tu
v×d*·
*»Y·µ*»Y·µ*»Y·
µ    +Ƨ
¸*+µ*+¶ ¶µ*»Y*·µ*+¶µ**´*¶µ±w.D5?B%E3F8GCHOIWJcKxdyzd\]
{ÿ-|}@

~
v/

*´°w
Nx
yz
€
v/

*´°w
Rx
yz    ‚ƒ
vÆ1*¶ ¶L²YM²+¹ÀN-Æ-,ð*¸,ð:,ÿ"*#)**.*w^_`ab#f*gx „z1\])Z[
{!þ#…†|ÿ}…†
‡    ˆƒ
v
Ft*¶ ¶L²YN²+¹šJ²+¹š§»Y·¶ +¶ !¶ ¶"¸#»Y*·$M²+,¹%W,¶&§*¸'M-ç
:-ÿ,°hkkokw*
prstFuOvZwayf|r}x4O„zf„zt\]lZ[
r„z{Fþ*…†@
5ÿ}…|†ÿ}…†
‡ÿ}…|    ‰Šv^²YK²¹(
¸)*ðL*Ã+¿w‚ƒ„{
ÿ
†
‡b‹    ŒŠv
X»*Y·+K²YL²¹(
¹,
M,¹-
™,¹.
ÀN*-¶/¹0W§ÿâ+ç
:+ÿ»1Y*·2L+¸3+°?BBFBw&    ‹Œ/Ž:=I‘R’V“x /„zPŽR
‘P’R“
{þ”†•ú D‡úb–
—˜
v
ÏÅ*´    YLÂ*´¶4=š+ñ*¶5¶6¶7*¶5¶ ¶8¶7§N²:;¹<*´¹(
¹,
N-¹-
™-¹.
À=:¶>§ÿç*´¹?
*´¶@*´**´¶A*´BÆ*´B¹C
*
µB+ç
:+ÿ²YL²*¶/¹DW+ç
:+ÿ±/29ž›žž¢ž«º½½Á½w^žŸ ¤"¥/¨2¦3§=ª`«e¬h­q®x°„±‹²”³™µ¥·«¸¸¹Äºx*3
™š`›œˆžÅyz{4
ý†
YŸ
ü•úú0D‡úÿ|†
‡ú ˜
vq%E½Y*¶/S¸FL*´¶Gš§+¸#±wÀÁ$Âx%yz¡[
{
ü…@
¢£
v 9*´BÇ0*´    YLÂ*·H*´BÇ*»IY*¶JK·LµB+çM+Ã,¿*´B°,//2/wÈÉÊËÌ*Î4Ðx
9yz{ü*†D‡ú
¤¥
v2

*´¶M°w
Ôx
yz¦£
v/

*·N°w
Øx
yz§¨vY*·O+ ²P¹Q°w
Üx*yz©ª
«¬­¬b®¯°
v®?*´    YMÂ*·H*´+¶R¹š§S¸*´+¶R+¹%W,çN,Ã-¿±699<9wãäå%æ4ç>èx?yz?›œ
{ü†@
X‡ú±²
vƒ*´    YMÂ*´+¹À=,ðN,Ã-¿wëìíxyz³[
{
ÿ|…†
‡
´˜
v‚*´    YLÂ*·H*´¶T+çM+Ã,¿±wôõö÷øx
yz{ÿ|†
‡ú    µ˜
v¯B²YK²¹(
¸)¶UL+¹-
™+¹.
ÀM,¶V§ÿé²¹?
*çN*Ã-¿±9<<?<wüþ(ÿ,
/

7
A
x
(„z{ý†•úL‡ú¶˜
v=¸W³:»Y·
³»Y·³±
w)/2·¸o

mÎn