xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge "Omaha #3622 Fix duplicate SiteActivationNotifications." into omaha_14.4.1

Browse source 
Former-commit-id: acbc667cfeab1ab6449a93967896e6e303bb238d
This commit is contained in:
Richard Peter 2014-09-26 11:27:53 -05:00 • committed by Gerrit Code Review
commit 23747ad042
2 changed files with 65 additions and 51 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
edexOsgi/com.raytheon.edex.plugin.gfe/.settings/org.eclipse.jdt.core.prefs
View file

@ -1,7 +0,0 @@
#Thu Mar 26 10:17:50 CDT 2009
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
org.eclipse.jdt.core.compiler.compliance=1.6
org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
org.eclipse.jdt.core.compiler.source=1.6

109
edexOsgi/com.raytheon.uf.edex.site/src/com/raytheon/uf/edex/site/SiteActivationMonitor.java
View file

@ -19,6 +19,8 @@
**/
package com.raytheon.uf.edex.site;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
@ -28,6 +30,9 @@ import java.util.Set;
import com.raytheon.uf.common.site.notify.ClusterActivationNotification;
import com.raytheon.uf.common.site.notify.SiteActivationNotification;
import com.raytheon.uf.common.site.notify.SiteActivationNotification.ACTIVATIONSTATUS;
import com.raytheon.uf.common.status.IUFStatusHandler;
import com.raytheon.uf.common.status.UFStatus;
import com.raytheon.uf.edex.core.EdexException;
/**
* Monitors site activation across all JVMs on all cluster members
@ -48,6 +53,9 @@ import com.raytheon.uf.common.site.notify.SiteActivationNotification.ACTIVATIONS
*/
public class SiteActivationMonitor {
private static final transient IUFStatusHandler statusHandler = UFStatus
.getHandler(SiteActivationMonitor.class);
private Map<String, Map<String, Set<String>>> activationMap = new HashMap<String, Map<String, Set<String>>>();
private Map<String, Map<String, Set<String>>> deactivationMap = new HashMap<String, Map<String, Set<String>>>();
@ -56,10 +64,18 @@ public class SiteActivationMonitor {
private ACTIVATIONSTATUS status = ACTIVATIONSTATUS.SUCCESS;
private SiteActivationMonitor() {
private String myHost;
private SiteActivationMonitor() throws EdexException {
try {
this.myHost = InetAddress.getLocalHost().getCanonicalHostName();
} catch (UnknownHostException e) {
statusHandler.error("Error resolving localhost name", e);
throw new EdexException("Error resolving localhost name", e);
}
}
public static SiteActivationMonitor getInstance() {
public static SiteActivationMonitor getInstance() throws EdexException {
if (instance == null) {
instance = new SiteActivationMonitor();
}
@ -104,50 +120,55 @@ public class SiteActivationMonitor {
public SiteActivationNotification handleNotification(
SiteActivationNotification notification) {
if (notification instanceof ClusterActivationNotification) {
if (!(notification instanceof ClusterActivationNotification)) {
String plugin = notification.getPluginName();
String modifiedSite = notification.getModifiedSite();
String serverAndMode = notification.getServerAndRunMode();
if (!activationMap.containsKey(plugin)) {
activationMap.put(plugin, new HashMap<String, Set<String>>());
}
if (!activationMap.get(plugin).containsKey(modifiedSite)) {
activationMap.get(plugin).put(modifiedSite,
new HashSet<String>());
}
if (!deactivationMap.containsKey(plugin)) {
deactivationMap.put(plugin, new HashMap<String, Set<String>>());
}
if (!deactivationMap.get(plugin).containsKey(modifiedSite)) {
deactivationMap.get(plugin).put(modifiedSite,
new HashSet<String>());
}
if (notification.isBegin()) {
if (notification.isActivation()) {
activationMap.get(plugin).get(modifiedSite)
.add(serverAndMode);
} else if (notification.isDeactivation()) {
deactivationMap.get(plugin).get(modifiedSite)
.add(serverAndMode);
}
} else {
if (notification.isActivation()) {
activationMap.get(plugin).get(modifiedSite)
.remove(serverAndMode);
} else if (notification.isDeactivation()) {
deactivationMap.get(plugin).get(modifiedSite)
.remove(serverAndMode);
}
if (notification.isFailure()) {
status = ACTIVATIONSTATUS.FAILURE;
}
}
}
if (notification.getServerName().equals(myHost)) {
return notification;
}
String plugin = notification.getPluginName();
String modifiedSite = notification.getModifiedSite();
String serverAndMode = notification.getServerAndRunMode();
if (!activationMap.containsKey(plugin)) {
activationMap.put(plugin, new HashMap<String, Set<String>>());
}
if (!activationMap.get(plugin).containsKey(modifiedSite)) {
activationMap.get(plugin).put(modifiedSite, new HashSet<String>());
}
if (!deactivationMap.containsKey(plugin)) {
deactivationMap.put(plugin, new HashMap<String, Set<String>>());
}
if (!deactivationMap.get(plugin).containsKey(modifiedSite)) {
deactivationMap.get(plugin)
.put(modifiedSite, new HashSet<String>());
}
if (notification.isBegin()) {
if (notification.isActivation()) {
activationMap.get(plugin).get(modifiedSite).add(serverAndMode);
} else if (notification.isDeactivation()) {
deactivationMap.get(plugin).get(modifiedSite)
.add(serverAndMode);
}
} else {
if (notification.isActivation()) {
activationMap.get(plugin).get(modifiedSite)
.remove(serverAndMode);
} else if (notification.isDeactivation()) {
deactivationMap.get(plugin).get(modifiedSite)
.remove(serverAndMode);
}
if (notification.isFailure()) {
status = ACTIVATIONSTATUS.FAILURE;
}
return null;
}
return notification;
}
}