ds.funnel.traffic.analysis

Class TrafficPublisher

java.lang.Object

ds.funnel.traffic.analysis.TrafficPublisher

public class TrafficPublisher
extends java.lang.Object

The TrafficPublisher should be used in conjunction with a TrafficReflector. The traffic publisher publishes traffic, and the traffic reflector responds by sending the traffic back so that the traffic publisher can collect statistics on each packet. Publishes traffic to the traffic generation topic, named by TrafficConstants.TOPIC_NAME. The traffic published is generated by a traffic generator specified using an input file. Also subscribes to the traffic generation topic, and listens for packets not produced by itself. (These packets are presumably responses produced by a traffic reflector.) Tracks the round trip time for each packet, along with other statistics. Statistics are logged to a specified output file, and include latency (round trip time / 2) in milliseconds, packet size, time sent, and packet loss rate. Three command line arguments are required in the following order: specFile: This should be a path to a file specifying the desired traffic generator configuration. The contents of the file must be in a format readable by the traffic generator builder. logFile: This is the desired path to the log file generated by the traffic publisher. duration: This is the length of time, in seconds, for which the traffic publisher should run. Once duration seconds have expired, the program simply exits.

Author:

Kira Lindburg

Constructor Summary

Constructors

Constructor and Description
TrafficPublisher()

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
static void	onEvent(TopicDataEvent inEvent, long receiveTimeNano) If the inEvent was not published by this traffic publisher, calculates statistics on the packet and logs them to the log file.
static void	usage() Prints a usage message.

Methods inherited from class java.lang.Object

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

Constructor Detail

TrafficPublisher

public TrafficPublisher()

Method Detail

usage

public static void usage()

Prints a usage message.

main

public static void main(java.lang.String[] args)
                 throws OverlayException,
                        TopicException,
                        ComponentException,
                        java.io.FileNotFoundException,
                        RegistrationException

Throws:

OverlayException

TopicException

ComponentException

java.io.FileNotFoundException

RegistrationException

onEvent

public static void onEvent(TopicDataEvent inEvent,
                           long receiveTimeNano)

If the inEvent was not published by this traffic publisher, calculates statistics on the packet and logs them to the log file. Statistics logged include timestamp of the log (not exactly when the event was published, but will give us the hour of day and day of week - close enough for government work), size of the data, latency for this event (in milliseconds), and the current packet loss rate. (Statistics will be logged in this order, comma separated.)

Parameters:

inEvent - the received event