test semaphore #2

integration/v3_grpc_test.go

@@ -16,6 +16,7 @@ package integration
 import (
 	"bytes"
 	"fmt"
+	"log"
 	"math/rand"
 	"reflect"
 	"sort"
@@ -706,16 +707,16 @@ func TestV3WatchMultipleEventsFromUnsynced(t *testing.T) {
 			continue
 		}
 		lastEvents = append(lastEvents, resp.Events...)
-		fmt.Println("lastEvents adding:", resp.Events)
+		log.Println("lastEvents adding:", resp.Events)
 	}
-	fmt.Println("lastEvents loop done... took", time.Since(st))
+	log.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...")
+	log.Println("wait...")
 	rok, nr := WaitResponse(wStream, 1*time.Second)
 	if !rok {
 		t.Errorf("unexpected pb.WatchResponse is received %+v", nr)