Package step.grid

Class GridImpl

java.lang.Object

step.grid.GridImpl

All Implemented Interfaces:

step.grid.Grid, step.grid.GridFileService

public class GridImpl
extends Object
implements step.grid.Grid

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GridImpl.GridImplConfig

Field Summary

Fields inherited from interface step.grid.Grid

LOCAL_AGENT

Constructor Summary

Constructors

Constructor	Description
GridImpl(File fileManagerFolder, Integer port)
GridImpl(File fileManagerFolder, Integer port, GridImpl.GridImplConfig gridConfig)
GridImpl(Integer port)

Method Summary

Modifier and Type	Method	Description
void	cleanupFileManagerCache()
List<step.grid.AgentRef>	getAgents()
step.grid.filemanager.FileVersion	getRegisteredFile(step.grid.filemanager.FileVersionId fileVersionId)
int	getServerPort()
List<step.grid.TokenWrapper>	getTokens()
protected void	handleRegistrationMessage(step.grid.agent.RegistrationMessage message)
void	markTokenAsFailing(String tokenId, String errorMessage, Exception e)
step.grid.filemanager.FileVersion	registerFile(File file)
step.grid.filemanager.FileVersion	registerFile(InputStream inputStream, String fileName, boolean isDirectory)
void	removeTokenError(String tokenId)
void	returnToken(String tokenId)
step.grid.TokenWrapper	selectToken(Map<String,String> attributes, Map<String,step.grid.tokenpool.Interest> interests, long matchTimeout, long noMatchTimeout, step.grid.TokenWrapperOwner tokenOwner)
void	start()
void	startTokenMaintenance(String tokenId)
void	stop()
void	stopTokenMaintenance(String tokenId)
void	unregisterFile(step.grid.filemanager.FileVersionId fileVersionId)

Methods inherited from class java.lang.Object

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

Constructor Detail

GridImpl

public GridImpl(Integer port)
         throws IOException

Throws:

IOException

GridImpl

public GridImpl(File fileManagerFolder,
                Integer port)

GridImpl

public GridImpl(File fileManagerFolder,
                Integer port,
                GridImpl.GridImplConfig gridConfig)

Method Detail

cleanupFileManagerCache

public void cleanupFileManagerCache()

Specified by:

cleanupFileManagerCache in interface step.grid.Grid

stop

public void stop()
          throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Throws:

Exception

handleRegistrationMessage

protected void handleRegistrationMessage(step.grid.agent.RegistrationMessage message)

selectToken

public step.grid.TokenWrapper selectToken(Map<String,String> attributes,
                                          Map<String,step.grid.tokenpool.Interest> interests,
                                          long matchTimeout,
                                          long noMatchTimeout,
                                          step.grid.TokenWrapperOwner tokenOwner)
                                   throws TimeoutException,
                                          InterruptedException

Specified by:

selectToken in interface step.grid.Grid

Throws:

TimeoutException

InterruptedException

returnToken

public void returnToken(String tokenId)

Specified by:

returnToken in interface step.grid.Grid

markTokenAsFailing

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

Specified by:

markTokenAsFailing in interface step.grid.Grid

removeTokenError

public void removeTokenError(String tokenId)

Specified by:

removeTokenError in interface step.grid.Grid

startTokenMaintenance

public void startTokenMaintenance(String tokenId)

Specified by:

startTokenMaintenance in interface step.grid.Grid

stopTokenMaintenance

public void stopTokenMaintenance(String tokenId)

Specified by:

stopTokenMaintenance in interface step.grid.Grid

getTokens

public List<step.grid.TokenWrapper> getTokens()

Specified by:

getTokens in interface step.grid.Grid

getAgents

public List<step.grid.AgentRef> getAgents()

Specified by:

getAgents in interface step.grid.Grid

getServerPort

public int getServerPort()

registerFile

public step.grid.filemanager.FileVersion registerFile(InputStream inputStream,
                                                      String fileName,
                                                      boolean isDirectory)
                                               throws step.grid.filemanager.FileManagerException

Specified by:

registerFile in interface step.grid.GridFileService

Throws:

step.grid.filemanager.FileManagerException

registerFile

public step.grid.filemanager.FileVersion registerFile(File file)
                                               throws step.grid.filemanager.FileManagerException

Specified by:

registerFile in interface step.grid.GridFileService

Throws:

step.grid.filemanager.FileManagerException

getRegisteredFile

public step.grid.filemanager.FileVersion getRegisteredFile(step.grid.filemanager.FileVersionId fileVersionId)
                                                    throws step.grid.filemanager.FileManagerException

Specified by:

getRegisteredFile in interface step.grid.GridFileService

Throws:

step.grid.filemanager.FileManagerException

unregisterFile

public void unregisterFile(step.grid.filemanager.FileVersionId fileVersionId)

Specified by:

unregisterFile in interface step.grid.GridFileService