From 68703090337a9fa12e793443d98fb978f3ea233c 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 bcab6c30f..6a1866332 100644
--- a/src/facade/dragonfly_connection.cc
+++ b/src/facade/dragonfly_connection.cc
@@ -309,7 +309,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