Êþº¾4 
jíî
í	ïð
ñò
óô
õö	÷øù	ú
ûü	ýþ
ÿ	



ÿ	


í	



	
	
ø
	











	
	











¿
¿

)
¾




 


!
"
/
#
$
/
%
/
&
,
'

(

)

*

+
,	
-

.
/

0
1

2
3
4
9
'	
5	
6

7
8

0
9
:


;ø
<
=
>
?H
@
B
Ó
D
Ó
E




F

GH
H

I	
J
K

L

M
N
û
O

P
Q
R
Wÿ

P
S

T
U

V
W

X
Y

X
Z

[ø
\
]

X
^ø
_
`	
a

b

c

A
d	
e
f
g
h

i
j

k
l
m

n

o

A
p

q

A
r
s
s
t

u
v

X
w

x
y

0
z
{
y
'ø
|
}
~

y
€

ServiceManagerState
InnerClasses
StoppedGuard
AwaitHealthGuard
monitor
+Lcom/google/common/util/concurrent/Monitor;
servicesByState
'Lcom/google/common/collect/SetMultimap;
	Signature
State
…Lcom/google/common/collect/SetMultimap<Lcom/google/common/util/concurrent/Service$State;Lcom/google/common/util/concurrent/Service;>;
RuntimeInvisibleAnnotations
8Lcom/google/errorprone/annotations/concurrent/GuardedBy;
value
states
$Lcom/google/common/collect/Multiset;
WLcom/google/common/collect/Multiset<Lcom/google/common/util/concurrent/Service$State;>;

startupTimers
Ljava/util/Map;
^Ljava/util/Map<Lcom/google/common/util/concurrent/Service;Lcom/google/common/base/Stopwatch;>;
ready

Z
transitioned
numberOfServices

I
awaitHealthGuard
‚
Guard
1Lcom/google/common/util/concurrent/Monitor$Guard;
stoppedGuard
	listeners
5Lcom/google/common/util/concurrent/ListenerCallQueue;
ƒ
Listener
rLcom/google/common/util/concurrent/ListenerCallQueue<Lcom/google/common/util/concurrent/ServiceManager$Listener;>;
<init>
2(Lcom/google/common/collect/ImmutableCollection;)V
Code
LineNumberTable
LocalVariableTable
this
FLcom/google/common/util/concurrent/ServiceManager$ServiceManagerState;
services
/Lcom/google/common/collect/ImmutableCollection;
LocalVariableTypeTable
\Lcom/google/common/collect/ImmutableCollection<Lcom/google/common/util/concurrent/Service;>;
_(Lcom/google/common/collect/ImmutableCollection<Lcom/google/common/util/concurrent/Service;>;)V
tryStartTiming
.(Lcom/google/common/util/concurrent/Service;)V
	stopwatch
"Lcom/google/common/base/Stopwatch;
service
+Lcom/google/common/util/concurrent/Service;

StackMapTable
„
	markReady
()V
servicesInBadStates
Ljava/util/List;
=Ljava/util/List<Lcom/google/common/util/concurrent/Service;>;
…
†
addListener
](Lcom/google/common/util/concurrent/ServiceManager$Listener;Ljava/util/concurrent/Executor;)V
listener
;Lcom/google/common/util/concurrent/ServiceManager$Listener;
executor
Ljava/util/concurrent/Executor;
awaitHealthy
#(JLjava/util/concurrent/TimeUnit;)V
timeout

J
unit
Ljava/util/concurrent/TimeUnit;

Exceptions
awaitStopped
2()Lcom/google/common/collect/ImmutableSetMultimap;
entry
Entry
Ljava/util/Map$Entry;
builder
‡
Builder
8Lcom/google/common/collect/ImmutableSetMultimap$Builder;
sLjava/util/Map$Entry<Lcom/google/common/util/concurrent/Service$State;Lcom/google/common/util/concurrent/Service;>;
–Lcom/google/common/collect/ImmutableSetMultimap$Builder<Lcom/google/common/util/concurrent/Service$State;Lcom/google/common/util/concurrent/Service;>;
()Lcom/google/common/collect/ImmutableSetMultimap<Lcom/google/common/util/concurrent/Service$State;Lcom/google/common/util/concurrent/Service;>;
startupTimes
*()Lcom/google/common/collect/ImmutableMap;
	loadTimes
dLjava/util/Map$Entry<Lcom/google/common/util/concurrent/Service;Lcom/google/common/base/Stopwatch;>;
dLjava/util/List<Ljava/util/Map$Entry<Lcom/google/common/util/concurrent/Service;Ljava/lang/Long;>;>;
g()Lcom/google/common/collect/ImmutableMap<Lcom/google/common/util/concurrent/Service;Ljava/lang/Long;>;
transitionService
(Lcom/google/common/util/concurrent/Service;Lcom/google/common/util/concurrent/Service$State;Lcom/google/common/util/concurrent/Service$State;)V
from
1Lcom/google/common/util/concurrent/Service$State;
to
enqueueStoppedEvent
enqueueHealthyEvent
enqueueFailedEvent
dispatchListenerEvents
checkHealthy
	exception
!Ljava/lang/IllegalStateException;

SourceFile
ServiceManager.java¥º
)com/google/common/util/concurrent/Monitor†‡
/com/google/common/util/concurrent/Service$State
ˆ
‰
‹
Œ



‘
’ˆ‰
“
”
•‘
–
—
˜“”
Ucom/google/common/util/concurrent/ServiceManager$ServiceManagerState$AwaitHealthGuard¥
™›ž
Qcom/google/common/util/concurrent/ServiceManager$ServiceManagerState$StoppedGuardŸž
3com/google/common/util/concurrent/ListenerCallQueue ¡
š
›
œ™š
â
ž
Ÿ
 º
¡
¢
£
 com/google/common/base/Stopwatch
¤
¥
¦
§
¨º˜—–—
©
ª
«ˆÎ
¬
­
®
¯
°
±
²
³
´
)com/google/common/util/concurrent/Service
µ
¶
·
¸
"java/lang/IllegalArgumentException
¹
º
»
¼
œ
java/lang/StringBuilder¥
½
YServices started transitioning asynchronously before the ServiceManager was constructed: 
¾
¿
À
Á¥
ÂÀ
Ã
Ä
Åèº
Æ
Ç
%java/util/concurrent/TimeoutException
Èâ
É
Ê
Ë
Ì
Í
Î
Ï
Ð
Ñ
]Timeout waiting for the services to become healthy. The following services have not started: 
Òâ
Óâ
Ô
Ê
Õ
Ö
×
STimeout waiting for the services to stop. The following services have not stopped: Ò
Ø
Ù
Ú
Û
¯
Ü
java/util/Map$Entry
Ý
´
Þ
<com/google/common/util/concurrent/ServiceManager$NoOpService
NoOpService
¦
ß
‘Î
à
á
â
Ú
ã
´
ä
²
å
æË
ç
è
é
º
ê
ë
ì
í
î
ï
Fcom/google/common/util/concurrent/ServiceManager$ServiceManagerState$1
ð
ñ
ò
ó
ô
õ
ö
÷
ø
ù
£
ú
ûçº
ü
ý
;Service %s not at the expected location in the state map %s
þ
ÿ
¦
ý
.Service %s in the state map unexpectedly at %sâ

¥
Started {0} in {1}.
java/lang/Object	
æ²
åºäº
Fcom/google/common/util/concurrent/ServiceManager$ServiceManagerState$2¥
²
;It is incorrect to execute listeners with the monitor held.
þº
java/lang/IllegalStateException
OExpected to be healthy after starting. The following services are not running: 
¢
>com/google/common/util/concurrent/ServiceManager$FailedService

FailedService¥²
Dcom/google/common/util/concurrent/ServiceManager$ServiceManagerState
/com/google/common/util/concurrent/Monitor$Guard
9com/google/common/util/concurrent/ServiceManager$Listener
java/lang/Throwable
java/util/List
java/util/Iterator
6com/google/common/collect/ImmutableSetMultimap$Builder
)com/google/common/collect/MultimapBuilder
enumKeys
MultimapBuilderWithKeys
V(Ljava/lang/Class;)Lcom/google/common/collect/MultimapBuilder$MultimapBuilderWithKeys;
Acom/google/common/collect/MultimapBuilder$MultimapBuilderWithKeys
linkedHashSetValues
SetMultimapBuilder
@()Lcom/google/common/collect/MultimapBuilder$SetMultimapBuilder;
<com/google/common/collect/MultimapBuilder$SetMultimapBuilder
build
)()Lcom/google/common/collect/SetMultimap;
%com/google/common/collect/SetMultimap
keys
&()Lcom/google/common/collect/Multiset;
com/google/common/collect/Maps
newIdentityHashMap
()Ljava/util/IdentityHashMap;
I(Lcom/google/common/util/concurrent/ServiceManager$ServiceManagerState;)V
-com/google/common/collect/ImmutableCollection
size
()I
NEW
putAll
)(Ljava/lang/Object;Ljava/lang/Iterable;)Z
enter

java/util/Map
get
&(Ljava/lang/Object;)Ljava/lang/Object;

createStarted
$()Lcom/google/common/base/Stopwatch;
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
leave
com/google/common/collect/Lists
newArrayList
()Ljava/util/ArrayList;
.com/google/common/collect/ImmutableSetMultimap
values
1()Lcom/google/common/collect/ImmutableCollection;
iterator
2()Lcom/google/common/collect/UnmodifiableIterator;
hasNext
()Z
next
()Ljava/lang/Object;
state
3()Lcom/google/common/util/concurrent/Service$State;
add
(Ljava/lang/Object;)Z
java/lang/String
valueOf
&(Ljava/lang/Object;)Ljava/lang/String;
length
(I)V
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
(Ljava/lang/String;)V
4(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
enterWhenUninterruptibly
4(Lcom/google/common/util/concurrent/Monitor$Guard;)V
waitForUninterruptibly
T(Lcom/google/common/util/concurrent/Monitor$Guard;JLjava/util/concurrent/TimeUnit;)Z
STARTING
&com/google/common/collect/ImmutableSet
of
N(Ljava/lang/Object;Ljava/lang/Object;)Lcom/google/common/collect/ImmutableSet;
!com/google/common/base/Predicates
in
:(Ljava/util/Collection;)Lcom/google/common/base/Predicate;
#com/google/common/collect/Multimaps

filterKeys
r(Lcom/google/common/collect/SetMultimap;Lcom/google/common/base/Predicate;)Lcom/google/common/collect/SetMultimap;

TERMINATED
FAILED
java/util/EnumSet
5(Ljava/lang/Enum;Ljava/lang/Enum;)Ljava/util/EnumSet;
not
F(Lcom/google/common/base/Predicate;)Lcom/google/common/base/Predicate;
:()Lcom/google/common/collect/ImmutableSetMultimap$Builder;
entries
()Ljava/util/Set;

java/util/Set
()Ljava/util/Iterator;
getValue
0com/google/common/util/concurrent/ServiceManager
O(Ljava/util/Map$Entry;)Lcom/google/common/collect/ImmutableSetMultimap$Builder;
newArrayListWithCapacity
(I)Ljava/util/ArrayList;
entrySet
getKey
	isRunning
java/util/concurrent/TimeUnit
MILLISECONDS
elapsed
"(Ljava/util/concurrent/TimeUnit;)J
java/lang/Long
(J)Ljava/lang/Long;
immutableEntry
;(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map$Entry;
"com/google/common/collect/Ordering
natural
&()Lcom/google/common/collect/Ordering;

onResultOf
G(Lcom/google/common/base/Function;)Lcom/google/common/collect/Ordering;
java/util/Collections
sort
)(Ljava/util/List;Ljava/util/Comparator;)V
&com/google/common/collect/ImmutableMap
copyOf
>(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableMap;
$com/google/common/base/Preconditions
checkNotNull

checkArgument
(Z)V
remove
'(Ljava/lang/Object;Ljava/lang/Object;)Z

checkState
:(ZLjava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
RUNNING
	compareTo
(Ljava/lang/Enum;)I
stop

access$200
()Ljava/util/logging/Logger;
java/util/logging/Level
FINE
Ljava/util/logging/Level;
java/util/logging/Logger
log
A(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V
"com/google/common/collect/Multiset
count
(Ljava/lang/Object;)I

access$300
Event
=()Lcom/google/common/util/concurrent/ListenerCallQueue$Event;
enqueue
>(Lcom/google/common/util/concurrent/ListenerCallQueue$Event;)V

access$400
t(Lcom/google/common/util/concurrent/ServiceManager$ServiceManagerState;Lcom/google/common/util/concurrent/Service;)V
isOccupiedByCurrentThread
(ZLjava/lang/Object;)V
dispatch
equalTo
6(Ljava/lang/Object;)Lcom/google/common/base/Predicate;
#(Ljava/lang/Object;)Ljava/util/Set;

addSuppressed
(Ljava/lang/Throwable;)V
9com/google/common/util/concurrent/ListenerCallQueue$Event0j
†‡ˆ‰ŠŒ
Ž
s†‘Š’
Ž
s†“”Š•
Ž
s†–—

Ž
s†˜—

Ž
s†™š›žŸž ¡
Š¤¥¦§æl*·
*»Y·µ*¸¶¶µ	**´	¹

µ*¸µ
*»Y*·µ*»Y*·µ*»Y·µ*+¶µ*´	²+¹W±¨:
»
½
¿
Á#
Â+
Ä,
Å2
à>
ôJU
]k©lª«l¬­
®
l¬¯
Š°±²
§°<*´¶*´
+¹ÀM,Ç*´
+¸¹W*´¶ §
N*´¶ -¿±
'1¨&	'.19;© ³´<ª«<µ¶
·'I¸	¹º
§
C‘*´¶*´!š*µ"§g¸#L*¶$¶%¶&M,¹'
™$,¹(
À)N-¹*
²¥+-¹+W§ÿٻ,Y+¸-MY,¸-¶.`»/Z_·01¶2,¶2¶3·4¿*´¶ §:*´¶ ¿±z„„†„¨:&(*-.8/D0L2O3z9:„9:;© 8µ¶`»¼
ԻǨ
`»½
·ý¾¿&úú*I¸ÀÁ
§L
*´+,¶5±¨
>	?© 
ª«
ÂÃ

ÄÅƺ
§{$*´*´¶6*¶7*´¶ §
L*´¶ +¿±
¨BDFGF!G#H©
$ª«·Y¸	Æǧôr*´¶*´*´-¶8šC»9Y*´	²²:¸;¸<¸=¸-:]¸-¶.`»/Z_·0>¶2¶2¶3·?¿*¶7*´¶ §:*´¶ ¿±[eege¨*
KMN%QWS[UbVeUnVqW© rª«rÈÉ
rÊË·
ûWM¸Ì
9ͺ
§E
*´*´¶6*´¶ ±¨Z[\©
ª«Íǧïq*´¶*´*´-¶8šF»9Y*´	²@²A¸B¸<¸C¸=¸-:S¸-¶.`»/Z_·0D¶2¶2¶3·?¿*´¶ §:*´¶ ¿±Zddfd¨&	_ab%eZhaidhmipj© qª«qÈÉ
qÊË·
ûZI¸Ì
9ˆÎ§
	]¸EL*´¶*´	¹F
