From 9aea99cd6e6644ae7ab59f6228414c251709d6e6 Mon Sep 17 00:00:00 2001 From: Anthony Romano Date: Fri, 15 Jan 2016 10:57:33 -0800 Subject: [PATCH] integration: submit keys concurrently with watcher streaming Tests for races between producer and consumer on watcher --- integration/v3_grpc_test.go | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/integration/v3_grpc_test.go b/integration/v3_grpc_test.go index 5c1688060..4ceda1518 100644 --- a/integration/v3_grpc_test.go +++ b/integration/v3_grpc_test.go @@ -369,17 +369,20 @@ func TestV3WatchFromCurrentRevision(t *testing.T) { t.Fatalf("#%d: wAPI.Watch error: %v", i, err) } + go func() { + for _, k := range tt.putKeys { + kvc := pb.NewKVClient(clus.RandConn()) + req := &pb.PutRequest{Key: []byte(k), Value: []byte("bar")} + if _, err := kvc.Put(context.TODO(), req); err != nil { + t.Fatalf("#%d: couldn't put key (%v)", i, err) + } + } + }() + if err := wStream.Send(tt.watchRequest); err != nil { t.Fatalf("#%d: wStream.Send error: %v", i, err) } - kvc := pb.NewKVClient(clus.RandConn()) - for _, k := range tt.putKeys { - if _, err := kvc.Put(context.TODO(), &pb.PutRequest{Key: []byte(k), Value: []byte("bar")}); err != nil { - t.Fatalf("#%d: couldn't put key (%v)", i, err) - } - } - var createdWatchId int64 for j, wresp := range tt.wresps { resp, err := wStream.Recv()