fix: invalid reference inside GetQueueBackpressure (#4789)

romange · romange · commit 68703090337a · 2025-03-17T19:17:29.000+02:00
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>
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -309,7 +309,8 @@ QueueBackpressure* thread_queue_backpressure = nullptr;`
`309`	`309`
`310`	`310`	`QueueBackpressure& GetQueueBackpressure() {`
`311`	`311`	`DCHECK(thread_queue_backpressure != nullptr);`
`312`		`- return *thread_queue_backpressure;`
	`312`	`+`
	`313`	`+ return thread_queue_backpressure[ProactorBase::me()->GetPoolIndex()];`
`313`	`314`	`}`
`314`	`315`
`315`	`316`	`} // namespace`