simplify wakeup queue monitor

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{

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)

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)