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

D

DATA - Static variable in interface cgl.narada.event.Protocol

Deprecated.

DATA - Static variable in interface ds.granules.bridge.ControlMessage

DataAvailabilityNotifier - Interface in ds.granules.dataset

This is a notifier that keeps track of when data is available on a given dataset and then proceeds to notify the availability of the data to the registered observers.

DataAvailabilityObserver - Interface in ds.granules.dataset

This is the interface which allows an observer to track the availability of a dataset.

dataAvailable(String) - Method in class ds.granules.dataset.DatasetNotifier

Called by the dataset as soon as additional data is available.

DataCollector - Interface in ds.synapse.data

DataCollector.DataEventCollector - Interface in ds.synapse.data

DataCollector.DataWindowCollector - Interface in ds.synapse.data

dataOffset - Variable in class ds.funnel.peer.event.MsgTopicData

Dataset - Interface in ds.granules.dataset

The interface outlines the core functionalities that need to be supported within datasets.

Dataset.DatasetType - Enum in ds.granules.dataset

DATASET_ID - Static variable in class ds.granules.interfere.computation.GIComputation

datasetClosure(String) - Method in class ds.granules.dataset.DatasetNotifier

Called by the dataset, just before it is ready to close down.

DatasetCollection - Interface in ds.granules.dataset

The DataCollection interface manages a collection of datasets that would be operated upon by an application instance.

DatasetCollectionManagement - Class in ds.granules.dataset

This is an implementation of the DataCollection Interface.

DatasetCollectionObserver - Interface in ds.granules.dataset

The observer interface for the DatasetCollection.

DatasetEnhancer - Class in ds.funnel.traffic.analysis.regress

Takes in a dataset produced by the DatasetProducer and generates two more columns: average latency over a time period and latency variance over that time period The output is a comma delimited file with a header.

DatasetEnhancer() - Constructor for class ds.funnel.traffic.analysis.regress.DatasetEnhancer

DatasetException - Exception in ds.granules.dataset

The DatasetException is thrown when problems are encountered with the dataset.

DatasetException() - Constructor for exception ds.granules.dataset.DatasetException

Constructs an DatasetException with no detail message.

DatasetException(String) - Constructor for exception ds.granules.dataset.DatasetException

Constructs an DatasetException with the specified detail message.

DatasetException(String, Throwable) - Constructor for exception ds.granules.dataset.DatasetException

Constructs an DatasetException with the specified detail message.

DatasetFactory - Class in ds.granules.dataset

A factory for creating different types of datasets.

DatasetFactory() - Constructor for class ds.granules.dataset.DatasetFactory

DatasetNotifier - Class in ds.granules.dataset

This is a class which implements the DataAvailabilityNotifier interface.

DatasetNotifier(String, String) - Constructor for class ds.granules.dataset.DatasetNotifier

DatasetProducer - Class in ds.funnel.traffic.analysis

Parses a pair of log files produced by a traffic publisher and traffic reflector, and produces a final dataset to use for packet arrival prediction.

DatasetProducer() - Constructor for class ds.funnel.traffic.analysis.DatasetProducer

dataSize - Variable in class ds.funnel.peer.event.MsgTopicData

DataSource - Interface in ds.synapse.data

DataSourceException - Exception in ds.synapse.data

DataSourceException(String) - Constructor for exception ds.synapse.data.DataSourceException

DataSourceException(String, Throwable) - Constructor for exception ds.synapse.data.DataSourceException

dataString() - Method in class ds.granules.interfere.computation.ecg.HeartbeatData

DataWindow - Class in ds.synapse.data

DataWindow(FileStorage, String, int, long) - Constructor for class ds.synapse.data.DataWindow

DataWindower - Class in ds.synapse.data

DataWindower(FileStorage, String) - Constructor for class ds.synapse.data.DataWindower

debug(String) - Method in class ds.funnel.node.FunnelLogger

