honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Inline ShardStateAction#innerShardFailed method

This commit is contained in:
Jason Tedor 2016-01-04 10:44:41 -05:00
parent a70f76f763
commit 1a131cf917
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java
View File

@ -83,16 +83,12 @@ public class ShardStateAction extends AbstractComponent {
shardFailed(clusterState, shardRouting, indexUUID, message, failure, null, listener); shardFailed(clusterState, shardRouting, indexUUID, message, failure, null, listener);
} }
public void shardFailed(final ClusterState clusterState, final ShardRouting shardRouting, final String indexUUID, final String message, @Nullable final Throwable failure, TimeValue timeout, Listener listener) {
innerShardFailed(clusterState, shardRouting, indexUUID, message, failure, timeout, listener);
}
public void resendShardFailed(final ClusterState clusterState, final ShardRouting shardRouting, final String indexUUID, final String message, @Nullable final Throwable failure, Listener listener) { public void resendShardFailed(final ClusterState clusterState, final ShardRouting shardRouting, final String indexUUID, final String message, @Nullable final Throwable failure, Listener listener) {
logger.trace("re-sending failed shard [{}], index UUID [{}], reason [{}]", failure, shardRouting, indexUUID, message); logger.trace("re-sending failed shard [{}], index UUID [{}], reason [{}]", failure, shardRouting, indexUUID, message);
shardFailed(clusterState, shardRouting, indexUUID, message, failure, listener); shardFailed(clusterState, shardRouting, indexUUID, message, failure, listener);
} }
private void innerShardFailed(final ClusterState clusterState, final ShardRouting shardRouting, final String indexUUID, final String message, final Throwable failure, TimeValue timeout, Listener listener) { public void shardFailed(final ClusterState clusterState, final ShardRouting shardRouting, final String indexUUID, final String message, @Nullable final Throwable failure, TimeValue timeout, Listener listener) {
DiscoveryNode masterNode = clusterState.nodes().masterNode(); DiscoveryNode masterNode = clusterState.nodes().masterNode();
if (masterNode == null) { if (masterNode == null) {
logger.warn("no master known to fail shard [{}]", shardRouting); logger.warn("no master known to fail shard [{}]", shardRouting);