X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Finternal%2Fkernel%2FCmsState.java;h=7ff650254b1149a45801e9623fed7e44c01645f6;hb=fb22feb37b0c2340d3d846dce4b6f47d0f728efb;hp=2f3bdcefd02185dd6474e47893f79603dc7a99fa;hpb=810aecacb19916bade7e4bcfcbbb54c301f672df;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsState.java b/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsState.java
index 2f3bdcefd..7ff650254 100644
--- a/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsState.java
+++ b/org.argeo.cms/src/org/argeo/cms/internal/kernel/CmsState.java
@@ -15,10 +15,10 @@ import javax.transaction.UserTransaction;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.argeo.api.NodeConstants;
+import org.argeo.api.NodeState;
 import org.argeo.cms.CmsException;
 import org.argeo.cms.LocaleUtils;
-import org.argeo.node.NodeConstants;
-import org.argeo.node.NodeState;
 import org.argeo.transaction.simple.SimpleTransactionManager;
 import org.argeo.util.LangUtils;
 import org.osgi.framework.BundleContext;
@@ -42,13 +42,13 @@ public class CmsState implements NodeState {
 	private List<Runnable> stopHooks = new ArrayList<>();
 
 	private final String stateUuid;
-	private final boolean cleanState;
+//	private final boolean cleanState;
 	private String hostname;
 
-	public CmsState(String stateUuid) {
-		this.stateUuid = stateUuid;
-		String frameworkUuid = KernelUtils.getFrameworkProp(Constants.FRAMEWORK_UUID);
-		this.cleanState = stateUuid.equals(frameworkUuid);
+	public CmsState() {
+//		this.stateUuid = stateUuid;
+		this.stateUuid = KernelUtils.getFrameworkProp(Constants.FRAMEWORK_UUID);
+//		this.cleanState = stateUuid.equals(frameworkUuid);
 		try {
 			this.hostname = InetAddress.getLocalHost().getHostName();
 		} catch (UnknownHostException e) {
@@ -57,7 +57,9 @@ public class CmsState implements NodeState {
 
 		availableSince = System.currentTimeMillis();
 		if (log.isDebugEnabled())
-			log.debug("## CMS starting... stateUuid=" + this.stateUuid + (cleanState ? " (clean state) " : " "));
+			// log.debug("## CMS starting... stateUuid=" + this.stateUuid + (cleanState ? "
+			// (clean state) " : " "));
+			log.debug("## CMS starting... (" + stateUuid + ")");
 
 		initI18n();
 		initServices();
@@ -113,7 +115,7 @@ public class CmsState implements NodeState {
 		bc.registerService(RepositoryFactory.class, repositoryFactory, null);
 
 		// Security
-		NodeUserAdmin userAdmin = new NodeUserAdmin(NodeConstants.ROLES_BASEDN);
+		NodeUserAdmin userAdmin = new NodeUserAdmin(NodeConstants.ROLES_BASEDN, NodeConstants.TOKENS_BASEDN);
 		stopHooks.add(() -> userAdmin.destroy());
 		bc.registerService(ManagedServiceFactory.class, userAdmin,
 				LangUtils.dico(Constants.SERVICE_PID, NodeConstants.NODE_USER_ADMIN_PID));
@@ -176,13 +178,18 @@ public class CmsState implements NodeState {
 
 	void shutdown() {
 		if (log.isDebugEnabled())
-			log.debug("CMS stopping...  stateUuid=" + this.stateUuid + (cleanState ? " (clean state) " : " "));
+			log.debug("CMS stopping...  (" + this.stateUuid + ")");
 
 		if (kernelThread != null)
 			kernelThread.destroyAndJoin();
-		// In a different state in order to avois interruptions
-		new Thread(() -> applyStopHooks(), "Apply Argeo Stop Hooks").start();
-		// applyStopHooks();
+		// In a different thread in order to avoid interruptions
+		Thread stopHookThread = new Thread(() -> applyStopHooks(), "Apply Argeo Stop Hooks");
+		stopHookThread.start();
+		try {
+			stopHookThread.join(10 * 60 * 1000);
+		} catch (InterruptedException e) {
+			// silent
+		}
 
 		long duration = ((System.currentTimeMillis() - availableSince) / 1000) / 60;
 		log.info("## ARGEO CMS STOPPED after " + (duration / 60) + "h " + (duration % 60) + "min uptime ##");
@@ -201,10 +208,10 @@ public class CmsState implements NodeState {
 		new GogoShellKiller().start();
 	}
 
-	@Override
-	public boolean isClean() {
-		return cleanState;
-	}
+//	@Override
+//	public boolean isClean() {
+//		return cleanState;
+//	}
 
 	@Override
 	public Long getAvailableSince() {