github/weave-scope
1
0
Fork 0
mirror of https://github.com/weaveworks/scope.git synced 2026-07-28 01:31:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Review feedback

Browse Source
This commit is contained in:
Tom Wilkie
2015-12-07 11:38:00 +00:00
parent 563a6e06ba
commit cb8ae536de
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
xfer/app_client.go
View File

@@ -102,8 +102,8 @@ func (c *appClient) doWithBackoff(msg string, f func() (bool, error)) {
backoff := initialBackoff
for {
again, err := f()
if !again {
done, err := f()
if done {
return
}
if err == nil {
@@ -170,7 +170,7 @@ func (c *appClient) ControlConnection(handler ControlHandler) {
log.Printf("Control connection to %s starting", c.target)
defer log.Printf("Control connection to %s exiting", c.target)
c.doWithBackoff("controls", func() (bool, error) {
return true, c.controlConnection(handler)
return false, c.controlConnection(handler)
})
}()
}
@@ -203,9 +203,9 @@ func (c *appClient) startPublishing() {
c.doWithBackoff("publish", func() (bool, error) {
r := <-c.readers
if r == nil {
return false, nil
return true, nil
}
return true, c.publish(r)
return false, c.publish(r)
})
}()
}