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

Merge pull request #15425 from fuweid/update-TestLeasingDeleteRangeContendTxn

Browse Source 
tests/integration: Update TestLeasingDeleteRangeContendTxn
This commit is contained in:
Benjamin Wang 2023-03-08 08:08:38 +08:00 committed by GitHub
commit aaa8bfee99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/integration/clientv3/lease/leasing_test.go
View File

@ -16,7 +16,6 @@ package lease_test
import (
"context"
"errors"
"fmt"
"math/rand"
"reflect"
@ -1286,12 +1285,13 @@ func testLeasingDeleteRangeContend(t *testing.T, op clientv3.Op) {
donec := make(chan struct{})
go func(t *testing.T) {
defer close(donec)
for i := 0; (i < maxKey) && (ctx.Err() == nil); i++ {
key := fmt.Sprintf("key/%d", i%8)
if _, err = putkv.Put(ctx, key, "123"); err != nil {
if !errors.Is(err, context.Canceled) {
t.Errorf("fail putting key %s, err was: %v", key, err)
}
for i := 0; ctx.Err() == nil; i++ {
key := fmt.Sprintf("key/%d", i%maxKey)
if _, err := putkv.Put(context.TODO(), key, "123"); err != nil {
t.Errorf("fail putting key %s: %v", key, err)
}
if _, err = putkv.Get(context.TODO(), key); err != nil {
t.Errorf("fail getting key %s: %v", key, err)
}
}
}(t)