Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W X 

C

cancel() - Method in class ds.funnel.node.task.DispatchEventTask
 
cancel() - Method in class ds.funnel.node.task.ScheduledTask
 
cancel() - Method in class ds.funnel.node.task.SelectableTask
 
cancel() - Method in class ds.funnel.node.task.SuperThreadPool.SubmittedRunnable
 
cancel() - Method in class ds.funnel.node.task.Task
 
cancel() - Method in interface ds.funnel.topic.TopicPublisher
 
cancel() - Method in class ds.funnel.topic.TopicPublisherImpl
 
cancel() - Method in interface ds.funnel.topic.TopicSubscription
 
cancel() - Method in class ds.funnel.topic.TopicSubscriptionImpl
 
cDetails - Variable in class ds.funnel.node.compnt.NodeComponentLinkImpl.OpenedComponentLink
 
cgl.narada.event - package cgl.narada.event
This package contains classes and interfaces specific to the native NaradaBrokering event type.
ChainedTask<P,T> - Class in ds.funnel.node.task
 
ChainedTask() - Constructor for class ds.funnel.node.task.ChainedTask
 
chainTask(ChainedTask<T, ?>) - Method in class ds.funnel.node.task.Task
 
chainTo(UUID) - Method in class ds.funnel.data.msglink.LinkClosedEvent
 
chainTo(UUID) - Method in interface ds.funnel.data.msglink.MessageEvent
Mark that this event belongs to a message chain.
chainTo(UUID) - Method in class ds.funnel.data.msglink.protocol3.MessageBase
 
CHANGE_BRIDGE_TYPE - Static variable in interface ds.granules.bridge.ControlMessage
 
changeToExecuteFixedNumberOfTimes(int) - Method in class ds.granules.operation.ExecutionProfileSetup
 
changeToExecuteOnce() - Method in class ds.granules.operation.ExecutionProfileSetup
 
changeToExecutePeriodically(long) - Method in class ds.granules.operation.ExecutionProfileSetup
 
changeToExecuteWhenDataAvailable() - Method in class ds.granules.operation.ExecutionProfileSetup
 
changeToStayAlive() - Method in class ds.granules.operation.ExecutionProfileSetup
 
ChannelAcceptEvent - Class in ds.funnel.data.channel
An event to be triggered when a channel is accepted.
ChannelAcceptEvent(ChannelManager) - Constructor for class ds.funnel.data.channel.ChannelAcceptEvent
Construct this event.
ChannelAddress - Class in ds.funnel.data.channel
 
ChannelAddress.ChannelAddressType - Enum in ds.funnel.data.channel
An enumeration of all accepted marshallable subtypes.
ChannelClosedEvent - Class in ds.funnel.data.channel
An event to be triggered when a channel is closed.
ChannelClosedEvent(ChannelManager) - Constructor for class ds.funnel.data.channel.ChannelClosedEvent
Construct this event.
ChannelEvent - Class in ds.funnel.data.channel
An event to be triggered for channel activity.
ChannelEvent(ChannelManager) - Constructor for class ds.funnel.data.channel.ChannelEvent
Construct this event.
ChannelListener - Class in ds.funnel.data.channel
 
ChannelListener(ServerSocketChannel, ChannelAddress, ChannelProtocolFactory) - Constructor for class ds.funnel.data.channel.ChannelListener
 
ChannelManager - Interface in ds.funnel.data.channel
 
ChannelManagerImpl - Class in ds.funnel.data.channel
 
ChannelManagerImpl(ChannelAddress, ByteChannel, ChannelProtocol) - Constructor for class ds.funnel.data.channel.ChannelManagerImpl
 
ChannelProtocol - Interface in ds.funnel.data.channel
 
ChannelProtocolFactory - Interface in ds.funnel.data.channel
 
