Skip to content

Commit

Permalink
revert channels for testing (todo revert commit)
Browse files Browse the repository at this point in the history
  • Loading branch information
zoemccormick committed Apr 17, 2024
1 parent d0cd516 commit 8f51ed1
Showing 1 changed file with 0 additions and 16 deletions.
16 changes: 0 additions & 16 deletions nsqd/channel.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 8f51ed1

Please sign in to comment.