plugins_usr.monitoring.distribution

Class AbstractUSRDataPlaneProducer

java.lang.Object

plugins_usr.monitoring.distribution.AbstractUSRDataPlaneProducer

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:

USRDataPlaneProducerNoNames, USRDataPlaneProducerWithNames

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

An AbstractUSRDataPlaneProducer 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
AbstractUSRDataPlaneProducer(SocketAddress addr) Construct an AbstractUSRDataPlaneProducer.

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractUSRDataPlaneProducer

public AbstractUSRDataPlaneProducer(SocketAddress addr)

Construct an AbstractUSRDataPlaneProducer.

Method Detail

connect

public boolean connect()

Connect to a delivery mechansim.

Specified by:

connect in interface eu.reservoir.monitoring.core.plane.Plane

disconnect

public boolean disconnect()

Disconnect from a delivery mechansim.

Specified by:

disconnect in interface eu.reservoir.monitoring.core.plane.Plane

announce

public boolean announce()

Announce that the plane is up and running

Specified by:

announce in interface eu.reservoir.monitoring.core.plane.Plane

dennounce

public boolean dennounce()

Un-announce that the plane is up and running

Specified by:

dennounce in interface eu.reservoir.monitoring.core.plane.Plane

transmit

public abstract 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

Throws:

java.lang.Exception

transmitted

public boolean transmitted(int id)

This method is called just after a message has been sent to the underlying transport.

Specified by:

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

sendData

public int sendData(eu.reservoir.monitoring.core.plane.DataPlaneMessage dpm)
             throws java.lang.Exception

Send a message.

Specified by:

sendData in interface eu.reservoir.monitoring.core.plane.DataService

Throws:

java.lang.Exception

sentData

public boolean sentData(int id)

This method is called just after a message has been sent to the underlying transport.

Specified by:

sentData in interface eu.reservoir.monitoring.core.plane.DataService

report

public eu.reservoir.monitoring.core.Measurement report(eu.reservoir.monitoring.core.Measurement m)

Receiver of a measurment, with an extra object that has context info

Specified by:

report in interface eu.reservoir.monitoring.core.MeasurementReceiver

getDataSourceDelegate

public eu.reservoir.monitoring.core.DataSourceDelegate getDataSourceDelegate()

Get the DataSourceDelegate this is a delegate for.

Specified by:

getDataSourceDelegate in interface eu.reservoir.monitoring.core.DataSourceDelegateInteracter

setDataSourceDelegate

public eu.reservoir.monitoring.core.DataSourceDelegate setDataSourceDelegate(eu.reservoir.monitoring.core.DataSourceDelegate ds)

Set the DataSourceDelegate this is a delegate for.

Specified by:

setDataSourceDelegate in interface eu.reservoir.monitoring.core.DataSourceDelegateInteracter