removed excessive argument

This commit is contained in:
Shlomi Noach 2016-08-29 10:44:43 +02:00
parent 6e5db089c8
commit 6dfa4873c2
2 changed files with 4 additions and 7 deletions

View File

@ -138,12 +138,9 @@ func (this *HooksExecutor) onFailure() error {
return this.executeHooks(onFailure) return this.executeHooks(onFailure)
} }
func (this *HooksExecutor) onStatus(statusMessage string, elapsedSeconds int64) error { func (this *HooksExecutor) onStatus(statusMessage string) error {
v := []string{ v := fmt.Sprintf("GH_OST_STATUS='%s'", statusMessage)
fmt.Sprintf("GH_OST_STATUS='%s'", statusMessage), return this.executeHooks(onStatus, v)
fmt.Sprintf("GH_OST_ELAPSED_SECONDS='%d'", elapsedSeconds),
}
return this.executeHooks(onStatus, v...)
} }
func (this *HooksExecutor) onStopReplication() error { func (this *HooksExecutor) onStopReplication() error {

View File

@ -1102,7 +1102,7 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) {
fmt.Fprintln(w, status) fmt.Fprintln(w, status)
if elapsedSeconds%60 == 0 { if elapsedSeconds%60 == 0 {
this.hooksExecutor.onStatus(status, elapsedSeconds) this.hooksExecutor.onStatus(status)
} }
} }