diff --git a/agent/engine/common_integ_test.go b/agent/engine/common_integ_test.go index 3d9c4c4343a..9dd5ce08d96 100644 --- a/agent/engine/common_integ_test.go +++ b/agent/engine/common_integ_test.go @@ -225,7 +225,7 @@ func skipIntegTestIfApplicable(t *testing.T) { } } -// Values in host resources from getTestHoustResources() should be looked at and CPU/Memory assigned +// Values in host resources from getTestHostResources() should be looked at and CPU/Memory assigned // accordingly func createTestContainerWithImageAndName(image string, name string) *apicontainer.Container { return &apicontainer.Container{ diff --git a/agent/engine/docker_task_engine.go b/agent/engine/docker_task_engine.go index d33d45f9b6e..a6eda849aac 100644 --- a/agent/engine/docker_task_engine.go +++ b/agent/engine/docker_task_engine.go @@ -323,7 +323,7 @@ func (engine *DockerTaskEngine) Init(ctx context.Context) error { return nil } -// Always wakes up when at least on even arrives on buffered channel monitorQueuedTaskEvent +// Always wakes up when at least one event arrives on buffered channel monitorQueuedTaskEvent // but does not block if monitorQueuedTasks is already processing queued tasks func (engine *DockerTaskEngine) wakeUpTaskQueueMonitor() { select { @@ -914,7 +914,7 @@ func (engine *DockerTaskEngine) emitTaskEvent(task *apitask.Task, reason string) resourcesToRelease := task.ToHostResources() err := engine.hostResourceManager.release(task.Arn, resourcesToRelease) if err != nil { - logger.Critical("Failed to release resources after tast stopped", logger.Fields{field.TaskARN: task.Arn}) + logger.Critical("Failed to release resources after test stopped", logger.Fields{field.TaskARN: task.Arn}) } } event, err := api.NewTaskStateChangeEvent(task, reason) diff --git a/agent/engine/task_manager_test.go b/agent/engine/task_manager_test.go index 9a918a6e76b..e002a9af373 100644 --- a/agent/engine/task_manager_test.go +++ b/agent/engine/task_manager_test.go @@ -2184,7 +2184,7 @@ func TestTaskWaitForHostResources(t *testing.T) { hostResourceManager := NewHostResourceManager(getTestHostResources()) taskEngine := &DockerTaskEngine{ managedTasks: make(map[string]*managedTask), - monitorQueuedTaskEvent: make(chan struct{}), + monitorQueuedTaskEvent: make(chan struct{}, 1), hostResourceManager: &hostResourceManager, } go taskEngine.monitorQueuedTasks(ctx)