DEBUG_BUFFER - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_CHANNEL - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_DHTLOOKUP - Static variable in class ds.synapse.Synapse

DEBUG_DHTSETUP - Static variable in class ds.synapse.Synapse

DEBUG_DISPATCH - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_MSGDROP - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_MSGRECV - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_MSGSEND - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_MSGWAIT - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_PROTOCOL - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_THREADS - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPEDATA - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPEVENT - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPLOOKUP - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPMEMBER - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPOLINK - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPOVERLAY - Static variable in class ds.funnel.node.FunnelLogger

DEBUG_TPREPAIR - Static variable in class ds.funnel.node.FunnelLogger

debugCopy() - Method in class ds.funnel.data.buffer.StreamBufferImpl

debugSubActive - Static variable in class ds.granules.interfere.computation.GIComputation

debugTag - Variable in class ds.funnel.data.buffer.StreamBufferImpl

debugTopology() - Method in class ds.funnel.peer.PeerGroupImpl

DEFAULT_PARAMS - Static variable in class ds.granules.interfere.PredictionTest

delay - Variable in class ds.granules.interfere.computation.ComputationStats

delayDiff - Variable in class ds.granules.interfere.computation.ComputationStats

DEPLOY - Static variable in class ds.granules.exchange.DeploymentMessage

