1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.model.content;
import com.yahoo.config.model.api.ModelContext;
import com.yahoo.metrics.MetricsmanagerConfig;
import com.yahoo.vespa.config.content.LoadTypeConfig;
import com.yahoo.vespa.config.content.core.StorCommunicationmanagerConfig;
import com.yahoo.vespa.config.content.core.StorServerConfig;
import com.yahoo.vespa.config.content.core.StorStatusConfig;
import com.yahoo.config.model.producer.AbstractConfigProducer;
import com.yahoo.vespa.model.AbstractService;
import com.yahoo.vespa.model.PortAllocBridge;
import com.yahoo.vespa.model.application.validation.RestartConfigs;
/**
* Common class for config producers for storage and distributor nodes.
*
* TODO: Author
*/
@RestartConfigs({StorCommunicationmanagerConfig.class, StorStatusConfig.class,
StorServerConfig.class, LoadTypeConfig.class, MetricsmanagerConfig.class})
public abstract class ContentNode extends AbstractService
implements StorCommunicationmanagerConfig.Producer, StorStatusConfig.Producer, StorServerConfig.Producer {
private final int distributionKey;
private final String rootDirectory;
private final boolean skipCommunicationManagerThread;
private final boolean skipMbusRequestThread;
private final boolean skipMbusReplyThread;
public ContentNode(ModelContext.FeatureFlags featureFlags, AbstractConfigProducer<?> parent, String clusterName, String rootDirectory, int distributionKey) {
super(parent, "" + distributionKey);
this.distributionKey = distributionKey;
this.skipCommunicationManagerThread = featureFlags.skipCommunicationManagerThread();
this.skipMbusRequestThread = featureFlags.skipMbusRequestThread();
this.skipMbusReplyThread = featureFlags.skipMbusReplyThread();
this.rootDirectory = rootDirectory;
initialize();
setProp("clustertype", "content");
setProp("clustername", clusterName);
setProp("index", distributionKey);
}
public int getDistributionKey() {
return distributionKey;
}
@Override
public void getConfig(StorServerConfig.Builder builder) {
builder.root_folder(rootDirectory);
builder.node_index(distributionKey);
}
private void initialize() {
portsMeta.on(0).tag("messaging");
portsMeta.on(1).tag("rpc").tag("status");
portsMeta.on(2).tag("http").tag("status").tag("state");
}
@Override
public int getPortCount() { return 3; }
@Override
public void allocatePorts(int start, PortAllocBridge from) {
if (start == 0) {
from.allocatePort("messaging");
from.allocatePort("rpc");
from.allocatePort("http");
} else {
from.wantPort(start++, "messaging");
from.wantPort(start++, "rpc");
from.wantPort(start++, "http");
}
}
@Override
public void getConfig(StorCommunicationmanagerConfig.Builder builder) {
builder.mbusport(getRelativePort(0));
builder.rpcport(getRelativePort(1));
builder.skip_thread(skipCommunicationManagerThread);
builder.mbus.skip_request_thread(skipMbusRequestThread);
builder.mbus.skip_reply_thread(skipMbusReplyThread);
}
@Override
public void getConfig(StorStatusConfig.Builder builder) {
builder.httpport(getRelativePort(2));
}
@Override
public int getHealthPort() {
return getRelativePort(2);
}
}
|