Repository: karaf-cellar Updated Branches: refs/heads/cellar-3.0.x 7c3e1c703 -> 01ecd4568
[KARAF-3981] Improve OBR synchronizer Project: http://git-wip-us.apache.org/repos/asf/karaf-cellar/repo Commit: http://git-wip-us.apache.org/repos/asf/karaf-cellar/commit/01ecd456 Tree: http://git-wip-us.apache.org/repos/asf/karaf-cellar/tree/01ecd456 Diff: http://git-wip-us.apache.org/repos/asf/karaf-cellar/diff/01ecd456 Branch: refs/heads/cellar-3.0.x Commit: 01ecd456876ea851b69d81a335c7c03033b527ce Parents: 7c3e1c7 Author: Jean-Baptiste Onofré <[email protected]> Authored: Sun Sep 13 17:51:01 2015 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Mon Sep 14 09:45:05 2015 +0200 ---------------------------------------------------------------------- .../karaf/cellar/obr/ObrBundleEventHandler.java | 6 +++ .../karaf/cellar/obr/ObrUrlEventHandler.java | 6 +++ .../karaf/cellar/obr/ObrUrlSynchronizer.java | 50 +++++++++++++++----- .../resources/OSGI-INF/blueprint/blueprint.xml | 1 + 4 files changed, 52 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/01ecd456/obr/src/main/java/org/apache/karaf/cellar/obr/ObrBundleEventHandler.java ---------------------------------------------------------------------- diff --git a/obr/src/main/java/org/apache/karaf/cellar/obr/ObrBundleEventHandler.java b/obr/src/main/java/org/apache/karaf/cellar/obr/ObrBundleEventHandler.java index f821cd5..9e3eff3 100644 --- a/obr/src/main/java/org/apache/karaf/cellar/obr/ObrBundleEventHandler.java +++ b/obr/src/main/java/org/apache/karaf/cellar/obr/ObrBundleEventHandler.java @@ -131,6 +131,12 @@ public class ObrBundleEventHandler extends ObrSupport implements EventHandler<Cl return; } + // check if it's not a "local" event + if (event.getSourceNode() != null && event.getSourceNode().getId().equalsIgnoreCase(clusterManager.getNode().getId())) { + LOGGER.trace("CELLAR BUNDLE: cluster event is local (coming from local synchronizer or listener)"); + return; + } + String bundleId = event.getBundleId(); boolean deployOptional = event.getDeployOptional(); boolean start = event.getStart(); http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/01ecd456/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlEventHandler.java ---------------------------------------------------------------------- diff --git a/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlEventHandler.java b/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlEventHandler.java index ed27ace..9c3078c 100644 --- a/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlEventHandler.java +++ b/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlEventHandler.java @@ -70,6 +70,12 @@ public class ObrUrlEventHandler extends ObrSupport implements EventHandler<Clust return; } + // check if it's not a "local" event + if (event.getSourceNode() != null && event.getSourceNode().getId().equalsIgnoreCase(clusterManager.getNode().getId())) { + LOGGER.trace("CELLAR BUNDLE: cluster event is local (coming from local synchronizer or listener)"); + return; + } + String url = event.getUrl(); try { if (isAllowed(event.getSourceGroup(), Constants.URLS_CONFIG_CATEGORY, url, EventType.INBOUND) || event.getForce()) { http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/01ecd456/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlSynchronizer.java ---------------------------------------------------------------------- diff --git a/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlSynchronizer.java b/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlSynchronizer.java index 73be384..b3e97e6 100644 --- a/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlSynchronizer.java +++ b/obr/src/main/java/org/apache/karaf/cellar/obr/ObrUrlSynchronizer.java @@ -18,6 +18,7 @@ import org.apache.felix.bundlerepository.Resource; import org.apache.karaf.cellar.core.Configurations; import org.apache.karaf.cellar.core.Group; import org.apache.karaf.cellar.core.Synchronizer; +import org.apache.karaf.cellar.core.event.EventProducer; import org.apache.karaf.cellar.core.event.EventType; import org.osgi.service.cm.Configuration; import org.slf4j.Logger; @@ -35,6 +36,12 @@ public class ObrUrlSynchronizer extends ObrSupport implements Synchronizer { private static final transient Logger LOGGER = LoggerFactory.getLogger(ObrUrlSynchronizer.class); + private EventProducer eventProducer; + + public void setEventProducer(EventProducer eventProducer) { + this.eventProducer = eventProducer; + } + @Override public void init() { Set<Group> groups = groupManager.listLocalGroups(); @@ -58,19 +65,32 @@ public class ObrUrlSynchronizer extends ObrSupport implements Synchronizer { @Override public void sync(Group group) { String policy = getSyncPolicy(group); - if (policy != null && policy.equalsIgnoreCase("cluster")) { - LOGGER.debug("CELLAR OBR: sync policy is set as 'cluster' for cluster group " + group.getName()); - if (clusterManager.listNodesByGroup(group).size() == 1 && clusterManager.listNodesByGroup(group).contains(clusterManager.getNode())) { - LOGGER.debug("CELLAR OBR: node is the first and only member of the group, pushing state"); - push(group); - } else { - LOGGER.debug("CELLAR OBR: pulling state"); - pull(group); - } + if (policy == null) { + LOGGER.warn("CELLAR OBR: sync policy is not defined for cluster group {}", group.getName()); } - if (policy != null && policy.equalsIgnoreCase("node")) { - LOGGER.debug("CELLAR OBR: sync policy is set as 'node' for cluster group " + group.getName()); + if (policy.equalsIgnoreCase("cluster")) { + LOGGER.debug("CELLAR OBR: sync policy set as 'cluster' for cluster group {}", group.getName()); + LOGGER.debug("CELLAR OBR: updating node from the cluster (pull first)"); + pull(group); + LOGGER.debug("CELLAR OBR: updating cluster from the local node (push after)"); + push(group); + } else if (policy.equalsIgnoreCase("node")) { + LOGGER.debug("CELLAR OBR: sync policy set as 'node' for cluster group {}", group.getName()); + LOGGER.debug("CELLAR OBR: updating cluster from the local node (push first)"); + push(group); + LOGGER.debug("CELLAR OBR: updating node from the cluster (pull after)"); + pull(group); + } else if (policy.equalsIgnoreCase("clusterOnly")) { + LOGGER.debug("CELLAR OBR: sync policy set as 'clusterOnly' for cluster group " + group.getName()); + LOGGER.debug("CELLAR OBR: updating node from the cluster (pull only)"); + pull(group); + } else if (policy.equalsIgnoreCase("nodeOnly")) { + LOGGER.debug("CELLAR OBR: sync policy set as 'nodeOnly' for cluster group " + group.getName()); + LOGGER.debug("CELLAR OBR: updating cluster from the local node (push only)"); push(group); + } else { + LOGGER.debug("CELLAR OBR: sync policy set as 'disabled' for cluster group " + group.getName()); + LOGGER.debug("CELLAR OBR: no sync"); } } @@ -120,11 +140,19 @@ public class ObrUrlSynchronizer extends ObrSupport implements Synchronizer { Repository[] repositories = obrService.listRepositories(); for (Repository repository : repositories) { if (isAllowed(group, Constants.URLS_CONFIG_CATEGORY, repository.getURI().toString(), EventType.OUTBOUND)) { + LOGGER.debug("CELLAR OBR: adding repository {} to the cluster", repository.getURI().toString()); + // update cluster state clusterUrls.add(repository.getURI().toString()); + // send cluster event + ClusterObrUrlEvent urlEvent = new ClusterObrUrlEvent(repository.getURI().toString(), Constants.URL_ADD_EVENT_TYPE); + urlEvent.setSourceGroup(group); + urlEvent.setSourceNode(clusterManager.getNode()); + eventProducer.produce(urlEvent); // update OBR bundles in the cluster group Set<ObrBundleInfo> clusterBundles = clusterManager.getSet(Constants.BUNDLES_DISTRIBUTED_SET_NAME + Configurations.SEPARATOR + groupName); Resource[] resources = repository.getResources(); for (Resource resource : resources) { + LOGGER.debug("CELLAR OBR: adding bundle {} to the cluster", resource.getPresentationName()); ObrBundleInfo info = new ObrBundleInfo(resource.getPresentationName(), resource.getSymbolicName(), resource.getVersion().toString()); clusterBundles.add(info); } http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/01ecd456/obr/src/main/resources/OSGI-INF/blueprint/blueprint.xml ---------------------------------------------------------------------- diff --git a/obr/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/obr/src/main/resources/OSGI-INF/blueprint/blueprint.xml index e3a5881..645a57f 100644 --- a/obr/src/main/resources/OSGI-INF/blueprint/blueprint.xml +++ b/obr/src/main/resources/OSGI-INF/blueprint/blueprint.xml @@ -35,6 +35,7 @@ <property name="clusterManager" ref="clusterManager"/> <property name="groupManager" ref="groupManager"/> <property name="configurationAdmin" ref="configurationAdmin"/> + <property name="eventProducer" ref="eventProducer"/> </bean> <service ref="obrUrlSynchronizer" interface="org.apache.karaf.cellar.core.Synchronizer"> <service-properties>
