class documentation

class SubscriberStatisticsLogger:

Constructor: SubscriberStatisticsLogger(subscriber)

View In Hierarchy

Class that monitors each subscriber.

this class basically just keeps a collection of ConnectionStatisticsLogger.

Class Method is_enabled Undocumented
Method __init__ Undocumented
Method callback This method is called for every message that has been received.
Method read_parameters Fetch window parameters from parameter server
Method shutdown Undocumented
Instance Variable connections Undocumented
Instance Variable max_elements Undocumented
Instance Variable max_window Undocumented
Instance Variable min_elements Undocumented
Instance Variable min_window Undocumented
Instance Variable subscriber_name Undocumented
@classmethod
def is_enabled(cls):

Undocumented

def __init__(self, subscriber):

Undocumented

def callback(self, msg, publisher, stat_bytes):

This method is called for every message that has been received.

@param msg: The message received. @param publisher: The name of the publisher node that sent the msg @param stat_bytes: A counter, how many bytes have been moved across this connection since it exists.

This method just looks up the ConnectionStatisticsLogger for the specific connection between publisher and subscriber and delegates to statistics logging to that instance.

def read_parameters(self):

Fetch window parameters from parameter server

def shutdown(self):

Undocumented

connections =

Undocumented

max_elements =

Undocumented

max_window =

Undocumented

min_elements =

Undocumented

min_window =

Undocumented

subscriber_name =

Undocumented