vbsServer

Class DataExtracter

java.lang.Object

vbsServer.DataExtracter

All Implemented Interfaces:

java.lang.Runnable

public class DataExtracter
extends java.lang.Object
implements java.lang.Runnable

The class DataExtracter is used to parse stored FDB files and extract their content into the MySQL database.

It is intended to run in its own thread.

Author:

Tomasz Bujlow (tbu@es.aau.dk)

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.Thread	dataExtracterThread Thread used by the class.
private static java.lang.String	defaultDirectoryName Folder storing the FDB files received from clients.
private static org.apache.log4j.Logger	log Used to log different events.
private int	packetSizeLimit Flows containing less than packetSizeLimit packets will not be stored in the database.
private boolean	runFlag The thread will stop when this flag is false.
private int	samplingInterval Interval between searching for FDB files in the folder.

Constructor Summary

Constructors

Constructor and Description
DataExtracter() Constructs the object.

Method Summary

Methods

Modifier and Type	Method and Description
private boolean	deleteShortFlowsFromDatabase(java.sql.Statement stmt) Deletes from the database flows having less than packetSizeLimit packets.
boolean	isAlive() Checks if the thread is alive.
private boolean	mergeFlowsInDatabase(java.sql.Statement stmt, java.sql.ResultSet rs, java.sql.Statement stmt2, java.sql.ResultSet rs2) Merges flows being split on the client side due to their length.
private boolean	processSQLiteDb(java.sql.Statement stmt, java.sql.ResultSet rs) Looks for FDB files in the data directory and extracts their content into the MySQL database.
void	run() Runs the thread.
void	setPacketSizeLimit(int packetSizeLimit) Sets limit for the flows.
void	start() Starts the thread.
void	stop() Stops the thread.

Methods inherited from class java.lang.Object

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

Field Detail

defaultDirectoryName

private static final java.lang.String defaultDirectoryName

Folder storing the FDB files received from clients.

See Also:

Constant Field Values

samplingInterval

private int samplingInterval

Interval between searching for FDB files in the folder.

log

private static org.apache.log4j.Logger log

Used to log different events.

dataExtracterThread

private java.lang.Thread dataExtracterThread

Thread used by the class.

packetSizeLimit

private int packetSizeLimit

Flows containing less than packetSizeLimit packets will not be stored in the database. 0 = limit is disabled.

runFlag

private boolean runFlag

The thread will stop when this flag is false.

Constructor Detail

DataExtracter

public DataExtracter()

Constructs the object.

Method Detail

start

public void start()

Starts the thread.

stop

public void stop()

Stops the thread.

isAlive

public boolean isAlive()

Checks if the thread is alive.

Returns:

true if the thread is alive, false otherwise

run

public void run()

Runs the thread. The thread in loop does the following steps. At first the processSQLiteDb function looks for FDB files in the data directory and extracts their content to the MySQL database. Then, the mergeFlowsInDatabase function merges flows being split on the client side because of their length. Lastly, flows having less than packetSizeLimit packets are deleted from the MySQL database by the deleteShortFlowsFromDatabase function.

Specified by:

run in interface java.lang.Runnable

processSQLiteDb

private boolean processSQLiteDb(java.sql.Statement stmt,
                      java.sql.ResultSet rs)

Looks for FDB files in the data directory and extracts their content into the MySQL database.

Parameters:

stmt - SQL statement

rs - SQL result set

Returns:

true if the FDB files were successfully found and extracted, false otherwise

mergeFlowsInDatabase

private boolean mergeFlowsInDatabase(java.sql.Statement stmt,
                           java.sql.ResultSet rs,
                           java.sql.Statement stmt2,
                           java.sql.ResultSet rs2)

Merges flows being split on the client side due to their length.

Parameters:

stmt - SQL statement

rs - SQL result set

stmt2 - SQL statement

rs2 - SQL result set

Returns:

true if the flows were successfully merged, false otherwise

deleteShortFlowsFromDatabase

private boolean deleteShortFlowsFromDatabase(java.sql.Statement stmt)

Deletes from the database flows having less than packetSizeLimit packets.

Parameters:

stmt - SQL statement

Returns:

true if the flows having less than packetSizeLimit packets were successfully deleted, false otherwise

setPacketSizeLimit

public void setPacketSizeLimit(int packetSizeLimit)

Sets limit for the flows. Flows having less than packetSizeLimit packets will be deleted from the MySQL database.

Parameters:

packetSizeLimit - the limit