- ScheduledTask<T> - Class in ds.funnel.node.task
-
- SchedulingException - Exception in ds.granules.scheduler
-
This is an exception that is thrown when there are problems in scheduling
tasks for execution.
- SchedulingException() - Constructor for exception ds.granules.scheduler.SchedulingException
-
Constructs an SchedulingException with no detail message.
- SchedulingException(String) - Constructor for exception ds.granules.scheduler.SchedulingException
-
Constructs an SchedulingException with the specified detail
message.
- scoreNow - Variable in class ds.granules.interfere.computation.ComputationStats
-
- scorePlaced - Variable in class ds.granules.interfere.computation.ComputationStats
-
- sDetails - Variable in class ds.funnel.node.compnt.NodeComponentLinkImpl.OpenedComponentLink
-
- SECURE_INTERACTIONS - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- SelectableTask<T> - Class in ds.funnel.node.task
-
- SEND_BUFFER_BYTES - Static variable in class ds.funnel.data.channel.udp.UDPChannelAddr
-
- SEND_BUFFER_SIZE - Static variable in class ds.funnel.data.channel.ChannelWriter
-
- sendCt - Static variable in class ds.funnel.samples.MPTestNodeA
-
- sendCt - Static variable in class ds.funnel.samples.MPTestNodeB
-
- sendCt - Static variable in class ds.funnel.samples.TimerTestNode
-
- senderDetails - Variable in class ds.funnel.data.msglink.event.MsgLinkAssociate
-
- sendEvent(TopicDataEvent, OverlayPath...) - Method in interface ds.funnel.topic.TopicPublisher
-
- sendEvent(TopicDataEvent, OverlayPath...) - Method in class ds.funnel.topic.TopicPublisherImpl
-
- sendEventData(byte[], OverlayPath...) - Method in interface ds.funnel.topic.TopicPublisher
-
- sendEventData(byte[], Properties, OverlayPath...) - Method in interface ds.funnel.topic.TopicPublisher
-
- sendEventData(byte[], OverlayPath...) - Method in class ds.funnel.topic.TopicPublisherImpl
-
- sendEventData(byte[], Properties, OverlayPath...) - Method in class ds.funnel.topic.TopicPublisherImpl
-
- sendMessage(MessageEvent) - Method in interface ds.funnel.data.msglink.MessageLink
-
Send a message to the connected destination.
- sendMessage(MessageEvent, Class<M>) - Method in interface ds.funnel.data.msglink.MessageLink
-
Send a message to the connected destination, and get a reply task.
- sendMessage(MessageEvent) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- sendMessage(MessageEvent, Class<M>) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- sendMessage(TopicEvent, List<OverlayPath>) - Method in interface ds.funnel.overlay.OverlayLink
-
Send a message to the connected destination.
- sendMessage(MessageEvent) - Method in class ds.funnel.overlay.OverlayLinkImpl
-
- sendMessage(MessageEvent, Class<M>) - Method in class ds.funnel.overlay.OverlayLinkImpl
-
- sendMessage(TopicEvent, List<OverlayPath>) - Method in class ds.funnel.overlay.OverlayLinkImpl
-
- sendMessage(JavaByteMessage) - Method in class ds.granules.bridge.JavaGenericComputation
-
Function which allows the resource to send messages to an attached
computation
- sendMessage(JavaByteMessage) - Method in class ds.granules.bridge.JavaPoolComputation
-
Function which allows the resource to send messages to an attached
computation
- sendMessage(byte[]) - Method in class ds.granules.bridge.StreamWriter
-
Responsible for sending messages
- SequencingInfo - Interface in ds.granules.results
-
Some applications often need to include sequencing descriptors along with
their results.
- SequencingWidget - Class in ds.granules.results
-
This class is an implementation of the SequencingInfo interface.
- ServiceException - Exception in cgl.narada.event
-
Deprecated.
- ServiceException(String) - Constructor for exception cgl.narada.event.ServiceException
-
Deprecated.
- ServiceException(String, String) - Constructor for exception cgl.narada.event.ServiceException
-
Deprecated.
- set(T) - Method in class ds.funnel.util.ThreadGroupLocal
-
- setArg(String, String) - Method in class ds.funnel.node.compnt.NodeComponentKey
-
- setAsExecuteFixedNumberOfTimes(String, int) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecuteFixedNumberOfTimes(int) - Method in class ds.granules.operation.OperationBase
-
- setAsExecuteFixedNumberOfTimes(int) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable a fixed number of times.
- setAsExecuteOnce(String) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecuteOnce() - Method in class ds.granules.operation.OperationBase
-
- setAsExecuteOnce() - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable exactly once.
- setAsExecutePeriodically(String, long) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecutePeriodically(long) - Method in class ds.granules.operation.OperationBase
-
- setAsExecutePeriodically(long) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable periodically at the specified
intervals.
- setAsExecuteWhenDataAvailable(String) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecuteWhenDataAvailable() - Method in class ds.granules.operation.OperationBase
-
- setAsExecuteWhenDataAvailable() - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable when data is available
- setAsStayAlive(String) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsStayAlive() - Method in class ds.granules.operation.OperationBase
-
- setAsStayAlive() - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being stayAlive.
- setAttribute(GraphAttributes.AttrKey<T>, T) - Method in class ds.funnel.overlay.graph.GraphAttributes
-
- setAttribute(GraphAttributes.AttrKey<T>, T, long) - Method in class ds.funnel.overlay.graph.GraphAttributes
-
- setAttribute(GraphAttributes.AttrKey<T>, T) - Method in class ds.funnel.overlay.graph.GraphEdge
-
- setAttribute(GraphAttributes.AttrKey<T>, T, long) - Method in class ds.funnel.overlay.graph.GraphEdge
-
- setAttribute(GraphAttributes.AttrKey<T>, T) - Method in class ds.funnel.overlay.graph.GraphNode
-
- setAttribute(GraphAttributes.AttrKey<T>, T, long) - Method in class ds.funnel.overlay.graph.GraphNode
-
- setAverageLatency(double) - Method in class ds.funnel.traffic.analysis.regress.Rows
-
- setBackingLink(NodeDetails, MessageLink) - Method in class ds.funnel.overlay.OverlayManagerImpl
-
- setBaseComponents(List<ComponentSpecification>) - Method in class ds.funnel.traffic.factory.ComplexComponentSpecification
-
Sets the list of base components for this complex component specification
to the provided list, overwriting any components which were previously
stored.
- setBaseRateDistribution(PacketTimeDistribution) - Method in class ds.funnel.traffic.component.timedistribution.BurstyTimeDistribution
-
- setBootstrapNodes(List<NodeDetails>) - Method in interface ds.funnel.peer.PeerManager
-
Provide a list of nodes that should be connected to upon startup.
- setBootstrapNodes(List<NodeDetails>) - Method in class ds.funnel.peer.PeerManagerImpl
-
- setBurstDurationDistribution(PacketTimeDistribution) - Method in class ds.funnel.traffic.component.timedistribution.BurstyTimeDistribution
-
- setBurstSpacingDistribution(PacketTimeDistribution) - Method in class ds.funnel.traffic.component.timedistribution.BurstyTimeDistribution
-
- setComponentKey(NodeComponentKey) - Method in interface ds.funnel.node.compnt.NodeComponent
-
Deprecated.
- setComponentKey(NodeComponentKey) - Method in class ds.funnel.node.compnt.NodeComponentImpl
-
Deprecated.
- setComponentParameters(List<String>) - Method in class ds.funnel.traffic.factory.ComponentSpecification
-
Sets the list of parameters stored in this component specification to the
provided list, overwriting all previous parameters.
- setComputations(GIComputation...) - Method in class ds.granules.interfere.computation.ComputationManager
-
- setConfigurationString(String) - Method in class ds.funnel.traffic.factory.ConfigurationParser
-
Sets the string this ConfigurationParser will parse to the specified
string.
- setCurrentOverlay(long) - Method in interface ds.funnel.overlay.OverlayManager
-
Set a specific version of the overlay as the current version.
- setCurrentOverlay(long) - Method in class ds.funnel.overlay.OverlayManagerImpl
-
- setDatasetCollection(DatasetCollection) - Method in class ds.granules.operation.OperationBase
-
- setDatasetCollection(DatasetCollection) - Method in interface ds.granules.operation.OperationConfiguration
-
Establish the dataset needed by the application in question
- setDatasetCollectionObserver(DatasetCollectionObserver) - Method in interface ds.granules.dataset.DatasetCollection
-
Register an observer for the DatasetCollection
- setDatasetCollectionObserver(DatasetCollectionObserver) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- setDefaultConsoleLogging(boolean) - Static method in class ds.funnel.traffic.TrafficGenerator
-
Toggles future logging of packet transmissions to the default console
handler by all TrafficGenerators.
- setDescription(String) - Method in class ds.granules.bridge.JavaByteMessage
-
- setDestinationsToReach(byte[]) - Method in interface cgl.narada.event.DistributionTraces
-
Deprecated.
Setting the destinations to reach
- setDestinationsToReach(byte[]) - Method in class cgl.narada.event.DistributionTracesImpl
-
Deprecated.
Setting the destinations to reach
- setDestinationsTraversedSoFar(byte[]) - Method in interface cgl.narada.event.DistributionTraces
-
Deprecated.
Setting the destinations traversed so far
- setDestinationsTraversedSoFar(byte[]) - Method in class cgl.narada.event.DistributionTracesImpl
-
Deprecated.
- setDetails(GIPlacementDetails, ComputationDescription, String, boolean, GIPlacementNode.Migration, String) - Method in class ds.granules.interfere.computation.GIComputation
-
- setDomain(String) - Method in class ds.granules.operation.OperationBase
-
- setDomain(String) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the domain for this operation
- setEncryptedPayloadInformation(byte[], String, String) - Method in interface cgl.narada.event.EventHeaders
-
Deprecated.
- setEncryptedPayloadInformation(byte[], String, String) - Method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
- setEventDispatcher(EventDispatcher) - Method in class ds.funnel.traffic.TrafficGenerator
-
- setEventHandler(EventHandler<? super MessageEvent>) - Method in interface ds.funnel.data.msglink.MessageLink
-
Set the event handler that incoming events are passed to.
- setEventHandler(EventHandler<? super MessageEvent>) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- setEventHandler(EventHandler<? super MessageEvent>) - Method in class ds.funnel.overlay.OverlayLinkImpl
-
- setEventProcessor(EventProcessor<MessageEvent>) - Method in interface ds.funnel.data.msglink.MessageLink
-
Set the event handler that incoming events are passed to.
- setEventProcessor(EventProcessor<MessageEvent>) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- setEventProcessor(EventProcessor<MessageEvent>) - Method in class ds.funnel.overlay.OverlayLinkImpl
-
- setEventType(NBEvent, int) - Static method in class cgl.narada.event.NBEventGenerator
-
Deprecated.
- setExchangeType(int) - Method in class ds.granules.exchange.Exchange
-
- setExecutionStatus(int) - Method in class ds.granules.scheduler.ExecutableTask
-
Set the execution status for the lifecycle metrics.
- setFileLogging(boolean, Map<String, String>) - Method in interface ds.granules.interfere.placement.component.GIStreamingTrackerCmpnt
-
- setFileLogging(boolean, Map<String, String>) - Method in class ds.granules.interfere.placement.component.GIStreamingTrackerImpl
-
- setFileLogging(boolean, Map<String, String>) - Method in class ds.granules.interfere.streaming.GIStreamingNode
-
- setFileLogging(boolean, Map<String, String>) - Method in class ds.granules.interfere.streaming.GIStreamingNodeProxy
-
- setFileLogging(boolean, Map<String, String>) - Method in interface ds.granules.interfere.streaming.GIStreamingProxyOps
-
- setFromJava(boolean) - Method in class ds.granules.bridge.JavaByteMessage
-
- setGraphBuilder(GraphBuilder) - Method in interface ds.funnel.peer.PeerGroup
-
Set the desired topology type.
- setGraphBuilder(GraphBuilder) - Method in class ds.funnel.peer.PeerGroupImpl
-
- setHandler(EventHandler<? super E>) - Method in class ds.funnel.node.event.EventProcessor
-
- setHashID(BigInteger) - Method in class ds.synapse.peer.SynapseDHTDetails
-
- setImmutableProperty(Object, Object, Object) - Method in interface cgl.narada.event.EventProperties
-
Deprecated.
Set an immutable property.
- setImmutableProperty(Object, Object, Object) - Method in class cgl.narada.event.EventPropertiesImpl
-
Deprecated.
Set an immutable property.
- setInitializationComplete() - Method in class ds.granules.interfere.computation.GIComputation
-
- setInitializationComplete() - Method in class ds.granules.operation.OperationBase
-
- setInitializationComplete() - Method in interface ds.granules.operation.OperationConfiguration
-
Mark the initialization of the application as having completed
- setInitializationNeeded(boolean) - Method in class ds.granules.operation.OperationBase
-
- setInitializationNeeded(boolean) - Method in interface ds.granules.operation.OperationConfiguration
-
Set/Unset whether this operation needs initialization.
- setInput(byte[]) - Method in class ds.granules.bridge.JavaByteMessage
-
- setInstanceIdentifier(String) - Method in class ds.granules.operation.OperationBase
-
- setInstanceIdentifier(String) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the instance identifier associated with a given operation.
- setInterval(int) - Method in class ds.funnel.traffic.component.timedistribution.RegularTimeDistribution
-
If the interval specified is a valid interval (greater than 0), sets the
value of interval to newInterval.
- setIntervalBounds(int, int) - Method in class ds.funnel.traffic.component.timedistribution.RandomTimeDistribution
-
Sets the minimum and maximum intervals for packet transmissions to the
specified bounds.
- setLatencyVariance(double) - Method in class ds.funnel.traffic.analysis.regress.Rows
-
- setLoggingEnabled(boolean) - Method in class ds.funnel.traffic.TrafficGenerator
-
Toggles packet transmission logging.
- setMainComponentType(ComponentType) - Method in class ds.funnel.traffic.factory.ComponentSpecification
-
Sets the basic component type (packet generator, packet size
distribution, etc) described by this specification to the provided type
identifier.
- setMaxInterval(int) - Method in class ds.funnel.traffic.component.timedistribution.RandomTimeDistribution
-
- setMaxSequence(long) - Method in interface ds.granules.results.SequencingInfo
-
Sets the max-sequence information.
- setMaxSequence(long) - Method in class ds.granules.results.SequencingWidget
-
- setMaxSize(int) - Method in class ds.funnel.traffic.component.sizedistribution.RandomSizeDistribution
-
- setMean(double) - Method in class ds.funnel.traffic.component.sizedistribution.NormalSizeDistribution
-
Sets the mean value of packet sizes generated by this normal size
distribution to the specified value.
- setMean(double) - Method in class ds.funnel.traffic.component.timedistribution.NormalTimeDistribution
-
Sets the mean value for inter-arrival times generated by this normal time
distribution to the specified value.
- setMinInterval(int) - Method in class ds.funnel.traffic.component.timedistribution.RandomTimeDistribution
-
- setMinSize(int) - Method in class ds.funnel.traffic.component.sizedistribution.RandomSizeDistribution
-
- setMutableProperty(Object, Object, Object) - Method in interface cgl.narada.event.EventProperties
-
Deprecated.
Set a mutable property.
- setMutableProperty(Object, Object, Object) - Method in class cgl.narada.event.EventPropertiesImpl
-
Deprecated.
Set a mutable property.
- setName(String) - Method in interface ds.funnel.node.NodeDetails
-
Update this node's nickname.
- setName(String) - Method in class ds.funnel.node.NodeDetailsBase
-
- setNormal(boolean) - Method in class ds.granules.interfere.computation.ecg.HeartbeatData
-
- setNumberOfComputations(int) - Method in class ds.granules.scheduler.ResourceMetrics
-
- setNumThreads(int) - Method in class ds.funnel.node.task.SuperThreadPool
-
- setNumThreads(int) - Method in class ds.funnel.node.task.TaskThreads
-
- setOperationIdentifier(String) - Method in class ds.granules.operation.OperationBase
-
- setOperationIdentifier(String) - Method in interface ds.granules.operation.OperationConfiguration
-
This method sets the operation identifier for a given operation
- setOutput(byte[]) - Method in class ds.granules.bridge.JavaByteMessage
-
- setPacketGenerator(PacketGenerator) - Method in class ds.funnel.traffic.TrafficGenerator
-
- setParent(LinkStatisticsImpl) - Method in class ds.funnel.data.msglink.LinkStatisticsImpl
-
- setParent(EventDispatchHandler<Event>) - Method in interface ds.funnel.node.event.EventDispatcher
-
Sets the parent event dispatcher.
- setParent(EventDispatchHandler<Event>) - Method in class ds.funnel.node.event.EventDispatcherImpl
-
- setPayload(NBEvent, byte[]) - Method in class cgl.narada.event.NBEventGenerator
-
Deprecated.
- setPeer(int, SynapseDHTDetails) - Method in class ds.synapse.peer.DHTFingerTable
-
- setPeerConnection(DHTConnection) - Method in class ds.synapse.peer.DHTLookup
-
- setPercentIncreaseDuringBursts(double) - Method in class ds.funnel.traffic.component.timedistribution.BurstyTimeDistribution
-
Sets the percentage increase of packet transmissions during bursts for
this bursty time distribution.
- setPosition(String, long) - Method in interface ds.granules.dataset.FileAccess
-
Deprecated.
Sets the position of filePointer for one of the file in the given
dataset.
- setPosition(String, long) - Method in interface ds.granules.dataset.FileDataset
-
Sets the position of filePointer for one of the file in the given
dataset.
- setPosition(String, long) - Method in class ds.granules.dataset.FileDatasetImpl
-
- setPosition(String, long) - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- setPred - Variable in class ds.synapse.peer.event.MsgInsertPeer
-
- setPredPeer(SynapseDHTDetails) - Method in class ds.synapse.peer.DHTFingerTable
-
Change this peer's predecessor.
- setPrimary(boolean) - Method in interface ds.funnel.overlay.OverlayLink
-
Set the primary status of this link.
- setPrimary(boolean) - Method in class ds.funnel.overlay.OverlayLinkImpl
-
- setProcessingDirectives(Properties) - Method in class ds.granules.operation.OperationBase
-
- setProcessingDirectives(Properties) - Method in interface ds.granules.operation.OperationConfiguration
-
Set the processing directives for the operation
- setPThreadName() - Static method in class ds.funnel.util.ProcUtil
-
- setPThreadName(String) - Static method in class ds.funnel.util.ProcUtil
-
- setQueueOnly(boolean) - Method in class ds.funnel.node.event.EventSequencer
-
- setReceivedOutputFrom(String) - Method in class ds.granules.operation.MapReduceBase
-
- setReceivedOutputFrom(String) - Method in interface ds.granules.operation.Reduce
-
Mark the receipt of Output from a given Map instance
- setRequestDataIn(boolean) - Method in interface ds.funnel.overlay.OverlayManager
-
Set the request mode of this node in the overlay.
- setRequestDataIn(boolean) - Method in class ds.funnel.overlay.OverlayManagerImpl
-
- setResource(String) - Method in class ds.granules.interfere.computation.ComputationDescription
-
- setRespondTo(String) - Method in class ds.granules.exchange.Exchange
-
Set the repondTo field for this exchange.
- setRespondTo(String) - Method in interface ds.granules.results.Results
-
Set the respondTo field for the Results
- setRespondTo(String) - Method in class ds.granules.results.ResultsWidget
-
- setResultPayload(byte[]) - Method in interface ds.granules.results.Results
-
Sets the payload for the Results.
- setResultPayload(byte[]) - Method in class ds.granules.results.ResultsWidget
-
- setResultType(int) - Method in interface ds.granules.results.Results
-
Set the type of the result encapsulated within the payload.
- setResultType(int) - Method in class ds.granules.results.ResultsWidget
-
- setSecurityTimeStampedSequenceNo(byte[]) - Method in interface cgl.narada.event.EventHeaders
-
Deprecated.
- setSecurityTimeStampedSequenceNo(byte[]) - Method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
- setSecurityToken(byte[]) - Method in interface cgl.narada.event.EventHeaders
-
Deprecated.
- setSecurityToken(byte[]) - Method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
Set the signed security token
- setSeed(long) - Method in class ds.funnel.traffic.component.packetgenerator.RandomPacketGenerator
-
Sets the seed of the underlying random generator to the specified seed.
- setSeqNumber(long) - Method in class ds.funnel.node.event.EventSequencer
-
- setSequenceRange(long, long) - Method in interface ds.granules.results.SequencingInfo
-
Sets the sequence range based on the specified upper and lower-bounds.
- setSequenceRange(long, long) - Method in class ds.granules.results.SequencingWidget
-
- setSignatureInformation(String, byte[]) - Method in interface cgl.narada.event.EventHeaders
-
Deprecated.
- setSignatureInformation(String, byte[]) - Method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
- setSingleSequence(long) - Method in interface ds.granules.results.SequencingInfo
-
Set the single sequence Information.
- setSingleSequence(long) - Method in class ds.granules.results.SequencingWidget
-
- setSize(int) - Method in class ds.funnel.traffic.component.sizedistribution.RegularSizeDistribution
-
Sets the packet size for this regular size distribution to the given
value, if it is valid (a positive value).
- setSizeBounds(int, int) - Method in class ds.funnel.traffic.component.sizedistribution.RandomSizeDistribution
-
- setSizeDistribution(PacketSizeDistribution) - Method in class ds.funnel.traffic.TrafficGenerator
-
- setSpecificComponentType(int) - Method in class ds.funnel.traffic.factory.ComponentSpecification
-
Sets the specific component type (random, normal, etc) described by this
specification to the provided type identifier.
- setStandardDeviation(double) - Method in class ds.funnel.traffic.component.sizedistribution.NormalSizeDistribution
-
Sets the standard deviation for packet sizes generated by this normal
size distribution to the specified value.
- setStandardDeviation(double) - Method in class ds.funnel.traffic.component.timedistribution.NormalTimeDistribution
-
Sets the standard deviation for inter-arrival times generated by this
normal time distribution to the specified value.
- setStartTime() - Method in class ds.granules.operation.InstanceDeployer
-
Resets the start timer which tracks the time at which an application
began execution.
- setStreamIdentifier(String) - Method in class ds.funnel.traffic.TrafficGenerator
-
- setStreamIdentifier(String) - Method in class ds.granules.bridge.JavaByteMessage
-
- setSuccPeers(List<SynapseDHTDetails>) - Method in class ds.synapse.peer.DHTFingerTable
-
Update this peer's successors.
- setTaskCompletionInfo(String) - Method in class ds.granules.scheduler.ExecutableTask
-
Include some information about the completion of the task.
- setTeminationConditionReached() - Method in class ds.granules.interfere.computation.GIComputation
-
- setTeminationConditionReached() - Method in class ds.granules.operation.OperationBase
-
- setTeminationConditionReached() - Method in interface ds.granules.operation.OperationConfiguration
-
Mark the termination condition of this operation as having reached.
- setTimeDistribution(PacketTimeDistribution) - Method in class ds.funnel.traffic.TrafficGenerator
-
- setTimestamp(long) - Method in class ds.granules.exchange.Exchange
-
Set the timestamp for this exchange.
- setTopic(Topic) - Method in class ds.funnel.peer.event.MessageBaseTE
-
- setTreeBuilder(GraphBuilder) - Method in interface ds.funnel.peer.PeerGroup
-
Set the desired routing tree type.
- setTreeBuilder(GraphBuilder) - Method in class ds.funnel.peer.PeerGroupImpl
-
- setVersionInformation(long) - Method in class ds.granules.operation.OperationBase
-
- setVersionInformation(long) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the version information for this operation.
- severe(String) - Method in class ds.funnel.node.FunnelLogger
-
- severe(Exception) - Method in class ds.funnel.node.FunnelLogger
-
- SHORT - Static variable in class ds.granules.results.ResultPayload
-
- SHORT_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- SHORT_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- shutdown(long) - Method in class ds.funnel.node.task.SuperThreadPool
-
- shutdown() - Method in class ds.granules.interfere.resource.GIResourceNode
-
- shutdown() - Method in class ds.granules.interfere.resource.GIResourceNodeProxy
-
- shutdown() - Method in interface ds.granules.interfere.resource.GIResourceProxyOps
-
- shutdown() - Method in class ds.granules.interfere.streaming.GIStreamingNode
-
- shutdown() - Method in class ds.granules.interfere.streaming.GIStreamingNodeProxy
-
- shutdown() - Method in interface ds.granules.interfere.streaming.GIStreamingProxyOps
-
- SimpleParameterCSVFormatter - Class in ds.funnel.traffic.formatter
-
Super simple formatter for formatting log records.
- SimpleParameterCSVFormatter() - Constructor for class ds.funnel.traffic.formatter.SimpleParameterCSVFormatter
-
- size - Static variable in class ds.funnel.samples.TimerTestNode
-
- size(String) - Method in interface ds.granules.dataset.FileAccess
-
Deprecated.
Returns the current size of the file in question
- size(String) - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- size() - Method in class ds.granules.util.Matrix
-
- SizeDistributionFactory - Class in ds.funnel.traffic.factory
-
SizeDistributionFactory creates PacketSizeDistributions of the appropriate
concrete types based upon ComponentSpecifications.
- SizeDistributionFactory() - Constructor for class ds.funnel.traffic.factory.SizeDistributionFactory
-
- SizeDistributionType - Class in ds.funnel.traffic.component.types
-
- SizeDistributionType() - Constructor for class ds.funnel.traffic.component.types.SizeDistributionType
-
- sizeOfExternalLibraries() - Method in interface ds.granules.scheduler.LibraryManager
-
- sleep(long) - Static method in class ds.funnel.util.NanoSleep
-
- SmallWorld - Class in ds.funnel.overlay.topology
-
- SmallWorld(int, double) - Constructor for class ds.funnel.overlay.topology.SmallWorld
-
- SORT_NAME_ASC - Static variable in class ds.funnel.topic.TopicBase
-
- splitMessage(MessageEvent, MessageLink) - Method in interface ds.funnel.overlay.routing.ChunkPolicy
-
Splits a message into one or more smaller message chunks.
- splitMessage(MessageEvent, MessageLink) - Method in class ds.funnel.overlay.routing.ChunkPolicyImpl
-
- START_STOP - Static variable in interface ds.granules.bridge.ControlMessage
-
- startComponent() - Method in interface ds.funnel.node.compnt.NodeComponent
-
Start the component and any sub-components
- startComponent() - Method in class ds.funnel.node.compnt.NodeComponentImpl
-
- startedExecution(String, String, TaskLifecycleMetrics) - Method in class ds.granules.interfere.computation.ComputationManager
-
- startedExecution(String, String, TaskLifecycleMetrics) - Method in class ds.granules.operation.InstanceDeployer
-
- startedExecution(String, String, TaskLifecycleMetrics) - Method in interface ds.granules.operation.JobLifecycleObserver
-
This method is invoked when the first task reports that it has
begun execution.
- startExecution(String, int, JavaMessageHandler) - Method in class ds.granules.bridge.JavaGenericComputation
-
Starts execution of a bridged program, needs actual execution command,
type of communication, and a link to the appropriate message handler As a
note, error stream is used even with TCP communications
- startExecution(String, int, JavaMessageHandler) - Method in class ds.granules.bridge.JavaPoolComputation
-
Starts execution of a bridged program, needs actual execution command,
type of communication, and a link to the appropriate message handler As a
note, error stream is used even with TCP communications
- startMigration(double) - Method in class ds.granules.interfere.computation.GIComputation
-
- startNode(ThreadGroup) - Method in interface ds.funnel.node.Node
-
Start the node threads.
- startNode(ThreadGroup) - Method in class ds.funnel.node.NodeBase
-
Register this node's message events.
- startRouter() - Static method in class ds.funnel.peer.RouterNode
-
- startServices() - Static method in class ds.funnel.Funnel
-
Start funnel services by starting a router node.
- startStream(ComputationDescription) - Method in class ds.granules.interfere.streaming.GIStreamingNode
-
- startStream(ComputationDescription) - Method in class ds.granules.interfere.streaming.GIStreamingNodeProxy
-
- startStream(ComputationDescription) - Method in interface ds.granules.interfere.streaming.GIStreamingProxyOps
-
- startTask() - Method in class ds.funnel.node.task.Task
-
- startTaskAsync() - Method in class ds.funnel.node.task.ScheduledTask
-
- startTaskEvent() - Method in class ds.funnel.node.task.DispatchEventTask
-
- startTaskEvent(EventDispatcher) - Method in class ds.funnel.node.task.DispatchEventTask
-
- startTaskEvent(EventDispatcher, long) - Method in class ds.funnel.node.task.DispatchEventTask
-
- startTaskLater(long) - Method in class ds.funnel.node.task.ScheduledTask
-
- startTaskSelect(SelectableChannel, int) - Method in class ds.funnel.node.task.SelectableTask
-
- startTaskSelectOnce(SelectableChannel, int) - Method in class ds.funnel.node.task.SelectableTask
-
- startTaskTimer(long, long) - Method in class ds.funnel.node.task.ScheduledTask
-
- startTimer() - Method in class ds.granules.interfere.computation.StreamTimer
-
- startTimer(long, long) - Method in class ds.granules.interfere.computation.StreamTimer
-
- state - Variable in class ds.funnel.peer.event.MsgTopicLookup
-
- STATUS - Static variable in interface ds.granules.bridge.ControlMessage
-
- STATUS - Static variable in class ds.granules.exchange.DeploymentMessage
-
- stopComponent() - Method in interface ds.funnel.node.compnt.NodeComponent
-
Stop the component and any sub-components
- stopComponent() - Method in class ds.funnel.node.compnt.NodeComponentImpl
-
- stopNode() - Method in interface ds.funnel.node.Node
-
Interrupt and stop node threads.
- stopNode() - Method in class ds.funnel.node.NodeBase
-
- stopStream(UUID) - Method in class ds.granules.interfere.streaming.GIStreamingNode
-
- stopStream(UUID) - Method in class ds.granules.interfere.streaming.GIStreamingNodeProxy
-
- stopStream(UUID) - Method in interface ds.granules.interfere.streaming.GIStreamingProxyOps
-
- STORAGE_INFO - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- StorageException - Exception in ds.synapse.files
-
- StorageException(String) - Constructor for exception ds.synapse.files.StorageException
-
- StorageException(String, Throwable) - Constructor for exception ds.synapse.files.StorageException
-
- store(boolean) - Method in interface ds.synapse.files.FileAccess
-
- store(boolean) - Method in class ds.synapse.files.sdht.DHTFileAccess
-
- stream - Variable in class ds.granules.interfere.computation.ComputationStats
-
- STREAM_SYNC_DELAY - Static variable in class ds.granules.interfere.placement.GIPlacementNode
-
- StreamBuffer - Interface in ds.funnel.data.buffer
-
- StreamBufferArrayImpl - Class in ds.funnel.data.buffer
-
- StreamBufferArrayImpl() - Constructor for class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- StreamBufferArrayImpl(byte[]) - Constructor for class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- StreamBufferImpl - Class in ds.funnel.data.buffer
-
- StreamBufferImpl() - Constructor for class ds.funnel.data.buffer.StreamBufferImpl
-
- StreamBufferImpl(byte[]) - Constructor for class ds.funnel.data.buffer.StreamBufferImpl
-
- StreamBufferTest - Class in ds.funnel.data.buffer
-
- StreamBufferTest() - Constructor for class ds.funnel.data.buffer.StreamBufferTest
-
- StreamCtrlPayload - Class in ds.granules.interfere.computation
-
- StreamCtrlPayload(byte[]) - Constructor for class ds.granules.interfere.computation.StreamCtrlPayload
-
- StreamCtrlPayload(StreamCtrlPayload.CtrlType, UUID, byte[]) - Constructor for class ds.granules.interfere.computation.StreamCtrlPayload
-
- StreamCtrlPayload.CtrlType - Enum in ds.granules.interfere.computation
-
- StreamDataPayload - Class in ds.granules.interfere.computation
-
- StreamDataPayload(byte[]) - Constructor for class ds.granules.interfere.computation.StreamDataPayload
-
- StreamDataPayload(long, byte[], long) - Constructor for class ds.granules.interfere.computation.StreamDataPayload
-
- StreamDataset - Interface in ds.granules.dataset
-
The interface which augments the Dataset interface to support
streaming capabilities.
- StreamDatasetImpl - Class in ds.granules.dataset
-
This class is a streaming implementation of the dataset.
- StreamDatasetImpl(String, String) - Constructor for class ds.granules.dataset.StreamDatasetImpl
-
Share the instance of the client service, so that multiple connections
are not created to the same broker.
- StreamDatasetImpl(FormatReader) - Constructor for class ds.granules.dataset.StreamDatasetImpl
-
- StreamDatasetImplLegacy - Class in ds.granules.dataset
-
Deprecated.
- StreamDatasetImplLegacy(String, String) - Constructor for class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- StreamDatasetImplLegacy(FormatReader) - Constructor for class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- StreamingAccess - Interface in ds.granules.dataset
-
Deprecated.
- StreamPublisher - Class in ds.granules.util
-
- StreamPublisher() - Constructor for class ds.granules.util.StreamPublisher
-
Create a new stream publisher instance.
- StreamReader - Class in ds.granules.bridge
-
- StreamReader(InputStream, JavaMessageHandler) - Constructor for class ds.granules.bridge.StreamReader
-
Initializes and starts the StreamReader thread.
- StreamStringReader - Class in ds.granules.bridge
-
- StreamStringReader(InputStream) - Constructor for class ds.granules.bridge.StreamStringReader
-
Initializes and starts a StreamStringReader thread
- StreamTimer - Class in ds.granules.interfere.computation
-
- StreamTimer() - Constructor for class ds.granules.interfere.computation.StreamTimer
-
- StreamWriter - Class in ds.granules.bridge
-
- StreamWriter(OutputStream) - Constructor for class ds.granules.bridge.StreamWriter
-
Initializes and starts the StreamWriter thread.
- STRING - Static variable in interface cgl.narada.event.TemplateProfileAndSynopsisTypes
-
Deprecated.
- STRING - Static variable in interface ds.granules.bridge.ControlMessage
-
- STRING - Static variable in class ds.granules.results.ResultPayload
-
- STRING_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- STRING_ARR - Static variable in interface ds.granules.bridge.ControlMessage
-
- STRING_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- STRING_SYNOPSIS - Static variable in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
- StringTopic - Class in ds.funnel.topic
-
- StringTopic(String) - Constructor for class ds.funnel.topic.StringTopic
-
- StringTopic(FormatReader) - Constructor for class ds.funnel.topic.StringTopic
-
- submit(Runnable) - Method in class ds.funnel.node.task.SuperThreadPool
-
- submit(Operation, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
Submit the given operation for execution.
- submit(Operation, String, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
Submit the given operation for execution.
- submit(Operation, String, String, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
This method allows one to group a set of related tasks together in a Job.
- submitLater(Runnable, long) - Method in class ds.funnel.node.task.SuperThreadPool
-
- submitPeriodic(Runnable, long, long) - Method in class ds.funnel.node.task.SuperThreadPool
-
- submitToPool(ScheduledTask<?>) - Method in class ds.funnel.node.task.TaskThreads
-
Use this method when a task must run in a certain thread group.
- subscribe(TopicSubscriptionHandler) - Method in interface ds.funnel.topic.Topic
-
- subscribe(TopicSubscriptionHandler) - Method in class ds.funnel.topic.TopicBase
-
- SUCCESS - Static variable in interface ds.granules.exchange.ConditionFlag
-
- SuperThreadPool - Class in ds.funnel.node.task
-
- SuperThreadPool(int) - Constructor for class ds.funnel.node.task.SuperThreadPool
-
- SuperThreadPool.SubmittedRunnable - Class in ds.funnel.node.task
-
- SuperThreadPoolTest - Class in ds.funnel.node.task
-
- SuperThreadPoolTest() - Constructor for class ds.funnel.node.task.SuperThreadPoolTest
-
- supportsDataAvailabilityNotifications() - Method in interface ds.granules.dataset.Dataset
-
Indicates whether this dataset supports dynamic data availability
notifications
- supportsDataAvailabilityNotifications() - Method in class ds.granules.dataset.FileDatasetImpl
-
- supportsDataAvailabilityNotifications() - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- supportsDataAvailabilityNotifications() - Method in class ds.granules.dataset.StreamDatasetImpl
-
- supportsDataAvailabilityNotifications() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- SuppressedException - Exception in ds.granules.scheduler
-
This is a utility exception class that is used when it is not possible to
propagated exceptions either within a VM or to a remote VM.
- SuppressedException() - Constructor for exception ds.granules.scheduler.SuppressedException
-
Constructs an SuppressedException with no detail message.
- SuppressedException(String) - Constructor for exception ds.granules.scheduler.SuppressedException
-
Constructs an SuppressedException with the specified detail
message.
- supressDistributionToSource() - Method in interface cgl.narada.event.EventHeaders
-
Deprecated.
Indicates that the message should not be rerouted to it source, that is
contained in the event headers
- supressDistributionToSource() - Method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
Indicates that the message should not be rerouted to it source, that is
contained in the event headers
- switchCommunication(JavaByteMessage, int) - Method in class ds.granules.bridge.JavaGenericComputation
-
Allows the user to switch communication types from Java.
- switchCommunication(JavaByteMessage, int) - Method in class ds.granules.bridge.JavaPoolComputation
-
Allows the user to switch communication types from Java.
- switchStream(InputStream) - Method in class ds.granules.bridge.StreamReader
-
- switchStream(OutputStream) - Method in class ds.granules.bridge.StreamWriter
-
- Synapse - Class in ds.synapse
-
- Synapse() - Constructor for class ds.synapse.Synapse
-
- SynapseDHTDetails - Class in ds.synapse.peer
-
- SynapseDHTDetails(ChannelAddress) - Constructor for class ds.synapse.peer.SynapseDHTDetails
-
- SynapseDHTDetails(FormatReader) - Constructor for class ds.synapse.peer.SynapseDHTDetails
-
- SynapseDHTNode - Class in ds.synapse.peer
-
- SYSTEM_PARTITION - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.