refactor: inline
This commit is contained in:
1 parent
6f65512471
commit
639cde0f67
1 file changed
+1
-5
+1
-5
@@ -119,10 +119,6 @@ func (proxy *Proxy) attachWithRetry(id string) {
|
||||
proxy.attachJobs[id] = j
|
||||
}
|
||||
|
||||
func (proxy *Proxy) attachAndKillOnFailure(id string) {
|
||||
proxy.notifyWaiters(id, proxy.attach(id, true))
|
||||
}
|
||||
|
||||
func (j attachJob) Stop() {
|
||||
j.timer.Stop()
|
||||
}
|
||||
@@ -388,7 +384,7 @@ func (proxy *Proxy) listen(protoAndAddr string) (net.Listener, string, error) {
|
||||
|
||||
// weavedocker.ContainerObserver interface
|
||||
func (proxy *Proxy) ContainerStarted(ident string) {
|
||||
proxy.attachAndKillOnFailure(ident)
|
||||
proxy.notifyWaiters(ident, proxy.attach(ident, true))
|
||||
}
|
||||
|
||||
func containerShouldAttach(container *docker.Container) bool {
|
||||
|
||||
Reference in new issue
Block a user