Browse code

Remove job from pause/unpause

Signed-off-by: Antonio Murdaca <me@runcom.ninja>

Antonio Murdaca authored on 2015/04/10 05:50:48
Showing 3 changed files
... ...
@@ -214,11 +214,21 @@ func postContainersPause(eng *engine.Engine, version version.Version, w http.Res
214 214
 	if err := parseForm(r); err != nil {
215 215
 		return err
216 216
 	}
217
-	job := eng.Job("pause", vars["name"])
218
-	if err := job.Run(); err != nil {
217
+
218
+	name := vars["name"]
219
+	d := getDaemon(eng)
220
+	cont, err := d.Get(name)
221
+	if err != nil {
219 222
 		return err
220 223
 	}
224
+
225
+	if err := cont.Pause(); err != nil {
226
+		return fmt.Errorf("Cannot pause container %s: %s", name, err)
227
+	}
228
+	cont.LogEvent("pause")
229
+
221 230
 	w.WriteHeader(http.StatusNoContent)
231
+
222 232
 	return nil
223 233
 }
224 234
 
... ...
@@ -229,11 +239,21 @@ func postContainersUnpause(eng *engine.Engine, version version.Version, w http.R
229 229
 	if err := parseForm(r); err != nil {
230 230
 		return err
231 231
 	}
232
-	job := eng.Job("unpause", vars["name"])
233
-	if err := job.Run(); err != nil {
232
+
233
+	name := vars["name"]
234
+	d := getDaemon(eng)
235
+	cont, err := d.Get(name)
236
+	if err != nil {
234 237
 		return err
235 238
 	}
239
+
240
+	if err := cont.Unpause(); err != nil {
241
+		return fmt.Errorf("Cannot unpause container %s: %s", name, err)
242
+	}
243
+	cont.LogEvent("unpause")
244
+
236 245
 	w.WriteHeader(http.StatusNoContent)
246
+
237 247
 	return nil
238 248
 }
239 249
 
... ...
@@ -125,13 +125,11 @@ func (daemon *Daemon) Install(eng *engine.Engine) error {
125 125
 		"info":              daemon.CmdInfo,
126 126
 		"kill":              daemon.ContainerKill,
127 127
 		"logs":              daemon.ContainerLogs,
128
-		"pause":             daemon.ContainerPause,
129 128
 		"resize":            daemon.ContainerResize,
130 129
 		"restart":           daemon.ContainerRestart,
131 130
 		"start":             daemon.ContainerStart,
132 131
 		"stop":              daemon.ContainerStop,
133 132
 		"top":               daemon.ContainerTop,
134
-		"unpause":           daemon.ContainerUnpause,
135 133
 		"wait":              daemon.ContainerWait,
136 134
 		"execCreate":        daemon.ContainerExecCreate,
137 135
 		"execStart":         daemon.ContainerExecStart,
138 136
deleted file mode 100644
... ...
@@ -1,39 +0,0 @@
1
-package daemon
2
-
3
-import (
4
-	"fmt"
5
-
6
-	"github.com/docker/docker/engine"
7
-)
8
-
9
-func (daemon *Daemon) ContainerPause(job *engine.Job) error {
10
-	if len(job.Args) != 1 {
11
-		return fmt.Errorf("Usage: %s CONTAINER", job.Name)
12
-	}
13
-	name := job.Args[0]
14
-	container, err := daemon.Get(name)
15
-	if err != nil {
16
-		return err
17
-	}
18
-	if err := container.Pause(); err != nil {
19
-		return fmt.Errorf("Cannot pause container %s: %s", name, err)
20
-	}
21
-	container.LogEvent("pause")
22
-	return nil
23
-}
24
-
25
-func (daemon *Daemon) ContainerUnpause(job *engine.Job) error {
26
-	if n := len(job.Args); n < 1 || n > 2 {
27
-		return fmt.Errorf("Usage: %s CONTAINER", job.Name)
28
-	}
29
-	name := job.Args[0]
30
-	container, err := daemon.Get(name)
31
-	if err != nil {
32
-		return err
33
-	}
34
-	if err := container.Unpause(); err != nil {
35
-		return fmt.Errorf("Cannot unpause container %s: %s", name, err)
36
-	}
37
-	container.LogEvent("unpause")
38
-	return nil
39
-}