step.grid

Class Grid

java.lang.Object

step.grid.Grid

All Implemented Interfaces:

GridFileService, TokenRegistry

public class Grid
extends Object
implements TokenRegistry, GridFileService

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOCAL_AGENT

Constructor Summary

Constructors

Constructor and Description
Grid(Integer port)
Grid(Integer port, Integer ttl)

Method Summary

Modifier and Type	Method and Description
Collection<AgentRef>	getAgents()
File	getRegisteredFile(String fileHandle) Get a file that has been previously registered to the GRID
int	getServerPort()
List<Token<TokenWrapper>>	getTokens()
protected void	handleRegistrationMessage(RegistrationMessage message)
void	markTokenAsFailing(String tokenId, String errorMessage, Exception e)
String	registerFile(File file) Register a file into the GRID
void	removeTokenError(String tokenId)
void	returnToken(TokenWrapper object)
TokenWrapper	selectToken(Identity pretender, long matchTimeout, long noMatchTimeout)
void	start()
void	startTokenMaintenance(String tokenId)
void	stop()
void	stopTokenMaintenance(String tokenId)

Methods inherited from class java.lang.Object

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

Field Detail

LOCAL_AGENT

public static final String LOCAL_AGENT

See Also:

Constant Field Values

Constructor Detail

Grid

public Grid(Integer port)

Grid

public Grid(Integer port,
            Integer ttl)

Method Detail

stop

public void stop()
          throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Throws:

Exception

handleRegistrationMessage

protected void handleRegistrationMessage(RegistrationMessage message)

selectToken

public TokenWrapper selectToken(Identity pretender,
                                long matchTimeout,
                                long noMatchTimeout)
                         throws TimeoutException,
                                InterruptedException

Specified by:

selectToken in interface TokenRegistry

Throws:

TimeoutException

InterruptedException

returnToken

public void returnToken(TokenWrapper object)

Specified by:

returnToken in interface TokenRegistry

markTokenAsFailing

public void markTokenAsFailing(String tokenId,
                               String errorMessage,
                               Exception e)

Specified by:

markTokenAsFailing in interface TokenRegistry

removeTokenError

public void removeTokenError(String tokenId)

startTokenMaintenance

public void startTokenMaintenance(String tokenId)

stopTokenMaintenance

public void stopTokenMaintenance(String tokenId)

registerFile

public String registerFile(File file)

Description copied from interface: GridFileService

Register a file into the GRID

Specified by:

registerFile in interface GridFileService

Parameters:

file - the file to be registered to the GRID

Returns:

an handle to the registered file. This handle will be used to retrieve the registered file

getRegisteredFile

public File getRegisteredFile(String fileHandle)

Description copied from interface: GridFileService

Get a file that has been previously registered to the GRID

Specified by:

getRegisteredFile in interface GridFileService

Parameters:

fileHandle - the handle returned at regitration

Returns:

the registered file

getTokens

public List<Token<TokenWrapper>> getTokens()

Specified by:

getTokens in interface TokenRegistry

getAgents

public Collection<AgentRef> getAgents()

getServerPort

public int getServerPort()