¹G
M,¹'
™",¹(
ÀHN-¹I
ÁJš	+-¶KW§ÿÛ*´¶ §:*´¶ ¿+¶L°BLLNL¨.mnp-q9r?tBvIwLvUwXx© -ÏÑ]ª«YÒÕ
®-ÏÖYÒ×
·ýÓ¿$úI¸ŠØÙÚ§
Ÿ£*´¶*´
¹M
¸NL*´
¹O
¹G
M,¹'
™M,¹(
ÀHN-¹P
À):-¹I
À:¶Qš"ÁJš+²R¶S¸T¸U¹+W§ÿ°*´¶ §:*´¶ ¿+¸V»WY*·X¶Y¸Z+¸[°v€€‚€¨F}6‚AƒL„\…s‡v‰}Š€‰‰ŠŒ‹˜Ž›‹ž•©>A2µ¶L'³´6=ÏÑlÛ¼
£ª«ŒÛ¼
® 6=ÏÜlÛÝ
ŒÛÝ
·$ý#¾¿ûOúÿ	

¸ü¾ŠÞßà
§*
+¸\W,-¥§¸]*´¶*µ!*´"š*´¶ *¶^±*´	,+¹_`+,¸a*´	-+¹bc+-¸a*´
+¹À:Ǹ:*´
+¹W-²d¶e›0¶Q™(¶fW+ÁJš¸g²hi½jY+SYS¶k-²A¦*+¶l*´²d¹m*´ 
*¶n§'*´²@¹m*´²A¹m`*´ *¶o*´¶ *¶^§:*´¶ *¶^¿±%

1ü






¨Ž#¥¦§©ª%Õ,×0«1®7¯@®C³I´R³U¹dºi¼n½{¿Á“šòɹʾÍÑÐØÑøÒüÕ
×
Ø

Õ
×
Ø
Ù©4d˜³´
ª«
µ¶

áâ
ãâ·
@
!üI6ú#M¸äº
§9
*´¸p¶q±¨
Ü
Ý©
ª«åº
§9
*´¸r¶q±¨
à
á©
ª«æ²
§I*´»sY*+·t¶q±¨
ä𩪫µ¶
çº
§a
*´¶uš§v¸w*´¶x±¨ôõô÷ø©
ª«·@
躧õ„*´²d¹m*´Ÿs»yY*´	²d¸z¸C¸=¸-MO,¸-¶.`»/Z_·0{¶2,¶2¶3·|L*´	²A¹}¹G
M,¹'
™,¹(
À)N+»~Y-·¶€§ÿá+¿±¨"üýM
r~ƒ© rµ¶M6éê
„ª«·ý_y¿ú!ú

Ž
s†ëìƒz
A‚„…sW)‹@œ	¢
A£	H
Ð	Ó
ÔJ
A
C~
A
~óñ
Š	õñ
Ž