ds.funnel.traffic.component.packetgenerator

Class EEGPacketGenerator

java.lang.Object

ds.funnel.traffic.component.packetgenerator.EEGPacketGenerator

All Implemented Interfaces:

PacketGenerator, JavaMessageHandler

public class EEGPacketGenerator
extends java.lang.Object
implements PacketGenerator, JavaMessageHandler

A packet generator which produces packets containing segments of EEG readings using data read from provided files. Runs an R script to process the files via JRI. The R script fakeStream.R must be accessible.

Author:

Kira Lindburg

Constructor Summary

Constructors

Constructor and Description
EEGPacketGenerator(java.lang.String ID, java.lang.String files) Creates a new EEGPacketGenerator with the given values.

Method Summary

Modifier and Type	Method and Description
byte[]	generatePacket(int packetSize) Generates a byte array containing a segment of EEG data.
void	grabFiles(java.lang.String inListFile) Reads the specified files (presumably containing EEG data) and segments the data.
void	handleMessage(byte[] msg) Function to handle messages recieved via a StreamReader.

Methods inherited from class java.lang.Object

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

Constructor Detail

EEGPacketGenerator

public EEGPacketGenerator(java.lang.String ID,
                          java.lang.String files)

Creates a new EEGPacketGenerator with the given values.

Parameters:

ID - a String identifying the stream to which the packets produced by this EEG packet generator belong

files - path to a file containing a list of files which contain the actual data (each filename in the list must be on its own line)

Method Detail

grabFiles

public void grabFiles(java.lang.String inListFile)
               throws java.io.IOException

Reads the specified files (presumably containing EEG data) and segments the data. Stores the data for future packet generation. This method must be called at least once before calling generatePacket().

Parameters:

fileList - the path to the file which contains a list of filenames, one per line; each of the listed files should contain EEG readings

Throws:

java.io.IOException - if an I/O error occurs when reading from the file

handleMessage

public void handleMessage(byte[] msg)

Description copied from interface: JavaMessageHandler

Function to handle messages recieved via a StreamReader. Allows the user to define an asynchronous method of handling messages

Specified by:

handleMessage in interface JavaMessageHandler

Parameters:

msg - byte[] to be decoded

generatePacket

public byte[] generatePacket(int packetSize)

Generates a byte array containing a segment of EEG data. Note that the provided size will be ignored. Each subsequent packet generated will contain a new segment of data from the provided files; when the end of the data is reached the packet generator will loop back to the beginning.

Specified by:

generatePacket in interface PacketGenerator

Parameters:

packetSize - the size of desired packet, in bytes

Returns:

a byte array containing the bytes of the generated packet data