support middleware

CECTC · Jul 27, 2022 · 1f4310a · 1f4310a
1 parent 599621d
commit 1f4310a
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/core/distributed_transaction_manger.go b/pkg/core/distributed_transaction_manger.go
@@ -224,7 +224,12 @@ func (manager *DistributedTransactionManager) processGlobalSessions() error {
 				if err := manager.storageDriver.DeleteGlobalSession(context.Background(), gs.XID); err != nil {
 					return err
 				}
-				log.Debugf("global session finished, key: %s", gs.XID)
+				if gs.Status == api.Committing {
+					log.Debugf("global session commit finished, key: %s", gs.XID)
+				}
+				if gs.Status == api.Rollbacking {
+					log.Debugf("global session rollback finished, key: %s", gs.XID)
+				}
 			}
 		}
 	}