Passing HostConfig for /start endpoint

Signed-off-by: Nishant Totla <nishanttotla@gmail.com>
This commit is contained in:
Nishant Totla 2016-02-17 01:27:33 -08:00
parent 3dff7aa96a
commit 6ff0d29c9d
6 changed files with 29 additions and 9 deletions

View File

@ -740,6 +740,26 @@ func getEvents(c *context, w http.ResponseWriter, r *http.Request) {
// POST /containers/{name:.*}/start // POST /containers/{name:.*}/start
func postContainersStart(c *context, w http.ResponseWriter, r *http.Request) { func postContainersStart(c *context, w http.ResponseWriter, r *http.Request) {
hostConfig := &dockerclient.HostConfig{
MemorySwappiness: -1,
}
buf, err := ioutil.ReadAll(r.Body)
if err != nil {
httpError(w, err.Error(), http.StatusBadRequest)
return
}
r.Body.Close()
if len(buf) == 0 {
hostConfig = nil
} else {
if err := json.Unmarshal(buf, hostConfig); err != nil {
httpError(w, err.Error(), http.StatusBadRequest)
return
}
}
name := mux.Vars(r)["name"] name := mux.Vars(r)["name"]
container := c.cluster.Container(name) container := c.cluster.Container(name)
if container == nil { if container == nil {
@ -747,7 +767,7 @@ func postContainersStart(c *context, w http.ResponseWriter, r *http.Request) {
return return
} }
if err := c.cluster.StartContainer(container); err != nil { if err := c.cluster.StartContainer(container, hostConfig); err != nil {
httpError(w, err.Error(), http.StatusInternalServerError) httpError(w, err.Error(), http.StatusInternalServerError)
return return
} }

View File

@ -27,7 +27,7 @@ type Cluster interface {
Containers() Containers Containers() Containers
// Start a container // Start a container
StartContainer(container *Container) error StartContainer(container *Container, hostConfig *dockerclient.HostConfig) error
// Return container the matching `IDOrName` // Return container the matching `IDOrName`
// TODO: remove this method from the interface as we can use // TODO: remove this method from the interface as we can use

View File

@ -1038,8 +1038,8 @@ func (e *Engine) cleanupContainers() {
} }
// StartContainer starts a container // StartContainer starts a container
func (e *Engine) StartContainer(id string) error { func (e *Engine) StartContainer(id string, hostConfig *dockerclient.HostConfig) error {
err := e.client.StartContainer(id, nil) err := e.client.StartContainer(id, hostConfig)
e.CheckConnectionErr(err) e.CheckConnectionErr(err)
if err != nil { if err != nil {
return err return err

View File

@ -179,10 +179,10 @@ func (c *Cluster) UnregisterEventHandler(h cluster.EventHandler) {
} }
// StartContainer starts a container // StartContainer starts a container
func (c *Cluster) StartContainer(container *cluster.Container) error { func (c *Cluster) StartContainer(container *cluster.Container, hostConfig *dockerclient.HostConfig) error {
// if the container was started less than a second ago in detach mode, do not start it // if the container was started less than a second ago in detach mode, do not start it
if time.Now().Unix()-container.Created > 1 || container.Config.Labels[cluster.SwarmLabelNamespace+".mesos.detach"] != "true" { if time.Now().Unix()-container.Created > 1 || container.Config.Labels[cluster.SwarmLabelNamespace+".mesos.detach"] != "true" {
return container.Engine.StartContainer(container.Id) return container.Engine.StartContainer(container.Id, hostConfig)
} }
return nil return nil
} }

View File

@ -125,8 +125,8 @@ func (c *Cluster) generateUniqueID() string {
} }
// StartContainer starts a container // StartContainer starts a container
func (c *Cluster) StartContainer(container *cluster.Container) error { func (c *Cluster) StartContainer(container *cluster.Container, hostConfig *dockerclient.HostConfig) error {
return container.Engine.StartContainer(container.Id) return container.Engine.StartContainer(container.Id, hostConfig)
} }
// CreateContainer aka schedule a brand new container into the cluster. // CreateContainer aka schedule a brand new container into the cluster.

View File

@ -83,7 +83,7 @@ func (w *Watchdog) rescheduleContainers(e *Engine) {
log.Infof("Rescheduled container %s from %s to %s as %s", c.Id, c.Engine.Name, newContainer.Engine.Name, newContainer.Id) log.Infof("Rescheduled container %s from %s to %s as %s", c.Id, c.Engine.Name, newContainer.Engine.Name, newContainer.Id)
if c.Info.State.Running { if c.Info.State.Running {
log.Infof("Container %s was running, starting container %s", c.Id, newContainer.Id) log.Infof("Container %s was running, starting container %s", c.Id, newContainer.Id)
if err := w.cluster.StartContainer(newContainer); err != nil { if err := w.cluster.StartContainer(newContainer, nil); err != nil {
log.Errorf("Failed to start rescheduled container %s", newContainer.Id) log.Errorf("Failed to start rescheduled container %s", newContainer.Id)
} }
} }