step.grid

Class GridImpl

java.lang.Object

step.grid.GridImpl

All Implemented Interfaces:

Grid, GridFileService, TokenRegistry

public class GridImpl
extends Object
implements Grid

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GridImpl.GridImplConfig

Field Summary

Fields inherited from interface step.grid.Grid

LOCAL_AGENT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Collection<AgentRef>	getAgents()
FileVersion	getRegisteredFile(FileVersionId fileVersionId)
int	getServerPort()
List<Token<TokenWrapper>>	getTokens()
protected void	handleRegistrationMessage(RegistrationMessage message)
void	markTokenAsFailing(String tokenId, String errorMessage, Exception e)
FileVersion	registerFile(File file)
FileVersion	registerFile(InputStream inputStream, String fileName, boolean isDirectory)
void	removeTokenError(String tokenId)
void	returnToken(TokenWrapper object)
TokenWrapper	selectToken(Map<String,String> attributes, Map<String,Interest> interests, long matchTimeout, long noMatchTimeout)
void	start()
void	startTokenMaintenance(String tokenId)
void	stop()
void	stopTokenMaintenance(String tokenId)
void	unregisterFile(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

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(Map<String,String> attributes,
                                Map<String,Interest> interests,
                                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)

getTokens

public List<Token<TokenWrapper>> getTokens()

Specified by:

getTokens in interface TokenRegistry

getAgents

public Collection<AgentRef> getAgents()

getServerPort

public int getServerPort()

registerFile

public FileVersion registerFile(InputStream inputStream,
                                String fileName,
                                boolean isDirectory)
                         throws FileManagerException

Specified by:

registerFile in interface GridFileService

Throws:

FileManagerException

registerFile

public FileVersion registerFile(File file)
                         throws FileManagerException

Specified by:

registerFile in interface GridFileService

Throws:

FileManagerException

getRegisteredFile

public FileVersion getRegisteredFile(FileVersionId fileVersionId)
                              throws FileManagerException

Specified by:

getRegisteredFile in interface GridFileService

Throws:

FileManagerException

unregisterFile

public void unregisterFile(FileVersionId fileVersionId)

Specified by:

unregisterFile in interface GridFileService