33org/elasticsearch/action/count/TransportCountActionLorg/elasticsearch/action/support/broadcast/TransportBroadcastOperationAction;Lorg/elasticsearch/action/support/broadcast/TransportBroadcastOperationActionTransportCountAction.java@org/elasticsearch/common/lucene/Lucene$EarlyTerminatingCollector&org/elasticsearch/common/lucene/Lucene EarlyTerminatingCollector.org/elasticsearch/index/engine/Engine$Searcher %org/elasticsearch/index/engine/EngineSearcherindicesService*Lorg/elasticsearch/indices/IndicesService; scriptService(Lorg/elasticsearch/script/ScriptService; cacheRecycler0Lorg/elasticsearch/cache/recycler/CacheRecycler;pageCacheRecycler4Lorg/elasticsearch/cache/recycler/PageCacheRecycler; bigArrays)Lorg/elasticsearch/common/util/BigArrays;(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/script/ScriptService;Lorg/elasticsearch/cache/recycler/CacheRecycler;Lorg/elasticsearch/cache/recycler/PageCacheRecycler;Lorg/elasticsearch/common/util/BigArrays;Lorg/elasticsearch/action/support/ActionFilters;)V(Lorg/elasticsearch/common/inject/Inject;indices:data/read/count(Lorg/elasticsearch/common/settings/Settings;Ljava/lang/String;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/action/support/ActionFilters;)V  !  #  %  '  )  +this5Lorg/elasticsearch/action/count/TransportCountAction;settings,Lorg/elasticsearch/common/settings/Settings; threadPool)Lorg/elasticsearch/threadpool/ThreadPool;clusterService*Lorg/elasticsearch/cluster/ClusterService;transportService.Lorg/elasticsearch/transport/TransportService; actionFilters0Lorg/elasticsearch/action/support/ActionFilters; doExecuteY(Lorg/elasticsearch/action/count/CountRequest;Lorg/elasticsearch/action/ActionListener;)Vjava/lang/System;currentTimeMillis()J => <?+org/elasticsearch/action/count/CountRequestA nowInMillisJ CD BEr(Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;Lorg/elasticsearch/action/ActionListener;)V 9G Hrequest-Lorg/elasticsearch/action/count/CountRequest;listenerYLorg/elasticsearch/action/ActionListener;)Lorg/elasticsearch/action/ActionListener;executor()Ljava/lang/String;searchQ newRequest/()Lorg/elasticsearch/action/count/CountRequest;()V U BVnewShardRequest4()Lorg/elasticsearch/action/count/ShardCountRequest;0org/elasticsearch/action/count/ShardCountRequestZ [V(ILorg/elasticsearch/cluster/routing/ShardRouting;Lorg/elasticsearch/action/count/CountRequest;)Lorg/elasticsearch/action/count/ShardCountRequest; 34 ^(org/elasticsearch/cluster/ClusterService`state*()Lorg/elasticsearch/cluster/ClusterState; bc ad&org/elasticsearch/cluster/ClusterStatefmetaData/()Lorg/elasticsearch/cluster/metadata/MetaData; hi gj.org/elasticsearch/cluster/routing/ShardRoutinglindex nP moindices()[Ljava/lang/String; qr Bs+org/elasticsearch/cluster/metadata/MetaDataufilteringAliases:(Ljava/lang/String;[Ljava/lang/String;)[Ljava/lang/String; wx vyshardId)()Lorg/elasticsearch/index/shard/ShardId; {| m}j(Lorg/elasticsearch/index/shard/ShardId;[Ljava/lang/String;Lorg/elasticsearch/action/count/CountRequest;)V  [ numShardsIshard0Lorg/elasticsearch/cluster/routing/ShardRouting;[Ljava/lang/String;newShardResponse5()Lorg/elasticsearch/action/count/ShardCountResponse;1org/elasticsearch/action/count/ShardCountResponse Vshards(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/action/count/CountRequest;[Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/GroupShardsIterator;routing P BresolveSearchRouting6(Ljava/lang/String;[Ljava/lang/String;)Ljava/util/Map; voperationRouting@()Lorg/elasticsearch/cluster/routing/operation/OperationRouting; a preference P B;>;Ljava/util/Map;checkGlobalBlock(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/action/count/CountRequest;)Lorg/elasticsearch/cluster/block/ClusterBlockException;blocks1()Lorg/elasticsearch/cluster/block/ClusterBlocks; g1org/elasticsearch/cluster/block/ClusterBlockLevelREAD3Lorg/elasticsearch/cluster/block/ClusterBlockLevel; -org/elasticsearch/cluster/block/ClusterBlocksglobalBlockedExceptionl(Lorg/elasticsearch/cluster/block/ClusterBlockLevel;)Lorg/elasticsearch/cluster/block/ClusterBlockException; checkRequestBlock(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/action/count/CountRequest;[Ljava/lang/String;)Lorg/elasticsearch/cluster/block/ClusterBlockException;indicesBlockedException(Lorg/elasticsearch/cluster/block/ClusterBlockLevel;[Ljava/lang/String;)Lorg/elasticsearch/cluster/block/ClusterBlockException;  countRequest newResponse(Lorg/elasticsearch/action/count/CountRequest;Ljava/util/concurrent/atomic/AtomicReferenceArray;Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/action/count/CountResponse;0java/util/concurrent/atomic/AtomicReferenceArrayjava/util/Listlength()I get(I)Ljava/lang/Object; java/lang/ObjectQorg/elasticsearch/action/support/broadcast/BroadcastShardOperationFailedException&org/elasticsearch/common/collect/Lists newArrayList()Ljava/util/ArrayList; Eorg/elasticsearch/action/support/DefaultShardOperationFailedException6(Lorg/elasticsearch/index/shard/IndexShardException;)V  add(Ljava/lang/Object;)Z getCount > terminatedEarly()Z ,org/elasticsearch/action/count/CountResponse(JZIIILjava/util/List;)V   shardResponseLjava/lang/Object;ishardsResponses2Ljava/util/concurrent/atomic/AtomicReferenceArray;successfulShards failedShardscountZ shardFailuresJLjava/util/List;Ljava/util/List;shardOperationg(Lorg/elasticsearch/action/count/ShardCountRequest;)Lorg/elasticsearch/action/count/ShardCountResponse;(org/elasticsearch/ElasticsearchExceptionjava/lang/Exception [}%org/elasticsearch/index/shard/ShardIdgetIndex P (org/elasticsearch/indices/IndicesServiceindexServiceSafeB(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService;   id   ,org/elasticsearch/index/service/IndexService shardSafe5(I)Lorg/elasticsearch/index/shard/service/IndexShard;  *org/elasticsearch/search/SearchShardTarget localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode;  a,org/elasticsearch/cluster/node/DiscoveryNode  P ((Ljava/lang/String;Ljava/lang/String;I)V   6org/elasticsearch/search/internal/DefaultSearchContext"9org/elasticsearch/search/internal/ShardSearchLocalRequest$types &r [' C> [) wr [+*([Ljava/lang/String;J[Ljava/lang/String;)V - %.0org/elasticsearch/index/shard/service/IndexShard1acquireSearcherD(Ljava/lang/String;)Lorg/elasticsearch/index/engine/Engine$Searcher; 34 25 12 7'org/elasticsearch/threadpool/ThreadPool9estimatedTimeInMillisCounter"()Lorg/apache/lucene/util/Counter; ;< :=(JLorg/elasticsearch/search/internal/ShardSearchRequest;Lorg/elasticsearch/search/SearchShardTarget;Lorg/elasticsearch/index/engine/Engine$Searcher;Lorg/elasticsearch/index/service/IndexService;Lorg/elasticsearch/index/shard/service/IndexShard;Lorg/elasticsearch/script/ScriptService;Lorg/elasticsearch/cache/recycler/CacheRecycler;Lorg/elasticsearch/cache/recycler/PageCacheRecycler;Lorg/elasticsearch/common/util/BigArrays;Lorg/apache/lucene/util/Counter;)V ? #@/org/elasticsearch/search/internal/SearchContextB setCurrent4(Lorg/elasticsearch/search/internal/SearchContext;)V DE CFminScore()F HI [J minimumScore4(F)Lorg/elasticsearch/search/internal/SearchContext; MN CO querySource1()Lorg/elasticsearch/common/bytes/BytesReference; QR [S-org/elasticsearch/common/bytes/BytesReferenceU V/org/elasticsearch/index/query/QueryParseContextXsetTypes([Ljava/lang/String;)V Z[ Y\queryParserService9()Lorg/elasticsearch/index/query/IndexQueryParserService; ^_ `5org/elasticsearch/index/query/IndexQueryParserServiceb parseQuery\(Lorg/elasticsearch/common/bytes/BytesReference;)Lorg/elasticsearch/index/query/ParsedQuery; de cf parsedQuery^(Lorg/elasticsearch/index/query/ParsedQuery;)Lorg/elasticsearch/search/internal/SearchContext; hi Cj removeTypes lU Ymjava/lang/ThrowableoterminateAfter q [r preProcess tU Cu)createCountBasedEarlyTerminatingCollectorE(I)Lorg/elasticsearch/common/lucene/Lucene$EarlyTerminatingCollector; wx ysearcher:()Lorg/elasticsearch/search/internal/ContextIndexSearcher; {| C}query"()Lorg/apache/lucene/search/Query;  CcountWithEarlyTermination(Lorg/apache/lucene/search/IndexSearcher;Lorg/apache/lucene/search/Query;Lorg/elasticsearch/common/lucene/Lucene$EarlyTerminatingCollector;)Z   K(Lorg/apache/lucene/search/IndexSearcher;Lorg/apache/lucene/search/Query;)J  ,(Lorg/elasticsearch/index/shard/ShardId;JZ)V  close U C removeCurrent U C;org/elasticsearch/search/query/QueryPhaseExecutionExceptionfailed to execute count[(Lorg/elasticsearch/search/internal/SearchContext;Ljava/lang/String;Ljava/lang/Throwable;)V  countCollectorBLorg/elasticsearch/common/lucene/Lucene$EarlyTerminatingCollector;eLjava/lang/Exception;source/Lorg/elasticsearch/common/bytes/BytesReference;hasTerminateAfterCount2Lorg/elasticsearch/action/count/ShardCountRequest; indexService.Lorg/elasticsearch/index/service/IndexService; indexShard2Lorg/elasticsearch/index/shard/service/IndexShard; shardTarget,Lorg/elasticsearch/search/SearchShardTarget;context1Lorg/elasticsearch/search/internal/SearchContext;(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;[Ljava/lang/String;)Lorg/elasticsearch/cluster/block/ClusterBlockException; x0x1FLorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;x2(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;)Lorg/elasticsearch/cluster/block/ClusterBlockException; (Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;[Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/GroupShardsIterator; (Lorg/elasticsearch/action/support/broadcast/BroadcastShardOperationRequest;)Lorg/elasticsearch/action/support/broadcast/BroadcastShardOperationResponse; KLorg/elasticsearch/action/support/broadcast/BroadcastShardOperationRequest;N()Lorg/elasticsearch/action/support/broadcast/BroadcastShardOperationResponse; (ILorg/elasticsearch/cluster/routing/ShardRouting;Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;)Lorg/elasticsearch/action/support/broadcast/BroadcastShardOperationRequest; X] M()Lorg/elasticsearch/action/support/broadcast/BroadcastShardOperationRequest; XY (Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest;Ljava/util/concurrent/atomic/AtomicReferenceArray;Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/action/support/broadcast/BroadcastOperationResponse; H()Lorg/elasticsearch/action/support/broadcast/BroadcastOperationRequest; ST  9: T(Lorg/elasticsearch/action/ActionRequest;Lorg/elasticsearch/action/ActionListener;)V(Lorg/elasticsearch/action/ActionRequest;CodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotationsLocalVariableTypeTable Signature(Lorg/elasticsearch/action/count/CountRequest;Lorg/elasticsearch/action/ActionListener;)V StackMapTable Exceptions SourceFile InnerClasses! ,*+,- "*$*&*(*** ,p ,-.,/0,12,34,56,,,,, ,78 R STUV%W+X9:f+@F*+,I -.JKLN LM\] ^OP-R -.bST2BYW -.gXY2[Y\ -.lX],*_ek,p-tz:[Y,~-4,-.,,,JKw qr2Y -.w,+k,,t:*_+,t-,4,-.,,JK,  |}I +  -. b JKT +-* -. b K  66 76: 6  ,ʢc, :  M ҙ' :  Y ҷݹW! a7 6 Y, p #R i -.JK D    N #+36;@Wdoru{, Bg*a*$+ M,+NY*_++!:#Y %Y+(+*+,/-06,-*&*(***,*8>A:G+KL +KPW+T:3W)+(],agkWn :n+s66v(+sz: ~ 6 7 ~7 Y+ :  : Y :  8C8TCVT  D 'D E nka-.aJPBBzB '8=CET[ [2C2[2CVp @3 [2CV[2CpDS *+,B-* -.   BDH *+,B  -.  BDS *+,B-* -.   BD= *+[ -. BD/* -.BDXS *,-B°* -.   BDX/*Ű -.BDS *+B,-Ȱ* -.   BDS/*˰ -.BD9GH *+B,ͱ  -.  NBD9H *+B,ͱ  -.  NB