You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by jx...@apache.org on 2018/07/09 20:58:16 UTC
helix git commit: minor logging improvements
Repository: helix
Updated Branches:
refs/heads/master 8a6ac8ff2 -> 3870ab0f3
minor logging improvements
Project: http://git-wip-us.apache.org/repos/asf/helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/3870ab0f
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/3870ab0f
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/3870ab0f
Branch: refs/heads/master
Commit: 3870ab0f31a8f8a44ac5816ed0bde38fc7433bd0
Parents: 8a6ac8f
Author: Harry Zhang <hr...@linkedin.com>
Authored: Mon Jul 9 13:56:57 2018 -0700
Committer: Harry Zhang <hr...@linkedin.com>
Committed: Mon Jul 9 13:56:57 2018 -0700
----------------------------------------------------------------------
.../org/apache/helix/participant/HelixStateMachineEngine.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/helix/blob/3870ab0f/helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java b/helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java
index 3a13180..e235201 100644
--- a/helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java
+++ b/helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java
@@ -145,11 +145,13 @@ public class HelixStateMachineEngine implements StateMachineEngine {
@Override
public void reset() {
+ logger.info("Resetting HelixStateMachineEngine");
for (Map<String, StateModelFactory<? extends StateModel>> ftyMap : _stateModelFactoryMap
.values()) {
for (StateModelFactory<? extends StateModel> stateModelFactory : ftyMap.values()) {
for (String resourceName : stateModelFactory.getResourceSet()) {
for (String partitionKey : stateModelFactory.getPartitionSet(resourceName)) {
+ logger.info("Resetting {}::{}", resourceName, partitionKey);
StateModel stateModel = stateModelFactory.getStateModel(resourceName, partitionKey);
stateModel.reset();
String initialState = _stateModelParser.getInitialState(stateModel.getClass());
@@ -160,6 +162,7 @@ public class HelixStateMachineEngine implements StateMachineEngine {
}
}
}
+ logger.info("Successfully reset HelixStateMachineEngine");
}
@Override