The SUMO toolbox  2018a
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Pages
Public Member Functions | Protected Member Functions | List of all members
RemoteSGEBackend Class Reference

This backend can submit jobs through a remote front end to a SGE cluster. More...

Inheritance diagram for RemoteSGEBackend:
Inheritance graph
[legend]

Public Member Functions

 RemoteSGEBackend ()
 
void cleanup ()
 
void configure (ContextConfig context, NodeConfig config) throws ConfigureException
 
DataSourceStatus getStatus ()
 
int getNumRunning ()
 Get the number of jobs that are currently waiting in the SGE queue. More...
 
int getNumWaiting ()
 Get the number of jobs that are currently waiting in the SGE queue. More...
 
int getNumJobs ()
 Get the number of jobs that are currently in the SGE system. More...
 
Pair< String, Pair< Integer,
Integer > > 
getBestQueue ()
 Return the queue with most available slots. More...
 
void submitJob (Job job) throws Exception
 Submit a job to the SGE middleware. More...
 
void jobFinished (JobEvent event)
 A job is finished, retrieve the necessary files. More...
 
JobPoller getPoller ()
 
void setResultProcessor (ResultProcessor rp)
 
String getUser ()
 
String getFrontNode ()
 
int getFrontNodePort ()
 
String getIdentityFile ()
 
String getKnownHostsFile ()
 
String getLocalDirectory ()
 
String getRemoteDirectory ()
 

Protected Member Functions

void connectToFrontNode () throws IOException
 
SSHWrapper getSSHWrapper ()
 
void setPoller (JobPoller poller)
 
Job getJob (String id)
 
void addJob (String id, Job j)
 
void removeJob (String id)
 
ResultProcessor getResultProcessor ()
 
void setLocalDirectory (String localDirectory)
 
void setRemoteDirectory (String dir)
 

Detailed Description

This backend can submit jobs through a remote front end to a SGE cluster.

This class will also periodically check if a different queue is faster than the current one and switch.

Constructor & Destructor Documentation

RemoteSGEBackend ( )
inline

Member Function Documentation

void addJob ( String  id,
Job  j 
)
inlineprotectedinherited
void cleanup ( )
inline
void configure ( ContextConfig  context,
NodeConfig  config 
) throws ConfigureException
inline
void connectToFrontNode ( ) throws IOException
inlineprotectedinherited
Pair<String, Pair<Integer, Integer> > getBestQueue ( )
inline

Return the queue with most available slots.

String getFrontNode ( )
inlineinherited
int getFrontNodePort ( )
inlineinherited
String getIdentityFile ( )
inlineinherited
Job getJob ( String  id)
inlineprotectedinherited
String getKnownHostsFile ( )
inlineinherited
String getLocalDirectory ( )
inlineinherited
int getNumJobs ( )
inline

Get the number of jobs that are currently in the SGE system.

int getNumRunning ( )
inline

Get the number of jobs that are currently waiting in the SGE queue.

int getNumWaiting ( )
inline

Get the number of jobs that are currently waiting in the SGE queue.

JobPoller getPoller ( )
inlineinherited
String getRemoteDirectory ( )
inlineinherited
ResultProcessor getResultProcessor ( )
inlineprotectedinherited
SSHWrapper getSSHWrapper ( )
inlineprotectedinherited
DataSourceStatus getStatus ( )
inline
String getUser ( )
inlineinherited
void jobFinished ( JobEvent  event)
inline

A job is finished, retrieve the necessary files.

Implements JobFinishedEventListener.

void removeJob ( String  id)
inlineprotectedinherited
void setLocalDirectory ( String  localDirectory)
inlineprotectedinherited
void setPoller ( JobPoller  poller)
inlineprotectedinherited
void setRemoteDirectory ( String  dir)
inlineprotectedinherited
void setResultProcessor ( ResultProcessor  rp)
inlineinherited
void submitJob ( Job  job) throws Exception
inline

Submit a job to the SGE middleware.


The documentation for this class was generated from the following file: