public abstract class AbstractUSRDataPlaneProducer
extends java.lang.Object
implements eu.reservoir.monitoring.core.plane.DataPlane, eu.reservoir.monitoring.core.DataSourceDelegateInteracter, eu.reservoir.monitoring.distribution.Transmitting
Constructor and Description |
---|
AbstractUSRDataPlaneProducer(SocketAddress addr)
Construct an AbstractUSRDataPlaneProducer.
|
Modifier and Type | Method and Description |
---|---|
boolean |
announce()
Announce that the plane is up and running
|
boolean |
connect()
Connect to a delivery mechansim.
|
boolean |
dennounce()
Un-announce that the plane is up and running
|
boolean |
disconnect()
Disconnect from a delivery mechansim.
|
eu.reservoir.monitoring.core.DataSourceDelegate |
getDataSourceDelegate()
Get the DataSourceDelegate this is a delegate for.
|
eu.reservoir.monitoring.core.Measurement |
report(eu.reservoir.monitoring.core.Measurement m)
Receiver of a measurment, with an extra object that has context info
|
int |
sendData(eu.reservoir.monitoring.core.plane.DataPlaneMessage dpm)
Send a message.
|
boolean |
sentData(int id)
This method is called just after a message
has been sent to the underlying transport.
|
eu.reservoir.monitoring.core.DataSourceDelegate |
setDataSourceDelegate(eu.reservoir.monitoring.core.DataSourceDelegate ds)
Set the DataSourceDelegate this is a delegate for.
|
abstract int |
transmit(eu.reservoir.monitoring.core.plane.DataPlaneMessage dsp)
Send a message onto the address.
|
boolean |
transmitted(int id)
This method is called just after a message
has been sent to the underlying transport.
|
public AbstractUSRDataPlaneProducer(SocketAddress addr)
public boolean connect()
connect
in interface eu.reservoir.monitoring.core.plane.Plane
public boolean disconnect()
disconnect
in interface eu.reservoir.monitoring.core.plane.Plane
public boolean announce()
announce
in interface eu.reservoir.monitoring.core.plane.Plane
public boolean dennounce()
dennounce
in interface eu.reservoir.monitoring.core.plane.Plane
public abstract int transmit(eu.reservoir.monitoring.core.plane.DataPlaneMessage dsp) throws java.lang.Exception
transmit
in interface eu.reservoir.monitoring.distribution.Transmitting
java.lang.Exception
public boolean transmitted(int id)
transmitted
in interface eu.reservoir.monitoring.distribution.Transmitting
public int sendData(eu.reservoir.monitoring.core.plane.DataPlaneMessage dpm) throws java.lang.Exception
sendData
in interface eu.reservoir.monitoring.core.plane.DataService
java.lang.Exception
public boolean sentData(int id)
sentData
in interface eu.reservoir.monitoring.core.plane.DataService
public eu.reservoir.monitoring.core.Measurement report(eu.reservoir.monitoring.core.Measurement m)
report
in interface eu.reservoir.monitoring.core.MeasurementReceiver
public eu.reservoir.monitoring.core.DataSourceDelegate getDataSourceDelegate()
getDataSourceDelegate
in interface eu.reservoir.monitoring.core.DataSourceDelegateInteracter
public eu.reservoir.monitoring.core.DataSourceDelegate setDataSourceDelegate(eu.reservoir.monitoring.core.DataSourceDelegate ds)
setDataSourceDelegate
in interface eu.reservoir.monitoring.core.DataSourceDelegateInteracter
User Space Routing 0.10.3