Skip to content

Commit

Permalink
fix rto of schedulingqueue add
Browse files Browse the repository at this point in the history
  • Loading branch information
sanposhiho committed Dec 20, 2021
1 parent 7a1494f commit 8c3ed44
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions minisched/queue/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,13 @@ func New() *SchedulingQueue {
}
}

func (s *SchedulingQueue) Add(pod *v1.Pod) error {
func (s *SchedulingQueue) Add(pod *v1.Pod) {
s.lock.L.Lock()
defer s.lock.L.Unlock()

s.activeQ = append(s.activeQ, pod)
s.lock.Signal()
return nil
return
}

func (s *SchedulingQueue) NextPod() *v1.Pod {
Expand Down

0 comments on commit 8c3ed44

Please sign in to comment.