You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by ni...@apache.org on 2019/08/05 14:47:20 UTC
[servicecomb-pack] 09/38: SCB-1369 Modified to finally call the
stopSagaData method
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 <co...@gmail.com>
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);
}
)
);