org/objectweb/proactive/core/descriptor/services/FaultToleranceService.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.services;

import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;

import org.apache.log4j.Logger;
import org.objectweb.proactive.core.ProActiveException;
import org.objectweb.proactive.core.body.ft.servers.resource.ResourceServer;
import org.objectweb.proactive.core.node.Node;
import org.objectweb.proactive.core.runtime.ProActiveRuntime;
import org.objectweb.proactive.core.util.log.Loggers;
import org.objectweb.proactive.core.util.log.ProActiveLogger;


public class FaultToleranceService implements UniversalService {
    public static final String FT_SERVICE_NAME = "Fault-Tolerance Service";
    public static final String DEFAULT_PARAM_LINE = "-Dproactive.ft=disable";

    // logger
    protected static Logger logger = ProActiveLogger.getLogger(Loggers.FAULT_TOLERANCE);

    // protocol Type
    private String protocolType;

    // fault tolerance servers
    private String recoveryProcessURL;
    private String checkpointServerURL;
    private String locationServerURL;
    private String globalServerURL; // priority on the 3 upper values

    // fault tolerance values
    private String ttcValue;

    // attached ressource server
    private String attachedResourceServer; // null if not registred has a ressource node

    public FaultToleranceService() {
        super();
    }

    public ProActiveRuntime[] startService() throws ProActiveException {
        return null;
    }

    public String getServiceName() {
        return FaultToleranceService.FT_SERVICE_NAME;
    }

    public String buildParamsLine() {
        StringBuffer line = new StringBuffer("-Dproactive.ft=enable");
        if (this.getGlobalServerURL() != null) {
            if ((this.getCheckpointServerURL() != null) ||
                    (this.getLocationServerURL() != null) ||
                    (this.getRecoveryProcessURL() != null)) {
                logger.warn(
                    "A global server is set : other servers are ignored !!");
            }
            line.append(" -Dproactive.ft.server.global=" +
                this.getGlobalServerURL());
        } else {
            line.append(" -Dproactive.ft.server.checkpoint=" +
                this.getCheckpointServerURL());
            line.append(" -Dproactive.ft.server.recovery=" +
                this.getRecoveryProcessURL());
            line.append(" -Dproactive.ft.server.location=" +
                this.getLocationServerURL());
        }

        if (this.getTtcValue() != null) {
            line.append(" -Dproactive.ft.ttc=" + this.getTtcValue());
        }
        if (this.getAttachedResourceServer() != null) {
            line.append(" -Dproactive.ft.server.resource=" +
                this.getAttachedResourceServer());
        }
        if (this.getProtocolType() != null) {
            line.append(" -Dproactive.ft.protocol=" + this.getProtocolType());
        }
        if (logger.isDebugEnabled()) {
            logger.debug("FT config is : " + line);
        }
        return line.toString();
    }

    public boolean registerRessources(Node[] nodes) {
        if (this.getAttachedResourceServer() != null) {
            try {
                ResourceServer rs = (ResourceServer) (Naming.lookup(this.getAttachedResourceServer()));
                for (int i = 0; i < nodes.length; i++) {
                    rs.addFreeNode(nodes[i]);
                }
                return true;
            } catch (MalformedURLException e) {
                logger.error(
                    "**ERROR** RessourceServer unreachable : ressource is not registred." +
                    e);
            } catch (RemoteException e) {
                logger.error(
                    "**ERROR** RessourceServer unreachable : ressource is not registred" +
                    e);
            } catch (NotBoundException e) {
                logger.error(
                    "**ERROR** RessourceServer unreachable : ressource is not registred" +
                    e);
            }
            return false;
        } else {
            return false;
        }
    }

    // Getters and setters
    public String getAttachedResourceServer() {
        return attachedResourceServer;
    }

    public void setAttachedResourceServer(String attachedRessourceServer) {
        this.attachedResourceServer = attachedRessourceServer;
    }

    public String getCheckpointServerURL() {
        return checkpointServerURL;
    }

    public void setCheckpointServerURL(String checkpointServerURL) {
        this.checkpointServerURL = checkpointServerURL;
    }

    public String getGlobalServerURL() {
        return globalServerURL;
    }

    public void setGlobalServerURL(String globalServerURL) {
        this.globalServerURL = globalServerURL;
    }

    public String getLocationServerURL() {
        return locationServerURL;
    }

    public void setLocationServerURL(String locationServerURL) {
        this.locationServerURL = locationServerURL;
    }

    public String getRecoveryProcessURL() {
        return recoveryProcessURL;
    }

    public void setRecoveryProcessURL(String recoveryProcessURL) {
        this.recoveryProcessURL = recoveryProcessURL;
    }

    public String getTtcValue() {
        return ttcValue;
    }

    public void setTtcValue(String ttcValue) {
        this.ttcValue = ttcValue;
    }

    public String getProtocolType() {
        return protocolType;
    }

    public void setProtocolType(String protocolType) {
        this.protocolType = protocolType;
    }
}

---