From 25ee03e1654b209042c7a395edc7e6a84462dfec Mon Sep 17 00:00:00 2001 From: Frank Schroeder Date: Thu, 19 Oct 2017 11:17:24 +0200 Subject: [PATCH] ae: add test for resume triggering SyncChanges --- agent/ae/ae_test.go | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-) diff --git a/agent/ae/ae_test.go b/agent/ae/ae_test.go index 500435359..2b61c9a33 100644 --- a/agent/ae/ae_test.go +++ b/agent/ae/ae_test.go @@ -27,7 +27,7 @@ func TestAE_scaleFactor(t *testing.T) { } } -func TestAE_nestedPauseResume(t *testing.T) { +func TestAE_Pause_nestedPauseResume(t *testing.T) { t.Parallel() l := NewStateSyner(nil, 0, nil, nil) if l.Paused() != false { @@ -59,7 +59,21 @@ func TestAE_nestedPauseResume(t *testing.T) { l.Resume() } -func TestAE_ifNotPausedRun(t *testing.T) { +func TestAE_Pause_ResumeTriggersSyncChanges(t *testing.T) { + l := NewStateSyner(nil, 0, nil, nil) + l.Pause() + l.Resume() + select { + case <-l.SyncChanges.Notif(): + // expected + case <-l.SyncFull.Notif(): + t.Fatal("resume triggered SyncFull instead of SyncChanges") + default: + t.Fatal("resume did not trigger SyncFull") + } +} + +func TestAE_Pause_ifNotPausedRun(t *testing.T) { l := NewStateSyner(nil, 0, nil, nil) errCalled := errors.New("f called")