Skip to content

Commit

Permalink
test:重启HA server
Browse files Browse the repository at this point in the history
  • Loading branch information
GongChangYan authored and tugraph committed Dec 20, 2023
1 parent dad9e4f commit 9583bbe
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions ogm/tugraph-db-ogm-test/src/main/java/test/TestBase.java
Original file line number Diff line number Diff line change
Expand Up @@ -338,7 +338,7 @@ public static void haClientTest() throws Exception {
log.info("-------------------------starting follower-------------------------");
driver.close();
Thread.sleep(1000 * 7);
executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start");
executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart");
Thread.sleep(1000 * 13);
driver = startHaClient("29092");
Thread.sleep(1000 * 7);
Expand All @@ -361,7 +361,7 @@ public static void haClientTest() throws Exception {
log.info("-------------------------starting leader-------------------------");
driver.close();
Thread.sleep(1000 * 7);
executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start");
executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart");
Thread.sleep(1000 * 13);
driver = startHaClient("29093");
Thread.sleep(1000 * 7);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,7 @@ public static void haClientTest() throws Exception {
log.info("-------------------------starting follower-------------------------");
client.logout();
Thread.sleep(1000 * 7);
executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start");
executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart");
Thread.sleep(1000 * 13);
client = startHaClient("29092");
Thread.sleep(1000 * 7);
Expand All @@ -348,7 +348,7 @@ public static void haClientTest() throws Exception {
log.info("-------------------------starting leader-------------------------");
client.logout();
Thread.sleep(1000 * 7);
executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start");
executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart");
Thread.sleep(1000 * 13);
client = startHaClient("29093");
Thread.sleep(1000 * 7);
Expand Down

0 comments on commit 9583bbe

Please sign in to comment.