fix(log): add dest chain sendIBTP log

meshplus · Jan 16, 2024 · 741a696 · 741a696
1 parent 5bd6821
commit 741a696
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/exchanger/direct_consumer.go b/internal/exchanger/direct_consumer.go
@@ -25,6 +25,7 @@ func (ex *Exchanger) listenIBTPFromDestAdaptForDirect(servicePair string) {
 			}
 			ex.logger.WithFields(logrus.Fields{"index": ibtp.Index, "type": ibtp.Type, "ibtp_id": ibtp.ID()}).Info("Receive ibtp from :", ex.destAdaptName)
 			index := ex.getCurrentIndexFromDest(ibtp)
+			ex.logger.Infof("current index from destAdaptor for ibtp: %s is %d", ibtp.ID(), index)
 
 			if index >= ibtp.Index {
 				if ibtp.Type == pb.IBTP_RECEIPT_ROLLBACK {
@@ -51,6 +52,7 @@ func (ex *Exchanger) listenIBTPFromDestAdaptForDirect(servicePair string) {
 			} else {
 				ex.sendIBTPForDirect(ex.destAdapt, ex.srcAdapt, ibtp, !ex.isIBTPBelongSrc(ibtp), false)
 			}
+			ex.logger.Infof("[direct-consumer] send IBTP [%s] returned", ibtp.ID())
 
 			if ex.isIBTPBelongSrc(ibtp) {
 				ex.destServiceMeta[ibtp.From].ReceiptCounter[ibtp.To] = ibtp.Index