- OBJECT - Static variable in class ds.granules.results.ResultPayload
-
- OBJECT_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- OBJECT_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- ObjectMarshaller - Class in cgl.narada.event
-
Deprecated.
- ObjectMarshaller() - Constructor for class cgl.narada.event.ObjectMarshaller
-
Deprecated.
- onCancelHandler() - Method in class ds.funnel.node.event.EventDispatcherImpl
-
- onCancelHandler() - Method in interface ds.funnel.node.event.EventDispatchHandler
-
Called when this handler is unregistered with the dispatcher.
- onCancelHandler() - Method in class ds.funnel.node.task.DispatchEventTask
-
- onCancelHandler() - Method in class ds.funnel.traffic.TrafficDataEventHandler
-
- onClose(ChannelManager) - Method in interface ds.funnel.data.channel.ChannelProtocol
-
Indicate that the channel used by this protocol has closed.
- onClose(ChannelManager) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- onCloseEvent(MsgLinkAssociate) - Method in class ds.funnel.node.compnt.NodeComponentLinkImpl
-
- onData(DataSource, long, double[]) - Method in interface ds.synapse.data.DataCollector.DataEventCollector
-
- onData(DataSource, DataWindow) - Method in interface ds.synapse.data.DataCollector.DataWindowCollector
-
- onData(DataSource, long, double[]) - Method in class ds.synapse.data.DataWindower
-
- onDataAvailability(String) - Method in interface ds.granules.dataset.DataAvailabilityObserver
-
This method is invoked on the observers to reflect the availability of
new data in the input dataset
- onDataAvailability(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- onDataAvailability() - Method in interface ds.granules.dataset.DatasetCollectionObserver
-
This method is invoked on the observers to reflect the availability of
new data in the dataset collection.
- onDataAvailability() - Method in class ds.granules.scheduler.ExecutableTask
-
- onDatasetClosure(String) - Method in interface ds.granules.dataset.DataAvailabilityObserver
-
This method is invoked on the observer when the dataset will be closed
and thus no more data will be available.
- onDatasetClosure(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- onDatasetCollectionClosure() - Method in interface ds.granules.dataset.DatasetCollectionObserver
-
This method is invoked on the observers to reflect the closure of the
dataset collection.
- onDatasetCollectionClosure() - Method in class ds.granules.scheduler.ExecutableTask
-
- onDeathEvent(LinkClosedEvent) - Method in class ds.funnel.node.compnt.NodeComponentLinkImpl
-
- onEvent(TopicEvent) - Method in interface ds.funnel.peer.PeerGroupUtilizer
-
Called by the group to pass incoming events to the utilizer.
- onEvent(TopicDataEvent) - Static method in class ds.funnel.samples.NanoTimeSample
-
- onEvent(TopicEvent) - Method in class ds.funnel.topic.TopicPublisherImpl
-
- onEvent(TopicDataEvent) - Method in interface ds.funnel.topic.TopicSubscriptionHandler
-
- onEvent(TopicEvent) - Method in class ds.funnel.topic.TopicSubscriptionImpl
-
- onEvent(TopicDataEvent, long) - Static method in class ds.funnel.traffic.analysis.TrafficPublisher
-
If the inEvent was not published by this traffic publisher, calculates
statistics on the packet and logs them to the log file.
- onEvent(TopicDataEvent, long) - Static method in class ds.funnel.traffic.analysis.TrafficReflector
-
If the inEvent was not published by this traffic reflector, republishes
the event to the traffic generation topic.
- onEvent(TopicDataEvent) - Method in class ds.granules.interfere.computation.GIComputationStreams
-
- onEvent(TopicDataEvent) - Method in class ds.granules.samples.uppercase.UpperCaseProducer
-
- onEvent(TopicDataEvent) - Method in class ds.granules.scheduler.ExchangeProcessor
-
- onEvt(MsgLinkTestping) - Method in class ds.funnel.samples.MPTestNodeA
-
- onFilePutRemote(MsgFilePut) - Method in class ds.synapse.files.sdht.DHTFileStorage
-
- onFinish(boolean) - Method in class ds.funnel.overlay.graph.GraphBFS
-
- onGetFileRemote(MsgFileGet) - Method in class ds.synapse.files.sdht.DHTFileStorage
-
- onInsertEvent(MsgInsertPeer) - Method in class ds.synapse.peer.DHTPredecessor
-
- onJoinMessage(MsgTopicJoin) - Method in class ds.funnel.peer.PeerGroupOverlay
-
- onLinkUpdatedRemote(MsgTLinkUpdate) - Method in class ds.funnel.overlay.OverlayManagerImpl
-
- onLookupEvent(MsgTopicLookup) - Method in class ds.funnel.peer.PeerGroupLookup
-
- onLookupEvent(MsgLookupPeer) - Method in class ds.synapse.peer.DHTLookup
-
- onMethodCall(MsgLinkMethodCall) - Method in class ds.funnel.node.compnt.NodeComponentProxyImpl
-
- onNeighborAdvert(MsgTopicNeighbor) - Method in class ds.funnel.peer.PeerGroupAdvert
-
- onOpenComponentLink(MsgLinkAssociate) - Method in class ds.funnel.node.NodeDetailsBase
-
- onOpenTopicLink(MsgTLinkOpen) - Method in class ds.funnel.peer.PeerManagerImpl
-
- onPathOf(OverlayPath) - Method in interface ds.funnel.overlay.OverlayPath
-
True is this location is on the path of the given destination.
- onPathOf(OverlayPath) - Method in class ds.funnel.overlay.OverlayPathImpl
-
- onPing(MsgLinkTestping) - Method in class ds.funnel.peer.RouterNode
-
- onPing(MsgLinkTestping) - Method in class ds.funnel.samples.TimerTestNode
-
- onPing(MsgLinkTestping) - Method in class ds.funnel.samples.UDPTestNode
-
- onPredecessorReq(MsgPredecessorReq) - Method in class ds.synapse.peer.DHTPredecessor
-
- onRecvBuffer(ChannelManager, ByteBuffer) - Method in interface ds.funnel.data.channel.ChannelProtocol
-
Called by a channel reader task to pass received bytes to the protocol.
- onRecvBuffer(ChannelManager, ByteBuffer) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- onResponse(SynapseDHTDetails) - Method in class ds.synapse.peer.DHTLookup.HandleOnResponse
-
- onSendBuffer(ChannelManager, ByteBuffer) - Method in interface ds.funnel.data.channel.ChannelProtocol
-
Called by a channel writer task to obtain bytes to send from the protocol.
- onSendBuffer(ChannelManager, ByteBuffer) - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- onSuccessorsEvent(MsgSuccessorPeers) - Method in class ds.synapse.peer.DHTUpdateFT
-
- onTopicAdvert(MsgTopicAdvert) - Method in class ds.funnel.peer.PeerGroupAdvert
-
- onUpdateMessage(MsgTopicOverlay) - Method in class ds.funnel.peer.PeerGroupOverlay
-
- onVisit(GraphNode, int) - Method in class ds.funnel.overlay.graph.GraphBFS
-
- openBackingLink(NodeDetails) - Method in class ds.funnel.overlay.OverlayManagerImpl
-
- OpenedComponentLink() - Constructor for class ds.funnel.node.compnt.NodeComponentLinkImpl.OpenedComponentLink
-
- openLink(NodeDetails) - Method in class ds.funnel.data.msglink.protocol3.MessageLinkFactory
-
Open a new connection to the given node.
- openLink() - Method in interface ds.funnel.node.NodeDetails
-
- openLink() - Method in class ds.funnel.node.NodeDetailsBase
-
- openLink(NodeDetails, boolean) - Method in interface ds.funnel.overlay.OverlayVersion
-
Open a link to a specific remote node, if one does not exist.
- openLink(NodeDetails, boolean) - Method in class ds.funnel.overlay.OverlayVersionImpl
-
- openVirtual() - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
-
- openVirtualLink(NodeDetails) - Method in class ds.funnel.data.msglink.protocol3.MessageLinkFactory
-
Open a new virtual connection using the stored group protocol.
- openVirtualLink() - Method in interface ds.funnel.node.NodeDetails
-
- openVirtualLink() - Method in class ds.funnel.node.NodeDetailsBase
-
- Operation - Interface in ds.granules.operation
-
This is the interface which encapsulates an application instance that will be
deployed.
- Operation.OperationType - Enum in ds.granules.operation
-
- OperationBase - Class in ds.granules.operation
-
This is an implementation of the Operation and
OperationConfiguration interfaces.
- OperationBase() - Constructor for class ds.granules.operation.OperationBase
-
- OperationConfiguration - Interface in ds.granules.operation
-
This is an interface that allows application instances to be configured.
- origin - Variable in class ds.synapse.peer.event.MsgLookupPeer
-
- OVERLAY_ACTIVATE_MILLIS - Static variable in class ds.funnel.peer.PeerManagerImpl
-
- OVERLAY_TIMEOUT_SECONDS - Static variable in class ds.funnel.peer.PeerManagerImpl
-
- OverlayException - Exception in ds.funnel.overlay
-
- OverlayException(String) - Constructor for exception ds.funnel.overlay.OverlayException
-
- OverlayException(String, Throwable) - Constructor for exception ds.funnel.overlay.OverlayException
-
- OverlayLink - Interface in ds.funnel.overlay
-
- OverlayLink.LinkState - Enum in ds.funnel.overlay
-
- OverlayLinkImpl - Class in ds.funnel.overlay
-
- OverlayLinkImpl(OverlayManagerImpl, OverlayVersionImpl, MessageLink, boolean) - Constructor for class ds.funnel.overlay.OverlayLinkImpl
-
- OverlayManager - Interface in ds.funnel.overlay
-
- OverlayManagerImpl - Class in ds.funnel.overlay
-
- OverlayManagerImpl(PeerGroupImpl) - Constructor for class ds.funnel.overlay.OverlayManagerImpl
-
- OverlayPath - Interface in ds.funnel.overlay
-
- OverlayPathImpl - Class in ds.funnel.overlay
-
- OverlayPathImpl(long, int...) - Constructor for class ds.funnel.overlay.OverlayPathImpl
-
- OverlayVersion - Interface in ds.funnel.overlay
-
- OverlayVersion.OverlayState - Enum in ds.funnel.overlay
-
- OverlayVersionImpl - Class in ds.funnel.overlay
-
- OverlayVersionImpl(OverlayManagerImpl, long) - Constructor for class ds.funnel.overlay.OverlayVersionImpl
-