volcano的代码流程图

1
2
3
4

cmd/sheduler/main.go:46 main       ->  cmd/sheduler/main.go:62 app.Run
cmd/sheduler/main.go:62 app.Run    ->  cmd/app/server.go:106 sched.Run
cmd/app/server.go:106 sched.Run    ->  pkg/scheduler/scheduler.go:64 Run
pkg/scheduler/scheduler.go:64 Run  ->  pkg/scheduler/scheduler.go:69 Run

1
2
3
4
5
6
7
8
9

// Run runs the Scheduler
func (pc *Scheduler) Run(stopCh <-chan struct{}) {
	// 同步cache，缓存节点，pod，job等信息
	go pc.cache.Run(stopCh)
	pc.cache.WaitForCacheSync(stopCh)
	
    //真正的调度核心，意思是没隔pc.schedulePeriod（1秒），就开启一次调度（pc.runOnce）.收到stopCh信     //号才停止
	go wait.Until(pc.runOnce, pc.schedulePeriod, stopCh)
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

func (pc *Scheduler) runOnce() {
	klog.V(4).Infof("Start scheduling ...")
	scheduleStartTime := time.Now()
	defer klog.V(4).Infof("End scheduling ...")
	defer metrics.UpdateE2eDuration(metrics.Duration(scheduleStartTime))
	
    // 导入配置文件
	pc.loadSchedulerConf()
	
    //根据配置文件的plugins(gang,drf等)，已经cache，开启一轮新的 会话
	ssn := framework.OpenSession(pc.cache, pc.plugins)
	defer framework.CloseSession(ssn)
	
    //依次执行配置文件中的指定的actions。现在默认是（enqueue,allocate,backfill）
	for _, action := range pc.actions {
		actionStartTime := time.Now()
		action.Execute(ssn)
		metrics.UpdateActionDuration(action.Name(), metrics.Duration(actionStartTime))
	}
}