Edit C:\dspace\webapps\rest\WEB-INF\lib\org\elasticsearch\index\gateway\IndexShardGatewayService.class
???? 3 ? 8org/elasticsearch/index/gateway/IndexShardGatewayService 9org/elasticsearch/index/shard/AbstractIndexShardComponent /org/elasticsearch/index/CloseableIndexComponent IndexShardGatewayService.java Iorg/elasticsearch/index/gateway/IndexShardGatewayService$RecoveryListener RecoveryListener :org/elasticsearch/index/gateway/IndexShardGatewayService$1 6org/elasticsearch/indices/recovery/RecoveryState$Timer 0org/elasticsearch/indices/recovery/RecoveryState Timer 6org/elasticsearch/indices/recovery/RecoveryState$Stage Stage threadPool )Lorg/elasticsearch/threadpool/ThreadPool; clusterService *Lorg/elasticsearch/cluster/ClusterService; indexShard :Lorg/elasticsearch/index/shard/service/InternalIndexShard; shardGateway 3Lorg/elasticsearch/index/gateway/IndexShardGateway; snapshotService GLorg/elasticsearch/index/snapshots/IndexShardSnapshotAndRestoreService; recoveryState 2Lorg/elasticsearch/indices/recovery/RecoveryState; <init>U(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/index/shard/service/IndexShard;Lorg/elasticsearch/index/gateway/IndexShardGateway;Lorg/elasticsearch/index/snapshots/IndexShardSnapshotAndRestoreService;Lorg/elasticsearch/cluster/ClusterService;)V (Lorg/elasticsearch/common/inject/Inject; 0Lorg/elasticsearch/index/settings/IndexSettings; V(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;)V ! % & ( 8org/elasticsearch/index/shard/service/InternalIndexShard * , . 0 *(Lorg/elasticsearch/index/shard/ShardId;)V ! 2 3 5 7 this :Lorg/elasticsearch/index/gateway/IndexShardGatewayService; shardId 'Lorg/elasticsearch/index/shard/ShardId; indexSettings ,Lorg/elasticsearch/common/settings/Settings; 2Lorg/elasticsearch/index/shard/service/IndexShard; routingStateChanged ()V 4()Lorg/elasticsearch/indices/recovery/RecoveryState; getTimer :()Lorg/elasticsearch/indices/recovery/RecoveryState$Timer; C D E startTime ()J G H I getStage :()Lorg/elasticsearch/indices/recovery/RecoveryState$Stage; K L M DONE 8Lorg/elasticsearch/indices/recovery/RecoveryState$Stage; O P Q java/lang/System S currentTimeMillis U H T V time (J)V X Y Z recover O(ZLorg/elasticsearch/index/gateway/IndexShardGatewayService$RecoveryListener;)V Borg/elasticsearch/index/gateway/IndexShardGatewayRecoveryException ^ >org/elasticsearch/index/gateway/IgnoreGatewayRecoveryException ` =org/elasticsearch/index/shard/IllegalIndexShardStateException b state 1()Lorg/elasticsearch/index/shard/IndexShardState; d e + f -org/elasticsearch/index/shard/IndexShardState h CLOSED /Lorg/elasticsearch/index/shard/IndexShardState; j k i l shard closed n onIgnoreRecovery (Ljava/lang/String;)V p q r routingEntry 2()Lorg/elasticsearch/cluster/routing/ShardRouting; t u + v .org/elasticsearch/cluster/routing/ShardRouting x primary ()Z z { y | ; < ~ 3Trying to recover when the shard is in backup state ? Q(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/Throwable;)V ! ? _ ? onRecoveryFailed G(Lorg/elasticsearch/index/gateway/IndexShardGatewayRecoveryException;)V ? ? ? restoreSource 3()Lorg/elasticsearch/cluster/routing/RestoreSource; ? ? y ? from snapshot ? recovering C(Ljava/lang/String;)Lorg/elasticsearch/index/shard/IndexShardState; ? ? + ? from gateway ? java/lang/StringBuilder ? ! A ? ? already in recovering process, ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? ? ? getMessage ()Ljava/lang/String; ? ? c ? toString ? ? ? ? 'org/elasticsearch/threadpool/ThreadPool ? generic !()Ljava/util/concurrent/Executor; ? ? ? ? ?(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;ZLorg/elasticsearch/index/gateway/IndexShardGatewayService$RecoveryListener;)V ! ? ? java/util/concurrent/Executor ? execute (Ljava/lang/Runnable;)V ? ? ? ? e ?Lorg/elasticsearch/index/shard/IllegalIndexShardStateException; indexShouldExists Z listener KLorg/elasticsearch/index/gateway/IndexShardGatewayService$RecoveryListener; close 1org/elasticsearch/index/gateway/IndexShardGateway ? ? A ? ? access$000 n(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/indices/recovery/RecoveryState; x0 access$100 f(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/cluster/ClusterService; access$200 v(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/index/shard/service/InternalIndexShard; access$300 g(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/common/logging/ESLogger; logger +Lorg/elasticsearch/common/logging/ESLogger; ? ? ? access$400 ?(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/index/snapshots/IndexShardSnapshotAndRestoreService; access$500 o(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/index/gateway/IndexShardGateway; access$600 access$700 access$800 access$900 access$1000 access$1100 c(Lorg/elasticsearch/index/gateway/IndexShardGatewayService;)Lorg/elasticsearch/index/shard/ShardId; Code LocalVariableTable LineNumberTable RuntimeVisibleAnnotations "RuntimeVisibleParameterAnnotations StackMapTable Exceptions SourceFile InnerClasses ! ! "