gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix collab issue #26

Browse Source 
Former-commit-id: 2392879772a77fc30c856488b9911d194ced827b
This commit is contained in:
John Sully 2021-06-03 04:43:38 +00:00
parent 6fdd8449ff
commit f5a8a97a43
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/rdb.cpp
View File

@ -2797,6 +2797,19 @@ public:
vars.clients_pending_asyncwrite = listCreate(); vars.clients_pending_asyncwrite = listCreate();
serverTL = &vars; serverTL = &vars;
aeSetThreadOwnsLockOverride(true); aeSetThreadOwnsLockOverride(true);
// We will inheret the server thread's affinity mask, clear it as we want to run on a different core.
cpu_set_t *cpuset = CPU_ALLOC(std::thread::hardware_concurrency());
if (cpuset != nullptr) {
size_t size = CPU_ALLOC_SIZE(std::thread::hardware_concurrency());
CPU_ZERO_S(size, cpuset);
for (unsigned i = 0; i < std::thread::hardware_concurrency(); ++i) {
CPU_SET_S(i, size, cpuset);
}
pthread_setaffinity_np(pthread_self(), size, cpuset);
CPU_FREE(cpuset);
}
for (;;) { for (;;) {
std::unique_lock<std::mutex> lock(queue.mutex); std::unique_lock<std::mutex> lock(queue.mutex);
if (listLength(queue.listJobs) == 0 && queue.queuefn.empty()) { if (listLength(queue.listJobs) == 0 && queue.queuefn.empty()) {