testing semaphore

integration/v3_grpc_test.go

@@ -695,6 +695,7 @@ func TestV3WatchMultipleEventsFromUnsynced(t *testing.T) {
 			Kv:   &storagepb.KeyValue{Key: []byte("foo1"), Value: []byte("bar"), CreateRevision: 3, ModRevision: 5, Version: 2},
 		},
 	}
+	st := time.Now()
 	lastEvents := []*storagepb.Event{}
 	for len(lastEvents) < 2 {
 		resp, err := wStream.Recv()
@@ -705,13 +706,16 @@ func TestV3WatchMultipleEventsFromUnsynced(t *testing.T) {
 			continue
 		}
 		lastEvents = append(lastEvents, resp.Events...)
+		fmt.Println("lastEvents adding:", resp.Events)
 	}
+	fmt.Println("lastEvents loop done... took", time.Since(st))
 	sort.Sort(eventsSortByKey(lastEvents))
 
 	if !reflect.DeepEqual(lastEvents, lastWevents) {
 		t.Errorf("lastEvents got = %+v, want = %+v", lastEvents, lastWevents)
 	}
 
+	fmt.Println("wait...")
 	rok, nr := WaitResponse(wStream, 1*time.Second)
 	if !rok {
 		t.Errorf("unexpected pb.WatchResponse is received %+v", nr)