йЧ╨Ў3Е1org/elasticsearch/indices/recovery/RecoveryTarget4org/elasticsearch/common/component/AbstractComponentRecoveryTarget.javaRorg/elasticsearch/indices/recovery/RecoveryTarget$FileChunkTransportRequestHandler FileChunkTransportRequestHandlerJorg/elasticsearch/indices/recovery/RecoveryTarget$CleanFilesRequestHandler CleanFilesRequestHandlerIorg/elasticsearch/indices/recovery/RecoveryTarget$FilesInfoRequestHandlerFilesInfoRequestHandlerRorg/elasticsearch/indices/recovery/RecoveryTarget$TranslogOperationsRequestHandler TranslogOperationsRequestHandlerPorg/elasticsearch/indices/recovery/RecoveryTarget$FinalizeRecoveryRequestHandlerFinalizeRecoveryRequestHandler\org/elasticsearch/indices/recovery/RecoveryTarget$PrepareForTranslogOperationsRequestHandler*PrepareForTranslogOperationsRequestHandlerBorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListenerRecoveryListener9org/elasticsearch/indices/recovery/RecoveryTarget$ActionsActions3org/elasticsearch/indices/recovery/RecoveryTarget$43org/elasticsearch/indices/recovery/RecoveryTarget$3 3org/elasticsearch/indices/recovery/RecoveryTarget$2"3org/elasticsearch/indices/recovery/RecoveryTarget$1$java/util/Map$Entry& java/util/Map(Entry3org/elasticsearch/indices/IndicesLifecycle$Listener+*org/elasticsearch/indices/IndicesLifecycle-Listener6org/elasticsearch/indices/recovery/RecoveryState$Timer00org/elasticsearch/indices/recovery/RecoveryState2Timer6org/elasticsearch/indices/recovery/RecoveryState$Stage5Stage5org/elasticsearch/indices/recovery/RecoveryState$Type8Type3org/elasticsearch/index/store/Store$LegacyChecksums;#org/elasticsearch/index/store/Store=LegacyChecksums threadPool)Lorg/elasticsearch/threadpool/ThreadPool;transportService.Lorg/elasticsearch/transport/TransportService;indicesService*Lorg/elasticsearch/indices/IndicesService;recoverySettings5Lorg/elasticsearch/indices/recovery/RecoverySettings;onGoingRecoveries;$assertionsDisabledZ(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/indices/IndicesLifecycle;Lorg/elasticsearch/indices/recovery/RecoverySettings;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)VMP Q>org/elasticsearch/common/util/concurrent/ConcurrentCollectionsSnewConcurrentMapLong>()Lorg/elasticsearch/common/util/concurrent/ConcurrentMapLong;UV TWHI Y@A [BC ]DE _FG a'internal:index/shard/recovery/filesInfoc6(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)VMe f,org/elasticsearch/transport/TransportServicehregisterHandlerJ(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)Vjk il(internal:index/shard/recovery/file_chunkn f)internal:index/shard/recovery/clean_filesq f.internal:index/shard/recovery/prepare_translogt f*internal:index/shard/recovery/translog_opsw f&internal:index/shard/recovery/finalizez f %faddListener8(Lorg/elasticsearch/indices/IndicesLifecycle$Listener;)V~.─this3Lorg/elasticsearch/indices/recovery/RecoveryTarget;settings,Lorg/elasticsearch/common/settings/Settings;indicesLifecycle,Lorg/elasticsearch/indices/IndicesLifecycle;recoveryStatusg(Lorg/elasticsearch/index/shard/service/IndexShard;)Lorg/elasticsearch/indices/recovery/RecoveryStatus;findRecoveryByShard┼┴ ▀1org/elasticsearch/indices/recovery/RecoveryStatus█ recoveryState4()Lorg/elasticsearch/indices/recovery/RecoveryState;▐░ ▌▒getTimer:()Lorg/elasticsearch/indices/recovery/RecoveryState$Timer;⌠■ 3∙ startTime()J≈≤ 1≥stage:()Lorg/elasticsearch/indices/recovery/RecoveryState$Stage;⌡° ▌²DONE8Lorg/elasticsearch/indices/recovery/RecoveryState$Stage;÷═ 6║java/lang/SystemёcurrentTimeMillis╔≤ єіtime(J)V╗╘ 1╙ indexShard2Lorg/elasticsearch/index/shard/service/IndexShard;3Lorg/elasticsearch/indices/recovery/RecoveryStatus;cancelRecovery5(Lorg/elasticsearch/index/shard/service/IndexShard;)Vjava/lang/InterruptedException╠sentCanceledToSourceЁL ▌Єcancel()VІЇ ▌╦recoveryThreadLjava/lang/Thread;╨╩ ▌╪java/lang/ThreadЎ interruptюЇ ©аd'Bхjava/lang/Mathхround(F)Iйк ил sourceNode.Lorg/elasticsearch/cluster/node/DiscoveryNode;но ▌п nodeConnected1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)Zрс iтsleepж╘ ©в currentThread()Ljava/lang/Thread;ыз ©шremoveAndCleanOnGoingRecovery6(Lorg/elasticsearch/indices/recovery/RecoveryStatus;)Vщч ъjava/lang/ThrowableАe Ljava/lang/InterruptedException; sleepTimeJmaxSleepTimerounds startRecovery╨(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/index/shard/service/InternalIndexShard;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)V=org/elasticsearch/index/shard/IllegalIndexShardStateExceptionКjava/lang/StringBuilderМMЇ НОfrom Яappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;СТ НУ7org/elasticsearch/indices/recovery/StartRecoveryRequestВ0()Lorg/elasticsearch/cluster/node/DiscoveryNode;нЫ ЬЗ-(Ljava/lang/Object;)Ljava/lang/StringBuilder;СЭ НЩtoString()Ljava/lang/String;Ъ Н8org/elasticsearch/index/shard/service/InternalIndexShard recoveringC(Ljava/lang/String;)Lorg/elasticsearch/index/shard/IndexShardState; already in recovering process, getMessage ЛonIgnoreRecovery(ZLjava/lang/String;)V recoveryId≤ Ьl(JLorg/elasticsearch/index/shard/service/InternalIndexShard;Lorg/elasticsearch/cluster/node/DiscoveryNode;)VM ▌2Lorg/elasticsearch/indices/recovery/RecoveryState;▐ ▌recoveryType9()Lorg/elasticsearch/indices/recovery/RecoveryState$Type; ЬsetType:(Lorg/elasticsearch/indices/recovery/RecoveryState$Type;)V 3! setSourceNode1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)V#$ 3% targetNode'Ы Ь( setTargetNode*$ 3+routingEntry2()Lorg/elasticsearch/cluster/routing/ShardRouting;-. /.org/elasticsearch/cluster/routing/ShardRouting1primary()Z3425 setPrimary(Z)V78 39Ф ▌;:org/elasticsearch/common/util/concurrent/ConcurrentMapLong=put'(JLjava/lang/Object;)Ljava/lang/Object;?@>A'org/elasticsearch/threadpool/ThreadPoolCgeneric!()Ljava/util/concurrent/Executor;EF DGФ(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)VMI #Jjava/util/concurrent/ExecutorLexecute(Ljava/lang/Runnable;)VNOMP?Lorg/elasticsearch/index/shard/IllegalIndexShardStateException;request9Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;:Lorg/elasticsearch/index/shard/service/InternalIndexShard;listenerDLorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener; retryRecoveryэ(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/common/unit/TimeValue;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)VE !Jschedulew(Lorg/elasticsearch/common/unit/TimeValue;Ljava/lang/String;Ljava/lang/Runnable;)Ljava/util/concurrent/ScheduledFuture;\] D^ retryAfter)Lorg/elasticsearch/common/unit/TimeValue;status doRecoveryЁ(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)VKL ejava/lang/AssertionErrorg)can't do a recovery without a source nodei(Ljava/lang/Object;)VMk hl╛U ▌n$shard missing locally, stop recoverypstate1()Lorg/elasticsearch/index/shard/IndexShardState;rs t-org/elasticsearch/index/shard/IndexShardStatevCLOSED/Lorg/elasticsearch/index/shard/IndexShardState;xy wz!local shard closed, stop recovery| isCanceled~4 ▌canceled recovery│store'()Lorg/elasticsearch/index/store/Store;┐└ ┘ tryIncRef┤4 >┬logger+Lorg/elasticsearch/common/logging/ESLogger;┼▀ ▄"[{}][{}] starting recovery from {}▌java/lang/Object░shardId)()Lorg/elasticsearch/index/shard/ShardId;▓⌠ Ь■%org/elasticsearch/index/shard/ShardId√index!()Lorg/elasticsearch/index/Index;≤≥ ≈ org/elasticsearch/index/Index°name· ²÷id()I║╒ ≈ёjava/lang/Integer╔valueOf(I)Ljava/lang/Integer;ї╗ і╘)org/elasticsearch/common/logging/ESLogger╚trace((Ljava/lang/String;[Ljava/lang/Object;)Vґў╛╞"org/elasticsearch/common/StopWatch╠ ╡Оstart&()Lorg/elasticsearch/common/StopWatch;Є╣ ╡І,internal:index/shard/recovery/start_recovery╦ f submitRequestс(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportResponseHandler;)Lorg/elasticsearch/transport/TransportFuture;╩╪ iҐ+org/elasticsearch/transport/TransportFuture©txGet()Ljava/lang/Object;абюц3org/elasticsearch/indices/recovery/RecoveryResponseеdecRefгЇ >хstopй╣ ╡кisTraceEnabledм4╛н(C)Ljava/lang/StringBuilder;Сп Ня(I)Ljava/lang/StringBuilder;Сс Нт] жrecovery completed from ь, took[з totalTime+()Lorg/elasticsearch/common/unit/TimeValue;эщ ╡ч] Ю phase1: recovered_files [Бphase1FileNamesLjava/util/List;ДЕ фФjava/util/ListХsizeЙ╒ИК]М with total_size of [О+org/elasticsearch/common/unit/ByteSizeValueЯphase1TotalSizeСФ фТM╘ РЖ, took [Ь phase1TimeЗФ фШ'org/elasticsearch/common/unit/TimeValueЩtimeValueMillis,(J)Lorg/elasticsearch/common/unit/TimeValue;Ъ Ч], throttling_wait [phase1ThrottlingWaitTimeФ ф : reusing_files [ phase1ExistingFileNamesЕ ф ] with total_size of [phase1ExistingTotalSizeФ ф phase2: start took [≈Ф ф : recovered [phase2OperationsI ф transaction log operations phase2Time Ф ф! phase3: recovered [#phase3Operations% ф& phase3Time(Ф ф)isDebugEnabled+4╛,*{} recovery completed from [{}], took [{}].debug0ў╛1onRecoveryDone3Ї4"[{}][{}] Got exception on recovery6=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)Vґ8╛9"org/elasticsearch/ExceptionsHelper;unwrapCause,(Ljava/lang/Throwable;)Ljava/lang/Throwable;=> }java/util/Collectioniterator()Ljava/util/Iterator;│┌─┐java/util/Iterator┘hasNext┤4├┬next┼б├▀i$Ljava/util/Iterator;remove(J)Ljava/lang/Object;▐░>▒cancelAndClearOpenIndexInputs()Ljava/util/Set;⌠■ ▌∙ java/util/Set≈≤┐getValue б'⌡#org/apache/lucene/store/IndexOutput²java/io/Closeable÷org/apache/lucene/util/IOUtils║closeWhileHandlingException([Ljava/io/Closeable;)Vёє ╒╔▐Ї├їlegacyChecksums5Lorg/elasticsearch/index/store/Store$LegacyChecksums;╘╙ ▌╚clearґЇ <ўentryNLjava/util/Map$Entry;Ljava/util/Map$Entry;entrySet_Ljava/util/Set;>;Ljava/util/Set;dLjava/util/Iterator;>;validateRecoveryStatus](Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/index/shard/ShardId;)V*(Lorg/elasticsearch/index/shard/ShardId;)VM╧ \╨onGoingRecovery'Lorg/elasticsearch/index/shard/ShardId; access$000 (Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/index/shard/service/IndexShard;)Lorg/elasticsearch/indices/recovery/RecoveryStatus;x0x1 access$100i(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/indices/recovery/RecoveryStatus;)V access$200cd еx2x3 access$300q(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/common/util/concurrent/ConcurrentMapLong; access$400░(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/index/shard/ShardId;)VЇ╦ м access$500_(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/indices/IndicesService; access$600`(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/common/logging/ESLogger; access$700j(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/indices/recovery/RecoverySettings;java/lang/ClassжdesiredAssertionStatusь4 вы SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotations StackMapTableLocalVariableTypeTable"RuntimeVisibleParameterAnnotations SourceFileInnerClasses!@ABCDEFGHIшJKLMNэ ├*+ЇR*╦X╣Z*,╣\*-╣^*╣`*╣b-d╩ Y*ЇgІm-o╩Y*ЇpІm-r╩ Y*ЇsІm-u╩Y*ЇvІm-x╩Y*ЇyІm-{╩Y*Ї|Іm╩%Y*Ї}╧│╠щH├┌┐├└┘├@A├BC├DE├├┤├FGч:YTZ[\]"_0`>aLbZchdvf┘nъO┬┴э═?*+Ї▄M,г╟,І▓І√І ■·%,І·╡╒╔,І▓І√╦ї,І▓І√І eІ╚,╟щ ?┌┐?╛ґ9┬ўчqr su%v=xЮ Э▌0╞╟эs*+Ї▄M,г╠,Є╣≥╠,І╧,ЄҐф ,ЄҐІбцBе7г╦м┘7,Є╣ 2*Є^,ЄяІу≥$ ■· e7ц╦ьїЪь: ╦эІбї*,ЇЮї : *,ЇЮ ©╠X^a╡lttvtщHc ЦД )CЕФ.>ГФ66ХФ┌┐╛ґy┬ўчZ|~ │┌└├┤%┼)▀.▄6▌R░X▓^√a⌠c■i∙l≥q t≥~°ЮЭ▌Чj╡Ь GБ ИЙэR╠,╩НYЇПРІЖ+ІШІЧІІWї%:-╩НYЇП ІЖІ ІЖІ╧╠╩▌Y+І,+ІШЇ:Є+ІІ"Є+ІШІ&Є+І)І,Є,І0╧6І:*ЄZЄ<╧BW*Є\ІH╩#Y*+-ЇK╧Q╠Лщ> ЦR╠┌┐╠ST╠╛U╠VWR_┬ўч6 ═╔║ ё?є@їR╗^╘j╙v╚┤╛≤ў╟ЄЮ^Л!XYэo *Є\,Z╩!Y*+-Ї[І_W╠щ4┌┐ST`abўVWч ЇҐcdэN н╡f +ІШг╩hYjЇm©,Єo:г-q╧╠Іu╡{і-}╧╠,І─≥-┌╧╠,╦э╣ҐІ├І┴≥^*Є█▐Ґ▒Y+І∙І⌡І═SY+І∙Іє╦╙SY+ІШS╧╟╩╡YЇЁІЇ:*Є^+ІШ╧+╩Y*Ї╨ІЎ╧дюф:Іu╡{і*,ЇЮ-}╧І├Іи╠ІлW*Є█╧о≥▒╩НYЇП:[Ір+І∙І⌡І═ІЖ]Ір[Ір+І∙ІєІувІЖWыІЖ+ІШІЧшІЖІъІЧАІЖWЦІЖЄГ╧ЛІуНІЖПІЖ╩РYЄУЇВІЧНІЖЫІЖЄЭ╦ІЧІЖЄ╦ІЧ]Ір ІЖWІЖЄ╧ЛІуІЖ╩РYЄЇВІЧАІЖWІЖЄ╦ІЧАІЖWІЖЄІуНІЖІЖЫІЖЄ"╦ІЧНІЖ ІЖW$ІЖЄ'ІуНІЖІЖЫІЖЄ*╦ІЧНІЖW*Є█ІҐ▒╧╟ї5*Є█╧-≥)*Є█/Ґ▒Y+І∙SY+ІШSYІъS╧2*,ЇЮ-╧5І├ІиїР:*Є█╧о≥/*Є█7Ґ▒Y+І∙І⌡І═SY+І∙Іє╦╙S╧:,І─≥-┌╧І├Іи╠Іu╡{і*,ЇЮ-}╧І├Іи╠╦@:аB≥ ІF:╦@:аB≥ ІF:аH аJ аL≥-M╦,╧RІ├Іи╠аT≥-M╦,╧RІ├Іи╠*,ЇЮаV≥0-╩НYЇПXІЖ+ІШІЧZІЖІ╧І├Іи╠а\≥0-╩НYЇП^ІЖ+ІШІЧZІЖІ╧І├Іи╠а`≥0-╩НYЇП^ІЖ+ІШІЧZІЖІ╧І├Іи╠*Є█bҐ▒Y+І∙І⌡І═SY+І∙Іє╦╙SY+ІШS╧e-╩gY+Їj╧nІ├Іиї:І├Іи©ї -p╧╠ hЮяБИфяБhЮЁИфЁяЁ%?ЁH≥Ё╒ЇЁюЯЁЗ&Ё/[Ёd╗ЁЁ╣Ёщf ┌qr╔!stфuvOYwxсуЦxн┌┐нSTн┬ўнVW╟yUч2Lюаб#ц-д.ф9гCхDйKлUмVп]яhс≥у╔жфэящжчЮ6ИАОБШЦД3ЕWФ╩ИЛЙК@НtП├Я∙Р╩ТюУф6н7яЖсВъЬЗЭ6%Ъ05?6HOW^ em t▄≥6╒╙Ї6ю"е$м%Я6З)*&6/.7/[6d3≈4╗6╟7Ё6ц9м;ЮbЭЩ▓╡фШ÷1ЪЬ▌БЭ9Б"ЭБ944ЪNЬ▌Б ┼┴э⌡1*ЄZ╧~╧└M,╧┴≥,╧▄ю▌N-Єo+і-╟їЪЦ╟щ*" ┬ў █▌1┌┐1╛ґчI"J*K,M/NЮЭ├Зъzщчэ}─+г╠*ЄZ+Є<╧▓ю▌L+г╠+І╧+І√M,╧≥N-╧┴≥G-╧▄ю':╧°ю·Y:бҐ═Y╧°ю═S╦іцї:ц©-╧╗їЪІ+Є╛І╞╠Mdgglgщ4?6╟╡─┌┐─bў$\Ё╣+U│▌А ?6╟╠$\ЁЄ+U│ІчFRSVWX\^$_+`4a?bMcadoeugxhiЮ/Щ≤├Ъ;▌≤├'▒БЗЗБzЇ╦э╟C+г╩\Y,Ї╩©+ЄoІu╡{і*+ЇЮ+╣╣╩\Y,Ї╩©+І─≥+╣╣╩\Y,Ї╩©╠щ C┌┐C╪ўC▓Ґч* z| ~─$│-┐4└9┘B┤Ю Ў©э:*+Ї▄╟щю┐аґчAбцэ:*+ЇЮ╠щю┐аўчAдIэP*+,-Їф╠щ*ю┐аTгўхWчAийэ/*ЄZ╟щю┐чAклэE*+,Їн╠щ ю┐аўгҐчAопэ/*Є`╟щю┐чAярэ/*Є█╟щю┐чAстэ/*Єb╟щю┐чAуЇэ4Із їЁf╠чAЮ@ЦД▓ !#%')* ,./ 134 637@93:@<>?