summaryrefslogtreecommitdiff
path: root/main.go
diff options
context:
space:
mode:
authorDimitri Sokolyuk <demon@dim13.org>2017-04-02 15:41:52 +0200
committerDimitri Sokolyuk <demon@dim13.org>2017-04-02 15:41:52 +0200
commit936e13ba9225e271911bf097e9f918c80f1d361d (patch)
tree9f947e8f63a949c5f28dd1204a7c2e2b49c9d52f /main.go
parent1a550cbf5a29f514d0db64884630f6a390871ec6 (diff)
Add report channelHEADmaster
Diffstat (limited to 'main.go')
-rw-r--r--main.go11
1 files changed, 10 insertions, 1 deletions
diff --git a/main.go b/main.go
index c955fde..08646a7 100644
--- a/main.go
+++ b/main.go
@@ -2,6 +2,7 @@ package main
import (
"flag"
+ "fmt"
"sync"
"time"
)
@@ -15,6 +16,7 @@ func main() {
flag.Parse()
forks := NewForks(len(names))
+ reports := make(chan string)
wg := sync.WaitGroup{}
for i, name := range names {
@@ -26,11 +28,18 @@ func main() {
Rounds: *rounds,
MaxDelay: *maxDelay,
TimeOut: *timeOut,
+ Report: reports,
}
go func() {
p.Dine()
wg.Done()
}()
}
- wg.Wait()
+ go func() {
+ wg.Wait()
+ close(reports)
+ }()
+ for v := range reports {
+ fmt.Println(v)
+ }
}