Skip to content

Commit

Permalink
Address the comment
Browse files Browse the repository at this point in the history
Signed-off-by: JmPotato <[email protected]>
  • Loading branch information
JmPotato committed Sep 14, 2023
1 parent 7d441d5 commit 0dfaa08
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pkg/mcs/scheduling/server/cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -258,7 +258,7 @@ func (c *Cluster) waitSchedulersInitialized() {
ticker := time.NewTicker(time.Millisecond * 100)
defer ticker.Stop()
for {
if c.coordinator.CheckSchedulersInitialized() {
if c.coordinator.AreSchedulersInitialized() {
return
}
select {
Expand Down
4 changes: 2 additions & 2 deletions pkg/schedule/coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,8 +117,8 @@ func (c *Coordinator) markSchedulersInitialized() {
c.schedulersInitialized = true
}

// CheckSchedulersInitialized returns whether the schedulers have been initialized.
func (c *Coordinator) CheckSchedulersInitialized() bool {
// AreSchedulersInitialized returns whether the schedulers have been initialized.
func (c *Coordinator) AreSchedulersInitialized() bool {
c.RLock()
defer c.RUnlock()
return c.schedulersInitialized
Expand Down

0 comments on commit 0dfaa08

Please sign in to comment.