public class WorkspaceKernel
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
void |
addArtifactFactory(ArtifactFactory factory) |
void |
addControllers(int n)
Extends the set of controllers used to serve operation execution
|
void |
bindAgentBodyArtifact(AgentId agentId,
AgentBodyArtifact art) |
void |
disposeArtifact(AgentId uid,
ArtifactId id)
Destroy an artifact
|
OpId |
doInternalOp(ArtifactId aid,
Op op) |
OpId |
execInterArtifactOp(ICartagoCallback evListener,
long callbackId,
AgentId userId,
ArtifactId srcId,
ArtifactId targetId,
Op op,
long timeout,
IAlignmentTest test) |
void |
execOp(long actionId,
AgentId userId,
ICartagoCallback ctx,
ArtifactId aid,
Op op,
long timeout,
IAlignmentTest test) |
void |
execOp(long actionId,
AgentId userId,
ICartagoCallback ctx,
Op op,
long timeout,
IAlignmentTest test) |
void |
execOp(long actionId,
AgentId userId,
ICartagoCallback ctx,
java.lang.String name,
Op op,
long timeout,
IAlignmentTest test) |
java.util.List<ArtifactObsProperty> |
focus(AgentId userId,
IEventFilter filter,
ICartagoCallback ctx,
ArtifactId aid) |
ArtifactId |
getAgentBodyArtifact(AgentId agentId) |
ArtifactId |
getArtifact(java.lang.String name) |
ArtifactId[] |
getArtifactIdList() |
java.lang.String[] |
getArtifactList() |
ICartagoController |
getController() |
WorkspaceId |
getId()
Gets environment name
|
ICartagoLoggerManager |
getLoggerManager() |
Manual |
getManual(AgentId userId,
java.lang.String manualName) |
cartago.security.IWorkspaceSecurityManager |
getSecurityManager() |
boolean |
hasOperation(ArtifactId aid,
Op op) |
boolean |
isArtifactPresent(java.lang.String name) |
ICartagoContext |
joinWorkspace(cartago.security.AgentCredential cred,
ICartagoCallback eventListener) |
void |
linkArtifacts(AgentId userId,
ArtifactId artifactOutId,
java.lang.String artifactOutPort,
ArtifactId artifactInId) |
java.lang.String |
loadManualSrc(java.lang.String fname) |
protected void |
log(java.lang.String st) |
ArtifactId |
lookupArtifact(AgentId userId,
java.lang.String name) |
ArtifactId |
lookupArtifactByType(AgentId userId,
java.lang.String type) |
ArtifactId |
makeArtifact(AgentId userId,
java.lang.String name,
java.lang.String template,
ArtifactConfig config) |
void |
notifyActionCompleted(ICartagoCallback listener,
long actionId,
ArtifactId aid,
Op op) |
void |
notifyActionFailed(ICartagoCallback listener,
long actionId,
Op op,
java.lang.String failureMsg,
Tuple failureReason) |
void |
notifyAgentPositionOrRadiusChange(AgentId agentId) |
void |
notifyArtifactPositionOrRadiusChange(ArtifactId id) |
void |
notifyConsultManualCompleted(ICartagoCallback listener,
long actionId,
ArtifactId aid,
Op op,
Manual man) |
void |
notifyFocusCompleted(ICartagoCallback listener,
long actionId,
ArtifactId aid,
Op op,
ArtifactId target,
java.util.List<ArtifactObsProperty> props) |
void |
notifyJoinWSPCompleted(ICartagoCallback listener,
long actionId,
ArtifactId aid,
Op op,
WorkspaceId wspId,
ICartagoContext ctx) |
void |
notifyObsEvent(ArtifactId sourceId,
Tuple signal,
ArtifactObsProperty[] changed,
ArtifactObsProperty[] added,
ArtifactObsProperty[] removed) |
void |
notifyObsEventToAgent(ArtifactId sourceId,
AgentId target,
Tuple signal,
ArtifactObsProperty[] changed,
ArtifactObsProperty[] added,
ArtifactObsProperty[] removed) |
void |
notifyQuitWSPCompleted(ICartagoCallback listener,
long actionId,
ArtifactId aid,
Op op,
WorkspaceId wspId) |
void |
notifyStopFocusCompleted(ICartagoCallback listener,
long actionId,
ArtifactId aid,
Op op,
ArtifactId target,
java.util.List<ArtifactObsProperty> props) |
void |
quitAgent(AgentId userId) |
Manual |
registerManual(java.lang.String artifactType,
java.lang.String uri,
java.lang.String src) |
boolean |
removeArtifactFactory(java.lang.String name) |
void |
removeGarbageBody(AgentBody ctx) |
boolean |
removeManual(java.lang.String name) |
void |
setLoggerManager(ICartagoLoggerManager man) |
void |
setSecurityManager(cartago.security.IWorkspaceSecurityManager man) |
void |
setWSPRuleEngine(AbstractWSPRuleEngine man) |
void |
setWSPTopology(AbstractWorkspaceTopology topology) |
void |
shutdown()
Shutdown the workspace.
|
java.util.List<ArtifactObsProperty> |
stopFocus(AgentId userId,
ICartagoCallback ctx,
ArtifactId aid) |
public WorkspaceId getId()
public void setSecurityManager(cartago.security.IWorkspaceSecurityManager man)
public cartago.security.IWorkspaceSecurityManager getSecurityManager()
public void setLoggerManager(ICartagoLoggerManager man)
public ICartagoLoggerManager getLoggerManager()
public ICartagoContext joinWorkspace(cartago.security.AgentCredential cred, ICartagoCallback eventListener) throws CartagoException
CartagoException
public void bindAgentBodyArtifact(AgentId agentId, AgentBodyArtifact art)
public ArtifactId getAgentBodyArtifact(AgentId agentId)
public void notifyAgentPositionOrRadiusChange(AgentId agentId) throws CartagoException
CartagoException
public void notifyArtifactPositionOrRadiusChange(ArtifactId id) throws CartagoException
CartagoException
public void setWSPTopology(AbstractWorkspaceTopology topology)
public void quitAgent(AgentId userId) throws CartagoException
CartagoException
public void addArtifactFactory(ArtifactFactory factory)
public boolean removeArtifactFactory(java.lang.String name)
public ArtifactId makeArtifact(AgentId userId, java.lang.String name, java.lang.String template, ArtifactConfig config) throws ArtifactAlreadyPresentException, UnknownArtifactTemplateException, ArtifactConfigurationFailedException
public void disposeArtifact(AgentId uid, ArtifactId id) throws CartagoException
id
- artifact identifierCartagoException
- if errors occurred in disposing the artifactpublic java.lang.String[] getArtifactList()
public ArtifactId[] getArtifactIdList()
public boolean isArtifactPresent(java.lang.String name)
public ArtifactId lookupArtifact(AgentId userId, java.lang.String name) throws UnknownArtifactException, ArtifactNotAvailableException
public ArtifactId lookupArtifactByType(AgentId userId, java.lang.String type) throws UnknownArtifactException, ArtifactNotAvailableException
public void execOp(long actionId, AgentId userId, ICartagoCallback ctx, ArtifactId aid, Op op, long timeout, IAlignmentTest test) throws CartagoException
CartagoException
public void execOp(long actionId, AgentId userId, ICartagoCallback ctx, java.lang.String name, Op op, long timeout, IAlignmentTest test) throws CartagoException
CartagoException
public void execOp(long actionId, AgentId userId, ICartagoCallback ctx, Op op, long timeout, IAlignmentTest test) throws CartagoException
CartagoException
public void setWSPRuleEngine(AbstractWSPRuleEngine man)
public java.util.List<ArtifactObsProperty> focus(AgentId userId, IEventFilter filter, ICartagoCallback ctx, ArtifactId aid) throws CartagoException
CartagoException
public java.util.List<ArtifactObsProperty> stopFocus(AgentId userId, ICartagoCallback ctx, ArtifactId aid) throws CartagoException
CartagoException
public void linkArtifacts(AgentId userId, ArtifactId artifactOutId, java.lang.String artifactOutPort, ArtifactId artifactInId) throws CartagoException
CartagoException
public OpId doInternalOp(ArtifactId aid, Op op) throws java.lang.InterruptedException, OpRequestTimeoutException, OperationUnavailableException, ArtifactNotAvailableException, CartagoException
java.lang.InterruptedException
OpRequestTimeoutException
OperationUnavailableException
ArtifactNotAvailableException
CartagoException
public boolean hasOperation(ArtifactId aid, Op op) throws NoArtifactException
NoArtifactException
public ArtifactId getArtifact(java.lang.String name)
public OpId execInterArtifactOp(ICartagoCallback evListener, long callbackId, AgentId userId, ArtifactId srcId, ArtifactId targetId, Op op, long timeout, IAlignmentTest test) throws CartagoException
CartagoException
public Manual getManual(AgentId userId, java.lang.String manualName) throws ManualNotAvailableException
ManualNotAvailableException
public Manual registerManual(java.lang.String artifactType, java.lang.String uri, java.lang.String src) throws java.lang.Exception
java.lang.Exception
public boolean removeManual(java.lang.String name)
public void addControllers(int n)
n
- number of controllers to be addedpublic void shutdown()
public void notifyObsEventToAgent(ArtifactId sourceId, AgentId target, Tuple signal, ArtifactObsProperty[] changed, ArtifactObsProperty[] added, ArtifactObsProperty[] removed)
public void notifyObsEvent(ArtifactId sourceId, Tuple signal, ArtifactObsProperty[] changed, ArtifactObsProperty[] added, ArtifactObsProperty[] removed)
public void notifyActionCompleted(ICartagoCallback listener, long actionId, ArtifactId aid, Op op)
public void notifyActionFailed(ICartagoCallback listener, long actionId, Op op, java.lang.String failureMsg, Tuple failureReason)
public void notifyFocusCompleted(ICartagoCallback listener, long actionId, ArtifactId aid, Op op, ArtifactId target, java.util.List<ArtifactObsProperty> props)
public void notifyStopFocusCompleted(ICartagoCallback listener, long actionId, ArtifactId aid, Op op, ArtifactId target, java.util.List<ArtifactObsProperty> props)
public void notifyJoinWSPCompleted(ICartagoCallback listener, long actionId, ArtifactId aid, Op op, WorkspaceId wspId, ICartagoContext ctx)
public void notifyQuitWSPCompleted(ICartagoCallback listener, long actionId, ArtifactId aid, Op op, WorkspaceId wspId)
public void notifyConsultManualCompleted(ICartagoCallback listener, long actionId, ArtifactId aid, Op op, Manual man)
protected void log(java.lang.String st)
public void removeGarbageBody(AgentBody ctx)
public ICartagoController getController()
public java.lang.String loadManualSrc(java.lang.String fname)
>DEIS - University of Bologna