From 6cd8f6a970e299be4a4a2afd01da5e22886ee2bf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kuba=20Podg=C3=B3rski?= Date: Fri, 15 Jan 2021 13:24:41 +0100 Subject: [PATCH] Less TestMain_Set_Quick parallel tests --- etcd/embed.go | 6 ++++++ server/server_test.go | 3 +-- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/etcd/embed.go b/etcd/embed.go index 0834eeaa0..40e73ef17 100644 --- a/etcd/embed.go +++ b/etcd/embed.go @@ -279,6 +279,9 @@ func (e *Etcd) Started(ctx context.Context) error { } func (e *Etcd) ID() string { + if e.e == nil || e.e.Server == nil { + return "" + } return e.e.Server.ID().String() } @@ -291,6 +294,9 @@ func (e *Etcd) Peers() []*disco.Peer { } func (e *Etcd) IsLeader() bool { + if e.e == nil || e.e.Server == nil { + return false + } return e.e.Server.Leader() == e.e.Server.ID() } diff --git a/server/server_test.go b/server/server_test.go index 23f429dfe..f21059e9c 100644 --- a/server/server_test.go +++ b/server/server_test.go @@ -54,8 +54,7 @@ func TestMain_Set_Quick(t *testing.T) { t.Skip("short") } - for i := 0; i < 100; i++ { - //for i := 0; i < 10; i++ { + for i := 0; i < 10; i++ { t.Run(fmt.Sprint(i), func(t *testing.T) { t.Parallel()