fix: invalid reference inside GetQueueBackpressure

romange · romange · commit 28287ac176ea · 2025-03-17T14:33:03.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
@@ -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

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