ChannelReader - Class in ds.funnel.data.channel
ChannelReader.java: Reads bytes from a channel.
ChannelReader(ReadableByteChannel, ChannelManager) - Constructor for class ds.funnel.data.channel.ChannelReader
Creates a reader task for this channel.
ChannelWriter - Class in ds.funnel.data.channel
ChannelWriter.java: Writes bytes to a channel.
ChannelWriter(WritableByteChannel, ChannelManager) - Constructor for class ds.funnel.data.channel.ChannelWriter
Creates a writer task for this channel.
check - Static variable in class ds.granules.interfere.computation.GIComputation
 
checkArrays(StreamBuffer) - Static method in class ds.funnel.data.buffer.StreamBufferTest
 
checkInsert(StreamBuffer) - Static method in class ds.funnel.data.buffer.StreamBufferTest
 
checkInts(StreamBuffer, int) - Static method in class ds.funnel.data.buffer.StreamBufferTest
 
Checksum - Class in ds.granules.util
Provides convenience functions for dealing with MessageDigest algorithms.
Checksum() - Constructor for class ds.granules.util.Checksum
Initializes a new Checksum generator using the default SHA-1 algorithm.
Checksum(String) - Constructor for class ds.granules.util.Checksum
Initializes a new Checksum generator using the specified algorithm.
checkTypes(StreamBuffer) - Static method in class ds.funnel.data.buffer.StreamBufferTest
 
chunkOffset - Variable in class ds.synapse.files.sdht.MsgFilePut
 
ChunkPolicy - Interface in ds.funnel.overlay.routing
 
ChunkPolicyImpl - Class in ds.funnel.overlay.routing
 
ChunkPolicyImpl(int) - Constructor for class ds.funnel.overlay.routing.ChunkPolicyImpl
 
clear() - Method in interface ds.funnel.data.buffer.StreamBuffer
Clear the contents of the stream buffer, setting position and length to 0.
clear(int) - Method in interface ds.funnel.data.buffer.StreamBuffer
Clear bytes from the current position, cutting them from the buffer.
clear() - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
 
