Edit C:\dspace\webapps\rest\WEB-INF\lib\org\elasticsearch\index\engine\internal\InternalEngine.class
???? 3 6org/elasticsearch/index/engine/internal/InternalEngine 9org/elasticsearch/index/shard/AbstractIndexShardComponent %org/elasticsearch/index/engine/Engine InternalEngine.java ?org/elasticsearch/index/engine/internal/InternalEngine$NoOpLock NoOpLock Dorg/elasticsearch/index/engine/internal/InternalEngine$IndexThrottle IndexThrottle Corg/elasticsearch/index/engine/internal/InternalEngine$InternalLock InternalLock Forg/elasticsearch/index/engine/internal/InternalEngine$RecoveryCounter RecoveryCounter Dorg/elasticsearch/index/engine/internal/InternalEngine$SearchFactory SearchFactory Eorg/elasticsearch/index/engine/internal/InternalEngine$EngineSearcher EngineSearcher Dorg/elasticsearch/index/engine/internal/InternalEngine$ApplySettings ApplySettings Oorg/elasticsearch/index/engine/internal/InternalEngine$FailEngineOnMergeFailure FailEngineOnMergeFailure 8org/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 . GetResult 3org/elasticsearch/index/translog/Translog$Operation 1 )org/elasticsearch/index/translog/Translog 3 Operation .org/elasticsearch/index/engine/Engine$Searcher 6 Searcher <org/elasticsearch/common/lucene/uid/Versions$DocIdAndVersion 9 ,org/elasticsearch/common/lucene/uid/Versions ; DocIdAndVersion ,org/elasticsearch/index/engine/Engine$Create > Create 2org/elasticsearch/index/translog/Translog$Location A Location +org/elasticsearch/index/engine/Engine$Index D Index ,org/elasticsearch/index/engine/Engine$Delete G Delete 3org/elasticsearch/index/engine/Engine$DeleteByQuery J DeleteByQuery -org/elasticsearch/index/engine/Engine$Refresh M Refresh +org/elasticsearch/index/engine/Engine$Flush P Flush java/util/Map$Entry S java/util/Map U Entry .org/elasticsearch/index/engine/Engine$Optimize X Optimize 5org/elasticsearch/index/engine/Engine$RecoveryHandler [ RecoveryHandler 2org/elasticsearch/index/translog/Translog$Snapshot ^ Snapshot 0org/elasticsearch/index/translog/Translog$Create a /org/elasticsearch/index/translog/Translog$Index c 0org/elasticsearch/index/translog/Translog$Delete e 7org/elasticsearch/index/translog/Translog$DeleteByQuery g 2org/apache/lucene/index/IndexWriterConfig$OpenMode i )org/apache/lucene/index/IndexWriterConfig k OpenMode :java/util/concurrent/locks/ReentrantReadWriteLock$ReadLock n 1java/util/concurrent/locks/ReentrantReadWriteLock p ReadLock ;java/util/concurrent/locks/ReentrantReadWriteLock$WriteLock s WriteLock >org/elasticsearch/index/settings/IndexSettingsService$Listener v 5org/elasticsearch/index/settings/IndexSettingsService x Listener Norg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$FailureListener { >org/elasticsearch/index/merge/scheduler/MergeSchedulerProvider } FailureListener 0org/elasticsearch/index/engine/Engine$Flush$Type ? Type Gorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$Listener ? 0org/elasticsearch/index/translog/Translog$Source ? Source /org/elasticsearch/index/engine/Engine$Operation ? 6org/elasticsearch/index/engine/Engine$Operation$Origin ? Origin 5org/apache/lucene/index/IndexWriter$IndexReaderWarmer ? #org/apache/lucene/index/IndexWriter ? IndexReaderWarmer failEngineOnCorruption Z indexingBufferSize -Lorg/elasticsearch/common/unit/ByteSizeValue; indexConcurrency I compoundOnFlush checksumOnMerge gcDeletesInMillis J lastDeleteVersionPruneTimeMSec enableGcDeletes codecName Ljava/lang/String; optimizeAutoGenerateId threadPool )Lorg/elasticsearch/threadpool/ThreadPool; indexingService 7Lorg/elasticsearch/index/indexing/ShardIndexingService; indexSettingsService 7Lorg/elasticsearch/index/settings/IndexSettingsService; warmer 8Lorg/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; analysisService 2Lorg/elasticsearch/index/analysis/AnalysisService; similarityService 6Lorg/elasticsearch/index/similarity/SimilarityService; codecService ,Lorg/elasticsearch/index/codec/CodecService; rwl 3Ljava/util/concurrent/locks/ReentrantReadWriteLock; readLock ELorg/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; closed dirty possibleMergeNeeded optimizeMutex +Ljava/util/concurrent/atomic/AtomicBoolean; flushNeeded flushing +Ljava/util/concurrent/atomic/AtomicInteger; flushLock !Ljava/util/concurrent/locks/Lock; onGoingRecoveries HLorg/elasticsearch/index/engine/internal/InternalEngine$RecoveryCounter; versionMap 8Lorg/elasticsearch/index/engine/internal/LiveVersionMap; dirtyLocks [Ljava/lang/Object; refreshMutex Ljava/lang/Object; applySettings FLorg/elasticsearch/index/engine/internal/InternalEngine$ApplySettings; failOnMergeFailure failedEngine Ljava/lang/Throwable; failEngineLock failedEngineListeners +Ljava/util/concurrent/CopyOnWriteArrayList; iLjava/util/concurrent/CopyOnWriteArrayList<Lorg/elasticsearch/index/engine/Engine$FailedEngineListener;>; translogIdGenerator (Ljava/util/concurrent/atomic/AtomicLong; versionMapRefreshPending lastCommittedSegmentInfos &Lorg/apache/lucene/index/SegmentInfos; throttle FLorg/elasticsearch/index/engine/internal/InternalEngine$IndexThrottle; INDEX_INDEX_CONCURRENCY index.index_concurrency ? INDEX_COMPOUND_ON_FLUSH index.compound_on_flush ? INDEX_CHECKSUM_ON_MERGE index.checksum_on_merge ? INDEX_GC_DELETES index.gc_deletes ? INDEX_FAIL_ON_MERGE_FAILURE index.fail_on_merge_failure ? INDEX_FAIL_ON_CORRUPTION index.fail_on_corruption ? $assertionsDisabled <init>?(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 ? ? 5 u(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 checkNotNull 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;XY WZ 7Snapshot deletion policy must be provided to the engine\ 'Translog must be provided to the engine^ < 'org/elasticsearch/common/unit/TimeValueb timeValueSeconds ,(J)Lorg/elasticsearch/common/unit/TimeValue;de cf *org/elasticsearch/common/settings/Settingsh getAsTime f(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue;jkil millis ()Jno cp ? ? r componentSettings ,Lorg/elasticsearch/common/settings/Settings;tu v index_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 ?? {? getAsBytesSize n(Ljava/lang/String;Lorg/elasticsearch/common/unit/ByteSizeValue;)Lorg/elasticsearch/common/unit/ByteSizeValue;??i? ? ? ? index.codec? default? get 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;??i? ? ? ? ? ? ? 'org/elasticsearch/threadpool/ThreadPool? estimatedTimeInMillis?o ?? ? ? ? ? ? ? ? ? ? 6org/elasticsearch/indices/warmer/InternalIndicesWarmer? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? java/lang/Boolean? valueOf (Z)Ljava/lang/Boolean;?? ?? getAsBoolean :(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;??i? booleanValue ()Z?? ?? 4org/elasticsearch/common/util/concurrent/EsExecutors? boundedNumberOfProcessors /(Lorg/elasticsearch/common/settings/Settings;)I?? ?????????? java/lang/Math? max (II)I?? ?? java/lang/Integer? (I)Ljava/lang/Integer;?? ?? getAsInt :(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;??i? intValue ()I?? ?? ? ? ? 6org/elasticsearch/index/engine/internal/LiveVersionMap? ? ? ? ? ? ? ? %org/elasticsearch/index/shard/ShardId? 5org/elasticsearch/index/indexing/ShardIndexingService? .org/elasticsearch/indices/warmer/IndicesWarmer? #org/elasticsearch/index/store/Store? =org/elasticsearch/index/deletionpolicy/SnapshotDeletionPolicy? 8org/elasticsearch/index/merge/policy/MergePolicyProvider? 0org/elasticsearch/index/analysis/AnalysisService? 4org/elasticsearch/index/similarity/SimilarityService? *org/elasticsearch/index/codec/CodecService? index.optimize_auto_generated_id? ? ? ? addListener C(Lorg/elasticsearch/index/settings/IndexSettingsService$Listener;)V y ? ? ? ? addFailureListener S(Lorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$FailureListener;)V ~ incRef ? i this 8Lorg/elasticsearch/index/engine/internal/InternalEngine; shardId 'Lorg/elasticsearch/index/shard/ShardId; indexSettings 0Lorg/elasticsearch/indices/warmer/IndicesWarmer; updateIndexingBufferSize 0(Lorg/elasticsearch/common/unit/ByteSizeValue;)V java/lang/Throwable 4org/elasticsearch/index/engine/EngineClosedException =org/elasticsearch/index/engine/FlushNotAllowedEngineException acquire G()Lorg/elasticsearch/index/engine/internal/InternalEngine$InternalLock; ! ? ? # getConfig 1()Lorg/apache/lucene/index/LiveIndexWriterConfig;%& ?' mbFrac ()D)* {+ -org/apache/lucene/index/LiveIndexWriterConfig- setRAMBufferSizeMB 2(D)Lorg/apache/lucene/index/LiveIndexWriterConfig;/0 .1 close3 4 addSuppressed (Ljava/lang/Throwable;)V67 8 bytes:o {; INACTIVE_SHARD_INDEXING_BUFFER= ? > logger +Lorg/elasticsearch/common/logging/ESLogger;@A B 7updating index_buffer_size from [{}] to (inactive) [{}]D )org/elasticsearch/common/logging/ESLoggerF debug ((Ljava/lang/String;[Ljava/lang/Object;)VHIGJ Q COMMIT 2Lorg/elasticsearch/index/engine/Engine$Flush$Type;MN ?O type a(Lorg/elasticsearch/index/engine/Engine$Flush$Type;)Lorg/elasticsearch/index/engine/Engine$Flush;QR QS flush 0(Lorg/elasticsearch/index/engine/Engine$Flush;)VUV W /failed to flush after setting shard to inactiveY warn =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V[\G] ,updating index_buffer_size from [{}] to [{}]_ x2 _ e 6Lorg/elasticsearch/index/engine/EngineClosedException; ?Lorg/elasticsearch/index/engine/FlushNotAllowedEngineException; preValue addFailedEngineListener ?(Lorg/elasticsearch/index/engine/Engine$FailedEngineListener;)V add (Ljava/lang/Object;)Zij Ik listener <Lorg/elasticsearch/index/engine/Engine$FailedEngineListener; start java/io/IOExceptionp <org/elasticsearch/index/engine/EngineAlreadyStartedExceptionr t *(Lorg/elasticsearch/index/shard/ShardId;)V ?v sw w isDebugEnabledz?G{ starting engine} createWriter '()Lorg/apache/lucene/index/IndexWriter;? ? ? ? ? removeListener L(Lorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider$Listener;)V?? ~? ?(Lorg/elasticsearch/index/merge/scheduler/MergeSchedulerProvider;Lorg/elasticsearch/common/logging/ESLogger;Lorg/elasticsearch/index/indexing/ShardIndexingService;)V ?? ? ? ~?o maybeFailEngine *(Ljava/lang/Throwable;Ljava/lang/String;)Z?? ? rollback? ?? q8 =org/elasticsearch/index/engine/EngineCreationFailureException? failed to create engine? Q(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/Throwable;)V ?? ?? directory %()Lorg/apache/lucene/store/Directory;?? ?? &org/elasticsearch/common/lucene/Lucene? indexExists &(Lorg/apache/lucene/store/Directory;)Z?? ?? readSegmentInfos K(Lorg/apache/lucene/store/Directory;)Lorg/apache/lucene/index/SegmentInfos;?? ?? $org/apache/lucene/index/SegmentInfos? getUserData ()Ljava/util/Map;?? ?? translog_id? containsKey?j V? &(Ljava/lang/Object;)Ljava/lang/Object;?? V? java/lang/String? java/lang/Long? parseLong (Ljava/lang/String;)J?? ?? set (J)V?? N? java/lang/System? currentTimeMillis?o ???o N? toString (J)Ljava/lang/String;?? ?? java/util/Collections? singletonMap 5(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;?? ?? setCommitData (Ljava/util/Map;)V?? ?? commit? ?? newTranslog?? 4? buildSearchManager Q(Lorg/apache/lucene/index/IndexWriter;)Lorg/apache/lucene/search/SearcherManager;?? ? ? ? ? setManager .(Lorg/apache/lucene/search/ReferenceManager;)V?? ?? readLastCommittedSegmentsInfo? ? java/io/Closeable? org/apache/lucene/util/IOUtils? closeWhileHandlingException ([Ljava/io/Closeable;)V?? ?? failed to open reader on writer? decRef? ?? pending e1 Ljava/io/IOException; commitUserData 5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>; Ljava/util/Map; (()Lorg/apache/lucene/index/SegmentInfos;? ? ? ? defaultRefreshInterval +()Lorg/elasticsearch/common/unit/TimeValue; java/util/concurrent/TimeUnit SECONDS Ljava/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;: getUnderLock Y(Lorg/apache/lucene/util/BytesRef;)Lorg/elasticsearch/index/engine/internal/VersionValue; ! ?" 4org/elasticsearch/index/engine/internal/VersionValue$ delete&? %' NOT_EXISTS 1Lorg/elasticsearch/index/engine/Engine$GetResult;)* /+ versionType '()Lorg/elasticsearch/index/VersionType;-. ,/ version1o %2 ,2 #org/elasticsearch/index/VersionType5 isVersionConflictForReads (JJ)Z78 69 text ()Ljava/lang/String;;< = "org/elasticsearch/index/mapper/Uid? createUid 8(Ljava/lang/String;)Lorg/elasticsearch/index/mapper/Uid;AB @C =org/elasticsearch/index/engine/VersionConflictEngineExceptionEQ< @G idI< @J P(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/String;JJ)V ?L FM loadSourceO? ,P 7(ZJLorg/elasticsearch/index/translog/Translog$Source;)V ?R /S translogLocation 6()Lorg/elasticsearch/index/translog/Translog$Location;UV %W read k(Lorg/elasticsearch/index/translog/Translog$Location;)Lorg/elasticsearch/index/translog/Translog$Operation;YZ 4[ getSource 4()Lorg/elasticsearch/index/translog/Translog$Source;]^ 2_? acquireSearcher D(Ljava/lang/String;)Lorg/elasticsearch/index/engine/Engine$Searcher;bc d reader '()Lorg/apache/lucene/index/IndexReader;fg 7h loadDocIdAndVersion ?(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 v Couldn'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; op 5Lorg/elasticsearch/index/translog/Translog$Operation; versionValue 6Lorg/elasticsearch/index/engine/internal/VersionValue; searcher 0Lorg/elasticsearch/index/engine/Engine$Searcher; docIdAndVersion >Lorg/elasticsearch/common/lucene/uid/Versions$DocIdAndVersion; +Lorg/elasticsearch/index/engine/Engine$Get; create 1(Lorg/elasticsearch/index/engine/Engine$Create;)V java/lang/OutOfMemoryError? java/lang/IllegalStateException? currentIndexWriter?? ? acquireThrottle -()Lorg/elasticsearch/common/lease/Releasable;?? ? innerCreate V(Lorg/elasticsearch/index/engine/Engine$Create;Lorg/apache/lucene/index/IndexWriter;)V?? ?o4? :org/elasticsearch/index/engine/CreateFailedEngineException? m(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; writer autoGeneratedId?? ?? canHaveDuplicates?? ?????????? innerCreateNoLock ?(Lorg/elasticsearch/index/engine/Engine$Create;Lorg/apache/lucene/index/IndexWriter;JLorg/elasticsearch/index/engine/internal/VersionValue;)V?? ? ? dirtyLock 2(Lorg/apache/lucene/index/Term;)Ljava/lang/Object;?? ? loadCurrentVersionFromIndex !(Lorg/apache/lucene/index/Term;)J?? ? time?o %? currentVersion ?2 ?/ isVersionConflictForWrites?8 6? origin :()Lorg/elasticsearch/index/engine/Engine$Operation$Origin;?? ?? RECOVERY 8Lorg/elasticsearch/index/engine/Engine$Operation$Origin;?? ?? ?G ?J updateVersion (JJ)J?? 6? REPLICA?? ?? ? ? ? PRIMARY?? ?? java/lang/AssertionError? ? =org/elasticsearch/index/engine/DocumentAlreadyExistsException? N(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/String;)V ?? ???? ?? docs ()Ljava/util/List;?? ?? java/util/List? size???? analyzer '()Lorg/apache/lucene/analysis/Analyzer;?? ?? updateDocuments Z(Lorg/apache/lucene/index/Term;Ljava/lang/Iterable;Lorg/apache/lucene/analysis/Analyzer;)V?? ?? (I)Ljava/lang/Object;???? java/lang/Iterable? updateDocument ? ? 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 ? % putUnderLock Z(Lorg/apache/lucene/util/BytesRef;Lorg/elasticsearch/index/engine/internal/VersionValue;)V ? postCreateUnderLock? ? updatedVersion expectedVersion doUpdate 4Lorg/elasticsearch/index/translog/Translog$Location; index 0(Lorg/elasticsearch/index/engine/Engine$Index;)V innerIndex U(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)Z12 '3 refresh5 executor 3(Ljava/lang/String;)Ljava/util/concurrent/Executor;78 ?9 ' java/util/concurrent/Executor< execute (Ljava/lang/Runnable;)V>?=@ ex GLorg/elasticsearch/common/util/concurrent/EsRejectedExecutionException; E E2 E/ E? EG EJ E? createdK EL E? E? ? dP postIndexUnderLockR ?S 1(Lorg/elasticsearch/index/engine/Engine$Delete;)V ?(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/Throwable;)V ?V W innerDelete V(Lorg/elasticsearch/index/engine/Engine$Delete;Lorg/apache/lucene/index/IndexWriter;)VYZ [& :org/elasticsearch/index/engine/DeleteFailedEngineException^ m(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/engine/Engine$Delete;Ljava/lang/Throwable;)V ?` _a maybePruneDeletedTombstonesc d .Lorg/elasticsearch/index/engine/Engine$Delete; pruneDeletedTombstonesg h H H2 H/ H? HG HJ deleteDocuments "([Lorg/apache/lucene/index/Term;)Vpq ?r (JZ)V?t Hu ?U fw :org/elasticsearch/index/engine/internal/DeleteVersionValuey 9(JJLorg/elasticsearch/index/translog/Translog$Location;)V ?{ z| postDeleteUnderLock~U ? found 8(Lorg/elasticsearch/index/engine/Engine$DeleteByQuery;)V nested?? K? aliasFilter #()Lorg/apache/lucene/search/Filter;?? K? <org/elasticsearch/index/search/nested/IncludeNestedDocsQuery? 5org/elasticsearch/common/lucene/search/XFilteredQuery? query "()Lorg/apache/lucene/search/Query;?? K? D(Lorg/apache/lucene/search/Query;Lorg/apache/lucene/search/Filter;)V ?? ?? parentFilter ?()Lorg/elasticsearch/index/cache/fixedbitset/FixedBitSetFilter;?? K? `(Lorg/apache/lucene/search/Query;Lorg/elasticsearch/index/cache/fixedbitset/FixedBitSetFilter;)V ?? ?? org/apache/lucene/search/Query? $([Lorg/apache/lucene/search/Query;)Vp? ?? ?? h? delete_by_query? Aorg/elasticsearch/index/engine/DeleteByQueryFailedEngineException? t(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/engine/Engine$DeleteByQuery;Ljava/lang/Throwable;)V ?? ?? (Ljava/lang/String;)V ?? N? force 2(Z)Lorg/elasticsearch/index/engine/Engine$Refresh;?? N? 2(Lorg/elasticsearch/index/engine/Engine$Refresh;)V5? ? Lorg/apache/lucene/search/Query; 5Lorg/elasticsearch/index/engine/Engine$DeleteByQuery; ensureOpen? ? %SearcherManager is null but shouldn't? (Ljava/lang/Object;)V ?? ?? (org/apache/lucene/search/SearcherManager? ()Ljava/lang/Object;? ?? &org/apache/lucene/search/IndexSearcher? newSearcher ?(Ljava/lang/String;Lorg/apache/lucene/search/IndexSearcher;Lorg/apache/lucene/search/SearcherManager;)Lorg/elasticsearch/index/engine/Engine$Searcher;?? ? release?? ?? %failed to acquire searcher, source {}? error?\G? java/lang/StringBuilder? ? #failed to acquire searcher, source ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder;?? ???< ?? retVal manager (Lorg/apache/lucene/search/IndexSearcher; source success ?(Lorg/elasticsearch/index/engine/internal/InternalEngine;Ljava/lang/String;Lorg/apache/lucene/search/IndexSearcher;Lorg/apache/lucene/search/SearcherManager;Lorg/elasticsearch/index/engine/internal/InternalEngine$1;)V ?? ? refreshNeeded tryIncRef?? ?? isSearcherCurrent?? ?? !failed to access searcher manager? failEngine *(Ljava/lang/String;Ljava/lang/Throwable;)V?? ? hasPendingMerges?? ?? .org/apache/lucene/store/AlreadyClosedException??? ??? N? maybeRefresh?? ?? 7failed to refresh even though refreshMutex was acquired? refresh failed? ;org/elasticsearch/index/engine/RefreshFailedEngineException W? ' refreshed 0Lorg/apache/lucene/store/AlreadyClosedException; /Lorg/elasticsearch/index/engine/Engine$Refresh; 9org/elasticsearch/index/engine/FlushFailedEngineException 4()Lorg/elasticsearch/index/engine/Engine$Flush$Type;Q Q NEW_WRITERN ? COMMIT_TRANSLOGN ??? recovery is in progress, flush [ -(Ljava/lang/Object;)Ljava/lang/StringBuilder;? ? ] is not allowed <(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;)V ? incrementAndGet ? .! waitIfOngoing#? Q$ decrementAndGet&? .' already flushing...) java/util/concurrent/locks/Lock+ lock- ,. -Recovery is in progress, flush is not allowed0 currentId2o 43 Q? o N63? ?8 'Failed to close current SearcherManager: W newTransientTranslog=? 4> version_table_flush@ makeTransientCurrentB 4C revertTransientE 4F 4org/elasticsearch/ElasticsearchIllegalStateExceptionH flush type [J ] not supportedL I? ,failed to read latest segment infos on flushO isCorruptionException (Ljava/lang/Throwable;)ZQR ?S unlockU ,VU translogId current ;Lorg/elasticsearch/index/engine/FlushFailedEngineException; -Lorg/elasticsearch/index/engine/Engine$Flush; currentFlushing getAllTombstones ()Ljava/lang/Iterable;^_ ?` iterator ()Ljava/util/Iterator;bc?d java/util/Iteratorf hasNexth?gi nextk?gl getKeyn? To org/apache/lucene/util/BytesRefq 5(Lorg/apache/lucene/util/BytesRef;)Ljava/lang/Object;?s t getTombstoneUnderLockv! ?w removeTombstoneUnderLock $(Lorg/apache/lucene/util/BytesRef;)Vyz ?{ !Lorg/apache/lucene/util/BytesRef; entry nLjava/util/Map$Entry<Lorg/apache/lucene/util/BytesRef;Lorg/elasticsearch/index/engine/internal/VersionValue;>; Ljava/util/Map$Entry; i$ Ljava/util/Iterator; timeMSec maybeMerge ?? ?? ?? maybe_merge? <org/elasticsearch/index/engine/OptimizeFailedEngineException? ?W waitForMerges? ?? 0(Z)Lorg/elasticsearch/index/engine/Engine$Flush;?? Q?#? Q? flushAfter optimize 3(Lorg/elasticsearch/index/engine/Engine$Optimize;)V compareAndSet (ZZ)Z?? '? getMergePolicy '()Lorg/apache/lucene/index/MergePolicy;?? .? =org/elasticsearch/index/merge/policy/ElasticsearchMergePolicy? MergePolicy is ? getClass ()Ljava/lang/Class;?? =? java/lang/Class? getName?< ?? #org/apache/lucene/index/MergePolicy? upgrade?? Y? setUpgradeInProgress? ?? onlyExpungeDeletes?? Y? forceMergeDeletes? ?? maxNumSegments?? Y? forceMerge (IZ)V?? ??? waitForMerge?? Y?U? Y?? ? % mp %Lorg/apache/lucene/index/MergePolicy; 0Lorg/elasticsearch/index/engine/Engine$Optimize; snapshotIndex >()Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit; snapshot?? ?? :org/elasticsearch/index/deletionpolicy/SnapshotIndexCommit? <org/elasticsearch/index/engine/SnapshotFailedEngineException? ?W recover :(Lorg/elasticsearch/index/engine/Engine$RecoveryHandler;)V startRecovery? ? recovery? 6org/elasticsearch/index/engine/RecoveryEngineException? Snapshot failed? R(Lorg/elasticsearch/index/shard/ShardId;ILjava/lang/String;Ljava/lang/Throwable;)V ?? ?? phase1 ?(Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit;)V?? \? recovery phase 1? Execution failed? wrapIfClosed ,(Ljava/lang/Throwable;)Ljava/lang/Throwable;?? ? 6()Lorg/elasticsearch/index/translog/Translog$Snapshot;?? 4? snapshot recovery? phase2 7(Lorg/elasticsearch/index/translog/Translog$Snapshot;)V?? \? recovery phase 2? j(Lorg/elasticsearch/index/translog/Translog$Snapshot;)Lorg/elasticsearch/index/translog/Translog$Snapshot;?? 4? phase3? \ 0(Z[Lorg/elasticsearch/common/lease/Releasable;)V3 q recovery phase 3 recoveryHandler 7Lorg/elasticsearch/index/engine/Engine$RecoveryHandler; phase1Snapshot <Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit; phase2Snapshot 4Lorg/elasticsearch/index/translog/Translog$Snapshot; phase3Snapshot corrupt file detected source: [ ] :corrupt file detected source: [{}] but [{}] is set to [{}] "org/elasticsearch/ExceptionsHelper isOOMR out of memory getReaderRamBytesUsed 0(Lorg/apache/lucene/index/AtomicReaderContext;)J +org/apache/lucene/index/AtomicReaderContext (()Lorg/apache/lucene/index/AtomicReader;f! " 2org/elasticsearch/common/lucene/SegmentReaderUtils$ segmentReader O(Lorg/apache/lucene/index/AtomicReader;)Lorg/apache/lucene/index/SegmentReader;&' %( %org/apache/lucene/index/SegmentReader* ramBytesUsed,o +- -Lorg/apache/lucene/index/AtomicReaderContext; 'Lorg/apache/lucene/index/SegmentReader; segmentsStats 0()Lorg/elasticsearch/index/engine/SegmentsStats; segments_stats3 ,org/elasticsearch/index/engine/SegmentsStats5 6 #org/apache/lucene/index/IndexReader8 leaves:? 9;?d > (JJ)Vi@ 6A ?- addVersionMapMemoryInBytesD? 6E ?- addIndexWriterMemoryInBytesH? 6I getRAMBufferSizeMBK* .L@? addIndexWriterMaxMemoryInBytesP? 6Q 74 stats .Lorg/elasticsearch/index/engine/SegmentsStats; segments java/util/HashMapW X V getSegmentInfo -()Lorg/apache/lucene/index/SegmentCommitInfo;[\ +] )org/apache/lucene/index/SegmentCommitInfo_ info %Lorg/apache/lucene/index/SegmentInfo;ab `c #org/apache/lucene/index/SegmentInfoe nameg ? fh &org/elasticsearch/index/engine/Segmentj k? searchm ? kn $org/apache/lucene/index/AtomicReaderp numDocsr? qs docCountu ? kv numDeletedDocsx? qy delDocCount{ ? k| getVersion "()Lorg/apache/lucene/util/Version;~ f? Lorg/apache/lucene/util/Version;1? k? getUseCompoundFile?? f? compound Ljava/lang/Boolean;?? k? sizeInBytes?o `?? ? k? failed to get size for [{}]? trace?\G? memoryInBytes? ? k? put?Y V? ?d committed? ? k? getDocCount?? f? getDelCount?? `? values ()Ljava/util/Collection;?? V? java/util/Collection??? toArray (([Ljava/lang/Object;)[Ljava/lang/Object;???? )[Lorg/elasticsearch/index/engine/Segment;? # java/util/Arrays? sort ,([Ljava/lang/Object;Ljava/util/Comparator;)V?? ?? onGoingMerges ()Ljava/util/Set;?? ~? java/util/Set??d *org/elasticsearch/index/merge/OnGoingMerge? getMergedSegments?? ?? k? equals?j ?? getId?< ?? mergeId? ? k? asList %([Ljava/lang/Object;)Ljava/util/List;?? ?? +Lorg/apache/lucene/index/SegmentCommitInfo; segment (Lorg/elasticsearch/index/engine/Segment; infos arr$ len$ segmentInfoPerCommit onGoingMerge ,Lorg/elasticsearch/index/merge/OnGoingMerge; KLjava/util/Map<Ljava/lang/String;Lorg/elasticsearch/index/engine/Segment;>; segmentsArr =Ljava/util/Set<Lorg/elasticsearch/index/merge/OnGoingMerge;>; Ljava/util/Set; (org/elasticsearch/ElasticsearchException?? y? clear? ?? I? Failed to close SearcherManager? "failed to rollback writer on close? currentIndexWriterConfig tryLock??,? -org/apache/lucene/index/CorruptIndexException? unwrap =(Ljava/lang/Throwable;Ljava/lang/Class;)Ljava/lang/Throwable;?? ? markStoreCorrupted 2(Lorg/apache/lucene/index/CorruptIndexException;)V?? ?? Couldn't marks store corrupted? assertLockIsHeld?? ? :readLock is held by a thread that tries to fail the engine Atried to fail engine but engine is already failed. ignoring. [{}] failed engine [{}] Id onFailedEngine? ) 4 Utried to fail engine but could not acquire lock - engine should be failed by now [{}] reason failure [B: r offset ? r length ? r Dorg/elasticsearch/cluster/routing/operation/hash/djb/DjbHashFunction DJB_HASH ([BII)I 'org/elasticsearch/common/math/MathUtils mod ? ! hash Lorg/apache/lucene/index/Term; load_version% loadVersion F(Lorg/apache/lucene/index/IndexReader;Lorg/apache/lucene/index/Term;)J'( <) isMergedSegment )(Lorg/apache/lucene/index/AtomicReader;)Z getDiagnostics-? f.? addIndexes(IndexReader...)1 merge3 contains5j?6 Unknown source 8 &Lorg/apache/lucene/index/AtomicReader; diagnostics 1org/apache/lucene/store/LockObtainFailedException< isLocked>? ?? shard is locked, releasing lockA[IGC &(Lorg/apache/lucene/store/Directory;)VUE ?F VERSIONH? ?I defaultIndexAnalyzer 2()Lorg/elasticsearch/index/analysis/NamedAnalyzer;KL ?M H(Lorg/apache/lucene/util/Version;Lorg/apache/lucene/analysis/Analyzer;)V ?O lP CREATE 4Lorg/apache/lucene/index/IndexWriterConfig$OpenMode;RS jT APPENDVS jW setOpenMode a(Lorg/apache/lucene/index/IndexWriterConfig$OpenMode;)Lorg/apache/lucene/index/IndexWriterConfig;YZ l[ setIndexDeletionPolicy Z(Lorg/apache/lucene/index/IndexDeletionPolicy;)Lorg/apache/lucene/index/IndexWriterConfig;]^ l_ 0org/elasticsearch/common/lucene/LoggerInfoStreamau c V(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/index/shard/ShardId;)V ?e bf setInfoStream P(Lorg/apache/lucene/util/InfoStream;)Lorg/apache/lucene/index/IndexWriterConfig;hi lj newMergeScheduler *()Lorg/apache/lucene/index/MergeScheduler;lm ~n setMergeScheduler U(Lorg/apache/lucene/index/MergeScheduler;)Lorg/apache/lucene/index/IndexWriterConfig;pq lr?? ((Lorg/apache/lucene/index/MergePolicy;)V ?u ?v setMergePolicy R(Lorg/apache/lucene/index/MergePolicy;)Lorg/apache/lucene/index/IndexWriterConfig;xy lz similarity 4()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;/? l? setMaxThreadStates .(I)Lorg/apache/lucene/index/IndexWriterConfig;?? l? codec 4(Ljava/lang/String;)Lorg/apache/lucene/codecs/Codec;?? ?? setCodec M(Lorg/apache/lucene/codecs/Codec;)Lorg/apache/lucene/index/IndexWriterConfig;?? l? ? setWriteLockTimeout .(J)Lorg/apache/lucene/index/IndexWriterConfig;?? l? setUseCompoundFile .(Z)Lorg/apache/lucene/index/IndexWriterConfig;?? l? setCheckIntegrityAtMerge 2(Z)Lorg/apache/lucene/index/LiveIndexWriterConfig;?? l? ! setMergedSegmentWarmer d(Lorg/apache/lucene/index/IndexWriter$IndexReaderWarmer;)Lorg/apache/lucene/index/IndexWriterConfig;?? l? Q(Lorg/apache/lucene/store/Directory;Lorg/apache/lucene/index/IndexWriterConfig;)V ?? ?? (Could not lock IndexWriter isLocked [{}]? config +Lorg/apache/lucene/index/IndexWriterConfig; mergePolicy 3Lorg/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)V x0 x1 access$300 e(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$700 r(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/indices/warmer/InternalIndicesWarmer; access$800 a(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$2000 L(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Ljava/lang/String; access$2100 f(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$2900 p(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/elasticsearch/index/similarity/SimilarityService; access$3000 d(Lorg/elasticsearch/index/engine/internal/InternalEngine;)Lorg/apache/lucene/search/SearcherManager; access$3100 access$3200 access$3300 <clinit> desiredAssertionStatus?? ?? RuntimeVisibleAnnotations Signature ConstantValue Code LocalVariableTable LineNumberTable StackMapTable Exceptions "RuntimeVisibleParameterAnnotations LocalVariableTypeTable <()Ljava/util/List<Lorg/elasticsearch/index/engine/Segment;>; SourceFile InnerClasses ! 7 B ? ? B ? ? B ? ? B ? ? B ? ? ? ? B ? ? B ? ? B ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? B ? ? ? ? B ? ? B ? ? B ? ? B ? ? ? ? B ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? B ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? W ? ? ? X q*+,?*?*?*?*? qY?? *? Y*? ???*? Y*? ???*? Y*??*?!*?#*?%*?'Y?(?**?,*?.Y?/?1*?3Y?4?6*? Y*?9?;*?=Y?>?@*? Y*?A?C*?E*?3Y?4?G*?IY?J?L*?NY?O?Q*?'Y?(?SU?[W]?[W _?[W*,?`?g?m ?q?s**?wy?{Y|?????? ??*,???? ??*-??*-????*??*??*????*??*??* ??* ??*??*??* ??*??*,?*????? ??*,?*????? ??*,?,???k????? ???*??Y???**??2h?=??6*?? *???=Y?>S????*,????? ???*??*?C?*,????? ??*,????? ??*?? *??? Y*???? ? ? ? ? q q qu q ? ? q ? ? q ? ? q ? q ? ? q ? ? q ? ? q ? ? q ? ? q ? ? q ? ? q ? ? ? ? : ? d e l ? ? 2 ? D ? P ? U ? Z ? _ ? j ? o ? z ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?' ?7 ?<