Skip to content

Commit

Permalink
task engine: mv container engine -> docker client
Browse files Browse the repository at this point in the history
Renamed docker_container_engine.go to docker_client.go
  • Loading branch information
aaithal committed Jan 23, 2018
1 parent 2e4364f commit 0b7ec2f
Show file tree
Hide file tree
Showing 4 changed files with 3 additions and 3 deletions.
File renamed without changes.
File renamed without changes.
2 changes: 1 addition & 1 deletion agent/engine/docker_task_engine.go
Original file line number Diff line number Diff line change
Expand Up @@ -339,7 +339,7 @@ func (engine *DockerTaskEngine) synchronizeContainerStatus(container *api.Docker
func (engine *DockerTaskEngine) CheckTaskState(task *api.Task) {
taskContainers, ok := engine.state.ContainerMapByArn(task.Arn)
if !ok {
seelog.Warnf("Task engine [%s]: could not check task state for task; no task in state", task.Arn)
seelog.Warnf("Task engine [%s]: could not check task state; no task in state", task.Arn)
return
}
for _, container := range task.Containers {
Expand Down
4 changes: 2 additions & 2 deletions agent/engine/task_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -424,10 +424,10 @@ func (mtask *managedTask) emitContainerEvent(task *api.Task, cont *api.Container
}

seelog.Infof("Managed task [%s]: sending container change event [%s]: %s",
mtask.Arn, container.Name, event.String())
mtask.Arn, cont.Name, event.String())
mtask.stateChangeEvents <- event
seelog.Infof("Managed task [%s]: sent container change event [%s]: %s",
mtask.Arn, container.Name, event.String())
mtask.Arn, cont.Name, event.String())
}

func (mtask *managedTask) isContainerFound(container *api.Container) bool {
Expand Down

0 comments on commit 0b7ec2f

Please sign in to comment.