This commit is contained in:
Nathan LaFreniere 2015-12-31 12:01:09 -08:00
parent 0d6aff17dc
commit 5707a06507

View File

@ -117,7 +117,7 @@ func main() {
jobChan := make(chan struct{}, maxConcurrent) jobChan := make(chan struct{}, maxConcurrent)
results := make(chan *result, len(jobs)) results := make(chan *result, len(jobs))
fmt.Printf("Synchronizing with bucket \"%s\"", vargs.Bucket) fmt.Printf("Synchronizing with bucket \"%s\"\n", vargs.Bucket)
for _, j := range jobs { for _, j := range jobs {
jobChan <- struct{}{} jobChan <- struct{}{}
go func(j job) { go func(j job) {
@ -138,7 +138,7 @@ func main() {
for _ = range jobs { for _ = range jobs {
r := <-results r := <-results
if r.err != nil { if r.err != nil {
fmt.Printf("ERROR: failed to %s %s to %s: %s\n", r.j.action, r.j.local, r.j.remote, r.err) fmt.Printf("ERROR: failed to %s %s to %s: %+v\n", r.j.action, r.j.local, r.j.remote, r.err)
os.Exit(1) os.Exit(1)
} }
} }