fix(rollback): compare returned time before calculating duration

meshplus · Feb 23, 2024 · 27d82d5 · 27d82d5
1 parent 1ab35fd
commit 27d82d5
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/internal/exchanger/direct_consumer.go b/internal/exchanger/direct_consumer.go
@@ -117,8 +117,10 @@ func (ex *Exchanger) isIBTPRollbackForDirect(ibtp *pb.IBTP) bool {
 	ex.logger.Infof("[isIBTPRollbackForDirect] ibtp.Type: %s, startTimeStamp: %d, timeoutPeriod: %d, "+
 		"txStatus: %v, for IBTP [%s], time.Now().Unix(): %d", ibtp.Type.String(), startTimeStamp, timeoutPeriod,
 		txStatus, ibtp.ID(), time.Now().Unix())
-
-	return uint64(time.Now().Unix())-startTimeStamp > timeoutPeriod
+	if uint64(time.Now().Unix()) > startTimeStamp {
+		return uint64(time.Now().Unix())-startTimeStamp > timeoutPeriod
+	}
+	return false
 }
 
 func (ex *Exchanger) rollbackIBTPForDirect(ibtp *pb.IBTP) {