Browse code

Move "wait" to daemon/wait.go

This is part of an effort to break apart the deprecated server/ package

Docker-DCO-1.1-Signed-off-by: Solomon Hykes <solomon@docker.com> (github: shykes)

Solomon Hykes authored on 2014/08/01 05:50:46
Showing 4 changed files
... ...
@@ -135,6 +135,9 @@ func (daemon *Daemon) Install(eng *engine.Engine) error {
135 135
 	if err := eng.Register("restart", daemon.ContainerRestart); err != nil {
136 136
 		return err
137 137
 	}
138
+	if err := eng.Register("wait", daemon.ContainerWait); err != nil {
139
+		return err
140
+	}
138 141
 	return nil
139 142
 }
140 143
 
141 144
new file mode 100644
... ...
@@ -0,0 +1,20 @@
0
+package daemon
1
+
2
+import (
3
+	"time"
4
+
5
+	"github.com/docker/docker/engine"
6
+)
7
+
8
+func (daemon *Daemon) ContainerWait(job *engine.Job) engine.Status {
9
+	if len(job.Args) != 1 {
10
+		return job.Errorf("Usage: %s", job.Name)
11
+	}
12
+	name := job.Args[0]
13
+	if container := daemon.Get(name); container != nil {
14
+		status, _ := container.State.WaitStop(-1 * time.Second)
15
+		job.Printf("%d\n", status)
16
+		return engine.StatusOK
17
+	}
18
+	return job.Errorf("%s: no such container: %s", job.Name, name)
19
+}
... ...
@@ -386,19 +386,6 @@ func (srv *Server) ContainerDestroy(job *engine.Job) engine.Status {
386 386
 	return engine.StatusOK
387 387
 }
388 388
 
389
-func (srv *Server) ContainerWait(job *engine.Job) engine.Status {
390
-	if len(job.Args) != 1 {
391
-		return job.Errorf("Usage: %s", job.Name)
392
-	}
393
-	name := job.Args[0]
394
-	if container := srv.daemon.Get(name); container != nil {
395
-		status, _ := container.State.WaitStop(-1 * time.Second)
396
-		job.Printf("%d\n", status)
397
-		return engine.StatusOK
398
-	}
399
-	return job.Errorf("%s: no such container: %s", job.Name, name)
400
-}
401
-
402 389
 func (srv *Server) ContainerResize(job *engine.Job) engine.Status {
403 390
 	if len(job.Args) != 3 {
404 391
 		return job.Errorf("Not enough arguments. Usage: %s CONTAINER HEIGHT WIDTH\n", job.Name)
... ...
@@ -86,7 +86,6 @@ func InitServer(job *engine.Job) engine.Status {
86 86
 	job.Eng.Hack_SetGlobalVar("httpapi.daemon", srv.daemon)
87 87
 
88 88
 	for name, handler := range map[string]engine.Handler{
89
-		"wait":             srv.ContainerWait,
90 89
 		"tag":              srv.ImageTag, // FIXME merge with "image_tag"
91 90
 		"resize":           srv.ContainerResize,
92 91
 		"commit":           srv.ContainerCommit,