Skip to content

Commit

Permalink
reorder raft server shutdown
Browse files Browse the repository at this point in the history
  • Loading branch information
lzydmxy authored and JackyWoo committed Nov 23, 2023
1 parent d98236b commit 86d945a
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions src/Service/KeeperServer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -103,15 +103,18 @@ int32 KeeperServer::getLeader()

void KeeperServer::shutdown()
{
LOG_INFO(log, "Shutting down keeper server.");
state_machine->shutdown();
LOG_INFO(log, "Shutting down raft core.");
if (!launcher.shutdown(settings->raft_settings->shutdown_timeout))
LOG_WARNING(log, "Failed to shutdown raft server in {} seconds", 5);

LOG_INFO(log, "Flush Log store.");
if (state_manager->load_log_store() && !state_manager->load_log_store()->flush())
LOG_WARNING(log, "Log store flush error while server shutdown.");

dynamic_cast<NuRaftFileLogStore &>(*state_manager->load_log_store()).shutdown();

if (!launcher.shutdown(settings->raft_settings->shutdown_timeout))
LOG_WARNING(log, "Failed to shutdown RAFT server in {} seconds", 5);
LOG_INFO(log, "Shutting down state machine.");
state_machine->shutdown();
LOG_INFO(log, "Shut down keeper server done!");
}

Expand Down

0 comments on commit 86d945a

Please sign in to comment.