Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

integration_test: fix the flaky test TestV3AuthRestartMembe

Browse Source 
Signed-off-by: Benjamin Wang <wachao@vmware.com>
This commit is contained in:
Benjamin Wang 2022-09-14 14:30:37 +08:00
parent bbcbcd9db4
commit e8ad008067
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/framework/integration/cluster.go
View File

@ -1097,11 +1097,15 @@ func (m *Member) WaitStarted(t testutil.TB) {
}
func WaitClientV3(t testutil.TB, kv clientv3.KV) {
WaitClientV3WithKey(t, kv, "/")
}
func WaitClientV3WithKey(t testutil.TB, kv clientv3.KV, key string) {
timeout := time.Now().Add(RequestTimeout)
var err error
for time.Now().Before(timeout) {
ctx, cancel := context.WithTimeout(context.Background(), RequestTimeout)
_, err = kv.Get(ctx, "/")
_, err = kv.Get(ctx, key)
cancel()
if err == nil {
return

1
tests/integration/v3_auth_test.go
View File

@ -492,6 +492,7 @@ func TestV3AuthRestartMember(t *testing.T) {
clus.Members[0].Stop(t)
err = clus.Members[0].Restart(t)
testutil.AssertNil(t, err)
integration.WaitClientV3WithKey(t, c2.KV, "foo")
// nothing has changed, but it fails without refreshing cache after restart
_, err = c2.Put(context.TODO(), "foo", "bar2")