org/objectweb/proactive/branchnbound/ProActiveBranchNBound.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.branchnbound;

import org.apache.log4j.Logger;
import org.objectweb.proactive.ActiveObjectCreationException;
import org.objectweb.proactive.ProActive;
import org.objectweb.proactive.branchnbound.core.Manager;
import org.objectweb.proactive.branchnbound.core.Task;
import org.objectweb.proactive.branchnbound.core.queue.TaskQueue;
import org.objectweb.proactive.core.config.ProActiveConfiguration;
import org.objectweb.proactive.core.descriptor.data.VirtualNode;
import org.objectweb.proactive.core.node.Node;
import org.objectweb.proactive.core.node.NodeException;
import org.objectweb.proactive.core.node.NodeFactory;
import org.objectweb.proactive.core.util.log.Loggers;
import org.objectweb.proactive.core.util.log.ProActiveLogger;


public class ProActiveBranchNBound {
    private static Logger logger = ProActiveLogger.getLogger(Loggers.P2P_SKELETONS);

    static {
        // Loading the ProActive's configuration
        ProActiveConfiguration.load();
    }

    // -------------------------------------------------------------------------
    // Manager static constructor
    // -------------------------------------------------------------------------

    public static Manager newBnB(Task root, Node managerNode, Node[] nodes,
        String queueType) throws ActiveObjectCreationException, NodeException {
        Object[] args = new Object[4];
        args[0] = root;
        args[1] = managerNode;
        args[2] = nodes;
        args[3] = queueType;
        return ProActiveBranchNBound.activingTheManager(args);
    }

    public static Manager newBnB(Task root, VirtualNode virtualNode,
        String queueType) throws ActiveObjectCreationException, NodeException {
        virtualNode.activate();
        Object[] args = new Object[4];
        args[0] = root;
        args[1] = null;
        args[2] = virtualNode.getNodes();
        args[3] = queueType;
        return ProActiveBranchNBound.activingTheManager(args);
    }

    public static Manager newBnB(Task root, Node managerNode, Node[][] nodes,
        String queueType) throws ActiveObjectCreationException, NodeException {
        Object[] args = new Object[4];
        args[0] = root;
        args[1] = managerNode;
        args[2] = nodes;
        args[3] = queueType;
        return ProActiveBranchNBound.activingTheManager(args);
    }

    public static Manager newBnB(Task root, VirtualNode[] virtualNodes,
        String queueType) throws ActiveObjectCreationException, NodeException {
        Object[] args = new Object[4];
        args[0] = root;
        args[1] = null;
        args[2] = virtualNodes;
        args[3] = queueType;
        return ProActiveBranchNBound.activingTheManager(args);
    }

    // -------------------------------------------------------------------------
    // Private methods
    // -------------------------------------------------------------------------

    private static Manager activingTheManager(Object[] args)
        throws ActiveObjectCreationException, NodeException {
        assert args.length == 4 : args;
        if (logger.isDebugEnabled()) {
            logger.debug("New Active Manager with these arguments:\n" + "\t" +
                args[0].getClass().getName() + "\n" + "\t" +
                args[1].getClass().getName() + "\n" + "\t" +
                args[2].getClass().getName() + "\n" + "\t" +
                args[3].getClass().getName() + "\n");
        }
        assert args[0] instanceof Task : args[0];
        args[1] = (args[1] == null) ? NodeFactory.getDefaultNode()
                                    : (Node) args[1];
        assert args[1] instanceof Node : args[1];
        assert args[2] instanceof Node[] || args[2] instanceof Node[][] ||
        args[2] instanceof VirtualNode[] : args[2];
        assert args[3] instanceof String : args[3];

        return (Manager) ProActive.newActive(Manager.class.getName(), args,
            (Node) args[1]);
    }
}

---