From 8b4c4df8b35f69100a34dbcdfcb98e63492396c5 Mon Sep 17 00:00:00 2001 From: Alex Dadgar Date: Thu, 19 Oct 2017 17:13:27 -0700 Subject: [PATCH] lax timing --- nomad/heartbeat_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/nomad/heartbeat_test.go b/nomad/heartbeat_test.go index 4f5105ad8..24d8283fd 100644 --- a/nomad/heartbeat_test.go +++ b/nomad/heartbeat_test.go @@ -88,7 +88,7 @@ func TestResetHeartbeatTimerLocked_Renew(t *testing.T) { testutil.WaitForLeader(t, s1.RPC) s1.heartbeatTimersLock.Lock() - s1.resetHeartbeatTimerLocked("foo", 5*time.Millisecond) + s1.resetHeartbeatTimerLocked("foo", 30*time.Millisecond) s1.heartbeatTimersLock.Unlock() if _, ok := s1.heartbeatTimers["foo"]; !ok { @@ -99,23 +99,23 @@ func TestResetHeartbeatTimerLocked_Renew(t *testing.T) { // Renew the heartbeat s1.heartbeatTimersLock.Lock() - s1.resetHeartbeatTimerLocked("foo", 5*time.Millisecond) + s1.resetHeartbeatTimerLocked("foo", 30*time.Millisecond) s1.heartbeatTimersLock.Unlock() renew := time.Now() // Watch for invalidation - for time.Now().Sub(renew) < time.Duration(testutil.TestMultiplier()*20)*time.Millisecond { + for time.Now().Sub(renew) < time.Duration(testutil.TestMultiplier()*100)*time.Millisecond { s1.heartbeatTimersLock.Lock() _, ok := s1.heartbeatTimers["foo"] s1.heartbeatTimersLock.Unlock() if !ok { end := time.Now() - if diff := end.Sub(renew); diff < 5*time.Millisecond { + if diff := end.Sub(renew); diff < 30*time.Millisecond { t.Fatalf("early invalidate %v", diff) } return } - time.Sleep(time.Millisecond) + time.Sleep(2 * time.Millisecond) } t.Fatalf("should have expired") }