Skip to content

Commit fb4f765

Browse files
committed
test: fix remote test
1 parent aa04a0d commit fb4f765

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

c_test.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ func TestC_Remote(t *testing.T) {
140140
envEtcdAddrs := strings.Split(addr, ",")
141141
cfg := clientv3.Config{
142142
Endpoints: envEtcdAddrs,
143-
DialTimeout: 2 * time.Second,
143+
DialTimeout: time.Second,
144144
}
145145
if err := put(cfg, key, "name: remote"); err != nil {
146146
t.Fatal(err)
@@ -212,11 +212,10 @@ func put(cfg clientv3.Config, key, val string) error {
212212
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
213213
defer cancel()
214214

215-
for i := 0; i < 2; i++ {
216-
_, err = client.Put(ctx, key, val)
217-
if err != nil {
218-
continue
219-
}
215+
_, err = client.Put(ctx, key, val)
216+
if err != nil {
217+
return err
220218
}
221-
return err
219+
220+
return nil
222221
}

0 commit comments

Comments
 (0)