36org/elasticsearch/index/engine/internal/InternalEngine9org/elasticsearch/index/shard/AbstractIndexShardComponent%org/elasticsearch/index/engine/EngineInternalEngine.java?org/elasticsearch/index/engine/internal/InternalEngine$NoOpLockNoOpLockDorg/elasticsearch/index/engine/internal/InternalEngine$IndexThrottle  IndexThrottleCorg/elasticsearch/index/engine/internal/InternalEngine$InternalLock InternalLockForg/elasticsearch/index/engine/internal/InternalEngine$RecoveryCounterRecoveryCounterDorg/elasticsearch/index/engine/internal/InternalEngine$SearchFactory SearchFactoryEorg/elasticsearch/index/engine/internal/InternalEngine$EngineSearcherEngineSearcherDorg/elasticsearch/index/engine/internal/InternalEngine$ApplySettings ApplySettingsOorg/elasticsearch/index/engine/internal/InternalEngine$FailEngineOnMergeFailureFailEngineOnMergeFailure8org/elasticsearch/index/engine/internal/InternalEngine$4 8org/elasticsearch/index/engine/internal/InternalEngine$3"8org/elasticsearch/index/engine/internal/InternalEngine$2$8org/elasticsearch/index/engine/internal/InternalEngine$1&:org/elasticsearch/index/engine/Engine$FailedEngineListener(FailedEngineListener)org/elasticsearch/index/engine/Engine$Get+Get/org/elasticsearch/index/engine/Engine$GetResult. GetResult3org/elasticsearch/index/translog/Translog$Operation1)org/elasticsearch/index/translog/Translog3 Operation.org/elasticsearch/index/engine/Engine$Searcher6SearcherCreate2org/elasticsearch/index/translog/Translog$LocationALocation+org/elasticsearch/index/engine/Engine$IndexDIndex,org/elasticsearch/index/engine/Engine$DeleteGDelete3org/elasticsearch/index/engine/Engine$DeleteByQueryJ DeleteByQuery-org/elasticsearch/index/engine/Engine$RefreshMRefresh+org/elasticsearch/index/engine/Engine$FlushPFlushjava/util/Map$EntryS java/util/MapUEntry.org/elasticsearch/index/engine/Engine$OptimizeXOptimize5org/elasticsearch/index/engine/Engine$RecoveryHandler[RecoveryHandler2org/elasticsearch/index/translog/Translog$Snapshot^Snapshot0org/elasticsearch/index/translog/Translog$Createa/org/elasticsearch/index/translog/Translog$Indexc0org/elasticsearch/index/translog/Translog$Deletee7org/elasticsearch/index/translog/Translog$DeleteByQueryg2org/apache/lucene/index/IndexWriterConfig$OpenModei)org/apache/lucene/index/IndexWriterConfigkOpenMode:java/util/concurrent/locks/ReentrantReadWriteLock$ReadLockn1java/util/concurrent/locks/ReentrantReadWriteLockpReadLock;java/util/concurrent/locks/ReentrantReadWriteLock$WriteLocks WriteLock>org/elasticsearch/index/settings/IndexSettingsService$Listenerv5org/elasticsearch/index/settings/IndexSettingsServicexListenerNorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$FailureListener{>org/elasticsearch/index/merge/scheduler/MergeSchedulerProvider}FailureListener0org/elasticsearch/index/engine/Engine$Flush$TypeTypeGorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$Listener0org/elasticsearch/index/translog/Translog$SourceSource/org/elasticsearch/index/engine/Engine$Operation6org/elasticsearch/index/engine/Engine$Operation$OriginOrigin5org/apache/lucene/index/IndexWriter$IndexReaderWarmer#org/apache/lucene/index/IndexWriterIndexReaderWarmerfailEngineOnCorruptionZindexingBufferSize-Lorg/elasticsearch/common/unit/ByteSizeValue;indexConcurrencyIcompoundOnFlushchecksumOnMergegcDeletesInMillisJlastDeleteVersionPruneTimeMSecenableGcDeletes codecNameLjava/lang/String;optimizeAutoGenerateId threadPool)Lorg/elasticsearch/threadpool/ThreadPool;indexingService7Lorg/elasticsearch/index/indexing/ShardIndexingService;indexSettingsService7Lorg/elasticsearch/index/settings/IndexSettingsService;warmer8Lorg/elasticsearch/indices/warmer/InternalIndicesWarmer;#Lorg/elasticsearch/common/Nullable;store%Lorg/elasticsearch/index/store/Store;deletionPolicy?Lorg/elasticsearch/index/deletionpolicy/SnapshotDeletionPolicy;translog+Lorg/elasticsearch/index/translog/Translog;mergePolicyProvider:Lorg/elasticsearch/index/merge/policy/MergePolicyProvider;mergeScheduler@Lorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider;analysisService2Lorg/elasticsearch/index/analysis/AnalysisService;similarityService6Lorg/elasticsearch/index/similarity/SimilarityService; codecService,Lorg/elasticsearch/index/codec/CodecService;rwl3Ljava/util/concurrent/locks/ReentrantReadWriteLock;readLockELorg/elasticsearch/index/engine/internal/InternalEngine$InternalLock; writeLock indexWriter%Lorg/apache/lucene/index/IndexWriter;searcherFactory*Lorg/apache/lucene/search/SearcherFactory;searcherManager*Lorg/apache/lucene/search/SearcherManager;closeddirtypossibleMergeNeeded optimizeMutex+Ljava/util/concurrent/atomic/AtomicBoolean; flushNeededflushing+Ljava/util/concurrent/atomic/AtomicInteger; flushLock!Ljava/util/concurrent/locks/Lock;onGoingRecoveriesHLorg/elasticsearch/index/engine/internal/InternalEngine$RecoveryCounter; versionMap8Lorg/elasticsearch/index/engine/internal/LiveVersionMap; dirtyLocks[Ljava/lang/Object; refreshMutexLjava/lang/Object; applySettingsFLorg/elasticsearch/index/engine/internal/InternalEngine$ApplySettings;failOnMergeFailure failedEngineLjava/lang/Throwable;failEngineLockfailedEngineListeners+Ljava/util/concurrent/CopyOnWriteArrayList;iLjava/util/concurrent/CopyOnWriteArrayList;translogIdGenerator(Ljava/util/concurrent/atomic/AtomicLong;versionMapRefreshPendinglastCommittedSegmentInfos&Lorg/apache/lucene/index/SegmentInfos;throttleFLorg/elasticsearch/index/engine/internal/InternalEngine$IndexThrottle;INDEX_INDEX_CONCURRENCYindex.index_concurrencyINDEX_COMPOUND_ON_FLUSHindex.compound_on_flushINDEX_CHECKSUM_ON_MERGEindex.checksum_on_mergeINDEX_GC_DELETESindex.gc_deletesINDEX_FAIL_ON_MERGE_FAILUREindex.fail_on_merge_failureINDEX_FAIL_ON_CORRUPTIONindex.fail_on_corruption$assertionsDisabled(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/index/settings/IndexSettingsService;Lorg/elasticsearch/index/indexing/ShardIndexingService;Lorg/elasticsearch/indices/warmer/IndicesWarmer;Lorg/elasticsearch/index/store/Store;Lorg/elasticsearch/index/deletionpolicy/SnapshotDeletionPolicy;Lorg/elasticsearch/index/translog/Translog;Lorg/elasticsearch/index/merge/policy/MergePolicyProvider;Lorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider;Lorg/elasticsearch/index/analysis/AnalysisService;Lorg/elasticsearch/index/similarity/SimilarityService;Lorg/elasticsearch/index/codec/CodecService;)V.org/elasticsearch/index/engine/EngineException(Lorg/elasticsearch/common/inject/Inject;0Lorg/elasticsearch/index/settings/IndexSettings;V(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;)V     ()V  q  >()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;  q$(Ljava/util/concurrent/locks/Lock;)V   ?()Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;  q ;(Lorg/elasticsearch/index/engine/internal/InternalEngine;)V     " $)java/util/concurrent/atomic/AtomicBoolean& ' ) +)java/util/concurrent/atomic/AtomicInteger- . 0(java/util/concurrent/locks/ReentrantLock2 3 5u(Lorg/elasticsearch/index/engine/internal/InternalEngine;Lorg/elasticsearch/index/engine/internal/InternalEngine$1;)V 7 8 :java/lang/Object< = ?  B D F)java/util/concurrent/CopyOnWriteArrayListH I K&java/util/concurrent/atomic/AtomicLongM N P R$Store must be provided to the engineT&org/elasticsearch/common/PreconditionsV checkNotNull8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; XY WZ7Snapshot deletion policy must be provided to the engine\'Translog must be provided to the engine^<'org/elasticsearch/common/unit/TimeValuebtimeValueSeconds,(J)Lorg/elasticsearch/common/unit/TimeValue; de cf*org/elasticsearch/common/settings/Settingsh getAsTimef(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; jk ilmillis()J no cp rcomponentSettings,Lorg/elasticsearch/common/settings/Settings; tu vindex_buffer_sizex+org/elasticsearch/common/unit/ByteSizeValuez@*org/elasticsearch/common/unit/ByteSizeUnit~MB,Lorg/elasticsearch/common/unit/ByteSizeUnit;  0(JLorg/elasticsearch/common/unit/ByteSizeUnit;)V  {getAsBytesSizen(Ljava/lang/String;Lorg/elasticsearch/common/unit/ByteSizeValue;)Lorg/elasticsearch/common/unit/ByteSizeValue;  i  index.codecdefaultget8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;  i  'org/elasticsearch/threadpool/ThreadPoolestimatedTimeInMillis o    6org/elasticsearch/indices/warmer/InternalIndicesWarmer         java/lang/BooleanvalueOf(Z)Ljava/lang/Boolean;   getAsBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;  i booleanValue()Z  4org/elasticsearch/common/util/concurrent/EsExecutorsboundedNumberOfProcessors/(Lorg/elasticsearch/common/settings/Settings;)I  ?java/lang/Mathmax(II)I  java/lang/Integer(I)Ljava/lang/Integer;  getAsInt:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;  iintValue()I   6org/elasticsearch/index/engine/internal/LiveVersionMap   %org/elasticsearch/index/shard/ShardId5org/elasticsearch/index/indexing/ShardIndexingService.org/elasticsearch/indices/warmer/IndicesWarmer#org/elasticsearch/index/store/Store=org/elasticsearch/index/deletionpolicy/SnapshotDeletionPolicy8org/elasticsearch/index/merge/policy/MergePolicyProvider0org/elasticsearch/index/analysis/AnalysisService4org/elasticsearch/index/similarity/SimilarityService*org/elasticsearch/index/codec/CodecService index.optimize_auto_generated_id  addListenerC(Lorg/elasticsearch/index/settings/IndexSettingsService$Listener;)V  y   addFailureListenerS(Lorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$FailureListener;)V   ~ incRef   ithis8Lorg/elasticsearch/index/engine/internal/InternalEngine;shardId'Lorg/elasticsearch/index/shard/ShardId; indexSettings0Lorg/elasticsearch/indices/warmer/IndicesWarmer;updateIndexingBufferSize0(Lorg/elasticsearch/common/unit/ByteSizeValue;)Vjava/lang/Throwable4org/elasticsearch/index/engine/EngineClosedException=org/elasticsearch/index/engine/FlushNotAllowedEngineExceptionacquireG()Lorg/elasticsearch/index/engine/internal/InternalEngine$InternalLock;  ! # getConfig1()Lorg/apache/lucene/index/LiveIndexWriterConfig; %& 'mbFrac()D )* {+-org/apache/lucene/index/LiveIndexWriterConfig-setRAMBufferSizeMB2(D)Lorg/apache/lucene/index/LiveIndexWriterConfig; /0 .1close 3 4 addSuppressed(Ljava/lang/Throwable;)V 67 8bytes :o {;INACTIVE_SHARD_INDEXING_BUFFER = >logger+Lorg/elasticsearch/common/logging/ESLogger; @A B7updating index_buffer_size from [{}] to (inactive) [{}]D)org/elasticsearch/common/logging/ESLoggerFdebug((Ljava/lang/String;[Ljava/lang/Object;)V HI GJ Q COMMIT2Lorg/elasticsearch/index/engine/Engine$Flush$Type; MN Otypea(Lorg/elasticsearch/index/engine/Engine$Flush$Type;)Lorg/elasticsearch/index/engine/Engine$Flush; QR QSflush0(Lorg/elasticsearch/index/engine/Engine$Flush;)V UV W/failed to flush after setting shard to inactiveYwarn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V [\ G],updating index_buffer_size from [{}] to [{}]_x2_e6Lorg/elasticsearch/index/engine/EngineClosedException;?Lorg/elasticsearch/index/engine/FlushNotAllowedEngineException;preValueaddFailedEngineListener?(Lorg/elasticsearch/index/engine/Engine$FailedEngineListener;)Vadd(Ljava/lang/Object;)Z ij Iklistener;Ljava/util/Map;(()Lorg/apache/lucene/index/SegmentInfos;   defaultRefreshInterval+()Lorg/elasticsearch/common/unit/TimeValue;java/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;     #(JLjava/util/concurrent/TimeUnit;)V  c/()Lorg/elasticsearch/common/unit/ByteSizeValue;(Z)V^(Lorg/elasticsearch/index/engine/Engine$Get;)Lorg/elasticsearch/index/engine/Engine$GetResult;realtime  ,uid ()Lorg/apache/lucene/index/Term;  ,org/apache/lucene/index/Term#()Lorg/apache/lucene/util/BytesRef; :  getUnderLockY(Lorg/apache/lucene/util/BytesRef;)Lorg/elasticsearch/index/engine/internal/VersionValue;  ! "4org/elasticsearch/index/engine/internal/VersionValue$delete & %' NOT_EXISTS1Lorg/elasticsearch/index/engine/Engine$GetResult; )* /+ versionType'()Lorg/elasticsearch/index/VersionType; -. ,/version 1o %2 ,2#org/elasticsearch/index/VersionType5isVersionConflictForReads(JJ)Z 78 69text()Ljava/lang/String; ;< ="org/elasticsearch/index/mapper/Uid? createUid8(Ljava/lang/String;)Lorg/elasticsearch/index/mapper/Uid; AB @C=org/elasticsearch/index/engine/VersionConflictEngineExceptionE Q< @Gid I< @JP(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/String;JJ)V L FM loadSource O ,P7(ZJLorg/elasticsearch/index/translog/Translog$Source;)V R /StranslogLocation6()Lorg/elasticsearch/index/translog/Translog$Location; UV %Wreadk(Lorg/elasticsearch/index/translog/Translog$Location;)Lorg/elasticsearch/index/translog/Translog$Operation; YZ 4[ getSource4()Lorg/elasticsearch/index/translog/Translog$Source; ]^ 2_acquireSearcherD(Ljava/lang/String;)Lorg/elasticsearch/index/engine/Engine$Searcher; bc dreader'()Lorg/apache/lucene/index/IndexReader; fg 7hloadDocIdAndVersion(Lorg/apache/lucene/index/IndexReader;Lorg/apache/lucene/index/Term;)Lorg/elasticsearch/common/lucene/uid/Versions$DocIdAndVersion; jk <l)org/elasticsearch/common/lease/Releasablen*org/elasticsearch/common/lease/Releasablesp/([Lorg/elasticsearch/common/lease/Releasable;)V r qs)()Lorg/elasticsearch/index/shard/ShardId; u vCouldn't resolve versionx  1 :{ 3r q}q(Lorg/elasticsearch/index/engine/Engine$Searcher;Lorg/elasticsearch/common/lucene/uid/Versions$DocIdAndVersion;)V  /$Lorg/elasticsearch/index/mapper/Uid;op5Lorg/elasticsearch/index/translog/Translog$Operation; versionValue6Lorg/elasticsearch/index/engine/internal/VersionValue;searcher0Lorg/elasticsearch/index/engine/Engine$Searcher;docIdAndVersion>Lorg/elasticsearch/common/lucene/uid/Versions$DocIdAndVersion;+Lorg/elasticsearch/index/engine/Engine$Get;create1(Lorg/elasticsearch/index/engine/Engine$Create;)Vjava/lang/OutOfMemoryErrorjava/lang/IllegalStateExceptioncurrentIndexWriter  acquireThrottle-()Lorg/elasticsearch/common/lease/Releasable;   innerCreateV(Lorg/elasticsearch/index/engine/Engine$Create;Lorg/apache/lucene/index/IndexWriter;)V   o4:org/elasticsearch/index/engine/CreateFailedEngineExceptionm(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/engine/Engine$Create;Ljava/lang/Throwable;)V  checkVersionMapRefresh  r+Lorg/elasticsearch/common/lease/Releasable;t.Lorg/elasticsearch/index/engine/Engine$Create;writerautoGeneratedId  ?canHaveDuplicates  ?innerCreateNoLock(Lorg/elasticsearch/index/engine/Engine$Create;Lorg/apache/lucene/index/IndexWriter;JLorg/elasticsearch/index/engine/internal/VersionValue;)V   ? dirtyLock2(Lorg/apache/lucene/index/Term;)Ljava/lang/Object;  loadCurrentVersionFromIndex!(Lorg/apache/lucene/index/Term;)J  time o %currentVersion ?2 ?/isVersionConflictForWrites 8 6origin:()Lorg/elasticsearch/index/engine/Engine$Operation$Origin;  ?RECOVERY8Lorg/elasticsearch/index/engine/Engine$Operation$Origin;   ?G ?J updateVersion(JJ)J  6REPLICA   PRIMARY  java/lang/AssertionError  =org/elasticsearch/index/engine/DocumentAlreadyExistsExceptionN(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/String;)V    ?docs()Ljava/util/List;  ?java/util/Listsize  analyzer'()Lorg/apache/lucene/analysis/Analyzer;  ?updateDocumentsZ(Lorg/apache/lucene/index/Term;Ljava/lang/Iterable;Lorg/apache/lucene/analysis/Analyzer;)V  (I)Ljava/lang/Object;  java/lang/IterableupdateDocument   addDocuments<(Ljava/lang/Iterable;Lorg/apache/lucene/analysis/Analyzer;)V   addDocument    b k(Lorg/elasticsearch/index/translog/Translog$Operation;)Lorg/elasticsearch/index/translog/Translog$Location; i 4 8(JLorg/elasticsearch/index/translog/Translog$Location;)V  % putUnderLockZ(Lorg/apache/lucene/util/BytesRef;Lorg/elasticsearch/index/engine/internal/VersionValue;)V  postCreateUnderLock  updatedVersionexpectedVersiondoUpdate4Lorg/elasticsearch/index/translog/Translog$Location;index0(Lorg/elasticsearch/index/engine/Engine$Index;)V innerIndexU(Lorg/elasticsearch/index/engine/Engine$Index;Lorg/apache/lucene/index/IndexWriter;)V  !9org/elasticsearch/index/engine/IndexFailedEngineException$l(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/engine/Engine$Index;Ljava/lang/Throwable;)V & %'-Lorg/elasticsearch/index/engine/Engine$Index;Eorg/elasticsearch/common/util/concurrent/EsRejectedExecutionException*ramBytesUsedForRefresh ,o -? getAndSet(Z)Z 12 '3refresh5executor3(Ljava/lang/String;)Ljava/util/concurrent/Executor; 78 9 'java/util/concurrent/Executor<execute(Ljava/lang/Runnable;)V >? =@exGLorg/elasticsearch/common/util/concurrent/EsRejectedExecutionException; E E2 E/ E EG EJ Ecreated K EL E E  dPpostIndexUnderLock R S1(Lorg/elasticsearch/index/engine/Engine$Delete;)V?(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/Throwable;)V V W innerDeleteV(Lorg/elasticsearch/index/engine/Engine$Delete;Lorg/apache/lucene/index/IndexWriter;)V YZ [&:org/elasticsearch/index/engine/DeleteFailedEngineException^m(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/engine/Engine$Delete;Ljava/lang/Throwable;)V ` _amaybePruneDeletedTombstones c d.Lorg/elasticsearch/index/engine/Engine$Delete;pruneDeletedTombstones g h H H2 H/ H HG HJdeleteDocuments"([Lorg/apache/lucene/index/Term;)V pq r(JZ)V t Hu U fw:org/elasticsearch/index/engine/internal/DeleteVersionValuey9(JJLorg/elasticsearch/index/translog/Translog$Location;)V { z|postDeleteUnderLock ~U found8(Lorg/elasticsearch/index/engine/Engine$DeleteByQuery;)Vnested  K aliasFilter#()Lorg/apache/lucene/search/Filter;  Kversion_table_flush@makeTransientCurrent B 4CrevertTransient E 4F4org/elasticsearch/ElasticsearchIllegalStateExceptionH flush type [J] not supportedL I,failed to read latest segment infos on flushOisCorruptionException(Ljava/lang/Throwable;)Z QR Sunlock U ,VU translogIdcurrent;Lorg/elasticsearch/index/engine/FlushFailedEngineException;-Lorg/elasticsearch/index/engine/Engine$Flush;currentFlushinggetAllTombstones()Ljava/lang/Iterable; ^_ `iterator()Ljava/util/Iterator; bc djava/util/IteratorfhasNext h ginext k glgetKey n Toorg/apache/lucene/util/BytesRefq5(Lorg/apache/lucene/util/BytesRef;)Ljava/lang/Object; s tgetTombstoneUnderLock v! wremoveTombstoneUnderLock$(Lorg/apache/lucene/util/BytesRef;)V yz {!Lorg/apache/lucene/util/BytesRef;entrynLjava/util/Map$Entry;Ljava/util/Map$Entry;i$Ljava/util/Iterator;timeMSec maybeMerge     maybe_merge()Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit;snapshot  :org/elasticsearch/index/deletionpolicy/SnapshotIndexCommit(JJ)V i@ 6A -addVersionMapMemoryInBytes D 6E -addIndexWriterMemoryInBytes H 6IgetRAMBufferSizeMB K* .L@addIndexWriterMaxMemoryInBytes P 6Q 74stats.Lorg/elasticsearch/index/engine/SegmentsStats;segmentsjava/util/HashMapW X VgetSegmentInfo-()Lorg/apache/lucene/index/SegmentCommitInfo; [\ +])org/apache/lucene/index/SegmentCommitInfo_info%Lorg/apache/lucene/index/SegmentInfo; ab `c#org/apache/lucene/index/SegmentInfoename g fh&org/elasticsearch/index/engine/Segmentj ksearch m kn$org/apache/lucene/index/AtomicReaderpnumDocs r qsdocCount u kvnumDeletedDocs x qy delDocCount { k| getVersion"()Lorg/apache/lucene/util/Version; ~ f Lorg/apache/lucene/util/Version; 1 kgetUseCompoundFile  fcompoundLjava/lang/Boolean;  k sizeInBytes o `  kfailed to get size for [{}]trace \ G memoryInBytes  kput Y V d committed  k getDocCount  f getDelCount  `values()Ljava/util/Collection;  Vjava/util/Collection toArray(([Ljava/lang/Object;)[Ljava/lang/Object;  )[Lorg/elasticsearch/index/engine/Segment; #java/util/Arrayssort,([Ljava/lang/Object;Ljava/util/Comparator;)V   onGoingMerges()Ljava/util/Set;  ~ java/util/Set d*org/elasticsearch/index/merge/OnGoingMergegetMergedSegments   kequals j getId < mergeId  kasList%([Ljava/lang/Object;)Ljava/util/List;  +Lorg/apache/lucene/index/SegmentCommitInfo;segment(Lorg/elasticsearch/index/engine/Segment;infosarr$len$segmentInfoPerCommit onGoingMerge,Lorg/elasticsearch/index/merge/OnGoingMerge;KLjava/util/Map; segmentsArr=Ljava/util/Set;Ljava/util/Set;(org/elasticsearch/ElasticsearchException  yclear   IFailed to close SearcherManager"failed to rollback writer on closecurrentIndexWriterConfigtryLock  ,-org/apache/lucene/index/CorruptIndexExceptionunwrap=(Ljava/lang/Throwable;Ljava/lang/Class;)Ljava/lang/Throwable;  markStoreCorrupted2(Lorg/apache/lucene/index/CorruptIndexException;)V  Couldn't marks store corruptedassertLockIsHeld  :readLock is held by a thread that tries to fail the engineAtried to fail engine but engine is already failed. ignoring. [{}]failed engine [{}] IdonFailedEngine  ) 4Utried to fail engine but could not acquire lock - engine should be failed by now [{}] reasonfailure[B : roffset  rlength  rDorg/elasticsearch/cluster/routing/operation/hash/djb/DjbHashFunctionDJB_HASH([BII)I  'org/elasticsearch/common/math/MathUtilsmod   !hashLorg/apache/lucene/index/Term; load_version% loadVersionF(Lorg/apache/lucene/index/IndexReader;Lorg/apache/lucene/index/Term;)J '( <)isMergedSegment)(Lorg/apache/lucene/index/AtomicReader;)ZgetDiagnostics - f.addIndexes(IndexReader...)1merge3contains 5j 6Unknown source 8&Lorg/apache/lucene/index/AtomicReader; diagnostics1org/apache/lucene/store/LockObtainFailedException<isLocked > ?shard is locked, releasing lockA [I GC&(Lorg/apache/lucene/store/Directory;)V UE FVERSION H IdefaultIndexAnalyzer2()Lorg/elasticsearch/index/analysis/NamedAnalyzer; KL MH(Lorg/apache/lucene/util/Version;Lorg/apache/lucene/analysis/Analyzer;)V O lPCREATE4Lorg/apache/lucene/index/IndexWriterConfig$OpenMode; RS jTAPPEND VS jW setOpenModea(Lorg/apache/lucene/index/IndexWriterConfig$OpenMode;)Lorg/apache/lucene/index/IndexWriterConfig; YZ l[setIndexDeletionPolicyZ(Lorg/apache/lucene/index/IndexDeletionPolicy;)Lorg/apache/lucene/index/IndexWriterConfig; ]^ l_0org/elasticsearch/common/lucene/LoggerInfoStreama u cV(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/index/shard/ShardId;)V e bf setInfoStreamP(Lorg/apache/lucene/util/InfoStream;)Lorg/apache/lucene/index/IndexWriterConfig; hi ljnewMergeScheduler*()Lorg/apache/lucene/index/MergeScheduler; lm ~nsetMergeSchedulerU(Lorg/apache/lucene/index/MergeScheduler;)Lorg/apache/lucene/index/IndexWriterConfig; pq lr ((Lorg/apache/lucene/index/MergePolicy;)V u vsetMergePolicyR(Lorg/apache/lucene/index/MergePolicy;)Lorg/apache/lucene/index/IndexWriterConfig; xy lz similarity4()Lorg/apache/lucene/search/similarities/Similarity; |} ~ setSimilarity_(Lorg/apache/lucene/search/similarities/Similarity;)Lorg/apache/lucene/index/IndexWriterConfig;  l.(D)Lorg/apache/lucene/index/IndexWriterConfig; / lsetMaxThreadStates.(I)Lorg/apache/lucene/index/IndexWriterConfig;  lcodec4(Ljava/lang/String;)Lorg/apache/lucene/codecs/Codec;  setCodecM(Lorg/apache/lucene/codecs/Codec;)Lorg/apache/lucene/index/IndexWriterConfig;  lsetWriteLockTimeout.(J)Lorg/apache/lucene/index/IndexWriterConfig;  lsetUseCompoundFile.(Z)Lorg/apache/lucene/index/IndexWriterConfig;  lsetCheckIntegrityAtMerge2(Z)Lorg/apache/lucene/index/LiveIndexWriterConfig;  l !setMergedSegmentWarmerd(Lorg/apache/lucene/index/IndexWriter$IndexReaderWarmer;)Lorg/apache/lucene/index/IndexWriterConfig;  lQ(Lorg/apache/lucene/store/Directory;Lorg/apache/lucene/index/IndexWriterConfig;)V  (Could not lock IndexWriter isLocked [{}]config+Lorg/apache/lucene/index/IndexWriterConfig; mergePolicy3Lorg/apache/lucene/store/LockObtainFailedException;S(Lorg/apache/lucene/index/IndexWriter;ZLorg/apache/lucene/search/SearcherFactory;)V   access$200<(Lorg/elasticsearch/index/engine/internal/InternalEngine;Z)Vx0x1 access$300e(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/common/logging/ESLogger; access$400;(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Z access$500 access$600 +,  access$700r(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/indices/warmer/InternalIndicesWarmer; access$800a(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/index/shard/ShardId; access$900 access$1000 access$1100;(Lorg/elasticsearch/index/engine/internal/InternalEngine;)J access$1200 access$1102<(Lorg/elasticsearch/index/engine/internal/InternalEngine;J)J access$1300 access$1400 access$1302<(Lorg/elasticsearch/index/engine/internal/InternalEngine;Z)Z access$1500_(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/apache/lucene/index/IndexWriter; access$1600 access$1700 access$1602 access$402 access$1800;(Lorg/elasticsearch/index/engine/internal/InternalEngine;)I access$1900 access$2000L(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Ljava/lang/String; access$2100f(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/index/codec/CodecService; access$2200(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/index/engine/internal/InternalEngine$InternalLock; access$2300 access$1802<(Lorg/elasticsearch/index/engine/internal/InternalEngine;I)I access$2400 access$2002^(Lorg/elasticsearch/index/engine/internal/InternalEngine;Ljava/lang/String;)Ljava/lang/String; access$2500 access$1902 access$2600 access$2700 access$2800_(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/index/store/Store; access$2900p(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/index/similarity/SimilarityService; access$3000d(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/apache/lucene/search/SearcherManager; access$3100 access$3200 access$3300desiredAssertionStatus  RuntimeVisibleAnnotations Signature ConstantValueCodeLocalVariableTableLineNumberTable StackMapTable Exceptions"RuntimeVisibleParameterAnnotationsLocalVariableTypeTable<()Ljava/util/List; SourceFile InnerClasses!7BBBBBBBBBBBBBBBWXq*+,****qY  *Y* *Y* *Y**!*#*%*'Y(**,*.Y/1*3Y46*Y*9;*=Y>@*Y*AC*E*3Y4G*IYJL*NYOQ*'Y(SU[W][W _[W*,`gmqs**wy{Y|*,*-*-****** * * * * **,*ŵ*,*ŵ*,,ˇkӸع*Y**2h=6*龢*=Y>S*,ŵ**C*,ŵ*,ŵ**Y* qqquqqqqqqq q q q q q:d el 2DPUZ_joz '7<DJPY_ekqw} $/BU\kp=iy4~Z%y*M*"N:*+*$:(*,2W-P-5D:98-51:::--5:9-5,<+<r+?S,?L*CE=Y,SY+SK*QYLPTX8N4N0N*CZ-=^*C`=Y,SY+SK9=@0S0\gknS^\f Bapa tbcdcecf^ 0S\Z0{O FH{{ {{ECCghB *L+lW  mn  o  >**"LM*$sY*ux*!Y*uy*C|*C~=K**$*** Y**C***?N*-W*$*$:*$ :-Y*u-*a*N-*Q-ŧ+*Qʶ*$*Q̸иֶ*$ݧ+*Qʶ*$*Q̸иֶ*$**Q̹***$***[N*-W*$Y*$S):Y*$S:Y*$SY*u-+F,+5;N,-92+5+N-M-:+,+5:,9+5*:*Sqqqq'1131f ;cMWcaab> M8$ + 7 CS[f}! &'()+,(-//20<1S2Z4j5v67B89;?@<?@?ACC'D.E1D=F$wq#qq?V''mq!qqRNFD I  : **   I Jq6 cY    N/* S>* XY 0*"MN+*+#:(),:,-,5:-9,5+03+4:.+>D:FY*uHK3+4N+Q4/Y3T:,-,5:-9,5*X\::/Y3`T:,-,5:-9,5*ae:i+m:":oYStY*wyzM+0|+4::oYS~+>D:FY*uHK|+4N1/Y:,-,5:-9,5oYS~,:,-,5:-9,5:N:,-,5: - 9,5;?B/2 3T 3 T     Dasaa<!4caa/ a (b00$\ ]^!_&`.a3Tcgdseghjklru/z2v4w@yQ|V}i~u\  B,%/ =%,%/ 9,%2/ ,7:N ,7:/ ,7:/ ,G ,  *"MN*:*::*+]N:9B8:::%:  9 *#*%*,,K-,5@:-95,5.:N: ,-,5: - 9,5 M*,WY*u+,* -47#M#VbilMXV  qf 9ana iaa bN #MV7?o IH ?o ?] ?G ? ??k*++*+,y*+YN*+#:*+76*(( *e*s 7 37*+,-ç :--HLx =O2 "-=BOs{*",=%+?=qK R+7+!ə%+ͲѦFY*u++!N+!76  (R!J+ͲѦ+Ͳڦ 6 /ܚ+Ͳߥ Y⿻Y*u++ӷ+ ?+,+++P,+++4+,++,++ *bY+ : *+%Y *+\ RRRRRALD 0"U j5AD^hisy0IQ  *q *"MN*:*::*+"]N:9B8:::%:  9 *#*%*,,K-,5@:-95,5.:N: ,-,5: - 9,5 M*,#W%Y*u+,(* -47#M#VbilMXV  qf 9ana iaa b)N #MV7Eo IH Eo E] EG E EE G*./*AZ^aQtQ}t} #& 9<i} i} Y.$YX>Zaa ibM;Y caab)Y Cc3caaba(a\b=,c~ B[U\SM]d235"6K9S:_;g<v?ABCDGJKLMOPRSV W%X.Y@ZG[R^X_d`oc{f~dehljkmBmnopq"r1u?vDxMyXzh{m}o )9>ACQt} 9<=DU\irz}~92*6r1+QQO FH Q Q3Q KO FHQ Q =QO FHQ Q $"Q FHQ QB,S K S*$Y*u*EX i*$L+Y*u*EX+ g M ~*@*aeN-j]-mT:pr:*uY:*x:e*s *|ç :*?jmmrm>J5@})L~c~v )L~2 )5?JO^gux}gQTr=E **%*"LM*+F,+5;N,-92+5+N-M-:+,+5:,9+5L*+WY*u+&*-=BLPS=DB eh4.aUaPbi6  =BehirG $FD B0*MY*u,*QYLX q  c00  /Jq  A***"MN*:(:ܚ.&YYٶ۷+ + !+*% +,K-,5@:-95,5.:N:,-,5:-9,5**'M*,÷WY*u,:**+ƙ*+ȷʧ!+ș*ö:%Y*˹A  Ry&oaabAAn &W^gnw~#$ !#()"*),@7cWY N FGY YJV *QYLPTX*"LM**N+,+5:,9+5-N-M-:+,+5:,9+5LY*u+ؿ37:+K+PZ^aKRPIsqKssq4<acaVbt c">?@#A+BK?PBtCX : D q6*"MN*!Y*uy*;,K-,5@:-95,5.:N:,-,5:-9,5*M,N*-߷WoY*;StY*u-+,4N*-WoY*;SY,StY*u*-*N7:*WoY*;SY,StY*u*+-;:*WoY*;SY,SY-StY*u**"W:6*-:+6oY*;SY*SY,SY-SYSN:*WY*u*:oY*;SY*SY,SY-SYS ,03 $E $MW[^EOMpx{ '*pp5a`ahb|(c0c2c,6c c  x   mp,K LMO$PEKMPpTxY{U|VWX\a]^_`ejfgh i l'q*m,n6oLpbsjtmupw|xy~z{|~~U FG\ \J(I0L3_I7K\__a(i+TR*$*Y,ٶ+*C+=Y,SYSY*S^+ *+ iii& -/V]eg/&[*!Y*u+X+ E *#)L+. f/&0 12 )*"LM**4eN:6Y7:-i<=:jm : ?B*CF*$GJ*$(MNkNkR:-#-S:9 -S+,+5:,9+5:::-#-S:  9 -SN-M-: +,+5: , 9+5   f H f/2$aa"TUa a !b)F "HSVbn276g#E766 N 7H 7 D  V *"LM*XYYN*Ze:i<=:jm :ܚ#+ Y#)^:ܚ-di Y⿻kYdil:o#tw#z}dd": *C =YdiS?-diWS: S **::jm`:-dik:kYdil:odw}dd": *C =YdiS-diW ;--k:#Y**::jwm:Ź=:  jR m`: :  6 6   0  2: diə̵ϧ ϧ:+,+5:,9+5N-M-:+,+5:,9+5 q#--/-q   c laFf/0c vcaMF < 7 4 @ tY heR~aV3Iab VI; F_l #*-9@Fcv{ 3@Ihk0V7g. +`Z V7g `kqV7I g V7g`kq<g!g!V7gg`- V7ggV7 D 3 r*"LM*!*!**C**LY*S9N*C-=^*$*$N*$*5N*C-=^*$*:*$*+F,+5;N,-92+5+N-M-:+,+5:,9+5 /=@Y`cdsds  HAdctcaabr !(/ = @ A RY`cdipstU@PN`NFD &: **$(   !" ܚ, Y*G`,T)*,N*C-=^ܚ*Y*E*C=Y+SY,SK*C,=Y+S^*,E*LN-j-m):*u+, * :* :ܚ*Y*E*C=Y+SY,SK*C,=Y+S^*,E*L:jm):*u+, * : *  *C =Y+SY,SK%69qKellnlR:c mn$U mn?& "67=%?6B9@:AKEfFmGHKMNOPRSRTEFGHK1M6NUObPeRiSlR{VXSfq!g#FB"g%Fsa+++=**龸"2 }# [\= *+u  $`N j*&eMN,i+*7,!-,S:-9 ,S:N:,!-,S: - 9 ,S$' ; CMSV;EC4)aXa bjj$d ef;dCfT'7 7G 7 q +,g*)^d/L+0MܚAY2SYXSY4S,7YY9,ٶ۷4,ɬ gf:Y;L Y;nop_q _V0.*@*CB=D*G*<lYJ*NQM, UX\W,*`W,bY*d*ugkW,*osW*tNY-wN,-{W,*W,*,W,*W,**W,W,*W,*W,!Y*WY*,L*@=*C+=YS^+=>:Lw> %B.fw xy'{:|L}^~g{ ,8'@llllj=qBY+*q:*ʱ_/*C _/* _/*C _,/* :_/* _/*u _/*! _/*C _/*s _/*C _;*]s_/* _/*C _;*Z_/*$ _/* _/*C _;*Z_;*Z_/* _/* _/* _/* _/* _/*C _;*Z_/*C _;*+Z_/*C _;*Z_/*C _/*C _/* _/* _/* _/*u _/*u _/*C _ 4ܱ_ @b,    !#%')* ,- /0 245 78 :<= ?@B4C EFHI KL NO QR TVW YZ \] _4` b4@ d4F f4I h4L jlm@oqr tqu wyz |~ Q@~z 4 5 @