Changeset 15085

Timestamp:

03/09/10 17:30:59 (2 years ago)

Author:

sys

Message:

OoConnection : ajout paramètre autoKill

Location:

trunk/Jav_Transform/src/com/scenari/s/co/transform/oo

Files:

• IOoConnection.java (modified) (1 diff)
• OoConnectionPoolLoader.java (modified) (3 diffs)
• impl/OoConnection.java (modified) (11 diffs)

trunk/Jav_Transform/src/com/scenari/s/co/transform/oo/IOoConnection.java

@@ -44 +44 @@
  */
 public interface IOoConnection {
-        
+
         public void setAutoLaunch(boolean pAutoLaunch);
-        
+
+        public void setAutoKill(boolean pAutoKill);
+
         public void setHost(String pHost);
-        
+
         public void setPort(int pPort);
-        
+
         public void setMaxCnxAttempts(int pMaxAttempts);
-        
+
         public void setPipeMode(boolean pPipeMode);
-        
+
         public void setPipeName(String pPipeName);
-        
+
         public void setProfilePath(String pProfilePath);
-        
+
         public void setHeadless(boolean pHeadless);
-        
+
         public void setReCheckInterval(long pMs);
-        
+
 }

trunk/Jav_Transform/src/com/scenari/s/co/transform/oo/OoConnectionPoolLoader.java

@@ -58 +58 @@
  *   [!-- Pour un server local, lancé automatiquement, en accès socket TCP/IP. --]
  *   [ooConnection host="localhost" port="8100" autoLaunch="true"/]
