Browse Source

integration: sync lapi server after puts in TestLeaseTimeToLive

Linearized read to ensure the keys have committed.
Anthony Romano 8 years ago
parent
commit
755270fa6a
1 changed files with 7 additions and 1 deletions
  1. 7 1
      clientv3/integration/lease_test.go

+ 7 - 1
clientv3/integration/lease_test.go

@@ -482,7 +482,8 @@ func TestLeaseTimeToLive(t *testing.T) {
 	clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 3})
 	defer clus.Terminate(t)
 
-	lapi := clus.RandClient()
+	c := clus.RandClient()
+	lapi := c
 
 	resp, err := lapi.Grant(context.Background(), 10)
 	if err != nil {
@@ -497,6 +498,11 @@ func TestLeaseTimeToLive(t *testing.T) {
 		}
 	}
 
+	// linearized read to ensure Puts propagated to server backing lapi
+	if _, err := c.Get(context.TODO(), "abc"); err != nil {
+		t.Fatal(err)
+	}
+
 	lresp, lerr := lapi.TimeToLive(context.Background(), resp.ID, clientv3.WithAttachedKeys())
 	if lerr != nil {
 		t.Fatal(lerr)