EarServiceImpl.java

package org.objectweb.jonas.ear;

import java.io.File;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
import java.security.Policy;
import java.util.ArrayList;
import java.util.Date;
import java.util.Enumeration;
import java.util.HashSet;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.StringTokenizer;
import java.util.Vector;

import javax.management.InstanceAlreadyExistsException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.NotCompliantMBeanException;
import javax.management.ObjectName;
import javax.management.modelmbean.ModelMBean;
import javax.naming.Context;
import javax.naming.NamingException;
import javax.security.jacc.PolicyConfiguration;
import javax.security.jacc.PolicyConfigurationFactory;
import javax.security.jacc.PolicyContextException;

import org.apache.commons.modeler.ManagedBean;
import org.apache.commons.modeler.Registry;
import org.objectweb.jonas.client.AppClientModule;
import org.objectweb.jonas.common.JModule;
import org.objectweb.jonas.common.JProp;
import org.objectweb.jonas.common.Log;
import org.objectweb.jonas.container.EJBService;
import org.objectweb.jonas.container.EJBServiceImpl;
import org.objectweb.jonas.ear.lib.EarClassPathManager;
import org.objectweb.jonas.ear.lib.EarClassPathManagerException;
import org.objectweb.jonas.ear.lib.JarList;
import org.objectweb.jonas.ear.lib.JarListException;
import org.objectweb.jonas.jmx.J2eeObjectName;
import org.objectweb.jonas.jmx.JmxService;
import org.objectweb.jonas.jmx.JonasObjectName;
import org.objectweb.jonas.management.JonasMBeanTools;
import org.objectweb.jonas.naming.CompNamingContext;
import org.objectweb.jonas.resource.ResourceService;
import org.objectweb.jonas.resource.ResourceServiceException;
import org.objectweb.jonas.security.jacc.JPolicyUserRoleMapping;
import org.objectweb.jonas.server.JClassLoader;
import org.objectweb.jonas.server.LoaderManager;
import org.objectweb.jonas.service.AbsServiceImpl;
import org.objectweb.jonas.service.ServiceException;
import org.objectweb.jonas.service.ServiceManager;
import org.objectweb.jonas.web.JWebContainerService;
import org.objectweb.jonas.web.JWebContainerServiceException;
import org.objectweb.jonas.ws.AbsWebServicesServiceImpl;
import org.objectweb.jonas.ws.WSServiceException;
import org.objectweb.jonas.ws.WebServicesService;
import org.objectweb.jonas_client.deployment.api.ClientContainerDeploymentDesc;
import org.objectweb.jonas_client.deployment.api.ClientContainerDeploymentDescException;
import org.objectweb.jonas_client.deployment.lib.wrapper.ClientManagerWrapper;
import org.objectweb.jonas_ear.deployment.api.EarDeploymentDesc;
import org.objectweb.jonas_ear.deployment.api.EarDeploymentDescException;
import org.objectweb.jonas_ear.deployment.lib.wrapper.EarManagerWrapper;
import org.objectweb.jonas_ear.deployment.xml.Web;

