org/objectweb/proactive/core/descriptor/Launcher.java

/* 
 * ################################################################
 * 
 * ProActive: The Java(TM) library for Parallel, Distributed, 
 *            Concurrent computing with Security and Mobility
 * 
 * Copyright (C) 1997-2007 INRIA/University of Nice-Sophia Antipolis
 * Contact: proactive@objectweb.org
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or any later version.
 *  
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
 * USA
 *  
 *  Initial developer(s):               The ProActive Team
 *                        http://www.inria.fr/oasis/ProActive/contacts.html
 *  Contributor(s): 
 * 
 * ################################################################
 */ 
package org.objectweb.proactive.core.descriptor;

import java.io.IOException;
import java.lang.reflect.InvocationTargetException;

import org.objectweb.proactive.ProActive;
import org.objectweb.proactive.core.ProActiveException;
import org.objectweb.proactive.core.descriptor.data.MainDefinition;
import org.objectweb.proactive.core.descriptor.data.ProActiveDescriptor;
import org.objectweb.proactive.core.descriptor.data.VirtualNode;
import org.objectweb.proactive.core.node.Node;
import org.objectweb.proactive.core.node.NodeException;


public class Launcher {
    private ProActiveDescriptor pad;
    private boolean activated;

    public Launcher(String fileDescriptorPath)
        throws ProActiveException, NodeException {
        // replace spaces by %20 char (hexadecimal space code) to avoid bug with the property
        String filePathWithoutSpaces = fileDescriptorPath.replaceAll(" ", "%20");

        // parse and reify the descriptor
        pad = ProActive.getProactiveDescriptor(filePathWithoutSpaces);
        activated = false;
    }

    public void activate()
        throws ProActiveException, NodeException, ClassNotFoundException, 
            NoSuchMethodException {
        MainDefinition[] mainDefinitions = pad.getMainDefinitions();

        // activate mains
        pad.activateMains();

        // launch the main classes
        for (int i = 0; i < mainDefinitions.length; i++) {
            MainDefinition mainDefinition = mainDefinitions[i];
            VirtualNode[] virtualNodes = mainDefinition.getVirtualNodes();
            for (int j = 0; j < virtualNodes.length; j++) {
                VirtualNode virtualNode = virtualNodes[j];
                Node node = virtualNode.getNode();

                ProActive.newMain(mainDefinition.getMainClass(),
                    mainDefinition.getParameters(), node);
            }
        }
        activated = true;
    }

    public ProActiveDescriptor getProActiveDescriptor() {
        return pad;
    }

    public boolean isActivated() {
        return activated;
    }
}

---