4#com/hazelcast/cache/impl/CacheProxyLcom/hazelcast/cache/impl/AbstractCacheProxy;Lcom/hazelcast/internal/journal/EventJournalReader;>;+com/hazelcast/cache/impl/AbstractCacheProxy1com/hazelcast/internal/journal/EventJournalReaderCacheProxy.java;com/hazelcast/cache/impl/AbstractCacheProxyBase$LoadAllTask /com/hazelcast/cache/impl/AbstractCacheProxyBase  LoadAllTaskjavax/cache/Cache$Entryjavax/cache/CacheEntryk(Lcom/hazelcast/config/CacheConfig;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/cache/impl/ICacheService;)Vs(Lcom/hazelcast/config/CacheConfig;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/cache/impl/ICacheService;)V  this-Lcom/hazelcast/cache/impl/CacheProxy;%Lcom/hazelcast/cache/impl/CacheProxy; cacheConfig*Lcom/hazelcast/config/CacheConfig;"Lcom/hazelcast/config/CacheConfig; nodeEngineLcom/hazelcast/spi/NodeEngine; cacheService(Lcom/hazelcast/cache/impl/ICacheService;get&(Ljava/lang/Object;)Ljava/lang/Object;(TK;)TV;G(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Ljava/lang/Object; "% &keyTK;Ljava/lang/Object;getAll (Ljava/util/Set;)Ljava/util/Map;.(Ljava/util/Set<+TK;>;)Ljava/util/Map;A(Ljava/util/Set;Ljavax/cache/expiry/ExpiryPolicy;)Ljava/util/Map; +. /keysLjava/util/Set<+TK;>;Ljava/util/Set; containsKey(Ljava/lang/Object;)Z(TK;)Z ensureOpen()V 78 9'com/hazelcast/cache/impl/CacheProxyUtil;validateNotNull(Ljava/lang/Object;)V => <?serializationService6Lcom/hazelcast/spi/serialization/SerializationService; AB C4com/hazelcast/spi/serialization/SerializationServiceEtoData:(Ljava/lang/Object;)Lcom/hazelcast/nio/serialization/Data; GH FIoperationProvider1Lcom/hazelcast/cache/impl/CacheOperationProvider; KL M/com/hazelcast/cache/impl/CacheOperationProviderOcreateContainsKeyOperationE(Lcom/hazelcast/nio/serialization/Data;)Lcom/hazelcast/spi/Operation; QR PS getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; UV Wcom/hazelcast/spi/NodeEngineYgetOperationService&()Lcom/hazelcast/spi/OperationService; [\ Z]getPartitionId)(Lcom/hazelcast/nio/serialization/Data;)I _` agetServiceName()Ljava/lang/String; cd e"com/hazelcast/spi/OperationServiceginvokeOnPartition_(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InternalCompletableFuture; ij hk+com/hazelcast/spi/InternalCompletableFuturemjoin()Ljava/lang/Object; op nqjava/lang/Booleans booleanValue()Z uv twdataKey&Lcom/hazelcast/nio/serialization/Data; operationLcom/hazelcast/spi/Operation;operationService$Lcom/hazelcast/spi/OperationService; partitionIdIfutureBLcom/hazelcast/spi/InternalCompletableFuture;-Lcom/hazelcast/spi/InternalCompletableFuture;loadAll?(Ljava/util/Set;ZLjavax/cache/integration/CompletionListener;)VE(Ljava/util/Set<+TK;>;ZLjavax/cache/integration/CompletionListener;)Vjava/lang/Exception(Ljava/util/Set;)V = < java/util/Setiterator()Ljava/util/Iterator; java/util/IteratorhasNext v next p  validateConfiguredTypes7(Lcom/hazelcast/config/CacheConfig;Ljava/lang/Object;)V <size()I com/hazelcast/util/SetUtil createHashSet(I)Ljava/util/Set; add 5 (Lcom/hazelcast/cache/impl/AbstractCacheProxyBase;Lcom/hazelcast/cache/impl/CacheOperationProvider;Ljava/util/Set;ZLjavax/cache/integration/CompletionListener;)V  submitLoadAllTask@(Lcom/hazelcast/cache/impl/AbstractCacheProxyBase$LoadAllTask;)V *javax/cache/integration/CompletionListener onException(Ljava/lang/Exception;)V javax/cache/CacheException(Ljava/lang/Throwable;)V  eLjava/lang/Exception;replaceExistingValuesZcompletionListener,Ljavax/cache/integration/CompletionListener;keysData7Ljava/util/Set; loadAllTaskELcom/hazelcast/cache/impl/AbstractCacheProxyBase.LoadAllTask;=Lcom/hazelcast/cache/impl/AbstractCacheProxyBase$LoadAllTask;put'(Ljava/lang/Object;Ljava/lang/Object;)V (TK;TV;)VH(Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)V valueTV; getAndPut8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; (TK;TV;)TV;Y(Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Ljava/lang/Object; putAll(Ljava/util/Map;)V(Ljava/util/Map<+TK;+TV;>;)V3(Ljava/util/Map;Ljavax/cache/expiry/ExpiryPolicy;)V mapLjava/util/Map<+TK;+TV;>;Ljava/util/Map; putIfAbsent'(Ljava/lang/Object;Ljava/lang/Object;)Z (TK;TV;)ZH(Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Z removejava/lang/ThrowableremoveAsyncInternalV(Ljava/lang/Object;Ljava/lang/Object;ZZZ)Lcom/hazelcast/spi/InternalCompletableFuture;  "p n com/hazelcast/util/ExceptionUtilrethrowAllowedTypeFirstD(Ljava/lang/Throwable;Ljava/lang/Class;)Ljava/lang/RuntimeException; Ljava/lang/Throwable;oldValue getAndRemove2Lcom/hazelcast/spi/InternalCompletableFuture;replace9(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z (TK;TV;TV;)ZZ(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Z newValuejavax/cache/expiry/ExpiryPolicy  getAndReplace   removeAll(Ljava/util/Set<+TK;>;)VisEmpty  v  removeAllInternal  clear clearInternal 8 getConfiguration<(Ljava/lang/Class;)Ljavax/cache/configuration/Configuration;Q;>(Ljava/lang/Class;)TC;java/lang/Class isInstance 5  com/hazelcast/config/CacheConfig getAsReadOnly,()Lcom/hazelcast/config/CacheConfigReadOnly;   cast "# #'javax/cache/configuration/Configuration%"java/lang/IllegalArgumentException'java/lang/StringBuilder) 8 *+The configuration class -append-(Ljava/lang/String;)Ljava/lang/StringBuilder; /0 *1-(Ljava/lang/Object;)Ljava/lang/StringBuilder; /3 *4( is not supported by this implementation6toString 8d *9(Ljava/lang/String;)V ; (<clazzLjava/lang/Class;Ljava/lang/Class;invoke_(Ljava/lang/Object;Ljavax/cache/processor/EntryProcessor;[Ljava/lang/Object;)Ljava/lang/Object;b(TK;Ljavax/cache/processor/EntryProcessor;[Ljava/lang/Object;)TT;-javax/cache/processor/EntryProcessorExceptionDEntry Processor is nullF com/hazelcast/util/PreconditionsH checkNotNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; JK ILregisterCompletionLatch(I)Ljava/lang/Integer; NO PcreateEntryProcessorOperation(Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Integer;Ljavax/cache/processor/EntryProcessor;[Ljava/lang/Object;)Lcom/hazelcast/spi/Operation; RS PTwaitCompletionLatch(Ljava/lang/Integer;)V VW Xjava/lang/ObjectZ$javax/cache/processor/EntryProcessor\[Ljava/lang/Object;^$com/hazelcast/nio/serialization/Data`java/lang/Integerbcom/hazelcast/spi/OperationdderegisterCompletionLatch fW g E2Lcom/hazelcast/spi/InternalCompletableFuture;safelyTT;ceLjavax/cache/CacheException;entryProcessor1Ljavax/cache/processor/EntryProcessor;&Ljavax/cache/processor/EntryProcessor; argumentskeyData completionIdLjava/lang/Integer;op invokeAllY(Ljava/util/Set;Ljavax/cache/processor/EntryProcessor;[Ljava/lang/Object;)Ljava/util/Map;(Ljava/util/Set<+TK;>;Ljavax/cache/processor/EntryProcessor;[Ljava/lang/Object;)Ljava/util/Map;>;com/hazelcast/util/MapUtilz createHashMap(I)Ljava/util/Map; |} {~ java/util/Map AB 2com/hazelcast/cache/impl/CacheEntryProcessorResult >   resultceResult9Lcom/hazelcast/cache/impl/CacheEntryProcessorResult;4Lcom/hazelcast/cache/impl/CacheEntryProcessorResult; allResultELjava/util/Map;>;unwrap%(Ljava/lang/Class;)Ljava/lang/Object;1(Ljava/lang/Class;)TT;getClass()Ljava/lang/Class;  [isAssignableFrom(Ljava/lang/Class;)Z  Unwrapping to Ljava/lang/Class;registerCacheEntryListener>(Ljavax/cache/configuration/CacheEntryListenerConfiguration;)VF(Ljavax/cache/configuration/CacheEntryListenerConfiguration;)V?(Ljavax/cache/configuration/CacheEntryListenerConfiguration;Z)V  cacheEntryListenerConfigurationCLjavax/cache/configuration/CacheEntryListenerConfiguration;;Ljavax/cache/configuration/CacheEntryListenerConfiguration;G(Ljavax/cache/configuration/CacheEntryListenerConfiguration;Z)V-CacheEntryListenerConfiguration can't be null2com/hazelcast/cache/impl/CacheEventListenerAdaptorgetSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService;  Z(Lcom/hazelcast/cache/ICache;Ljavax/cache/configuration/CacheEntryListenerConfiguration;Lcom/hazelcast/spi/serialization/SerializationService;)V   getService#()Lcom/hazelcast/spi/RemoteService;  &com/hazelcast/cache/impl/ICacheServicegetDistributedObjectName d registerListeners(Ljava/lang/String;Lcom/hazelcast/cache/impl/CacheEventListener;Lcom/hazelcast/spi/EventFilter;Z)Ljava/lang/String;  "addCacheEntryListenerConfigurationf(Ljavax/cache/configuration/CacheEntryListenerConfiguration;)Lcom/hazelcast/config/CacheConfiguration;  java/lang/StringaddListenerLocallyP(Ljava/lang/String;Ljavax/cache/configuration/CacheEntryListenerConfiguration;)V  %updateCacheListenerConfigOnOtherNodes   addToConfig entryListener;4Lcom/hazelcast/cache/impl/CacheEventListenerAdaptor;regIdLjava/lang/String;deregisterCacheEntryListenergetListenerIdLocalO(Ljavax/cache/configuration/CacheEntryListenerConfiguration;)Ljava/lang/String;  deregisterListener'(Ljava/lang/String;Ljava/lang/String;)Z  removeListenerLocally  %removeCacheEntryListenerConfiguration  getClusterService1()Lcom/hazelcast/internal/cluster/ClusterService;  Z-com/hazelcast/internal/cluster/ClusterService getMembers()Ljava/util/Set;  java/util/Collection com/hazelcast/core/Member localMember v Ecom/hazelcast/cache/impl/operation/CacheListenerRegistrationOperationQ(Ljava/lang/String;Ljavax/cache/configuration/CacheEntryListenerConfiguration;Z)V  hz:impl:cacheService getAddress()Lcom/hazelcast/nio/Address;  invokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture;  hmemberLcom/hazelcast/core/Member; isRegistermembers3Ljava/util/Collection;Ljava/util/Collection;9()Ljava/util/Iterator;>;,com/hazelcast/cache/impl/ClusterWideIterator )(Lcom/hazelcast/cache/impl/CacheProxy;Z)V   (I)Ljava/util/Iterator;:(I)Ljava/util/Iterator;>;*(Lcom/hazelcast/cache/impl/CacheProxy;IZ)V    fetchSize(IIZ)Ljava/util/Iterator;<(IIZ)Ljava/util/Iterator;>;/com/hazelcast/cache/impl/CachePartitionIterator+(Lcom/hazelcast/cache/impl/CacheProxy;IIZ)V  prefetchValuesaddPartitionLostListenerO(Lcom/hazelcast/cache/impl/event/CachePartitionLostListener;)Ljava/lang/String;(CachePartitionLostListener can't be null (Lcom/hazelcast/cache/impl/event/CachePartitionLostListener;)V ' &(injectDependencies *> + WgetEventService"()Lcom/hazelcast/spi/EventService; ./ Z0name 2 3com/hazelcast/spi/EventService5|(Ljava/lang/String;Ljava/lang/String;Lcom/hazelcast/spi/EventFilter;Ljava/lang/Object;)Lcom/hazelcast/spi/EventRegistration; 7 68#com/hazelcast/spi/EventRegistration:getId <d ;=listener;Lcom/hazelcast/cache/impl/event/CachePartitionLostListener;filterLcom/hazelcast/spi/EventFilter;listenerAdapterJLcom/hazelcast/cache/impl/event/InternalCachePartitionLostListenerAdapter; registration%Lcom/hazelcast/spi/EventRegistration;removePartitionLostListener(Ljava/lang/String;)ZListener ID should not be null!I9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Object;)Z K 6LidsubscribeToEventJournal*(I)Lcom/hazelcast/core/ICompletableFuture;o(I)Lcom/hazelcast/core/ICompletableFuture;Dcom/hazelcast/cache/impl/journal/CacheEventJournalSubscribeOperationRnameWithPrefix T U S<setPartitionId (I)Lcom/hazelcast/spi/Operation; XY SZL(Lcom/hazelcast/spi/Operation;)Lcom/hazelcast/spi/InternalCompletableFuture; i\ h]FLcom/hazelcast/cache/impl/journal/CacheEventJournalSubscribeOperation;readFromEventJournalz(JIIILcom/hazelcast/util/function/Predicate;Lcom/hazelcast/util/function/Function;)Lcom/hazelcast/core/ICompletableFuture;A(JIIILcom/hazelcast/util/function/Predicate<-Lcom/hazelcast/cache/journal/EventJournalCacheEvent;>;Lcom/hazelcast/util/function/Function<-Lcom/hazelcast/cache/journal/EventJournalCacheEvent;+TT;>;)Lcom/hazelcast/core/ICompletableFuture;>;maxSize c(I)Ljava/lang/StringBuilder; /e *f% must be greater or equal to minSize h?com/hazelcast/cache/impl/journal/CacheEventJournalReadOperationje(Ljava/lang/String;JIILcom/hazelcast/util/function/Predicate;Lcom/hazelcast/util/function/Function;)V l km kZ startSequenceJminSizemaxSize predicatefLcom/hazelcast/util/function/Predicate<-Lcom/hazelcast/cache/journal/EventJournalCacheEvent;>;'Lcom/hazelcast/util/function/Predicate; projectioniLcom/hazelcast/util/function/Function<-Lcom/hazelcast/cache/journal/EventJournalCacheEvent;+TT;>;&Lcom/hazelcast/util/function/Function;LLcom/hazelcast/cache/impl/journal/CacheEventJournalReadOperation;ALcom/hazelcast/cache/impl/journal/CacheEventJournalReadOperation;     setExpiryPolicy3(Ljava/util/Set;Ljavax/cache/expiry/ExpiryPolicy;)V  6(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Z      / &getAndReplaceAsyncn(Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Lcom/hazelcast/core/ICompletableFuture;  M(Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/core/ICompletableFuture;   replaceAsync(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Lcom/hazelcast/core/ICompletableFuture;  _(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/core/ICompletableFuture;      getAndRemoveAsync;(Ljava/lang/Object;)Lcom/hazelcast/core/ICompletableFuture;   removeAsyncS(Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/spi/InternalCompletableFuture;  A(Ljava/lang/Object;)Lcom/hazelcast/spi/InternalCompletableFuture;  getAndPutAsync    putIfAbsentAsynct(Ljava/lang/Object;Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Lcom/hazelcast/spi/InternalCompletableFuture;    putAsync    getAsyncb(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Lcom/hazelcast/spi/InternalCompletableFuture;    getLocalCacheStatistics'()Lcom/hazelcast/cache/CacheStatistics;  countDownCompletionLatch(I)V  resetCacheManager 8 setCacheManager.(Lcom/hazelcast/cache/HazelcastCacheManager;)V  getCacheManager()Ljavax/cache/CacheManager;   9hashCode  equals 5  isDestroyed v isClosed v close 8 open 8  egetPrefixedName d getName d CodeLineNumberTableLocalVariableTableLocalVariableTypeTable Signature StackMapTable Exceptions InnerClasses SourceFile!Mp*+,- TU* !"#W*+'Y(*()$+,W*+0^1312-45N*:+@*D+JM*N,TN*X^:*,b6*f-l:rtx"cdefg)h0i@jHNN(*;yz0{|)%}~0@ NN()@6*:++::*+:+:':@*DJWջ Y**N-:*:- -Y:-   Jopq#r,s/t:uUvZwmxpy{|}~\ # (*U(*13:j3"># ()U()12:j"p*+,ϱ  (** ()l*+,װ (** ()[*+ݱ l*+, (** ()5*+M,txM,W * (*  ()6*+,N-txN-W 4 (*** ()#*+M,M,Q * (*  ()$ *+,-*  (* * **  ()  o *+,   (* *   () l*+, (** ()*:++ *+1312 8N *:*     8M *:*    <+*+*!$&(Y*Y,.2+572:= <<>@<<>?AB *:+@,GMW*D+J:*Q:*N,-U:*X^:*b6*fl:  r: *Y :*h:*hEYi4ij4iu%j[]_aceJJ#4?GXagjlruw} ?+}~G#X a k* l mnw(*oqr^ksz#dtu4Sv|4Xj a kl ()opECwx *:+,GMW+:+:S:@*,-:Y::Y:W;Y\D#2[[@]_[ >6;EY \ ^ i n z}f E*Y^ i6D(*13oqr^eRElYi6D()12opey3+* +*$(Y*Y,2+572:= 33>@33>[*+ X*:+MWY*+*XN**--:! *+W*+ *+ͱ F2 #$ &()4*9+=,F.M/Q0W34XXX94$ XX9<+MW*+M,,**,*+W*+W*+ͱ;"79:;&<,=5>;A <<.<<+i*X^N*X::>:%Y*+:-W#hA"E FG9HCIRKeMhNHRv|9,iii _}~O  iiON*: Y* RS   Y*: Y* XY n*:Y* ^_* G+!MW#Y$M&Y+)N*+,*-1*4,-9:>dfghi8j?l4GG?@7AB.CD?EF GGHy'+JMW*-1*4+Mqr!s&r''N 'OPz"SY*VWM,[W*X^,^x yz "" v_ "Q`a [*(Y*Y,d2gi2g:=kY*Vn:oW*X^^--BJR[[pq[r[s[[tv[wyBv{*[[tu[wxBvzbAA*|O  AD*+,-}O  AD*+,-~O  AF *+,-O    AD*+,-O  AC*+,O  AC*+,O  AC*+,O  AD*+,-O  AD*+,-O  A+.C*+,O  A"%C*+,O  AD*+,-O  AC*+,O  AF *+,-O    AD*+,-O  AD*+,-O  AC*+,O  AB*+O  AC*+,O  AB*+O  AD*+,-O  AC*+,O  AD*+,-O  AC*+,O  AD*+,-O  AC*+,O  AC*+,O  AB*+O  AA*ðO  AB*DZO  A8A*ʱO  AB*+αO  AA*ҰO  A8dA*ӰO  AA*֬O  A5B*+٬O  AvA*ܬO  AvA*߬O  A8A*O  A8A*O  AcdA*O  AdA*O  AdA*O