From 246e7eba095888a443dc115be1b032405c32086f Mon Sep 17 00:00:00 2001 From: Linhai Date: Tue, 21 Dec 2021 04:46:39 -0500 Subject: [PATCH] fixing the goroutine in two unit tests --- server/storage/mvcc/kvstore_test.go | 2 ++ server/storage/mvcc/watchable_store_test.go | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/server/storage/mvcc/kvstore_test.go b/server/storage/mvcc/kvstore_test.go index 027430814..99e95ade1 100644 --- a/server/storage/mvcc/kvstore_test.go +++ b/server/storage/mvcc/kvstore_test.go @@ -536,6 +536,8 @@ type hashKVResult struct { func TestHashKVWhenCompacting(t *testing.T) { b, tmpPath := betesting.NewDefaultTmpBackend(t) s := NewStore(zap.NewExample(), b, &lease.FakeLessor{}, StoreConfig{}) + defer s.Close() + defer b.Close() defer os.Remove(tmpPath) rev := 10000 diff --git a/server/storage/mvcc/watchable_store_test.go b/server/storage/mvcc/watchable_store_test.go index c34e7446b..3fc857295 100644 --- a/server/storage/mvcc/watchable_store_test.go +++ b/server/storage/mvcc/watchable_store_test.go @@ -536,7 +536,8 @@ func TestWatchVictims(t *testing.T) { s := newWatchableStore(zap.NewExample(), b, &lease.FakeLessor{}, StoreConfig{}) defer func() { - s.store.Close() + s.Close() + b.Close() os.Remove(tmpPath) chanBufLen, maxWatchersPerSync = oldChanBufLen, oldMaxWatchersPerSync }()