public class SRBConnect extends Source
The SRBConnection actor provides users with valid accounts an ability to connect to the SDSC Storage Resoure Broker from within the Kepler computational environment. SRB actors enable access to a Data Grid Management System (DGMS) that provides a hierarchical logical namespace to manage the organization of data (usually files).
This actor connects to the SRB and returns a reference to the SRB file system. This reference can be further shared by other SRB Actors which perform various SCommands like functionality from within the Kepler Worfklows system. The connection reference can be propagated to all actors accessing the SRB workspace. This actor will create a different connection object to each connected channel to allow paralel operations.
To access the Distributed Logical File System and other SRB features each user is assigned an SRB account which includes the following information:
Required User input: The SRBConnection actor asks the user to specify the above connection parameters and in return creates an SRB Account and outputs the created SRB file system. The user needs to specify the following connection parameters: srbHost, srbPort, srbUserName, srbPasswd, srbHomeCollection, srbMdasDomainHome and srbDefaultResource by double- clicking the actor and entering the above information in the Edit Parameters Dialog Box.
Actor Output: The SRB connection reference system.
The following actor creates SRB Account and SRB file reference system with the SRB Jargon API provided. The JARGON is a pure API for developing programs with a data grid interface and I/O for SRB file systems.
Further information on SRBEntity.ContainedObjectsIterator| Modifier and Type | Field and Description |
|---|---|
StringAttribute |
srbDefaultResource
A SRB resource is a system that is capable of storing data objects and is
accessible to the SRB
|
StringAttribute |
srbHomeCollection
Each SRB-registered user is started with a 'home' collection.
|
StringAttribute |
srbHost
srbHost : represents available srb server hosts
|
StringAttribute |
srbMdasDomainHome
A domainHome is used to identify a site or project
|
StringAttribute |
srbPasswd
SRB User's password
|
StringAttribute |
srbPort
the port number required to connect to the srb server
|
StringAttribute |
srbUserName
SRB Users are uniquely identified by their usernames combined with their
domains.
|
_triggered, output, trigger_typesValid_actorFiringListeners, _initializables, _notifyingActorFiring, _stopRequested_changeListeners, _changeLock, _changeRequests, _debugging, _debugListeners, _deferChangeRequests, _elementName, _isPersistent, _verbose, _workspace, ATTRIBUTES, CLASSNAME, COMPLETE, CONTENTS, DEEP, FULLNAME, LINKSCOMPLETED, NOT_READY, STOP_ITERATING| Constructor and Description |
|---|
SRBConnect(CompositeEntity container,
java.lang.String name)
Construct an actor with the given container and name.
|
| Modifier and Type | Method and Description |
|---|---|
void |
fire()
Connects to SRB and returns a connection reference.
|
void |
initialize()
Connect to SRB account.
|
void |
wrapup()
Disconnect from SRB.
|
_customTypeConstraints, prefire_containedTypeConstraints, _defaultTypeConstraints, _fireAt, _fireAt, attributeTypeChanged, clone, clone, isBackwardTypeInferenceEnabled, newPort, typeConstraintList, typeConstraints_actorFiring, _actorFiring, _declareDelayDependency, addActorFiringListener, addInitializable, connectionsChanged, createReceivers, declareDelayDependency, getCausalityInterface, getDirector, getExecutiveDirector, getManager, inputPortList, isFireFunctional, isStrict, iterate, newReceiver, outputPortList, postfire, preinitialize, pruneDependencies, recordFiring, removeActorFiringListener, removeDependency, removeInitializable, setContainer, stop, stopFire, terminate_adjustDeferrals, _checkContainer, _getContainedObject, _propagateExistence, getContainer, instantiate, isAtomic, isOpaque, moveDown, moveToFirst, moveToIndex, moveToLast, moveUp, propagateExistence, setName_addPort, _description, _exportMoMLContents, _removePort, _validateSettables, connectedPortList, connectedPorts, containedObjectsIterator, getAttribute, getPort, getPorts, linkedRelationList, linkedRelations, portList, removeAllPorts, setClassDefinition, uniqueName_setParent, exportMoML, getChildren, getElementName, getParent, getPrototypeList, isClassDefinition, isWithinClassDefinition_addAttribute, _adjustOverride, _attachText, _cloneFixAttributeFields, _containedDecorators, _copyChangeRequestList, _debug, _debug, _debug, _debug, _debug, _executeChangeRequests, _getIndentPrefix, _isMoMLSuppressed, _markContentsDerived, _notifyHierarchyListenersAfterChange, _notifyHierarchyListenersBeforeChange, _propagateValue, _removeAttribute, _splitName, _stripNumericSuffix, addChangeListener, addDebugListener, addHierarchyListener, attributeChanged, attributeDeleted, attributeList, attributeList, decorators, deepContains, depthInHierarchy, description, description, event, executeChangeRequests, exportMoML, exportMoML, exportMoML, exportMoML, exportMoMLPlain, getAttribute, getAttributes, getChangeListeners, getClassName, getDecoratorAttribute, getDecoratorAttributes, getDerivedLevel, getDerivedList, getDisplayName, getFullName, getModelErrorHandler, getName, getName, getSource, handleModelError, isDeferringChangeRequests, isOverridden, isPersistent, lazyContainedObjectsIterator, message, notifyOfNameChange, propagateValue, propagateValues, removeAttribute, removeChangeListener, removeDebugListener, removeHierarchyListener, requestChange, setClassName, setDeferringChangeRequests, setDerivedLevel, setDisplayName, setModelErrorHandler, setPersistent, setSource, sortContainedObjects, toplevel, toString, validateSettables, workspaceequals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcreateReceivers, getCausalityInterface, getDirector, getExecutiveDirector, getManager, inputPortList, newReceiver, outputPortListisFireFunctional, isStrict, iterate, postfire, stop, stopFire, terminateaddInitializable, preinitialize, removeInitializabledescription, getContainer, getDisplayName, getFullName, getName, getName, setNamegetDerivedLevel, getDerivedList, propagateValuepublic StringAttribute srbHost
public StringAttribute srbPort
public StringAttribute srbUserName
public StringAttribute srbPasswd
public StringAttribute srbHomeCollection
public StringAttribute srbMdasDomainHome
public StringAttribute srbDefaultResource
public SRBConnect(CompositeEntity container, java.lang.String name) throws NameDuplicationException, IllegalActionException
container - The container.name - The name of this actor.IllegalActionException - If the actor cannot be contained by the proposed
container.NameDuplicationException - If the container already has an actor with this name.public void fire() throws IllegalActionException
fire in interface Executablefire in class SourceIllegalActionException - Not thrown in this base class.public void initialize() throws IllegalActionException
initialize in interface Initializableinitialize in class AtomicActor<TypedIOPort>IllegalActionException - If a derived class throws it.public void wrapup()
wrapup in interface Initializablewrapup in class AtomicActor<TypedIOPort>