Skip to content

Commit

Permalink
chore: improve
Browse files Browse the repository at this point in the history
  • Loading branch information
zyxxoo committed Feb 28, 2023
1 parent 5f17594 commit ac55871
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ public void serverStarted(Id serverId, NodeRole serverRole) {
serverId, serverRole, this.name);
this.serverInfoManager().initServerInfo(serverId, serverRole);

initRoleStateWorker(serverId);
this.initRoleStateWorker(serverId);

// TODO: check necessary?
LOG.info("Check olap property-key tables for graph '{}'", this.name);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -637,23 +637,23 @@ public static synchronized CoreOptions instance() {

public static final ConfigOption<Integer> RANDOM_TIMEOUT_MILLISECOND =
new ConfigOption<>(
"server.role.random.timeout",
"server.role.random_timeout",
"The role state machine random timeout millisecond time",
rangeInt(0, Integer.MAX_VALUE),
400
);

public static final ConfigOption<Integer> HEARTBEAT_INTERVAL_SECOUND =
new ConfigOption<>(
"server.role.heartbeat.interval",
"server.role.heartbeat_interval",
"The role state machine heartbeat interval second time",
rangeInt(0, Integer.MAX_VALUE),
1
);

public static final ConfigOption<Integer> EXCEEDS_WORKER_COUNT =
new ConfigOption<>(
"server.role.worker.count",
"server.role.worker_count",
"Check the number of times that the master node does not initiate " +
"the heartbeat threshold",
rangeInt(0, Integer.MAX_VALUE),
Expand All @@ -662,7 +662,7 @@ public static synchronized CoreOptions instance() {

public static final ConfigOption<Integer> BASE_TIMEOUT_MILLISECOND =
new ConfigOption<>(
"server.role.base.timeout",
"server.role.base_timeout",
"The role state machine candidate state base timeout time",
rangeInt(0, Integer.MAX_VALUE),
100
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,9 +43,9 @@ public class StandardRoleTypeDataAdapter implements RoleTypeDataAdapter {
private final HugeGraphParams graphParams;
private final Schema schema;

public StandardRoleTypeDataAdapter(HugeGraphParams graphParams) {
this.graphParams = graphParams;
this.schema = new Schema(graphParams);
public StandardRoleTypeDataAdapter(HugeGraphParams graph) {
this.graphParams = graph;
this.schema = new Schema(graph);
this.schema.initSchemaIfNeeded();
}

Expand Down

0 comments on commit ac55871

Please sign in to comment.