mooncake-track
/
Mooncake
0
0
Fork 12
Code Issues Pull Requests 13 Actions Packages Projects Releases Wiki Activity

[CCF Archive] Store object type eviction policy submission #3

Closed
kancel wants to merge 382 commits from kancel:ccf-archive-pr2746 into main
pull from: kancel:ccf-archive-pr2746
merge into: mooncake-track:main
Conversation 0 Commits 382 Files Changed 654 +5 -1
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 6b98d67d8a - Show all commits

6
mooncake-transfer-engine/src/transport/ascend_transport/ascend_direct_transport/utils.cpp
View File

@ -17,7 +17,9 @@
#include <cstring>
#include <memory>
#include <pthread.h>
#include <random>
#include <string>
#include <glog/logging.h>
#if __has_include(<jsoncpp/json/json.h>)
@ -163,7 +165,9 @@ bool IsRoceModeEnabled() {
// AscendThreadPool implementation
AscendThreadPool::AscendThreadPool(size_t num_threads) : running_(true) {
for (size_t i = 0; i < num_threads; ++i) {
workers_.emplace_back([this] {
workers_.emplace_back([this, i] {
auto thread_name = "ascend-wk-" + std::to_string(i);
pthread_setname_np(pthread_self(), thread_name.c_str());
while (true) {
std::function<void()> task;
{