veyron/services/wsprd: Added more logging to find race condition in
testwriter.
Change-Id: I0ad4f8d057ee28bd99706a1db78f85005da5f5e5
diff --git a/services/wsprd/lib/testwriter/writer.go b/services/wsprd/lib/testwriter/writer.go
index f6d06e2..79b7c76 100644
--- a/services/wsprd/lib/testwriter/writer.go
+++ b/services/wsprd/lib/testwriter/writer.go
@@ -70,14 +70,18 @@
fmt.Println("Found ", w.Stream)
return nil
}
+ fmt.Println("Createing channel")
w.Lock()
w.notifier = make(chan bool, 1)
w.Unlock()
for w.streamLength() < n {
+ fmt.Println("Waiting for notification")
select {
case <-w.notifier:
+ fmt.Println("got notification")
continue
case <-time.After(time.Second):
+ fmt.Println("Timed out")
return fmt.Errorf("timed out")
}
}
