3,org/elasticsearch/river/routing/RiversRouterLorg/elasticsearch/common/component/AbstractLifecycleComponent;Lorg/elasticsearch/cluster/ClusterStateListener;=org/elasticsearch/common/component/AbstractLifecycleComponent.org/elasticsearch/cluster/ClusterStateListenerRiversRouter.java.org/elasticsearch/river/routing/RiversRouter$2 .org/elasticsearch/river/routing/RiversRouter$1 java/util/Map$Entry  java/util/MapEntry5org/elasticsearch/river/routing/RiversRouting$Builder-org/elasticsearch/river/routing/RiversRoutingBuilder+org/elasticsearch/river/RiverIndexName$Conf&org/elasticsearch/river/RiverIndexNameConf9org/elasticsearch/river/cluster/RiverClusterState$Builder1org/elasticsearch/river/cluster/RiverClusterStateRIVER_START_RETRY_INTERVAL)Lorg/elasticsearch/common/unit/TimeValue;RIVER_START_MAX_RETRIESIriverIndexNameLjava/lang/String;client!Lorg/elasticsearch/client/Client;riverClusterService5Lorg/elasticsearch/river/cluster/RiverClusterService; threadPool)Lorg/elasticsearch/threadpool/ThreadPool;(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/client/Client;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/river/cluster/RiverClusterService;Lorg/elasticsearch/threadpool/ThreadPool;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V -0 1 indexName@(Lorg/elasticsearch/common/settings/Settings;)Ljava/lang/String; 34 5 %& 7 )* 9 '( ; +, =(org/elasticsearch/cluster/ClusterService?add3(Lorg/elasticsearch/cluster/ClusterStateListener;)V AB @Cthis.Lorg/elasticsearch/river/routing/RiversRouter;settings,Lorg/elasticsearch/common/settings/Settings;clusterService*Lorg/elasticsearch/cluster/ClusterService;doStart()V(org/elasticsearch/ElasticsearchExceptionMdoStopdoCloseclusterChanged2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V-org/elasticsearch/cluster/ClusterChangedEventSlocalNodeMaster()Z UV TWreroute_rivers_node_changedY2org/elasticsearch/common/util/concurrent/CountDown[(I)V -] \^(Lorg/elasticsearch/river/routing/RiversRouter;Lorg/elasticsearch/cluster/ClusterChangedEvent;Lorg/elasticsearch/common/util/concurrent/CountDown;)V -` a3org/elasticsearch/river/cluster/RiverClusterServicecsubmitStateUpdateTaskR(Ljava/lang/String;Lorg/elasticsearch/river/cluster/RiverClusterStateUpdateTask;)V ef dgevent/Lorg/elasticsearch/cluster/ClusterChangedEvent;source countDown4Lorg/elasticsearch/common/util/concurrent/CountDown;updateRiverClusterState(Ljava/lang/String;Lorg/elasticsearch/river/cluster/RiverClusterState;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/common/util/concurrent/CountDown;)Lorg/elasticsearch/river/cluster/RiverClusterState;8org/elasticsearch/action/NoShardAvailableActionExceptionp5org/elasticsearch/cluster/block/ClusterBlockExceptionr/org/elasticsearch/indices/IndexMissingExceptiont=org/elasticsearch/index/shard/IllegalIndexShardStateExceptionvjava/lang/ExceptionxEorg/elasticsearch/common/util/concurrent/EsRejectedExecutionExceptionz&org/elasticsearch/cluster/ClusterState|metaData/()Lorg/elasticsearch/cluster/metadata/MetaData; ~ }+org/elasticsearch/cluster/metadata/MetaDatahasIndex(Ljava/lang/String;)Z routing1()Lorg/elasticsearch/river/routing/RiversRouting; isEmpty V builder=()Lorg/elasticsearch/river/cluster/RiverClusterState$Builder; statep(Lorg/elasticsearch/river/cluster/RiverClusterState;)Lorg/elasticsearch/river/cluster/RiverClusterState$Builder; 9()Lorg/elasticsearch/river/routing/RiversRouting$Builder; t(Lorg/elasticsearch/river/routing/RiversRouting$Builder;)Lorg/elasticsearch/river/cluster/RiverClusterState$Builder; build5()Lorg/elasticsearch/river/cluster/RiverClusterState; h(Lorg/elasticsearch/river/routing/RiversRouting;)Lorg/elasticsearch/river/routing/RiversRouting$Builder; indexF(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; 0org/elasticsearch/cluster/metadata/IndexMetaDatamappings5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; 1org/elasticsearch/common/collect/ImmutableOpenMapvalues1()Lorg/elasticsearch/common/hppc/ObjectContainer; -org/elasticsearch/common/hppc/ObjectContaineriterator()Ljava/util/Iterator; java/lang/Stringjava/util/IteratorhasNext V next()Ljava/lang/Object; 2org/elasticsearch/common/hppc/cursors/ObjectCursorvalueLjava/lang/Object; 2org/elasticsearch/cluster/metadata/MappingMetaDatatype()Ljava/lang/String;  _default_equals(Ljava/lang/Object;)Z hasRiverByName _metaorg/elasticsearch/client/Client prepareGeth(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/elasticsearch/action/get/GetRequestBuilder; _primary.org/elasticsearch/action/get/GetRequestBuilder setPreferenceD(Ljava/lang/String;)Lorg/elasticsearch/action/get/GetRequestBuilder; get+()Lorg/elasticsearch/action/ActionResponse; (org/elasticsearch/action/get/GetResponseisExists V logger+Lorg/elasticsearch/common/logging/ESLogger; {}/{}/_meta document found.java/lang/Object)org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V getSourceAsMap()Ljava/util/Map;  &(Ljava/lang/Object;)Ljava/lang/Object;  ;org/elasticsearch/common/xcontent/support/XContentMapValues nodeStringValue8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/String;     ,no river type provided for [{}], ignoring...warn  ,org/elasticsearch/river/routing/RiverRouting!org/elasticsearch/river/RiverName'(Ljava/lang/String;Ljava/lang/String;)V - T(Lorg/elasticsearch/river/RiverName;Lorg/elasticsearch/cluster/node/DiscoveryNode;)V - putg(Lorg/elasticsearch/river/routing/RiverRouting;)Lorg/elasticsearch/river/routing/RiversRouting$Builder;   "failed to get/parse _meta for [{}]"=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V $ % lV \'/no river _meta document found after {} attempts)java/lang/Integer+valueOf(I)Ljava/lang/Integer; -. ,//no river _meta document found retrying in {} ms1 ! 3'org/elasticsearch/common/unit/TimeValue5millis()J 78 69java/lang/Long;(J)Ljava/lang/Long; -= <>generic@w(Lorg/elasticsearch/river/routing/RiversRouter;Ljava/lang/String;Lorg/elasticsearch/common/util/concurrent/CountDown;)V -B C'org/elasticsearch/threadpool/ThreadPoolEschedulew(Lorg/elasticsearch/common/unit/TimeValue;Ljava/lang/String;Ljava/lang/Runnable;)Ljava/util/concurrent/ScheduledFuture; GH FI@Couldn't schedule river start retry, node might be shutting downK $ M  riverName%()Lorg/elasticsearch/river/RiverName; PQ Rname T U containsKey W Xremove Z [node0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ]^ _nodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; ab }c,org/elasticsearch/cluster/node/DiscoveryNodeeid g fh-org/elasticsearch/cluster/node/DiscoveryNodesj nodeExists l km%org/elasticsearch/common/collect/Mapso newHashMap()Ljava/util/HashMap; qr ps k/org/elasticsearch/river/cluster/RiverNodeHelperv isRiverNode1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)Z xy wz&org/elasticsearch/common/collect/Lists| newArrayList()Ljava/util/ArrayList; ~ }8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;   java/util/List A  entrySet()Ljava/util/Set;   java/util/Set getKey  T(Lorg/elasticsearch/cluster/node/DiscoveryNode;Lorg/elasticsearch/river/RiverName;)Z x wgetValue  size()I   ZL 1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)V ] 'going to allocate river [{}] on node {}getName   riverType getResponse*Lorg/elasticsearch/action/get/GetResponse;e:Lorg/elasticsearch/action/NoShardAvailableActionException;7Lorg/elasticsearch/cluster/block/ClusterBlockException;1Lorg/elasticsearch/indices/IndexMissingException;?Lorg/elasticsearch/index/shard/IllegalIndexShardStateException;Ljava/lang/Exception; mappingTypecursorjLorg/elasticsearch/common/hppc/cursors/ObjectCursor;4Lorg/elasticsearch/common/hppc/cursors/ObjectCursor;i$Ljava/util/Iterator;exGLorg/elasticsearch/common/util/concurrent/EsRejectedExecutionException;.Lorg/elasticsearch/river/routing/RiverRouting;.Lorg/elasticsearch/cluster/node/DiscoveryNode;l@Ljava/util/List;Ljava/util/List;entryLjava/util/Map$Entry;>;Ljava/util/Map$Entry;smallest smallestSizeitDLjava/util/Iterator; currentState3Lorg/elasticsearch/river/cluster/RiverClusterState;newClusterState(Lorg/elasticsearch/cluster/ClusterState;routingBuilder7Lorg/elasticsearch/river/routing/RiversRouting$Builder;dirtyZ indexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData; metaFound nodesToRiversLjava/util/Map;>;Ljava/util/Map; unassigned access$000e(Lorg/elasticsearch/river/routing/RiversRouter;)Lorg/elasticsearch/river/cluster/RiverClusterService;x0timeValueMillis,(J)Lorg/elasticsearch/common/unit/TimeValue;  6 ConstantValueCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotations Exceptions StackMapTableLocalVariableTypeTable Signature SourceFile InnerClasses! !"#$%&'()*+,-.&*+2*+68*:*,<*>-*D>&EF&GH&'(&IJ&)*&+,MN OPQR%S/KL+ EFWNOL+ EF[NPL+ EF_NQR(+XZM\Y_N*:Z Y*+-bh*(EF(ij k&lmcdf hi'ono-*8 ,,,,:6-*8:6:   :  ̶:  ֙, ٚ*<*8 ۹:  o*Y*8SY S :  *Y*8SYY  !W660: +: &: !: : *# Y S&q(**Y0SO*2Y4:?S*>4A Y*+DJW: *L N,O:  k :  SVY \W6; `3-d `in! \WY S!W6t: -du:  ' f:  {  Wո: O:  [ :  `  W7  `:  :   ` W  W :   : : 6 :X:f S4 6f:  H6      W*Y SSY S+,,*-q*2s*7u*<w*Ay{`#;& w / 4 9 > C |& o Y  Y r o] Y. # I b CF-_  # EFk&lm7:GJP d >o # CF P d ^Wsuv)x+{7|:}GJo|!$'*-/2479<>ACZ]bj *2EHKPow CXl}%)- }\/~BqDsDuDwDy&w{67 **) +}\f[I/*: F>L" ۸4@2