46com/hazelcast/internal/partition/PartitionServiceProxyjava/lang/Object#com/hazelcast/core/PartitionServicePartitionServiceProxy.javaEcom/hazelcast/internal/partition/PartitionServiceProxy$PartitionProxyPartitionProxy8com/hazelcast/internal/partition/PartitionServiceProxy$1 .com/hazelcast/util/FutureUtil$ExceptionHandler com/hazelcast/util/FutureUtilExceptionHandler nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl;partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl; partitionMapLjava/util/Map;BLjava/util/Map; partitionSetLjava/util/Set;/Ljava/util/Set;randomLjava/util/Random;loggerLcom/hazelcast/logging/ILogger;exceptionHandler0Lcom/hazelcast/util/FutureUtil$ExceptionHandler;n(Lcom/hazelcast/spi/impl/NodeEngineImpl;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V()V "$ %java/util/Random' (%  *;(Lcom/hazelcast/internal/partition/PartitionServiceProxy;)V ", - ! /  1  3Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl5getPartitionCount()I 78 69com/hazelcast/util/MapUtil; createHashMap(I)Ljava/util/Map; => <?java/util/TreeSetA B%%com/hazelcast/spi/impl/NodeEngineImplD java/util/MapF java/util/SetH<(Lcom/hazelcast/internal/partition/PartitionServiceProxy;I)V "J Kadd(Ljava/lang/Object;)Z MN IOjava/lang/IntegerQvalueOf(I)Ljava/lang/Integer; ST RUput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; WX GYjava/util/Collections[unmodifiableMap (Ljava/util/Map;)Ljava/util/Map; ]^ \_  aunmodifiableSet (Ljava/util/Set;)Ljava/util/Set; cd \e  g getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; ij Ek  m partitionLcom/hazelcast/core/Partition;iIthis8Lcom/hazelcast/internal/partition/PartitionServiceProxy;partitionCountmapsetrandomPartitionKey()Ljava/lang/String;nextInt(I)I z{ (|toString(I)Ljava/lang/String; ~ R getPartitions()Ljava/util/Set;1()Ljava/util/Set; getPartition2(Ljava/lang/Object;)Lcom/hazelcast/core/Partition;getPartitionId(Ljava/lang/Object;)I 6get&(Ljava/lang/Object;)Ljava/lang/Object; Gcom/hazelcast/core/PartitionkeyLjava/lang/Object; partitionIdaddMigrationListener:(Lcom/hazelcast/core/MigrationListener;)Ljava/lang/String; 6migrationListener&Lcom/hazelcast/core/MigrationListener;removeMigrationListener(Ljava/lang/String;)Z 6registrationIdLjava/lang/String;addPartitionLostListenerC(Lcom/hazelcast/partition/PartitionLostListener;)Ljava/lang/String; 6partitionLostListener/Lcom/hazelcast/partition/PartitionLostListener;removePartitionLostListener 6 isClusterSafe()ZgetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; E-com/hazelcast/internal/cluster/ClusterService getMembers java/util/CollectionisEmpty java/util/ArrayListsize 8 (I)V " iterator()Ljava/util/Iterator; java/util/IteratorhasNext next()Ljava/lang/Object; com/hazelcast/core/Member getAddress()Lcom/hazelcast/nio/Address; Bcom/hazelcast/internal/partition/operation/SafeStateCheckOperation %getOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService; Ehz:core:partitionService@com/hazelcast/spi/impl/operationservice/InternalOperationServiceinvokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture; OgetMaxWaitTime 8 java/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit; returnWithDeadline~(Ljava/util/Collection;JLjava/util/concurrent/TimeUnit;Lcom/hazelcast/util/FutureUtil$ExceptionHandler;)Ljava/util/Collection; java/lang/Boolean booleanValue targetLcom/hazelcast/nio/Address; operationLcom/hazelcast/spi/Operation;future2Ljava/util/concurrent/Future;Ljava/util/concurrent/Future;memberLcom/hazelcast/core/Member;resultLjava/lang/Boolean;members3Ljava/util/Collection;Ljava/util/Collection;futuresJLjava/util/Collection;>; maxWaitTimeresults+Ljava/util/Collection; isMemberSafe(Lcom/hazelcast/core/Member;)Zjava/lang/Throwable java/lang/NullPointerException #Parameter member should not be null(Ljava/lang/String;)V " getLocalMember%()Lcom/hazelcast/instance/MemberImpl;  Eequals N isLocalMemberSafe   +com/hazelcast/spi/InternalCompletableFuture 4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object; " !#com/hazelcast/nio/Address%com/hazelcast/spi/Operation'java/lang/StringBuilder) *%*Error while querying member's safe state [,append-(Ljava/lang/String;)Ljava/lang/StringBuilder; ./ *0-(Ljava/lang/Object;)Ljava/lang/StringBuilder; .2 *3]5 ~y *7com/hazelcast/logging/ILogger9warning*(Ljava/lang/String;Ljava/lang/Throwable;)V ;< :=safeZtLjava/lang/Throwable; localMember-Lcom/hazelcast/spi/InternalCompletableFuture; nodeActive E FisMemberStateSafe H 6IforceLocalMemberToBeSafe#(JLjava/util/concurrent/TimeUnit;)Z %"java/lang/IllegalArgumentExceptionN O%getPartitionReplicaStateCheckerF()Lcom/hazelcast/internal/partition/impl/PartitionReplicaStateChecker; QR 6SBcom/hazelcast/internal/partition/impl/PartitionReplicaStateCheckerUtriggerAndWaitForReplicaSync WL VXtimeoutJunitgetNode()Lcom/hazelcast/instance/Node; ]^ E_com/hazelcast/instance/NodeagetState$()Lcom/hazelcast/instance/NodeState; cd be com/hazelcast/instance/NodeStateg SHUT_DOWN"Lcom/hazelcast/instance/NodeState; ij hk getProperties4()Lcom/hazelcast/spi/properties/HazelcastProperties; mn Eo*com/hazelcast/spi/properties/GroupPropertyqGRACEFUL_SHUTDOWN_MAX_WAIT0Lcom/hazelcast/spi/properties/HazelcastProperty; st ru0com/hazelcast/spi/properties/HazelcastPropertiesw getSeconds3(Lcom/hazelcast/spi/properties/HazelcastProperty;)I yz x{ access$000Y(Lcom/hazelcast/internal/partition/PartitionServiceProxy;)Lcom/hazelcast/logging/ILogger;x0 access$100~(Lcom/hazelcast/internal/partition/PartitionServiceProxy;)Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl; access$200a(Lcom/hazelcast/internal/partition/PartitionServiceProxy;)Lcom/hazelcast/spi/impl/NodeEngineImpl; SignatureCode StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTable InnerClasses SourceFile! !"#y*&*(Y)+* Y*.0*+2*,4,:>@:BYC:6. Y*L:PWVZW*`b*fh*+ln<E6GI0F?58@ A%C*D0E9FBGNHXIgFmLvMNORNop<1qrst*`ur0Zv9Qw0Zv9Qwxy<*+*4:}S st/*hX st\*4+=*bV ] ^ st r= *4+c st = *4+h st = *4+m st = *4+r st *2L+ +Y+M+N-@-::Y:*2:,W*>,*0:,::&E%Rw xy|*}E~NWdktw|f N&Wk E/ st *|Or@*k  *@  +Y*2M,+*+NY:*2-:$:6-:6*n*Y+-1+4618>G`c )>&(! )B$+4@GV`cehf V `?@e(ABstyC+e4\GIDh(?@L*G*4J   stKL0- YM OYP*G*4T-Y  !# 0st0Z[0\EK*2`fl@ st88*2pv| st}~/*n/ t/*4/ t/*2/ t