Receive: fix issue-7248 with parallel receive_forward (thanos-io#7267)

* Receive: fix issue-7248 by introducing a worker pool Signed-off-by: Yi Jin <[email protected]> * fix unit test bug Signed-off-by: Yi Jin <[email protected]> * fix CLI flags not pass into the receive handler Signed-off-by: Yi Jin <[email protected]> * address comments Signed-off-by: Yi Jin <[email protected]> * init context in constructor Signed-off-by: Yi Jin <[email protected]> --------- Signed-off-by: Yi Jin <[email protected]>
databricks · Aug 22, 2024 · a646c05 · a646c05
1 parent eddbbb3
commit a646c05
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/receive/handler.go b/pkg/receive/handler.go
@@ -1440,7 +1440,8 @@ func (p *peerGroup) closeUnlocked(addr string) error {
 		// was never established.
 		return nil
 	}
-	c.wp.Close()
+
+	p.connections[addr].wp.Close()
 	delete(p.connections, addr)
 	if err := c.cc.Close(); err != nil {
 		return fmt.Errorf("closing connection for %s", addr)