Skip to content

Commit

Permalink
Internal: fixed typo in NodeService s/disovery/discovery
Browse files Browse the repository at this point in the history
  • Loading branch information
javanna committed Aug 6, 2014
1 parent feb3839 commit b73b37a
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions src/main/java/org/elasticsearch/node/service/NodeService.java
Expand Up @@ -56,7 +56,7 @@ public class NodeService extends AbstractComponent {

private final Version version;

private final Discovery disovery;
private final Discovery discovery;

@Inject
public NodeService(Settings settings, ThreadPool threadPool, MonitorService monitorService, Discovery discovery,
Expand All @@ -67,7 +67,7 @@ public NodeService(Settings settings, ThreadPool threadPool, MonitorService moni
this.monitorService = monitorService;
this.transportService = transportService;
this.indicesService = indicesService;
this.disovery = discovery;
this.discovery = discovery;
discovery.setNodeService(this);
this.version = version;
this.pluginService = pluginService;
Expand Down Expand Up @@ -104,7 +104,7 @@ public ImmutableMap<String, String> attributes() {
}

public NodeInfo info() {
return new NodeInfo(version, Build.CURRENT, disovery.localNode(), serviceAttributes,
return new NodeInfo(version, Build.CURRENT, discovery.localNode(), serviceAttributes,
settings,
monitorService.osService().info(),
monitorService.processService().info(),
Expand All @@ -119,7 +119,7 @@ public NodeInfo info() {

public NodeInfo info(boolean settings, boolean os, boolean process, boolean jvm, boolean threadPool,
boolean network, boolean transport, boolean http, boolean plugin) {
return new NodeInfo(version, Build.CURRENT, disovery.localNode(), serviceAttributes,
return new NodeInfo(version, Build.CURRENT, discovery.localNode(), serviceAttributes,
settings ? this.settings : null,
os ? monitorService.osService().info() : null,
process ? monitorService.processService().info() : null,
Expand All @@ -135,7 +135,7 @@ public NodeInfo info(boolean settings, boolean os, boolean process, boolean jvm,
public NodeStats stats() {
// for indices stats we want to include previous allocated shards stats as well (it will
// only be applied to the sensible ones to use, like refresh/merge/flush/indexing stats)
return new NodeStats(disovery.localNode(), System.currentTimeMillis(),
return new NodeStats(discovery.localNode(), System.currentTimeMillis(),
indicesService.stats(true),
monitorService.osService().stats(),
monitorService.processService().stats(),
Expand All @@ -153,7 +153,7 @@ public NodeStats stats(CommonStatsFlags indices, boolean os, boolean process, bo
boolean fs, boolean transport, boolean http, boolean circuitBreaker) {
// for indices stats we want to include previous allocated shards stats as well (it will
// only be applied to the sensible ones to use, like refresh/merge/flush/indexing stats)
return new NodeStats(disovery.localNode(), System.currentTimeMillis(),
return new NodeStats(discovery.localNode(), System.currentTimeMillis(),
indices.anySet() ? indicesService.stats(true, indices) : null,
os ? monitorService.osService().stats() : null,
process ? monitorService.processService().stats() : null,
Expand Down

0 comments on commit b73b37a

Please sign in to comment.