- P2P_CONN_REQUEST - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- P2P_CONN_RESPONSE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PacketGenerator - Interface in ds.funnel.traffic.component
-
A PacketGenerator is an object which generates the data for a packet, a byte
array, by some method.
- PacketGeneratorFactory - Class in ds.funnel.traffic.factory
-
PacketGeneratorFactory creates PacketGenerators of the appropriate concrete
types based upon ComponentSpecifications.
- PacketGeneratorFactory() - Constructor for class ds.funnel.traffic.factory.PacketGeneratorFactory
-
- PacketGeneratorType - Class in ds.funnel.traffic.component.types
-
- PacketGeneratorType() - Constructor for class ds.funnel.traffic.component.types.PacketGeneratorType
-
- PacketSizeDistribution - Interface in ds.funnel.traffic.component
-
The PacketSizeDistribution interface defines an object which specifies some
sort of size distribution pattern for packets over time.
- PacketTimeDistribution - Interface in ds.funnel.traffic.component
-
The PacketTimeDistribution interface defines an object which specifies some
sort of time distribution pattern for packet transmissions.
- params - Variable in class ds.funnel.data.msglink.event.MsgLinkMethodCall
-
- ParamsReader - Class in ds.granules.util
-
This is a utility class which is useful in reading specified configuration
parameters.
- ParamsReader() - Constructor for class ds.granules.util.ParamsReader
-
- parseConfigurationString() - Method in class ds.funnel.traffic.factory.ConfigurationParser
-
Parses the configuration string currently stored in this
ConfigurationParser and stores the results.
- parseConfigurationString(String) - Method in class ds.funnel.traffic.factory.ConfigurationParser
-
Sets the configuration string for this parser to the specified string,
and then parses the string.
- passesReadinessCheck() - Method in class ds.granules.scheduler.ExecutableTask
-
Checks to see if the task is ready for execution.
- PAUSE_RESUME - Static variable in interface ds.granules.bridge.ControlMessage
-
- pauseAvailabilityNotifications(DataAvailabilityObserver) - Method in interface ds.granules.dataset.DataAvailabilityNotifier
-
Pauses data availability notifications for the specified observer
- pauseAvailabilityNotifications(DataAvailabilityObserver) - Method in class ds.granules.dataset.DatasetNotifier
-
- pauseTask() - Method in interface ds.granules.scheduler.Controller
-
- peer - Variable in class ds.synapse.peer.event.MsgInsertPeer
-
- peer - Variable in class ds.synapse.peer.event.MsgInsertResp
-
- peer - Variable in class ds.synapse.peer.event.MsgPeerInfo
-
- PeerDetails - Interface in ds.funnel.peer
-
- PeerDetailsImpl - Class in ds.funnel.peer
-
- PeerDetailsImpl(PeerGroupImpl, NodeDetails, OverlayPath, int) - Constructor for class ds.funnel.peer.PeerDetailsImpl
-
- PeerGroup - Interface in ds.funnel.peer
-
- PeerGroupAdvert - Class in ds.funnel.peer
-
- PeerGroupAdvert(PeerGroup) - Constructor for class ds.funnel.peer.PeerGroupAdvert
-
- PeerGroupImpl - Class in ds.funnel.peer
-
- PeerGroupImpl(PeerManager, Topic) - Constructor for class ds.funnel.peer.PeerGroupImpl
-
- PeerGroupLookup - Class in ds.funnel.peer
-
- PeerGroupOverlay - Class in ds.funnel.peer
-
- PeerGroupOverlay(PeerManager, PeerGroup) - Constructor for class ds.funnel.peer.PeerGroupOverlay
-
- PeerGroupQueue - Class in ds.funnel.peer
-
- PeerGroupQueue(PeerGroupImpl) - Constructor for class ds.funnel.peer.PeerGroupQueue
-
- PeerGroupUtilizer - Interface in ds.funnel.peer
-
- PeerManager - Interface in ds.funnel.peer
-
- PeerManagerImpl - Class in ds.funnel.peer
-
- PeerManagerImpl() - Constructor for class ds.funnel.peer.PeerManagerImpl
-
- peerNode - Variable in class ds.funnel.peer.event.MsgTopicLookup
-
- peerPath - Variable in class ds.funnel.peer.event.MsgTopicLookup
-
- peers - Variable in class ds.synapse.peer.event.MsgSuccessorPeers
-
- PERFORMANCE_MEASUREMENT - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PERFORMANCE_MEASUREMENT_INITIATE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- performNotOperation(int) - Static method in class cgl.narada.event.ByteUtilities
-
Deprecated.
This performs an inversion of the bits in an integer.
- PERSISTENT_EVENT - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- perWindow - Variable in class ds.granules.interfere.computation.ComputationStats
-
- PING - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PING_REPLY - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- pingdata - Variable in class ds.funnel.data.msglink.event.MsgLinkTestping
-
- placeComputation(GIComputation) - Method in class ds.granules.interfere.placement.GIPlacementNode
-
- placeComputation(GIComputation) - Method in class ds.granules.interfere.placement.GIPlacementNodeProxy
-
- placeComputation(GIComputation) - Method in interface ds.granules.interfere.placement.GIPlacementProxyOps
-
- placeComputations(List<GIResourceTrackerImpl.ResourceState>, List<ComputationManager>, int) - Method in interface ds.granules.interfere.placement.component.GICompPlacerCmpnt
-
- placeComputations(List<GIResourceTrackerImpl.ResourceState>, List<ComputationManager>, int) - Method in class ds.granules.interfere.placement.component.GICompPlacerHistory
-
- placeComputations(List<GIResourceTrackerImpl.ResourceState>, List<ComputationManager>, int) - Method in class ds.granules.interfere.placement.component.GICompPlacerRoundRobin
-
- POISSON - Static variable in class ds.funnel.traffic.component.types.TimeDistributionType
-
- pongdata - Variable in class ds.funnel.data.msglink.event.MsgLinkTestpong
-
- position() - Method in interface ds.funnel.data.buffer.StreamBuffer
-
- position(int) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Set the current buffer position.
- position() - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- position(int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- position() - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- position(int) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- PowerLaw - Class in ds.funnel.overlay.topology
-
- PowerLaw(int, double, double) - Constructor for class ds.funnel.overlay.topology.PowerLaw
-
- PPP_ADD_PREDICATE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PPP_CLIENT_ADD_PREDICATE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PPP_CLIENT_PREDICATE_BUFFER - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PPP_CLIENT_REMOVE_PREDICATE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PPP_PREDICATE_BUFFER - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PPP_REMOVE_PREDICATE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- preAllocate(int) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Pre-allocate buffers for writing, extending the length to the passed size.
- preAllocate(int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- preAllocate(int) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- prediction(int) - Method in interface ds.funnel.traffic.component.PacketTimeDistribution
-
Generates an array containing predicted packet transmission times, in
terms of number of ms from this instant.
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.BurstyTimeDistribution
-
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.ECGTimeDistribution
-
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.EEGTimeDistribution
-
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.NormalTimeDistribution
-
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.RandomTimeDistribution
-
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.RegularTimeDistribution
-
- prediction(int) - Method in class ds.funnel.traffic.component.timedistribution.ThoraxTimeDistribution
-
- prediction() - Method in class ds.funnel.traffic.TrafficGenerator
-
Generates the next predicted interval.
- prediction(int) - Method in class ds.funnel.traffic.TrafficGenerator
-
Generates an array containing predicted packet transmission times, in
terms of number of ms from this instant.
- PredictionRing - Class in ds.granules.interfere.prediction
-
- PredictionTest - Class in ds.granules.interfere
-
- PredictionTrackList - Class in ds.granules.interfere.prediction
-
- PredictionTrackList(CompStreamDescription) - Constructor for class ds.granules.interfere.prediction.PredictionTrackList
-
- PredictionTrackRoll - Class in ds.granules.interfere.prediction
-
- PredictionTrackRoll(CompStreamDescription) - Constructor for class ds.granules.interfere.prediction.PredictionTrackRoll
-
- preloadFiles(String) - Static method in class ds.funnel.traffic.component.packetgenerator.ECGPacketGenerator
-
Load data from all files in a given directory
- prepareInstancesAndDeploy(double, int) - Method in class ds.granules.interfere.computation.ecg.ECGDeployer
-
This method deploys RespirationMap instances over the set of
available resources.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.interfere.computation.eeg.EEGDeployer
-
- prepareInstancesAndDeploy(double, int) - Method in class ds.granules.interfere.computation.thorax.RespirationMonitorDeployer
-
This method deploys RespirationMap instances over the set of
available resources.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.samples.uppercase.UpperCaseDeployer
-
This method deploys FlipMap instances over the set of
available resources.
- prepareInstancesAndDeploy(int, String) - Method in class ds.granules.samples.wordcount.WordCountDeployer
-
Prepares a set of Map/Reduce instances for the WordCount example and
deploys it on the set of available resources.
- primary - Variable in class ds.funnel.peer.event.MsgTopicOverlay
-
- printAllocated() - Method in interface ds.funnel.data.buffer.BufferPool
-
Print a list of buffers currently allocated.
- printAllocated() - Method in class ds.funnel.data.buffer.BufferPoolChunk
-
Print a list of buffers currently allocated.
- printAllocated() - Method in class ds.funnel.data.buffer.BufferPoolImpl
-
Print a list of buffers currently allocated.
- printAllocated() - Method in class ds.funnel.data.buffer.BufferPoolStriped
-
- printByte(byte) - Static method in class cgl.narada.event.ByteUtilities
-
Deprecated.
This method is primarily used for debugging purposes, and provides
us with a representation of a byte as sequence of 1's and 0's that is
of length=8.
- printGraphDebug(boolean) - Method in class ds.funnel.peer.PeerGroupOverlay
-
- printHeaders() - Method in class cgl.narada.event.EventHeadersImpl
-
Deprecated.
- printInt(int) - Static method in class cgl.narada.event.ByteUtilities
-
Deprecated.
This method is primarily used for debugging purposes, and provides
us with a representation of an integer as sequence of 1's and 0's that
is of length=32.
- printVersionInformation() - Method in class ds.granules.util.Version
-
- priPath - Variable in class ds.funnel.peer.event.MsgTopicOverlay
-
- PROBLEMS_ENCOUNTERED - Static variable in interface ds.granules.exchange.ConditionFlag
-
- processEvent(TopicEvent) - Method in interface ds.funnel.peer.PeerGroup
-
Process a topic event.
- processEvent(TopicEvent) - Method in class ds.funnel.peer.PeerGroupImpl
-
- processExecutionStatusRequest(ExecutionStatus) - Method in class ds.granules.scheduler.Diagnostics
-
- ProcessingException - Exception in ds.granules.operation
-
This exception is thrown when an operation wishes to report problems in its
execution.
- ProcessingException() - Constructor for exception ds.granules.operation.ProcessingException
-
Constructs an ProcessingException with no detail message.
- ProcessingException(String) - Constructor for exception ds.granules.operation.ProcessingException
-
Constructs an ProcessingException with the specified detail
message.
- processQueued(TopicEvent) - Method in class ds.funnel.peer.PeerGroupImpl
-
- processResourceDiscoveryRequest(ResourceDiscovery) - Method in class ds.granules.scheduler.Diagnostics
-
- ProcUtil - Class in ds.funnel.util
-
- ProcUtil() - Constructor for class ds.funnel.util.ProcUtil
-
- PROFILE_PROPAGATION - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- PROFILES_EXCHANGE - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- ProgressTracker - Interface in ds.granules.operation
-
The ProgressTracker encapsulates information about the status of
jobs.
- ProgressTrackerWidget - Class in ds.granules.operation
-
An implementation of the ProgressTracker interface.
- Protocol - Interface in cgl.narada.event
-
Deprecated.
- publish() - Method in interface ds.funnel.topic.Topic
-
- publish() - Method in class ds.funnel.topic.TopicBase
-
- publishEvent(String) - Method in class ds.granules.samples.uppercase.UpperCaseProducer
-
- PublishSubscribeSample - Class in ds.funnel.samples
-
- PublishSubscribeSample() - Constructor for class ds.funnel.samples.PublishSubscribeSample
-
- publishToStream(String, byte[]) - Method in class ds.granules.util.StreamPublisher
-
Utility method that allows a producer to publish a set of bytes onto the
specified stream.
- put(byte) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a byte to the underlying buffers, allocating more if needed.
- put(byte[]) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a byte array to the underlying buffers, allocating more if needed.
- put(byte[], int, int) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write part of a byte array to the underlying buffers, starting at the
provided offset and limited by the provided length, allocating more if
needed.
- put(ByteBuffer...) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write ByteBuffer contents to the underlying buffers,
allocating more if needed.
- put(byte) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- put(byte[]) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- put(byte[], int, int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- put(ByteBuffer...) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- put(byte) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- put(byte[]) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- put(byte[], int, int) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- put(ByteBuffer...) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putChar(char) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a char to the underlying buffers, allocating more if needed.
- putChar(char) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putChar(char) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putDouble(double) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a double to the underlying buffers, allocating more if needed.
- putDouble(double) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putDouble(double) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putFloat(float) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a float to the underlying buffers, allocating more if needed.
- putFloat(float) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putFloat(float) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putInt(int) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write an integer to the underlying buffers, allocating more if needed.
- putInt(int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putInt(int) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putLong(long) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a long to the underlying buffers, allocating more if needed.
- putLong(long) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putLong(long) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putNoCopy(ByteBuffer...) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Add ByteBuffers to the list of underlying buffers, the position is
advanced by the content length.
- putNoCopy(ByteBuffer...) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putNoCopy(ByteBuffer...) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- putShort(short) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Write a short to the underlying buffers, allocating more if needed.
- putShort(short) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- putShort(short) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-