Edit C:\dspace\webapps\xmlui\WEB-INF\lib\org\elasticsearch\indices\recovery\RecoverySource$1.class
???? 3? 3org/elasticsearch/indices/recovery/RecoverySource$1 java/lang/Object 5org/elasticsearch/index/engine/Engine$RecoveryHandler RecoverySource.java 1org/elasticsearch/indices/recovery/RecoverySource recover p(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;)Lorg/elasticsearch/indices/recovery/RecoveryResponse; 5org/elasticsearch/indices/recovery/RecoverySource$1$3 5org/elasticsearch/indices/recovery/RecoverySource$1$2 5org/elasticsearch/indices/recovery/RecoverySource$1$1 4org/elasticsearch/index/store/Store$MetadataSnapshot #org/elasticsearch/index/store/Store MetadataSnapshot 0org/elasticsearch/index/store/Store$RecoveryDiff RecoveryDiff 2org/elasticsearch/index/translog/Translog$Snapshot )org/elasticsearch/index/translog/Translog Snapshot Qorg/elasticsearch/cluster/action/index/MappingUpdatedAction$MappingUpdateListener ;org/elasticsearch/cluster/action/index/MappingUpdatedAction " MappingUpdateListener 3org/elasticsearch/index/translog/Translog$Operation % Operation %org/elasticsearch/index/engine/Engine ( RecoveryHandler 8org/elasticsearch/transport/TransportRequestOptions$Type + 3org/elasticsearch/transport/TransportRequestOptions - Type val$shard :Lorg/elasticsearch/index/shard/service/InternalIndexShard; val$request 9Lorg/elasticsearch/indices/recovery/StartRecoveryRequest; val$response 5Lorg/elasticsearch/indices/recovery/RecoveryResponse; val$indexService .Lorg/elasticsearch/index/service/IndexService; this$0 3Lorg/elasticsearch/indices/recovery/RecoverySource; <init> (Lorg/elasticsearch/indices/recovery/RecoverySource;Lorg/elasticsearch/index/shard/service/InternalIndexShard;Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/indices/recovery/RecoveryResponse;Lorg/elasticsearch/index/service/IndexService;)V 8 9 < 0 1 > 2 3 @ 4 5 B 6 7 D ()V : F G this 5Lorg/elasticsearch/indices/recovery/RecoverySource$1; phase1 ?(Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit;)V (org/elasticsearch/ElasticsearchException M java/lang/Throwable O 8org/elasticsearch/index/shard/service/InternalIndexShard Q store '()Lorg/elasticsearch/index/store/Store; S T R U incRef W F X "org/elasticsearch/common/StopWatch Z [ G start &()Lorg/elasticsearch/common/StopWatch; ] ^ [ _ getMetadata ](Lorg/apache/lucene/index/IndexCommit;)Lorg/elasticsearch/index/store/Store$MetadataSnapshot; a b c :org/elasticsearch/index/deletionpolicy/SnapshotIndexCommit e getFiles ()[Ljava/lang/String; g h f i [Ljava/lang/String; k get E(Ljava/lang/String;)Lorg/elasticsearch/index/store/StoreFileMetaData; m n o access$000 `(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/logging/ESLogger; q r s 8Snapshot differs from actual index for file: {} meta: {} u asMap ()Ljava/util/Map; w x y )org/elasticsearch/common/logging/ESLogger { info ((Ljava/lang/String;[Ljava/lang/Object;)V } ~ | -org/apache/lucene/index/CorruptIndexException ? java/lang/StringBuilder ? ? G JSnapshot differs from actual index - maybe index was removed metadata has ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? ? ? java/util/Map ? size ()I ? ? ? ? (I)Ljava/lang/StringBuilder; ? ? ? ? files ? toString ()Ljava/lang/String; ? ? ? ? (Ljava/lang/String;)V : ? ? ? 7org/elasticsearch/indices/recovery/StartRecoveryRequest ? existingFiles ? x ? ? (Ljava/util/Map;)V : ? ? recoveryDiff j(Lorg/elasticsearch/index/store/Store$MetadataSnapshot;)Lorg/elasticsearch/index/store/Store$RecoveryDiff; ? ? ? identical Ljava/util/List; ? ? ? java/util/List ? iterator ()Ljava/util/Iterator; ? ? ? ? java/util/Iterator ? hasNext ()Z ? ? ? ? next ()Ljava/lang/Object; ? ? ? ? /org/elasticsearch/index/store/StoreFileMetaData ? 3org/elasticsearch/indices/recovery/RecoveryResponse ? phase1ExistingFileNames ? ? ? ? name ? ? ? ? add (Ljava/lang/Object;)Z ? ? ? ? phase1ExistingFileSizes ? ? ? ? length ()J ? ? ? ? java/lang/Long ? valueOf (J)Ljava/lang/Long; ? ? ? ? access$100 ? r ? isTraceEnabled ? ? | ? access$200 ? r ? m[{}][{}] recovery [phase1] to {}: not recovering [{}], exists in local store and has checksum [{}], size [{}] ? shardId )()Lorg/elasticsearch/index/shard/ShardId; ? ? ? ? %org/elasticsearch/index/shard/ShardId ? index !()Lorg/elasticsearch/index/Index; ? ? ? ? org/elasticsearch/index/Index ? ? ? id ? ? ? ? java/lang/Integer ? (I)Ljava/lang/Integer; ? ? ? ? targetNode 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? ? checksum ? ? ? ? trace ~ | different ? missing ? *org/elasticsearch/common/collect/Iterables concat >(Ljava/lang/Iterable;Ljava/lang/Iterable;)Ljava/lang/Iterable; java/lang/Iterable ? containsKey ? ? access$300 r s[{}][{}] recovery [phase1] to {}: recovering [{}], exists in local store, but is different: remote [{}], local [{}] &(Ljava/lang/Object;)Ljava/lang/Object; m ? access$400 r L[{}][{}] recovery [phase1] to {}: recovering [{}], does not exists in remote phase1FileNames " ? ?# phase1FileSizes % ? ?& phase1TotalSize J () ?* phase1ExistingTotalSize ,) ?- access$500 / r 0 u[{}][{}] recovery [phase1] to {}: recovering_files [{}] with total_size [{}], reusing_files [{}] with total_size [{}]2 ? ? +org/elasticsearch/common/unit/ByteSizeValue5 (J)V :7 68 ;org/elasticsearch/indices/recovery/RecoveryFilesInfoRequest: recoveryId < ? ?= m(JLorg/elasticsearch/index/shard/ShardId;Ljava/util/List;Ljava/util/List;Ljava/util/List;Ljava/util/List;JJ)V :? ;@ access$700 c(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/transport/TransportService; BC D 'internal:index/shard/recovery/filesInfoF options 7()Lorg/elasticsearch/transport/TransportRequestOptions; HI .J access$600 ^(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/unit/TimeValue; LM N withTimeout `(Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/transport/TransportRequestOptions; PQ .R 9org/elasticsearch/transport/EmptyTransportResponseHandlerT INSTANCE_SAME ;Lorg/elasticsearch/transport/EmptyTransportResponseHandler; VW UX ,org/elasticsearch/transport/TransportServiceZ submitRequest(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportRequestOptions;Lorg/elasticsearch/transport/TransportResponseHandler;)Lorg/elasticsearch/transport/TransportFuture; \] [^ +org/elasticsearch/transport/TransportFuture` txGet b ? ac #java/util/concurrent/CountDownLatche (I)V :g fh )java/util/concurrent/CopyOnWriteArrayListj k G +java/util/concurrent/atomic/AtomicReferencem n G java/lang/Stringp (I)Ljava/lang/Object; mr ?s longValue u ? ?v access$800 j(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/indices/recovery/RecoverySettings; xy z 3org/elasticsearch/indices/recovery/RecoverySettings| SMALL_FILE_CUTOFF_BYTES ~) } concurrentStreamPool +()Ljava/util/concurrent/ThreadPoolExecutor; ?? }? concurrentSmallFileStreamPool ?? }? 'java/util/concurrent/ThreadPoolExecutor?"(Lorg/elasticsearch/indices/recovery/RecoverySource$1;Lorg/elasticsearch/index/store/Store;Lorg/elasticsearch/index/store/Store$MetadataSnapshot;Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicReference;Ljava/util/concurrent/CopyOnWriteArrayList;Ljava/util/concurrent/CountDownLatch;)V :? ? execute (Ljava/lang/Runnable;)V ?? ?? await ? F f? m ? n? "org/elasticsearch/ExceptionsHelper? rethrowAndSuppress (Ljava/util/List;)V ?? ?? %org/elasticsearch/common/collect/Sets? newHashSet (([Ljava/lang/Object;)Ljava/util/HashSet; ?? ?? )internal:index/shard/recovery/clean_files? <org/elasticsearch/indices/recovery/RecoveryCleanFilesRequest? R ? :(JLorg/elasticsearch/index/shard/ShardId;Ljava/util/Set;)V :? ?? stop ? ^ [? access$1100 ? r ? +[{}][{}] recovery [phase1] to {}: took [{}]? totalTime +()Lorg/elasticsearch/common/unit/TimeValue; ?? [? 'org/elasticsearch/common/unit/TimeValue? millis ? ? ?? phase1Time ?) ?? decRef ? F ? @org/elasticsearch/indices/recovery/RecoverFilesRecoveryException? m(Lorg/elasticsearch/index/shard/ShardId;ILorg/elasticsearch/common/unit/ByteSizeValue;Ljava/lang/Throwable;)V :? ?? md 1Lorg/elasticsearch/index/store/StoreFileMetaData; Ljava/lang/String; arr$ len$ I i$ Ljava/util/Iterator; pool )Ljava/util/concurrent/ThreadPoolExecutor; fileSize stopWatch $Lorg/elasticsearch/common/StopWatch; recoverySourceMetadata 6Lorg/elasticsearch/index/store/Store$MetadataSnapshot; diff 2Lorg/elasticsearch/index/store/Store$RecoveryDiff; recoveryInfoFilesRequest =Lorg/elasticsearch/indices/recovery/RecoveryFilesInfoRequest; latch %Ljava/util/concurrent/CountDownLatch; exceptions BLjava/util/concurrent/CopyOnWriteArrayList<Ljava/lang/Throwable;>; +Ljava/util/concurrent/CopyOnWriteArrayList; corruptedEngine ^Ljava/util/concurrent/atomic/AtomicReference<Lorg/apache/lucene/index/CorruptIndexException;>; -Ljava/util/concurrent/atomic/AtomicReference; fileIndex snapshotFiles #Ljava/util/Set<Ljava/lang/String;>; Ljava/util/Set; e Ljava/lang/Throwable; snapshot <Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit; totalSize existingTotalSize %Lorg/elasticsearch/index/store/Store; phase2 7(Lorg/elasticsearch/index/translog/Translog$Snapshot;)V state 1()Lorg/elasticsearch/index/shard/IndexShardState; ?? R? -org/elasticsearch/index/shard/IndexShardState? CLOSED /Lorg/elasticsearch/index/shard/IndexShardState; ?? ?? 7org/elasticsearch/index/shard/IndexShardClosedException? *(Lorg/elasticsearch/index/shard/ShardId;)V :? ?? access$1200 ? r ? !{} recovery [phase2] to {}: start .internal:index/shard/recovery/prepare_translog Norg/elasticsearch/indices/recovery/RecoveryPrepareForTranslogOperationsRequest +(JLorg/elasticsearch/index/shard/ShardId;)V : startTime ) ? access$1300 r +{} recovery [phase2] to {}: start took [{}] access$1400 r >{} recovery [phase2] to {}: updating current mapping to master updateMappingOnMaster F access$1500 r >{} recovery [phase2] to {}: sending transaction log operations sendSnapshot 7(Lorg/elasticsearch/index/translog/Translog$Snapshot;)I access$1600 " r # %{} recovery [phase2] to {}: took [{}]% phase2Time ') ?( phase2Operations *? ?+ 4Lorg/elasticsearch/index/translog/Translog$Snapshot; totalOperations java/lang/InterruptedException/ >org/elasticsearch/common/util/concurrent/ConcurrentCollections1 newBlockingQueue &()Ljava/util/concurrent/BlockingQueue; 34 25 access$1700 _(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/cluster/ClusterService; 78 9 recovery_mapping_check; ?(Lorg/elasticsearch/indices/recovery/RecoverySource$1;Ljava/util/concurrent/CountDownLatch;Ljava/util/concurrent/BlockingQueue;)V := > (org/elasticsearch/cluster/ClusterService@ submitStateUpdateTask G(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V BC AD "java/util/concurrent/BlockingQueueF java/lang/ThreadH currentThread ()Ljava/lang/Thread; JK IL interrupt N F IO isEmpty Q ? GR G ? ](Lorg/elasticsearch/indices/recovery/RecoverySource$1;Ljava/util/concurrent/CountDownLatch;)V :U V G ? -org/elasticsearch/index/mapper/DocumentMapperY access$2000 r(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction; [\ ] ,org/elasticsearch/index/service/IndexService_ ` ? getName b ? ?c indexUUID e ? `f ?(Ljava/lang/String;Lorg/elasticsearch/index/mapper/DocumentMapper;Ljava/lang/String;Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction$MappingUpdateListener;)V h #i java/util/concurrent/TimeUnitk MILLISECONDS Ljava/util/concurrent/TimeUnit; mn lo #(JLjava/util/concurrent/TimeUnit;)Z ?q fr access$2100 t r u T{} recovery [phase2] to {}: waiting on pending mapping update timed out. waited [{}]w debug y ~ |z access$2200 | r } 9interrupted while waiting for mapping to update on master Ljava/lang/InterruptedException; documentMapper /Lorg/elasticsearch/index/mapper/DocumentMapper; documentMappersToUpdate ULjava/util/concurrent/BlockingQueue<Lorg/elasticsearch/index/mapper/DocumentMapper;>; $Ljava/util/concurrent/BlockingQueue; updatedOnMaster listener SLorg/elasticsearch/cluster/action/index/MappingUpdatedAction$MappingUpdateListener; phase3 =org/elasticsearch/index/shard/IllegalIndexShardStateException? access$2300 ? r ? D[{}][{}] recovery [phase3] to {}: sending transaction log operations? &internal:index/shard/recovery/finalize? Borg/elasticsearch/indices/recovery/RecoveryFinalizeRecoveryRequest? ? access$2400 ?M ? markAsRelocated ? ? ?? to ? -(Ljava/lang/Object;)Ljava/lang/StringBuilder; ?? ?? relocated N(Ljava/lang/String;)Lorg/elasticsearch/index/shard/service/InternalIndexShard; ?? R? access$2500 ? r ? +[{}][{}] recovery [phase3] to {}: took [{}]? phase3Time ?) ?? phase3Operations ?? ?? ?Lorg/elasticsearch/index/shard/IllegalIndexShardStateException; &org/elasticsearch/common/collect/Lists? newArrayList ()Ljava/util/ArrayList; ?? ?? 7()Lorg/elasticsearch/index/translog/Translog$Operation; ?? ? estimateSize ? ? &? translogOps ? ? }? translogSize /()Lorg/elasticsearch/common/unit/ByteSizeValue; ?? }? bytes ? ? 6? Dorg/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest? ;(JLorg/elasticsearch/index/shard/ShardId;Ljava/util/List;)V :? ?? *internal:index/shard/recovery/translog_ops? compress ? ? }? withCompress 8(Z)Lorg/elasticsearch/transport/TransportRequestOptions; ?? .? RECOVERY :Lorg/elasticsearch/transport/TransportRequestOptions$Type; ?? ,? withType q(Lorg/elasticsearch/transport/TransportRequestOptions$Type;)Lorg/elasticsearch/transport/TransportRequestOptions; ?? .? clear ? F ?? ?R translogOperationsRequest FLorg/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest; ops operations GLjava/util/List<Lorg/elasticsearch/index/translog/Translog$Operation;>; operation 5Lorg/elasticsearch/index/translog/Translog$Operation; Code LocalVariableTable LineNumberTable LocalVariableTypeTable StackMapTable Exceptions SourceFile EnclosingMethod InnerClasses 0 1 2 3 4 5 6 7 8 9 : ; ? J *+? =*,? ?*-? A*? C*? E*? H? ? I J ? ? K L ? j 0 A 7*? ?? V:? Y? [Y? \? `:+? d:+? j: ?6 6 ? f 2: ? p: ? K*? =? tv? Y SY? zS? ? ? ?Y? ?Y? ??? ?? z? ? ? ??? ?? ?? ??? ???? Y*? A? ?? ?? ?: ? ?? ? : ? ? ? ? ? ? ? ?: *? C? ? ? ? ? W*? C? ? ? ? ? ? W ? ?a7*? =? ? ? ? [*? =? ??? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?SY ? ?SY ? ?SY ? ? ?S? ? ?aA??J ? ??? : ? ? ? ? ? ? ? ?: *? A? ? ? ? ? e*? =?? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?SY ? ?SY*? A? ? ? ? SY S? ? H*? =? !? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?SY ? ?S? *? C?$ ? ? ? W*? C?' ? ? ? ? W ? ?aA?? *? C ?+*? C?.*? =?13? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?SY*? C?$?4 ? ?SY?6Y ?9SY*? C? ?4 ? ?SY?6Y?9S? ?;Y*? A?>*? A? ?*? C?$*? C?'*? C? ?*? C? ?*? C?+*? C?.?A: *? =?E*? A? ?G ?K*? =?O?S?Y?_?d W?fY*? C?$?4 ?i: ?kY?l: ?nY?o: 6*? C?$? ? :? ? ? p? ? ?q:*? C?'?t ? ?w7*? =?{W???? *? =?{??:? *? =?{??:? Y* ???????? ?? ??? ??? ?? ??+? j??:*? =?E*? A? ????Y*? A?>*? ??????K*? =?O?S?Y?_?d W??W*? =???? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?SY??S? *? C????????? 4:??Y*? A? ?*? C?$?4 ?6Y ?9??:???? ?? P ?% ?'% ? $ L M?? C V ?? - r? k 2 m?? 5 j?? ? ??? ? ??? ? ??? ??? ?? ?? ? H?) ? ^ ?? ? w?? ??? '??? ?B?? \??? ?Y?? ?P?? ?G?? ?D?? [ ??? %?? 0 I J 0?? .?) +?) " S? ? ?P?? ?G?? [ ??? ? ? = ? ? ? ? ? ? ' ? C ? L ? Q ? p ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?n ?v ?y ?? ?? ? ?^ ?p ?? ?? ?? ?? ?? ? ?\ ?? ?? ?? ?? ?? ?? ?? ?? ? ? ?147<DM R [?????? %/? ? ? 5 f [ l ? c? ? ?? ? ?? ? ?? ? ?? D? 1?/ f [ ;fkn ? ? Kq? ?? f [ ;fkn ? ? f Pf P ? N ?? ? ?*? ????? ??Y*? A? ??*? =??? Y*? A? ?SY*? A? ?S? ? [Y? \? `M*? =?E*? A? ??Y*? A?>*? A? ??K*? =?O?S?Y?_?d W,??W*? C,????? *? =?? Y*? A? ?SY*? A? ?SY*? A? ?SY,??S? *? =?? Y*? A? ?SY*? A? ?S? *?*? =? ? Y*? A? ?SY*? A? ?S? ? [Y? \? `M*+?!>,??W*? =?$&? Y*? A? ?SY*? A? ?SY,??S? *? C,?????)*? C ?,? ? * ? I J ??- N7?? ; J.? ? J C N! ?" ?# ?$ ?' ?(**+5,;-@.n/|0?1? ? N F ? ??6L?fY?iM*? =?:<? Y*,+???E ,??? N?M?P+?S ? ??fY+?T ?iN? Y*-?W:+?X :? ? ? 5? ? ?Z:*? =?^*? E?a ?d*? E?g ?j???-*? =?O???p?s? 4*? =?vx? Y*? A? ?SY*? A? ?SY*? =?OS?{ ? :?M?P*? =?~?? ?{ ? & * -0 ? ? ?0 ? \ . ?? u #?? _ <?? ? ?? ? I J ??? ??? L ??? W ??? ? ??? ? V 7 8 9 &Z *] -[ .\ 4^ =_ >a Lb Wn uo ?p ?r ?s ?x ?u ?v ?w ?z? . ? - Gf 0 ? f ! ?? ;? DB0 ?? ? ? :*? ????? ??Y*? A? ??*? =???? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?S? ? [Y? \? `M*+?!>*? =?E*? A? ????Y*? A?>*? A? ???K*? =???S?Y?_?d W*? A??? **? ?? ?Y? ??? ?*? A? ??? ???W? :,??W*? =???? Y*? A? ? ? ?SY*? A? ? ? ?SY*? A? ?SY,??S? *? C,??????*? C ??? ? ? ?? ? 4 ? ?? : I J :?- d ??? j ?.? ? > ? ? Y? d? j? ?? ?? ?? ?? ?? ??#?1?9?? ? ? [ ?? N ? M B= B6??:+?? :? ?*? ????? ??Y*? A? ??? ? W?!?? aB? *? =?{??? !*? =?{???? f??Y*? A?>*? A? ???:*? =?E*? A? ???K*? =?{?????*? =???S?Y?_?d W= B?? +?? :??:?? ? [??Y*? A?>*? A? ???:*? =?E*? A? ???K*? =?{?????*? =???S?Y?_?d W? ? \ ? J?? ??? B I J B?- @?? > ?) ;.? 6? ? .?? ? 6?? ? ^ ? ? ? ? ? ? ? &? 5? ?? B? L? O? o? ?? ?? ?? ?? ?? ?? ?? ???? ! ? ? & 9? b ? a? N ? ? ? Z ! # $ & ' ) * , . /@
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de