import org.objectweb.jonas_ejb.deployment.lib.wrapper.EjbManagerWrapper;
import org.objectweb.jonas_lib.deployment.work.CleanerException;
import org.objectweb.jonas_lib.deployment.work.DeployerLog;
import org.objectweb.jonas_lib.deployment.work.DeployerLogException;
import org.objectweb.jonas_lib.deployment.work.EarCleanTask;
import org.objectweb.jonas_lib.deployment.work.EarFileManager;
import org.objectweb.jonas_lib.deployment.work.FileManagerException;
import org.objectweb.jonas_lib.deployment.work.WorkCleaner;
import org.objectweb.jonas_lib.loader.ClientClassLoader;
import org.objectweb.jonas_lib.loader.EjbJarClassLoader;
import org.objectweb.jonas_web.deployment.lib.wrapper.WebManagerWrapper;
import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public class EarServiceImpl extends AbsServiceImpl implements EarService, EarServiceImplMBean {

    protected static final String JONAS_BASE = JProp.getJonasBase();

    protected static final String APPS_DIR = JONAS_BASE + File.separator + "apps";

    protected static final String WORK_DIR = JProp.getWorkDir();

    protected static final String WORK_APPS_DIR = WORK_DIR + File.separator + "apps";

    protected static final String DESCRIPTORS = "jonas.service.ear.descriptors";

    protected static final String AUTOLOADDIR = "jonas.service.ear.autoloaddir";

    protected static final String PARSINGWITHVALIDATION = "jonas.service.ear.parsingwithvalidation";

    protected static final String CLASS = "jonas.service.ear.class";

    private static Logger logger = null;

    private static WorkCleaner workCleaner = null;

    private MBeanServer mbeanServer = null;

    private Vector earNames = new Vector();

    private EJBService ejbService = null;

    private JWebContainerService webContainerService = null;

    private WebServicesService wsService = null;

    private ResourceService resourceService = null;

    private Hashtable ears = null;

    private ArrayList autoloadDirectories = new ArrayList();

    private DeployerLog earDeployerLog = null;

    private ClassLoader appsClassLoader;

    protected void doInit(Context ctx) throws ServiceException {

        //we init the logger
        logger = Log.getLogger(Log.JONAS_EAR_PREFIX);

        // get apps ClassLoader
        try {
            LoaderManager lm = LoaderManager.getInstance();
            appsClassLoader = lm.getAppsLoader();
        } catch (Exception e) {
            logger.log(BasicLevel.ERROR, "Cannot get the Applications ClassLoader from EAR Container Service: " + e);
            throw new ServiceException("Cannot get the Applications ClassLoader from EAR Container Service", e);
        }

        ServiceManager sm  = null;

        try {
            sm = ServiceManager.getInstance();
        } catch (Exception e) {
            String err = "Cannot get ServiceManager instance";
            logger.log(BasicLevel.ERROR, err);
            throw new ServiceException(err, e);
        }

        // Get the JMX Server via JMX Service
        try {
            mbeanServer = ((JmxService) sm.getJmxService()).getJmxServer();
        } catch (ServiceException e) {
            // the JMX service may not be started
            mbeanServer = null;
        }

        // Get the EJB service
        try {
            ejbService = (EJBService) sm.getEjbService();
        } catch (ServiceException e) {
            //not started
            ejbService = null;
        }

        // Get the Web Container service
        try {
            webContainerService = (JWebContainerService) sm.getWebContainerService();
        } catch (ServiceException e) {
            //not started
            webContainerService = null;
        }

        // Get the WebServices service
        try {
            wsService = (WebServicesService) sm.getWebServicesService();
        } catch (ServiceException e) {
            //not started
            wsService = null;
        }

        // Get the Resource service
        try {
            resourceService = (ResourceService) sm.getResourceService();
        } catch (ServiceException e) {
            //not started
            resourceService = null;
        }

        // Set the XML parsing mode to no validation
        String parsingMode = "false";
        try {
            parsingMode = (String) ctx.lookup(PARSINGWITHVALIDATION);
        } catch (NamingException e) {
            /*
             * No problem if there is no value for 'parsingwithvalidation'
             * (false by default)
             */
            logger.log(BasicLevel.DEBUG, "No XML parsing validation property, use default");
        }
        EarManagerWrapper.setParsingWithValidation("true".equalsIgnoreCase(parsingMode));
        if ("false".equalsIgnoreCase(parsingMode)) {
            logger.log(BasicLevel.DEBUG, "Ear XML parsing without validation");
        } else {
            logger.log(BasicLevel.DEBUG, "Ear XML parsing with validation");
        }

        // Init the ear names to be loaded when starting
        String descsValue = null;
        try {
            descsValue = (String) ctx.lookup(DESCRIPTORS);
        } catch (NamingException e) {
            logger.log(BasicLevel.DEBUG, "No property DESCRIPTORS");
            // No problem if there is no value for 'descriptors'
            //(no ear to load)
        }
        if (descsValue != null) {
            StringTokenizer st = new StringTokenizer(descsValue, ",");
            while (st.hasMoreTokens()) {
                String fileName = st.nextToken().trim();
                earNames.add(fileName);
            }
        }

        // Add the ears of the jonas.service.ear.autoloaddir property
        String dirValue = null;
        ArrayList autoDirs = new ArrayList();
        try {
            dirValue = (String) ctx.lookup(AUTOLOADDIR);
        } catch (NamingException e) {
            logger.log(BasicLevel.DEBUG, "No AUTOLOADDIR property");
            // No problem if there is no value for 'autoloaddir'
            //(no ear to load)
        }
        if (dirValue != null) {
            StringTokenizer st = new StringTokenizer(dirValue, ",");
            while (st.hasMoreTokens()) {
                String dirName = st.nextToken().trim();
                addEars(dirName);
                autoDirs.add(dirName);
            }
        }
        // Build autoload directories
        File oFile;
        Iterator it = autoDirs.iterator();
        while (it.hasNext()) {
            String dirName = (String) it.next();
            try {
                oFile = new File(APPS_DIR, dirName);
                if (!oFile.exists()) {
                    oFile = new File(dirName);
                }
                if (oFile.exists()) {
                    autoloadDirectories.add(oFile.getCanonicalPath());
                }
            } catch (Exception e) {
                String err = "Error when trying to verify Application EAR autoload directory : " + dirName;
                logger.log(BasicLevel.ERROR, err + " " + e.getMessage());
            }
        }

        //create hashtable of the ears ( Url of an ear ---> Ear structure)
        ears = new Hashtable();

        // Init the rar deployment desc manager.
        //rarDDManager = RarDeploymentDescManager.getInstance();
    }

    protected void doStop() throws ServiceException {

        //undeploy the loaded ears files
        URL earFileName = null;
        //For each ear file, we delegate the operation to the
        //unDeployEar method
        for (Enumeration earEntries = ears.keys(); earEntries.hasMoreElements();) {
            earFileName = (URL) earEntries.nextElement();
            //Try to undeploy the ear
            try {
                Context ctx = new CompNamingContext(earFileName.getFile());
                ctx.rebind("filename", earFileName);
                unDeployEar(ctx);
            } catch (Exception e) {
                //We don't stop the process of undeploying the ears.
                //We only display an error in the logger.
                String err = "Error when undeploying the ear :" + earFileName;
                logger.log(BasicLevel.ERROR, err + e.getMessage());
            }
        }

        if (mbeanServer != null) {
            try {
                // unregister EarService MBean : EarServiceImplMBean
                mbeanServer.unregisterMBean(JonasObjectName.earService());
            } catch (Exception e) {
                logger.log(BasicLevel.ERROR, "Cannot stop the EarService: " + e.getMessage());
            }
        }

        //The service is stopped
        logger.log(BasicLevel.DEBUG, "EarService stopped");

    }

    public String deployEar(Context ctx) throws EarServiceException {

        //We have one of the ejb or web services launched
        if ((webContainerService == null) && (ejbService == null)) {
            throw new EarServiceException(
                    "The ear service requires that at least the service ejb or web is launched for deploying an ear file.");
        }

        //We get the fileName
        // Get the file name and check if file exists
        String fileName;
        try {
            fileName = (String) ctx.lookup("filename");
        } catch (NamingException e) {
            throw new EarServiceException("Error during performing lookup a fileName", e);
        }

        File f = null;
        try {
            //We search the file
            f = new File(fileName).getCanonicalFile();

            if (!f.exists()) {
                boolean found = false;
                String earFileName = null;
                if (fileName.toLowerCase().endsWith(".ear")) {
                    // In case of the name is a ear file name, check also in
                    // the JONAS_BASE/apps directory
                    earFileName = APPS_DIR + File.separator + fileName;
                    f = new File(earFileName).getCanonicalFile();
                    found = f.exists();
                }
                if (found) {
                    fileName = earFileName;
                } else {
                    String err = "deployEar: The file " + fileName
                            + " was not found neither in the current directory nor in the " + APPS_DIR + " directory";
                    logger.log(BasicLevel.ERROR, err);
                    throw new EarServiceException(err);
                }
            }
        } catch (IOException e) {
            String err = "Error when trying to get the canonical file from " + fileName;
            logger.log(BasicLevel.ERROR, err + " " + e.getMessage());
            throw new EarServiceException(err, e);
        }

        //Make the url for the specified fileName and the earRootUrl
        URL[] earUrl = new URL[1];
        URL earRootUrl = null;

        try {
            earUrl[0] = f.toURL();
            earRootUrl = (new File(WORK_APPS_DIR + File.separator + getJonasServerName())).toURL();
        } catch (MalformedURLException e) {
            String err = "Invalid ear file name '" + fileName;
            logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
            throw new EarServiceException(err, e);
        }

        //Check if the ear is already deployed or not
        if (ears.get(earUrl[0]) != null) {
            String err = "The ear file : " + f.getName() + " is already deployed ('" + earUrl[0].getFile()
                    + "'). You must undeploy the application " + "before a new deployment.";
            logger.log(BasicLevel.ERROR, err);
            throw new EarServiceException(err);
        }

        //Create classLoader
        //parent classloader is the current classloader
        URLClassLoader loaderCls = new URLClassLoader(earUrl, appsClassLoader);

        EarDeploymentDesc earDD = null;
        logger.log(BasicLevel.DEBUG, "Getting the deployment descriptor of the file" + f.getName());
        try {
            earDD = EarManagerWrapper.getDeploymentDesc(earUrl[0].getFile(), loaderCls);
        } catch (EarDeploymentDescException e) {
            String err = "Error in the Deployment descriptor '" + fileName + "': " + e;
            logger.log(BasicLevel.ERROR, err);
            throw new EarServiceException(err, e);
        }

        //We get the tags from the Deployment descriptor
        Web[] webTags = earDD.getWebTags();
        String[] ejbTags = earDD.getEjbTags();
        String[] connectorTags = earDD.getConnectorTags();
        String[] clientTags = earDD.getClientTags();
        String[] altDDClients = earDD.getAltDDClients();
        String[] altDDEjbs = earDD.getAltDDEjbs();
        String[] altDDWebs = earDD.getAltDDWebs();
        String[] altDDConnectors = earDD.getAltDDConnectors();
        String[] securityRoles = earDD.getSecurityRolesNames();

        //Check if all modules are inside the EAR file
        //no relatives mode like ../../file1.jar

        File fEar = new File(earUrl[0].getFile());
        File tmpFile = null;

        try {
            File fCanonicEar = fEar.getCanonicalFile();
            for (int i = 0; i < ejbTags.length; i++) {
                tmpFile = new File(fEar, ejbTags[i]);
                tmpFile = tmpFile.getCanonicalFile();
                if (!tmpFile.getPath().startsWith(fCanonicEar.getPath())) {
                    String err = "Error : The ejb-jar file " + ejbTags[i] + " is not inside the ear file " + fEar;
                    logger.log(BasicLevel.ERROR, err);
                    throw new EarServiceException(err);
                }
            }

            for (int i = 0; i < webTags.length; i++) {
                tmpFile = new File(fEar, webTags[i].getWebUri());
                tmpFile = tmpFile.getCanonicalFile();
                if (!tmpFile.getPath().startsWith(fCanonicEar.getPath())) {
                    String err = "Error : The war file " + webTags[i].getWebUri() + " is not inside the ear file "
                            + fEar;
                    logger.log(BasicLevel.ERROR, err);
                    throw new EarServiceException(err);
                }
            }

            for (int i = 0; i < connectorTags.length; i++) {
                tmpFile = new File(fEar, connectorTags[i]);
                tmpFile = tmpFile.getCanonicalFile();
                if (!tmpFile.getPath().startsWith(fCanonicEar.getPath())) {
                    String err = "Error : The rar file " + connectorTags[i] + " is not inside the ear file " + fEar;
                    logger.log(BasicLevel.ERROR, err);
                    throw new EarServiceException(err);
                }
            }


            for (int i = 0; i < clientTags.length; i++) {
                tmpFile = new File(fEar, clientTags[i]);
                tmpFile = tmpFile.getCanonicalFile();

                if (!tmpFile.getPath().startsWith(fCanonicEar.getPath())) {
                    String err = "Error : The client jar file " + clientTags[i] + " is not inside the ear file " + fEar;
                    throw new EarServiceException(err);
                }
            }
        } catch (IOException ioe) {
            String err = "Error while trying to get the canonical file of " + tmpFile;
            logger.log(BasicLevel.ERROR, err + " : " + ioe.getMessage());
            throw new EarServiceException(err, ioe);
        }

        //Changing array into JarList
        JarList ejbsList = new JarList(ejbTags);
        JarList warsList = new JarList(webTags);
        JarList connectorsList = new JarList(connectorTags);
        JarList clientsList = new JarList(clientTags);

        //Unpack the ear file and get the unpacked dir
        URL dirUnpackURL = null;
        try {
            dirUnpackURL = EarFileManager.unpackEar(earUrl[0], earRootUrl);
        } catch (FileManagerException e) {
            String err = "Error while unpacking the file '" + earUrl[0] + "'";
            logger.log(BasicLevel.ERROR, err + " : " + e.getMessage());
            throw new EarServiceException(err, e);
        }

        //the file is unpacked. Log it only if the ear is a file and not a
        // directory
        if (new File(earUrl[0].getFile()).isFile()) {
            try {
                earDeployerLog.addEntry(new File(earUrl[0].getFile()), new File(dirUnpackURL.getFile()));
            } catch (DeployerLogException e) {
                String err = "Error while adding the " + earUrl[0] + " entry in the log file";
                logger.log(BasicLevel.ERROR, err + " : " + e.getMessage());
                throw new EarServiceException(err, e);
            }
        }

        //We have successfully unpacked the ear file, now we analyze manifest
        // Class-path:
        EarClassPathManager earCPManager = null;
        try {
            earCPManager = new EarClassPathManager(ejbsList, warsList, dirUnpackURL);
        } catch (EarClassPathManagerException e) {
            String err = "Error while creating the Ear class path manager of the ear : '" + earUrl[0] + "'";
            logger.log(BasicLevel.ERROR, err + " : " + e.getMessage());
            throw new EarServiceException(err, e);
        }

        URL[] classpathURLs = null;
        //Get the urls of the ear class path manager
        try {
            classpathURLs = earCPManager.getResolvedClassPath();
        } catch (EarClassPathManagerException e) {
            String err = "Error while trying to resolve the classpath of the ejbjars and wars of the ear : '"
                    + earUrl[0] + "'";
            logger.log(BasicLevel.ERROR, err + " : " + e.getMessage());
            throw new EarServiceException(err, e);
        }

        /*
         * We have the urls to load at our level We can now create our
         * classLoader
         */
        logger.log(BasicLevel.DEBUG, "Creating the EAR classLoader");
        JClassLoader earClassLoader = new JClassLoader(earUrl[0].toExternalForm() , new URL[0], appsClassLoader);

        //Extract the urls of the jarList
        URL[] jarUrls = null;
        URL[] warUrls = null;
        URL[] connectorUrls = null;
        URL[] clientUrls = null;
        try {
            jarUrls = ejbsList.getURLs(dirUnpackURL.toExternalForm());
            warUrls = warsList.getURLs(dirUnpackURL.toExternalForm());
            connectorUrls = connectorsList.getURLs(dirUnpackURL.toExternalForm());
            clientUrls = clientsList.getURLs(dirUnpackURL.toExternalForm());
        } catch (JarListException e) {
            String err = "Error while geting the Urls from jarlist of the ear : '" + earUrl[0] + "'";
            logger.log(BasicLevel.ERROR, err + " : " + e.getMessage());
            throw new EarServiceException(err, e);
        }

        //Extract context roots for wars
        //They are in webTags. Dump into warsContextRoots
        String[] warsContextRoots = new String[webTags.length];
        String ctxRoot = null;
        for (int i = 0; i < webTags.length; i++) {
            ctxRoot = webTags[i].getContextRoot();
            if (ctxRoot != null) {
                warsContextRoots[i] = ctxRoot;
            }
        }

        //Fill Alt-DD for Ejbs and Wars and Rars
        String altdd = null;
        File fAltDD = null;

        //Transorm the array altDDWebs into an array with the absolute URL to
        // the file
        URL[] warsAltDDs = new URL[altDDWebs.length];
        for (int i = 0; i < altDDWebs.length; i++) {
            if (altDDWebs[i] != null) {
                altdd = altDDWebs[i];
                if (altdd != null) {
                    try {
                        fAltDD = new File(new URL(dirUnpackURL.toExternalForm() + File.separator + altdd).getFile());
                        warsAltDDs[i] = fAltDD.getCanonicalFile().toURL();
                    } catch (MalformedURLException e) {
                        String err = "Can't build URL for alt-dd '" + altdd;
                        logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                        throw new EarServiceException(err, e);
                    } catch (IOException ioe) {
                        String err = "Can't get canonicalFile() for the file '" + fAltDD;
                        logger.log(BasicLevel.ERROR, err + "': " + ioe.getMessage());
                        throw new EarServiceException(err, ioe);
                    }
                }
            }
        }

        URL[] ejbsAltDDs = new URL[altDDEjbs.length];
        for (int i = 0; i < altDDEjbs.length; i++) {
            if (altDDEjbs[i] != null) {
                altdd = altDDEjbs[i];
                if (altdd != null) {
                    try {
                        fAltDD = new File(new URL(dirUnpackURL.toExternalForm() + File.separator + altdd).getFile());
                        ejbsAltDDs[i] = fAltDD.getCanonicalFile().toURL();
                    } catch (MalformedURLException e) {
                        String err = "Can't build URL for alt-dd '" + altdd;
                        logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                        throw new EarServiceException(err, e);
                    } catch (IOException ioe) {
                        String err = "Can't get canonicalFile() for the file '" + fAltDD;
                        logger.log(BasicLevel.ERROR, err + "': " + ioe.getMessage());
                        throw new EarServiceException(err, ioe);
                    }
                }
            }
        }

        URL[] connectorsAltDDs = new URL[altDDConnectors.length];
        for (int i = 0; i < altDDConnectors.length; i++) {
            if (altDDConnectors[i] != null) {
                altdd = altDDConnectors[i];
                if (altdd != null) {
                    try {
                        fAltDD = new File(new URL(dirUnpackURL.toExternalForm() + File.separator + altdd).getFile());
                        connectorsAltDDs[i] = fAltDD.getCanonicalFile().toURL();
                    } catch (MalformedURLException e) {
                        String err = "Can't build URL for alt-dd '" + altdd;
                        logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                        throw new EarServiceException(err, e);
                    } catch (IOException ioe) {
                        String err = "Can't get canonicalFile() for the file '" + fAltDD;
                        logger.log(BasicLevel.ERROR, err + "': " + ioe.getMessage());
                        throw new EarServiceException(err, ioe);
                    }
                }
            }
        }

        URL[] clientAltDDs = new URL[altDDClients.length];
        for (int i = 0; i < altDDClients.length; i++) {
            if (altDDClients[i] != null) {
                altdd = altDDClients[i];
                if (altdd != null) {
                    try {
                        fAltDD = new File(new URL(dirUnpackURL.toExternalForm() + File.separator + altdd).getFile());
                        clientAltDDs[i] = fAltDD.getCanonicalFile().toURL();
                    } catch (MalformedURLException e) {
                        String err = "Can't build URL for alt-dd '" + altdd;
                        logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                        throw new EarServiceException(err, e);
                    } catch (IOException ioe) {
                        String err = "Can't get canonicalFile() for the file '" + fAltDD;
                        logger.log(BasicLevel.ERROR, err + "': " + ioe.getMessage());
                        throw new EarServiceException(err, ioe);
                    }
                }
            }
        }
        //Extract roles name from the securityRole array
        String[] roleNames = new String[securityRoles.length];
        String affRoleNames = "";
        for (int i = 0; i < securityRoles.length; i++) {
            roleNames[i] = securityRoles[i];
            affRoleNames += roleNames[i] + ";";
        }

        logger.log(BasicLevel.DEBUG, "role names = " + affRoleNames);

        // Set the list of the ejb-jar, war and clients that can do an ejb-link in this
        // ear application. This array can be empty.
        // The alternate urls are given
        EjbManagerWrapper.setAvailableEjbJarsAndAltDDs(earClassLoader, jarUrls, ejbsAltDDs);
        WebManagerWrapper.setAltDD(earClassLoader, warUrls, warsAltDDs);
        ClientManagerWrapper.setAltDD(earClassLoader, clientUrls, clientAltDDs);

        // Construct the ejb classloader for all the ejb-jars of the same
        // ear application. Because there is one ejb classloader for all
        // the ejb-jars of the same ear application.
        URL[] urls = new URL[jarUrls.length + classpathURLs.length];
        System.arraycopy(jarUrls, 0, urls, 0, jarUrls.length);
        System.arraycopy(classpathURLs, 0, urls, jarUrls.length, classpathURLs.length);
        URLClassLoader ejbClassLoader;
        try {
            ejbClassLoader = new EjbJarClassLoader(urls, earClassLoader);
        } catch (IOException ioe) {
            String err = "Cannot Create EJB ClassLoader for EAR '" + fileName + "'";
            logger.log(BasicLevel.ERROR, err + " : " + ioe.getMessage());
            throw new EarServiceException(err, ioe);
        }

        // Set the list of the rars that can be referenced in this
        // ear application. This array can be empty.
        // The alternate urls are given

        //rarDDManager.setAvailableRarsAndAltDDs(earClassLoader, connectorUrls,
        // connectorsAltDDs);

        //Only if the connectorUrls is not empty
        //And if the service is started
        if (resourceService != null && (connectorUrls.length > 0)) {
            try {
                CompNamingContext contctx = null;
                try {
                    contctx = new CompNamingContext(dirUnpackURL.getFile());
                    contctx.rebind("earUrl", earUrl[0]);
                    contctx.rebind("urls", connectorUrls);
                    contctx.rebind("earClassLoader", earClassLoader);
                    contctx.rebind("altDDs", connectorsAltDDs);
                } catch (NamingException e) {
                    String err = "Can not bind params for the resource service, Can't deploy rars ";
                    throw new ResourceServiceException(err, e);
                }
                resourceService.deployRars(contctx);
            } catch (ServiceException e) {
                String err = "Error during the deployment of the rars files of the Ear file " + fileName;
                logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                //remove DDesc
                //resourceService.removeCache(earClassLoader);
                throw new EarServiceException(err, e);
            }
        }

        // Only if the WebServicesService is started
        if (wsService != null) {
            try {
                Hashtable ctxRoots = new Hashtable();
                for (int w = 0; w < webTags.length; w++) {
                    ctxRoots.put(warUrls[w], webTags[w].getContextRoot());
                }
                CompNamingContext contctx = null;
                try {
                    contctx = new CompNamingContext(dirUnpackURL.getFile());
                    contctx.rebind("unpackDir", dirUnpackURL.toExternalForm());
                    contctx.rebind("jarUrls", jarUrls);
                    contctx.rebind("warUrls", warUrls);
                    contctx.rebind("earURL", earUrl[0]);
                    contctx.rebind("ejbClassLoader", ejbClassLoader);
                    contctx.rebind("earClassLoader", earClassLoader);
                    contctx.rebind("warCtxRootMapping", ctxRoots);
                } catch (NamingException e) {
                    String err = "Cannot bind params for the WebServices service, Can't deploy Web Services Endpoints ";
                    throw new WSServiceException(err, e);
                }
                wsService.deployWebServices(contctx);
            } catch (ServiceException se) {
                String err = "Error during the deployment of the WebServices of the Ear file " + fileName;
                logger.log(BasicLevel.ERROR, err + " : " + se.getMessage());
                wsService.removeCache(earClassLoader);
                try {
                    logger.log(BasicLevel.DEBUG, "Undeploying Rars of the ear " + fileName);
                    if (resourceService != null && connectorUrls.length > 0) {
                        // remove Resource
                        resourceService.unDeployRars(connectorUrls, earUrl[0]);
                    }
                } catch (ServiceException se2) {
                    err = "Error during the undeployment of the rars files of the Ear file " + fileName;
                    logger.log(BasicLevel.ERROR, err + "': " + se2.getMessage());
                }

                throw new EarServiceException(err, se);
            }
        }

        // ejbClassLoader created above

        //Only if the jarUrls is not empty
        //And if the service is started
        if (ejbService != null && (jarUrls.length > 0)) {
            try {
                CompNamingContext contctx = null;
                try {
                    contctx = new CompNamingContext(dirUnpackURL.getFile());
                    contctx.rebind("earRootUrl", dirUnpackURL);
                    contctx.rebind("earUrl", earUrl[0]);
                    contctx.rebind("jarURLs", jarUrls);
                    contctx.rebind("earClassLoader", earClassLoader);
                    contctx.rebind("ejbClassLoader", ejbClassLoader);
                    contctx.rebind("roleNames", roleNames);
                } catch (NamingException e) {
                    String err = "Can not bind params for the ejb service, Can't deploy jars ";
                    throw new EarServiceException(err, e);
                }
                ejbService.deployJars(contctx);
            } catch (ServiceException e) {
                String err = "Error during the deployment of the jars files of the Ear file " + fileName;
                logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                //remove DDesc
                ejbService.removeCache(earClassLoader);
                // Remove the deployed rars
                if (resourceService != null && connectorUrls.length > 0) {
                    // remove Resource
                    resourceService.unDeployRars(connectorUrls, earUrl[0]);
                }
                throw new EarServiceException(err, e);
            }
        }

        /*
         * We have deploy the ejb-jar files if the service is active And we have
         * the ejbClassLoader
         */

        /*
         * We're going to deploy wars Parent ClassLoader for web container is
         * ejbclassloader if ejbService is active, and a classloader with the
         * visibility of jar file if ejbservice is not active.
         */

        ClassLoader parentWarClassLoader = ejbClassLoader;

        //Only if the warUrls is not empty
        //And if the service is started
        if (webContainerService != null && (warUrls.length > 0)) {
            try {
                CompNamingContext contctx = null;
                try {
                    contctx = new CompNamingContext(dirUnpackURL.getFile());
                    contctx.rebind("earURL", earUrl[0]);
                    contctx.rebind("urls", warUrls);
                    contctx.rebind("parentClassLoader", parentWarClassLoader);
                    contctx.rebind("earClassLoader", earClassLoader);
                    contctx.rebind("altDDs", warsAltDDs);
                    contctx.rebind("contextRoots", warsContextRoots);
                } catch (NamingException e) {
                    String err = "Can not bind params for the web container service, Can't deploy wars ";
                    throw new EarServiceException(err, e);
                }
                webContainerService.deployWars(contctx);

            } catch (JWebContainerServiceException e) {
                String err = "Error during the deployment of the wars file of the Ear file " + fileName;
                logger.log(BasicLevel.ERROR, err + "': " + e.getMessage());
                //remove DDesc
                webContainerService.removeCache(earClassLoader);
                err = "Undeploy the jars loaded from this ear";
                logger.log(BasicLevel.DEBUG, err);
                try {
                    if (ejbService != null && (jarUrls.length > 0)) {
                        //remove DDesc
                        ejbService.removeCache(earClassLoader);
                        //remove the ejbs
                        ejbService.unDeployJars(jarUrls);
                    }
                    // Remove the deployed rars
                    if (resourceService != null && connectorUrls.length > 0) {
                        // remove Resource
                        resourceService.unDeployRars(connectorUrls, earUrl[0]);
                    }
                } catch (ServiceException se) {
                    err = "Error during the undeployment of the jars file of the Ear file " + fileName;
                    logger.log(BasicLevel.ERROR, err + "': " + se.getMessage());
                    throw new EarServiceException(err, e);
                }

                throw new EarServiceException(err, e);
            }
        }

        // Link the JACC policy configuration objects of EJB and WebApp together and commit them to be available.
        linkPolicyObjects(earDD.getUserToRoleMapping(), jarUrls, warUrls);

       logger.log(BasicLevel.DEBUG, "We store the rars/wars/jars associated to the url :" + earUrl[0]);

        // Complete the Deployment of the WebServices
        // Only if the WebServicesService is started
        if (wsService != null) {
            try {
                CompNamingContext contctx = null;
                try {
                    contctx = new CompNamingContext(earRootUrl.getFile());
                    contctx.rebind(AbsWebServicesServiceImpl.CLASSLOADER_CTX_PARAM, earClassLoader);
                } catch (NamingException e) {
                    String err = "Can not bind params for the WebServices service, "
                            + "can't complete deployment of Web Services Endpoints";
                    throw new JWebContainerServiceException(err, e);
                }
                wsService.completeWSDeployment(contctx);
            } catch (ServiceException se) {
                String err = "Error during the deployment of the WebServices of the Ear file '" + earRootUrl + "'";
                logger.log(BasicLevel.ERROR, err + " : " + se.getMessage());
                try {
                    logger.log(BasicLevel.DEBUG, "Undeploy the WebApps loaded from this ear");
                    if (webContainerService != null && (warUrls.length > 0)) {
                        //remove DDesc
                        webContainerService.removeCache(earClassLoader);
                        //remove the webapps
                        webContainerService.unDeployWars(warUrls);
                    }
                    logger.log(BasicLevel.DEBUG, "Undeploy the EjbJars loaded from this ear");
                    if (ejbService != null && (jarUrls.length > 0)) {
                        //remove DDesc
                        ejbService.removeCache(earClassLoader);
                        //remove the ejbs
                        ejbService.unDeployJars(jarUrls);
                    }
                    // Remove the deployed rars
                    logger.log(BasicLevel.DEBUG, "Undeploy the Resources loaded from this ear");
                    if (resourceService != null && connectorUrls.length > 0) {
                        // remove Resource
                        resourceService.unDeployRars(connectorUrls, earUrl[0]);
                    }
                } catch (ServiceException se2) {
                    err = "Error during the undeployment of the webapps/ejbjars/rars file of the Ear file " + fileName;
                    logger.log(BasicLevel.ERROR, err + "': " + se2.getMessage());
                }
                throw new JWebContainerServiceException(err, se);
            }
        }


        // Management support
        // ------------------

        // Build the 'name' used to construct the J2EEApplication ObjectName
        String sJ2EEApplicationName = buildJ2eeApplicationName(earUrl[0]);

        // Create AppClientModule MBeans first
        AppClientModule[] appClientModules = null;
        ObjectName[] onAppClientModules = null;
        if (clientUrls.length > 0) {
            appClientModules = new AppClientModule[clientUrls.length];
            onAppClientModules = new ObjectName[clientUrls.length];
        }

        String moduleName = null;
        String moduleFileName = null;
        String moduleDD = null;
        String jonasModuleDD = null;
        ClientContainerDeploymentDesc clientContainerDD = null;
        for (int i = 0; i < clientUrls.length; i++) {
            ClassLoader moduleCL = null;
            try {
                moduleCL = new ClientClassLoader(clientUrls[i], ejbClassLoader);
            } catch (IOException ioe) {
                // fail case :
                // we use the ejbjar classloader, but the descriptor loading will fail
                moduleCL = ejbClassLoader;
                // TODO Find a better Exception handling ?
            }
            moduleName =  EJBServiceImpl.buildEJBModuleName(clientUrls[i]);
            moduleFileName = clientUrls[i].getPath();
            try {
                clientContainerDD = ClientManagerWrapper.getDeploymentDesc(clientUrls[i], moduleCL, earClassLoader);
                moduleDD = clientContainerDD.getXmlContent();
                jonasModuleDD = clientContainerDD.getJOnASXmlContent();
            } catch (ClientContainerDeploymentDescException e) {
                // make debug trace
                String err = "Cannot read the deployment descriptors ': " + clientUrls[i] + "'" + e.toString();
                logger.log(BasicLevel.ERROR, err);
            }
            onAppClientModules[i] = J2eeObjectName.getAppClientModule(getDomainName(), getJonasServerName(), sJ2EEApplicationName, moduleName);
            appClientModules[i] = new AppClientModule(onAppClientModules[i].toString()
                    , moduleFileName
                    , moduleDD
                    , jonasModuleDD);
        }
        URL clientUrl = null;
        try {
            if (mbeanServer != null) {
                Registry oRegistry = JonasMBeanTools.getRegistry();
                ManagedBean oManaged = null;
                ModelMBean oMBean = null;
                // Register AppClientModule MBeans
                if (appClientModules != null) {
                    oManaged = oRegistry.findManagedBean("AppClientModule");
                    for (int i = 0; i < appClientModules.length; i++) {
                        clientUrl = clientUrls[i];
                        oMBean = oManaged.createMBean(appClientModules[i]);
                        mbeanServer.registerMBean(oMBean, onAppClientModules[i]);
                    }
                }
            }
        } catch (Exception eare) {
            logger.log(BasicLevel.ERROR, "Can not register the MBean for the client jar " + clientUrl + " :"
                    + eare.getMessage());
        }

        // Remove the Deployment descriptors
        if (ejbService != null) {
            ejbService.removeCache(earClassLoader);
        }

        if (webContainerService != null) {
            webContainerService.removeCache(earClassLoader);
        }

        if (wsService != null) {
            wsService.removeCache(earClassLoader);
        }

        // Create J2EEApplication MBeans
        ObjectName onEar = J2eeObjectName.J2EEApplication(getDomainName(), getJonasServerName(), sJ2EEApplicationName);
        // Store the ejb-jar, war and the rar urls associated with the ear URL
        // in case of success deploy
        Ear ear = new Ear(onEar.toString(), sJ2EEApplicationName, dirUnpackURL.getFile(), earUrl[0], earDD.getXmlContent(), jarUrls, warUrls,
                connectorUrls);

        try {
            if (mbeanServer != null) {
                Registry oRegistry = JonasMBeanTools.getRegistry();
                ManagedBean oManaged = oRegistry.findManagedBean("J2EEApplication");
                ModelMBean oMBean = oManaged.createMBean(ear);
                // Register Ear MBean (all the J2EEModule MBeans are already registered
                mbeanServer.registerMBean(oMBean, onEar);
            }
        } catch (Exception eare) {
            logger.log(BasicLevel.ERROR, "Can not register the MBean for the ear " + earUrl[0] + " :"
                    + eare.getMessage());
        }


        ears.put(earUrl[0], ear);

        logger.log(BasicLevel.INFO, "Ear " + earUrl[0] + " available.");

        //set the timestamp dir
        File dirUnpackFile = new File(dirUnpackURL.getFile());
        dirUnpackFile.setLastModified((new Date()).getTime());

        // return ObjectName of the J2EEApplication MBean
        return onEar.toString();
    }

    public String deployEar(String fileName) throws Exception {
        return deployEarMBean(fileName);
    }

    public String deployEarMBean(String fileName) throws Exception {
        Context ctx = null;
        String mbeanOn = null;
        try {
            ctx = new CompNamingContext(fileName);
            ctx.rebind("filename", fileName);
        } catch (NamingException e) {
            String err = "Error when deploying the ear file ";
            logger.log(BasicLevel.ERROR, err + e.getMessage());
            throw e;
        }
        try {
            mbeanOn = deployEar(ctx);
        } catch (ServiceException e) {
            System.out.println("in ServiceException: " + e.getMessage());
            throw new Exception("in ServiceException: " + e.getMessage(), e);
        }
        return mbeanOn;
    }

    protected void doStart() throws ServiceException {

        //url
        URL earApps = null;
        try {
            earApps = new File(WORK_APPS_DIR + File.separator + getJonasServerName()).toURL();
        } catch (MalformedURLException mue) {
            throw new ServiceException("Error when trying to get the URL of the jonasroot/apps directory", mue);
        }

        File fLog = new File(earApps.getFile() + File.separator + getJonasServerName() + ".log");
        if (!fLog.exists()) {
            try {
                //create
                fLog.getParentFile().mkdirs();
                fLog.createNewFile();
            } catch (IOException e) {
                throw new ServiceException("cannot create the log file" + fLog, e);
            }
        }

        //get the logger
        try {
            earDeployerLog = new DeployerLog(fLog);
        } catch (DeployerLogException e) {
            throw new ServiceException("Can not get an EarDeployerLog", e);
        }

        // create the ear deployment work file control task
        EarCleanTask earCleanTask = new EarCleanTask(earApps, earDeployerLog);

        //get the cleaner ref
        workCleaner = WorkCleaner.getInstance();

        // add the ear deployment work file control task
        try {
            workCleaner.registerTask(earCleanTask);
        } catch (CleanerException ce) {
            throw new ServiceException("Cannot register the EAR clean task", ce);
        }

        // force the cleaning now
        workCleaner.executeTasks();

        // Deploy all ear which are in descriptors section
        Iterator it = earNames.iterator();
        while (it.hasNext()) {
            String fileName = (String) it.next();
            Context contctx = null;
            try {
                contctx = new CompNamingContext(fileName);
                contctx.rebind("filename", fileName);
            } catch (NamingException e) {
                throw new ServiceException("Cannot start the EarService", e);
            }
            deployEar(contctx);
        }

        try {
            // Register EarService MBean : EarServiceImplMBean
            if (mbeanServer != null) {
                mbeanServer.registerMBean(this, JonasObjectName.earService());
            }
        } catch (InstanceAlreadyExistsException iae) {
            throw new ServiceException("Cannot start the EarService Already Exists", iae);
        } catch (MBeanRegistrationException mbre) {
            throw new ServiceException("Cannot start the EarService (MBean registration error)", mbre);
        } catch (NotCompliantMBeanException ncmbe) {
            throw new ServiceException("Cannot start the EarService (MBean Not compliant error)", ncmbe);
        }
    }

    public void unDeployEar(Context ctx) throws EarServiceException {

        //Get the ear url param which we want to undeploy
        URL earUrl = null;
        try {
            earUrl = (URL) ctx.lookup("filename");
        } catch (NamingException e) {
            throw new EarServiceException("Trying to remove the ear file but there is no filename specified", e);
        }

        //This ear is in loaded EARs files ?
        Ear ear = (Ear) ears.get(earUrl);

        //Not loaded
        if (ear == null) {
            throw new EarServiceException("Trying to remove the ear file " + earUrl.getFile()
                    + " but this file was not found in the loaded Ear files");
        }

        //undeploy wars if the web container service is started
        URL[] warsToUndeploy = ear.getWars();
        if (webContainerService != null && (warsToUndeploy.length > 0)) {
            webContainerService.unDeployWars(warsToUndeploy);
        }

        //undeploy jars if the ejb service is started
        URL[] jarsToUndeploy = ear.getEjbJars();
        if (ejbService != null && (jarsToUndeploy.length > 0)) {
            ejbService.unDeployJars(jarsToUndeploy);
        }

        //undeploy rars if the resource service is started
        URL[] rarsToUndeploy = ear.getRars();
        if (resourceService != null && (rarsToUndeploy.length > 0)) {
            resourceService.unDeployRars(rarsToUndeploy, earUrl);
        }

        File f = new File(earUrl.getFile());
        //Undeploy successful, we remove the ear

        //Only if there is no Exception !
        ears.remove(earUrl);
        //unregister mbean
        if (mbeanServer != null) {
            // Build the ObjectName if the ear's MBea
            //String sJ2EEApplicationName = buildJ2eeApplicationName(earUrl);
            //ObjectName onEar =
            // J2eeObjectName.J2EEApplication(getDomainName(),
            // getJonasServerName(), sJ2EEApplicationName);
            // Un-regsiter the MBean
            try {
                // unregister J2EEApplication
                ObjectName onJ2EEApplication = ObjectName.getInstance(ear.getObjectName());
                String appName = onJ2EEApplication.getKeyProperty("name");
                String domainName = onJ2EEApplication.getDomain();
                String serverName = onJ2EEApplication.getKeyProperty("J2EEServer");
                mbeanServer.unregisterMBean(onJ2EEApplication);
                // ubregister the AppClientModules, if any
                ObjectName onAppClientModules = J2eeObjectName.getAppClientModules(domainName, serverName, appName);
                ArrayList onList = (ArrayList) J2eeObjectName.queryObjectNames(onAppClientModules);
                for (int i = 0; i < onList.size(); i++) {
                    mbeanServer.unregisterMBean((ObjectName) onList.get(i));
                }
            } catch (Exception e) {
                logger.log(BasicLevel.ERROR, "Cannot remove the MBean for the ear " + earUrl.getFile() + " : "
                        + e.getMessage());
            }
        }

        logger.log(BasicLevel.INFO, "Ear " + f.getName() + " no longer available.");

    }

    public void unDeployEar(String fileName) throws Exception {
        unDeployEarMBean(fileName);
    }

    public void unDeployEarMBean(String fileName) throws Exception {

        /*
         * We have only the name of the file, not its associated path, so we
         * look in the current directory and in the ear applications directory
         */

        //We check if the url exists in the hashtable
        //compare: First in the current dir, after in the apps directory
        URL url = null;
        URL earUrl = null;
        boolean found = false;
        try {
            Enumeration e = ears.keys();
            url = new File(fileName).getCanonicalFile().toURL();
            while (e.hasMoreElements() && !found) {
                earUrl = (URL) e.nextElement();
                if (earUrl.equals(url)) {
                    //We have found
                    found = true;
                }
            }

            if (fileName.toLowerCase().endsWith(".ear") && !found) {
                // In case of the name is an ear check also in
                // the JONAS_BASE/apps directory
                String earFileName = APPS_DIR + File.separator + fileName;
                e = ears.keys();
                url = new File(earFileName).getCanonicalFile().toURL();
                while (e.hasMoreElements() && !found) {
                    earUrl = (URL) e.nextElement();
                    if (earUrl.equals(url)) {
                        //We have found
                        found = true;
                    }
                }
            }
            if (!found) {
                String err = "Cannot undeploy the ear '" + fileName + "', it is not deployed.";
                logger.log(BasicLevel.ERROR, err);
                throw new Exception(err);
            }
        } catch (MalformedURLException mue) {
            String err = "Error when trying to get the url from" + fileName;
            logger.log(BasicLevel.ERROR, err + mue.getMessage());
            throw new Exception(err, mue);
        } catch (IOException ioe) {
            String err = "Error when trying to get the canonical file from " + fileName;
            logger.log(BasicLevel.ERROR, err + ioe.getMessage());
            throw new Exception(err, ioe);
        }

        //We've got the file, now we bind the params
        Context ctx = null;
        try {
            ctx = new CompNamingContext(fileName);
            //The fileName is an url
            ctx.rebind("filename", url);
        } catch (NamingException e) {
            String err = "Error when binding parameters";
            logger.log(BasicLevel.ERROR, err + e.getMessage());
            throw new Exception(err, e);
        }

        //Call the function
        try {
            unDeployEar(ctx);
        } catch (EarServiceException e) {
            throw new Exception(e);
        }

    }

    public Integer getCurrentNumberOfEars() {
        return new Integer(ears.size());
    }

    public List getInstalledEars() throws Exception {
        // get EAR files found in JONAS_BASE/apps
        ArrayList al = JModule.getInstalledContainersInDir(APPS_DIR, JModule.EAR_EXTENSION, JModule.EAR_CHILD_DIR,
                JModule.EAR_CONFIRM_FILE);
        // get EAR files found in all autoload directories
        Iterator it = autoloadDirectories.iterator();
        while (it.hasNext()) {
            String name = (String) it.next();
            al.addAll(JModule.getInstalledContainersInDir(name, JModule.EAR_EXTENSION, JModule.EAR_CHILD_DIR,
                    JModule.EAR_CONFIRM_FILE));
        }
        return al;
    }

    public Set getEarNames() {
        HashSet names = new HashSet();
        URL earUrl = null;
        for (Enumeration e = ears.keys(); e.hasMoreElements();) {
            earUrl = (URL) e.nextElement();
            names.add(earUrl.getFile());
        }
        return names;
    }

    private void addEars(String dirPath) {
        boolean found = false;

        // Look the directory relative to where the JOnAS server is launch or
        // if the path is absolute.
        File dir = new File(dirPath);
        found = dir.isDirectory();

        if (!found) {
            // Look the directory relative to the $JONAS_BASE/apps directory
            dir = new File(APPS_DIR + File.separator + dirPath);
            found = dir.isDirectory();
        }

        if (found) {
            addEarsFrom(dir);
        } else {
            String err = "Warning: Cannot load dir: '" + dirPath + "' ";
            err += "is not a directory or directory doesn't exist";
            logger.log(BasicLevel.WARN, err);
        }
    }

    private void addEarsFrom(File dir) throws EarServiceException {
        try {
            if (dir.isDirectory()) {
                File[] files = dir.listFiles();
                for (int i = 0; i < files.length; i++) {
                    if (files[i].getPath().toLowerCase().endsWith(".ear")) {
                        earNames.add(files[i].getCanonicalPath());
                    } else {
                        if (files[i].isDirectory()) {
                            addEarsFrom(files[i]);
                        }
                    }
                }
            } else {
                String err = "Cannot load dir: '" + dir.getPath();
                err += "' is not a directory";
                logger.log(BasicLevel.ERROR, err);
                throw new EarServiceException(err);
            }
        } catch (IOException e) {
            String err = "Invalid file name '" + dir.getPath();
            logger.log(BasicLevel.ERROR, err);
            throw new EarServiceException(err, e);
        }
    }

    public boolean isEarLoaded(String fileName) {

        URL url = null;
        boolean isLoaded = false;
        try {
            // Absolute filename
            try {
                url = new File(fileName).getCanonicalFile().toURL();
                //Check if the ear is already deployed or not
                if (ears.get(url) != null) {
                    isLoaded = true;
                } else {
                    // Not found force to test in relative Apps directory
                    url = null;
                }
            } catch (Exception e) {
                url = null;
            }
            // Relative filename
            if (url == null) {
                url = new File(APPS_DIR + File.separator + fileName).getCanonicalFile().toURL();
                //Check if the ear is already deployed or not
                if (ears.get(url) != null) {
                    isLoaded = true;
                }
            }
        } catch (Exception e) {
            String err = "Can not found if the ear is deployed or not";
            logger.log(BasicLevel.ERROR, err);
            return false;
        }

        return isLoaded;
    }

    public Boolean isEarDeployed(String fileName) {
        return new Boolean(isEarLoaded(fileName));
    }

    public boolean isEarDeployedByUnpackName(String unpackName) {
        logger.log(BasicLevel.DEBUG, "entering for unpackName= " + unpackName);
        // for each ear loaded
        Enumeration lc = ears.elements();
        while (lc.hasMoreElements()) {
            Ear ear = (Ear) lc.nextElement();

            // get unpack name of the ear
            String deployedUnpackName = new File(ear.getUnpackName()).getName();
            logger.log(BasicLevel.DEBUG, "deployedUnpackName=" + deployedUnpackName);

            if (deployedUnpackName.equals(unpackName)) {
                return true;
            }
            // else, go to the next loop
        }
        // not found
        return false;
    }


    public List getDeployedEars() {
        ArrayList al = new ArrayList();
        Ear oEar;
        URL oURL;
        for (Enumeration enumEars = ears.elements(); enumEars.hasMoreElements();) {
            oEar = (Ear) enumEars.nextElement();
            oURL = oEar.getEarUrl();
            al.add(oURL.getFile());
        }
        return al;
    }

    public List getDeployableEars() throws Exception {
        List al = getInstalledEars();
        al.removeAll(getDeployedEars());
        return al;
    }

    public List getAutoloadDirectories() {
        ArrayList al = new ArrayList();
        Iterator it = autoloadDirectories.iterator();
        while (it.hasNext()) {
            String fileName = (String) it.next();
            try {
                al.add(new File(fileName).toURL().getPath());
            } catch (Exception e) {
                logger.log(BasicLevel.DEBUG, "Can't get autoload directories : " + e.getMessage());
            }
        }
        return al;
    }

    public String getAppsDirectory() {
        String sRet = null;
        try {
            sRet = (new File(APPS_DIR)).toURL().getPath();
        } catch (Exception e) {
            throw new RuntimeException("Cannot get the APPS directory", e);
        }
        return sRet;
    }

    public static String buildJ2eeApplicationName(URL pUrl) {
        String sName = null;
        try {
            sName = new File(pUrl.getFile()).getName();
            if ("file".equals(pUrl.getProtocol())) {
                sName = buildJ2eeApplicationName(sName);
            }
        } catch (NullPointerException e) {
            if (logger != null) {
                logger.log(BasicLevel.DEBUG, "Can't build j2ee application : " + e.getMessage());
            }
        }
        return sName;
    }

    public static String buildJ2eeApplicationName(String pFilename) {
        String sName = null;
        try {
            sName = new File(pFilename).getName();
            int iPos = sName.lastIndexOf('.');
            if (iPos > -1) {
                sName = sName.substring(0, iPos);
            }
        } catch (NullPointerException e) {
            if (logger != null) {
                logger.log(BasicLevel.DEBUG, "Can't build j2ee application : " + e.getMessage());
            }
        }
        return sName;
    }

    private void linkPolicyObjects(Map userToRoleMapping, URL[] jarUrls, URL[] warUrls) throws EarServiceException {
        String[] ctxIDs = new String[jarUrls.length + warUrls.length];
        // Get contextID of EJB
        for (int u = 0; u < jarUrls.length; u++) {
            ctxIDs[u] = ejbService.getContainer(jarUrls[u].getFile()).getContextId();
        }
        // Now for WebApp
        for (int u = 0; u < warUrls.length; u++) {
            ctxIDs[u + jarUrls.length] = webContainerService.getWar(warUrls[u]).getContextId();
        }

        PolicyConfigurationFactory pcFactory = null;
        try {
            pcFactory = PolicyConfigurationFactory.getPolicyConfigurationFactory();
        } catch (Exception cnfe) {
            String err = "Cannot retrieve current policy configuration factory";
            logger.log(BasicLevel.ERROR, err + "': " + cnfe.getMessage());
            throw new EarServiceException(err, cnfe);
        }

        try {
            // Now link the policy configuration objects
            for (int cId = 0; cId < ctxIDs.length; cId++) {
                String toBeLinkedCtxId = ctxIDs[cId];
                PolicyConfiguration toBeLinkedPC = pcFactory.getPolicyConfiguration(toBeLinkedCtxId, false);
                for (int linkCId = 0; linkCId < ctxIDs.length; linkCId++) {
                    String linkedCtxId = ctxIDs[linkCId];
                    if (!toBeLinkedCtxId.equals(linkedCtxId)) {
                        PolicyConfiguration linkedPC = pcFactory.getPolicyConfiguration(linkedCtxId, false);
                        toBeLinkedPC.linkConfiguration(linkedPC);
                    }
                }
            }
        } catch (PolicyContextException pce) {
            String err = "Cannot retrieve a policy configuration";
            logger.log(BasicLevel.ERROR, err + "': " + pce.getMessage());
            throw new EarServiceException(err, pce);
        }

        // Do user-to-role mapping
        if (userToRoleMapping != null) {
            for (int cId = 0; cId < ctxIDs.length; cId++) {
                for (Iterator itMapping = userToRoleMapping.keySet().iterator(); itMapping.hasNext();) {
                    String principalName = (String) itMapping.next();
                    List roles = (List) userToRoleMapping.get(principalName);
                    String[] roleNames = (String[]) roles.toArray(new String[roles.size()]);
                    JPolicyUserRoleMapping.addUserToRoleMapping(ctxIDs[cId], principalName, roleNames);
                }
            }

        }


        String ctxId = null;
        try {
            // And to finish, commit the policy configuration objects
            for (int cId = 0; cId < ctxIDs.length; cId++) {
                ctxId = ctxIDs[cId];
                PolicyConfiguration pc = pcFactory.getPolicyConfiguration(ctxId, false);
                pc.commit();
            }
        } catch (PolicyContextException pce) {
            String err = "Cannot commit policy configuration with Id '" + ctxId + "'";
            logger.log(BasicLevel.ERROR, err + "': " + pce.getMessage());
            throw new EarServiceException(err, pce);
        }

        // refresh policy
        Policy.getPolicy().refresh();
    }

}

---