Skip to content

Commit

Permalink
[native] Fix exchange HTTP executors shutdown order
Browse files Browse the repository at this point in the history
  • Loading branch information
Yuhta authored and amitkdutta committed Jul 24, 2024
1 parent 9d55bda commit ca11b2f
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions presto-native-execution/presto_cpp/main/PrestoServer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -615,20 +615,20 @@ void PrestoServer::run() {
httpSrvIOExecutor_->join();
}

PRESTO_SHUTDOWN_LOG(INFO)
<< "Joining Exchange Http IO executor '"
<< exchangeHttpIoExecutor_->getName()
<< "': threads: " << exchangeHttpIoExecutor_->numActiveThreads() << "/"
<< exchangeHttpIoExecutor_->numThreads();
exchangeHttpIoExecutor_->join();

PRESTO_SHUTDOWN_LOG(INFO)
<< "Joining Exchange Http CPU executor '"
<< exchangeHttpCpuExecutor_->getName()
<< "': threads: " << exchangeHttpCpuExecutor_->numActiveThreads() << "/"
<< exchangeHttpCpuExecutor_->numThreads();
exchangeHttpCpuExecutor_->join();

PRESTO_SHUTDOWN_LOG(INFO)
<< "Joining Exchange Http IO executor '"
<< exchangeHttpIoExecutor_->getName()
<< "': threads: " << exchangeHttpIoExecutor_->numActiveThreads() << "/"
<< exchangeHttpIoExecutor_->numThreads();
exchangeHttpIoExecutor_->join();

PRESTO_SHUTDOWN_LOG(INFO) << "Done joining our executors.";

auto globalCPUKeepAliveExec = folly::getGlobalCPUExecutor();
Expand Down

0 comments on commit ca11b2f

Please sign in to comment.