plugins_usr.monitoring.distribution

Class AbstractUSRDataPlaneConsumer

java.lang.Object

plugins_usr.monitoring.distribution.AbstractUSRDataPlaneConsumer

All Implemented Interfaces:

eu.reservoir.monitoring.core.MeasurementReceiver, eu.reservoir.monitoring.core.MeasurementReporting, eu.reservoir.monitoring.core.plane.DataPlane, eu.reservoir.monitoring.core.plane.DataService, eu.reservoir.monitoring.core.plane.Plane, eu.reservoir.monitoring.distribution.Receiving

Direct Known Subclasses:

USRDataPlaneConsumerNoNames, USRDataPlaneConsumerWithNames

public abstract class AbstractUSRDataPlaneConsumer
extends java.lang.Object
implements eu.reservoir.monitoring.core.plane.DataPlane, eu.reservoir.monitoring.core.MeasurementReporting, eu.reservoir.monitoring.distribution.Receiving

Constructor Summary

Constructors

Constructor and Description
AbstractUSRDataPlaneConsumer(SocketAddress addr) Construct a AbstractUSRDataPlaneConsumer.

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() Dicconnect from a delivery mechansim.
void	eof() This method is called just after there has been EOF in received from some underlying transport.
void	error(java.lang.Exception e)
abstract void	received(java.io.ByteArrayInputStream bis, eu.reservoir.monitoring.distribution.MetaData metaData) This method is called just after a packet has been received from some underlying transport at a particular address.
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.
java.lang.Object	setMeasurementReceiver(eu.reservoir.monitoring.core.MeasurementReceiver mr) Set the object that will recieve the measurements.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractUSRDataPlaneConsumer

public AbstractUSRDataPlaneConsumer(SocketAddress addr)

Construct a AbstractUSRDataPlaneConsumer.

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()

Dicconnect 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

received

public abstract void received(java.io.ByteArrayInputStream bis,
            eu.reservoir.monitoring.distribution.MetaData metaData)
                       throws java.io.IOException,
                              eu.reservoir.monitoring.core.TypeException

This method is called just after a packet has been received from some underlying transport at a particular address. The expected message is XDR encoded and it's structure is: +-------------------------------------------------------------------+ | data source id (long) | msg type (int) | seq no (int) | payload | +-------------------------------------------------------------------+

Specified by:

received in interface eu.reservoir.monitoring.distribution.Receiving

Throws:

java.io.IOException

eu.reservoir.monitoring.core.TypeException

eof

public void eof()

This method is called just after there has been EOF in received from some underlying transport.

Specified by:

eof in interface eu.reservoir.monitoring.distribution.Receiving

error

public void error(java.lang.Exception e)

Specified by:

error in interface eu.reservoir.monitoring.distribution.Receiving

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

setMeasurementReceiver

public java.lang.Object setMeasurementReceiver(eu.reservoir.monitoring.core.MeasurementReceiver mr)

Set the object that will recieve the measurements.

Specified by:

setMeasurementReceiver in interface eu.reservoir.monitoring.core.MeasurementReporting