|
DisTAnz 1.0 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--DTA.agent.DataCollector
Der DataCollector nimmt Verbindung zu der Helper-Application auf, die den Datenstrom des Netzwerkes als Text zur Verfügung stellt. Dieser Text wird geparst und gefiltert, und in einem DataStorage-Objekt abgelegt.
Tritt beim Parsen des Paketes ein Fehler auf, wird es verworfen, filterPacketInfo gibt null zurück.
Erstellt: Jun 2000
Field Summary | |
private java.lang.Thread |
collThread
Dient der Threadkontrolle (start/die). |
private java.io.BufferedReader |
in
|
private DataStorage |
myMemory
|
private int |
port
|
private java.net.Socket |
socket
|
Constructor Summary | |
DataCollector(DataStorage dataStorage)
Erzeugt einen DataCollector mit dataStorage als Speicher und einem Standardport von 2000. |
|
DataCollector(DataStorage dataStorage,
int port)
Erzeugt einen DataCollector auf Port port mit dataStorage als Datenspeicher. |
Method Summary | |
void |
die()
Die die-Methode hält den DataCollector an. |
private Flow |
filterPacketInfo(java.lang.String dataPacket)
Describe filterPacketInfo method here. |
static void |
main(java.lang.String[] args)
Dient dem Test der Funktionalität der Klasse. |
void |
run()
run liest jeweils eine Zeile von tcpdump (böse
Falle, das mit der ersten Zeile der localhost:2000-Ausgabe :),
läßt sie von filterPacketInfo parsen und speichert ein
zurückgegebenes Flow-Objekt in myMemory.
|
void |
start()
Startet den DataCollector. |
Methods inherited from class java.lang.Object |
|
Field Detail |
private java.io.BufferedReader in
private int port
private java.net.Socket socket
private DataStorage myMemory
private java.lang.Thread collThread
Constructor Detail |
public DataCollector(DataStorage dataStorage) throws java.net.UnknownHostException, java.net.SocketException, java.io.IOException
dataStorage
- Der zu verwendende DataStorage.public DataCollector(DataStorage dataStorage, int port) throws java.net.UnknownHostException, java.net.SocketException, java.io.IOException
dataStorage
- Der zu verwendende DataStorage.port
- Der Port zur Verbindung mit der Helper-ApplicationMethod Detail |
public void start()
public void run()
run
liest jeweils eine Zeile von tcpdump (böse
Falle, das mit der ersten Zeile der localhost:2000-Ausgabe :),
läßt sie von filterPacketInfo parsen und speichert ein
zurückgegebenes Flow-Objekt in myMemory.
Kommt null
zurück, war das Paket kein IP-Paket
und wird ignoriert.
public void die()
private Flow filterPacketInfo(java.lang.String dataPacket)
filterPacketInfo
method here.dataPacket
- Ein String
Flow
-Objekt, aus den Daten des
übergebenen dataPacket.Flow
public static void main(java.lang.String[] args) throws java.io.IOException, java.lang.InterruptedException
args
- Wird nicht genutzt.
|
DisTAnz 1.0 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |