This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit 06aa10330ad22a4e5ae61923da988abcc69c3c6c Author: Lei Zhang <[email protected]> AuthorDate: Fri Jul 26 14:56:27 2019 +0800 SCB-1369 Modified to finally call the stopSagaData method --- .../java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java index b998dcf..2675de3 100644 --- a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java +++ b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java @@ -358,14 +358,14 @@ public class SagaActor extends if (LOG.isDebugEnabled()) { LOG.debug("stop {} {}", data.getGlobalTxId(), state); } - data.setTerminated(true); + sagaEndTime = System.currentTimeMillis(); + SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(context().system()).doSagaEndCounter(); + SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(context().system()).doSagaAvgTime(sagaEndTime - sagaBeginTime); data.setLastState(state); data.setEndTime(new Date()); + data.setTerminated(true); SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(getContext().getSystem()) .stopSagaData(data.getGlobalTxId(), data); - sagaEndTime = System.currentTimeMillis(); - SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(context().system()).doSagaEndCounter(); - SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(context().system()).doSagaAvgTime(sagaEndTime - sagaBeginTime); } ) );
