4A?com/hazelcast/concurrent/atomicreference/AtomicReferenceServicejava/lang/Object com/hazelcast/spi/ManagedServicecom/hazelcast/spi/RemoteService'com/hazelcast/spi/MigrationAwareService $com/hazelcast/spi/QuorumAwareService *com/hazelcast/spi/SplitBrainHandlerService AtomicReferenceService.javaFcom/hazelcast/concurrent/atomicreference/AtomicReferenceService$MergerMergerAcom/hazelcast/concurrent/atomicreference/AtomicReferenceService$2Acom/hazelcast/concurrent/atomicreference/AtomicReferenceService$1java/util/Map$Entry java/util/MapEntry SERVICE_NAMELjava/lang/String;hz:impl:atomicReferenceService NULL_OBJECTLjava/lang/Object; containers$Ljava/util/concurrent/ConcurrentMap;{Ljava/util/concurrent/ConcurrentMap;"atomicReferenceConstructorFunction(Lcom/hazelcast/util/ConstructorFunction;Lcom/hazelcast/util/ConstructorFunction;quorumConfigCacheJLjava/util/concurrent/ConcurrentMap;quorumConfigCacheMutexFactory(Lcom/hazelcast/util/ContextMutexFactory;quorumConfigConstructorNLcom/hazelcast/util/ConstructorFunction; nodeEngineLcom/hazelcast/spi/NodeEngine;()V 01 2&java/util/concurrent/ConcurrentHashMap4 52 "# 7D(Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceService;)V 09 : %& < (# >&com/hazelcast/util/ContextMutexFactory@ A2 *+ C : ,& FthisALcom/hazelcast/concurrent/atomicreference/AtomicReferenceService;getReferenceContainerW(Ljava/lang/String;)Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceContainer;"com/hazelcast/util/ConcurrencyUtilLgetOrPutIfAbsentr(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object; NO MPAcom/hazelcast/concurrent/atomicreference/AtomicReferenceContainerRnamecontainsReferenceContainer(Ljava/lang/String;)Z"java/util/concurrent/ConcurrentMapW containsKey(Ljava/lang/Object;)Z YZ X[init7(Lcom/hazelcast/spi/NodeEngine;Ljava/util/Properties;)V ./ _ propertiesLjava/util/Properties;resetclear d1 Xeshutdown(Z)V c1 i terminateZcreateDistributedObjectS(Ljava/lang/String;)Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceProxy;com/hazelcast/spi/NodeEngineo getConfig()Lcom/hazelcast/config/Config; qr pscom/hazelcast/config/ConfigufindAtomicReferenceConfig@(Ljava/lang/String;)Lcom/hazelcast/config/AtomicReferenceConfig; wx vy getSplitBrainMergePolicyProvider9()Lcom/hazelcast/spi/merge/SplitBrainMergePolicyProvider; {| p}-com/hazelcast/internal/config/ConfigValidatorcheckBasicConfigd(Lcom/hazelcast/config/AbstractBasicConfig;Lcom/hazelcast/spi/merge/SplitBrainMergePolicyProvider;)V =com/hazelcast/concurrent/atomicreference/AtomicReferenceProxyt(Ljava/lang/String;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceService;)V 0 atomicReferenceConfig,Lcom/hazelcast/config/AtomicReferenceConfig;destroyDistributedObject(Ljava/lang/String;)Vremove&(Ljava/lang/Object;)Ljava/lang/Object; XbeforeMigration.(Lcom/hazelcast/spi/PartitionMigrationEvent;)VpartitionMigrationEvent+Lcom/hazelcast/spi/PartitionMigrationEvent;prepareReplicationOperationL(Lcom/hazelcast/spi/PartitionReplicationEvent;)Lcom/hazelcast/spi/Operation;+com/hazelcast/spi/PartitionReplicationEventgetReplicaIndex()I java/util/HashMap 2getPartitionId entrySet()Ljava/util/Set; X java/util/Setiterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next()Ljava/lang/Object; getKey java/lang/String(Ljava/lang/String;)I getValue get(()Lcom/hazelcast/nio/serialization/Data; Sput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; isEmpty Wcom/hazelcast/concurrent/atomicreference/operations/AtomicReferenceReplicationOperation(Ljava/util/Map;)V 0 com/hazelcast/spi/OperationatomicReferenceContainerCLcom/hazelcast/concurrent/atomicreference/AtomicReferenceContainer;value&Lcom/hazelcast/nio/serialization/Data;containerEntrylLjava/util/Map$Entry;Ljava/util/Map$Entry;event-Lcom/hazelcast/spi/PartitionReplicationEvent;dataILjava/util/Map;Ljava/util/Map; partitionIdIcommitMigration)com/hazelcast/spi/PartitionMigrationEventgetMigrationEndpoint1()Lcom/hazelcast/spi/partition/MigrationEndpoint; -com/hazelcast/spi/partition/MigrationEndpointSOURCE/Lcom/hazelcast/spi/partition/MigrationEndpoint; getNewReplicaIndex clearPartitionReplica(I)V thresholdReplicaIndexrollbackMigration DESTINATION getCurrentReplicaIndex keySet  X 1 (Ljava/util/Iterator;Ljava/util/Iterator;getPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService;  p ;com/hazelcast/partition/strategy/StringPartitioningStrategy getPartitionKey&(Ljava/lang/String;)Ljava/lang/String;    -com/hazelcast/spi/partition/IPartitionService(Ljava/lang/Object;)I  partitionService/Lcom/hazelcast/spi/partition/IPartitionService; partitionKey getQuorumNamegetOrPutSynchronized(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ContextMutexFactory;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object;  M !  quorumNameprepareMergeRunnable()Ljava/lang/Runnable;Jcom/hazelcast/concurrent/atomicreference/AtomicReferenceContainerCollector#E(Lcom/hazelcast/spi/NodeEngine;Ljava/util/concurrent/ConcurrentMap;)V 0% $&run (1 $)(Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceService;Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceContainerCollector;)V 0+ , collectorLLcom/hazelcast/concurrent/atomicreference/AtomicReferenceContainerCollector;:(Ljava/lang/String;)Lcom/hazelcast/core/DistributedObject; mn 1 access$000a(Lcom/hazelcast/concurrent/atomicreference/AtomicReferenceService;)Lcom/hazelcast/spi/NodeEngine;x0 access$100 ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile! 8 !"#9$%&9'(#9)*+,&9-./01:>*3*5Y68*Y*;=*5Y6?*AYBD*Y*EG;T<>E&F1G=U< >HIJK:D*8+*=QS;X<HITUV:? *8+\;\< HI T]^:H*+`; ab< HI./abc1:8 *8f; f g<  HIgh:=*j; kl<HIklmn:o)*`t+zM,*`~Y+*`*;pqs< )HI)T:S*8+W*?+W;x yz<HIT:5;~<HI:` +YM+>*8:F::*!S::,W, Y,Ұ= I G;2  =IS_fqt<R_f I(T=4HIxs>=4x:"++= *+= ; !< "HI":"++= *+= ; !< "HI":5*8M,,N*- ,ޱ= !;"+14<*"T5HI5&> &:g*` M+N,-; <*HIT :u!*?+*D*GM,,= C; < !HI!T !!":Z$Y*`*8'L+*Y*+-;<HI./Am0:0*+2;5< HI34:/*`;5< 5I6:;571:# Y3;:?" @