- main(String[]) - Static method in class cgl.narada.event.ByteUtilities
-
Deprecated.
- main(String[]) - Static method in class cgl.narada.event.DistributionTracesImpl
-
Deprecated.
- main(String[]) - Static method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
A test routine to test the functionality
- main(String[]) - Static method in class cgl.narada.event.EventID
-
Deprecated.
- main(String[]) - Static method in class cgl.narada.event.EventIDGenerator
-
Deprecated.
- main(String[]) - Static method in class cgl.narada.event.NBEventImpl
-
Deprecated.
A utility method to test the NBEvent implementation
- main(String[]) - Static method in class ds.funnel.data.buffer.StreamBufferTest
-
- main(String[]) - Static method in class ds.funnel.node.task.SuperThreadPoolTest
-
- main(String[]) - Static method in class ds.funnel.peer.RouterNode
-
- main(String[]) - Static method in class ds.funnel.samples.FunTestNode
-
- main(String[]) - Static method in class ds.funnel.samples.IOTestNode
-
- main(String[]) - Static method in class ds.funnel.samples.MPTestNodeA
-
- main(String[]) - Static method in class ds.funnel.samples.MPTestNodeB
-
- main(String[]) - Static method in class ds.funnel.samples.NanoTimeSample
-
- main(String[]) - Static method in class ds.funnel.samples.PublishSubscribeSample
-
- main(String[]) - Static method in class ds.funnel.samples.TimerTestNode
-
- main(String[]) - Static method in class ds.funnel.samples.UDPTestNode
-
- main(String[]) - Static method in class ds.funnel.traffic.analysis.DatasetProducer
-
- main(String[]) - Static method in class ds.funnel.traffic.analysis.regress.DatasetEnhancer
-
- main(String[]) - Static method in class ds.funnel.traffic.analysis.regress.RegressStarter
-
- main(String[]) - Static method in class ds.funnel.traffic.analysis.TrafficPublisher
-
- main(String[]) - Static method in class ds.funnel.traffic.analysis.TrafficReflector
-
- main(String[]) - Static method in class ds.funnel.traffic.driver.TrafficGeneratorDriver
-
- main(String[]) - Static method in class ds.funnel.util.NaturalComparator
-
- main(String[]) - Static method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- main(String[]) - Static method in class ds.granules.interfere.computation.ecg.ECGDeployer
-
- main(String[]) - Static method in class ds.granules.interfere.computation.eeg.EEGDeployer
-
- main(String[]) - Static method in class ds.granules.interfere.computation.thorax.RespirationMonitorDeployer
-
- main(String[]) - Static method in class ds.granules.interfere.InterfereTest
-
- main(String[]) - Static method in class ds.granules.interfere.placement.GIPlacementNode
-
- main(String[]) - Static method in class ds.granules.interfere.PredictionTest
-
- main(String[]) - Static method in class ds.granules.interfere.resource.GIResourceNode
-
- main(String[]) - Static method in class ds.granules.interfere.streaming.GIStreamingNode
-
- main(String[]) - Static method in class ds.granules.samples.uppercase.UpperCaseDeployer
-
- main(String[]) - Static method in class ds.granules.samples.uppercase.UpperCaseProducer
-
- main(String[]) - Static method in class ds.granules.samples.wordcount.WordCountDeployer
-
- main(String[]) - Static method in class ds.granules.scheduler.Resource
-
Main entry point for a Granules computational resource.
- main(String[]) - Static method in class ds.granules.util.Matrix
-
- main(String[]) - Static method in class ds.granules.util.MatrixColumnMajor
-
- main(String[]) - Static method in class ds.granules.util.UUIDRetriever
-
- main(String[]) - Static method in class ds.granules.util.Version
-
- main(String[]) - Static method in class ds.synapse.peer.SynapseDHTNode
-
Entry point for peer node.
- manageExecution(String, Operation) - Method in class ds.granules.scheduler.TaskManagement
-
Manage the execution of the given operation
- Map - Interface in ds.granules.operation
-
This interface corresponds to the Map role in a Map-Reduce operation.
- MapReduce - Interface in ds.granules.operation
-
This is an interface which encapsulates functionality that is common to both
the Map and Reduce roles that are associated with
the applications.
- MapReduceBase - Class in ds.granules.operation
-
This is the base class which will serve as the base for implementations of
the Map and Reduce interface.
- MapReduceBase() - Constructor for class ds.granules.operation.MapReduceBase
-
- MapReduceException - Exception in ds.granules.operation
-
This is the exception that would be thrown if there are problems in
performing Map-Reduce operations.
- MapReduceException() - Constructor for exception ds.granules.operation.MapReduceException
-
Constructs an ProcessingException with no detail message.
- MapReduceException(String) - Constructor for exception ds.granules.operation.MapReduceException
-
Constructs an ProcessingException with the specified detail
message.
- markFillTime() - Method in interface ds.granules.interfere.computation.ComputationUsageTracker
-
- markFillTime() - Method in class ds.granules.interfere.prediction.PredictionTrackList
-
- markFillTime() - Method in class ds.granules.interfere.prediction.PredictionTrackRoll
-
- markInitializationAsComplete() - Method in class ds.granules.operation.OperationBase
-
- markSentTo(MessageEvent, NodeDetails) - Method in class ds.funnel.data.msglink.ReplyStatus
-
- markUpdate(Graph, GraphNode) - Method in interface ds.funnel.overlay.graph.GraphListener
-
- markUpdate(Graph, GraphNode) - Method in class ds.funnel.peer.PeerGroupOverlay
-
- markUsageEnd() - Method in interface ds.granules.interfere.computation.ComputationUsageTracker
-
- markUsageEnd() - Method in class ds.granules.interfere.prediction.PredictionTrackList
-
- markUsageEnd() - Method in class ds.granules.interfere.prediction.PredictionTrackRoll
-
- markUsageStart() - Method in interface ds.granules.interfere.computation.ComputationUsageTracker
-
- markUsageStart() - Method in class ds.granules.interfere.prediction.PredictionTrackList
-
- markUsageStart() - Method in class ds.granules.interfere.prediction.PredictionTrackRoll
-
- marshall(Object) - Static method in class cgl.narada.event.ObjectMarshaller
-
Deprecated.
Marshall an object into a byte stream
- marshall(ChannelAddress.ChannelAddressType, FormatWriter) - Method in class ds.funnel.data.channel.ChannelAddress
-
Write this object to a message output object.
- marshall(FormatWriter) - Method in class ds.funnel.data.channel.tcp.TCPChannelAddr
-
- marshall(FormatWriter) - Method in class ds.funnel.data.channel.udp.UDPChannelAddr
-
- marshall(FormatWriter) - Method in interface ds.funnel.data.format.FormatMarshaller
-
- marshall(FormatWriter) - Method in class ds.funnel.data.msglink.LinkStatisticsImpl
-
- marshall(FormatWriter) - Method in class ds.funnel.data.msglink.LinkStatisticsSnapshotImpl
-
- marshall(FormatWriter, Object) - Method in class ds.funnel.data.msglink.protocol3.MessageFormatMarshaller
-
Marshall the passed object, writing it to the passed formatter.
- marshall(FormatWriter) - Method in class ds.funnel.node.compnt.NodeComponentKey
-
- marshall(FormatWriter) - Method in class ds.funnel.overlay.OverlayPathImpl
-
- marshall(FormatWriter) - Method in class ds.funnel.peer.RouterDetails
-
- marshall(FormatWriter) - Method in class ds.funnel.topic.StringTopic
-
- marshall(FormatWriter) - Method in enum ds.granules.dataset.Dataset.DatasetType
-
- marshall(FormatWriter) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- marshall(FormatWriter) - Method in class ds.granules.dataset.FileDatasetImpl
-
- marshall(FormatWriter) - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- marshall(FormatWriter) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- marshall(FormatWriter) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- marshall(FormatWriter) - Method in class ds.granules.interfere.computation.CompStreamDescription
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.computation.ComputationDescription
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.computation.GIComputation
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.placement.GIPlacementDetails
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.prediction.PredictionRing
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.prediction.UsageFutureRing
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.resource.GIResourceDetails
-
- marshall(FormatWriter) - Method in class ds.granules.interfere.streaming.GIStreamingDetails
-
- marshall(FormatWriter) - Method in class ds.granules.operation.MapReduceBase
-
- marshall(FormatWriter) - Method in class ds.granules.operation.OperationBase
-
- marshall(FormatWriter) - Method in class ds.granules.results.ResultsWidget
-
- marshall(FormatWriter) - Method in class ds.granules.results.SequencingWidget
-
- marshall(FormatWriter) - Method in class ds.synapse.peer.SynapseDHTDetails
-
- marshallExchangeSpecificElements(FormatWriter) - Method in class ds.granules.exchange.DeploymentMessage
-
- marshallExchangeSpecificElements(FormatWriter) - Method in class ds.granules.exchange.Exchange
-
This method is utilized by the derived classes to marshall (or serialize)
elements that are specific to the derived class.
- marshallExchangeSpecificElements(FormatWriter) - Method in class ds.granules.exchange.ExecutionStatus
-
- marshallExchangeSpecificElements(FormatWriter) - Method in class ds.granules.exchange.ResourceDiscovery
-
- MarshallingException - Exception in ds.granules.exception
-
This is an exception that is thrown if there are problems marshalling or
unmarshalling exchanges.
- MarshallingException() - Constructor for exception ds.granules.exception.MarshallingException
-
Constructs an MarshallingException with no detail message.
- MarshallingException(String) - Constructor for exception ds.granules.exception.MarshallingException
-
Constructs an MarshallingException with the specified detail
message.
- MarshallingUtil - Class in ds.granules.util
-
This is a utility class which includes methods for marshalling and
un-marshalling several commonly used data types.
- MarshallingUtil() - Constructor for class ds.granules.util.MarshallingUtil
-
- marshallToBuffer(int, long) - Method in class ds.funnel.data.msglink.protocol3.MessageBase
-
Update the header and return a new StreamBuffer view of the data for writing.
- MASTER_TOPIC - Static variable in class ds.funnel.peer.PeerManagerImpl
-
- match(String) - Method in class ds.funnel.topic.StringTopic
-
- matchWith(Topic) - Method in class ds.funnel.topic.StringTopic
-
- Matrix - Class in ds.granules.util
-
A class that encapsulates a Matrix.
- Matrix(String, int, int, boolean, int) - Constructor for class ds.granules.util.Matrix
-
- Matrix(String) - Constructor for class ds.granules.util.Matrix
-
- MatrixColumnMajor - Class in ds.granules.util
-
A matrix encapsulator where the Matrix is stored in column-major format for
faster reads from the underlying file system.
- MatrixColumnMajor(String, int, int, boolean, int) - Constructor for class ds.granules.util.MatrixColumnMajor
-
- MatrixColumnMajor(String) - Constructor for class ds.granules.util.MatrixColumnMajor
-
- MatrixFactory - Class in ds.granules.util
-
This is a Factory class which creates matrices that are stored either in row
major or column major formats.
- MatrixFactory() - Constructor for class ds.granules.util.MatrixFactory
-
- MD5Checksum - Class in ds.granules.util
-
A class that calculate checksum for a string.
- MD5Checksum() - Constructor for class ds.granules.util.MD5Checksum
-
- mergeMessage(MessageEvent[]) - Method in interface ds.funnel.overlay.routing.ChunkPolicy
-
Merge one or more message chunks into a single message.
- mergeMessage(MessageEvent[]) - Method in class ds.funnel.overlay.routing.ChunkPolicyImpl
-
- mergeUsage(ComputationUsage) - Method in class ds.granules.interfere.computation.ComputationUsage
-
- mergeUsage(ComputationUsage) - Method in class ds.granules.interfere.prediction.UsageFutureRing
-
- message - Variable in class ds.funnel.data.msglink.event.MsgLinkTestping
-
- message - Variable in class ds.funnel.data.msglink.event.MsgLinkTestpong
-
- MessageBase - Class in ds.funnel.data.msglink.protocol3
-
Message.java: Marshals and unmarshals messages.
- MessageBaseTE - Class in ds.funnel.peer.event
-
- MessageEvent - Interface in ds.funnel.data.msglink
-
- MessageFormat - Class in ds.funnel.data.msglink.protocol3
-
MessageOutput.java: Supplies methods to write data to a buffer.
- MessageFormat() - Constructor for class ds.funnel.data.msglink.protocol3.MessageFormat
-
Creates a new MessageOutput object.
- MessageFormat(byte[]) - Constructor for class ds.funnel.data.msglink.protocol3.MessageFormat
-
- MessageFormat(StreamBuffer) - Constructor for class ds.funnel.data.msglink.protocol3.MessageFormat
-
- MessageFormatMarshaller - Class in ds.funnel.data.msglink.protocol3
-
- MessageFormatMarshaller() - Constructor for class ds.funnel.data.msglink.protocol3.MessageFormatMarshaller
-
- MessageFormatMarshaller.MarshallerType - Enum in ds.funnel.data.msglink.protocol3
-
- MessageLink - Interface in ds.funnel.data.msglink
-
- MessageLinkFactory - Class in ds.funnel.data.msglink.protocol3
-
- MessageLinkFactory(int) - Constructor for class ds.funnel.data.msglink.protocol3.MessageLinkFactory
-
Create a new protocol store.
- MessageProtocol - Class in ds.funnel.data.msglink.protocol3
-
- MessageProtocol(NodeDetails, int) - Constructor for class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- MessageType - Enum in ds.funnel.data.msglink
-
MessageType.java: An enumeration of all valid message types.
- methodId - Variable in class ds.funnel.data.msglink.event.MsgLinkMethodCall
-
- MIGRATE_LEAVEALONE - Static variable in class ds.granules.interfere.placement.GIPlacementNode
-
- MIGRATE_TASKRATE - Static variable in class ds.granules.interfere.placement.GIPlacementNode
-
- MIGRATE_THRESH_PCT - Static variable in class ds.granules.interfere.placement.GIPlacementNode
-
- migrCt - Variable in class ds.granules.interfere.placement.component.GIResourceTrackerImpl.ResourceState
-
- migrFinished() - Method in class ds.granules.interfere.resource.component.GIResourceMonitor
-
- migrTry - Variable in class ds.granules.interfere.placement.component.GIResourceTrackerImpl.ResourceState
-
- mode - Variable in class ds.funnel.data.msglink.event.MsgLinkConnect
-
- MODULE - Static variable in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- MODULE - Static variable in class ds.granules.dataset.StreamDatasetImpl
-
- MODULE - Static variable in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- MODULE - Static variable in class ds.granules.operation.InstanceDeployer
-
- MODULE - Static variable in class ds.granules.operation.JobSubmission
-
- MODULE - Static variable in class ds.granules.operation.MapReduceBase
-
- MODULE - Static variable in class ds.granules.results.ResultsWidget
-
- MODULE - Static variable in class ds.granules.samples.uppercase.UpperCaseProducer
-
- MODULE - Static variable in class ds.granules.scheduler.Diagnostics
-
- MODULE - Static variable in class ds.granules.scheduler.ExchangeProcessor
-
- MODULE - Static variable in class ds.granules.scheduler.ResourceMetrics
-
- MODULE - Static variable in class ds.granules.util.UUIDRetriever
-
- MODULE_ - Static variable in class ds.granules.samples.uppercase.UpperCaseDeployer
-
- MODULE_ - Static variable in class ds.granules.samples.wordcount.WordCountDeployer
-
- monitorMigrateTask() - Method in class ds.granules.interfere.resource.component.GIResourceMonitor
-
- monitorUpdateTask() - Method in class ds.granules.interfere.resource.component.GIResourceMonitor
-
- MPTestNodeA - Class in ds.funnel.samples
-
- MPTestNodeA(String...) - Constructor for class ds.funnel.samples.MPTestNodeA
-
- MPTestNodeB - Class in ds.funnel.samples
-
- MPTestNodeB(String...) - Constructor for class ds.funnel.samples.MPTestNodeB
-
- MsgFileGet - Class in ds.synapse.files.sdht
-
- MsgFileGet(BigInteger, String, boolean) - Constructor for class ds.synapse.files.sdht.MsgFileGet
-
- MsgFileGet(MessageFormat) - Constructor for class ds.synapse.files.sdht.MsgFileGet
-
- MsgFilePut - Class in ds.synapse.files.sdht
-
- MsgFilePut(BigInteger, String, int, int, byte[]) - Constructor for class ds.synapse.files.sdht.MsgFilePut
-
- MsgFilePut(MessageFormat) - Constructor for class ds.synapse.files.sdht.MsgFilePut
-
- MsgInsertPeer - Class in ds.synapse.peer.event
-
- MsgInsertPeer(SynapseDHTDetails, boolean) - Constructor for class ds.synapse.peer.event.MsgInsertPeer
-
- MsgInsertPeer(MessageFormat) - Constructor for class ds.synapse.peer.event.MsgInsertPeer
-
- MsgInsertResp - Class in ds.synapse.peer.event
-
- MsgInsertResp(SynapseDHTDetails, boolean) - Constructor for class ds.synapse.peer.event.MsgInsertResp
-
- MsgInsertResp(MessageFormat) - Constructor for class ds.synapse.peer.event.MsgInsertResp
-
- MsgLinkAssociate - Class in ds.funnel.data.msglink.event
-
- MsgLinkAssociate(NodeDetails, NodeComponentKey) - Constructor for class ds.funnel.data.msglink.event.MsgLinkAssociate
-
- MsgLinkAssociate(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkAssociate
-
- MsgLinkAssocResp - Class in ds.funnel.data.msglink.event
-
- MsgLinkAssocResp(NodeDetails, String) - Constructor for class ds.funnel.data.msglink.event.MsgLinkAssocResp
-
- MsgLinkAssocResp(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkAssocResp
-
- MsgLinkConnect - Class in ds.funnel.data.msglink.event
-
- MsgLinkConnect(byte) - Constructor for class ds.funnel.data.msglink.event.MsgLinkConnect
-
- MsgLinkConnect(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkConnect
-
- MsgLinkMethodCall - Class in ds.funnel.data.msglink.event
-
- MsgLinkMethodCall(short, Object[]) - Constructor for class ds.funnel.data.msglink.event.MsgLinkMethodCall
-
- MsgLinkMethodCall(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkMethodCall
-
- MsgLinkMethodResp - Class in ds.funnel.data.msglink.event
-
- MsgLinkMethodResp(Object, Exception) - Constructor for class ds.funnel.data.msglink.event.MsgLinkMethodResp
-
- MsgLinkMethodResp(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkMethodResp
-
- MsgLinkTestping - Class in ds.funnel.data.msglink.event
-
- MsgLinkTestping(String, byte[]) - Constructor for class ds.funnel.data.msglink.event.MsgLinkTestping
-
- MsgLinkTestping(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkTestping
-
- MsgLinkTestpong - Class in ds.funnel.data.msglink.event
-
- MsgLinkTestpong(String, byte[]) - Constructor for class ds.funnel.data.msglink.event.MsgLinkTestpong
-
- MsgLinkTestpong(MessageFormat) - Constructor for class ds.funnel.data.msglink.event.MsgLinkTestpong
-
- MsgLookupPeer - Class in ds.synapse.peer.event
-
- MsgLookupPeer(BigInteger, NodeDetails, List<BigInteger>) - Constructor for class ds.synapse.peer.event.MsgLookupPeer
-
- MsgLookupPeer(MessageFormat) - Constructor for class ds.synapse.peer.event.MsgLookupPeer
-
- MsgPeerInfo - Class in ds.synapse.peer.event
-
- MsgPeerInfo(SynapseDHTDetails, String) - Constructor for class ds.synapse.peer.event.MsgPeerInfo
-
- MsgPeerInfo(MessageFormat) - Constructor for class ds.synapse.peer.event.MsgPeerInfo
-
- MsgPredecessorReq - Class in ds.synapse.peer.event
-
- MsgPredecessorReq() - Constructor for class ds.synapse.peer.event.MsgPredecessorReq
-
- MsgPredecessorReq(MessageFormat) - Constructor for class ds.synapse.peer.event.MsgPredecessorReq
-
- MsgSuccessorPeers - Class in ds.synapse.peer.event
-
- MsgSuccessorPeers(List<SynapseDHTDetails>) - Constructor for class ds.synapse.peer.event.MsgSuccessorPeers
-
- MsgSuccessorPeers(MessageFormat) - Constructor for class ds.synapse.peer.event.MsgSuccessorPeers
-
- MsgTopicAdvert - Class in ds.funnel.peer.event
-
- MsgTopicAdvert(Topic, NodeDetails, OverlayPath, int) - Constructor for class ds.funnel.peer.event.MsgTopicAdvert
-
- MsgTopicAdvert(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicAdvert
-
- MsgTopicData - Class in ds.funnel.peer.event
-
- MsgTopicData(Properties, byte[]) - Constructor for class ds.funnel.peer.event.MsgTopicData
-
- MsgTopicData(Properties, byte[], int, int, List<OverlayPath>) - Constructor for class ds.funnel.peer.event.MsgTopicData
-
- MsgTopicData(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicData
-
- MsgTopicJoin - Class in ds.funnel.peer.event
-
- MsgTopicJoin(boolean) - Constructor for class ds.funnel.peer.event.MsgTopicJoin
-
- MsgTopicJoin(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicJoin
-
- MsgTopicLookup - Class in ds.funnel.peer.event
-
- MsgTopicLookup(Topic, int, NodeDetails, OverlayPath, String) - Constructor for class ds.funnel.peer.event.MsgTopicLookup
-
- MsgTopicLookup(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicLookup
-
- MsgTopicNeighbor - Class in ds.funnel.peer.event
-
- MsgTopicNeighbor(NodeDetails, OverlayPath, boolean) - Constructor for class ds.funnel.peer.event.MsgTopicNeighbor
-
- MsgTopicNeighbor(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicNeighbor
-
- MsgTopicOverlay - Class in ds.funnel.peer.event
-
- MsgTopicOverlay(OverlayPath, List<NodeDetails>, List<OverlayPath>, List<NodeDetails>) - Constructor for class ds.funnel.peer.event.MsgTopicOverlay
-
- MsgTopicOverlay(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicOverlay
-
- MsgTopicRepair - Class in ds.funnel.peer.event
-
- MsgTopicRepair(NodeDetails, OverlayPath, OverlayPath) - Constructor for class ds.funnel.peer.event.MsgTopicRepair
-
- MsgTopicRepair(MessageFormat) - Constructor for class ds.funnel.peer.event.MsgTopicRepair
-
- mTime - Static variable in class ds.funnel.samples.TimerTestNode
-
- MULTICAST - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.