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

Addressing PR comments

Browse Source 
Former-commit-id: bdd14ac517fb1921dd6c398ad10346c74324740d
This commit is contained in:
Kajaruban Surendran 2020-12-02 00:27:39 +00:00 committed by John Sully
parent d46ed5d770
commit 8586dfb15c
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/config.cpp
View File

@ -2276,7 +2276,7 @@ static int updateMaxclients(long long val, long long prev, const char **err) {
/* Change the SetSize for the current thread first. If any error, return the error message to the client, /* Change the SetSize for the current thread first. If any error, return the error message to the client,
* otherwise, continue to do the same for other threads */ * otherwise, continue to do the same for other threads */
if ((unsigned int) aeGetSetSize(aeGetCurrentEventLoop()) < if ((unsigned int) aeGetSetSize(aeGetCurrentEventLoop()) <
g_pserver->maxclients + CONFIG_FDSET_INCR) g_pserver->maxclients + CONFIG_FDSET_INCR)
{ {
if (aeResizeSetSize(aeGetCurrentEventLoop(), if (aeResizeSetSize(aeGetCurrentEventLoop(),
g_pserver->maxclients + CONFIG_FDSET_INCR) == AE_ERR) g_pserver->maxclients + CONFIG_FDSET_INCR) == AE_ERR)
@ -2284,13 +2284,12 @@ static int updateMaxclients(long long val, long long prev, const char **err) {
*err = "The event loop API used by Redis is not able to handle the specified number of clients"; *err = "The event loop API used by Redis is not able to handle the specified number of clients";
return 0; return 0;
} }
serverLog(LL_DEBUG,"Successfully changed the setsize for current thread %d", ielFromEventLoop(aeGetCurrentEventLoop())); serverLog(LL_DEBUG,"Successfully changed the setsize for current thread %d", ielFromEventLoop(aeGetCurrentEventLoop()));
} }
for (int iel = 0; iel < cserver.cthreads; ++iel) for (int iel = 0; iel < cserver.cthreads; ++iel)
{ {
if (g_pserver->rgthreadvar[iel].el == aeGetCurrentEventLoop()) if (g_pserver->rgthreadvar[iel].el == aeGetCurrentEventLoop()){
{
continue; continue;
} }
@ -2309,7 +2308,7 @@ static int updateMaxclients(long long val, long long prev, const char **err) {
*err = msg; *err = msg;
return 0; return 0;
} }
serverLog(LL_DEBUG,"Successfully post the request to change the setsize for thread %d", iel); serverLog(LL_DEBUG,"Successfully post the request to change the setsize for thread %d", iel);
} }
} }
} }