Edit C:\dspace\webapps\xmlui\WEB-INF\lib\org\elasticsearch\indices\cache\query\IndicesQueryCache.class
???? 3" 7org/elasticsearch/indices/cache/query/IndicesQueryCache ?Lorg/elasticsearch/common/component/AbstractComponent;Lorg/elasticsearch/common/cache/RemovalListener<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;Lorg/elasticsearch/common/bytes/BytesReference;>; 4org/elasticsearch/common/component/AbstractComponent .org/elasticsearch/common/cache/RemovalListener IndicesQueryCache.java 9org/elasticsearch/indices/cache/query/IndicesQueryCache$1 Norg/elasticsearch/indices/cache/query/IndicesQueryCache$BytesQuerySearchResult BytesQuerySearchResult >org/elasticsearch/indices/cache/query/IndicesQueryCache$Reaper Reaper Borg/elasticsearch/indices/cache/query/IndicesQueryCache$CleanupKey CleanupKey ;org/elasticsearch/indices/cache/query/IndicesQueryCache$Key Key >org/elasticsearch/indices/cache/query/IndicesQueryCache$Loader Loader Iorg/elasticsearch/indices/cache/query/IndicesQueryCache$QueryCacheWeigher QueryCacheWeigher 8org/apache/lucene/index/IndexReader$ReaderClosedListener #org/apache/lucene/index/IndexReader ReaderClosedListener INDEX_CACHE_QUERY_ENABLED Ljava/lang/String; index.cache.query.enable $ "INDICES_CACHE_QUERY_CLEAN_INTERVAL "indices.cache.query.clean_interval ' INDICES_CACHE_QUERY_SIZE indices.cache.query.size * INDICES_CACHE_QUERY_EXPIRE indices.cache.query.expire - %INDICES_CACHE_QUERY_CONCURRENCY_LEVEL %indices.cache.query.concurrency_level 0 threadPool )Lorg/elasticsearch/threadpool/ThreadPool; clusterService *Lorg/elasticsearch/cluster/ClusterService; cleanInterval )Lorg/elasticsearch/common/unit/TimeValue; reaper @Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Reaper; registeredClosedListeners $Ljava/util/concurrent/ConcurrentMap; }Ljava/util/concurrent/ConcurrentMap<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$CleanupKey;Ljava/lang/Boolean;>; keysToClean Ljava/util/Set; ULjava/util/Set<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$CleanupKey;>; size expire concurrencyLevel I cache &Lorg/elasticsearch/common/cache/Cache; ?Lorg/elasticsearch/common/cache/Cache<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;Lorg/elasticsearch/common/bytes/BytesReference;>; $assertionsDisabled Z <init> ?(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/threadpool/ThreadPool;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V I L M >org/elasticsearch/common/util/concurrent/ConcurrentCollections O newConcurrentMap &()Ljava/util/concurrent/ConcurrentMap; Q R P S : ; U newConcurrentSet ()Ljava/util/Set; W X P Y = > [ 4 5 ] 2 3 _ < 'org/elasticsearch/common/unit/TimeValue c timeValueSeconds ,(J)Lorg/elasticsearch/common/unit/TimeValue; e f d g *org/elasticsearch/common/settings/Settings i getAsTime f(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; k l j m 6 7 o 1% q get 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; s t j u @ # w A 7 y java/lang/Integer { valueOf (I)Ljava/lang/Integer; } ~ | getAsInt :(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer; ? ? j ? intValue ()I ? ? | ? B C ? 7org/elasticsearch/ElasticsearchIllegalArgumentException ? java/lang/StringBuilder ? ()V I ? ? ? 'concurrency_level must be > 0 but was: ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? ? ? (I)Ljava/lang/StringBuilder; ? ? ? ? toString ()Ljava/lang/String; ? ? ? ? (Ljava/lang/String;)V I ? ? ? (org/elasticsearch/cluster/ClusterService ? 'org/elasticsearch/threadpool/ThreadPool ? buildCache ? ? ? w(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache;Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$1;)V I ? ? 8 9 ? same ? schedule w(Lorg/elasticsearch/common/unit/TimeValue;Ljava/lang/String;Ljava/lang/Runnable;)Ljava/util/concurrent/ScheduledFuture; ? ? ? ? this 9Lorg/elasticsearch/indices/cache/query/IndicesQueryCache; settings ,Lorg/elasticsearch/common/settings/Settings; -org/elasticsearch/common/unit/MemorySizeValue ? parseBytesSizeValueOrHeapRatio A(Ljava/lang/String;)Lorg/elasticsearch/common/unit/ByteSizeValue; ? ? ? ? +org/elasticsearch/common/unit/ByteSizeValue ? bytes ()J ? ? ? ? +org/elasticsearch/common/cache/CacheBuilder ? newBuilder /()Lorg/elasticsearch/common/cache/CacheBuilder; ? ? ? ? maximumWeight 0(J)Lorg/elasticsearch/common/cache/CacheBuilder; ? ? ? ? >(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$1;)V I ? ? weigher W(Lorg/elasticsearch/common/cache/Weigher;)Lorg/elasticsearch/common/cache/CacheBuilder; ? ? ? ? removalListener _(Lorg/elasticsearch/common/cache/RemovalListener;)Lorg/elasticsearch/common/cache/CacheBuilder; ? ? ? ? 0(I)Lorg/elasticsearch/common/cache/CacheBuilder; B ? ? ? millis ? ? d ? java/util/concurrent/TimeUnit ? MILLISECONDS Ljava/util/concurrent/TimeUnit; ? ? ? ? expireAfterAccess O(JLjava/util/concurrent/TimeUnit;)Lorg/elasticsearch/common/cache/CacheBuilder; ? ? ? ? build (()Lorg/elasticsearch/common/cache/Cache; ? ? ? ? D E ? sizeInBytes J cacheBuilder ?Lorg/elasticsearch/common/cache/CacheBuilder<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;Lorg/elasticsearch/common/bytes/BytesReference;>; -Lorg/elasticsearch/common/cache/CacheBuilder; close ? ? ? $org/elasticsearch/common/cache/Cache ? invalidateAll ? ? ? ? clear 5(Lorg/elasticsearch/index/shard/service/IndexShard;)V???????? ?(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache;Lorg/elasticsearch/index/shard/service/IndexShard;JLorg/elasticsearch/indices/cache/query/IndicesQueryCache$1;)V I java/util/Set add (Ljava/lang/Object;)Z logger +Lorg/elasticsearch/common/logging/ESLogger; {} explicit cache clear java/lang/Object 0org/elasticsearch/index/shard/service/IndexShard shardId )()Lorg/elasticsearch/index/shard/ShardId; )org/elasticsearch/common/logging/ESLogger trace ((Ljava/lang/String;[Ljava/lang/Object;)V reap ? shard 2Lorg/elasticsearch/index/shard/service/IndexShard; onRemoval 7(Lorg/elasticsearch/common/cache/RemovalNotification;)V 2org/elasticsearch/common/cache/RemovalNotification$ getKey ()Ljava/lang/Object;&' %( ! * queryCache 7()Lorg/elasticsearch/index/cache/query/ShardQueryCache;,-. 3org/elasticsearch/index/cache/query/ShardQueryCache0"# 12 notification ?Lorg/elasticsearch/common/cache/RemovalNotification<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;Lorg/elasticsearch/common/bytes/BytesReference;>; 4Lorg/elasticsearch/common/cache/RemovalNotification; canCache j(Lorg/elasticsearch/search/internal/ShardSearchRequest;Lorg/elasticsearch/search/internal/SearchContext;)Z 4org/elasticsearch/search/internal/ShardSearchRequest9 templateSource 1()Lorg/elasticsearch/common/bytes/BytesReference;;<:= org/elasticsearch/common/Strings? hasLength 2(Lorg/elasticsearch/common/bytes/BytesReference;)ZAB @C /org/elasticsearch/search/internal/SearchContextE searchType .()Lorg/elasticsearch/action/search/SearchType;GH FI *org/elasticsearch/action/search/SearchTypeK COUNT ,Lorg/elasticsearch/action/search/SearchType;MN LO state *()Lorg/elasticsearch/cluster/ClusterState;QR ?S &org/elasticsearch/cluster/ClusterStateU getMetaData /()Lorg/elasticsearch/cluster/metadata/MetaData;WX VY index[ ?:\ +org/elasticsearch/cluster/metadata/MetaData^ F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData;[` _a 0org/elasticsearch/cluster/metadata/IndexMetaDatac ()Ljava/lang/Boolean;,e:f .()Lorg/elasticsearch/common/settings/Settings; ?h di java/lang/Booleank FALSE Ljava/lang/Boolean;mn lo getAsBoolean :(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;qr js booleanValue ()Zuv lw searcher :()Lorg/elasticsearch/search/internal/ContextIndexSearcher;yz F{ 6org/elasticsearch/search/internal/ContextIndexSearcher} getIndexReader '()Lorg/apache/lucene/index/IndexReader;? ~? 'org/apache/lucene/index/DirectoryReader? nowInMillisUsed?v F? request 6Lorg/elasticsearch/search/internal/ShardSearchRequest; context 1Lorg/elasticsearch/search/internal/SearchContext; 2Lorg/elasticsearch/cluster/metadata/IndexMetaData; load ?(Lorg/elasticsearch/search/internal/ShardSearchRequest;Lorg/elasticsearch/search/internal/SearchContext;Lorg/elasticsearch/search/query/QueryPhase;)Lorg/elasticsearch/search/query/QuerySearchResultProvider; java/lang/Exception? G H ?78 ? java/lang/AssertionError? ? ? buildKey ?(Lorg/elasticsearch/search/internal/ShardSearchRequest;Lorg/elasticsearch/search/internal/SearchContext;)Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;?? ? ?(Lorg/elasticsearch/search/query/QueryPhase;Lorg/elasticsearch/search/internal/SearchContext;Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;)V I? ? E(Ljava/lang/Object;Ljava/util/concurrent/Callable;)Ljava/lang/Object; s? ?? -org/elasticsearch/common/bytes/BytesReference? isLoaded?v ? onMiss? ? 1? indexShard 4()Lorg/elasticsearch/index/shard/service/IndexShard;?? F? getVersion? ? ?? "java/util/concurrent/ConcurrentMap? containsKey??? TRUE?n l? putIfAbsent 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;???? addReaderClosedListener =(Lorg/apache/lucene/index/IndexReader$ReaderClosedListener;)V?? ? onHit? ? 1? id? ? F? shardTarget .()Lorg/elasticsearch/search/SearchShardTarget;?? F? queryResult 4()Lorg/elasticsearch/search/query/QuerySearchResult;?? F? )org/elasticsearch/search/query/QueryPhase? *org/elasticsearch/search/SearchShardTarget? 0org/elasticsearch/search/query/QuerySearchResult? ?(JLorg/elasticsearch/search/SearchShardTarget;Lorg/elasticsearch/common/bytes/BytesReference;Lorg/elasticsearch/search/query/QuerySearchResult;Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$1;)V I? ? previous cleanupKey DLorg/elasticsearch/indices/cache/query/IndicesQueryCache$CleanupKey; queryPhase +Lorg/elasticsearch/search/query/QueryPhase; key =Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key; loader @Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Loader; value /Lorg/elasticsearch/common/bytes/BytesReference; )verifyCacheSerializationSameAsQueryResult ?(Lorg/elasticsearch/common/bytes/BytesReference;Lorg/elasticsearch/search/internal/SearchContext;Lorg/elasticsearch/search/query/QuerySearchResult;)Z 4org/elasticsearch/common/io/stream/BytesStreamOutput? ? ? ?(JLorg/elasticsearch/search/SearchShardTarget;Lorg/elasticsearch/common/bytes/BytesReference;Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$1;)V I? ? writeTo 4(Lorg/elasticsearch/common/io/stream/StreamOutput;)V?? ? ?? ?< ?? equals? ? cacheData result 2Lorg/elasticsearch/search/query/QuerySearchResult; out1 6Lorg/elasticsearch/common/io/stream/BytesStreamOutput; out2 cacheKey?<:? e(Lorg/elasticsearch/index/shard/service/IndexShard;JLorg/elasticsearch/common/bytes/BytesReference;)V I? ? access$400?? x0 x1 x2 access$600 d(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache;)Lorg/elasticsearch/threadpool/ThreadPool; access$700 f(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache;)Lorg/elasticsearch/common/logging/ESLogger; access$800 d(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache;)Lorg/elasticsearch/common/unit/TimeValue; access$900 access$1000 a(Lorg/elasticsearch/indices/cache/query/IndicesQueryCache;)Lorg/elasticsearch/common/cache/Cache; <clinit> java/lang/Class desiredAssertionStatusv ConstantValue Signature Code LocalVariableTable LineNumberTable StackMapTable RuntimeVisibleAnnotations LocalVariableTypeTable ?(Lorg/elasticsearch/common/cache/RemovalNotification<Lorg/elasticsearch/indices/cache/query/IndicesQueryCache$Key;Lorg/elasticsearch/common/bytes/BytesReference;>;)V Exceptions SourceFile InnerClasses ! "