From 8734e7957e6c411e4482e9f289b1425681d23aae Mon Sep 17 00:00:00 2001 From: wuxianrong Date: Mon, 9 Jun 2025 11:08:50 +0800 Subject: [PATCH] Divide the auth command into the command thread pool in pipeling mode --- src/pika_client_conn.cc | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/pika_client_conn.cc b/src/pika_client_conn.cc index d84a78de06..6bef366f0b 100644 --- a/src/pika_client_conn.cc +++ b/src/pika_client_conn.cc @@ -305,6 +305,13 @@ void PikaClientConn::ProcessRedisCmds(const std::vector& bool is_slow_cmd = g_pika_conf->is_slow_cmd(opt); bool is_admin_cmd = g_pika_conf->is_admin_cmd(opt); + + // Special handling for auth command in pipeline + if (is_admin_cmd && opt == kCmdNameAuth && argvs.size() > 1) { + // This is a pipeline with auth as first command + // Force it to use client processor pool + is_admin_cmd = false; + } // we don't intercept pipeline batch (argvs.size() > 1) if (g_pika_conf->rtc_cache_read_enabled() && argvs.size() == 1 && IsInterceptedByRTC(opt) && PIKA_CACHE_NONE != g_pika_conf->cache_mode() && !IsInTxn()) {