4                               !            / 4     9  <  ?     E      ! " # $ % &' &(  ]) *+ , !, &-. !/ *0 !12 ]3 *45 6 `7 8 9 : * ; < 6% !%= k> k? *@ A B C D E F G G H I J K L M N 0 O PQ R S T  *U V WX Y Z [\ ] ^ _ ` ab c de f ghi j kl mn o pq rst uvw xyz!NearCacheInvalidationEventHandler InnerClassesInvalidateCallbackCacheOrInvalidateCallbackPutAsyncOneShotCallbackGetAsyncCallback-minConsistentNearCacheSupportingServerVersionI cacheOnUpdateZinvalidateOnChange serializeKeysnearCacheManager3Lcom/hazelcast/internal/nearcache/NearCacheManager; nearCache,Lcom/hazelcast/internal/nearcache/NearCache; SignatureRLcom/hazelcast/internal/nearcache/NearCache;!nearCacheMembershipRegistrationIdLjava/lang/String;$assertionsDisabledM(Lcom/hazelcast/config/CacheConfig;Lcom/hazelcast/client/spi/ClientContext;)VCodeLineNumberTableLocalVariableTablethis;*Lcom/hazelcast/config/CacheConfig;U(Lcom/hazelcast/config/CacheConfig;Lcom/hazelcast/client/spi/ClientContext;)V getNearCache.()Lcom/hazelcast/internal/nearcache/NearCache; onInitialize()V clientConfig*Lcom/hazelcast/client/config/ClientConfig;nearCacheConfig&Lcom/hazelcast/config/NearCacheConfig;adapter;Lcom/hazelcast/internal/adapter/ICacheDataStructureAdapter;localCacheStatistics%Lcom/hazelcast/cache/CacheStatistics;CLcom/hazelcast/internal/adapter/ICacheDataStructureAdapter;getSyncInternalG(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Ljava/lang/Object;keyData&Lcom/hazelcast/nio/serialization/Data; reservationIdJ throwableLjava/lang/Throwable;keyLjava/lang/Object; expiryPolicy!Ljavax/cache/expiry/ExpiryPolicy;valueTV; StackMapTablei.w{8(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)TV;getAsyncInternal(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;Lcom/hazelcast/core/ExecutionCallback;)Lcom/hazelcast/spi/InternalCompletableFuture;getAsyncCallbackMLcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$GetAsyncCallback;tcallback&Lcom/hazelcast/core/ExecutionCallback;ULcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy.GetAsyncCallback;+Lcom/hazelcast/core/ExecutionCallback;(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;Lcom/hazelcast/core/ExecutionCallback;)Lcom/hazelcast/spi/InternalCompletableFuture;onPutSyncInternals(Ljava/lang/Object;Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;)V valueDataTK;U(TK;TV;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;)VonPutIfAbsentSyncInternalonPutIfAbsentAsyncInternal(Ljava/lang/Object;Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/util/ClientDelegatingFuture;Lcom/hazelcast/core/ExecutionCallback;)VdelegatingFuture2Lcom/hazelcast/client/util/ClientDelegatingFuture; callbackKeywrappedVLcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$CacheOrInvalidateCallback;GLcom/hazelcast/client/util/ClientDelegatingFuture;;Lcom/hazelcast/core/ExecutionCallback;sLcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy.CacheOrInvalidateCallback;(TK;TV;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/util/ClientDelegatingFuture;Lcom/hazelcast/core/ExecutionCallback;)VwrapPutAsyncFuture(Ljava/lang/Object;Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/spi/impl/ClientInvocationFuture;Lcom/hazelcast/client/cache/impl/OneShotExecutionCallback;)Lcom/hazelcast/client/util/ClientDelegatingFuture;invocationFuture6Lcom/hazelcast/client/spi/impl/ClientInvocationFuture;:Lcom/hazelcast/client/cache/impl/OneShotExecutionCallback;TLcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$PutAsyncOneShotCallback;?Lcom/hazelcast/client/cache/impl/OneShotExecutionCallback;\Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy.PutAsyncOneShotCallback;(TK;TV;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/spi/impl/ClientInvocationFuture;Lcom/hazelcast/client/cache/impl/OneShotExecutionCallback;)Lcom/hazelcast/client/util/ClientDelegatingFuture;onGetAndRemoveAsyncInternal(Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/util/ClientDelegatingFuture;Lcom/hazelcast/core/ExecutionCallback;)VOLcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$InvalidateCallback;7Lcom/hazelcast/client/util/ClientDelegatingFuture;+Lcom/hazelcast/core/ExecutionCallback;\Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy.InvalidateCallback;(TK;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/util/ClientDelegatingFuture;Lcom/hazelcast/core/ExecutionCallback;)VonReplaceInternalAsynccLcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy.CacheOrInvalidateCallback;(TK;TV;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/client/util/ClientDelegatingFuture;Lcom/hazelcast/core/ExecutionCallback;)VonReplaceAndGetAsyncgetAllInternalZ(Ljava/util/Set;Ljava/util/Collection;Ljavax/cache/expiry/ExpiryPolicy;Ljava/util/List;J)V currentSizekeysLjava/util/Set;dataKeysLjava/util/Collection;resultingKeyValuePairsLjava/util/List; startNanosncKeys reservationsLjava/util/Map; reverseKeyMapLjava/util/Set<+TK;>;>Ljava/util/Collection;$Ljava/util/List;Ljava/util/Collection<*>;3Ljava/util/Map;ILjava/util/Map;|}(Ljava/util/Set<+TK;>;Ljava/util/Collection;Ljavax/cache/expiry/ExpiryPolicy;Ljava/util/List;J)VtoDataKeysWithReservationsM(Ljava/util/Collection;Ljava/util/Collection;Ljava/util/Map;Ljava/util/Map;)V~(Ljava/util/Collection<*>;Ljava/util/Collection;Ljava/util/Map;Ljava/util/Map;)VpopulateResultFromNearCache)(Ljava/util/Collection;Ljava/util/List;)VcachediteratorLjava/util/Iterator;Ljava/util/Iterator<*>;@(Ljava/util/Collection<*>;Ljava/util/List;)VcreateNearCacheReservations((Ljava/util/Collection;Ljava/util/Map;)Vt(Ljava/util/Collection;Ljava/util/Map;)VpopulateResultFromRemote2(ILjava/util/List;Ljava/util/Map;Ljava/util/Map;)V cachedValuencKeyLjava/lang/Long;i(ILjava/util/List;Ljava/util/Map;Ljava/util/Map;)VsetExpiryPolicyInternal3(Ljava/util/Set;Ljavax/cache/expiry/ExpiryPolicy;)VserializedKeys7Ljava/util/Set;9(Ljava/util/Set<+TK;>;Ljavax/cache/expiry/ExpiryPolicy;)V6(Ljava/lang/Object;Ljavax/cache/expiry/ExpiryPolicy;)Zresult'(TK;Ljavax/cache/expiry/ExpiryPolicy;)ZputAllInternalT(Ljava/util/Map;Ljavax/cache/expiry/ExpiryPolicy;Ljava/util/Map;[Ljava/util/List;J)VmapkeyMapentriesPerPartition[Ljava/util/List;Ljava/util/Map<+TK;+TV;>;ILjava/util/Map;Entryv[Ljava/util/List;>;(Ljava/util/Map<+TK;+TV;>;Ljavax/cache/expiry/ExpiryPolicy;Ljava/util/Map;[Ljava/util/List;>;J)V invalidate!(Ljava/util/Set;Ljava/util/Set;)VkeysDataO(Ljava/util/Set<+TK;>;Ljava/util/Set;)VcacheOrInvalidate3(Ljava/util/Map;Ljava/util/Map;[Ljava/util/List;Z)VentryLjava/util/Map$Entry;entries partitionIdisCacheOrInvalidatecLjava/util/Map$Entry;uLjava/util/List;>;Ljava/util/Map$Entry<+TK;+TV;>;=(Ljava/util/Map<+TK;+TV;>;Ljava/util/Map;[Ljava/util/List;>;Z)VcontainsKeyInternal(Ljava/lang/Object;)ZloadAllInternalO(Ljava/util/Set;Ljava/util/List;ZLjavax/cache/integration/CompletionListener;)VdataKeyreplaceExistingValuescompletionListener,Ljavax/cache/integration/CompletionListener;8Ljava/util/List;}(Ljava/util/Set<+TK;>;Ljava/util/List;ZLjavax/cache/integration/CompletionListener;)VremoveAllKeysInternal)(Ljava/util/Set;Ljava/util/Collection;J)VW(Ljava/util/Set<+TK;>;Ljava/util/Collection;J)VonRemoveSyncInternal;(Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;)VonRemoveAsyncInternalfuture removeAllclearinvokeInternal_(Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;[Ljava/lang/Object;)Ljava/lang/Object;epData arguments[Ljava/lang/Object;close postDestroygetCachedValue'(Ljava/lang/Object;Z)Ljava/lang/Object;deserializeValues(Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;)Vd(Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;TV;Lcom/hazelcast/nio/serialization/Data;)VinvalidateNearCache(Ljava/lang/Object;)VtryReserveForUpdate;(Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;)JtryPublishReserved:(Ljava/lang/Object;Ljava/lang/Object;JZ)Ljava/lang/Object; remoteValue deserialize9(Ljava/lang/Object;Ljava/lang/Object;J)Ljava/lang/Object;releaseRemainingReservedKeys(Ljava/util/Map;)V reservedKeys6(Ljava/util/Map;)V addNearCacheInvalidationListener;(Lcom/hazelcast/client/spi/EventHandler;)Ljava/lang/String; eventHandler'Lcom/hazelcast/client/spi/EventHandler;registerInvalidationListenercreateInvalidationListenerCodec6()Lcom/hazelcast/client/spi/impl/ListenerMessageCodec;supportsRepairableNearCache()ZremoveInvalidationListenerregistrationIdisCacheOnUpdateZ(Lcom/hazelcast/config/NearCacheConfig;Ljava/lang/String;Lcom/hazelcast/logging/ILogger;)Z cacheNameloggerLcom/hazelcast/logging/ILogger;localUpdatePolicyLocalUpdatePolicy8Lcom/hazelcast/config/NearCacheConfig$LocalUpdatePolicy;checkNearCacheConfigw(Lcom/hazelcast/config/NearCacheConfig;Lcom/hazelcast/config/NativeMemoryConfig;)Lcom/hazelcast/config/NearCacheConfig;nativeMemoryConfig)Lcom/hazelcast/config/NativeMemoryConfig;inMemoryFormat%Lcom/hazelcast/config/InMemoryFormat; access$200?(Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy;)Zx0 access$300v(Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy;Ljava/lang/Object;Ljava/lang/Object;JZ)Ljava/lang/Object;x1x2x3x4 access$400Q(Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy;Ljava/lang/Object;)V access$500(Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy;Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Object;Lcom/hazelcast/nio/serialization/Data;)V access$600j(Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy;)Lcom/hazelcast/internal/nearcache/NearCache; access$700 access$800b(Lcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy;Ljava/lang/Object;)Ljava/lang/Object; access$900 access$1000dLcom/hazelcast/client/cache/impl/ClientCacheProxy; SourceFileNearCachedClientCacheProxy.java0com/hazelcast/internal/nearcache/NearCacheRecord  ]    3.8             9com/hazelcast/internal/adapter/ICacheDataStructureAdapter     9com/hazelcast/client/cache/impl/ClientCacheStatisticsImpl        java/lang/Throwable +com/hazelcast/util/executor/CompletedFuture    Kcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$GetAsyncCallback  Tcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$CacheOrInvalidateCallback  Rcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$PutAsyncOneShotCallback  Mcom/hazelcast/client/cache/impl/NearCachedClientCacheProxy$InvalidateCallback     01java/util/LinkedList  45|    ;<  >?  7~   }  k $com/hazelcast/nio/serialization/Data   java/lang/Long  java/util/HashSet  E YZ EK NO ]^java/util/Map$Entry    jk lm uv xy z ~         java/lang/AssertionError  Y   \com/hazelcast/client/cache/impl/NearCachedClientCacheProxy$NearCacheInvalidationEventHandler   df ghgi,j4k<mEnPocpiqzs~t4 scE:iE:I_* *+%+L*+&N-'-*+%:*+(7*,)N* *+-,N-:*+.!QR-6 yz{|!(6>GPRTYH(*6T ___G_G*@.f u* *+%+L*+&:'/Y*0*123*+%:*+(74Y*+-5:*,6:*+.;gh-. !;BP^hjo\ B&P^ j uuuu\*^ uu\@*l@:*+,-7**-+-,:**-+-, "   694::::: :::dUI  @:*+,-8**-+-,:**-+-, "   694::::: :::dUI   .*-+:9Y*-,::*+,-; -\ .......  >.....  @ /*-+:!\ /////// !! 4//// !  @ &*,+:?Y*@:*+,-A%H&&&&& 4&&&&  @ .*-+:9Y*-,::*+,-B -\ .......  >.....  @ .*-+:9Y*-,::*+,-C -\ .......  >.....  @ * *+,D*, EY+F:*GHIJ:: *IJ: *, D *KL6 *+,-M*  N*O: *O oR$,67CFMYgoxf x  !"$#Ca$%F^&% H'( )$#*Ca$+F^&,  G--/..h /01S f+P:QVR:*%:-$*S7*-TUWUW,VW. #'1:H M Y b eR1#?Gffff$%f&%4ff*f(f$+f&,2? 345E+PN-Q7-R:*&:',WW,WW-XƱ* !)2;AD>)! 6EEE !>78*EE*E )>79 29:;<@+PN-Q2-RY:*S7*,TUW˱% .!<#?$4%!@@@$% @@(@$+ 24=>? 6,L,ZY:,`ZY:* [:*,\W-[]:  (* ^,: ,` \W-_Wv6 ()**,A-H.S1`2e3t45(8p t@ o*`AIA`*B C !$%&%* )$+&,2H6DEF%N*`Y+abN*+,-c*+-d<= >@A$B*%%%#G %%'#GHIJEK!*+,e>***+%*+FGHJL*!!!L!!MNO:* +fJN*+,-g*+-h:*+-h.%(-& STVW%[(X*Y3Z9\H*::P%::Q%:RS:"*::PT:QU:RWVXYZ P**,iN-Q-RY:*$+iN-Q-R:*"_`"a(b.dFeLfOh4"FPPP[*FPP'P[H22\]^2 *p6-c-2:Rj:Q?Rk:lY: *  mY * Y+ni:QBRk:l:*,[Ym *Jlmnop;qGrLtbvhxkmt|}~p G! ;-_`Ta! gb'0_`P%Q%RScR;-_dTae'0_fPTQURW7 g2<h 2?hijk/* *+%+L*+&M,' ,*+o) //6 /@@lm *+,p*-,j:QRY:*+i:QR:*]:*-,j:QRY: * '+i:QR: *  aacaJ .4:U[^aj\ .nUn  !opq4U 'rE 22B Igs22tuv *+,!q*-,P:QRY:*+i:QR:*]:*-,P:QRY: * '+i:QR: * __a_J,28SY\_hR,nSn  "4S '(B 22BI-22wxy-*+,r**,+N**,+-*, --- -RRE z$2*+,-s**,+:**,+  .142222{2 2dU|}E |}|}~*t*uL*u+   P *v*uL*u+   P ,* *+%+L*+,-w:*+:*+""$"")*,,,, , @Qd*x**yzW*{  &*x**y|W*} L*}+#% & &^6*+~N- Y-' *--  $(*666 +6 6  @]**+,-*+4t+ Y*+    \ *+,(     G,' Y, *+:!**+,!:,"!" %#&+';)>GGGGG#$@ G Ac *+,!-*     *+iM,Q,RN*-12&3)4  **%**+  2P **+7   {*Y*L**+;<?@A  E Y*D   X** f  @2**L+#****+Wjkn op#q1s2 % 2 (:*N-$,Y+SYSYS-wx y+|-*:::5 - @ u*M,*+*  /*L \ *+,!L4     :*+L\ *+,-L4     /*L /*L :*+L:*+L:*+L4K @B?9<4k*V @