Edit C:\dspace\webapps\rest\WEB-INF\lib\org\elasticsearch\snapshots\SnapshotsService.class
???? 3? ,org/elasticsearch/snapshots/SnapshotsService ?Lorg/elasticsearch/common/component/AbstractLifecycleComponent<Lorg/elasticsearch/snapshots/SnapshotsService;>;Lorg/elasticsearch/cluster/ClusterStateListener; =org/elasticsearch/common/component/AbstractLifecycleComponent .org/elasticsearch/cluster/ClusterStateListener SnapshotsService.java Norg/elasticsearch/snapshots/SnapshotsService$UpdateSnapshotStateRequestHandler !UpdateSnapshotStateRequestHandler Rorg/elasticsearch/snapshots/SnapshotsService$UpdateIndexShardSnapshotStatusRequest %UpdateIndexShardSnapshotStatusRequest ;org/elasticsearch/snapshots/SnapshotsService$SnapshotShards SnapshotShards <org/elasticsearch/snapshots/SnapshotsService$SnapshotRequest SnapshotRequest Gorg/elasticsearch/snapshots/SnapshotsService$SnapshotCompletionListener SnapshotCompletionListener Corg/elasticsearch/snapshots/SnapshotsService$DeleteSnapshotListener DeleteSnapshotListener Corg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener CreateSnapshotListener /org/elasticsearch/snapshots/SnapshotsService$10 .org/elasticsearch/snapshots/SnapshotsService$9 .org/elasticsearch/snapshots/SnapshotsService$8 " .org/elasticsearch/snapshots/SnapshotsService$7 $ .org/elasticsearch/snapshots/SnapshotsService$6 & .org/elasticsearch/snapshots/SnapshotsService$5 ( .org/elasticsearch/snapshots/SnapshotsService$4 * .org/elasticsearch/snapshots/SnapshotsService$3 , .org/elasticsearch/snapshots/SnapshotsService$2 . .org/elasticsearch/snapshots/SnapshotsService$1 0 9org/elasticsearch/cluster/metadata/SnapshotMetaData$Entry 2 3org/elasticsearch/cluster/metadata/SnapshotMetaData 4 Entry 3org/elasticsearch/cluster/metadata/MetaData$Builder 7 +org/elasticsearch/cluster/metadata/MetaData 9 Builder 6org/elasticsearch/common/collect/ImmutableList$Builder < .org/elasticsearch/common/collect/ImmutableList > 5org/elasticsearch/common/collect/ImmutableMap$Builder @ -org/elasticsearch/common/collect/ImmutableMap B Gorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus D ShardSnapshotStatus java/util/Map$Entry G java/util/Map I 2org/elasticsearch/cluster/metadata/MetaData$Custom K Custom @org/elasticsearch/index/snapshots/IndexShardSnapshotStatus$Stage N :org/elasticsearch/index/snapshots/IndexShardSnapshotStatus P Stage 9org/elasticsearch/cluster/metadata/SnapshotMetaData$State S State 3org/elasticsearch/cluster/node/DiscoveryNodes$Delta V -org/elasticsearch/cluster/node/DiscoveryNodes X Delta UPDATE_SNAPSHOT_ACTION_NAME Ljava/lang/String; )internal:cluster/snapshot/update_snapshot ] clusterService *Lorg/elasticsearch/cluster/ClusterService; repositoriesService 4Lorg/elasticsearch/repositories/RepositoriesService; threadPool )Lorg/elasticsearch/threadpool/ThreadPool; indicesService *Lorg/elasticsearch/indices/IndicesService; transportService .Lorg/elasticsearch/transport/TransportService; shardSnapshots /Lorg/elasticsearch/common/collect/ImmutableMap; ?Lorg/elasticsearch/common/collect/ImmutableMap<Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotShards;>; shutdownLock !Ljava/util/concurrent/locks/Lock; shutdownCondition &Ljava/util/concurrent/locks/Condition; snapshotCompletionListeners +Ljava/util/concurrent/CopyOnWriteArrayList; vLjava/util/concurrent/CopyOnWriteArrayList<Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotCompletionListener;>; <init>(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/transport/TransportService;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V s v w of 1()Lorg/elasticsearch/common/collect/ImmutableMap; y z C { i j } (java/util/concurrent/locks/ReentrantLock ()V s ? ? ? l m ? java/util/concurrent/locks/Lock ? newCondition (()Ljava/util/concurrent/locks/Condition; ? ? ? ? n o ? )java/util/concurrent/CopyOnWriteArrayList ? ? ? p q ? _ ` ? a b ? c d ? e f ? g h ? a(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/snapshots/SnapshotsService$1;)V s ? ? ,org/elasticsearch/transport/TransportService ? registerHandler J(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V ? ? ? ? (org/elasticsearch/cluster/ClusterService ? addLast 3(Lorg/elasticsearch/cluster/ClusterStateListener;)V ? ? ? ? this .Lorg/elasticsearch/snapshots/SnapshotsService; settings ,Lorg/elasticsearch/common/settings/Settings; snapshot W(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/snapshots/Snapshot; -org/elasticsearch/cluster/metadata/SnapshotId ? getRepository ()Ljava/lang/String; ? ? ? ? 2org/elasticsearch/repositories/RepositoriesService ? repository ?(Ljava/lang/String;)Lorg/elasticsearch/repositories/Repository; ? ? ? ? )org/elasticsearch/repositories/Repository ? readSnapshot ? ? ? ? snapshotId /Lorg/elasticsearch/cluster/metadata/SnapshotId; snapshots D(Ljava/lang/String;)Lorg/elasticsearch/common/collect/ImmutableList; &org/elasticsearch/common/collect/Lists ? newArrayList ()Ljava/util/ArrayList; ? ? ? ? 2()Lorg/elasticsearch/common/collect/ImmutableList; ? ? ? ? iterator ()Ljava/util/Iterator; ? ? ? ? java/lang/String ? java/util/ArrayList ? java/util/Iterator ? hasNext ()Z ? ? ? ? next ()Ljava/lang/Object; ? ? ? ? add (Ljava/lang/Object;)Z ? ? ? ? %org/apache/lucene/util/CollectionUtil ? timSort (Ljava/util/List;)V ? ? ? ? copyOf H(Ljava/util/Collection;)Lorg/elasticsearch/common/collect/ImmutableList; ? ? ? ? i$ Ljava/util/Iterator; repositoryName snapshotList =Ljava/util/ArrayList<Lorg/elasticsearch/snapshots/Snapshot;>; Ljava/util/ArrayList; +Lorg/elasticsearch/repositories/Repository; snapshotIds aLorg/elasticsearch/common/collect/ImmutableList<Lorg/elasticsearch/cluster/metadata/SnapshotId;>; 0Lorg/elasticsearch/common/collect/ImmutableList; createSnapshot ?(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V ? ? ? name ? ? ? '(Ljava/lang/String;Ljava/lang/String;)V s ? cause ? ?(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V s 1 submitStateUpdateTask G(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V ? request >Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest; listener ELorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener; validate i(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/cluster/ClusterState;)V (org/elasticsearch/ElasticsearchException &org/elasticsearch/cluster/ClusterState getMetaData /()Lorg/elasticsearch/cluster/metadata/MetaData; repositories custom H(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; : 7org/elasticsearch/cluster/metadata/RepositoriesMetaData" K(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/RepositoryMetaData; ?$ #% 9org/elasticsearch/repositories/RepositoryMissingException' (Ljava/lang/String;)V s) (* org/elasticsearch/common/Strings, hasLength (Ljava/lang/String;)Z./ -0 8org/elasticsearch/snapshots/InvalidSnapshotNameException2 cannot be empty4 D(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;)V s6 37 9 contains (Ljava/lang/CharSequence;)Z;< ?= must not contain whitespace? ,A must not contain ','C #E must not contain '#'G charAt (I)CIJ ?K must not start with '_'M java/util/LocaleO ROOT Ljava/util/Locale;QR PS toLowerCase &(Ljava/util/Locale;)Ljava/lang/String;UV ?W equalsY ? ?Z must be lowercase\ validFileName^/ -_ java/lang/StringBuildera b ? *must not contain the following characters d append -(Ljava/lang/String;)Ljava/lang/StringBuilder;fg bh INVALID_FILENAME_CHARS /Lorg/elasticsearch/common/collect/ImmutableSet;jk -l -(Ljava/lang/Object;)Ljava/lang/StringBuilder;fn bo toStringq ? br state (Lorg/elasticsearch/cluster/ClusterState; repositoriesMetaData 9Lorg/elasticsearch/cluster/metadata/RepositoriesMetaData; beginSnapshot ?(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;ZLorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V java/lang/Throwablez 1()Lorg/elasticsearch/cluster/metadata/SnapshotId; ?| 3} metaData ? includeGlobalState? ? 3? builder 7()Lorg/elasticsearch/cluster/metadata/MetaData$Builder;?? :? indices? ? 3? index F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData;?? :? put j(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Z)Lorg/elasticsearch/cluster/metadata/MetaData$Builder;?? 8? build? 8? initializeSnapshot ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/cluster/metadata/MetaData;)V?? ?? isEmpty? ? ?? onResponse? ? ? endSnapshot >(Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;)V?? ? update_snapshot [? ]? ?(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;ZLorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V s? /? logger +Lorg/elasticsearch/common/logging/ESLogger;?? ? failed to create snapshot [{}]? java/lang/Object? )org/elasticsearch/common/logging/ESLogger? warn =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V???? removeSnapshotFromClusterState q(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotInfo;Ljava/lang/Throwable;)V?? ? "org/elasticsearch/ExceptionsHelper? detailedMessage )(Ljava/lang/Throwable;)Ljava/lang/String;?? ?? y ? ?? finalizeSnapshot ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;ILorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/snapshots/Snapshot;?? ?? +[{}] failed to close snapshot in repository? ((Ljava/lang/String;[Ljava/lang/Object;)V???? onFailure (Ljava/lang/Throwable;)V?? ? 5Lorg/elasticsearch/cluster/metadata/MetaData$Builder; -Lorg/elasticsearch/cluster/metadata/MetaData; t2 Ljava/lang/Throwable; t clusterState ;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry; partial Z userCreateSnapshotListener snapshotCreated currentSnapshots W(Ljava/lang/String;[Ljava/lang/String;)Lorg/elasticsearch/common/collect/ImmutableList; *()Lorg/elasticsearch/cluster/ClusterState;t? ?? ? entries? ? 5? _all? size ()I?? ?? get (I)Ljava/lang/Object;?? ?? [Ljava/lang/String;? getSnapshot? ? ?? :()Lorg/elasticsearch/common/collect/ImmutableList$Builder;?? ?? L(Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableList$Builder; ?? =?? ? =? arr$ len$ I entry snapshotMetaData 5Lorg/elasticsearch/cluster/metadata/SnapshotMetaData; uLorg/elasticsearch/common/collect/ImmutableList$Builder<Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;>; 8Lorg/elasticsearch/common/collect/ImmutableList$Builder; currentSnapshotShards `(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/common/collect/ImmutableMap; &(Ljava/lang/Object;)Ljava/lang/Object;? C access$1600 n(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotShards;)Lorg/elasticsearch/common/collect/ImmutableMap; snapshotShards =Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotShards; 9()Lorg/elasticsearch/common/collect/ImmutableMap$Builder;? C indexShardRepository L(Ljava/lang/String;)Lorg/elasticsearch/index/snapshots/IndexShardRepository; ? $org/elasticsearch/snapshots/Snapshot? readSnapshotMetaData ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/cluster/metadata/MetaData; ? 6org/elasticsearch/index/snapshots/IndexShardRepository 5()Lorg/elasticsearch/common/collect/ImmutableOpenMap;?! :" 1org/elasticsearch/common/collect/ImmutableOpenMap$ % 0org/elasticsearch/cluster/metadata/IndexMetaData' getNumberOfShards)? (* %org/elasticsearch/index/shard/ShardId, (Ljava/lang/String;I)V s. -/ shardFailures1 ?2 findShardFailure ?(Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/index/shard/ShardId;)Lorg/elasticsearch/snapshots/SnapshotShardFailure;45 6 Q ? FAILURE BLorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus$Stage;9: O; updateStage E(Lorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus$Stage;)V=> Q? 0org/elasticsearch/snapshots/SnapshotShardFailureA reasonC ? BD failureF) QG ](Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder;?I AJ snapshotStatus ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/index/shard/ShardId;)Lorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus;LM N? z AP shardSnapshotStatus <Lorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus; shardId 'Lorg/elasticsearch/index/shard/ShardId; shardFailure 2Lorg/elasticsearch/snapshots/SnapshotShardFailure; i numberOfShards indexMetaData 2Lorg/elasticsearch/cluster/metadata/IndexMetaData; shardStatusBuilder ?Lorg/elasticsearch/common/collect/ImmutableMap$Builder<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus;>; 7Lorg/elasticsearch/common/collect/ImmutableMap$Builder; 8Lorg/elasticsearch/index/snapshots/IndexShardRepository; &Lorg/elasticsearch/snapshots/Snapshot; getIndexa ? -b? ? Bd getIdf? -gT? Bi dLorg/elasticsearch/common/collect/ImmutableList<Lorg/elasticsearch/snapshots/SnapshotShardFailure;>; clusterChanged 2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V -org/elasticsearch/cluster/ClusterChangedEventn localNodeMasterp ? oq nodesRemoveds ? ot processSnapshotsOnRemovedNodesvm w routingTableChangedy ? oz processStartedShards|m } previousState? o? o? processIndexShardSnapshots 8(Lorg/elasticsearch/cluster/metadata/SnapshotMetaData;)V?? ? 5Z Failed to update snapshot state ? prev curr event /Lorg/elasticsearch/cluster/ClusterChangedEvent; removedNodesCleanupNeeded 2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)Z?? ? nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes;?? ? Yq (update snapshot state after node removal? 2(Lorg/elasticsearch/snapshots/SnapshotsService;Z)V s? -? newMaster waitingShardsStartedOrUnassigned?? ? *update snapshot state after shards started? 1(Lorg/elasticsearch/snapshots/SnapshotsService;)V s? +? processWaitingShards ?(Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/cluster/routing/RoutingTable;)Lorg/elasticsearch/common/collect/ImmutableMap; entrySet 1()Lorg/elasticsearch/common/collect/ImmutableSet;?? C? -org/elasticsearch/common/collect/ImmutableSet? ? ? getValue? ? H? =()Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State;t? E? WAITING ;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State;?? T? getKey? ? H? .org/elasticsearch/cluster/routing/RoutingTable? I(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/IndexRoutingTable;?? ?? id?? -? 3org/elasticsearch/cluster/routing/IndexRoutingTable? shard =(I)Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;?? ?? 8org/elasticsearch/cluster/routing/IndexShardRoutingTable? primaryShard 2()Lorg/elasticsearch/cluster/routing/ShardRouting;?? ?? .org/elasticsearch/cluster/routing/ShardRouting? started? ??? 9starting shard that we were waiting for [{}] on node [{}]? nodeId? ? E? trace???? currentNodeId? ??? E* initializing? ??? relocating? ??? N(Ljava/util/Map$Entry;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder;?? A? 7failing snapshot of shard [{}] on unassigned shard [{}]? FAILED?? T? shard is unassigned? b(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State;Ljava/lang/String;)V s? E? shardRouting :Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable; indexShardRoutingTable 5Lorg/elasticsearch/cluster/routing/IndexRoutingTable; shardStatus ILorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus; shardEntry ?Ljava/util/Map$Entry<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus;>; Ljava/util/Map$Entry; ?Lorg/elasticsearch/common/collect/ImmutableMap<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus;>; routingTable 0Lorg/elasticsearch/cluster/routing/RoutingTable; snapshotChanged shards ?Lorg/elasticsearch/common/collect/ImmutableMap$Builder<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus;>; 3? STARTED? T waitingIndices z 3 C? keySet ? C indexRoutingTableChanged / o getRoutingTable 2()Lorg/elasticsearch/cluster/routing/RoutingTable; unassigned ?? 0Lorg/elasticsearch/cluster/routing/ShardRouting; SUCCESS? T INIT? T nodesDelta 7()Lorg/elasticsearch/cluster/node/DiscoveryNodes$Delta; o removedNodes"