Internal: fixed typo in NodeService s/disovery/discovery

This commit is contained in:
javanna 2014-08-06 13:30:03 +02:00 committed by Luca Cavanna
parent feb3839f0f
commit b73b37a8f0
1 changed files with 6 additions and 6 deletions

View File

@ -56,7 +56,7 @@ public class NodeService extends AbstractComponent {
private final Version version; private final Version version;
private final Discovery disovery; private final Discovery discovery;
@Inject @Inject
public NodeService(Settings settings, ThreadPool threadPool, MonitorService monitorService, Discovery discovery, public NodeService(Settings settings, ThreadPool threadPool, MonitorService monitorService, Discovery discovery,
@ -67,7 +67,7 @@ public class NodeService extends AbstractComponent {
this.monitorService = monitorService; this.monitorService = monitorService;
this.transportService = transportService; this.transportService = transportService;
this.indicesService = indicesService; this.indicesService = indicesService;
this.disovery = discovery; this.discovery = discovery;
discovery.setNodeService(this); discovery.setNodeService(this);
this.version = version; this.version = version;
this.pluginService = pluginService; this.pluginService = pluginService;
@ -104,7 +104,7 @@ public class NodeService extends AbstractComponent {
} }
public NodeInfo info() { public NodeInfo info() {
return new NodeInfo(version, Build.CURRENT, disovery.localNode(), serviceAttributes, return new NodeInfo(version, Build.CURRENT, discovery.localNode(), serviceAttributes,
settings, settings,
monitorService.osService().info(), monitorService.osService().info(),
monitorService.processService().info(), monitorService.processService().info(),
@ -119,7 +119,7 @@ public class NodeService extends AbstractComponent {
public NodeInfo info(boolean settings, boolean os, boolean process, boolean jvm, boolean threadPool, public NodeInfo info(boolean settings, boolean os, boolean process, boolean jvm, boolean threadPool,
boolean network, boolean transport, boolean http, boolean plugin) { 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, settings ? this.settings : null,
os ? monitorService.osService().info() : null, os ? monitorService.osService().info() : null,
process ? monitorService.processService().info() : null, process ? monitorService.processService().info() : null,
@ -135,7 +135,7 @@ public class NodeService extends AbstractComponent {
public NodeStats stats() { public NodeStats stats() {
// for indices stats we want to include previous allocated shards stats as well (it will // 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) // 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), indicesService.stats(true),
monitorService.osService().stats(), monitorService.osService().stats(),
monitorService.processService().stats(), monitorService.processService().stats(),
@ -153,7 +153,7 @@ public class NodeService extends AbstractComponent {
boolean fs, boolean transport, boolean http, boolean circuitBreaker) { boolean fs, boolean transport, boolean http, boolean circuitBreaker) {
// for indices stats we want to include previous allocated shards stats as well (it will // 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) // 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, indices.anySet() ? indicesService.stats(true, indices) : null,
os ? monitorService.osService().stats() : null, os ? monitorService.osService().stats() : null,
process ? monitorService.processService().stats() : null, process ? monitorService.processService().stats() : null,