+ *   
+ *   [!-- Pour un server local, lancé automatiquement, en accès socket TCP/IP et kill automatique
+ *   à la fermeture de l'application. --]
+ *   [ooConnection host="localhost" port="8101" autoLaunch="true" autoKill="true" profilePath="file:///ooPf01"/]
  *   
  *   [!-- Pour un server local, lancé automatiquement, en accès pipe, avec pipeName automatique. --]
@@ -129 +133 @@
         public static final String TAG_CONN_ATT_AUTOLAUCNH = "autoLaunch";
 
+        public static final String TAG_CONN_ATT_AUTOKILL = "autoKill";
+
         public static final String TAG_CONN_ATT_MAXCNXATTEMPTS = "maxCnxAttempts";
 
@@ -202 +208 @@
                         String vAutoLaunch = pAttributes.getValue(TAG_CONN_ATT_AUTOLAUCNH);
                         if (vAutoLaunch != null) vCon.setAutoLaunch(Boolean.parseBoolean(vAutoLaunch));
+
+                        String vAutoKill = pAttributes.getValue(TAG_CONN_ATT_AUTOLAUCNH);
+                        if (vAutoKill != null) vCon.setAutoKill(Boolean.parseBoolean(vAutoKill));
 
                         String vMaxCnxAttempts = pAttributes.getValue(TAG_CONN_ATT_MAXCNXATTEMPTS);

trunk/Jav_Transform/src/com/scenari/s/co/transform/oo/impl/OoConnection.java

@@ -44 +44 @@
 import java.io.InputStreamReader;
 import java.io.PrintStream;
+import java.util.HashSet;
 import java.util.Random;
+import java.util.Set;
 
 import com.scenari.s.co.transform.oo.HTransformerOo;
@@ -75 +77 @@
  * Implémentation d'une Connection à Oo.
  * 
- * 
- *
+ * Implémentation non thread-safe concue pour être appelée par une seul thread
+ * à la fois (cf {@link OoConnectionPool} pour les accès concurrents).
  */
 public class OoConnection implements IOoConnection, XEventListener {
@@ -114 +116 @@
         protected boolean fAutoLaunch = true;
 
+        /** Kill auto du serveur pour les url locales. */
+        protected boolean fAutoKill = false;
+
         /** Lancement en mode headless du serveur pour les url locales. */
         protected boolean fHeadless = false;
@@ -163 +168 @@
         public OoConnection() {
                 super();
+        }
+
+        /** Gestion du kill des process OO externes lancés par cette JVM. */
+        static class OoShutdownHook extends Thread {
+                protected Set<OoConnection> fConnectionsToShutdown = new HashSet<OoConnection>();
+
+                public void run() {
+                        //On clone la liste (modifications concurrentes dans vCon.killConnection()).
+                        OoConnection[] vConList = (OoConnection[]) fConnectionsToShutdown.toArray(new OoConnection[fConnectionsToShutdown.size()]);
+                        for (OoConnection vCon : vConList) {
+                                try {
+                                        if (vCon.isAutoKill()) {
+                                                LogMgr.publishTrace("kill Scenari OoServer : " + vCon);
+                                                vCon.killConnection();
+                                        }
+                                } catch (Exception e) {
+                                        LogMgr.publishException(e);
+                                }
+                        }
+                }
+        }
+
+        private static OoShutdownHook sOoShutdownHook = null;
+
+        protected static synchronized void addConnectionToShutdown(OoConnection pCon) {
+                if (sOoShutdownHook == null) {
+                        sOoShutdownHook = new OoShutdownHook();
+                        Runtime.getRuntime().addShutdownHook(sOoShutdownHook);
+                }
+                sOoShutdownHook.fConnectionsToShutdown.add(pCon);
+        }
+
+        protected static synchronized void removeConnectionToShutdown(OoConnection pCon) {
+                if (sOoShutdownHook != null) {
+                        sOoShutdownHook.fConnectionsToShutdown.remove(pCon);
+                }
         }
 
@@ -178 +219 @@
         }
 
+        public boolean isLocal() {
+                return fPipeMode || fHost.equals(LOCALHOST) || fHost.equals(LOCALIP);
+        }
+
         public boolean isAutoLaunch() {
                 return fAutoLaunch;
         }
 
-        public boolean isLocal() {
-                return fPipeMode || fHost.equals(LOCALHOST) || fHost.equals(LOCALIP);
-        }
-
         public void setAutoLaunch(boolean pAutoLaunch) {
                 fAutoLaunch = pAutoLaunch;
+        }
+
+        public boolean isAutoKill() {
+                return fAutoKill;
+        }
+
+        public void setAutoKill(boolean pAutoKill) {
+                fAutoKill = pAutoKill;
         }
 
@@ -335 +384 @@
          * Doit être appelé par le pool quand une connexion est demandée.
          */
-        public void reservedInPool() {
+        void reservedInPool() {
                 fUsageCount++;
         }
@@ -342 +391 @@
          * Doit être appelé par le pool quand une connexion est restituée au pool.
          */
-        public void freedInPool() throws Exception {
+        void freedInPool() throws Exception {
                 if (fAutoLaunch && fHeadless && fOoProcess != null && fUsageCount >= 5) {
-                        fComponentContext = null;
-                        fServiceMgr = null;
-                        fComponentLoader = null;
-                        if (fBridgeComponent != null) {
-                                try {
-                                        fBridgeComponent.dispose();
-                                } catch (Exception e) {
-                                        LogMgr.publishException(e, "");
-                                }
-                                fBridgeComponent = null;
-                        }
-                        fExternalUriReferenceTranslator = null;
+                        killConnection();
+                }
+        }
+
+        /** Tue cette connection qui pourra ensuite être relancée. */
+        void killConnection() throws Exception {
+                fComponentContext = null;
+                fServiceMgr = null;
+                fComponentLoader = null;
+                if (fBridgeComponent != null) {
+                        try {
+                                fBridgeComponent.dispose();
+                        } catch (Exception e) {
+                                LogMgr.publishException(e);
+                        }
+                        fBridgeComponent = null;
+                }
+                fExternalUriReferenceTranslator = null;
+                if (fOoProcess != null) {
                         fOoProcess.destroy();
                         fOoProcess = null;
-                        fUsageCount = 0;
-                }
+                        removeConnectionToShutdown(this);
+                }
+                fUsageCount = 0;
         }
 
@@ -374 +431 @@
                                 fBridgeComponent.dispose();
                         } catch (Exception e) {
-                                LogMgr.publishException(e, "");
+                                LogMgr.publishException(e);
                         }
                 }
@@ -521 +578 @@
                         fOoProcess = Runtime.getRuntime().exec(vCmdArray);
 
+                        //Mémorisation de cette connection server à faire tomber au shutdown de la jvm.
+                        addConnectionToShutdown(this);
+
                         if (sDebug) {
                                 pipe(fOoProcess.getInputStream(), System.out, "CO> ");
@@ -564 +624 @@
          * On est informé par le serveur oo de son arrêt.
          *
-         */
-        public synchronized void disposing(EventObject pArg0) {
+         * FIXME utile ? OoConnection n'est pas ThreadSafe, or cette
+         * méthode serait par nature appelée en asynchrone...
+         */
+        public void disposing(EventObject pArg0) {
                 LogMgr.publishTrace("Oo server shutdown.");
                 fComponentContext = null;
@@ -574 +636 @@
         }
 
+        public String toString() {
+                return fPipeMode ? "OoConnection pipe mode : " + fPipeName : "OoConnection socket mode : " + fHost + ":" + fPort;
+        }
 }