Method putTask

controller/pool.go:59–68

func (this *TaskPool) PutTasks(items map[string]cache.Item) error { if len(this.tasks) != 0 { this.clean() } for _, item := range items { task, _ := item.Object.(*types.AlarmTask) for { err := this.putTask(task) if err == nil { break } if err == ErrTaskPoolFull { expireT

(task *types.AlarmTask)

// }

func (tp *TaskPool) putTask(task *types.AlarmTask) error {
	select {
	case tp.tasks <- task:
		lg.Info("put new task into task pool, taskid:%s strategy:%s hostname:%s ip:%s",
			task.ID, task.Strategy.Name, task.Host.Hostname, task.Host.IP)
		return nil
	default:
		return ErrTaskPoolFull
	}
}

func (tp *TaskPool) getTasks(batchSize int) []*types.AlarmTask {
	tasks := make([]*types.AlarmTask, 0)