donot free protected client in freeClientsInAsyncFreeQueue

related #7234
This commit is contained in:
zhaozhao.zz 2020-06-02 11:34:28 +08:00
parent 52e56bf70d
commit ad6b71352d

View File

@ -1239,14 +1239,20 @@ void freeClientAsync(client *c) {
/* Free the clietns marked as CLOSE_ASAP, return the number of clients /* Free the clietns marked as CLOSE_ASAP, return the number of clients
* freed. */ * freed. */
int freeClientsInAsyncFreeQueue(void) { int freeClientsInAsyncFreeQueue(void) {
int freed = listLength(server.clients_to_close); int freed = 0;
while (listLength(server.clients_to_close)) { listIter li;
listNode *ln = listFirst(server.clients_to_close); listNode *ln;
listRewind(server.clients_to_close,&li);
while ((ln = listNext(&li)) != NULL) {
client *c = listNodeValue(ln); client *c = listNodeValue(ln);
if (c->flags & CLIENT_PROTECTED) continue;
c->flags &= ~CLIENT_CLOSE_ASAP; c->flags &= ~CLIENT_CLOSE_ASAP;
freeClient(c); freeClient(c);
listDelNode(server.clients_to_close,ln); listDelNode(server.clients_to_close,ln);
freed++;
} }
return freed; return freed;
} }