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

Revert "Debug sleep should apply to all threads"

Browse Source 
This reverts commit b8cc7e2b9c9223de33c1d6513decb80261998461 [formerly 41b678814b2c2ff93935b57e630028aaf2e9ae62].


Former-commit-id: 3ae75c2d2bd952d0a075b9ba257a08f962fe0739
This commit is contained in:
John Sully 2019-11-17 15:39:47 -05:00
parent baffeff5c7
commit a27c1c9f0a
1 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/debug.cpp
View File

@ -595,19 +595,9 @@ NULL
double dtime = strtod(szFromObj(c->argv[2]),NULL); double dtime = strtod(szFromObj(c->argv[2]),NULL);
long long utime = dtime*1000000; long long utime = dtime*1000000;
struct timespec tv; struct timespec tv;
tv.tv_sec = utime / 1000000; tv.tv_sec = utime / 1000000;
tv.tv_nsec = (utime % 1000000) * 1000; tv.tv_nsec = (utime % 1000000) * 1000;
// Ensure all threads sleep
for (int iel = 0; iel < cserver.cthreads; ++iel)
{
if (iel == ielFromEventLoop(serverTL->el))
continue; // we will sleep ourselves below
aePostFunction(g_pserver->rgthreadvar[iel].el, [tv]{
nanosleep(&tv, NULL);
});
}
nanosleep(&tv, NULL); nanosleep(&tv, NULL);
addReply(c,shared.ok); addReply(c,shared.ok);
} else if (!strcasecmp(szFromObj(c->argv[1]),"set-active-expire") && } else if (!strcasecmp(szFromObj(c->argv[1]),"set-active-expire") &&