From 0d8437f4ab58d1bf436b3f277ed580ba1be3246d Mon Sep 17 00:00:00 2001 From: Lang Martin Date: Wed, 17 Jul 2019 15:57:10 -0400 Subject: [PATCH] blocked_evals_test disable calls Flush --- nomad/blocked_evals_test.go | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) diff --git a/nomad/blocked_evals_test.go b/nomad/blocked_evals_test.go index 1403a0d2238f..f5c2961f8bfe 100644 --- a/nomad/blocked_evals_test.go +++ b/nomad/blocked_evals_test.go @@ -644,3 +644,30 @@ func TestBlockedEvals_SystemUntrack(t *testing.T) { require.Equal(t, 0, bs.TotalEscaped) require.Equal(t, 0, bs.TotalQuotaLimit) } + +func TestBlockedEvals_SystemDisableFlush(t *testing.T) { + t.Parallel() + blocked, _ := testBlockedEvals(t) + + // Create a blocked evals and add it to the blocked tracker. + e := mock.Eval() + e.Type = structs.JobTypeSystem + e.NodeID = "foo" + blocked.Block(e) + + // Verify block did track + bs := blocked.Stats() + require.Equal(t, 1, bs.TotalBlocked) + require.Equal(t, 0, bs.TotalEscaped) + require.Equal(t, 0, bs.TotalQuotaLimit) + + // Disable empties + blocked.SetEnabled(false) + bs = blocked.Stats() + require.Equal(t, 0, bs.TotalBlocked) + require.Equal(t, 0, bs.TotalEscaped) + require.Equal(t, 0, bs.TotalQuotaLimit) + require.Empty(t, blocked.system.evals) + require.Empty(t, blocked.system.byJob) + require.Empty(t, blocked.system.byNode) +}