Skip to content

Commit

Permalink
Merge pull request #1009 from qazwsxedckll/fix-throttle-log
Browse files Browse the repository at this point in the history
fix: throttle debug log
  • Loading branch information
rogeralsing authored Dec 30, 2023
2 parents 742c858 + b84e0e4 commit 1fcdf9e
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion cluster/gossiper.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,9 @@ func newGossiper(cl *Cluster, opts ...Option) (*Gossiper, error) {
}

func (g *Gossiper) GetState(key string) (map[string]*GossipKeyValue, error) {
g.cluster.Logger().Debug(fmt.Sprintf("Gossiper getting state from %s", g.pid))
if g.throttler() == actor.Open {
g.cluster.Logger().Debug(fmt.Sprintf("Gossiper getting state from %s", g.pid))
}

msg := NewGetGossipStateRequest(key)
timeout := g.cluster.Config.TimeoutTime
Expand Down

0 comments on commit 1fcdf9e

Please sign in to comment.