Skip to content

Commit

Permalink
chore: fix function names in comment (#1405)
Browse files Browse the repository at this point in the history
Signed-off-by: mountcount <[email protected]>
Co-authored-by: Tim Vaillancourt <[email protected]>
  • Loading branch information
mountcount and timvaillancourt authored Apr 14, 2024
1 parent e6c198c commit 8d99e46
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion go/base/context.go
Original file line number Diff line number Diff line change
Expand Up @@ -772,7 +772,7 @@ func (this *MigrationContext) ReadMaxLoad(maxLoadList string) error {
return nil
}

// ReadMaxLoad parses the `--max-load` flag, which is in multiple key-value format,
// ReadCriticalLoad parses the `--max-load` flag, which is in multiple key-value format,
// such as: 'Threads_running=100,Threads_connected=500'
// It only applies changes in case there's no parsing error.
func (this *MigrationContext) ReadCriticalLoad(criticalLoadList string) error {
Expand Down
2 changes: 1 addition & 1 deletion go/logic/applier.go
Original file line number Diff line number Diff line change
Expand Up @@ -796,7 +796,7 @@ func (this *Applier) StartSlaveIOThread() error {
return nil
}

// StartSlaveSQLThread is applicable with --test-on-replica
// StopSlaveSQLThread is applicable with --test-on-replica
func (this *Applier) StopSlaveSQLThread() error {
query := `stop /* gh-ost */ slave sql_thread`
this.migrationContext.Log.Infof("Verifying SQL thread is stopped")
Expand Down
2 changes: 1 addition & 1 deletion go/logic/throttler.go
Original file line number Diff line number Diff line change
Expand Up @@ -284,7 +284,7 @@ func (this *Throttler) criticalLoadIsMet() (met bool, variableName string, value
return false, variableName, value, threshold, nil
}

// collectReplicationLag reads the latest changelog heartbeat value
// collectThrottleHTTPStatus reads the latest changelog heartbeat value
func (this *Throttler) collectThrottleHTTPStatus(firstThrottlingCollected chan<- bool) {
collectFunc := func() (sleep bool, err error) {
if atomic.LoadInt64(&this.migrationContext.HibernateUntil) > 0 {
Expand Down

0 comments on commit 8d99e46

Please sign in to comment.