From 8f51ed1d0cf6ad0ad1f128717a9671b02f07a437 Mon Sep 17 00:00:00 2001 From: zoemccormick Date: Wed, 17 Apr 2024 17:20:01 +0000 Subject: [PATCH] revert channels for testing (todo revert commit) --- nsqd/channel.go | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/nsqd/channel.go b/nsqd/channel.go index 3f2e0a56e..1d281ef3c 100644 --- a/nsqd/channel.go +++ b/nsqd/channel.go @@ -325,22 +325,6 @@ func (c *Channel) put(m *Message) error { // Because messagePump is intermittently unavailable while writing a msg to a client // we continue to have higher priority channels in the select loop, this means at each // attempt a higher priority channel can still win - select { - case c.zoneLocalMsgChan <- m: - atomic.AddUint64(&c.zoneLocalMsgCount, 1) - return nil - default: - } - select { - case c.zoneLocalMsgChan <- m: - atomic.AddUint64(&c.zoneLocalMsgCount, 1) - return nil - case c.regionLocalMsgChan <- m: - atomic.AddUint64(&c.regionLocalMsgCount, 1) - return nil - default: - } - select { case c.zoneLocalMsgChan <- m: atomic.AddUint64(&c.zoneLocalMsgCount, 1)