From aba2e9f1f50abc07b3b21c3976d0082f79d2c82b Mon Sep 17 00:00:00 2001 From: Victor Vieux Date: Sat, 3 May 2014 00:11:20 +0000 Subject: [PATCH] move acceptconnections as builtin Docker-DCO-1.1-Signed-off-by: Victor Vieux (github: vieux) Upstream-commit: 937f8f2d813f58480e4bb2c0060353be31b04e10 Component: engine --- components/engine/api/server/server.go | 8 +++----- components/engine/builtins/builtins.go | 5 ++++- components/engine/docker/docker.go | 2 +- 3 files changed, 8 insertions(+), 7 deletions(-) diff --git a/components/engine/api/server/server.go b/components/engine/api/server/server.go index ed1d434064..8fe518f7c6 100644 --- a/components/engine/api/server/server.go +++ b/components/engine/api/server/server.go @@ -1285,10 +1285,6 @@ func ServeApi(job *engine.Job) engine.Status { ) activationLock = make(chan struct{}) - if err := job.Eng.Register("acceptconnections", AcceptConnections); err != nil { - return job.Error(err) - } - for _, protoAddr := range protoAddrs { protoAddrParts := strings.SplitN(protoAddr, "://", 2) if len(protoAddrParts) != 2 { @@ -1315,7 +1311,9 @@ func AcceptConnections(job *engine.Job) engine.Status { go systemd.SdNotify("READY=1") // close the lock so the listeners start accepting connections - close(activationLock) + if activationLock != nil { + close(activationLock) + } return engine.StatusOK } diff --git a/components/engine/builtins/builtins.go b/components/engine/builtins/builtins.go index 572e16252a..3e0041c9d7 100644 --- a/components/engine/builtins/builtins.go +++ b/components/engine/builtins/builtins.go @@ -28,7 +28,10 @@ func Register(eng *engine.Engine) error { // remote: a RESTful api for cross-docker communication func remote(eng *engine.Engine) error { - return eng.Register("serveapi", apiserver.ServeApi) + if err := eng.Register("serveapi", apiserver.ServeApi); err != nil { + return err + } + return eng.Register("acceptconnections", apiserver.AcceptConnections) } // daemon: a default execution and storage backend for Docker on Linux, diff --git a/components/engine/docker/docker.go b/components/engine/docker/docker.go index 1683d7a0e8..ab485d0b63 100644 --- a/components/engine/docker/docker.go +++ b/components/engine/docker/docker.go @@ -185,7 +185,7 @@ func main() { job.Setenv("TlsCa", *flCa) job.Setenv("TlsCert", *flCert) job.Setenv("TlsKey", *flKey) - job.SetenvBool("BuffferRequests", true) + job.SetenvBool("BufferRequests", true) if err := job.Run(); err != nil { log.Fatal(err) }