4,com/hazelcast/map/impl/LocalMapStatsProviderjava/lang/ObjectLocalMapStatsProvider.javaLcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStatsLocalMapOnDemandCalculatedStats.com/hazelcast/map/impl/LocalMapStatsProvider$1 java/util/Map$Entry  java/util/Map EntryEMPTY_LOCAL_MAP_STATS%Lcom/hazelcast/monitor/LocalMapStats; RETRY_COUNTI"WAIT_PARTITION_TABLE_UPDATE_MILLISdloggerLcom/hazelcast/logging/ILogger; localAddressLcom/hazelcast/nio/Address; nodeEngineLcom/hazelcast/spi/NodeEngine;clusterService/Lcom/hazelcast/internal/cluster/ClusterService;mapServiceContext*Lcom/hazelcast/map/impl/MapServiceContext;mapNearCacheManager6Lcom/hazelcast/map/impl/nearcache/MapNearCacheManager;partitionService/Lcom/hazelcast/spi/partition/IPartitionService;statsMap$Ljava/util/concurrent/ConcurrentMap;fLjava/util/concurrent/ConcurrentMap;constructorFunction(Lcom/hazelcast/util/ConstructorFunction;jLcom/hazelcast/util/ConstructorFunction;$assertionsDisabledZ-(Lcom/hazelcast/map/impl/MapServiceContext;)V()V -/ 0&java/util/concurrent/ConcurrentHashMap2(I)V -4 35 %& 71(Lcom/hazelcast/map/impl/LocalMapStatsProvider;)V -9 : () <  >(com/hazelcast/map/impl/MapServiceContext@ getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; BC AD  FgetClass()Ljava/lang/Class; HI Jcom/hazelcast/spi/NodeEngineL getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; NO MP  RgetMapNearCacheManager8()Lcom/hazelcast/map/impl/nearcache/MapNearCacheManager; TU AV !" XgetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; Z[ M\  ^getPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService; `a Mb #$ d-com/hazelcast/internal/cluster/ClusterServicefgetThisAddress()Lcom/hazelcast/nio/Address; hi gj  lthis.Lcom/hazelcast/map/impl/LocalMapStatsProvider;getMapServiceContext,()Lcom/hazelcast/map/impl/MapServiceContext;getLocalMapStatsImplB(Ljava/lang/String;)Lcom/hazelcast/monitor/impl/LocalMapStatsImpl;"com/hazelcast/util/ConcurrencyUtiltgetOrPutIfAbsentr(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object; vw ux,com/hazelcast/monitor/impl/LocalMapStatsImplznameLjava/lang/String;destroyLocalMapStatsImpl(Ljava/lang/String;)V"java/util/concurrent/ConcurrentMapremove&(Ljava/lang/Object;)Ljava/lang/Object; createLocalMapStats rs  0addNearCacheStats(Ljava/lang/String;Lcom/hazelcast/monitor/impl/LocalMapStatsImpl;Lcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStats;)V  addIndexStatsC(Ljava/lang/String;Lcom/hazelcast/monitor/impl/LocalMapStatsImpl;)V updateMapOnDemandStatsc(Ljava/lang/String;Lcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStats;)V  updateAndGet^(Lcom/hazelcast/monitor/impl/LocalMapStatsImpl;)Lcom/hazelcast/monitor/impl/LocalMapStatsImpl; mapNamestats.Lcom/hazelcast/monitor/impl/LocalMapStatsImpl; onDemandStatsNLcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStats;createAllLocalMapStats()Ljava/util/Map;J()Ljava/util/Map;java/util/HashMap 0getPartitionContainers.()[Lcom/hazelcast/map/impl/PartitionContainer; A,[Lcom/hazelcast/map/impl/PartitionContainer;)com/hazelcast/map/impl/PartitionContainergetAllRecordStores()Ljava/util/Collection; java/util/Collectioniterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next()Ljava/lang/Object; .com/hazelcast/map/impl/recordstore/RecordStoreisStatsCalculationEnabledFor3(Lcom/hazelcast/map/impl/recordstore/RecordStore;)Z getPartitionId()I -com/hazelcast/spi/partition/IPartitionService getPartition,(IZ)Lcom/hazelcast/spi/partition/IPartition; &com/hazelcast/spi/partition/IPartitionisLocal getOrCreateOnDemandStats(Ljava/util/Map;Lcom/hazelcast/map/impl/recordstore/RecordStore;)Lcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStats; addPrimaryStatsOf(Lcom/hazelcast/map/impl/recordstore/RecordStore;Lcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStats;)V addReplicaStatsOf entrySet()Ljava/util/Set;  java/util/Set getKey java/lang/StringgetValue addStructureStats setValue addStatsOfNoDataIncludedMaps(Ljava/util/Map;)V  partition(Lcom/hazelcast/spi/partition/IPartition; recordStore0Lcom/hazelcast/map/impl/recordstore/RecordStore;allRecordStoresHLjava/util/Collection;Ljava/util/Collection;partitionContainer+Lcom/hazelcast/map/impl/PartitionContainer;entryLjava/util/Map$Entry; existingStatsonDemand updatedStatsobjectLjava/lang/Object; statsPerMapLjava/util/Map;partitionContainersgetProxyService"()Lcom/hazelcast/spi/ProxyService;   Mhz:impl:mapServicecom/hazelcast/spi/ProxyServicegetDistributedObjectNames*(Ljava/lang/String;)Ljava/util/Collection;   containsKey(Ljava/lang/Object;)Z    put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;  ! proxyService Lcom/hazelcast/spi/ProxyService;mapNames*Ljava/util/Collection;getMapContainer'()Lcom/hazelcast/map/impl/MapContainer; '( )#com/hazelcast/map/impl/MapContainer+ getMapConfig"()Lcom/hazelcast/config/MapConfig; -. ,/com/hazelcast/config/MapConfig1isStatisticsEnabled 3 24(Ljava/util/Map;Lcom/hazelcast/map/impl/recordstore/RecordStore;)Lcom/hazelcast/map/impl/LocalMapStatsProvider$LocalMapOnDemandCalculatedStats;getName()Ljava/lang/String; 78 9get ; <5Ljava/util/Map;+(I)Lcom/hazelcast/spi/partition/IPartition; ? @getExistingRecordStoreD(Ljava/lang/String;)Lcom/hazelcast/map/impl/recordstore/RecordStore; BC DgetLockedEntryCount F GincrementLockedEntryCount(J)V IJ K hasRecords M NgetLocalRecordStoreStats/()Lcom/hazelcast/monitor/LocalRecordStoreStats; PQ R+com/hazelcast/monitor/LocalRecordStoreStatsTgetHits()J VW UX incrementHits ZJ [getMapDataStore0()Lcom/hazelcast/map/impl/mapstore/MapDataStore; ]^ _,com/hazelcast/map/impl/mapstore/MapDataStoreanotFinishedOperationsCount c bdincrementDirtyEntryCount fJ ggetOwnedEntryCost iW jincrementOwnedEntryMemoryCost lJ m#com/hazelcast/config/InMemoryFormatoNATIVE%Lcom/hazelcast/config/InMemoryFormat; qr psgetInMemoryFormat'()Lcom/hazelcast/config/InMemoryFormat; uv 2wincrementHeapCost yJ zsize | }incrementOwnedEntryCount J getLastAccessTime W UsetLastAccessTime J getLastUpdateTime W UsetLastUpdateTime J getTotalBackupCount  2setBackupCount 4 -Lcom/hazelcast/monitor/LocalRecordStoreStats; , getReplicaAddress (III)Lcom/hazelcast/nio/Address;  isReplicaAvailable(Lcom/hazelcast/nio/Address;I)Z   printWarning(II)V  com/hazelcast/nio/AddressisReplicaOnThisNode(Lcom/hazelcast/nio/Address;)Z  incrementBackupEntryMemoryCost J incrementBackupEntryCount J  partitionIdreplicaAddress replicaNumberbackupEntryCountJbackupEntryMemoryCosttotalBackupCountgetMaxAllowedBackupCount   backupCountequals  java/lang/StringBuilder 0 partitionId: append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  (I)Ljava/lang/StringBuilder;   , replica:  has no owner!toString 8 com/hazelcast/logging/ILoggerwarning  replica(I)Lcom/hazelcast/nio/Address;  waitForReplicaAddressG(ILcom/hazelcast/spi/partition/IPartition;I)Lcom/hazelcast/nio/Address;  sleep / tryCountjava/lang/InterruptedExceptionjava/util/concurrent/TimeUnit MILLISECONDSLjava/util/concurrent/TimeUnit;  d J java/lang/Thread currentThread()Ljava/lang/Thread;   interrupt /  com/hazelcast/util/ExceptionUtilrethrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;  e Ljava/lang/InterruptedException;4com/hazelcast/map/impl/nearcache/MapNearCacheManager getNearCache@(Ljava/lang/String;)Lcom/hazelcast/internal/nearcache/NearCache;  *com/hazelcast/internal/nearcache/NearCachegetNearCacheStats(()Lcom/hazelcast/monitor/NearCacheStats;  setNearCacheStats)(Lcom/hazelcast/monitor/NearCacheStats;)V   { $com/hazelcast/monitor/NearCacheStatsgetOwnedEntryMemoryCost W  localMapStats nearCache,Lcom/hazelcast/internal/nearcache/NearCache;nearCacheStats&Lcom/hazelcast/monitor/NearCacheStats;9(Ljava/lang/String;)Lcom/hazelcast/map/impl/MapContainer; ' A getIndexes$()Lcom/hazelcast/query/impl/Indexes;  , +,  com/hazelcast/query/impl/Indexes!isGlobal # "$java/lang/AssertionError& '0getIndexesStats+()Lcom/hazelcast/monitor/impl/IndexesStats; )* "+'com/hazelcast/monitor/impl/IndexesStats- getQueryCount /W .0 setQueryCount 2J {3getIndexedQueryCount 5W .6setIndexedQueryCount 8J {9+()[Lcom/hazelcast/query/impl/InternalIndex; ; "<aggregateFreshIndexStatsI([Lcom/hazelcast/query/impl/InternalIndex;Ljava/util/Map;)Ljava/util/Map; >? @finalizeFreshIndexStats B C&()Ljava/util/concurrent/ConcurrentMap; E F <java/lang/MathImax(JJ)J KL JMupdateIndexStats O {PpartitionIndexes"Lcom/hazelcast/query/impl/Indexes; indexesStats)Lcom/hazelcast/monitor/impl/IndexesStats; queryCountindexedQueryCount mapContainer%Lcom/hazelcast/map/impl/MapContainer; globalIndexes freshStatsRLjava/util/Map;([Lcom/hazelcast/query/impl/InternalIndex;Ljava/util/Map;)Ljava/util/Map;)[Lcom/hazelcast/query/impl/InternalIndex;^&com/hazelcast/query/impl/InternalIndex` a9-com/hazelcast/monitor/impl/OnDemandIndexStatsc d0setCreationTime hJ digetPerIndexStats,()Lcom/hazelcast/monitor/impl/PerIndexStats; kl amgetCreationTime oW dp(com/hazelcast/monitor/impl/PerIndexStatsr spmin uL Jv getHitCount xW sy dy setHitCount |J d} d0 s0 d3 getMemoryCost W d s setMemoryCost J dgetAverageHitSelectivity()D  d getTotalNormalizedHitCardinality  ssetAverageHitSelectivity(D)V  dgetAverageHitLatency W dgetTotalHitLatency W ssetAverageHitLatency J dgetTotalHitCount W dsetTotalHitCount J dgetInsertCount W d ssetInsertCount J dgetTotalInsertLatency W d ssetTotalInsertLatency J dgetUpdateCount W d ssetUpdateCount J dgetTotalUpdateLatency W d ssetTotalUpdateLatency J dgetRemoveCount W d ssetRemoveCount J dgetTotalRemoveLatency W d ssetTotalRemoveLatency J d indexNamefreshIndexStats/Lcom/hazelcast/monitor/impl/OnDemandIndexStats; indexStats*Lcom/hazelcast/monitor/impl/PerIndexStats;hitCountindex(Lcom/hazelcast/query/impl/InternalIndex; freshIndexesU(Ljava/util/Map;)Vvalues  (DD)D K JaverageHitSelectivityD totalHitCountjava/lang/ClassdesiredAssertionStatus   {0 ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile!  !"#$%&'()*+,-.p*1*3Y68* Y*;=*+?*+EG**G*KQS*+WY**G]_**Gce**_km. OGHP#Q-R>SHTUUbVoWpnop pq/*?Z norsD*8+*=y{^no|}~D *8+W b c no |}s'*+MYN*+,-*+,*+--,fghij!l*'no'}!q YL*?M,N-66x-2:::R:  ƚ*e:   + ٸݧ* + ٷ+N-b-: ::*::***:  W*++A  (  gjprs(t/uNvVwYyjzt{}s  j$ N@ /b(iMA}9-  T no     /bM*GM,N-:):++"Wӱ, 2=IL42}MnoM   C#$9% 9%& 7 **05  )+:M*,=N-YN*,-"W- $$*) )"}  )>6  b*?N-:66B2:*eʹA:+E,ݧ*+E,*+,)4 & #3=JU[a>3"#2bnob}b X ? no} *+*HL*O*SM+,Y\+*`eh+*knt**0x +*k{+*~+,+,+**0 FU>(8BT^is} p +O B 7+*66Q+6 * : * * !* +ka7!+~aBt+*0x ,{,,!,+*0%0V "*6AILU`jp\ *@ 64 Uno   MH**~@ a+*e@  noT+*m+@nop.*SYʶ̶ŶϹ - .no..(*eA:: *: %  %">(no((( 26:'*e,: ()*+ ,#-//>2no222/, /lK* L 4 8 5 679  +*Y+: :, -{> ?@CEF*G>+no+}++ !!*?+N-::H % 'Y(,,14,,7:=A:D 7 7*?:  :  6 6     2:*eʹA:`G+H":H % 'Y(,:1N77N7=A: u,4,:D,QK /,". {,"*".zJ KMNO/P=QKRVS^UaVdWoXYZ[^_`bcijlX opru v jMRS(TUzaVdWo !no!}! XYZS [   [\ >?j \*+ YL*M,>6>,2:b:+=d:dYe:fj+"Wn:qtwjz7 { N~Naca aaaaaaā+$_Bad_rz {~%.;@IQ\ey 0BT~ZH.&};e %/\^\[  \[\] BV**L+>+dM,B! &,!og99,,,!m @. $)/:BHRU*:))$.V[  V[\/B {Y @ 9;