Skip to content

Commit

Permalink
addressed PR comment
Browse files Browse the repository at this point in the history
  • Loading branch information
ortuman committed Jan 7, 2022
1 parent 21a4374 commit 7e18983
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions kv/memberlist/memberlist_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -968,11 +968,7 @@ func (m *KV) NotifyMsg(msg []byte) {

ch := m.getKeyWorkerChannel(kvPair.Key)
select {
case ch <- valueUpdate{
value: kvPair.Value,
codec: codec,
messageSize: len(msg),
}:
case ch <- valueUpdate{value: kvPair.Value, codec: codec, messageSize: len(msg)}:
default:
m.numberOfDroppedMessages.Inc()
level.Warn(m.logger).Log("msg", "notify queue full, dropping message", "key", kvPair.Key)
Expand Down

0 comments on commit 7e18983

Please sign in to comment.