X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Finternal%2Fkernel%2FCmsDeployment.java;h=7a4ca1bf4eeed4fec009f4c11a2203bcb9c3516f;hb=7add600d7837fb72f019de190bd5cafd817a0a0c;hp=6fbe7a95c50964d5a4489b978456359fb879303d;hpb=06acf73a99f0e3908fe8998f1ff08dee109c5562;p=lgpl%2Fargeo-commons.git diff --git a/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsDeployment.java b/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsDeployment.java index 6fbe7a95c..7a4ca1bf4 100644 --- a/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsDeployment.java +++ b/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsDeployment.java @@ -4,8 +4,8 @@ import static org.argeo.node.DataModelNamespace.CMS_DATA_MODEL_NAMESPACE; import java.io.InputStreamReader; import java.io.Reader; +import java.lang.management.ManagementFactory; import java.net.URL; -import java.util.Dictionary; import java.util.HashSet; import java.util.Hashtable; import java.util.List; @@ -18,39 +18,113 @@ import javax.jcr.Session; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.jackrabbit.commons.cnd.CndImporter; +import org.apache.jackrabbit.core.RepositoryContext; import org.argeo.cms.CmsException; import org.argeo.jcr.ArgeoJcrConstants; import org.argeo.jcr.JcrUtils; import org.argeo.node.DataModelNamespace; +import org.argeo.node.NodeConstants; import org.argeo.node.NodeDeployment; +import org.argeo.node.NodeState; import org.osgi.framework.Bundle; import org.osgi.framework.BundleContext; +import org.osgi.framework.Constants; import org.osgi.framework.FrameworkUtil; +import org.osgi.framework.ServiceReference; import org.osgi.framework.wiring.BundleCapability; import org.osgi.framework.wiring.BundleWire; import org.osgi.framework.wiring.BundleWiring; -import org.osgi.service.cm.ConfigurationException; -import org.osgi.service.cm.ManagedService; +import org.osgi.service.http.HttpService; +import org.osgi.service.useradmin.UserAdmin; +import org.osgi.util.tracker.ServiceTracker; -public class CmsDeployment implements NodeDeployment, ManagedService { +public class CmsDeployment implements NodeDeployment { private final Log log = LogFactory.getLog(getClass()); private final BundleContext bc = FrameworkUtil.getBundle(getClass()).getBundleContext(); - private Repository deployedNodeRepository; + private final DeployConfig deployConfig; private HomeRepository homeRepository; - - @Override - public void updated(Dictionary properties) throws ConfigurationException { - if (properties == null) - return; + + private Long availableSince; + + // Readiness + private boolean nodeAvailable = false; + private boolean userAdminAvailable = false; + private boolean httpExpected = false; + private boolean httpAvailable = false; + + public CmsDeployment() { + ServiceReference nodeStateSr = bc.getServiceReference(NodeState.class); + if (nodeStateSr == null) + throw new CmsException("No node state available"); + + NodeState nodeState = bc.getService(nodeStateSr); + deployConfig = new DeployConfig(nodeState.isClean()); + httpExpected = deployConfig.getProps(KernelConstants.JETTY_FACTORY_PID, "default") != null; + + initTrackers(); + } + + private void initTrackers() { + new PrepareHttpStc().open(); + new RepositoryContextStc().open(); + new ServiceTracker(bc, UserAdmin.class, null) { + @Override + public UserAdmin addingService(ServiceReference reference) { + userAdminAvailable = true; + checkReadiness(); + return super.addingService(reference); + } + }.open(); + } + + public void shutdown() { + deployConfig.save(); + } + + private void checkReadiness() { + if (nodeAvailable && userAdminAvailable && (httpExpected ? httpAvailable : true)) { + availableSince = System.currentTimeMillis(); + long jvmUptime = ManagementFactory.getRuntimeMXBean().getUptime(); + log.info("## ARGEO CMS AVAILABLE in " + (jvmUptime / 1000) + "." + (jvmUptime % 1000) + "s ##"); + long begin = bc.getService(bc.getServiceReference(NodeState.class)).getAvailableSince(); + long initDuration = System.currentTimeMillis() - begin; + if (log.isTraceEnabled()) + log.trace("Kernel initialization took " + initDuration + "ms"); + directorsCut(initDuration); + } + } + + final private void directorsCut(long initDuration) { + // final long ms = 128l + (long) (Math.random() * 128d); + long ms = initDuration / 100; + log.info("Spend " + ms + "ms" + " reflecting on the progress brought to mankind" + " by Free Software..."); + long beginNano = System.nanoTime(); + try { + Thread.sleep(ms, 0); + } catch (InterruptedException e) { + // silent + } + long durationNano = System.nanoTime() - beginNano; + final double M = 1000d * 1000d; + double sleepAccuracy = ((double) durationNano) / (ms * M); + if (log.isDebugEnabled()) + log.debug("Sleep accuracy: " + String.format("%.2f", 100 - (sleepAccuracy * 100 - 100)) + " %"); + } + + private void prepareNodeRepository(Repository deployedNodeRepository) { + if (availableSince != null) { + throw new CmsException("Deployment is already available"); + } prepareDataModel(KernelUtils.openAdminSession(deployedNodeRepository)); Hashtable regProps = new Hashtable(); + regProps.put(NodeConstants.CN, ArgeoJcrConstants.ALIAS_HOME); regProps.put(ArgeoJcrConstants.JCR_REPOSITORY_ALIAS, ArgeoJcrConstants.ALIAS_HOME); homeRepository = new HomeRepository(deployedNodeRepository); // register bc.registerService(Repository.class, homeRepository, regProps); -} + } /** Session is logged out. */ private void prepareDataModel(Session adminSession) { @@ -104,14 +178,87 @@ public class CmsDeployment implements NodeDeployment, ManagedService { Hashtable properties = new Hashtable<>(); properties.put(ArgeoJcrConstants.JCR_REPOSITORY_ALIAS, name); + properties.put(NodeConstants.CN, name); + if (name.equals(ArgeoJcrConstants.ALIAS_NODE)) + properties.put(Constants.SERVICE_RANKING, Integer.MAX_VALUE); bc.registerService(Repository.class, adminSession.getRepository(), properties); if (log.isDebugEnabled()) log.debug("Published data model " + name); } - public void setDeployedNodeRepository(Repository deployedNodeRepository) { - this.deployedNodeRepository = deployedNodeRepository; + @Override + public Long getAvailableSince() { + return availableSince; + } + + private class RepositoryContextStc extends ServiceTracker { + + public RepositoryContextStc() { + super(bc, RepositoryContext.class, null); + } + + @Override + public RepositoryContext addingService(ServiceReference reference) { + RepositoryContext nodeRepo = bc.getService(reference); + Object cn = reference.getProperty(NodeConstants.CN); + if (cn != null && cn.equals(ArgeoJcrConstants.ALIAS_NODE)) { + prepareNodeRepository(nodeRepo.getRepository()); + nodeAvailable = true; + checkReadiness(); + } + return nodeRepo; + } + + @Override + public void modifiedService(ServiceReference reference, RepositoryContext service) { + } + + @Override + public void removedService(ServiceReference reference, RepositoryContext service) { + } + + } + + private class PrepareHttpStc extends ServiceTracker { + private DataHttp dataHttp; + private NodeHttp nodeHttp; + + public PrepareHttpStc() { + super(bc, HttpService.class, null); + } + + @Override + public HttpService addingService(ServiceReference reference) { + HttpService httpService = addHttpService(reference); + return httpService; + } + + @Override + public void removedService(ServiceReference reference, HttpService service) { + if (dataHttp != null) + dataHttp.destroy(); + dataHttp = null; + if (nodeHttp != null) + nodeHttp.destroy(); + nodeHttp = null; + } + + private HttpService addHttpService(ServiceReference sr) { + HttpService httpService = bc.getService(sr); + // TODO find constants + Object httpPort = sr.getProperty("http.port"); + Object httpsPort = sr.getProperty("https.port"); + dataHttp = new DataHttp(httpService); + nodeHttp = new NodeHttp(httpService, bc); + log.info(httpPortsMsg(httpPort, httpsPort)); + httpAvailable = true; + checkReadiness(); + return httpService; + } + + private String httpPortsMsg(Object httpPort, Object httpsPort) { + return "HTTP " + httpPort + (httpsPort != null ? " - HTTPS " + httpsPort : ""); + } } - }