[fix] rate limit pause

ctripcorp · Jul 16, 2024 · 3391f0c · 3391f0c
1 parent 6e0c87b
commit 3391f0c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/ctrip_swap_evict.c b/src/ctrip_swap_evict.c
@@ -477,7 +477,7 @@ void swapRateLimitPause(swapRatelimitCtx *rlctx, client *c) {
     if (server.swap_ratelimit_policy != SWAP_RATELIMIT_POLICY_PAUSE) return;
 
     if (swapRatelimitNeeded(rlctx,server.swap_ratelimit_policy,&pause_ms) &&
-            pause_ms > 0 && c->rate_limit_event_id != -1) {
+            pause_ms > 0 && c->rate_limit_event_id == -1) {
         protectClient(c);
         c->rate_limit_event_id = aeCreateTimeEvent(server.el,pause_ms,unprotectClientdProc,c,NULL);
         server.stat_swap_ratelimit_client_pause_count++;