1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
package main
import (
"fmt"
"net/http"
"strconv"
"github.com/gorilla/mux"
)
var apiInternal = []Command{
internalReadyCmd,
internalShutdownCmd,
internalContainerOnStartCmd,
internalContainerOnStopCmd,
}
func internalReady(d *Daemon, r *http.Request) Response {
if !d.SetupMode {
return InternalError(fmt.Errorf("The server isn't currently in setup mode"))
}
err := d.Ready()
if err != nil {
return InternalError(err)
}
d.SetupMode = false
return EmptySyncResponse
}
func internalWaitReady(d *Daemon, r *http.Request) Response {
<-d.readyChan
return EmptySyncResponse
}
func internalShutdown(d *Daemon, r *http.Request) Response {
d.shutdownChan <- true
return EmptySyncResponse
}
func internalContainerOnStart(d *Daemon, r *http.Request) Response {
id, err := strconv.Atoi(mux.Vars(r)["id"])
if err != nil {
return SmartError(err)
}
c, err := containerLoadById(d, id)
if err != nil {
return SmartError(err)
}
err = c.OnStart()
if err != nil {
return SmartError(err)
}
return EmptySyncResponse
}
func internalContainerOnStop(d *Daemon, r *http.Request) Response {
id, err := strconv.Atoi(mux.Vars(r)["id"])
if err != nil {
return SmartError(err)
}
target := r.FormValue("target")
if target == "" {
target = "unknown"
}
c, err := containerLoadById(d, id)
if err != nil {
return SmartError(err)
}
err = c.OnStop(target)
if err != nil {
return SmartError(err)
}
return EmptySyncResponse
}
var internalShutdownCmd = Command{name: "shutdown", put: internalShutdown}
var internalReadyCmd = Command{name: "ready", put: internalReady, get: internalWaitReady}
var internalContainerOnStartCmd = Command{name: "containers/{id}/onstart", get: internalContainerOnStart}
var internalContainerOnStopCmd = Command{name: "containers/{id}/onstop", get: internalContainerOnStop}
|