org.objectweb.proactive.ext.scilab.monitor
Class ScilabService

java.lang.Object
  org.objectweb.proactive.ext.scilab.monitor.ScilabService

All Implemented Interfaces:

java.io.Serializable

public class ScilabService
extends java.lang.Object
implements java.io.Serializable

This class is used to offer a set of services: 1. to deploy, activate, and manage Scilab Engines over the Grid, 2. to execute and kill tasks 3. to retrieve results, 4. to notify the user application of each event.

Author:

ProActive Team (amangin)

See Also:

Serialized Form

Constructor Summary

ScilabService()
constructor

Method Summary

void	addEventListenerEngine(SciEventListener evtListener)
void	addEventListenerTask(SciEventListener evtListener)
void	cancelTask(java.lang.String idTask) Cancel a pending task
int	deployEngine(java.lang.String nameVirtualNode, java.lang.String pathDescriptor)
int	deployEngine(java.lang.String nameVirtualNode, java.lang.String pathDescriptor, int nbEngine)
int	deployEngine(java.lang.String nameVirtualNode, java.lang.String pathDescriptor, java.lang.String[] arrayIdEngine) Deploy engines over each node defined in the the file descriptor
void	exit() exit the monitor and free each deployed engine
java.util.ArrayList<SciTaskInfo>	getListTaskWait()
java.util.HashMap<java.lang.String,SciEngineInfo>	getMapEngine()
java.util.HashMap<java.lang.String,SciTaskInfo>	getMapTaskEnd()
java.util.HashMap<java.lang.String,SciTaskInfo>	getMapTaskRun()
int	getNbEngine()
SciTaskInfo	getTaskEnd(java.lang.String idTask)
void	killTask(java.lang.String idTask) Kill a running task
void	removeAllEventListenerEngine()
void	removeAllEventListenerTask()
void	removeEventListenerEngine(SciEventListener evtListener)
void	removeEventListenerTask(SciEventListener evtListener)
void	removeTask(java.lang.String idTask) Remove a terminated task
void	restartEngine(java.lang.String idEngine) Restart a Scilab Engine
void	sendTask(SciTask sciTask) Put the task in a queue of pending tasks.
void	sendTask(java.lang.String pathScript, java.lang.String jobInit, java.lang.String[] dataOut)
void	sendTask(java.lang.String pathScript, java.lang.String jobInit, java.lang.String[] dataOut, int Priority)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScilabService

public ScilabService()

constructor

Method Detail

deployEngine

public int deployEngine(java.lang.String nameVirtualNode,
                        java.lang.String pathDescriptor,
                        java.lang.String[] arrayIdEngine)

Deploy engines over each node defined in the the file descriptor

Parameters:

nameVirtualNode -

pathDescriptor -

arrayIdEngine -

Returns:

the number of deployed engine

deployEngine

public int deployEngine(java.lang.String nameVirtualNode,
                        java.lang.String pathDescriptor)

deployEngine

public int deployEngine(java.lang.String nameVirtualNode,
                        java.lang.String pathDescriptor,
                        int nbEngine)

sendTask

public void sendTask(SciTask sciTask)

Put the task in a queue of pending tasks. The task will be sent when a Scilab Engine will be free. An event notify the user application of the effective sending .

Parameters:

sciTask -

sendTask

public void sendTask(java.lang.String pathScript,
                     java.lang.String jobInit,
                     java.lang.String[] dataOut)
              throws java.io.IOException

Throws:

java.io.IOException

sendTask

public void sendTask(java.lang.String pathScript,
                     java.lang.String jobInit,
                     java.lang.String[] dataOut,
                     int Priority)
              throws java.io.IOException

Throws:

java.io.IOException

killTask

public void killTask(java.lang.String idTask)

Kill a running task

Parameters:

idTask -

restartEngine

public void restartEngine(java.lang.String idEngine)

Restart a Scilab Engine

Parameters:

idEngine -

cancelTask

public void cancelTask(java.lang.String idTask)

Cancel a pending task

Parameters:

idTask -

removeTask

public void removeTask(java.lang.String idTask)

Remove a terminated task

Parameters:

idTask -

addEventListenerTask

public void addEventListenerTask(SciEventListener evtListener)

addEventListenerEngine

public void addEventListenerEngine(SciEventListener evtListener)

removeEventListenerTask

public void removeEventListenerTask(SciEventListener evtListener)

removeAllEventListenerTask

public void removeAllEventListenerTask()

removeAllEventListenerEngine

public void removeAllEventListenerEngine()

removeEventListenerEngine

public void removeEventListenerEngine(SciEventListener evtListener)

getTaskEnd

public SciTaskInfo getTaskEnd(java.lang.String idTask)

Parameters:

idTask - of the terminated task

Returns:

return the task

getNbEngine

public int getNbEngine()

Returns:

the number of deployed engine

getMapTaskEnd

public java.util.HashMap<java.lang.String,SciTaskInfo> getMapTaskEnd()

Returns:

a Map of terminated task

getMapTaskRun

public java.util.HashMap<java.lang.String,SciTaskInfo> getMapTaskRun()

Returns:

a Map of running task

getMapEngine

public java.util.HashMap<java.lang.String,SciEngineInfo> getMapEngine()

Returns:

a Map of Deployed Engine

getListTaskWait

public java.util.ArrayList<SciTaskInfo> getListTaskWait()

Returns:

a List of pending tasks

exit

public void exit()

exit the monitor and free each deployed engine