4E5com/hazelcast/concurrent/atomiclong/AtomicLongServicejava/lang/Object com/hazelcast/spi/ManagedServicecom/hazelcast/spi/RemoteService'com/hazelcast/spi/MigrationAwareService $com/hazelcast/spi/QuorumAwareService *com/hazelcast/spi/SplitBrainHandlerService AtomicLongService.java;atomicLongConstructorFunction(Lcom/hazelcast/util/ConstructorFunction;uLcom/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 "# 7:(Lcom/hazelcast/concurrent/atomiclong/AtomicLongService;)V 09 : %& < (# >&com/hazelcast/util/ContextMutexFactory@ A2 *+ C : ,& Fthis7Lcom/hazelcast/concurrent/atomiclong/AtomicLongService;getLongContainerM(Ljava/lang/String;)Lcom/hazelcast/concurrent/atomiclong/AtomicLongContainer;"com/hazelcast/util/ConcurrencyUtilLgetOrPutIfAbsentr(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object; NO MP7com/hazelcast/concurrent/atomiclong/AtomicLongContainerRnamecontainsAtomicLong(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 terminateZcreateDistributedObjectI(Ljava/lang/String;)Lcom/hazelcast/concurrent/atomiclong/AtomicLongProxy;com/hazelcast/spi/NodeEngineo getConfig()Lcom/hazelcast/config/Config; qr pscom/hazelcast/config/ConfigufindAtomicLongConfig;(Ljava/lang/String;)Lcom/hazelcast/config/AtomicLongConfig; wx vy getSplitBrainMergePolicyProvider9()Lcom/hazelcast/spi/merge/SplitBrainMergePolicyProvider; {| p}-com/hazelcast/internal/config/ConfigValidatorcheckBasicConfigd(Lcom/hazelcast/config/AbstractBasicConfig;Lcom/hazelcast/spi/merge/SplitBrainMergePolicyProvider;)V 3com/hazelcast/concurrent/atomiclong/AtomicLongProxyj(Ljava/lang/String;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/concurrent/atomiclong/AtomicLongService;)V 0 atomicLongConfig'Lcom/hazelcast/config/AtomicLongConfig;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()J Sjava/lang/LongvalueOf(J)Ljava/lang/Long; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; isEmpty Mcom/hazelcast/concurrent/atomiclong/operations/AtomicLongReplicationOperation(Ljava/util/Map;)V 0 com/hazelcast/spi/Operation container9Lcom/hazelcast/concurrent/atomiclong/AtomicLongContainer;containerEntrybLjava/util/Map$Entry;Ljava/util/Map$Entry;event-Lcom/hazelcast/spi/PartitionReplicationEvent;data3Ljava/util/Map;Ljava/util/Map; partitionIdIgetPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService; p;com/hazelcast/partition/strategy/StringPartitioningStrategygetPartitionKey&(Ljava/lang/String;)Ljava/lang/String; -com/hazelcast/spi/partition/IPartitionService(Ljava/lang/Object;)I partitionService/Lcom/hazelcast/spi/partition/IPartitionService; partitionKeycommitMigration)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; getQuorumNamegetOrPutSynchronized(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ContextMutexFactory;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object;  M ! " quorumNameprepareMergeRunnable()Ljava/lang/Runnable;@com/hazelcast/concurrent/atomiclong/AtomicLongContainerCollector'E(Lcom/hazelcast/spi/NodeEngine;Ljava/util/concurrent/ConcurrentMap;)V 0) (*run ,1 (-|(Lcom/hazelcast/concurrent/atomiclong/AtomicLongService;Lcom/hazelcast/concurrent/atomiclong/AtomicLongContainerCollector;)V 0/ 0 collectorBLcom/hazelcast/concurrent/atomiclong/AtomicLongContainerCollector;:(Ljava/lang/String;)Lcom/hazelcast/core/DistributedObject; mn 5 access$000W(Lcom/hazelcast/concurrent/atomiclong/AtomicLongService;)Lcom/hazelcast/spi/NodeEngine;x0 access$100 ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile! < !"#=$%&='(#=)*+,&=-./01>>*3*5Y68*Y*;=*5Y6?*AYBD*Y*EG?R;<C&D1E=S@ >HIJK>D*8+*=QS?V@HITUV>? *8+\?Z@ HI T]^>H*+`? _`@ HI./abc1>8 *8f? d e@  HIgh>=*j? ij@HIklmn>o)*`t+zM,*`~Y+*`*?noq@ )HI)T>S*8+W*?+W?v wx@HIT>5?|@HI>Q+YM+>*8:E::* S:,Ƹ̹W, Y,ذA H G?.  =IS_ps@H_I'T=3HIwrB=3w>g*`M+N,-? @*HIT >"++= *+  A ? !@ "HI">"++= *+  A ? !@ "HI"  >5*8M,,N*- ,ޱA !?"+14@*"T5HI5&B &>u!*?+*D*G!M,#,A C? @ !HI!T$!%&>Z(Y*`*8+L+.Y*+1?@HI23Am4>0*+6?4@ HI78>/*`?4@ 9I:>#?4;1># Y3#?9C" D