From d90ef35967cd8f66b1f98b19396a2c1c17313366 Mon Sep 17 00:00:00 2001 From: chronolaw Date: Mon, 6 Jan 2025 13:12:09 +0800 Subject: [PATCH] fix(clustering/rpc): fix mistake of stop timer --- kong/clustering/services/sync/init.lua | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kong/clustering/services/sync/init.lua b/kong/clustering/services/sync/init.lua index ba431420d0da..73864a17f092 100644 --- a/kong/clustering/services/sync/init.lua +++ b/kong/clustering/services/sync/init.lua @@ -76,7 +76,7 @@ function _M:init_worker() -- cp does not support kong.sync.v2 if not has_sync_v2 then ngx.log(ngx.WARN, "rpc sync is disabled in CP.") - assert(self.rpc:sync_every(EACH_SYNC_DELAY), true) -- stop timer + assert(self.rpc:sync_every(EACH_SYNC_DELAY, true)) -- stop timer return end @@ -89,7 +89,7 @@ function _M:init_worker() -- if rpc is down we will also stop to sync worker_events.register(function() - assert(self.rpc:sync_every(EACH_SYNC_DELAY), true) -- stop timer + assert(self.rpc:sync_every(EACH_SYNC_DELAY, true)) -- stop timer end, "clustering:jsonrpc", "disconnected") end