deploy(Operation[], int, String, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission

DEPLOY_DELAY_MILLIS - Static variable in interface ds.granules.interfere.placement.component.GICompPlacerCmpnt

deployJob(int, String, boolean) - Method in class ds.granules.interfere.computation.ComputationManager

DEPLOYMENT - Static variable in interface ds.granules.exchange.ExchangeType

DeploymentException - Exception in ds.granules.exception

This is an exception that is thrown when there are problems in deployment-related actions that are initiated on operations.

DeploymentException() - Constructor for exception ds.granules.exception.DeploymentException

Constructs an DeploymentException with no detail message.

DeploymentException(String) - Constructor for exception ds.granules.exception.DeploymentException

Constructs an DeploymentException with the specified detail message.

DeploymentMessage - Class in ds.granules.exchange

This class encapsulates the exchanges related to the deployment of an application instance.

deployOperations(Operation[]) - Method in class ds.granules.operation.InstanceDeployer

This method deploys a set of operations on a specified number of resources.

deployOperations(Operation[], String) - Method in class ds.granules.operation.InstanceDeployer

This method deploys a set of operations on the set of available resources.

deployOperations(Operation[], int, String) - Method in class ds.granules.operation.InstanceDeployer

This method deploys a set of operations on a specified number of resources.

deployStream - Variable in class ds.granules.interfere.placement.component.GIResourceTrackerImpl.ResourceState

deregisterDataAvailabilityObserver(DataAvailabilityObserver) - Method in interface ds.granules.dataset.DataAvailabilityNotifier

Deregisters a data availability observer

deregisterDataAvailabilityObserver(DataAvailabilityObserver) - Method in class ds.granules.dataset.DatasetNotifier

destroyGroup(ThreadGroup) - Method in class ds.funnel.node.task.TaskThreads

dests - Variable in class ds.funnel.peer.event.MessageBaseTE

details - Variable in class ds.funnel.data.msglink.event.MsgLinkAssocResp

df - Static variable in class ds.funnel.samples.FunTestNode

df - Static variable in class ds.funnel.samples.IOTestNode

df - Static variable in class ds.funnel.samples.MPTestNodeA

df - Static variable in class ds.funnel.samples.MPTestNodeB

df - Static variable in class ds.funnel.samples.TimerTestNode

DHT_DATA_DIR - Static variable in class ds.synapse.Synapse

DHT_NUM_HASH_BITS - Static variable in class ds.synapse.Synapse

DHT_NUM_SUCCESSORS - Static variable in class ds.synapse.Synapse

DHT_TIMEOUT_MILLIS - Static variable in class ds.synapse.Synapse

DHT_UPDATE_MILLIS - Static variable in class ds.synapse.Synapse

DHTCommException - Exception in ds.synapse.peer

DHTCommException(String) - Constructor for exception ds.synapse.peer.DHTCommException

DHTCommException(String, Throwable) - Constructor for exception ds.synapse.peer.DHTCommException

DHTConnection - Class in ds.synapse.peer

Deprecated.

DHTConnection(SynapseDHTDetails) - Constructor for class ds.synapse.peer.DHTConnection

Deprecated.

DHTFileAccess - Class in ds.synapse.files.sdht

DHTFileAccess(String, BigInteger, DHTFileStorage) - Constructor for class ds.synapse.files.sdht.DHTFileAccess

DHTFileStorage - Class in ds.synapse.files.sdht

DHTFileStorage(FileLifecycle, DHTLookup, DHTFingerTable, String) - Constructor for class ds.synapse.files.sdht.DHTFileStorage

DHTFingerTable - Class in ds.synapse.peer

DHTFingerTable(BigInteger, int) - Constructor for class ds.synapse.peer.DHTFingerTable

DHTHashGenerator - Class in ds.synapse.peer

DHTHashGenerator() - Constructor for class ds.synapse.peer.DHTHashGenerator

DHTLookup - Class in ds.synapse.peer

DHTLookup(SynapseDHTDetails, DHTFingerTable) - Constructor for class ds.synapse.peer.DHTLookup

DHTLookup(DHTConnection) - Constructor for class ds.synapse.peer.DHTLookup

DHTLookup.HandleOnResponse - Class in ds.synapse.peer

DHTPeerException - Exception in ds.synapse.peer

DHTPeerException(String) - Constructor for exception ds.synapse.peer.DHTPeerException

DHTPeerException(String, Throwable) - Constructor for exception ds.synapse.peer.DHTPeerException

DHTPredecessor - Class in ds.synapse.peer

DHTPredecessor(SynapseDHTNode) - Constructor for class ds.synapse.peer.DHTPredecessor

DHTUpdateFT - Class in ds.synapse.peer

DHTUpdateFT(SynapseDHTNode, DHTPredecessor, DHTLookup) - Constructor for class ds.synapse.peer.DHTUpdateFT

DIAGNOSTIC - Static variable in interface ds.granules.exchange.ExchangeType

Diagnostics - Class in ds.granules.scheduler

This class keeps track of various diagnostic-related elements.

Diagnostics(String, int) - Constructor for class ds.granules.scheduler.Diagnostics

DirectivesException - Exception in ds.granules.exception

This is an exception that is thrown when there are problems enforcing the directives associated with an application instance.

DirectivesException() - Constructor for exception ds.granules.exception.DirectivesException

Constructs an DirectivesException with no detail message.

DirectivesException(String) - Constructor for exception ds.granules.exception.DirectivesException

Constructs an DirectivesException with the specified detail message.

disableFunnelStartup - Static variable in class ds.funnel.peer.PeerManagerImpl

discoverResource() - Method in class ds.granules.operation.JobSubmission

Discovers the available computational resources.

discoverResource(int) - Method in class ds.granules.operation.JobSubmission

Discovers the available computational resources.

discoverResources(int) - Method in interface ds.granules.interfere.placement.component.GIResourceTrackerCmpnt

discoverResources(int) - Method in class ds.granules.interfere.placement.component.GIResourceTrackerImpl

DISCOVERY_REQUEST - Static variable in interface cgl.narada.event.Protocol

Deprecated.

dispatch(E) - Method in interface ds.funnel.node.event.EventDispatcher

Dispatch an event, passing the event to matching registered handlers.

dispatch(E) - Method in class ds.funnel.node.event.EventDispatcherImpl

DispatchEventTask<E extends Event,T> - Class in ds.funnel.node.task

DispatchEventTask(Class<E>) - Constructor for class ds.funnel.node.task.DispatchEventTask

DispatchEventTask(int, Class<E>) - Constructor for class ds.funnel.node.task.DispatchEventTask

DispatchReplyTask<M extends MessageEvent> - Class in ds.funnel.node.task

DispatchReplyTask(int, MessageEvent, Class<M>) - Constructor for class ds.funnel.node.task.DispatchReplyTask

dispose() - Method in interface ds.granules.operation.Operation

Reclaim resources if any prior to exiting ...

dispose() - Method in class ds.granules.operation.OperationBase

distanceTo(OverlayPath) - Method in interface ds.funnel.overlay.OverlayPath

The number of hops to reach the given destination using primary links.

distanceTo(OverlayPath) - Method in class ds.funnel.overlay.OverlayPathImpl

DistributionTraces - Interface in cgl.narada.event

Deprecated.

DistributionTracesImpl - Class in cgl.narada.event

Deprecated.

DistributionTracesImpl() - Constructor for class cgl.narada.event.DistributionTracesImpl

Deprecated.

DistributionTracesImpl(byte[]) - Constructor for class cgl.narada.event.DistributionTracesImpl

Deprecated.

DJMS_BL2BROKER_CONN_REQUEST - Static variable in interface cgl.narada.event.Protocol

Deprecated.

The connection request being forwarded to the broker located by the locator service

DJMS_BL2CLIENT_CONN_RESPONSE - Static variable in interface cgl.narada.event.Protocol

Deprecated.

Information pertaining to located valid broker being forwarded to the client.

DJMS_BROKER2BL_BROKER_ADDED - Static variable in interface cgl.narada.event.Protocol

Deprecated.

DJMS_BROKER2BL_BROKER_REMOVED - Static variable in interface cgl.narada.event.Protocol

Deprecated.

DJMS_BROKER2BL_CONN_RESPONSE - Static variable in interface cgl.narada.event.Protocol

Deprecated.

Once the conn request has been forwarded to a broker, the broker responds with info pertaining to the conn request

DJMS_BROKER2BL_CONNINFO_UPDATE - Static variable in interface cgl.narada.event.Protocol

Deprecated.

This is used by the brokers to update information pertaining to the increase or decrease of concurrent connections being mainatained by a broker

DJMS_BROKER2CLIENT_CONN_RESPONSE - Static variable in interface cgl.narada.event.Protocol

Deprecated.

The final step in the initialization sequence where the BL initiates a connection

DJMS_CLIENT2BL_CONN_REQUEST - Static variable in interface cgl.narada.event.Protocol

Deprecated.

The request for a connection initiated by the client in Distributed JMS

DOUBLE - Static variable in class ds.granules.results.ResultPayload

DOUBLE_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload

DOUBLE_ARR - Static variable in interface ds.granules.bridge.ControlMessage

DOUBLE_ARRAY - Static variable in class ds.granules.results.ResultPayload

ds.funnel - package ds.funnel

ds.funnel.data.buffer - package ds.funnel.data.buffer

ds.funnel.data.channel - package ds.funnel.data.channel

ds.funnel.data.channel.tcp - package ds.funnel.data.channel.tcp

ds.funnel.data.channel.udp - package ds.funnel.data.channel.udp

ds.funnel.data.format - package ds.funnel.data.format

ds.funnel.data.msglink - package ds.funnel.data.msglink

ds.funnel.data.msglink.event - package ds.funnel.data.msglink.event

ds.funnel.data.msglink.protocol3 - package ds.funnel.data.msglink.protocol3

ds.funnel.node - package ds.funnel.node

ds.funnel.node.compnt - package ds.funnel.node.compnt

ds.funnel.node.event - package ds.funnel.node.event

ds.funnel.node.task - package ds.funnel.node.task

ds.funnel.overlay - package ds.funnel.overlay

ds.funnel.overlay.graph - package ds.funnel.overlay.graph

ds.funnel.overlay.routing - package ds.funnel.overlay.routing

ds.funnel.overlay.topology - package ds.funnel.overlay.topology

ds.funnel.peer - package ds.funnel.peer

ds.funnel.peer.event - package ds.funnel.peer.event

ds.funnel.samples - package ds.funnel.samples

ds.funnel.topic - package ds.funnel.topic

ds.funnel.traffic - package ds.funnel.traffic

ds.funnel.traffic.analysis - package ds.funnel.traffic.analysis

ds.funnel.traffic.analysis.regress - package ds.funnel.traffic.analysis.regress

ds.funnel.traffic.component - package ds.funnel.traffic.component

ds.funnel.traffic.component.packetgenerator - package ds.funnel.traffic.component.packetgenerator

ds.funnel.traffic.component.sizedistribution - package ds.funnel.traffic.component.sizedistribution

ds.funnel.traffic.component.timedistribution - package ds.funnel.traffic.component.timedistribution

ds.funnel.traffic.component.types - package ds.funnel.traffic.component.types

ds.funnel.traffic.driver - package ds.funnel.traffic.driver

ds.funnel.traffic.factory - package ds.funnel.traffic.factory

ds.funnel.traffic.formatter - package ds.funnel.traffic.formatter

ds.funnel.util - package ds.funnel.util

ds.granules - package ds.granules

ds.granules.bridge - package ds.granules.bridge

This package contains basic Granules Bridging code.

ds.granules.dataset - package ds.granules.dataset

This package contains functionality related to datasets that deployed application instances need to operate on.

ds.granules.exception - package ds.granules.exception

This package contains exceptions that are used across multiple packages within the project.

ds.granules.exchange - package ds.granules.exchange

This package contains classes related to processing exchanges.

ds.granules.interfere - package ds.granules.interfere

ds.granules.interfere.computation - package ds.granules.interfere.computation

ds.granules.interfere.computation.ecg - package ds.granules.interfere.computation.ecg

ds.granules.interfere.computation.eeg - package ds.granules.interfere.computation.eeg

ds.granules.interfere.computation.gzip - package ds.granules.interfere.computation.gzip

ds.granules.interfere.computation.thorax - package ds.granules.interfere.computation.thorax

ds.granules.interfere.placement - package ds.granules.interfere.placement

ds.granules.interfere.placement.component - package ds.granules.interfere.placement.component

ds.granules.interfere.prediction - package ds.granules.interfere.prediction

ds.granules.interfere.resource - package ds.granules.interfere.resource

ds.granules.interfere.resource.component - package ds.granules.interfere.resource.component

ds.granules.interfere.streaming - package ds.granules.interfere.streaming

ds.granules.operation - package ds.granules.operation

This package encapsulates functionality related to application instances that will be deployed on the cloud.

ds.granules.results - package ds.granules.results

Functionality for processing results generated by application instances.

ds.granules.samples.uppercase - package ds.granules.samples.uppercase

This package contains a simple example which flips an input string from lowercase to uppercase.

ds.granules.samples.wordcount - package ds.granules.samples.wordcount

This package contains classes that demonstrate using Granules with a simple information retrieval capability: Histogramming Word Counts in a set of files on a distributed set of machines.

ds.granules.scheduler - package ds.granules.scheduler

This package contains functionality related to scheduling the application instances.

ds.granules.util - package ds.granules.util

This package contains utility classes used by several components.

ds.synapse - package ds.synapse

ds.synapse.data - package ds.synapse.data

ds.synapse.data.source - package ds.synapse.data.source

ds.synapse.files - package ds.synapse.files

ds.synapse.files.sdht - package ds.synapse.files.sdht

ds.synapse.peer - package ds.synapse.peer

ds.synapse.peer.event - package ds.synapse.peer.event

duplicate() - Method in interface ds.funnel.data.buffer.StreamBuffer

duplicate(int) - Method in interface ds.funnel.data.buffer.StreamBuffer

duplicate() - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl

duplicate(int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl

duplicate() - Method in class ds.funnel.data.buffer.StreamBufferImpl

duplicate(int) - Method in class ds.funnel.data.buffer.StreamBufferImpl

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