3q/org/elasticsearch/indices/ttl/IndicesTTLServicerLorg/elasticsearch/common/component/AbstractLifecycleComponent;=org/elasticsearch/common/component/AbstractLifecycleComponentIndicesTTLService.java8org/elasticsearch/indices/ttl/IndicesTTLService$NotifierNotifier=org/elasticsearch/indices/ttl/IndicesTTLService$ApplySettings  ApplySettingsDorg/elasticsearch/indices/ttl/IndicesTTLService$ExpiredDocsCollector ExpiredDocsCollector:org/elasticsearch/indices/ttl/IndicesTTLService$DocToPurge DocToPurgeLorg/elasticsearch/indices/ttl/IndicesTTLService$PurgerThread;(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/node/settings/NodeSettingsService;Lorg/elasticsearch/action/bulk/TransportBulkAction;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V 36 7 )* 9 +, ;componentSettings,Lorg/elasticsearch/common/settings/Settings; => ?intervalA<'org/elasticsearch/common/unit/TimeValueEtimeValueSeconds,(J)Lorg/elasticsearch/common/unit/TimeValue; GH FI*org/elasticsearch/common/settings/SettingsK getAsTimef(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; MN LO -. Q bulk_sizeSjava/lang/IntegerUvalueOf(I)Ljava/lang/Integer; WX VYgetAsInt:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer; [\ L]intValue()I _` Va /0 c [ttl_expire]e4org/elasticsearch/common/util/concurrent/EsExecutorsg threadNameR(Lorg/elasticsearch/common/settings/Settings;Ljava/lang/String;)Ljava/lang/String; ij hko(Lorg/elasticsearch/indices/ttl/IndicesTTLService;Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)V 3m n 12 p4(Lorg/elasticsearch/indices/ttl/IndicesTTLService;)V 3r s addListenerA(Lorg/elasticsearch/node/settings/NodeSettingsService$Listener;)V uv wthis1Lorg/elasticsearch/indices/ttl/IndicesTTLService;settingsnodeSettingsService5Lorg/elasticsearch/node/settings/NodeSettingsService;)Lorg/elasticsearch/common/unit/TimeValue;doStart()V(org/elasticsearch/ElasticsearchExceptionstart doStopjava/lang/InterruptedExceptionshutdown java/lang/Thread interrupted()Z e Ljava/lang/InterruptedException;doClose purgeShards(Ljava/util/List;)Vjava/lang/Exceptionjava/util/Listiterator()Ljava/util/Iterator; java/util/IteratorhasNext next()Ljava/lang/Object; 0org/elasticsearch/index/shard/service/IndexShard indexService0()Lorg/elasticsearch/index/service/IndexService; ,org/elasticsearch/index/service/IndexService mapperService0()Lorg/elasticsearch/index/mapper/MapperService; _ttl,org/elasticsearch/index/mapper/MapperServicesmartNameFieldMapper@(Ljava/lang/String;)Lorg/elasticsearch/index/mapper/FieldMapper; java/lang/SystemcurrentTimeMillis()J java/lang/Long(J)Ljava/lang/Long; W *org/elasticsearch/index/mapper/FieldMapper rangeQueryy(Ljava/lang/Object;Ljava/lang/Object;ZZLorg/elasticsearch/index/query/QueryParseContext;)Lorg/apache/lucene/search/Query;  indices_ttlacquireSearcherD(Ljava/lang/String;)Lorg/elasticsearch/index/engine/Engine$Searcher; logger+Lorg/elasticsearch/common/logging/ESLogger; [{}][{}] purging shardjava/lang/Object routingEntry2()Lorg/elasticsearch/cluster/routing/ShardRouting; .org/elasticsearch/cluster/routing/ShardRoutingindex()Ljava/lang/String; id ` )org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V ssearcher*()Lorg/apache/lucene/search/IndexSearcher; &org/apache/lucene/search/IndexSearchersearchG(Lorg/apache/lucene/search/Query;Lorg/apache/lucene/search/Collector;)V getDocsToPurge()Ljava/util/List; )org/elasticsearch/action/bulk/BulkRequest 3 org/apache/lucene/search/Query-org/elasticsearch/action/delete/DeleteRequest c(Ljava/lang/String;)Lorg/elasticsearch/action/support/replication/ShardReplicationOperationRequest;  type  #  C(Ljava/lang/String;)Lorg/elasticsearch/action/delete/DeleteRequest;    #   versionJ  2(J)Lorg/elasticsearch/action/delete/DeleteRequest;  routing #   add\(Lorg/elasticsearch/action/delete/DeleteRequest;)Lorg/elasticsearch/action/bulk/BulkRequest;  !processBulkIfNeededY(Lorg/elasticsearch/action/bulk/BulkRequest;Z)Lorg/elasticsearch/action/bulk/BulkRequest; #$ %close ' (failed to purge*warn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V ,- .java/lang/Throwable0 docToPurge;Ljava/util/List; bulkRequest+Lorg/elasticsearch/action/bulk/BulkRequest;Ljava/lang/Exception;query Lorg/apache/lucene/search/Query;0Lorg/elasticsearch/index/engine/Engine$Searcher; shardToPurge2Lorg/elasticsearch/index/shard/service/IndexShard; shardsToPurgeDLjava/util/List;numberOfActions E` F s1org/elasticsearch/action/bulk/TransportBulkActionI executeBulkW(Lorg/elasticsearch/action/bulk/BulkRequest;Lorg/elasticsearch/action/ActionListener;)V KL JMfailed to process bulkOforceZ access$000D(Lorg/elasticsearch/indices/ttl/IndicesTTLService;Ljava/util/List;)V Ux0x1 access$100^(Lorg/elasticsearch/indices/ttl/IndicesTTLService;)Lorg/elasticsearch/common/logging/ESLogger; access$200](Lorg/elasticsearch/indices/ttl/IndicesTTLService;)Lorg/elasticsearch/cluster/ClusterService; access$300](Lorg/elasticsearch/indices/ttl/IndicesTTLService;)Lorg/elasticsearch/indices/IndicesService; access$400 access$500 access$600 access$700q(Lorg/elasticsearch/indices/ttl/IndicesTTLService;)Lorg/elasticsearch/indices/ttl/IndicesTTLService$PurgerThread; access$800 ConstantValueCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotations Exceptions StackMapTableLocalVariableTypeTable SignatureG(Ljava/util/List;)V SourceFile InnerClasses!"#e%&#e()*+,-./01234fb*+8*,:*-<*@BCJP:*R**@T'Z^bd*Y*+floq Y*txgHbyzb{>b)*b+,b|}b-."@A~h& RS TU"V(W@XTZa[i5f6*qg yzh _`jfi*qLW g yzheh f gikJjf+g yzhmjf D+M,6,N-:-ι:*Y-SY-ZSY*::Y::  Y : Y-     "W*&:*&W)-:*+ڹ/): ) DZE E 4*4464gz G23 `45 }67z8:q;<=;>?E@&AB<45DyzDC:lz89DCDhZ;Es} *14@CkV _]1 mn#$fE +G+G*d0*R+Y*HNN*P-ڹ/YL+&)g**=EyzE;<EQRh&#)!*";$C&k  RSTf:*+VgWzX:hDYZf/*ְg WzhD[\f/*:g WzhD]^f/*<g WzhD_Zf/*ְg WzhD`Zf/*ְg WzhDaZf/*ְg WzhDbcf/*qg WzhDdZf/*ְg WzhDmopB      !