Skip to content

Commit

Permalink
fix bug
Browse files Browse the repository at this point in the history
  • Loading branch information
JameKeal committed Mar 31, 2023
1 parent 0e8faa2 commit 948d8be
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cmd/yurthub/app/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -224,7 +224,7 @@ func createClients(heartbeatTimeoutSeconds int, remoteServers []*url.URL, tp tra
}

// coordinatorRun will initialize and start all coordinator-related components in an async way.
// It returns Getter function for coordinator, coordinator health checker and coordinator transport manager,
// It returns Getter function for coordinator, coordinator health checker, coordinator transport manager and coordinator service url,
// which will return the relative component if it has been initialized, otherwise it will return nil.
func coordinatorRun(ctx context.Context,
cfg *config.YurtHubConfiguration,
Expand Down Expand Up @@ -252,7 +252,7 @@ func coordinatorRun(ctx context.Context,

// waiting for service sync complete
if !cache.WaitForCacheSync(ctx.Done(), cfg.SharedFactory.Core().V1().Services().Informer().HasSynced) {
klog.Error("coordinatorRun sync service timeout")
klog.Error("coordinatorRun sync service shutdown")
return
}
klog.Info("coordinatorRun sync service complete")
Expand Down

0 comments on commit 948d8be

Please sign in to comment.