From 51f400ac4a4bbd5ddd88662f1178c4dff67fa74c Mon Sep 17 00:00:00 2001
From: Roman Gershman <roman@dragonflydb.io>
Date: Mon, 17 Mar 2025 15:29:00 +0200
Subject: [PATCH] fix: invalid reference inside GetQueueBackpressure (#4789)

thread_queue_backpressure is a global array of per thread QueueBackpressure
objects. We referenced these objects incorrectly in 1.27.0-2.

Fixes #4770

Signed-off-by: Roman Gershman <roman@dragonflydb.io>
---
 src/facade/dragonfly_connection.cc | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/facade/dragonfly_connection.cc b/src/facade/dragonfly_connection.cc
index e3bad32f2..9f1785f8a 100644
--- a/src/facade/dragonfly_connection.cc
+++ b/src/facade/dragonfly_connection.cc
@@ -313,7 +313,8 @@ QueueBackpressure* thread_queue_backpressure = nullptr;
 
 QueueBackpressure& GetQueueBackpressure() {
   DCHECK(thread_queue_backpressure != nullptr);
-  return *thread_queue_backpressure;
+
+  return thread_queue_backpressure[ProactorBase::me()->GetPoolIndex()];
 }
 
 }  // namespace