Skip to content

Print status to migrationContext logger #1027

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
SocalNick wants to merge 2 commits into from
Closed

Print status to migrationContext logger #1027

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3faa221
Print status to migrationContext logger
SocalNick Sep 17, 2021
52c2a46
Merge branch 'master' into nc--send-status-to-migration-context-logger
SocalNick Jan 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 11 additions & 5 deletions go/logic/migrator.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -103,6 +103,12 @@ func NewMigrator(context *base.MigrationContext) *Migrator {
return migrator
}

func (this *Migrator) Write(p []byte) (n int, err error) {
s := string(p[:])
this.migrationContext.Log.Infof(s)
return len(s), nil
}

// initiateHooksExecutor
func (this *Migrator) initiateHooksExecutor() (err error) {
this.hooksExecutor = NewHooksExecutor(this.migrationContext)
Expand Down Expand Up @@ -418,7 +424,7 @@ func (this *Migrator) Migrate() (err error) {
if err := this.hooksExecutor.onRowCopyComplete(); err != nil {
return err
}
this.printStatus(ForcePrintStatusRule)
this.printStatus(ForcePrintStatusRule, this)

if err := this.hooksExecutor.onBeforeCutOver(); err != nil {
return err
Expand Down Expand Up @@ -594,7 +600,7 @@ func (this *Migrator) waitForEventsUpToLock() (err error) {
waitForEventsUpToLockDuration := time.Since(waitForEventsUpToLockStartTime)

this.migrationContext.Log.Infof("Done waiting for events up to lock; duration=%+v", waitForEventsUpToLockDuration)
this.printStatus(ForcePrintStatusAndHintRule)
this.printStatus(ForcePrintStatusAndHintRule, this)

return nil
}
Expand Down Expand Up @@ -726,7 +732,7 @@ func (this *Migrator) atomicCutOver() (err error) {
// initiateServer begins listening on unix socket/tcp for incoming interactive commands
func (this *Migrator) initiateServer() (err error) {
var f printStatusFunc = func(rule PrintStatusRule, writer io.Writer) {
this.printStatus(rule, writer)
this.printStatus(rule, writer, this)
}
this.server = NewServer(this.migrationContext, this.hooksExecutor, f)
if err := this.server.BindSocketFile(); err != nil {
Expand Down Expand Up @@ -805,13 +811,13 @@ func (this *Migrator) initiateInspector() (err error) {

// initiateStatus sets and activates the printStatus() ticker
func (this *Migrator) initiateStatus() error {
this.printStatus(ForcePrintStatusAndHintRule)
this.printStatus(ForcePrintStatusAndHintRule, this)
statusTick := time.Tick(1 * time.Second)
for range statusTick {
if atomic.LoadInt64(&this.finishedMigrating) > 0 {
return nil
}
go this.printStatus(HeuristicPrintStatusRule)
go this.printStatus(HeuristicPrintStatusRule, this)
}

return nil
Expand Down