plugins_usr.monitoring.distribution

Class USRDataPlaneConsumerWithNames

java.lang.Object

plugins_usr.monitoring.distribution.AbstractUSRDataPlaneConsumer

plugins_usr.monitoring.distribution.USRDataPlaneConsumerWithNames

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:

USRDataPlaneConsumer

public class USRDataPlaneConsumerWithNames
extends AbstractUSRDataPlaneConsumer
implements eu.reservoir.monitoring.core.plane.DataPlane, eu.reservoir.monitoring.core.MeasurementReporting, eu.reservoir.monitoring.distribution.Receiving

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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.

Methods inherited from class plugins_usr.monitoring.distribution.AbstractUSRDataPlaneConsumer

announce, connect, dennounce, disconnect, eof, error, report, sendData, sentData, setMeasurementReceiver

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.MeasurementReporting

setMeasurementReceiver

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

eof, error

Constructor Detail

USRDataPlaneConsumerWithNames

public USRDataPlaneConsumerWithNames(SocketAddress addr)

Construct a USRDataPlaneConsumerWithNames.

Method Detail

received

public 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 (2 X long) | msg type (int) | seq no (int) | payload | +---------------------------------------------------------------------+

Specified by:

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

Specified by:

received in class AbstractUSRDataPlaneConsumer

Throws:

java.io.IOException

eu.reservoir.monitoring.core.TypeException