Method checkAbort

go/logic/migrator.go:447–466

checkAbort returns abort error if migration was aborted

()

// checkAbort returns abort error if migration was aborted
func (mgtr *Migrator) checkAbort() error {
	if abortErr := mgtr.migrationContext.GetAbortError(); abortErr != nil {
		return abortErr
	}

	ctx := mgtr.migrationContext.GetContext()
	if ctx != nil {
		select {
		case <-ctx.Done():
			// Context cancelled but no abort error stored yet
			if abortErr := mgtr.migrationContext.GetAbortError(); abortErr != nil {
				return abortErr
			}
			return ctx.Err()
		default:
			// Not cancelled
		}
	}
	return nil
}

// Migrate executes the complete migration logic. This is *the* major gh-ost function.
func (mgtr *Migrator) Migrate() (err error) {