misc

- add logs for BiglogRelay
- queueOrExec

Author: ffffwh

driver/mysql/applier_incr.go

@@ -533,7 +533,11 @@ func (a *ApplierIncr) ApplyBinlogEvent(workerIdx int, binlogEntryCtx *common.Ent
 		// TODO check if shutdown?
 		if !a.noBigTxDMLPipe && a.inBigTx {
 			a.bigTxEventWg.Add(1)
-			a.bigTxEventQueue <- item
+			select {
+			case <-a.shutdownCh:
+				return fmt.Errorf("queueOrExec: ApplierIncr shutdown")
+			case a.bigTxEventQueue <- item:
+			}
 			return nil
 		} else {
 			return a.prepareIfNilAndExecute(item, workerIdx)

driver/mysql/binlog/binlog_reader.go

@@ -330,6 +330,7 @@ func (b *BinlogReader) ConnectBinlogStreamer(coordinates common.MySQLCoordinates
 		}
 
 		go func() {
+			b.logger.Info("starting BinlogRelay", "gtidSet", coordinates.GtidSet)
 			pr := b.relay.Process(ctx)
 			b.logger.Warn("relay.Process stopped", "isCancelled", pr.IsCanceled, "deail", string(pr.Detail))
 			for _, prErr := range pr.Errors {