From a50c707050ee8c63a472936bb75347a72f008f1a Mon Sep 17 00:00:00 2001 From: Anthony Romano Date: Thu, 25 Aug 2016 19:25:35 -0700 Subject: [PATCH] clientv3/integration: wait for two request timeouts in txn tests Read only txns and Get may timeout once if the leader is lost. --- clientv3/integration/txn_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/clientv3/integration/txn_test.go b/clientv3/integration/txn_test.go index 3969c8bf0..1b6b808ec 100644 --- a/clientv3/integration/txn_test.go +++ b/clientv3/integration/txn_test.go @@ -73,6 +73,7 @@ func TestTxnWriteFail(t *testing.T) { }() go func() { + defer close(getc) select { case <-time.After(5 * time.Second): t.Fatalf("timed out waiting for txn fail") @@ -86,11 +87,10 @@ func TestTxnWriteFail(t *testing.T) { if len(gresp.Kvs) != 0 { t.Fatalf("expected no keys, got %v", gresp.Kvs) } - close(getc) }() select { - case <-time.After(5 * time.Second): + case <-time.After(2 * clus.Members[1].ServerConfig.ReqTimeout()): t.Fatalf("timed out waiting for get") case <-getc: } @@ -125,7 +125,7 @@ func TestTxnReadRetry(t *testing.T) { clus.Members[0].Restart(t) select { case <-donec: - case <-time.After(5 * time.Second): + case <-time.After(2 * clus.Members[1].ServerConfig.ReqTimeout()): t.Fatalf("waited too long") } }