scheduling.go 956 B

12345678910111213141516171819202122232425262728293031323334353637
  1. package balance
  2. import (
  3. "github.com/seaweedfs/seaweedfs/weed/worker/tasks/base"
  4. "github.com/seaweedfs/seaweedfs/weed/worker/types"
  5. )
  6. // Scheduling implements the scheduling logic for balance tasks
  7. func Scheduling(task *types.TaskInput, runningTasks []*types.TaskInput, availableWorkers []*types.WorkerData, config base.TaskConfig) bool {
  8. balanceConfig := config.(*Config)
  9. // Count running balance tasks
  10. runningBalanceCount := 0
  11. for _, runningTask := range runningTasks {
  12. if runningTask.Type == types.TaskTypeBalance {
  13. runningBalanceCount++
  14. }
  15. }
  16. // Check concurrency limit
  17. if runningBalanceCount >= balanceConfig.MaxConcurrent {
  18. return false
  19. }
  20. // Check if we have available workers
  21. availableWorkerCount := 0
  22. for _, worker := range availableWorkers {
  23. for _, capability := range worker.Capabilities {
  24. if capability == types.TaskTypeBalance {
  25. availableWorkerCount++
  26. break
  27. }
  28. }
  29. }
  30. return availableWorkerCount > 0
  31. }