func (engine *DockerTaskEngine) synchronizeState() {
	engine.tasksLock.Lock()
	defer engine.tasksLock.Unlock()
	imageStates := engine.state.AllImageStates()
	if len(imageStates) != 0 {
		engine.imageManager.AddAllImageStates(imageStates)
	}

	tasks := engine.state.AllTasks()
	tasksToStart := engine.filterTasksToStartUnsafe(tasks)
	for _, task := range tasks {
		task.InitializeResources(engine.resourceFields)
	}

	for _, task := range tasksToStart {
		engine.startTask(task)
	}

	engine.saver.Save()
}
func (engine *DockerTaskEngine) synchronizeState() {
	engine.tasksLock.Lock()
	defer engine.tasksLock.Unlock()
	imageStates := engine.state.AllImageStates()
	if len(imageStates) != 0 {
		engine.imageManager.AddAllImageStates(imageStates)
	}

	tasks := engine.state.AllTasks()
	tasksToStart := engine.filterTasksToStartUnsafe(tasks)
	for _, task := range tasks {
		task.InitializeResources(engine.resourceFields)
	}

	for _, task := range tasksToStart {
		engine.startTask(task)
	}

	engine.saver.Save()
}
func ( engine * DockerTaskEngine ) synchronizeState ( ) { engine . tasksLock . Lock ( ) defer engine . tasksLock . Unlock ( ) imageStates := engine . state . AllImageStates ( ) if len ( imageStates ) != 0 { engine . imageManager . AddAllImageStates ( imageStates ) } tasks := engine . state . AllTasks ( ) tasksToStart := engine . filterTasksToStartUnsafe ( tasks ) for _ , task := range tasks { task . InitializeResources ( engine . resourceFields ) } for _ , task := range tasksToStart { engine . startTask ( task ) } engine . saver . Save ( ) }
// synchronizeState explicitly goes through each docker container stored in
// "state" and updates its KnownStatus appropriately, as well as queueing up
// events to push upstream.
synchronizeState explicitly goes through each docker container stored in state and updates its KnownStatus appropriately as well as queueing up events to push upstream .