plugins_usr.monitoring.distribution

Class USRDataPlaneProducerWithNames

java.lang.Object

plugins_usr.monitoring.distribution.AbstractUSRDataPlaneProducer

plugins_usr.monitoring.distribution.USRDataPlaneProducerWithNames

All Implemented Interfaces:

eu.reservoir.monitoring.core.DataSourceDelegateInteracter, eu.reservoir.monitoring.core.MeasurementReceiver, eu.reservoir.monitoring.core.plane.DataPlane, eu.reservoir.monitoring.core.plane.DataService, eu.reservoir.monitoring.core.plane.Plane, eu.reservoir.monitoring.distribution.Transmitting

Direct Known Subclasses:

USRDataPlaneProducer

public class USRDataPlaneProducerWithNames
extends AbstractUSRDataPlaneProducer
implements eu.reservoir.monitoring.core.plane.DataPlane, eu.reservoir.monitoring.core.DataSourceDelegateInteracter, eu.reservoir.monitoring.distribution.Transmitting

A USRDataPlaneProducerWithNames is a DataPlane implementation that sends Measurements by USR. It is also a DataSourceDelegateInteracter so it can, if needed, talk to the DataSource object it gets bound to.

Constructor Summary

Constructors

Constructor and Description
USRDataPlaneProducerWithNames(SocketAddress addr) Construct a USRDataPlaneProducerWithNames

Method Summary

Methods

Modifier and Type	Method and Description
int	transmit(eu.reservoir.monitoring.core.plane.DataPlaneMessage dsp) Send a message onto the address.

Methods inherited from class plugins_usr.monitoring.distribution.AbstractUSRDataPlaneProducer

announce, connect, dennounce, disconnect, getDataSourceDelegate, report, sendData, sentData, setDataSourceDelegate, transmitted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface eu.reservoir.monitoring.core.plane.Plane

announce, connect, dennounce, disconnect

Methods inherited from interface eu.reservoir.monitoring.core.plane.DataService

sendData, sentData

Methods inherited from interface eu.reservoir.monitoring.core.MeasurementReceiver

report

Methods inherited from interface eu.reservoir.monitoring.core.DataSourceDelegateInteracter

getDataSourceDelegate, setDataSourceDelegate

Methods inherited from interface eu.reservoir.monitoring.distribution.Transmitting

transmitted

Constructor Detail

USRDataPlaneProducerWithNames

public USRDataPlaneProducerWithNames(SocketAddress addr)

Construct a USRDataPlaneProducerWithNames

Method Detail

transmit

public int transmit(eu.reservoir.monitoring.core.plane.DataPlaneMessage dsp)
             throws java.lang.Exception

Send a message onto the address. The message is XDR encoded and it's structure is: +-------------------------------------------------------------------+ | data source id (long) | msg type (int) | seq no (int) | payload | +-------------------------------------------------------------------+

Specified by:

transmit in interface eu.reservoir.monitoring.distribution.Transmitting

Specified by:

transmit in class AbstractUSRDataPlaneProducer

Throws:

java.lang.Exception