org/objectweb/proactive/core/process/AbstractSequentialListProcessDecorator.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.process;

import org.objectweb.proactive.core.descriptor.services.UniversalService;
import org.objectweb.proactive.core.process.filetransfer.FileTransferWorkShop;
import org.objectweb.proactive.core.util.RemoteProcessMessageLogger;

import java.util.ArrayList;


public abstract class AbstractSequentialListProcessDecorator
    implements ExternalProcessDecorator {
    boolean isFirstElementService = false;

    //Array of processes
    protected ArrayList processes;

    // position of the next process to return  
    protected int currentProcessRank = 0;

    public AbstractSequentialListProcessDecorator() {
        processes = new ArrayList();
    }

    public void addProcessToList(ExternalProcess process) {
        this.processes.add(process);
    }

    public void addServiceToList(UniversalService service) {
        this.processes.add(service);
    }

    public void addProcessToList(int rank, ExternalProcess process) {
        this.processes.add(rank, process);
    }

    public void addServiceToList(int rank, UniversalService service) {
        this.processes.add(rank, service);
    }

    public ExternalProcess getFirstProcess() {
        currentProcessRank++;
        return (ExternalProcess) processes.get(0);
    }

    public UniversalService getFirstService() {
        currentProcessRank++;
        return (UniversalService) processes.get(0);
    }

    public ExternalProcess getNextProcess() {
        ExternalProcess res = null;
        if (currentProcessRank < processes.size()) {
            res = (ExternalProcess) processes.get(currentProcessRank);
            currentProcessRank++;
        }
        return res;
    }

    //
    //--------------------------Implements ExternalProcessDecorator----------------------

    public ExternalProcess getTargetProcess() {
        return ((ExternalProcessDecorator) processes.get(currentProcessRank)).getTargetProcess();
    }

    public void setTargetProcess(ExternalProcess targetProcess) {
        ((ExternalProcessDecorator) processes.get(currentProcessRank)).setTargetProcess(targetProcess);
    }

    public int getCompositionType() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getCompositionType();
    }

    public void setCompositionType(int compositionType) {
        ((ExternalProcessDecorator) processes.get(currentProcessRank)).setCompositionType(compositionType);
    }

    public FileTransferWorkShop getFileTransferWorkShopRetrieve() {

        /* TODO Check if this is the correct place
         * implement this. Then implement it
         */
        return null;
    }

    public FileTransferWorkShop getFileTransferWorkShopDeploy() {

        /* TODO Check if this is the correct place
         * implement this. Then implement it
         */
        return null;
    }

    public void startFileTransfer() {

        /* TODO Check if this is the correct place
         * implement this. Then implement it
         */
    }

    public boolean isRequiredFileTransferDeployOnNodeCreation() {

        /* TODO Check if this is the correct place
         * implement this. Then implement it
         */
        return false;
    }

    public void closeStream() {
        ((ExternalProcess) processes.get(currentProcessRank)).closeStream();
    }

    public RemoteProcessMessageLogger getInputMessageLogger() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getInputMessageLogger();
    }

    public RemoteProcessMessageLogger getErrorMessageLogger() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getErrorMessageLogger();
    }

    public MessageSink getOutputMessageSink() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getOutputMessageSink();
    }

    public void setInputMessageLogger(
        RemoteProcessMessageLogger inputMessageLogger) {
        for (int i = 0; i < processes.size(); i++) {
            ((ExternalProcess) processes.get(i)).setInputMessageLogger(inputMessageLogger);
        }
    }

    public void setErrorMessageLogger(
        RemoteProcessMessageLogger errorMessageLogger) {
        for (int i = 0; i < processes.size(); i++) {
            ((ExternalProcess) processes.get(i)).setErrorMessageLogger(errorMessageLogger);
        }
    }

    public void setOutputMessageSink(MessageSink outputMessageSink) {
        for (int i = 0; i < processes.size(); i++) {
            ((ExternalProcess) processes.get(i)).setOutputMessageSink(outputMessageSink);
        }
    }

    public String[] getEnvironment() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getEnvironment();
    }

    public void setEnvironment(String[] environment) {
        ((ExternalProcess) processes.get(currentProcessRank)).setEnvironment(environment);
    }

    public String getUsername() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getUsername();
    }

    public void setUsername(String username) {
        ((ExternalProcess) processes.get(currentProcessRank)).setUsername(username);
    }

    public String getCommand() {
        return null;
    }

    public String getProcessId() {
        return "ps";
    }

    public int getNodeNumber() {
        return ((ExternalProcessDecorator) processes.get(currentProcessRank)).getNodeNumber();
    }

    public UniversalProcess getFinalProcess() {
        return ((ExternalProcessDecorator) processes.get(currentProcessRank)).getFinalProcess();
    }

    public ArrayList getListProcess() {
        return this.processes;
    }

    public void stopProcess() {
        ((ExternalProcess) processes.get(currentProcessRank)).stopProcess();
    }

    public int waitFor() throws InterruptedException {
        int status = 0;
        status = ((ExternalProcess) processes.get(currentProcessRank)).waitFor();
        return status;
    }

    public boolean isStarted() {
        boolean started = true;
        started = ((ExternalProcess) processes.get(currentProcessRank)).isStarted();
        return started;
    }

    public boolean isFinished() {
        boolean finished = true;
        finished = ((ExternalProcess) processes.get(currentProcessRank)).isFinished();
        return finished;
    }

    public boolean isSequential() {
        return true;
    }

    public void setCommandPath(String path) {
        ((ExternalProcess) processes.get(currentProcessRank)).setCommandPath(path);
    }

    public String getCommandPath() {
        return ((ExternalProcess) processes.get(currentProcessRank)).getCommandPath();
    }

    //
    //-----------------protected methods----------------------------------------
    //
    protected abstract ExternalProcess createProcess();

    public int exitValue() throws IllegalThreadStateException {
        // TODO Auto-generated method stub
        return 0;
    }

    public void setStarted(boolean isStarted) {
        // TODO Auto-generated method stub
    }

    public void setFinished(boolean isStarted) {
        // TODO Auto-generated method stub
    }

    public boolean isFirstElementIsService() {
        return isFirstElementService;
    }

    public void setFirstElementIsService(boolean isFirstElementIsService) {
        this.isFirstElementService = isFirstElementIsService;
    }
}

---