Edit C:\dspace\webapps\xmlui\WEB-INF\lib\org\elasticsearch\indices\recovery\RecoverySource.class
???? 3C 1org/elasticsearch/indices/recovery/RecoverySource 4org/elasticsearch/common/component/AbstractComponent RecoverySource.java Vorg/elasticsearch/indices/recovery/RecoverySource$StartRecoveryTransportRequestHandler $StartRecoveryTransportRequestHandler 9org/elasticsearch/indices/recovery/RecoverySource$Actions Actions 3org/elasticsearch/indices/recovery/RecoverySource$1 5org/elasticsearch/index/engine/Engine$RecoveryHandler %org/elasticsearch/index/engine/Engine RecoveryHandler transportService .Lorg/elasticsearch/transport/TransportService; indicesService *Lorg/elasticsearch/indices/IndicesService; recoverySettings 5Lorg/elasticsearch/indices/recovery/RecoverySettings; mappingUpdatedAction =Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction; clusterService *Lorg/elasticsearch/cluster/ClusterService; internalActionTimeout )Lorg/elasticsearch/common/unit/TimeValue; internalActionLongTimeout <init>#(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/indices/recovery/RecoverySettings;Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction;Lorg/elasticsearch/cluster/ClusterService;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V # $ & ( * , . ,internal:index/shard/recovery/start_recovery 0 6(Lorg/elasticsearch/indices/recovery/RecoverySource;)V 2 3 ,org/elasticsearch/transport/TransportService 5 registerHandler J(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V 7 8 6 9 componentSettings ,Lorg/elasticsearch/common/settings/Settings; ; < = internal_action_timeout ? 'org/elasticsearch/common/unit/TimeValue C timeValueMinutes ,(J)Lorg/elasticsearch/common/unit/TimeValue; E F D G *org/elasticsearch/common/settings/Settings I getAsTime f(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; K L J M O millis ()J Q R D S (J)V W D X Z this 3Lorg/elasticsearch/indices/recovery/RecoverySource; settings recover p(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;)Lorg/elasticsearch/indices/recovery/RecoveryResponse; 7org/elasticsearch/indices/recovery/StartRecoveryRequest a shardId )()Lorg/elasticsearch/index/shard/ShardId; c d b e %org/elasticsearch/index/shard/ShardId g index !()Lorg/elasticsearch/index/Index; i j h k org/elasticsearch/index/Index m name ()Ljava/lang/String; o p n q (org/elasticsearch/indices/IndicesService s indexServiceSafe B(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; u v t w id ()I y z h { ,org/elasticsearch/index/service/IndexService } shardSafe 5(I)Lorg/elasticsearch/index/shard/service/IndexShard; ? ~ ? 8org/elasticsearch/index/shard/service/InternalIndexShard ? (org/elasticsearch/cluster/ClusterService ? state *()Lorg/elasticsearch/cluster/ClusterState; ? ? ? ? &org/elasticsearch/cluster/ClusterState ? readOnlyRoutingNodes 2()Lorg/elasticsearch/cluster/routing/RoutingNodes; ? ? ? ? targetNode 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? b ? ,org/elasticsearch/cluster/node/DiscoveryNode ? y p ? ? .org/elasticsearch/cluster/routing/RoutingNodes ? node C(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/RoutingNode; ? ? ? ? logger +Lorg/elasticsearch/common/logging/ESLogger; ? ? ? 4delaying recovery of {} as source node {} is unknown ? java/lang/Object ? )org/elasticsearch/common/logging/ESLogger ? debug ((Ljava/lang/String;[Ljava/lang/Object;)V ? ? ? ? 9org/elasticsearch/indices/recovery/DelayRecoveryException ? java/lang/StringBuilder ? ()V ? ? ? $source node does not have the node [ ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? ? ? -(Ljava/lang/Object;)Ljava/lang/StringBuilder; ? ? ? ? ] in its state yet.. ? toString ? p ? ? (Ljava/lang/String;)V ? ? ? -org/elasticsearch/cluster/routing/RoutingNode ? iterator ()Ljava/util/Iterator; ? ? ? ? .org/elasticsearch/cluster/routing/ShardRouting ? java/util/Iterator ? hasNext ()Z ? ? ? ? next ()Ljava/lang/Object; ? ? ? ? ? e equals (Ljava/lang/Object;)Z ? ? h ? Idelaying recovery of {} as it is not listed as assigned to target node {} ? Psource node does not have the shard listed in its state as allocated on the node ? initializing ? ? ? ? mdelaying recovery of {} as it is not listed as initializing on the target node {}. known shards state is [{}] ? 7()Lorg/elasticsearch/cluster/routing/ShardRoutingState; ? ? ? ? 5source node has the state of the target shard to be [ ? !], expecting to be [initializing] ? 6[{}][{}] starting recovery to {}, mark_as_relocated {} ? java/lang/Integer ? valueOf (I)Ljava/lang/Integer; ? ? ? ? markAsRelocated ? ? b ? java/lang/Boolean ? (Z)Ljava/lang/Boolean; ? ? ? ? trace ? ? ? ? 3org/elasticsearch/indices/recovery/RecoveryResponse ? ?(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 :(Lorg/elasticsearch/index/engine/Engine$RecoveryHandler;)V _ ? shardRouting 0Lorg/elasticsearch/cluster/routing/ShardRouting; i$ Ljava/util/Iterator; request 9Lorg/elasticsearch/indices/recovery/StartRecoveryRequest; indexService .Lorg/elasticsearch/index/service/IndexService; shard :Lorg/elasticsearch/index/shard/service/InternalIndexShard; /Lorg/elasticsearch/cluster/routing/RoutingNode; targetShardRouting response 5Lorg/elasticsearch/indices/recovery/RecoveryResponse; access$000 `(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/logging/ESLogger; x0 access$100 access$200 access$300 access$400 access$500 access$600 ^(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/unit/TimeValue; access$700 c(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/transport/TransportService; access$800 j(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/indices/recovery/RecoverySettings; access$900 access$1000 access$1100 access$1200 access$1300 access$1400 access$1500 access$1600 access$1700 _(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/cluster/ClusterService; access$1800 access$1900 access$2000 r(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction; access$2100 access$2200 access$2300 access$2400 access$2500 access$2600 ?(Lorg/elasticsearch/indices/recovery/RecoverySource;Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;)Lorg/elasticsearch/indices/recovery/RecoveryResponse; _ ` 9 x1 Code LocalVariableTable LineNumberTable RuntimeVisibleAnnotations StackMapTable SourceFile InnerClasses ! ! <