4=com/hazelcast/internal/nearcache/impl/DefaultNearCacheManagerjava/lang/Object1com/hazelcast/internal/nearcache/NearCacheManagerDefaultNearCacheManager.javaIcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager$StorageTask StorageTaskIcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager$PreloadTask  PreloadTask scheduler!Lcom/hazelcast/spi/TaskScheduler; classLoaderLjava/lang/ClassLoader; properties2Lcom/hazelcast/spi/properties/HazelcastProperties;serializationService6Lcom/hazelcast/spi/serialization/SerializationService;mutexLjava/lang/Object;preloadTaskFuturesLjava/util/Queue;9Ljava/util/Queue; nearCacheMap$Ljava/util/concurrent/ConcurrentMap;dLjava/util/concurrent/ConcurrentMap;storageTaskFuture&Ljava/util/concurrent/ScheduledFuture;$assertionsDisabledZ(Lcom/hazelcast/spi/serialization/SerializationService;Lcom/hazelcast/spi/TaskScheduler;Ljava/lang/ClassLoader;Lcom/hazelcast/spi/properties/HazelcastProperties;)V()V "$ %  '*java/util/concurrent/ConcurrentLinkedQueue) *%  ,&java/util/concurrent/ConcurrentHashMap. /%  1 ! 3java/lang/AssertionError5 6%4com/hazelcast/spi/serialization/SerializationService8com/hazelcast/spi/TaskScheduler:java/lang/ClassLoader<0com/hazelcast/spi/properties/HazelcastProperties>  @  B  D  Fthis?Lcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager;sses getNearCache@(Ljava/lang/String;)Lcom/hazelcast/internal/nearcache/NearCache;r(Ljava/lang/String;)Lcom/hazelcast/internal/nearcache/NearCache;"java/util/concurrent/ConcurrentMapOget&(Ljava/lang/Object;)Ljava/lang/Object; QR PS*com/hazelcast/internal/nearcache/NearCacheUnameLjava/lang/String;getOrCreateNearCachef(Ljava/lang/String;Lcom/hazelcast/config/NearCacheConfig;)Lcom/hazelcast/internal/nearcache/NearCache;(Ljava/lang/String;Lcom/hazelcast/config/NearCacheConfig;)Lcom/hazelcast/internal/nearcache/NearCache;(Ljava/lang/String;Lcom/hazelcast/config/NearCacheConfig;Lcom/hazelcast/internal/adapter/DataStructureAdapter;)Lcom/hazelcast/internal/nearcache/NearCache; Y\ ]nearCacheConfig&Lcom/hazelcast/config/NearCacheConfig;(Ljava/lang/String;Lcom/hazelcast/config/NearCacheConfig;Lcom/hazelcast/internal/adapter/DataStructureAdapter;)Lcom/hazelcast/internal/nearcache/NearCache;createNearCache bZ c initialize e$ Vfput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; hi Pj$com/hazelcast/config/NearCacheConfiglgetPreloaderConfig1()Lcom/hazelcast/config/NearCachePreloaderConfig; no mp-com/hazelcast/config/NearCachePreloaderConfigr isEnabled()Z tu svcreateAndSchedulePreloadTaskd(Lcom/hazelcast/internal/nearcache/NearCache;Lcom/hazelcast/internal/adapter/DataStructureAdapter;)V xy zcreateAndScheduleStorageTask2(Lcom/hazelcast/config/NearCachePreloaderConfig;)V |} ~java/lang/ThrowablepreloaderConfig/Lcom/hazelcast/config/NearCachePreloaderConfig;dataStructureAdapter5Lcom/hazelcast/internal/adapter/DataStructureAdapter; nearCache4Lcom/hazelcast/internal/nearcache/NearCache;,Lcom/hazelcast/internal/nearcache/NearCache;,com/hazelcast/config/NearCacheConfigAccessor.copyWithInitializedDefaultMaxSizeForOnHeapMapsN(Lcom/hazelcast/config/NearCacheConfig;)Lcom/hazelcast/config/NearCacheConfig; 6com/hazelcast/internal/nearcache/impl/DefaultNearCache(Ljava/lang/String;Lcom/hazelcast/config/NearCacheConfig;Lcom/hazelcast/spi/serialization/SerializationService;Lcom/hazelcast/spi/TaskScheduler;Ljava/lang/ClassLoader;Lcom/hazelcast/spi/properties/HazelcastProperties;)V " copylistAllNearCaches()Ljava/util/Collection;F()Ljava/util/Collection;values PclearNearCache(Ljava/lang/String;)Zclear $ VclearAllNearCachesjava/util/Collectioniterator()Ljava/util/Iterator; java/util/IteratorhasNext u next()Ljava/lang/Object; destroyNearCacheremove R Pdestroy $ VdestroyAllNearCachesjava/util/HashSet(Ljava/util/Collection;)V " getName()Ljava/lang/String; V java/util/Queue $java/util/concurrent/ScheduledFuturecancel(Z)Z  preloadTaskFuture(Lcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager;Lcom/hazelcast/internal/nearcache/NearCache;Lcom/hazelcast/internal/adapter/DataStructureAdapter;)V " java/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit; schedule\(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; ; access$002(Lcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager$PreloadTask;Ljava/util/concurrent/ScheduledFuture;)Ljava/util/concurrent/ScheduledFuture; add(Ljava/lang/Object;)Z  preloadTaskKLcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager$PreloadTask;scheduledFuture)Ljava/util/concurrent/ScheduledFuture<*>;adapterq(Lcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager;Lcom/hazelcast/config/NearCachePreloaderConfig;)V " scheduleWithRepetition](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; ; storageTaskKLcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager$StorageTask;getSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; getScheduler#()Lcom/hazelcast/spi/TaskScheduler;getClassLoader()Ljava/lang/ClassLoader; access$100R(Lcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager;)Ljava/util/Queue;x0 access$200e(Lcom/hazelcast/internal/nearcache/impl/DefaultNearCacheManager;)Ljava/util/concurrent/ConcurrentMap;java/lang/ClassdesiredAssertionStatus u  SignatureCode StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTable InnerClasses SourceFile! B !"#_*&*Y&(**Y+-*/Y024+ 6Y74, 6Y7*+A*,C*-E*G79;=? . 7012%879I;N<S=X>^? 4_HI_J_K__LMB*2+TV D HIWXNYZF*+,^ I HIWX_`[Y\Bx*2+TV:d*(Y:*2+TV::*+,d:g*2+kW,q:w*-{*ç :jmmrmgVE :QRST+U0V8W?YL[R\Z]a^gauc >RxHIxWXx_`xi iabZk,NY+-*A*C*E*G gh *HIWX_``[4 *2 n  HI}"*2+TVM, ,, V@ stuw "HI"WX$},*2L++VM,  |"}(~+ ",HIB*2+TVM,1*(YN*2+VM, ,-ì-ì:-495899=95VC * '+159@ BHIBWX4$pY*2L++VM*,W*-L++M,W**W  & '25RZ]do ' RpHIxy5,3 Y*+,N*C-Ӳڹ:-W*-W4 !(4 4%!5HI55 !|}x%* Y*+M**C, ڹα$ $ %HI%/*A  HI/*C  HI/*E  HI/*- ) I/*2 ) I$44 @ )