43Icom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongServiceOLjava/lang/Object;Lcom/hazelcast/cp/internal/datastructures/spi/RaftManagedService;Lcom/hazelcast/cp/internal/datastructures/spi/RaftRemoteService;Lcom/hazelcast/cp/internal/RaftNodeLifecycleAwareService;Lcom/hazelcast/cp/internal/raft/SnapshotAwareService;java/lang/Object?com/hazelcast/cp/internal/datastructures/spi/RaftManagedService>com/hazelcast/cp/internal/datastructures/spi/RaftRemoteService7com/hazelcast/cp/internal/RaftNodeLifecycleAwareService 3com/hazelcast/cp/internal/raft/SnapshotAwareService RaftAtomicLongService.javajava/util/Map$Entry java/util/MapEntry SERVICE_NAMELjava/lang/String;hz:raft:atomicLongService atomicLongsLjava/util/Map;Ljava/util/Map;Lcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLong;>;destroyedLongsLjava/util/Set;hLjava/util/Set;>; nodeEngineLcom/hazelcast/spi/NodeEngine; raftService'Lcom/hazelcast/cp/internal/RaftService;!(Lcom/hazelcast/spi/NodeEngine;)V()V "$ %&java/util/concurrent/ConcurrentHashMap' (%  *java/util/Collections, newSetFromMap (Ljava/util/Map;)Ljava/util/Set; ./ -0  2  4thisKLcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongService;init7(Lcom/hazelcast/spi/NodeEngine;Ljava/util/Properties;)V hz:core:raft:com/hazelcast/spi/NodeEngine< getService&(Ljava/lang/String;)Ljava/lang/Object; >? =@%com/hazelcast/cp/internal/RaftServiceB ! D propertiesLjava/util/Properties;resetshutdown(Z)Vclear K$ L terminateZonCPSubsystemRestart java/util/SetQ RL takeSnapshotk(Lcom/hazelcast/cp/CPGroupId;J)Lcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongSnapshot; com/hazelcast/util/PreconditionsV checkNotNull&(Ljava/lang/Object;)Ljava/lang/Object; XY WZjava/util/HashMap\ ]%values()Ljava/util/Collection; _` ajava/util/Collectionciterator()Ljava/util/Iterator; ef dgjava/util/IteratorihasNext()Z kl jmnext()Ljava/lang/Object; op jqBcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongsgroupId()Lcom/hazelcast/cp/CPGroupId; uv twequals(Ljava/lang/Object;)Z yz {name()Ljava/lang/String; }~ tvalue()J tjava/lang/LongvalueOf(J)Ljava/lang/Long; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; java/util/HashSet % Rg%com/hazelcast/cp/internal/util/Tuple2element1Ljava/lang/Object; element2 add z RJcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongSnapshot!(Ljava/util/Map;Ljava/util/Set;)V "  atomicLongDLcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLong;tupleWLcom/hazelcast/cp/internal/util/Tuple2;'Lcom/hazelcast/cp/internal/util/Tuple2;Lcom/hazelcast/cp/CPGroupId; commitIndexJlongs3Ljava/util/Map; destroyed#Ljava/util/Set;restoreSnapshotl(Lcom/hazelcast/cp/CPGroupId;JLcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongSnapshot;)VgetLongs()Ljava/lang/Iterable; java/lang/Iterable ggetKey p java/lang/StringgetValue p  longValue ofM(Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/cp/internal/util/Tuple2; 2(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;J)V " t getDestroyed()Ljava/util/Set; vale9Ljava/util/Map$Entry;Ljava/util/Map$Entry;snapshotLLcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLongSnapshot;destroyRaftObject1(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;)Zremove Y keyonRaftGroupDestroyed(Lcom/hazelcast/cp/CPGroupId;)VkeySet  $ jitermLjava/util/Iterator;>;Ljava/util/Iterator;onRaftNodeSteppedDown getAtomicLongt(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;)Lcom/hazelcast/cp/internal/datastructures/atomiclong/RaftAtomicLong;contains z R?com/hazelcast/spi/exception/DistributedObjectDestroyedExceptionjava/lang/StringBuilder % AtomicLong[append-(Ljava/lang/String;)Ljava/lang/StringBuilder; ] is already destroyed!toString ~ (Ljava/lang/String;)V " get Y 1(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;)V " t createProxy4(Ljava/lang/String;)Lcom/hazelcast/core/IAtomicLong;java/lang/ExceptionwithoutDefaultGroupName&(Ljava/lang/String;)Ljava/lang/String;  C createRaftGroupForProxy;(Ljava/lang/String;)Lcom/hazelcast/cp/internal/RaftGroupId;   CMcom/hazelcast/cp/internal/datastructures/atomiclong/proxy/RaftAtomicLongProxygetObjectNameForProxy  Cl(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/cp/internal/RaftGroupId;Ljava/lang/String;Ljava/lang/String;)V "  com/hazelcast/util/ExceptionUtilrethrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;  'Lcom/hazelcast/cp/internal/RaftGroupId;Ljava/lang/Exception; proxyName:(Ljava/lang/String;)Lcom/hazelcast/core/DistributedObject;  "2(Lcom/hazelcast/cp/CPGroupId;JLjava/lang/Object;)V %1(Lcom/hazelcast/cp/CPGroupId;J)Ljava/lang/Object; TU ( ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile! *++B !"#,k#*&*(Y)+*(Y)13*+5-A:<=B"C.#67#89,R*+;ACE- GH. 67FGH$,+-L. 67IJ,B *+M- P Q. 67 NOP$,E*+M*3S-U VW. 67TU,+[W]Y^:*+bh:n3rt:x+|WɻY:*3:n+r:+|WѻY/j6Rj.-2 [\]4^@_UaXcadefhj.H4!67uaI0 aI,W +[W:nIr::7*++ǻtY+ʹWι:n"r:*3+ǹWڱ/jO j(-* op'q3rBs^tavwxy.R3+}B'7}67u0 '7,$+,N*3-W*+-/ "@-}~.*$67$u$}0 ,B*+M,n,,rN+-|*3-W,ѱ/ j.-""-8>A.*"oB67Bu30"o3,5-.67u,l+[W,[W+,N*3-#YY,*+-t:tY+,:*+-W/=+t-*  =LQ\i.4l67lul}\L 0 \,&+ L*E+MY*5,++M, /`- !.*u!&67& A!,0*+#-2. 67A$,6 *+ &-2.  67AT',1*+ )-2. 671  +2