fix off-by-one error in the threshold

libp2p · Jan 23, 2018 · be4a5f4 · be4a5f4
1 parent 6b92f28
commit be4a5f4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/p2p/net/upgrader/threshold.go b/p2p/net/upgrader/threshold.go
@@ -43,7 +43,7 @@ func (t *threshold) Release() {
 // Wait waits for the counter to drop below the threshold
 func (t *threshold) Wait() {
 	t.mu.Lock()
-	for t.count > t.threshold {
+	for t.count >= t.threshold {
 		t.cond.Wait()
 	}
 	t.mu.Unlock()