mirror of
https://github.com/rclone/rclone.git
synced 2025-12-31 15:43:53 +00:00
pacer: attempt to fix occasional "beginSleep didn't fire" test failures
This commit is contained in:
@@ -212,7 +212,7 @@ func TestBeginCall(t *testing.T) {
|
|||||||
connTime := time.Now()
|
connTime := time.Now()
|
||||||
p.connTokens <- struct{}{}
|
p.connTokens <- struct{}{}
|
||||||
time.Sleep(1 * time.Millisecond)
|
time.Sleep(1 * time.Millisecond)
|
||||||
paceTime := waitForPace(p, 10*time.Millisecond)
|
paceTime := waitForPace(p, 1000*time.Millisecond)
|
||||||
if paceTime.IsZero() {
|
if paceTime.IsZero() {
|
||||||
t.Errorf("beginSleep didn't fire")
|
t.Errorf("beginSleep didn't fire")
|
||||||
} else if paceTime.Sub(startTime) < 0 {
|
} else if paceTime.Sub(startTime) < 0 {
|
||||||
@@ -232,7 +232,7 @@ func TestBeginCallZeroConnections(t *testing.T) {
|
|||||||
startTime := time.Now()
|
startTime := time.Now()
|
||||||
p.pacer <- struct{}{}
|
p.pacer <- struct{}{}
|
||||||
time.Sleep(1 * time.Millisecond)
|
time.Sleep(1 * time.Millisecond)
|
||||||
paceTime := waitForPace(p, 10*time.Millisecond)
|
paceTime := waitForPace(p, 1000*time.Millisecond)
|
||||||
if paceTime.IsZero() {
|
if paceTime.IsZero() {
|
||||||
t.Errorf("beginSleep didn't fire")
|
t.Errorf("beginSleep didn't fire")
|
||||||
} else if paceTime.Sub(startTime) < 0 {
|
} else if paceTime.Sub(startTime) < 0 {
|
||||||
|
|||||||
Reference in New Issue
Block a user