Skip to content

Commit

Permalink
Fix typo in bandwidthFilter_test.go
Browse files Browse the repository at this point in the history
reseting -> resetting
  • Loading branch information
eltociear authored May 23, 2022
1 parent 4a922c4 commit 1ae651a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions agreement/fuzzer/bandwidthFilter_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ func (n *BandwidthFilter) Tick(newClockTime int) bool {
n.downstreamMutex.Lock()
if n.downstreamDataSize < 0 && n.downstreamQueue.Len() == 0 {
if n.debugMessageLevel >= 1 {
fmt.Printf("node: %d, tick: %d, reseting queued downstream capacity %d -> 0\n", n.nodeID, n.currentTick, n.upstreamDataSize)
fmt.Printf("node: %d, tick: %d, resetting queued downstream capacity %d -> 0\n", n.nodeID, n.currentTick, n.upstreamDataSize)
}
n.downstreamDataSize = 0
}
Expand All @@ -179,7 +179,7 @@ func (n *BandwidthFilter) Tick(newClockTime int) bool {
// adjust the upstream size.
if n.upstreamDataSize < 0 && n.upstreamQueue.Len() == 0 {
if n.debugMessageLevel >= 1 {
fmt.Printf("node: %d, tick: %d, reseting queued upstream capacity %d -> 0\n", n.nodeID, n.currentTick, n.upstreamDataSize)
fmt.Printf("node: %d, tick: %d, resetting queued upstream capacity %d -> 0\n", n.nodeID, n.currentTick, n.upstreamDataSize)
}
n.upstreamDataSize = 0
}
Expand Down

0 comments on commit 1ae651a

Please sign in to comment.