diff options
| author | Eike Stepper | 2010-09-22 17:30:25 +0000 |
|---|---|---|
| committer | Eike Stepper | 2010-09-22 17:30:25 +0000 |
| commit | 16e28b8a6070952bd0fffd9d2c8df6316170d11e (patch) | |
| tree | 0fd42894b9429ce1f6b470eb7f83bb781dadf828 /plugins/org.eclipse.emf.cdo.server.net4j | |
| parent | 70dda6326113fbf48486e1e1906e04654e4b869f (diff) | |
| download | cdo-16e28b8a6070952bd0fffd9d2c8df6316170d11e.tar.gz cdo-16e28b8a6070952bd0fffd9d2c8df6316170d11e.tar.xz cdo-16e28b8a6070952bd0fffd9d2c8df6316170d11e.zip | |
[325928] Provide FailoverMonitor server and FailoverAgents to coordinate fail-over scenarios
https://bugs.eclipse.org/bugs/show_bug.cgi?id=325928
Diffstat (limited to 'plugins/org.eclipse.emf.cdo.server.net4j')
| -rw-r--r-- | plugins/org.eclipse.emf.cdo.server.net4j/src/org/eclipse/emf/cdo/server/net4j/FailoverMonitor.java | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/plugins/org.eclipse.emf.cdo.server.net4j/src/org/eclipse/emf/cdo/server/net4j/FailoverMonitor.java b/plugins/org.eclipse.emf.cdo.server.net4j/src/org/eclipse/emf/cdo/server/net4j/FailoverMonitor.java index eda3e30375..c651c6d344 100644 --- a/plugins/org.eclipse.emf.cdo.server.net4j/src/org/eclipse/emf/cdo/server/net4j/FailoverMonitor.java +++ b/plugins/org.eclipse.emf.cdo.server.net4j/src/org/eclipse/emf/cdo/server/net4j/FailoverMonitor.java @@ -99,8 +99,9 @@ public class FailoverMonitor extends Container<AgentProtocol> if (newMasterAgent != null) { publishNewMaster(newAgents, newMasterAgent); - fireElementAddedEvent(agent); } + + fireElementAddedEvent(agent); } public void deregisterAgent(AgentProtocol agent) @@ -134,8 +135,9 @@ public class FailoverMonitor extends Container<AgentProtocol> if (newMasterAgent != null) { publishNewMaster(newAgents, newMasterAgent); - fireElementRemovedEvent(agent); } + + fireElementRemovedEvent(agent); } @Override @@ -345,7 +347,7 @@ public class FailoverMonitor extends Container<AgentProtocol> switch (signalID) { case SIGNAL_QUERY_REPOSITORY_INFO: - return new IndicationWithResponse(this, SIGNAL_QUERY_REPOSITORY_INFO) + return new IndicationWithResponse(this, SIGNAL_QUERY_REPOSITORY_INFO, "QueryRepositoryInfo") { @Override protected void indicating(ExtendedDataInputStream in) throws Exception |