4-Gcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefServiceMLjava/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 RaftAtomicRefService.javajava/util/Map$Entry java/util/MapEntry SERVICE_NAMELjava/lang/String;hz:raft:atomicRefService atomicRefsLjava/util/Map;Ljava/util/Map;Lcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRef;>; destroyedRefsLjava/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  4thisILcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefService;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)V terminateZonCPSubsystemRestartclear N$ O java/util/SetQ RO takeSnapshoti(Lcom/hazelcast/cp/CPGroupId;J)Lcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefSnapshot; 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 jq@com/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefsgroupId()Lcom/hazelcast/cp/CPGroupId; uv twequals(Ljava/lang/Object;)Z yz {name()Ljava/lang/String; }~ tget(()Lcom/hazelcast/nio/serialization/Data; tput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; java/util/HashSet % Rg%com/hazelcast/cp/internal/util/Tuple2element1Ljava/lang/Object; element2 add z RHcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefSnapshot!(Ljava/util/Map;Ljava/util/Set;)V " refBLcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRef;tupleWLcom/hazelcast/cp/internal/util/Tuple2;'Lcom/hazelcast/cp/internal/util/Tuple2;Lcom/hazelcast/cp/CPGroupId; commitIndexJrefsILjava/util/Map; destroyed#Ljava/util/Set;restoreSnapshotj(Lcom/hazelcast/cp/CPGroupId;JLcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefSnapshot;)VgetRefs()Ljava/lang/Iterable; java/lang/Iterable ggetKey p java/lang/StringgetValue p $com/hazelcast/nio/serialization/DataofM(Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/cp/internal/util/Tuple2; W(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;Lcom/hazelcast/nio/serialization/Data;)V " t getDestroyed()Ljava/util/Set; val&Lcom/hazelcast/nio/serialization/Data;eOLjava/util/Map$Entry;Ljava/util/Map$Entry;snapshotJLcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRefSnapshot;onRaftGroupDestroyed(Lcom/hazelcast/cp/CPGroupId;)VkeySet remove $ jitermLjava/util/Iterator;>;Ljava/util/Iterator;onRaftNodeSteppedDowndestroyRaftObject1(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;)Z Y key getAtomicRefr(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;)Lcom/hazelcast/cp/internal/datastructures/atomicref/RaftAtomicRef;contains z R?com/hazelcast/spi/exception/DistributedObjectDestroyedExceptionjava/lang/StringBuilder %AtomicReference[append-(Ljava/lang/String;)Ljava/lang/StringBuilder; ] is already destroyed!toString ~ (Ljava/lang/String;)V " Y 1(Lcom/hazelcast/cp/CPGroupId;Ljava/lang/String;)V " t atomicRef createProxy9(Ljava/lang/String;)Lcom/hazelcast/core/IAtomicReference;java/lang/ExceptionwithoutDefaultGroupName&(Ljava/lang/String;)Ljava/lang/String;  CcreateRaftGroupForProxy;(Ljava/lang/String;)Lcom/hazelcast/cp/internal/RaftGroupId;  CKcom/hazelcast/cp/internal/datastructures/atomicref/proxy/RaftAtomicRefProxy getObjectNameForProxy   C l(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'B;=>C"D(#67#89&R*+;ACE' HI( 67FGH$&+'M( 67IJ&5'Q(67KLM$&E*+P*3S'U VW( 67TU&+[W]Y^:*+bh:n0rt:x+|W̻Y:*3:n+r:+|WѻY)j3Rj.'2 [\]4^@_RaUc^defhj(H467u^I* ^I&T +[W:nFr:::*++tY+ùWǹ:n"r:*3+Wڱ)jL j('* op'q3r?s[t^vwxy(R3(}?'4}67u* '4&B*+M,n,,rN+-|*3-W,ѱ) j.'"}~"-8>A(*"oB67Bu3*"o3&5'(67u&$+,N*3-W*+-) "@'(*$67$u$}* &l+[W,[W+,N*3-#YY,*+-t:tY+,:*+-W)=+t'*  =LQ\i(4l67lul}\L * \&&+L*E+ M Y*5,++M, )`' !(*u!&67&A&0*+'3( 67A&6 *+  '3(  67AT!&1*+ #'3( 67+  %,