Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
clear process info error when registration is opened
  • Loading branch information
chenson42 committed Apr 25, 2013
1 parent dabd366 commit b7af5e1
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 0 deletions.
Expand Up @@ -462,6 +462,7 @@ protected String openRegistration(Node node, String remoteHost, String remoteAdd
} else {
reOpenRegistration(nodeId);
}
statisticManager.removeProcessInfo(new ProcessInfoKey(me.getNodeId(), nodeId, ProcessType.REGISTRATION_HANDLER));
return nodeId;
} else {
throw new IllegalStateException(
Expand Down
Expand Up @@ -37,6 +37,8 @@ public interface IStatisticManager {

public List<ProcessInfo> getProcessInfos();

public void removeProcessInfo(ProcessInfoKey key);

public Set<String> getNodesWithProcessesInError();

public void flush();
Expand Down
Expand Up @@ -103,6 +103,10 @@ public ProcessInfo newProcessInfo(ProcessInfoKey key) {
return process;
}

public void removeProcessInfo(ProcessInfoKey key) {
processInfos.remove(key);
}

public Set<String> getNodesWithProcessesInError() {
String identityNodeId = nodeService.findIdentityNodeId();
Set<String> status = new HashSet<String>();
Expand Down
Expand Up @@ -33,6 +33,9 @@ public List<ProcessInfo> getProcessInfos() {
return null;
}

public void removeProcessInfo(ProcessInfoKey key) {
}

public ProcessInfo newProcessInfo(ProcessInfoKey key) {
return null;
}
Expand Down

0 comments on commit b7af5e1

Please sign in to comment.