4]#com/hazelcast/map/impl/MapKeyLoaderjava/lang/ObjectMapKeyLoader.java%com/hazelcast/map/impl/MapKeyLoader$56com/hazelcast/map/impl/MapKeyLoader$LoadFinishedFutureLoadFinishedFuture)com/hazelcast/map/impl/MapKeyLoader$State State(com/hazelcast/map/impl/MapKeyLoader$RoleRole%com/hazelcast/map/impl/MapKeyLoader$4%com/hazelcast/map/impl/MapKeyLoader$3%com/hazelcast/map/impl/MapKeyLoader$2%com/hazelcast/map/impl/MapKeyLoader$1java/util/Map$Entry java/util/MapEntryLOADING_TRIGGER_DELAYJloggerLcom/hazelcast/logging/ILogger;mapNameLjava/lang/String; opService$Lcom/hazelcast/spi/OperationService;partitionService/Lcom/hazelcast/spi/partition/IPartitionService;clusterService/Lcom/hazelcast/internal/cluster/ClusterService;toDataLcom/hazelcast/core/IFunction;XLcom/hazelcast/core/IFunction; execService$Lcom/hazelcast/spi/ExecutionService;delayedTrigger7Lcom/hazelcast/util/scheduler/CoalescingDelayedTrigger;maxSizePerNodeImaxBatchmapNamePartition partitionId hasBackupZkeyLoadFinished8Lcom/hazelcast/map/impl/MapKeyLoader$LoadFinishedFuture;operationProvider7Lcom/hazelcast/map/impl/operation/MapOperationProvider;role!Lcom/hazelcast/util/StateMachine;MLcom/hazelcast/util/StateMachine;stateNLcom/hazelcast/util/StateMachine;(Ljava/lang/String;Lcom/hazelcast/spi/OperationService;Lcom/hazelcast/spi/partition/IPartitionService;Lcom/hazelcast/internal/cluster/ClusterService;Lcom/hazelcast/spi/ExecutionService;Lcom/hazelcast/core/IFunction;)V(Ljava/lang/String;Lcom/hazelcast/spi/OperationService;Lcom/hazelcast/spi/partition/IPartitionService;Lcom/hazelcast/internal/cluster/ClusterService;Lcom/hazelcast/spi/ExecutionService;Lcom/hazelcast/core/IFunction;)V()V AD Ejava/lang/BooleanGvalueOf(Z)Ljava/lang/Boolean; IJ HK=(Ljava/lang/Boolean;Lcom/hazelcast/map/impl/MapKeyLoader$1;)V AM N 89 PNONE*Lcom/hazelcast/map/impl/MapKeyLoader$Role; RS Tcom/hazelcast/util/StateMachineVof3(Ljava/lang/Enum;)Lcom/hazelcast/util/StateMachine; XY WZSENDER \S ]RECEIVER _S ` SENDER_BACKUP bS cwithTransitionT(Ljava/lang/Enum;Ljava/lang/Enum;[Ljava/lang/Enum;)Lcom/hazelcast/util/StateMachine; ef Wg <= i NOT_LOADED+Lcom/hazelcast/map/impl/MapKeyLoader$State; kl mLOADING ol pLOADED rl s ?= u "# w $% y &' { () } *+  -. com/hazelcast/logging/Logger getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; ! this%Lcom/hazelcast/map/impl/MapKeyLoader;ps serializestartInitialLoadQ(Lcom/hazelcast/map/impl/mapstore/MapStoreContext;I)Ljava/util/concurrent/Future; 52 com/hazelcast/core/IFunctionapply&(Ljava/lang/Object;)Ljava/lang/Object; $com/hazelcast/nio/serialization/Data-com/hazelcast/spi/partition/IPartitionServicegetPartitionId)(Lcom/hazelcast/nio/serialization/Data;)I 42  calculateRole,()Lcom/hazelcast/map/impl/MapKeyLoader$Role;  nextOrStay(Ljava/lang/Enum;)V Wnext Y Wcom/hazelcast/logging/ILoggerisFinestEnabled()Z java/lang/StringBuilder EstartInitialLoad invoked append-(Ljava/lang/String;)Ljava/lang/StringBuilder; getStateMessage()Ljava/lang/String; toString finest(Ljava/lang/String;)V 3$SwitchMap$com$hazelcast$map$impl$MapKeyLoader$Role[I ordinal()I sendKeysQ(Lcom/hazelcast/map/impl/mapstore/MapStoreContext;Z)Ljava/util/concurrent/Future; triggerLoading()Ljava/util/concurrent/Future; mapStoreContext1Lcom/hazelcast/map/impl/mapstore/MapStoreContext;newRoleisPartitionOwner(I)Z 67  getPartition+(I)Lcom/hazelcast/spi/partition/IPartition; &com/hazelcast/spi/partition/IPartitiongetReplicaAddress(I)Lcom/hazelcast/nio/Address; -com/hazelcast/internal/cluster/ClusterService getMember@(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/instance/MemberImpl; com/hazelcast/core/Member localMember 'com/hazelcast/map/impl/MapKeyLoaderUtil assignRole/(ZZZ)Lcom/hazelcast/map/impl/MapKeyLoader$Role;  partition(Lcom/hazelcast/spi/partition/IPartition;firstReplicaAddressLcom/hazelcast/nio/Address;memberLcom/hazelcast/core/Member;isMapNamePartitionisMapNamePartitionFirstReplicaT(Lcom/hazelcast/map/impl/mapstore/MapStoreContext;Z)Ljava/util/concurrent/Future<*>;isDone  *(Lcom/hazelcast/map/impl/MapKeyLoader$1;)V A  hz:map-loadAllKeys Z(Lcom/hazelcast/map/impl/MapKeyLoader;Lcom/hazelcast/map/impl/mapstore/MapStoreContext;Z)V A "com/hazelcast/spi/ExecutionServicesubmitP(Ljava/lang/String;Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;  asCompletableFutureF(Ljava/util/concurrent/Future;)Lcom/hazelcast/core/ICompletableFuture;  %com/hazelcast/core/ICompletableFutureandThen)(Lcom/hazelcast/core/ExecutionCallback;)V  sent2Ljava/util/concurrent/Future;Ljava/util/concurrent/Future;replaceExistingValues((Lcom/hazelcast/map/impl/MapKeyLoader;)V A$ %execute)(Ljava/lang/String;Ljava/lang/Runnable;)V '( )loadingFinishedCallback(()Lcom/hazelcast/core/ExecutionCallback;=()Lcom/hazelcast/core/ExecutionCallback; %updateLocalKeyLoadStatus(Ljava/lang/Throwable;)V7com/hazelcast/map/impl/operation/KeyLoadStatusOperation1*(Ljava/lang/String;Ljava/lang/Throwable;)V A3 24is$(Ljava/lang/Enum;[Ljava/lang/Enum;)Z 67 W8hz:impl:mapService:"com/hazelcast/spi/OperationService<createInvocationBuilderW(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InvocationBuilder; >? =@#com/hazelcast/spi/InvocationBuilderBsetReplicaIndex((I)Lcom/hazelcast/spi/InvocationBuilder; DE CFinvoke/()Lcom/hazelcast/spi/InternalCompletableFuture; HI CJcom/hazelcast/spi/OperationLtLjava/lang/Throwable;opLcom/hazelcast/spi/Operation; startLoading trackLoading(ZLjava/lang/Throwable;)V setResult(Ljava/lang/Object;)Z UV W lastBatch exceptiontriggerLoadingWithDelay /0 \ %5com/hazelcast/util/scheduler/CoalescingDelayedTrigger_  a=(Lcom/hazelcast/spi/ExecutionService;JJLjava/lang/Runnable;)V Ac `dexecuteWithDelay fD `grunnableLjava/lang/Runnable;shouldDoInitialLoadsendKeysInBatches5(Lcom/hazelcast/map/impl/mapstore/MapStoreContext;Z)Vjava/lang/ExceptionnsendKeysInBatches invoked pgetMemberPartitionsMap()Ljava/util/Map; rs tsize v w/com/hazelcast/map/impl/mapstore/MapStoreContexty loadAllKeys()Ljava/lang/Iterable; {| z}java/lang/Iterableiterator()Ljava/util/Iterator;  com/hazelcast/util/IterableUtilmapH(Ljava/util/Iterator;Lcom/hazelcast/core/IFunction;)Ljava/util/Iterator;   12 limit+(Ljava/util/Iterator;I)Ljava/util/Iterator;  java/util/Iteratorjava/lang/Throwable toPartitionO(Lcom/hazelcast/spi/partition/IPartitionService;)Lcom/hazelcast/core/IFunction;   32  toBatches  java/util/ArrayList Ejava/util/ListhasNext  ()Ljava/lang/Object;   sendBatch"(Ljava/util/Map;Z)Ljava/util/List;  addAll(Ljava/util/Collection;)Z  com/hazelcast/util/FutureUtil waitForever(Ljava/util/Collection;)V  sendKeyLoadCompleted(ILjava/lang/Throwable;)V  java/io/Closeablecom/hazelcast/nio/IOUtil closeResource(Ljava/io/Closeable;)V  batch\Ljava/util/Map;>;Ljava/util/Map;allKeys(Ljava/lang/Iterable;Ljava/lang/Iterable;dataKeys;Ljava/util/Iterator; mapMaxSizepartitionsAndKeysfLjava/util/Iterator;>;batchesrLjava/util/Iterator;>;>;futures/Ljava/util/List;Ljava/util/List;caughtLjava/lang/Exception; clusterSizekeys(Ljava/util/Iterator; loadError(Ljava/util/Map;>;Z)Ljava/util/List;entrySet()Ljava/util/Set;   java/util/Set w(I)V A  getKey  java/lang/IntegerintValue  getValue   :; 5com/hazelcast/map/impl/operation/MapOperationProvidercreateLoadAllOperationT(Ljava/lang/String;Ljava/util/List;Z)Lcom/hazelcast/map/impl/operation/MapOperation;  invokeOnPartition_(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InternalCompletableFuture;  =add V 8Ljava/util/List;/Lcom/hazelcast/map/impl/operation/MapOperation;futureALcom/hazelcast/spi/InternalCompletableFuture;-Lcom/hazelcast/spi/InternalCompletableFuture;ebLjava/util/Map$Entry;>;Ljava/util/Map$Entry;entriessLjava/util/Set;>;>;Ljava/util/Set;java/util/concurrent/Future >com/hazelcast/map/impl/operation/KeyLoadStatusOperationFactory 4invokeOnAllPartitionsG(Ljava/lang/String;Lcom/hazelcast/spi/OperationFactory;)Ljava/util/Map;  =senderBackupStatussenderBackupFuture senderStatus senderFuture setMaxBatch setMaxSizemaxSize setHasBackup(Z)VsetMapOperationProvider:(Lcom/hazelcast/map/impl/operation/MapOperationProvider;)VisKeyLoadFinishedpromoteToLoadedOnMigrationon partitionId=!(I)Ljava/lang/StringBuilder; # $ on &getThisAddress()Lcom/hazelcast/nio/Address; () *-(Ljava/lang/Object;)Ljava/lang/StringBuilder; , - role=/ state=1 access$200 lm 4x0x1x2 access$3009(Lcom/hazelcast/map/impl/MapKeyLoader;)Ljava/lang/String; access$400M(Lcom/hazelcast/map/impl/MapKeyLoader;)Lcom/hazelcast/core/ExecutionCallback; +, = access$500((Lcom/hazelcast/map/impl/MapKeyLoader;)I access$600K(Lcom/hazelcast/map/impl/MapKeyLoader;)Lcom/hazelcast/spi/OperationService; access$700=(Lcom/hazelcast/map/impl/MapKeyLoader;Ljava/lang/Throwable;)V /0 Ejava/util/concurrent/TimeUnitHSECONDSLjava/util/concurrent/TimeUnit; JK ILtoMillis(J)J PQ IR SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFile! !"#$%&'()*+T,-./0123242526789:;<=T>?=T@ABU^*F* YLOQ*U[U^YaSYdShd^hj*n[nq hqt YnShtq hv*+x*,z*-|*~***VFx1>DUhu{WH"#$%'()-.+X ,TCU***|**x*N*j-*vqW*"*Y*ù-.'""*+Ӱ*װ*QY e"V. "'/:FeW*52'rSUf*|*<**=>*:6*|*::*~: >Y @@V* !,;ERW_WH;$ER fX7G7!E7UE*Q9* Y Q* Y*+N*-*Q*QY@V -@W*- "EEE#7X - !TUn/*Q#* Y Q* Y*&**QY*V   *W /+,U3 Y*.V!W  T-/0UW2Y*x+5M*0*jd9*z;,*AGKW*z;,*AKWY AMV8 <%=A?VAW WWNO JPQRU2*j^*vq 9*Q*vqW*+ӰY VM OP R+TW 222#7TSTUJ,*vt,*Q,XW.*QLXW*vt 9*vqWYV"bcdeg-i>jIlW JJY7JZO[DU{ .*]"Y*^L*`Y*bb+e]*]hY&Vrsz&}-~Wij.kUS*jd96*j^W*vq 9*vnW*QLXW*vn 9YDV-8DW SlmU1*#*Yq*ù*|ux>::+~::*:*h6 :*|:  *: Y:  ! :  * W *J§?::**§: *  AoAY|,F z!'zo_zzV  ,;>AIR]ejs W Iy]ee]2A 6 - #7;2>AOXH Iy]eA 6 - >ZoU +NY-:-:[:6:**x: *z; :  WYaV* 4COas}Wf C:52O.aP s  4I#7| mX>O.s  4I| mTU\YN2Y*x,5:*z;*AGK:-W*:52Y*x,5:*z;*AGK:-W-*z;Y*x,WYxM V6 )1 : F Tgox|WRT$Qo "2ZOQ1e"X ZoU>*V %&W32U>*V /0W2U>*V 89W67U>*+V <=W:;U2*QVDW  DUI*vqW*vtWVL MNW UnDY"*%'*~+.0*j.2*v.ðVQW D3 UE*+5VIW 6787Zo9:U/*xVIW 6;<U/*>VIW 6?@U/*VIW 6ABU/*zVIW 6CDU:*+FVIW67OGDU% MNSbVK[J     @@ \