Skip to content

Commit

Permalink
change to lower case
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Oct 9, 2023
1 parent ae72ada commit 13b2126
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 13 deletions.
2 changes: 1 addition & 1 deletion pkg/mcs/resourcemanager/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -387,7 +387,7 @@ func CreateServerWrapper(cmd *cobra.Command, args []string) {
defer log.Sync()

versioninfo.Log(serviceName)
log.Info("Resource manager config", zap.Reflect("config", cfg))
log.Info("resource manager config", zap.Reflect("config", cfg))

grpcprometheus.EnableHandlingTimeHistogram()
metricutil.Push(&cfg.Metric)
Expand Down
2 changes: 1 addition & 1 deletion pkg/mcs/scheduling/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -540,7 +540,7 @@ func CreateServerWrapper(cmd *cobra.Command, args []string) {
defer log.Sync()

versioninfo.Log(serviceName)
log.Info("Scheduling service config", zap.Reflect("config", cfg))
log.Info("scheduling service config", zap.Reflect("config", cfg))

grpcprometheus.EnableHandlingTimeHistogram()
metricutil.Push(&cfg.Metric)
Expand Down
18 changes: 9 additions & 9 deletions pkg/schedule/coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@ func (c *Coordinator) PatrolRegions() {
ticker := time.NewTicker(c.cluster.GetCheckerConfig().GetPatrolRegionInterval())
defer ticker.Stop()

log.Info("Coordinator starts patrol regions")
log.Info("coordinator starts patrol regions")
start := time.Now()
var (
key []byte
Expand Down Expand Up @@ -252,7 +252,7 @@ func (c *Coordinator) checkPriorityRegions() {
func (c *Coordinator) checkSuspectRanges() {
defer logutil.LogPanic()
defer c.wg.Done()
log.Info("Coordinator begins to check suspect key ranges")
log.Info("coordinator begins to check suspect key ranges")
ticker := time.NewTicker(checkSuspectRangesInterval)
defer ticker.Stop()
for {
Expand Down Expand Up @@ -316,7 +316,7 @@ func (c *Coordinator) drivePushOperator() {
defer logutil.LogPanic()

defer c.wg.Done()
log.Info("Coordinator begins to actively drive push operator")
log.Info("coordinator begins to actively drive push operator")
ticker := time.NewTicker(pushOperatorTickInterval)
defer ticker.Stop()
for {
Expand Down Expand Up @@ -370,10 +370,10 @@ func (c *Coordinator) driveSlowNodeScheduler() {
func (c *Coordinator) RunUntilStop() {
c.Run()
<-c.ctx.Done()
log.Info("Coordinator is stopping")
log.Info("coordinator is stopping")
c.GetSchedulersController().Wait()
c.wg.Wait()
log.Info("Coordinator has been stopped")
log.Info("coordinator has been stopped")
}

// Run starts coordinator.
Expand All @@ -383,20 +383,20 @@ func (c *Coordinator) Run() {
ticker = time.NewTicker(100 * time.Millisecond)
})
defer ticker.Stop()
log.Info("Coordinator starts to collect cluster information")
log.Info("coordinator starts to collect cluster information")
for {
if c.ShouldRun() {
log.Info("Coordinator has finished cluster information preparation")
log.Info("coordinator has finished cluster information preparation")
break
}
select {
case <-ticker.C:
case <-c.ctx.Done():
log.Info("Coordinator stops running")
log.Info("coordinator stops running")
return
}
}
log.Info("Coordinator starts to run schedulers")
log.Info("coordinator starts to run schedulers")
c.InitSchedulers(true)

c.wg.Add(4)
Expand Down
4 changes: 2 additions & 2 deletions pkg/unsaferecovery/unsafe_recovery_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -465,7 +465,7 @@ func (u *Controller) CollectReport(heartbeat *pdpb.StoreHeartbeatRequest) (bool,
}

if heartbeat.StoreReport.GetStep() != u.step {
log.Info("Unsafe recovery receives invalid store report",
log.Info("unsafe recovery receives invalid store report",
zap.Uint64("store-id", storeID), zap.Uint64("expected-step", u.step), zap.Uint64("obtained-step", heartbeat.StoreReport.GetStep()))
// invalid store report, ignore
return false, nil
Expand Down Expand Up @@ -891,7 +891,7 @@ func (t *regionTree) insert(item *regionItem) (bool, error) {
}

for _, newer := range overlaps {
log.Info("Unsafe recovery found overlap regions", logutil.ZapRedactStringer("newer-region-meta", core.RegionToHexMeta(newer.Region())), logutil.ZapRedactStringer("older-region-meta", core.RegionToHexMeta(item.Region())))
log.Info("unsafe recovery found overlap regions", logutil.ZapRedactStringer("newer-region-meta", core.RegionToHexMeta(newer.Region())), logutil.ZapRedactStringer("older-region-meta", core.RegionToHexMeta(item.Region())))
// it's ensured by the `buildUpFromReports` that peers are inserted in epoch descending order.
if newer.IsEpochStale(item) {
return false, errors.Errorf("region %v's epoch shouldn't be staler than old ones %v", item, newer)
Expand Down

0 comments on commit 13b2126

Please sign in to comment.