clear(int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
 
clear() - Method in class ds.funnel.data.buffer.StreamBufferImpl
 
clear(int) - Method in class ds.funnel.data.buffer.StreamBufferImpl
 
clearExternalLibraries() - Method in interface ds.granules.scheduler.LibraryManager
 
clearTracker(CompStreamDescription) - Method in class ds.granules.interfere.computation.ComputationUsage
 
clearTracker(CompStreamDescription) - Method in class ds.granules.interfere.prediction.UsageFutureRing
 
CLIENT_EVENT - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CLIENT_PERSISTENT_EVENT - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CLIENT_RECOVERY - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CLIENT_SETUP - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CLIENT_SETUP_FAILURE - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CLIENT_SETUP_SUCCESS - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
close() - Method in interface ds.funnel.data.msglink.MessageLink
Close the connection used by this message handler.
close() - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
 
close() - Method in class ds.funnel.node.event.EventLimiter.QueueSemaphore
 
close() - Method in class ds.funnel.overlay.OverlayLinkImpl
 
close() - Method in interface ds.granules.dataset.Dataset
Close access to this dataset.
close() - Method in class ds.granules.dataset.FileDatasetImpl
 
close() - Method in class ds.granules.dataset.FileDatasetImplLegacy
Deprecated.
 
close() - Method in class ds.granules.dataset.StreamDatasetImpl
 
close() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
Deprecated.
 
close() - Method in interface ds.synapse.data.DataSource
 
close() - Method in class ds.synapse.data.source.CSVFileDataSource
 
close() - Method in class ds.synapse.data.source.FunnelDataSource
 
close() - Method in class ds.synapse.data.source.WindowDataSource
 
close() - Method in class ds.synapse.peer.DHTConnection
Deprecated.
 
closeConnection() - Method in class ds.granules.bridge.JavaGenericComputation
Function to close all open connections
closeConnection() - Method in class ds.granules.bridge.JavaPoolComputation
Function to close all open connections
closingStream() - Method in class ds.granules.bridge.StreamReader
 
clusterCoeff() - Method in class ds.funnel.overlay.graph.Graph
 
commitUpdates() - Method in class ds.funnel.peer.PeerGroupOverlay
 
commitUpdates() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
Deprecated.
 
commitUpdates() - Method in interface ds.granules.dataset.StreamingAccess
Deprecated.
Commit any changes that have been made to the set of streams managed by this dataset.
CommunicationsException - Exception in ds.granules.exception
This is an exception that is thrown when there are communications related problems that have been encountered.
CommunicationsException(String) - Constructor for exception ds.granules.exception.CommunicationsException
Constructs an CommunicationsException with the specified detail message.
CommunicationsException(String, Throwable) - Constructor for exception ds.granules.exception.CommunicationsException
Constructs an CommunicationsException with the specified detail message.
COMP_DIST - Static variable in class ds.funnel.overlay.OverlayPathImpl
 
COMP_FLAT - Static variable in class ds.funnel.overlay.OverlayPathImpl
 
compare(Object, Object) - Method in class ds.funnel.util.NaturalComparator
 
compareTo(SuperThreadPool.SubmittedRunnable) - Method in class ds.funnel.node.task.SuperThreadPool.SubmittedRunnable
 
COMPLETE - Static variable in interface ds.granules.bridge.ControlMessage
 
COMPLETE - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
completedExecution(String, String, TaskLifecycleMetrics) - Method in class ds.granules.interfere.computation.ComputationManager
 
completedExecution(String, String, TaskLifecycleMetrics) - Method in class ds.granules.operation.InstanceDeployer
 
completedExecution(String, String, TaskLifecycleMetrics) - Method in interface ds.granules.operation.JobLifecycleObserver
This method is invoked when a task has completed execution either successfully or due to an abnormal termination or previously issued abort request.
completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.interfere.computation.ComputationManager
 
completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.operation.InstanceDeployer
 
completedSuccessfully(String, ProgressTracker) - Method in interface ds.granules.operation.JobLifecycleObserver
This method is invoked when all the constituent distributed tasks have finished executing successfully.
completedTask(String) - Method in class ds.granules.scheduler.Diagnostics
Process the completion of the task.
completedWithErrors(String, ProgressTracker) - Method in class ds.granules.interfere.computation.ComputationManager
 
completedWithErrors(String, ProgressTracker) - Method in class ds.granules.operation.InstanceDeployer
 
completedWithErrors(String, ProgressTracker) - Method in interface ds.granules.operation.JobLifecycleObserver
This method is invoked when we have heard from all the sub-tasks, and one or more errors have been encountered in the execution of constituent tasks.
completeJob() - Method in class ds.granules.interfere.computation.ComputationManager
 
ComplexComponentSpecification - Class in ds.funnel.traffic.factory
A ComplexComponentSpecification is a ComponentSpecification which specifies how to construct a 'complex' component for a TrafficGenerator.
ComplexComponentSpecification() - Constructor for class ds.funnel.traffic.factory.ComplexComponentSpecification
Creates a new complex component specification with undefined types and empty parameter and base component lists.
ComplexComponentSpecification(ComponentType) - Constructor for class ds.funnel.traffic.factory.ComplexComponentSpecification
Creates a new complex component specification with the provided main type, undefined specific type, and empty parameter and base component lists.
ComplexComponentSpecification(ComponentType, int) - Constructor for class ds.funnel.traffic.factory.ComplexComponentSpecification
Creates a new complex component specification with the provided types and empty parameter and base component lists.
ComplexComponentSpecification(ComponentType, int, String...) - Constructor for class ds.funnel.traffic.factory.ComplexComponentSpecification
Creates a new complex component specification with the provided types and parameter list, and an empty base component list.
ComplexComponentSpecification(ComponentType, int, List<ComponentSpecification>, String...) - Constructor for class ds.funnel.traffic.factory.ComplexComponentSpecification
Creates a new complex component specification with the provided types, parameter list, and base component list.
ComponentException - Exception in ds.funnel.node.compnt
 
ComponentException(String) - Constructor for exception ds.funnel.node.compnt.ComponentException
 
ComponentException(String, Throwable) - Constructor for exception ds.funnel.node.compnt.ComponentException
 
componentKey - Variable in class ds.funnel.data.msglink.event.MsgLinkAssociate
 
ComponentLinker - Interface in ds.funnel.node.compnt
 
ComponentManager - Interface in ds.funnel.node.compnt
 
ComponentSpecification - Class in ds.funnel.traffic.factory
An instance of the ComponentSpecification class contains all of the information needed to create a component for a TrafficGenerator.
ComponentSpecification() - Constructor for class ds.funnel.traffic.factory.ComponentSpecification
Creates a new specification with undefined main and specific types, and an empty parameter list.
ComponentSpecification(ComponentType) - Constructor for class ds.funnel.traffic.factory.ComponentSpecification
Creates a new specification with the given main type, an undefined specific type, and an empty parameter list.
ComponentSpecification(ComponentType, int) - Constructor for class ds.funnel.traffic.factory.ComponentSpecification
Creates a new specification with the given main and specific types, and an empty parameter list.
ComponentSpecification(ComponentType, int, String...) - Constructor for class ds.funnel.traffic.factory.ComponentSpecification
Creates a new specification with the given parameter list and types.
ComponentType - Enum in ds.funnel.traffic.component.types
 
CompStreamDescription - Class in ds.granules.interfere.computation
 
CompStreamDescription(String, String, String, int) - Constructor for class ds.granules.interfere.computation.CompStreamDescription
 
ComputationDescription - Class in ds.granules.interfere.computation
 
ComputationDescription(String, String) - Constructor for class ds.granules.interfere.computation.ComputationDescription
 
ComputationFactory - Interface in ds.granules.interfere.computation
 
ComputationManager - Class in ds.granules.interfere.computation
 
ComputationManager.ComputationManagerState - Enum in ds.granules.interfere.computation
 
ComputationStats - Class in ds.granules.interfere.computation
 
ComputationStats() - Constructor for class ds.granules.interfere.computation.ComputationStats
 
ComputationUsage - Class in ds.granules.interfere.computation
 
ComputationUsage() - Constructor for class ds.granules.interfere.computation.ComputationUsage
 
ComputationUsage.ComputationUsageType - Enum in ds.granules.interfere.computation
An enumeration of all accepted marshallable subtypes.
ComputationUsageTracker - Interface in ds.granules.interfere.computation
 
ConditionFlag - Interface in ds.granules.exchange
This interface outlines the status associated with various exchanges.
ConfigurationParser - Class in ds.funnel.traffic.factory
This class contains methods to parse the contents of a string which specifies components for a TrafficGenerator object.
ConfigurationParser() - Constructor for class ds.funnel.traffic.factory.ConfigurationParser
Creates a new ConfigurationParser without any set string to parse; a string should be given to the parser before attempting to call the parseConfigurationString() method.
ConfigurationParser(String) - Constructor for class ds.funnel.traffic.factory.ConfigurationParser
Creates a new ConfigurationParser which will parse the specified configuration string.
configureComponent(ComponentSpecification) - Method in class ds.funnel.traffic.factory.TrafficGeneratorBuilder
Configures the builder to use a component following the provided specification when the createTrafficGenerator() method is called.
configureComponentsFromFile(String) - Method in class ds.funnel.traffic.factory.TrafficGeneratorBuilder
If the configurationFile contains a valid specification for a traffic generator as defined in the ConfigurationParser class, configures the builder to create the desired component types with the specified parameters.
configureComponentsFromString(String) - Method in class ds.funnel.traffic.factory.TrafficGeneratorBuilder
If the configurationString contains a valid specification for a traffic generator as defined in the ConfigurationParser class, configures the builder to create the desired component types with the specified parameters.
CONN_ALREADY - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CONN_REQ - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CONN_SETUP - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CONN_SUCC - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
connect(ChannelProtocol) - Method in class ds.funnel.data.channel.ChannelAddress
Opens a new connection to the node.
connect(ByteChannel, ChannelProtocol) - Method in class ds.funnel.data.channel.ChannelAddress
Completes a connection made to the node.
connect(ChannelProtocol) - Method in class ds.funnel.data.channel.tcp.TCPChannelAddr
 
connect(ByteChannel, ChannelProtocol) - Method in class ds.funnel.data.channel.tcp.TCPChannelAddr
 
connect(ChannelProtocol) - Method in class ds.funnel.data.channel.udp.UDPChannelAddr
 
connect(ByteChannel, ChannelProtocol) - Method in class ds.funnel.data.channel.udp.UDPChannelAddr
 
ConnectException - Exception in ds.funnel.data.channel
 
ConnectException(String) - Constructor for exception ds.funnel.data.channel.ConnectException
 
ConnectException(String, Throwable) - Constructor for exception ds.funnel.data.channel.ConnectException
 
CONNECTION_ADDED - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CONNECTION_BUFFER - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
CONNECTION_LOST - Static variable in interface cgl.narada.event.Protocol
Deprecated.
 
ConsoleTGLogFormatter - Class in ds.funnel.traffic.formatter
A ConsoleTGLogFormatter can be used to format LogRecords as a record of a packet transmission.
ConsoleTGLogFormatter() - Constructor for class ds.funnel.traffic.formatter.ConsoleTGLogFormatter
 
consolidateAndFree() - Method in interface ds.funnel.data.buffer.StreamBuffer
Copies buffer contents into a single heap buffer and frees unused buffers.
consolidateAndFree() - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
 
consolidateAndFree() - Method in class ds.funnel.data.buffer.StreamBufferImpl
 
Controller - Interface in ds.granules.scheduler
This is an interface which snapshots functionalities that need to be supported for managing tasks and their constituent libraries.
ControlMessage - Interface in ds.granules.bridge
Responsible for enumerating communication types across a bridge.
convertByteArrayToLongArray(byte[]) - Method in class ds.granules.util.MarshallingUtil
Converts a byte[] into a long[]
convertLongArrayToByteArray(long[]) - Method in class ds.granules.util.MarshallingUtil
Converts a long[] into a byte[].
coord - Variable in class ds.funnel.peer.event.MsgTopicAdvert
 
coordPath - Variable in class ds.funnel.peer.event.MsgTopicAdvert
 
count - Variable in class ds.granules.interfere.computation.ComputationStats
 
create2080(List<Object>, int, int) - Static method in class ds.funnel.overlay.topology.PowerLaw
 
createComputations(String[], int) - Method in interface ds.granules.interfere.placement.component.GICompDistrCmpnt
 
createComputations(String[], int) - Method in class ds.granules.interfere.placement.component.GICompDistrImpl
 
createDatasetCollection() - Method in class ds.granules.dataset.DatasetFactory
Creates a dataset collection
createDenseIntColumn(int) - Method in class ds.granules.util.Matrix
 
createDenseIntRow() - Method in class ds.granules.util.Matrix
 
createDeploymentResponse(String, String, int, int, String) - Method in class ds.granules.exchange.ExchangeFactory
Creates a deployment response, to a previously issued request.
createDeploymentStatusOrAbortRequest(String, String, String, int) - Method in class ds.granules.exchange.ExchangeFactory
Creates a DeploymentMessage that is a request for either getting the STATUS or ABORTing a previously deployment operation.
createDepoymentRequest(String, Operation, String) - Method in class ds.granules.exchange.ExchangeFactory
Creates a deployment request based on the specified parameters.
createdTask(String, TaskLifecycleMetrics) - Method in class ds.granules.scheduler.Diagnostics
Manage information about the newly created task.
createExecutionStatusRequest(String, String, String) - Method in class ds.granules.exchange.ExchangeFactory
Creates an ExecutionStatus REQUEST based on the specified parameters
createExecutionStatusResponse(String, String, int, String, TaskLifecycleMetrics, String) - Method in class ds.granules.exchange.ExchangeFactory
Creates an ExecutionStatus RESPONSE based on the specified parameters
createFile(String) - Method in interface ds.synapse.files.FileFactory
 
createFile(String) - Method in class ds.synapse.files.sdht.DHTFileStorage
 
createFileDataset(String, String) - Method in class ds.granules.dataset.DatasetFactory
Creates a file dataset based on the specified arguments.
createHeaderSnapshot() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Creates a snapshot of the headers contained in the event headers
createJobIdentifier() - Method in class ds.granules.operation.InstanceDeployer
Create a Job Identifier.
createJobIdentifier() - Method in class ds.granules.operation.JobSubmission
Creates a Job Identifier
createLegacyFileDataset(String, String) - Method in class ds.granules.dataset.DatasetFactory
Deprecated.
createOverlay(long) - Method in interface ds.funnel.overlay.OverlayManager
Create a specific version of the overlay.
createOverlay(long) - Method in class ds.funnel.overlay.OverlayManagerImpl
 
createPacketGenerator(ComponentSpecification) - Static method in class ds.funnel.traffic.factory.PacketGeneratorFactory
Creates a new PacketGenerator following the provided ComponentSpecification, if the specification is valid (has the correct main and specific type identifiers for a recognized packet generator type, and has valid parameters for the specified packet generator).
createProtocol() - Method in interface ds.funnel.data.channel.ChannelProtocolFactory
 
createProtocol() - Method in class ds.funnel.data.msglink.protocol3.MessageLinkFactory
 
createResourceDiscoveryRequest(int, String) - Method in class ds.granules.exchange.ExchangeFactory
Create a ResourceDiscovery request
createResourceDiscoveryResponse(int, String, ResourceMetrics, String) - Method in class ds.granules.exchange.ExchangeFactory
Creates a ResourceDiscovery response
createResult(String, boolean, boolean) - Method in class ds.granules.results.ResultsFactory
This method creates a Results object.
createResults(boolean, boolean) - Method in interface ds.granules.operation.MapReduce
Create the Results type to be used for reporting results produced as a result of the processing.
createResults(boolean, boolean) - Method in class ds.granules.operation.MapReduceBase
 
createSequenceInfo() - Method in interface ds.granules.results.Results
Create the sequencing information to be associated with this result.
createSequenceInfo() - Method in class ds.granules.results.ResultsWidget
 
createSequencingInfo() - Method in class ds.granules.results.ResultsFactory
Creates a sequencing info object.
createSizeDistribution(ComponentSpecification) - Static method in class ds.funnel.traffic.factory.SizeDistributionFactory
Creates a new PacketSizeDistribution following the provided ComponentSpecification, if the specification is valid (has the correct main and specific type identifiers for a recognized size distribution type, and has valid parameters for the specified size distribution).
createStreamDataset(String, String) - Method in class ds.granules.dataset.DatasetFactory
Creates a streaming dataset based on the specified arguments.
createStreamingDataset(String, String) - Method in class ds.granules.dataset.DatasetFactory
Deprecated.
createTimeDistribution(ComponentSpecification) - Static method in class ds.funnel.traffic.factory.TimeDistributionFactory
 
createTrafficGenerator() - Method in class ds.funnel.traffic.factory.TrafficGeneratorBuilder
 
createTrafficGenerator(EventDispatcher) - Method in class ds.funnel.traffic.factory.TrafficGeneratorBuilder
 
createTrafficGenerator(EventDispatcher, String) - Method in class ds.funnel.traffic.factory.TrafficGeneratorBuilder
 
CSVFileDataSource - Class in ds.synapse.data.source
 
CSVFileDataSource(String, int, int[], String, int) - Constructor for class ds.synapse.data.source.CSVFileDataSource
 
CUR_VER - Static variable in interface ds.funnel.overlay.OverlayManager
 
curLoc - Variable in class ds.funnel.peer.event.MsgTopicRepair
 
A B C D E F G H I J K L M N O P Q R S T U V W X 
Skip navigation links