Method onError

driver/oracle/extractor/extractor_oracle.go:822–834

(state int, err error)

}

func (e *ExtractorOracle) onError(state int, err error) {
	e.logger.Error("onError", "err", err, "hasShutdown", e.shutdown)
	if e.shutdown {
		return
	}
	common.WriteWaitCh(e.waitCh, &drivers.ExitResult{
		ExitCode:  state,
		Signal:    0,
		OOMKilled: false,
		Err:       err,
	})
	_ = e.Shutdown()
}

func (e *ExtractorOracle) sendFullComplete() (err error) {
	dumpMsg, err := common.Encode(&common.DumpStatResult{