start parsing 802.11 control frames

3 files changed, 1335 insertions, 1319 deletions

diff --git a/libopie2/opienet/802_11_user.h b/libopie2/opienet/802_11_user.h
index ad84514..7ae27c5 100644
--- a/libopie2/opienet/802_11_user.h
+++ b/libopie2/opienet/802_11_user.h
@@ -56,397 +56,397 @@ struct ieee_802_3_header {
 #define P80211_OUI_LEN 3
 
 struct ieee_802_11_802_2_header {
 
 	u_int8_t    dsap;
 	u_int8_t    ssap;   /* always 0xAA */
 	u_int8_t    ctrl;   /* always 0x03 */
 	u_int8_t    oui[P80211_OUI_LEN];    /* organizational universal id */
 	u_int16_t   type;      /* packet type ID field */
 };
 
 /* See RFC 826 for protocol description.  ARP packets are variable
    in size; the arphdr structure defines the fixed-length portion.
    Protocol type values are the same as those for 10 Mb/s Ethernet.
    It is followed by the variable-sized fields ar_sha, arp_spa,
    arp_tha and arp_tpa in that order, according to the lengths
    specified.  Field names used correspond to RFC 826.  */
 
 #define ETH_ALEN 6
 
 struct myarphdr
 {
     unsigned short int ar_hrd;          /* Format of hardware address.  */
     unsigned short int ar_pro;          /* Format of protocol address.  */
     unsigned char ar_hln;               /* Length of hardware address.  */
     unsigned char ar_pln;               /* Length of protocol address.  */
     unsigned short int ar_op;           /* ARP opcode (command).  */
     /* Ethernet looks like this : This bit is variable sized
        however...  */
     unsigned char ar_sha[ETH_ALEN];   /* Sender hardware address.  */
     unsigned char ar_sip[4];          /* Sender IP address.  */
     unsigned char ar_tha[ETH_ALEN];   /* Target hardware address.  */
     unsigned char ar_tip[4];          /* Target IP address.  */
 };
 
 
 // following is incoplete and may be incorrect and need reorganization
 
 #define ieee_802_11_frame_type_Management	0x00
 #define ieee_802_11_frame_type_Control		0x01
 #define ieee_802_11_frame_type_Data		0x10
 #define ieee_802_11_frame_type_Reserved		0x11
 
 #define ieee_802_11_frame_subtype_Association_Req	0x0 // Association Request
 #define ieee_802_11_frame_subtype_Association_Resp	0x1 // Association Response
 #define ieee_802_11_frame_subtype_Reassociation_Req	0x2 // Reassociation Request
 #define ieee_802_11_frame_subtype_Reassociation_Resp	0x3 // Reassociation Response
 #define ieee_802_11_frame_subtype_Probe_Req		0x4 // Probe Request
 #define ieee_802_11_frame_subtype_Probe_Resp		0x5 // Probe Response
 #define ieee_802_11_frame_subtype_Beacon 		0x8 // Beacon
 #define ieee_802_11_frame_subtype_ATIM 			0x9 // ATIM
 #define ieee_802_11_frame_subtype_Disassociation 	0xA // Disassociation
 #define ieee_802_11_frame_subtype_Authentication 	0xB // Authentication
 #define ieee_802_11_frame_subtype_Deauthentication 	0xC // Deauthentication
 #define ieee_802_11_frame_subtype_PS_Poll 		0xA // PS-Poll
 #define ieee_802_11_frame_subtype_RTS 			0xB // RTS
 #define ieee_802_11_frame_subtype_CTS 			0xC // CTS
 #define ieee_802_11_frame_subtype_ACK 			0xD // ACK
 #define ieee_802_11_frame_subtype_CFEnd 		0xE // CF-End
 #define ieee_802_11_frame_subtype_CFEnd_CFAck 		0xF // CF-End + CF-Ack
 #define ieee_802_11_frame_subtype_Data 			0x0 // Data
 #define ieee_802_11_frame_subtype_Data_CFAck 		0x1 // Data + CF-Ack
 #define ieee_802_11_frame_subtype_Data_CF_Poll 		0x2 // Data + CF-Poll
 #define ieee_802_11_frame_subtype_Data_CF_AckCF_Poll 	0x3 // Data + CF-Ack + CF-Poll
 #define ieee_802_11_frame_subtype_NullFunction 		0x4 // Null Function (no data)
 #define ieee_802_11_frame_subtype_CF_Ack 		0x5 // CF-Ack (no data)
 #define ieee_802_11_frame_subtype_CF_Poll 		0x6 // CF-Poll (no data)
 #define ieee_802_11_frame_subtype_CF_AckCF_Poll 	0x7 // CF-Ack + CF-Poll (no data)
 
 
 #define ieee_802_11_frame_subtype_strings {\
 	{ ieee_802_11_frame_subtype_Association_Req,	0xF,"f  Association Request"},\
 	{ ieee_802_11_frame_subtype_Association_Resp,	0xF,"1  Association Response"},\
 	{ ieee_802_11_frame_subtype_Reassociation_Req,	0xF,"2  Reassociation Request"},\
 	{ ieee_802_11_frame_subtype_Reassociation_Resp,	0xF,"3  Reassociation Response"},\
 	{ ieee_802_11_frame_subtype_Probe_Req	,	0xF,"4  Probe Request"},\
 	{ ieee_802_11_frame_subtype_Probe_Resp	,	0xF,"5  Probe Response"},\
 	{ ieee_802_11_frame_subtype_Beacon 	,	0xF,"8  Beacon"},\
 	{ ieee_802_11_frame_subtype_ATIM 	,	0xF,"9  ATIM"},\
 	{ ieee_802_11_frame_subtype_Disassociation,	0xF,"A  Disassociation"},\
 	{ ieee_802_11_frame_subtype_Authentication,	0xF,"B  Authentication"},\
 	{ ieee_802_11_frame_subtype_Deauthentication,	0xF,"C  Deauthentication"},\
 	{ ieee_802_11_frame_subtype_PS_Poll 	,	0xF,"A  PS-Poll"},\
 	{ ieee_802_11_frame_subtype_RTS 	,	0xF,"B  RTS"},\
 	{ ieee_802_11_frame_subtype_CTS 	,	0xF,"C  CTS"},\
 	{ ieee_802_11_frame_subtype_ACK 	,	0xF,"D  ACK"},\
 	{ ieee_802_11_frame_subtype_CFEnd	,	0xF,"E  CF-End"},\
 	{ ieee_802_11_frame_subtype_CFEnd_CFAck ,	0xF,"F  CF-End + CF-Ack"},\
 	{ ieee_802_11_frame_subtype_Data 	,	0xF,"0  Data"},\
 	{ ieee_802_11_frame_subtype_Data_CFAck 	,	0xF,"1  Data + CF-Ack"},\
 	{ ieee_802_11_frame_subtype_Data_CFPoll ,	0xF,"2  Data + CF-Poll"},\
 	{ ieee_802_11_frame_subtype_Data_CFAck_CFPoll,	0xF,"3  Data + CF-Ack + CF-Poll"},\
 	{ ieee_802_11_frame_subtype_Null_Function ,	0xF,"4  Null Function (no data)"},\
 	{ ieee_802_11_frame_subtype_CFAck ,		0xF,"5  CF-Ack (no data)"},\
 	{ ieee_802_11_frame_subtype_CFPoll ,		0xF,"6  CF-Poll (no data)"},\
 	{ ieee_802_11_frame_subtype_CFAck_CFPoll,	0xF,"y7  CF-Ack + CF-Poll (no data)"},\
 	{ 0,0,NULL}\
 }
 struct ieee_802_11_frame_subtype_class {
 	u_int8_t	subtype;
 	u_int8_t	mask;
 	u_int8_t	klass;
 	u_int8_t	type;
 };
 #define ieee_802_11_frame_subtype_classes {\
 	{ ieee_802_11_frame_subtype_Association_Req,	0xF,2,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Association_Resp,	0xF,2,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Reassociation_Req,	0xF,2,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Reassociation_Resp,	0xF,2,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Probe_Req	,	0xF,1,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Probe_Resp	,	0xF,1,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Beacon 	,	0xF,1,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_ATIM 	,	0xF,1,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Disassociation,	0xF,2,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Authentication,	0xF,1,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_Deauthentication,	0xF,3,ieee_802_11_frame_type_Management},\
 	{ ieee_802_11_frame_subtype_PS-Poll 	,	0xF,3,ieee_802_11_frame_type_Control},\
 	{ ieee_802_11_frame_subtype_RTS 	,	0xF,1,ieee_802_11_frame_type_Control},\
 	{ ieee_802_11_frame_subtype_CTS 	,	0xF,1,ieee_802_11_frame_type_Control},\
 	{ ieee_802_11_frame_subtype_ACK 	,	0xF,1,ieee_802_11_frame_type_Control},\
 	{ ieee_802_11_frame_subtype_CFEnd	,	0xF,1,ieee_802_11_frame_type_Control},\
 	{ ieee_802_11_frame_subtype_CFEnd_CFAck ,	0xF,1,ieee_802_11_frame_type_Control},\
 	{ ieee_802_11_frame_subtype_Data 	,	0xF,3,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_Data_CFAck 	,	0xF,3,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_Data_CF_Poll 	0xF,3,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_Data_CF_AckCF_Poll,	0xF,3,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_NullFunction 	0xF,1,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_CF_Ack ,		0xF,1,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_CF_Poll ,		0xF,1,ieee_802_11_frame_type_Data},\
 	{ ieee_802_11_frame_subtype_CF_AckCF_Poll,	0xF,1,ieee_802_11_frame_type_Data},\
 	{ 0,0,NULL}\
 }
 
 #define IEEE802_11_FC_LEN	2
 
 #define T_MGMT 0x0  /* management */
 #define T_CTRL 0x1  /* control */
 #define T_DATA 0x2 /* data */
 #define T_RESV 0x3  /* reserved */
 
 #define ST_ASSOC_REQUEST   	0x0
 #define ST_ASSOC_RESPONSE 	0x1
 #define ST_REASSOC_REQUEST   	0x2
 #define ST_REASSOC_RESPONSE  	0x3
 #define ST_PROBE_REQUEST   	0x4
 #define ST_PROBE_RESPONSE   	0x5
 /* RESERVED 			0x6  */
 /* RESERVED 			0x7  */
 #define ST_BEACON   		0x8
 #define ST_ATIM			0x9
 #define ST_DISASSOC		0xA
 #define ST_AUTH			0xB
 #define ST_DEAUTH		0xC
 /* RESERVED 			0xD  */
 /* RESERVED 			0xE  */
 /* RESERVED 			0xF  */
 
 
 #define CTRL_PS_POLL	0xA
 #define CTRL_RTS	0xB
 #define CTRL_CTS	0xC
 #define CTRL_ACK	0xD
 #define CTRL_CF_END	0xE
 #define CTRL_END_ACK	0xF
 
 /*
  * Bits in the frame control field.
  */
 #define FC_VERSION(fc)		((fc) & 0x3)
 #define FC_TYPE(fc)		(((fc) >> 2) & 0x3)
 #define FC_SUBTYPE(fc)		(((fc) >> 4) & 0xF)
 #define FC_TO_DS(fc)		((fc) & 0x0100)
 #define FC_FROM_DS(fc)		((fc) & 0x0200)
 #define FC_MORE_FLAG(fc)	((fc) & 0x0400)
 #define FC_RETRY(fc)		((fc) & 0x0800)
 #define FC_POWER_MGMT(fc)	((fc) & 0x1000)
 #define FC_MORE_DATA(fc)	((fc) & 0x2000)
 #define FC_WEP(fc)		((fc) & 0x4000)
 #define FC_ORDER(fc)		((fc) & 0x8000)
 
 
 struct ieee_802_11_mgmt_header {
   u_int16_t fc;
   u_int16_t duration;
   u_int8_t  da[6];
   u_int8_t  sa[6];
   u_int8_t  bssid[6];
   u_int16_t seq_ctrl;
 };
 
 
 struct ieee_802_11_data_header {
-	u_int16_t	frame_control;
+	u_int16_t	fc;
 	u_int16_t	duration;
 	u_int8_t	mac1[6];
 	u_int8_t	mac2[6];
 	u_int8_t	mac3[6];
 	u_int16_t	SeqCtl;
 	u_int8_t	mac4[6];
 //	u_int16_t	gapLen;
 //	u_int8_t	gap[8];
 };
 
 struct ieee_802_11_control_header {
-	u_int16_t	frame_control;
+	u_int16_t	fc;
 	u_int16_t	duration;
 	u_int8_t	mac1[6];
 	u_int8_t	mac2[6];
 	u_int8_t	mac3[6];
 	u_int16_t	SeqCtl;
 	u_int8_t	mac4[6];
 //	u_int16_t	gapLen;
 //	u_int8_t	gap[8];
 };
 
 #define CAPABILITY_ESS(cap)     ((cap) & 0x0001)
 #define CAPABILITY_IBSS(cap)    ((cap) & 0x0002)
 #define CAPABILITY_CFP(cap)     ((cap) & 0x0004)
 #define CAPABILITY_CFP_REQ(cap) ((cap) & 0x0008)
 #define CAPABILITY_PRIVACY(cap) ((cap) & 0x0010)
 
 struct ssid_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_char		ssid[33];  /* 32 + 1 for null */
 };
 
 
 struct rates_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int8_t	rate[8];
 };
 
 
 struct challenge_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int8_t	text[254]; /* 1-253 + 1 for null */
 };
 
 
 struct fh_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int16_t	dwell_time;
   u_int8_t	hop_set;
   u_int8_t 	hop_pattern;
   u_int8_t	hop_index;
 };
 
 
 struct ds_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int8_t	channel;
 };
 
 
 struct cf_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int8_t	count;
   u_int8_t	period;
   u_int16_t	max_duration;
   u_int16_t	dur_remaing;
 };
 
 
 struct tim_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int8_t	count;
   u_int8_t	period;
   u_int8_t	bitmap_control;
   u_int8_t	bitmap[251];
 };
 
 
 struct ibss_t {
   u_int8_t	element_id;
   u_int8_t	length;
   u_int16_t	atim_window;
 };
 
 
 #define E_SSID      0
 #define E_RATES     1
 #define E_FH        2
 #define E_DS        3
 #define E_CF        4
 #define E_TIM       5
 #define E_IBSS      6
 #define E_CHALLENGE 16
 #define E_CISCO     133
 
 
 struct ieee_802_11_mgmt_body {
   u_int8_t  timestamp[8];
   u_int16_t beacon_interval;
 //  u_int16_t 	listen_interval;
 //  u_int16_t 	status_code;
 //  u_int16_t 	aid;
 //  u_char		ap[6];
 //  u_int16_t	reason_code;
 //  u_int16_t	auth_alg;
 //  u_int16_t	auth_trans_seq_num;
 //  struct challenge_t  challenge;
   u_int16_t capability_info;
 //  struct ssid_t	ssid;
 //  struct rates_t 	rates;
 //  struct ds_t	ds;
 //  struct cf_t	cf;
 //  struct fh_t	fh;
 //  struct tim_t	tim;
 };
 
 /* a 802.11 value */
 struct val_80211 {
     unsigned int did;
     unsigned short status, len;
     unsigned int data;
 };
 
 /* header attached during prism monitor mode */
 struct prism_hdr {
     unsigned int msgcode, msglen;
     char devname[16];
     struct val_80211 hosttime, mactime, channel, rssi, sq, signal,
         noise, rate, istx, frmlen;
 };
 
 struct ieee_802_11_data_body {
 //FIXME
 };
 
 struct ieee_802_11_control_body {
 //FIXME
 };
 
 struct ctrl_rts_t {
   u_int16_t	fc;
   u_int16_t	duration;
   u_int8_t	ra[6];
   u_int8_t	ta[6];
   u_int8_t	fcs[4];
 };
 
 #define CTRL_RTS_LEN	(2+2+6+6+4)
 
 struct ctrl_cts_t {
   u_int16_t	fc;
   u_int16_t	duration;
   u_int8_t	ra[6];
   u_int8_t	fcs[4];
 };
 
 #define CTRL_CTS_LEN	(2+2+6+4)
 
 struct ctrl_ack_t {
   u_int16_t	fc;
   u_int16_t	duration;
   u_int8_t	ra[6];
   u_int8_t	fcs[4];
 };
 
 #define CTRL_ACK_LEN	(2+2+6+4)
 
 struct ctrl_ps_poll_t {
   u_int16_t	fc;
   u_int16_t	aid;
   u_int8_t	bssid[6];
   u_int8_t	ta[6];
   u_int8_t	fcs[4];
 };
 
 #define CTRL_PS_POLL_LEN	(2+2+6+6+4)
 
 struct ctrl_end_t {
   u_int16_t	fc;
   u_int16_t	duration;
   u_int8_t	ra[6];
   u_int8_t	bssid[6];
   u_int8_t	fcs[4];
 };
 
 #define CTRL_END_LEN	(2+2+6+6+4)
 
 struct ctrl_end_ack_t {
   u_int16_t	fc;
   u_int16_t	duration;
   u_int8_t	ra[6];
   u_int8_t	bssid[6];
   u_int8_t	fcs[4];
 };
 
 #define CTRL_END_ACK_LEN	(2+2+6+6+4)
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp
index e9b3b2c..012c0a3 100644
--- a/libopie2/opienet/opcap.cpp
+++ b/libopie2/opienet/opcap.cpp
@@ -1,1317 +1,1331 @@
-/*

-                             This file is part of the Opie Project

-                             Copyright (C) 2003 by Michael 'Mickey' Lauer <mickey@Vanille.de>

-              =.

-            .=l.

-           .>+-=

- _;:,     .>    :=|.         This program is free software; you can

-.> <`_,   >  .   <=          redistribute it and/or  modify it under

-:`=1 )Y*s>-.--   :           the terms of the GNU Library General Public

-.="- .-=="i,     .._         License as published by the Free Software

- - .   .-<_>     .<>         Foundation; either version 2 of the License,

-     ._= =}       :          or (at your option) any later version.

-    .%`+i>       _;_.

-    .i_,=:_.      -<s.       This program is distributed in the hope that

-     +  .  -:.       =       it will be useful,  but WITHOUT ANY WARRANTY;

-    : ..    .:,     . . .    without even the implied warranty of

-    =_        +     =;=|`    MERCHANTABILITY or FITNESS FOR A

-  _.=:.       :    :=>`:     PARTICULAR PURPOSE. See the GNU

-..}^=.=       =       ;      Library General Public License for more

-++=   -.     .`     .:       details.

- :     =  ...= . :.=-

- -.   .:....=;==+<;          You should have received a copy of the GNU

-  -_. . .   )=.  =           Library General Public License along with

-    --        :-=`           this library; see the file COPYING.LIB.

-                             If not, write to the Free Software Foundation,

-                             Inc., 59 Temple Place - Suite 330,

-                             Boston, MA 02111-1307, USA.

-

-*/

-

-/* OPIE */

-#include <opie2/opcap.h>

-#include <opie2/odebug.h>

-

-/* QT */

-#include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects)

-#include <qsocketnotifier.h>

-#include <qobjectlist.h>

-

-/* SYSTEM */

-#include <sys/time.h>

-#include <sys/types.h>

-#include <unistd.h>

-

-/* LOCAL */

-#include "udp_ports.h"

-

-/*======================================================================================

- * OPacket

- *======================================================================================*/

-

-OPacket::OPacket( int datalink, packetheaderstruct header, const unsigned char* data, QObject* parent )

-        :QObject( parent, "Generic" ), _hdr( header ), _data( data )

-{

-    //qDebug( "OPacket::OPacket(): (Len %d, CapLen %d)" /*, ctime((const time_t*) header.ts.tv_sec)*/, header.len, header.caplen );

-

-    _end = (unsigned char*) data + header.len;

-    //qDebug( "OPacket::data @ %0x, end @ %0x", data, _end );

-

-    switch ( datalink )

-    {

-        case DLT_EN10MB:

-            odebug << "OPacket::OPacket(): Received Packet. Datalink = ETHERNET" << oendl;

-            new OEthernetPacket( _end, (const struct ether_header*) data, this );

-            break;

-

-        case DLT_IEEE802_11:

-            odebug << "OPacket::OPacket(): Received Packet. Datalink = IEEE802.11" << oendl;

-            new OWaveLanPacket( _end, (const struct ieee_802_11_header*) data, this );

-            break;

-

-        case DLT_PRISM_HEADER:

-            odebug << "OPacket::OPacket(): Received Packet. Datalink = PRISM_HEADER" << oendl;

-            new OPrismHeaderPacket( _end, (const struct prism_hdr*) (unsigned char*) data, this );

-            break;

-

-        default:

-            owarn << "OPacket::OPacket(): Received Packet over unsupported datalink, type " << datalink << "!" << oendl;

-    }

-}

-

-

-OPacket::~OPacket()

-{

-}

-

-

-timevalstruct OPacket::timeval() const

-{

-    return _hdr.ts;

-}

-

-

-int OPacket::caplen() const

-{

-    return _hdr.caplen;

-}

-

-

-void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l )

-{

-    if (!l) return;

-    QObject* o = l->first();

-    while ( o )

-    {

-        stats[o->name()]++;

-        updateStats( stats, const_cast<QObjectList*>( o->children() ) );

-        o = l->next();

-    }

-}

-

-

-void OPacket::dumpStructure( QObjectList* l )

-{

-    QString packetString( "[ |" + _dumpStructure( l ) + " ]" );

-    odebug << "OPacket::dumpStructure: " << packetString << oendl;

-}

-

-

-QString OPacket::_dumpStructure( QObjectList* l )

-{

-    if (!l) return QString::null;

-    QObject* o = l->first();

-    QString str(" ");

-

-    while ( o )

-    {

-        str.append( o->name() );

-        str.append( " |" );

-        str += _dumpStructure( const_cast<QObjectList*>( o->children() ) );

-        o = l->next();

-    }

-    return str;

-}

-

-QString OPacket::dump( int bpl ) const

-{

-    static int index = 0;

-    index++;

-    int len = _hdr.caplen;

-    QString str;

-    str.sprintf( "\n<----- Packet #%04d Len = 0x%X (%d) ----->\n\n", index, len, len );

-    str.append( "0000: " );

-    QString tmp;

-    QString bytes;

-    QString chars;

-

-    for ( int i = 0; i < len; ++i )

-    {

-        tmp.sprintf( "%02X ", _data[i] ); bytes.append( tmp );

-        if ( (_data[i] > 31) && (_data[i]<128) ) chars.append( _data[i] );

-        else chars.append( '.' );

-

-        if ( !((i+1) % bpl) )

-        {

-            str.append( bytes );

-            str.append( ' ' );

-            str.append( chars );

-            str.append( '\n' );

-            tmp.sprintf( "%04X: ", i+1 ); str.append( tmp );

-            bytes = "";

-            chars = "";

-        }

-

-    }

-    if ( (len % bpl) )

-    {

-        str.append( bytes.leftJustify( 1 + 3*bpl ) );

-        str.append( chars );

-    }

-    str.append( '\n' );

-    return str;

-}

-

-

-int OPacket::len() const

-{

-    return _hdr.len;

-}

-

-

-/*======================================================================================

- * OEthernetPacket

- *======================================================================================*/

-

-OEthernetPacket::OEthernetPacket( const unsigned char* end, const struct ether_header* data, QObject* parent )

-                :QObject( parent, "Ethernet" ), _ether( data )

-{

-

-    odebug << "Source = " << sourceAddress().toString();

-    odebug << "Destination = " << destinationAddress().toString();

-

-    if ( sourceAddress() == OMacAddress::broadcast )

-        odebug << "Source is broadcast address" << oendl;

-    if ( destinationAddress() == OMacAddress::broadcast )

-        odebug << "Destination is broadcast address" << oendl;

-

-    switch ( type() )

-    {

-        case ETHERTYPE_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break;

-        case ETHERTYPE_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break;

-        case ETHERTYPE_REVARP: { odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = RARP" << oendl; break; }

-        default: odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = UNKNOWN" << oendl;

-    }

-

-}

-

-

-OEthernetPacket::~OEthernetPacket()

-{

-}

-

-

-OMacAddress OEthernetPacket::sourceAddress() const

-{

-    return OMacAddress( _ether->ether_shost );

-}

-

-

-OMacAddress OEthernetPacket::destinationAddress() const

-{

-    return OMacAddress( _ether->ether_dhost );

-}

-

-int OEthernetPacket::type() const

-{

-    return ntohs( _ether->ether_type );

-}

-

-

-/*======================================================================================

- * OIPPacket

- *======================================================================================*/

-

-

-OIPPacket::OIPPacket( const unsigned char* end, const struct iphdr* data, QObject* parent )

-          :QObject( parent, "IP" ), _iphdr( data )

-{

-    odebug << "OIPPacket::OIPPacket(): decoding IP header..." << oendl;

-

-    odebug << "FromAddress = " << fromIPAddress().toString();

-    odebug << "  toAddress = " << toIPAddress().toString();

-

-    switch ( protocol() )

-    {

-        case IPPROTO_UDP: new OUDPPacket( end, (const struct udphdr*) (data+1), this ); break;

-        case IPPROTO_TCP: new OTCPPacket( end, (const struct tcphdr*) (data+1), this ); break;

-        default: odebug << "OIPPacket::OIPPacket(): unknown IP protocol, type = " << protocol() << oendl;

-    }

-

-}

-

-OIPPacket::~OIPPacket()

-{

-}

-

-

-QHostAddress OIPPacket::fromIPAddress() const

-{

-    return EXTRACT_32BITS( &_iphdr->saddr );

-}

-

-

-QHostAddress OIPPacket::toIPAddress() const

-{

-    return EXTRACT_32BITS( &_iphdr->saddr );

-}

-

-

-int OIPPacket::tos() const

-{

-    return _iphdr->tos;

-}

-

-

-int OIPPacket::len() const

-{

-    return EXTRACT_16BITS( &_iphdr->tot_len );

-}

-

-

-int OIPPacket::id() const

-{

-    return EXTRACT_16BITS( &_iphdr->id );

-}

-

-

-int OIPPacket::offset() const

-{

-    return EXTRACT_16BITS( &_iphdr->frag_off );

-}

-

-

-int OIPPacket::ttl() const

-{

-    return _iphdr->ttl;

-}

-

-

-int OIPPacket::protocol() const

-{

-    return _iphdr->protocol;

-}

-

-

-int OIPPacket::checksum() const

-{

-    return EXTRACT_16BITS( &_iphdr->check );

-}

-

-/*======================================================================================

- * OARPPacket

- *======================================================================================*/

-

-

-OARPPacket::OARPPacket( const unsigned char* end, const struct myarphdr* data, QObject* parent )

-           :QObject( parent, "ARP" ), _arphdr( data )

-{

-    odebug << "OARPPacket::OARPPacket(): decoding ARP header..." << oendl;

-    odebug << "ARP type seems to be " << EXTRACT_16BITS( &_arphdr->ar_op ) << " = " << type() << oendl;

-    odebug << "Sender: MAC " << senderMacAddress().toString() << " = IP " << senderIPV4Address().toString() << oendl;

-    odebug << "Target: MAC " << targetMacAddress().toString() << " = IP " << targetIPV4Address().toString() << oendl;

-}

-

-

-OARPPacket::~OARPPacket()

-{

-}

-

-

-QString OARPPacket::type() const

-{

-    switch ( EXTRACT_16BITS( &_arphdr->ar_op ) )

-    {

-        case 1: return "REQUEST";

-        case 2: return "REPLY";

-        case 3: return "RREQUEST";

-        case 4: return "RREPLY";

-        case 8: return "InREQUEST";

-        case 9: return "InREPLY";

-        case 10: return "NAK";

-        default: qWarning( "OARPPacket::type(): invalid ARP type!" ); return "<unknown>";

-    }

-}

-

-

-QHostAddress OARPPacket::senderIPV4Address() const

-{

-    return EXTRACT_32BITS( &_arphdr->ar_sip );

-}

-

-

-QHostAddress OARPPacket::targetIPV4Address() const

-{

-    return EXTRACT_32BITS( &_arphdr->ar_tip );

-}

-

-

-OMacAddress OARPPacket::senderMacAddress() const

-{

-    return OMacAddress( _arphdr->ar_sha );

-}

-

-

-OMacAddress OARPPacket::targetMacAddress() const

-{

-    return OMacAddress( _arphdr->ar_tha );

-}

-

-

-/*======================================================================================

- * OUDPPacket

- *======================================================================================*/

-

-

-OUDPPacket::OUDPPacket( const unsigned char* end, const struct udphdr* data, QObject* parent )

-           :QObject( parent, "UDP" ), _udphdr( data )

-

-{

-    odebug << "OUDPPacket::OUDPPacket(): decoding UDP header..." << oendl;

-    odebug << "fromPort = " << fromPort() << oendl;

-    odebug << "  toPort = " << toPort() << oendl;

-

-    // TODO: Make this a case or a hash if we know more udp protocols

-

-    if ( fromPort() == UDP_PORT_BOOTPS || fromPort() == UDP_PORT_BOOTPC ||

-         toPort() == UDP_PORT_BOOTPS || toPort() == UDP_PORT_BOOTPC )

-    {

-        odebug << "seems to be part of a DHCP conversation => creating DHCP packet." << oendl;

-        new ODHCPPacket( end, (const struct dhcp_packet*) (data+1), this );

-    }

-}

-

-

-OUDPPacket::~OUDPPacket()

-{

-}

-

-

-int OUDPPacket::fromPort() const

-{

-    return EXTRACT_16BITS( &_udphdr->source );

-}

-

-

-int OUDPPacket::toPort() const

-{

-    return EXTRACT_16BITS( &_udphdr->dest );

-}

-

-

-int OUDPPacket::length() const

-{

-    return EXTRACT_16BITS( &_udphdr->len );

-}

-

-

-int OUDPPacket::checksum() const

-{

-    return EXTRACT_16BITS( &_udphdr->check );

-}

-

-

-/*======================================================================================

- * ODHCPPacket

- *======================================================================================*/

-

-

-ODHCPPacket::ODHCPPacket( const unsigned char* end, const struct dhcp_packet* data, QObject* parent )

-           :QObject( parent, "DHCP" ), _dhcphdr( data )

-

-{

-    odebug << "ODHCPPacket::ODHCPPacket(): decoding DHCP information..." << oendl;

-    odebug << "DHCP opcode seems to be " << _dhcphdr->op << ": " << ( isRequest() ? "REQUEST" : "REPLY" ) << oendl;

-    odebug << "clientAddress = " << clientAddress().toString() << oendl;

-    odebug << "  yourAddress = " << yourAddress().toString() << oendl;

-    odebug << "serverAddress = " << serverAddress().toString() << oendl;

-    odebug << " relayAddress = " << relayAddress().toString() << oendl;

-    odebug << "parsing DHCP options..." << oendl;

-

-    _type = 0;

-

-    const unsigned char* option = &_dhcphdr->options[4];

-    char tag = -1;

-    char len = -1;

-

-    while ( ( tag = *option++ ) != -1 /* end of option field */ )

-    {

-        len = *option++;

-        odebug << "recognized DHCP option #" << tag << ", length " << len << oendl;

-

-        if ( tag == DHO_DHCP_MESSAGE_TYPE )

-            _type = *option;

-

-        option += len;

-        if ( option >= end )

-        {

-            owarn << "DHCP parsing ERROR: sanity check says the packet is at its end!" << oendl;

-            break;

-        }

-    }

-

-    odebug << "DHCP type seems to be << " << type() << oendl;

-}

-

-

-ODHCPPacket::~ODHCPPacket()

-{

-}

-

-

-bool ODHCPPacket::isRequest() const

-{

-    return ( _dhcphdr->op == 01 );

-}

-

-

-bool ODHCPPacket::isReply() const

-{

-    return ( _dhcphdr->op == 02 );

-}

-

-

-QString ODHCPPacket::type() const

-{

-    switch ( _type )

-    {

-        case 1: return "DISCOVER";

-        case 2: return "OFFER";

-        case 3: return "REQUEST";

-        case 4: return "DECLINE";

-        case 5: return "ACK";

-        case 6: return "NAK";

-        case 7: return "RELEASE";

-        case 8: return "INFORM";

-        default: qWarning( "ODHCPPacket::type(): invalid DHCP type (%d) !", _dhcphdr->op ); return "<unknown>";

-    }

-}

-

-

-QHostAddress ODHCPPacket::clientAddress() const

-{

-    return EXTRACT_32BITS( &_dhcphdr->ciaddr );

-}

-

-

-QHostAddress ODHCPPacket::yourAddress() const

-{

-    return EXTRACT_32BITS( &_dhcphdr->yiaddr );

-}

-

-

-QHostAddress ODHCPPacket::serverAddress() const

-{

-    return EXTRACT_32BITS( &_dhcphdr->siaddr );

-}

-

-

-QHostAddress ODHCPPacket::relayAddress() const

-{

-    return EXTRACT_32BITS( &_dhcphdr->giaddr );

-}

-

-

-OMacAddress ODHCPPacket::clientMacAddress() const

-{

-    return OMacAddress( _dhcphdr->chaddr );

-}

-

-

-/*======================================================================================

- * OTCPPacket

- *======================================================================================*/

-

-

-OTCPPacket::OTCPPacket( const unsigned char* end, const struct tcphdr* data, QObject* parent )

-           :QObject( parent, "TCP" ), _tcphdr( data )

-

-{

-    odebug << "OTCPPacket::OTCPPacket(): decoding TCP header..." << oendl;

-}

-

-

-OTCPPacket::~OTCPPacket()

-{

-}

-

-

-int OTCPPacket::fromPort() const

-{

-    return EXTRACT_16BITS( &_tcphdr->source );

-}

-

-

-int OTCPPacket::toPort() const

-{

-    return EXTRACT_16BITS( &_tcphdr->dest );

-}

-

-

-int OTCPPacket::seq() const

-{

-    return EXTRACT_16BITS( &_tcphdr->seq );

-}

-

-

-int OTCPPacket::ack() const

-{

-    return EXTRACT_16BITS( &_tcphdr->ack_seq );

-}

-

-

-int OTCPPacket::window() const

-{

-    return EXTRACT_16BITS( &_tcphdr->window );

-}

-

-

-int OTCPPacket::checksum() const

-{

-    return EXTRACT_16BITS( &_tcphdr->check );

-}

-

-/*======================================================================================

- * OPrismHeaderPacket

- *======================================================================================*/

-

-

-OPrismHeaderPacket::OPrismHeaderPacket( const unsigned char* end, const struct prism_hdr* data, QObject* parent )

-                :QObject( parent, "Prism" ), _header( data )

-

-{

-    odebug << "OPrismHeaderPacket::OPrismHeaderPacket(): decoding PRISM header..." << oendl;

-

-    odebug << "Signal Strength = " << data->signal.data << oendl;

-

-    new OWaveLanPacket( end, (const struct ieee_802_11_header*) (data+1), this );

-}

-

-OPrismHeaderPacket::~OPrismHeaderPacket()

-{

-}

-

-

-unsigned int OPrismHeaderPacket::signalStrength() const

-{

-    return _header->signal.data;

-}

-

-/*======================================================================================

- * OWaveLanPacket

- *======================================================================================*/

-

-

-OWaveLanPacket::OWaveLanPacket( const unsigned char* end, const struct ieee_802_11_header* data, QObject* parent )

-                :QObject( parent, "802.11" ), _wlanhdr( data )

-

-{

-    odebug << "OWaveLanPacket::OWaveLanPacket(): decoding IEEE 802.11 header..." << oendl;

-    odebug << "type = " << type() << oendl;

-    odebug << "subType = " << subType() << oendl;

-    odebug << "duration = " << duration() << oendl;

-    odebug << "powermanagement = " << usesPowerManagement() << oendl;

-    odebug << "payload is encrypted = " << ( usesWep() ? "yes" : "no" ) << oendl;

-    odebug << "MAC1 = " << macAddress1().toString() << oendl;

-    odebug << "MAC2 = " << macAddress2().toString() << oendl;

-    odebug << "MAC3 = " << macAddress3().toString() << oendl;

-    odebug << "MAC4 = " << macAddress4().toString() << oendl;

-

-    switch ( type() )

-    {

-        case T_MGMT: new OWaveLanManagementPacket( end, (const struct ieee_802_11_mgmt_header*) data, this ); break;

-        case T_DATA: new OWaveLanDataPacket( end, (const struct ieee_802_11_data_header*) data, this ); break;

-        case T_CTRL: new OWaveLanControlPacket( end, (const struct ieee_802_11_control_header*) data, this ); break;

-        default: odebug << "OWaveLanPacket::OWaveLanPacket(): Warning: Unknown major type = " << type() << oendl;

-    }

-}

-

-OWaveLanPacket::~OWaveLanPacket()

-{

-}

-

-

-int OWaveLanPacket::duration() const

-{

-    return _wlanhdr->duration;

-}

-

-

-OMacAddress OWaveLanPacket::macAddress1() const

-{

-    return OMacAddress( _wlanhdr->mac1 );

-}

-

-

-OMacAddress OWaveLanPacket::macAddress2() const

-{

-    return OMacAddress( _wlanhdr->mac2 );

-}

-

-

-OMacAddress OWaveLanPacket::macAddress3() const

-{

-    return OMacAddress( _wlanhdr->mac3 );

-}

-

-

-OMacAddress OWaveLanPacket::macAddress4() const

-{

-    return OMacAddress( _wlanhdr->mac4 );

-}

-

-

-int OWaveLanPacket::subType() const

-{

-    return FC_SUBTYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-int OWaveLanPacket::type() const

-{

-    return FC_TYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-int OWaveLanPacket::version() const

-{

-    return FC_VERSION( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-bool OWaveLanPacket::fromDS() const

-{

-    return FC_FROM_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-bool OWaveLanPacket::toDS() const

-{

-    return FC_TO_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-bool OWaveLanPacket::usesPowerManagement() const

-{

-    return FC_POWER_MGMT( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-bool OWaveLanPacket::usesWep() const

-{

-    return FC_WEP( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );

-}

-

-

-/*======================================================================================

- * OWaveLanManagementPacket

- *======================================================================================*/

-

-OWaveLanManagementPacket::OWaveLanManagementPacket( const unsigned char* end, const struct ieee_802_11_mgmt_header* data, OWaveLanPacket* parent )

-                :QObject( parent, "802.11 Management" ), _header( data ),

-                _body( (const struct ieee_802_11_mgmt_body*) (data+1) )

-{

-    odebug << "OWaveLanManagementPacket::OWaveLanManagementPacket(): decoding frame..." << oendl;

-    odebug << "Detected subtype is " << managementType() << oendl;

-

-    // grab tagged values

-    const unsigned char* ptr = (const unsigned char*) (_body+1);

-    while (ptr < end)

-    {

-        switch ( *ptr )

-        {

-            case E_SSID: new OWaveLanManagementSSID( end, (struct ssid_t*) ptr, this ); break;

-            case E_FH: new OWaveLanManagementFH( end, (struct fh_t*) ptr, this ); break;

-            case E_DS: new OWaveLanManagementDS( end, (struct ds_t*) ptr, this ); break;

-            case E_RATES: new OWaveLanManagementRates( end, (struct rates_t*) ptr, this ); break;

-            case E_CF: new OWaveLanManagementCF( end, (struct cf_t*) ptr, this ); break;

-            case E_TIM: new OWaveLanManagementTim( end, (struct tim_t*) ptr, this ); break;

-            case E_IBSS: new OWaveLanManagementIBSS( end, (struct ibss_t*) ptr, this ); break;

-            case E_CHALLENGE: new OWaveLanManagementChallenge( end, (struct challenge_t*) ptr, this ); break;

-        }

-        ptr+= ( ( struct ssid_t* ) ptr )->length; // skip length of tagged value

-        ptr+= 2; // skip tag ID and length

-    }

-}

-

-

-OWaveLanManagementPacket::~OWaveLanManagementPacket()

-{

-}

-

-

-QString OWaveLanManagementPacket::managementType() const

-{

-    switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) )

-    {

-        case ST_ASSOC_REQUEST: return "AssociationRequest"; break;

-        case ST_ASSOC_RESPONSE: return "AssociationResponse"; break;

-        case ST_REASSOC_REQUEST: return "ReassociationRequest"; break;

-        case ST_REASSOC_RESPONSE: return "ReassociationResponse"; break;

-        case ST_PROBE_REQUEST: return "ProbeRequest"; break;

-        case ST_PROBE_RESPONSE: return "ProbeResponse"; break;

-        case ST_BEACON: return "Beacon"; break;

-        case ST_ATIM: return "Atim"; break;

-        case ST_DISASSOC: return "Disassociation"; break;

-        case ST_AUTH: return "Authentication"; break;

-        case ST_DEAUTH: return "Deathentication"; break;

-        default:

-            qWarning( "OWaveLanManagementPacket::managementType(): unhandled subtype %d", FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) );

-            return "Unknown";

-    }

-}

-

-

-int OWaveLanManagementPacket::beaconInterval() const

-{

-    return EXTRACT_LE_16BITS( &_body->beacon_interval );

-}

-

-

-int OWaveLanManagementPacket::capabilities() const

-{

-    return EXTRACT_LE_16BITS( &_body->capability_info );

-}

-

-

-bool OWaveLanManagementPacket::canESS() const

-{

-    return CAPABILITY_ESS( EXTRACT_LE_16BITS( &_body->capability_info ) );

-}

-

-

-bool OWaveLanManagementPacket::canIBSS() const

-{

-    return CAPABILITY_IBSS( EXTRACT_LE_16BITS( &_body->capability_info ) );

-}

-

-

-bool OWaveLanManagementPacket::canCFP() const

-{

-    return CAPABILITY_CFP( EXTRACT_LE_16BITS( &_body->capability_info ) );

-}

-

-

-bool OWaveLanManagementPacket::canCFP_REQ() const

-{

-    return CAPABILITY_CFP_REQ( EXTRACT_LE_16BITS( &_body->capability_info ) );

-}

-

-

-bool OWaveLanManagementPacket::canPrivacy() const

-{

-    return CAPABILITY_PRIVACY( EXTRACT_LE_16BITS( &_body->capability_info ) );

-}

-

-

-/*======================================================================================

- * OWaveLanManagementSSID

- *======================================================================================*/

-

-OWaveLanManagementSSID::OWaveLanManagementSSID( const unsigned char* end, const struct ssid_t* data, QObject* parent )

-                :QObject( parent, "802.11 SSID" ), _data( data )

-{

-    odebug << "OWaveLanManagementSSID()" << oendl;

-}

-

-

-OWaveLanManagementSSID::~OWaveLanManagementSSID()

-{

-}

-

-

-QString OWaveLanManagementSSID::ID() const

-{

-    int length = _data->length;

-    if ( length > 32 ) length = 32;

-    char essid[length+1];

-    memcpy( &essid, &_data->ssid, length );

-    essid[length] = 0x0;

-    return essid;

-}

-

-

-/*======================================================================================

- * OWaveLanManagementRates

- *======================================================================================*/

-

-OWaveLanManagementRates::OWaveLanManagementRates( const unsigned char* end, const struct rates_t* data, QObject* parent )

-                :QObject( parent, "802.11 Rates" ), _data( data )

-{

-    odebug << "OWaveLanManagementRates()" << oendl;

-}

-

-

-OWaveLanManagementRates::~OWaveLanManagementRates()

-{

-}

-

-/*======================================================================================

- * OWaveLanManagementCF

- *======================================================================================*/

-

-OWaveLanManagementCF::OWaveLanManagementCF( const unsigned char* end, const struct cf_t* data, QObject* parent )

-                :QObject( parent, "802.11 CF" ), _data( data )

-{

-    odebug << "OWaveLanManagementCF()" << oendl;

-}

-

-

-OWaveLanManagementCF::~OWaveLanManagementCF()

-{

-}

-

-/*======================================================================================

- * OWaveLanManagementFH

- *======================================================================================*/

-

-OWaveLanManagementFH::OWaveLanManagementFH( const unsigned char* end, const struct fh_t* data, QObject* parent )

-                :QObject( parent, "802.11 FH" ), _data( data )

-{

-    odebug << "OWaveLanManagementFH()" << oendl;

-}

-

-

-OWaveLanManagementFH::~OWaveLanManagementFH()

-{

-}

-

-/*======================================================================================

- * OWaveLanManagementDS

- *======================================================================================*/

-

-OWaveLanManagementDS::OWaveLanManagementDS( const unsigned char* end, const struct ds_t* data, QObject* parent )

-                :QObject( parent, "802.11 DS" ), _data( data )

-{

-    odebug << "OWaveLanManagementDS()" << oendl;

-}

-

-

-OWaveLanManagementDS::~OWaveLanManagementDS()

-{

-}

-

-

-int OWaveLanManagementDS::channel() const

-{

-    return _data->channel;

-}

-

-/*======================================================================================

- * OWaveLanManagementTim

- *======================================================================================*/

-

-OWaveLanManagementTim::OWaveLanManagementTim( const unsigned char* end, const struct tim_t* data, QObject* parent )

-                :QObject( parent, "802.11 Tim" ), _data( data )

-{

-    odebug << "OWaveLanManagementTim()" << oendl;

-}

-

-

-OWaveLanManagementTim::~OWaveLanManagementTim()

-{

-}

-

-/*======================================================================================

- * OWaveLanManagementIBSS

- *======================================================================================*/

-

-OWaveLanManagementIBSS::OWaveLanManagementIBSS( const unsigned char* end, const struct ibss_t* data, QObject* parent )

-                :QObject( parent, "802.11 IBSS" ), _data( data )

-{

-    odebug << "OWaveLanManagementIBSS()" << oendl;

-}

-

-

-OWaveLanManagementIBSS::~OWaveLanManagementIBSS()

-{

-}

-

-/*======================================================================================

- * OWaveLanManagementChallenge

- *======================================================================================*/

-

-OWaveLanManagementChallenge::OWaveLanManagementChallenge( const unsigned char* end, const struct challenge_t* data, QObject* parent )

-                :QObject( parent, "802.11 Challenge" ), _data( data )

-{

-    odebug << "OWaveLanManagementChallenge()" << oendl;

-}

-

-

-OWaveLanManagementChallenge::~OWaveLanManagementChallenge()

-{

-}

-

-/*======================================================================================

- * OWaveLanDataPacket

- *======================================================================================*/

-

-OWaveLanDataPacket::OWaveLanDataPacket( const unsigned char* end, const struct ieee_802_11_data_header* data, OWaveLanPacket* parent )

-                :QObject( parent, "802.11 Data" ), _header( data )

-{

-    odebug << "OWaveLanDataPacket::OWaveLanDataPacket(): decoding frame..." << oendl;

-

-    const unsigned char* payload = (const unsigned char*) data + sizeof( struct ieee_802_11_data_header );

-

-    #warning The next line works for most cases, but can not be correct generally!

-    if (!( ( (OWaveLanPacket*) this->parent())->duration() )) payload -= 6; // compensation for missing last address

-

-    new OLLCPacket( end, (const struct ieee_802_11_802_2_header*) payload, this );

-}

-

-

-OWaveLanDataPacket::~OWaveLanDataPacket()

-{

-}

-

-

-/*======================================================================================

- * OLLCPacket

- *======================================================================================*/

-

-OLLCPacket::OLLCPacket( const unsigned char* end, const struct ieee_802_11_802_2_header* data, QObject* parent )

-                :QObject( parent, "802.11 LLC" ), _header( data )

-{

-    odebug << "OLLCPacket::OLLCPacket(): decoding frame..." << oendl;

-

-    if ( !(_header->oui[0] || _header->oui[1] || _header->oui[2]) )

-    {

-        owarn << "OLLCPacket::OLLCPacket(): contains an encapsulated Ethernet frame (type = " << EXTRACT_16BITS( &_header->type ) << ")" << oendl;

-

-        switch ( EXTRACT_16BITS( &_header->type ) ) // defined in linux/if_ether.h

-        {

-            case ETH_P_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break;

-            case ETH_P_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break;

-            default: owarn << "OLLCPacket::OLLCPacket(): Unknown Encapsulation type = " << EXTRACT_16BITS( &_header->type ) << oendl;

-        }

-    }

-}

-

-

-OLLCPacket::~OLLCPacket()

-{

-}

-

-

-/*======================================================================================

- * OWaveLanControlPacket

- *======================================================================================*/

-

-OWaveLanControlPacket::OWaveLanControlPacket( const unsigned char* end, const struct ieee_802_11_control_header* data, OWaveLanPacket* parent )

-                :QObject( parent, "802.11 Control" ), _header( data )

-{

-    odebug << "OWaveLanControlPacket::OWaveLanDataControl(): decoding frame..." << oendl;

-    //TODO: Implement this

-}

-

-

-OWaveLanControlPacket::~OWaveLanControlPacket()

-{

-}

-

-

-/*======================================================================================

- * OPacketCapturer

- *======================================================================================*/

-

-OPacketCapturer::OPacketCapturer( QObject* parent, const char* name )

-                 :QObject( parent, name ), _name( QString::null ), _open( false ),

-                 _pch( 0 ), _pcd( 0 ), _sn( 0 )

-{

-}

-

-

-OPacketCapturer::~OPacketCapturer()

-{

-    if ( _open )

-    {

-        odebug << "OPacketCapturer::~OPacketCapturer(): pcap still open, autoclosing." << oendl;

-        close();

-    }

-}

-

-

-void OPacketCapturer::setBlocking( bool b )

-{

-    if ( pcap_setnonblock( _pch, 1-b, _errbuf ) != -1 )

-    {

-        odebug << "OPacketCapturer::setBlocking(): blocking mode changed successfully." << oendl;

-    }

-    else

-    {

-        odebug << "OPacketCapturer::setBlocking(): can't change blocking mode: " << _errbuf << oendl;

-    }

-}

-

-

-bool OPacketCapturer::blocking() const

-{

-    int b = pcap_getnonblock( _pch, _errbuf );

-    if ( b == -1 )

-    {

-        odebug << "OPacketCapturer::blocking(): can't get blocking mode: " << _errbuf << oendl;

-        return -1;

-    }

-    return !b;

-}

-

-

-void OPacketCapturer::closeDumpFile()

-{

-    if ( _pcd )

-    {

-        pcap_dump_close( _pcd );

-        _pcd = 0;

-    }

-    pcap_close( _pch );

-}

-

-

-void OPacketCapturer::close()

-{

-    if ( _open )

-    {

-        if ( _sn )

-        {

-            _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );

-            delete _sn;

-        }

-        closeDumpFile();

-    _open = false;

-    }

-

-    odebug << "OPacketCapturer::close() --- dumping capturing statistics..." << oendl;

-    odebug << "--------------------------------------------------" << oendl;

-    for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it )

-        odebug << it.key() << " = " << it.data() << oendl;

-    odebug << "--------------------------------------------------" << oendl;

-

-}

-

-

-int OPacketCapturer::dataLink() const

-{

-    return pcap_datalink( _pch );

-}

-

-

-void OPacketCapturer::dump( OPacket* p )

-{

-    if ( !_pcd )

-    {

-        qWarning( "OPacketCapturer::dump() - cannot dump without open capture file!" );

-        return;

-    }

-    pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data );

-}

-

-

-int OPacketCapturer::fileno() const

-{

-    if ( _open )

-    {

-        return pcap_fileno( _pch );

-    }

-    else

-    {

-        return -1;

-    }

-}

-

-

-OPacket* OPacketCapturer::next( int time )

-{

-    fd_set fds;

-    struct timeval tv;

-    FD_ZERO( &fds );

-    FD_SET( pcap_fileno( _pch ), &fds );

-    tv.tv_sec = time / 1000;

-    tv.tv_usec = time % 1000;

-    int retval = select( pcap_fileno( _pch )+1, &fds, NULL, NULL, &tv);

-    if ( retval > 0 ) // clear to read!

-        return next();

-    else

-        return 0;

-}

-

-

-OPacket* OPacketCapturer::next()

-{

-    packetheaderstruct header;

-    odebug << "==> OPacketCapturer::next()" << oendl;

-    const unsigned char* pdata = pcap_next( _pch, &header );

-    odebug << "<== OPacketCapturer::next()" << oendl;

-

-    if ( pdata && header.len )

-    {

-        OPacket* p = new OPacket( dataLink(), header, pdata, 0 );

-        // packets shouldn't be inserted in the QObject child-parent hierarchy,

-        // because due to memory constraints they will be deleted as soon

-        // as possible - that is right after they have been processed

-        // by emit() [ see below ]

-        //TODO: make gathering statistics optional, because it takes time

-        p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) );

-        #ifndef NODEBUG

-        p->dumpStructure( const_cast<QObjectList*>( p->children() ) );

-        #endif

-        return p;

-    }

-    else

-    {

-        qWarning( "OPacketCapturer::next() - no packet received!" );

-        return 0;

-    }

-}

-

-

-bool OPacketCapturer::open( const QString& name )

-{

-    if ( _open )

-    {

-        if ( name == _name )    // ignore opening an already openend device

-        {

-            return true;

-        }

-        else                    // close the last opened device

-        {

-            close();

-        }

-    }

-

-    _name = name;

-

-    // open libpcap

-    pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] );

-

-    if ( !handle )

-    {

-        owarn << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl;

-        return false;

-    }

-

-    odebug << "OPacketCapturer::open(): libpcap [" << name << "] opened successfully." << oendl;

-    _pch = handle;

-    _open = true;

-    _stats.clear();

-

-    // in case we have an application object, create a socket notifier

-    if ( qApp ) //TODO: I don't like this here...

-    {

-        _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );

-        connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );

-    }

-

-    return true;

-}

-

-

-bool OPacketCapturer::openDumpFile( const QString& filename )

-{

-    pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) );

-    if ( !dump )

-    {

-        owarn << "OPacketCapturer::open(): can't open dump with '" << filename << "': " << _errbuf << oendl;

-        return false;

-    }

-    odebug << "OPacketCapturer::open(): dump [" << filename << "] opened successfully." << oendl;

-    _pcd = dump;

-

-    return true;

-}

-

-

-bool OPacketCapturer::open( const QFile& file )

-{

-    QString name = file.name();

-

-    if ( _open )

-    {

-        close();

-        if ( name == _name )    // ignore opening an already openend device

-        {

-            return true;

-        }

-        else                    // close the last opened device

-        {

-            close();

-        }

-    }

-

-    _name = name;

-

-    pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] );

-

-    if ( handle )

-    {

-        odebug << "OPacketCapturer::open(): libpcap opened successfully." << oendl;

-        _pch = handle;

-        _open = true;

-

-        // in case we have an application object, create a socket notifier

-        if ( qApp )

-        {

-            _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );

-            connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );

-        }

-

-        return true;

-    }

-    else

-    {

-        odebug << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl;

-        return false;

-    }

-

-}

-

-

-bool OPacketCapturer::isOpen() const

-{

-    return _open;

-}

-

-

-void OPacketCapturer::readyToReceive()

-{

-    odebug << "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" << oendl;

-    OPacket* p = next();

-    emit receivedPacket( p );

-    // emit is synchronous - packet has been dealt with, now it's safe to delete

-    delete p;

-}

-

-

-const QMap<QString,int>& OPacketCapturer::statistics() const

-{

-    return _stats;

-}

-

-

-int OPacketCapturer::snapShot() const

-{

-    return pcap_snapshot( _pch );

-}

-

-

-bool OPacketCapturer::swapped() const

-{

-    return pcap_is_swapped( _pch );

-}

-

-

-QString OPacketCapturer::version() const

-{

-    return QString().sprintf( "%s.%s", pcap_major_version( _pch ), pcap_minor_version( _pch ) );

-}

-

-

+/*
+                             This file is part of the Opie Project
+                             Copyright (C) 2003 by Michael 'Mickey' Lauer <mickey@Vanille.de>
+              =.
+            .=l.
+           .>+-=
+ _;:,     .>    :=|.         This program is free software; you can
+.> <`_,   >  .   <=          redistribute it and/or  modify it under
+:`=1 )Y*s>-.--   :           the terms of the GNU Library General Public
+.="- .-=="i,     .._         License as published by the Free Software
+ - .   .-<_>     .<>         Foundation; either version 2 of the License,
+     ._= =}       :          or (at your option) any later version.
+    .%`+i>       _;_.
+    .i_,=:_.      -<s.       This program is distributed in the hope that
+     +  .  -:.       =       it will be useful,  but WITHOUT ANY WARRANTY;
+    : ..    .:,     . . .    without even the implied warranty of
+    =_        +     =;=|`    MERCHANTABILITY or FITNESS FOR A
+  _.=:.       :    :=>`:     PARTICULAR PURPOSE. See the GNU
+..}^=.=       =       ;      Library General Public License for more
+++=   -.     .`     .:       details.
+ :     =  ...= . :.=-
+ -.   .:....=;==+<;          You should have received a copy of the GNU
+  -_. . .   )=.  =           Library General Public License along with
+    --        :-=`           this library; see the file COPYING.LIB.
+                             If not, write to the Free Software Foundation,
+                             Inc., 59 Temple Place - Suite 330,
+                             Boston, MA 02111-1307, USA.
+
+*/
+
+/* OPIE */
+#include <opie2/opcap.h>
+#include <opie2/odebug.h>
+
+/* QT */
+#include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects)
+#include <qsocketnotifier.h>
+#include <qobjectlist.h>
+
+/* SYSTEM */
+#include <sys/time.h>
+#include <sys/types.h>
+#include <unistd.h>
+
+/* LOCAL */
+#include "udp_ports.h"
+
+/*======================================================================================
+ * OPacket
+ *======================================================================================*/
+
+OPacket::OPacket( int datalink, packetheaderstruct header, const unsigned char* data, QObject* parent )
+        :QObject( parent, "Generic" ), _hdr( header ), _data( data )
+{
+    //qDebug( "OPacket::OPacket(): (Len %d, CapLen %d)" /*, ctime((const time_t*) header.ts.tv_sec)*/, header.len, header.caplen );
+
+    _end = (unsigned char*) data + header.len;
+    //qDebug( "OPacket::data @ %0x, end @ %0x", data, _end );
+
+    switch ( datalink )
+    {
+        case DLT_EN10MB:
+            odebug << "OPacket::OPacket(): Received Packet. Datalink = ETHERNET" << oendl;
+            new OEthernetPacket( _end, (const struct ether_header*) data, this );
+            break;
+
+        case DLT_IEEE802_11:
+            odebug << "OPacket::OPacket(): Received Packet. Datalink = IEEE802.11" << oendl;
+            new OWaveLanPacket( _end, (const struct ieee_802_11_header*) data, this );
+            break;
+
+        case DLT_PRISM_HEADER:
+            odebug << "OPacket::OPacket(): Received Packet. Datalink = PRISM_HEADER" << oendl;
+            new OPrismHeaderPacket( _end, (const struct prism_hdr*) (unsigned char*) data, this );
+            break;
+
+        default:
+            owarn << "OPacket::OPacket(): Received Packet over unsupported datalink, type " << datalink << "!" << oendl;
+    }
+}
+
+
+OPacket::~OPacket()
+{
+}
+
+
+timevalstruct OPacket::timeval() const
+{
+    return _hdr.ts;
+}
+
+
+int OPacket::caplen() const
+{
+    return _hdr.caplen;
+}
+
+
+void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l )
+{
+    if (!l) return;
+    QObject* o = l->first();
+    while ( o )
+    {
+        stats[o->name()]++;
+        updateStats( stats, const_cast<QObjectList*>( o->children() ) );
+        o = l->next();
+    }
+}
+
+
+void OPacket::dumpStructure( QObjectList* l )
+{
+    QString packetString( "[ |" + _dumpStructure( l ) + " ]" );
+    odebug << "OPacket::dumpStructure: " << packetString << oendl;
+}
+
+
+QString OPacket::_dumpStructure( QObjectList* l )
+{
+    if (!l) return QString::null;
+    QObject* o = l->first();
+    QString str(" ");
+
+    while ( o )
+    {
+        str.append( o->name() );
+        str.append( " |" );
+        str += _dumpStructure( const_cast<QObjectList*>( o->children() ) );
+        o = l->next();
+    }
+    return str;
+}
+
+QString OPacket::dump( int bpl ) const
+{
+    static int index = 0;
+    index++;
+    int len = _hdr.caplen;
+    QString str;
+    str.sprintf( "\n<----- Packet #%04d Len = 0x%X (%d) ----->\n\n", index, len, len );
+    str.append( "0000: " );
+    QString tmp;
+    QString bytes;
+    QString chars;
+
+    for ( int i = 0; i < len; ++i )
+    {
+        tmp.sprintf( "%02X ", _data[i] ); bytes.append( tmp );
+        if ( (_data[i] > 31) && (_data[i]<128) ) chars.append( _data[i] );
+        else chars.append( '.' );
+
+        if ( !((i+1) % bpl) )
+        {
+            str.append( bytes );
+            str.append( ' ' );
+            str.append( chars );
+            str.append( '\n' );
+            tmp.sprintf( "%04X: ", i+1 ); str.append( tmp );
+            bytes = "";
+            chars = "";
+        }
+
+    }
+    if ( (len % bpl) )
+    {
+        str.append( bytes.leftJustify( 1 + 3*bpl ) );
+        str.append( chars );
+    }
+    str.append( '\n' );
+    return str;
+}
+
+
+int OPacket::len() const
+{
+    return _hdr.len;
+}
+
+
+/*======================================================================================
+ * OEthernetPacket
+ *======================================================================================*/
+
+OEthernetPacket::OEthernetPacket( const unsigned char* end, const struct ether_header* data, QObject* parent )
+                :QObject( parent, "Ethernet" ), _ether( data )
+{
+
+    odebug << "Source = " << sourceAddress().toString();
+    odebug << "Destination = " << destinationAddress().toString();
+
+    if ( sourceAddress() == OMacAddress::broadcast )
+        odebug << "Source is broadcast address" << oendl;
+    if ( destinationAddress() == OMacAddress::broadcast )
+        odebug << "Destination is broadcast address" << oendl;
+
+    switch ( type() )
+    {
+        case ETHERTYPE_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break;
+        case ETHERTYPE_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break;
+        case ETHERTYPE_REVARP: { odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = RARP" << oendl; break; }
+        default: odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = UNKNOWN" << oendl;
+    }
+
+}
+
+
+OEthernetPacket::~OEthernetPacket()
+{
+}
+
+
+OMacAddress OEthernetPacket::sourceAddress() const
+{
+    return OMacAddress( _ether->ether_shost );
+}
+
+
+OMacAddress OEthernetPacket::destinationAddress() const
+{
+    return OMacAddress( _ether->ether_dhost );
+}
+
+int OEthernetPacket::type() const
+{
+    return ntohs( _ether->ether_type );
+}
+
+
+/*======================================================================================
+ * OIPPacket
+ *======================================================================================*/
+
+
+OIPPacket::OIPPacket( const unsigned char* end, const struct iphdr* data, QObject* parent )
+          :QObject( parent, "IP" ), _iphdr( data )
+{
+    odebug << "OIPPacket::OIPPacket(): decoding IP header..." << oendl;
+
+    odebug << "FromAddress = " << fromIPAddress().toString() << oendl;
+    odebug << "  toAddress = " << toIPAddress().toString() << oendl;
+
+    switch ( protocol() )
+    {
+        case IPPROTO_UDP: new OUDPPacket( end, (const struct udphdr*) (data+1), this ); break;
+        case IPPROTO_TCP: new OTCPPacket( end, (const struct tcphdr*) (data+1), this ); break;
+        default: odebug << "OIPPacket::OIPPacket(): unknown IP protocol, type = " << protocol() << oendl;
+    }
+
+}
+
+OIPPacket::~OIPPacket()
+{
+}
+
+
+QHostAddress OIPPacket::fromIPAddress() const
+{
+    return EXTRACT_32BITS( &_iphdr->saddr );
+}
+
+
+QHostAddress OIPPacket::toIPAddress() const
+{
+    return EXTRACT_32BITS( &_iphdr->saddr );
+}
+
+
+int OIPPacket::tos() const
+{
+    return _iphdr->tos;
+}
+
+
+int OIPPacket::len() const
+{
+    return EXTRACT_16BITS( &_iphdr->tot_len );
+}
+
+
+int OIPPacket::id() const
+{
+    return EXTRACT_16BITS( &_iphdr->id );
+}
+
+
+int OIPPacket::offset() const
+{
+    return EXTRACT_16BITS( &_iphdr->frag_off );
+}
+
+
+int OIPPacket::ttl() const
+{
+    return _iphdr->ttl;
+}
+
+
+int OIPPacket::protocol() const
+{
+    return _iphdr->protocol;
+}
+
+
+int OIPPacket::checksum() const
+{
+    return EXTRACT_16BITS( &_iphdr->check );
+}
+
+/*======================================================================================
+ * OARPPacket
+ *======================================================================================*/
+
+
+OARPPacket::OARPPacket( const unsigned char* end, const struct myarphdr* data, QObject* parent )
+           :QObject( parent, "ARP" ), _arphdr( data )
+{
+    odebug << "OARPPacket::OARPPacket(): decoding ARP header..." << oendl;
+    odebug << "ARP type seems to be " << EXTRACT_16BITS( &_arphdr->ar_op ) << " = " << type() << oendl;
+    odebug << "Sender: MAC " << senderMacAddress().toString() << " = IP " << senderIPV4Address().toString() << oendl;
+    odebug << "Target: MAC " << targetMacAddress().toString() << " = IP " << targetIPV4Address().toString() << oendl;
+}
+
+
+OARPPacket::~OARPPacket()
+{
+}
+
+
+QString OARPPacket::type() const
+{
+    switch ( EXTRACT_16BITS( &_arphdr->ar_op ) )
+    {
+        case 1: return "REQUEST";
+        case 2: return "REPLY";
+        case 3: return "RREQUEST";
+        case 4: return "RREPLY";
+        case 8: return "InREQUEST";
+        case 9: return "InREPLY";
+        case 10: return "NAK";
+        default: owarn << "OARPPacket::type(): invalid ARP type!" << oendl; return "<unknown>";
+    }
+}
+
+
+QHostAddress OARPPacket::senderIPV4Address() const
+{
+    return EXTRACT_32BITS( &_arphdr->ar_sip );
+}
+
+
+QHostAddress OARPPacket::targetIPV4Address() const
+{
+    return EXTRACT_32BITS( &_arphdr->ar_tip );
+}
+
+
+OMacAddress OARPPacket::senderMacAddress() const
+{
+    return OMacAddress( _arphdr->ar_sha );
+}
+
+
+OMacAddress OARPPacket::targetMacAddress() const
+{
+    return OMacAddress( _arphdr->ar_tha );
+}
+
+
+/*======================================================================================
+ * OUDPPacket
+ *======================================================================================*/
+
+
+OUDPPacket::OUDPPacket( const unsigned char* end, const struct udphdr* data, QObject* parent )
+           :QObject( parent, "UDP" ), _udphdr( data )
+
+{
+    odebug << "OUDPPacket::OUDPPacket(): decoding UDP header..." << oendl;
+    odebug << "fromPort = " << fromPort() << oendl;
+    odebug << "  toPort = " << toPort() << oendl;
+
+    // TODO: Make this a case or a hash if we know more udp protocols
+
+    if ( fromPort() == UDP_PORT_BOOTPS || fromPort() == UDP_PORT_BOOTPC ||
+         toPort() == UDP_PORT_BOOTPS || toPort() == UDP_PORT_BOOTPC )
+    {
+        odebug << "seems to be part of a DHCP conversation => creating DHCP packet." << oendl;
+        new ODHCPPacket( end, (const struct dhcp_packet*) (data+1), this );
+    }
+}
+
+
+OUDPPacket::~OUDPPacket()
+{
+}
+
+
+int OUDPPacket::fromPort() const
+{
+    return EXTRACT_16BITS( &_udphdr->source );
+}
+
+
+int OUDPPacket::toPort() const
+{
+    return EXTRACT_16BITS( &_udphdr->dest );
+}
+
+
+int OUDPPacket::length() const
+{
+    return EXTRACT_16BITS( &_udphdr->len );
+}
+
+
+int OUDPPacket::checksum() const
+{
+    return EXTRACT_16BITS( &_udphdr->check );
+}
+
+
+/*======================================================================================
+ * ODHCPPacket
+ *======================================================================================*/
+
+
+ODHCPPacket::ODHCPPacket( const unsigned char* end, const struct dhcp_packet* data, QObject* parent )
+           :QObject( parent, "DHCP" ), _dhcphdr( data )
+
+{
+    odebug << "ODHCPPacket::ODHCPPacket(): decoding DHCP information..." << oendl;
+    odebug << "DHCP opcode seems to be " << _dhcphdr->op << ": " << ( isRequest() ? "REQUEST" : "REPLY" ) << oendl;
+    odebug << "clientAddress = " << clientAddress().toString() << oendl;
+    odebug << "  yourAddress = " << yourAddress().toString() << oendl;
+    odebug << "serverAddress = " << serverAddress().toString() << oendl;
+    odebug << " relayAddress = " << relayAddress().toString() << oendl;
+    odebug << "parsing DHCP options..." << oendl;
+
+    _type = 0;
+
+    const unsigned char* option = &_dhcphdr->options[4];
+    char tag = -1;
+    char len = -1;
+
+    while ( ( tag = *option++ ) != -1 /* end of option field */ )
+    {
+        len = *option++;
+        odebug << "recognized DHCP option #" << tag << ", length " << len << oendl;
+
+        if ( tag == DHO_DHCP_MESSAGE_TYPE )
+            _type = *option;
+
+        option += len;
+        if ( option >= end )
+        {
+            owarn << "DHCP parsing ERROR: sanity check says the packet is at its end!" << oendl;
+            break;
+        }
+    }
+
+    odebug << "DHCP type seems to be << " << type() << oendl;
+}
+
+
+ODHCPPacket::~ODHCPPacket()
+{
+}
+
+
+bool ODHCPPacket::isRequest() const
+{
+    return ( _dhcphdr->op == 01 );
+}
+
+
+bool ODHCPPacket::isReply() const
+{
+    return ( _dhcphdr->op == 02 );
+}
+
+
+QString ODHCPPacket::type() const
+{
+    switch ( _type )
+    {
+        case 1: return "DISCOVER";
+        case 2: return "OFFER";
+        case 3: return "REQUEST";
+        case 4: return "DECLINE";
+        case 5: return "ACK";
+        case 6: return "NAK";
+        case 7: return "RELEASE";
+        case 8: return "INFORM";
+        default: owarn << "ODHCPPacket::type(): invalid DHCP type " << _dhcphdr->op << oendl; return "<unknown>";
+    }
+}
+
+
+QHostAddress ODHCPPacket::clientAddress() const
+{
+    return EXTRACT_32BITS( &_dhcphdr->ciaddr );
+}
+
+
+QHostAddress ODHCPPacket::yourAddress() const
+{
+    return EXTRACT_32BITS( &_dhcphdr->yiaddr );
+}
+
+
+QHostAddress ODHCPPacket::serverAddress() const
+{
+    return EXTRACT_32BITS( &_dhcphdr->siaddr );
+}
+
+
+QHostAddress ODHCPPacket::relayAddress() const
+{
+    return EXTRACT_32BITS( &_dhcphdr->giaddr );
+}
+
+
+OMacAddress ODHCPPacket::clientMacAddress() const
+{
+    return OMacAddress( _dhcphdr->chaddr );
+}
+
+
+/*======================================================================================
+ * OTCPPacket
+ *======================================================================================*/
+
+
+OTCPPacket::OTCPPacket( const unsigned char* end, const struct tcphdr* data, QObject* parent )
+           :QObject( parent, "TCP" ), _tcphdr( data )
+
+{
+    odebug << "OTCPPacket::OTCPPacket(): decoding TCP header..." << oendl;
+}
+
+
+OTCPPacket::~OTCPPacket()
+{
+}
+
+
+int OTCPPacket::fromPort() const
+{
+    return EXTRACT_16BITS( &_tcphdr->source );
+}
+
+
+int OTCPPacket::toPort() const
+{
+    return EXTRACT_16BITS( &_tcphdr->dest );
+}
+
+
+int OTCPPacket::seq() const
+{
+    return EXTRACT_16BITS( &_tcphdr->seq );
+}
+
+
+int OTCPPacket::ack() const
+{
+    return EXTRACT_16BITS( &_tcphdr->ack_seq );
+}
+
+
+int OTCPPacket::window() const
+{
+    return EXTRACT_16BITS( &_tcphdr->window );
+}
+
+
+int OTCPPacket::checksum() const
+{
+    return EXTRACT_16BITS( &_tcphdr->check );
+}
+
+/*======================================================================================
+ * OPrismHeaderPacket
+ *======================================================================================*/
+
+
+OPrismHeaderPacket::OPrismHeaderPacket( const unsigned char* end, const struct prism_hdr* data, QObject* parent )
+                :QObject( parent, "Prism" ), _header( data )
+
+{
+    odebug << "OPrismHeaderPacket::OPrismHeaderPacket(): decoding PRISM header..." << oendl;
+
+    odebug << "Signal Strength = " << data->signal.data << oendl;
+
+    new OWaveLanPacket( end, (const struct ieee_802_11_header*) (data+1), this );
+}
+
+OPrismHeaderPacket::~OPrismHeaderPacket()
+{
+}
+
+
+unsigned int OPrismHeaderPacket::signalStrength() const
+{
+    return _header->signal.data;
+}
+
+/*======================================================================================
+ * OWaveLanPacket
+ *======================================================================================*/
+
+
+OWaveLanPacket::OWaveLanPacket( const unsigned char* end, const struct ieee_802_11_header* data, QObject* parent )
+                :QObject( parent, "802.11" ), _wlanhdr( data )
+
+{
+    odebug << "OWaveLanPacket::OWaveLanPacket(): decoding IEEE 802.11 header..." << oendl;
+    odebug << "type = " << type() << oendl;
+    odebug << "subType = " << subType() << oendl;
+    odebug << "duration = " << duration() << oendl;
+    odebug << "powermanagement = " << usesPowerManagement() << oendl;
+    odebug << "payload is encrypted = " << ( usesWep() ? "yes" : "no" ) << oendl;
+    odebug << "MAC1 = " << macAddress1().toString() << oendl;
+    odebug << "MAC2 = " << macAddress2().toString() << oendl;
+    odebug << "MAC3 = " << macAddress3().toString() << oendl;
+    odebug << "MAC4 = " << macAddress4().toString() << oendl;
+
+    switch ( type() )
+    {
+        case T_MGMT: new OWaveLanManagementPacket( end, (const struct ieee_802_11_mgmt_header*) data, this ); break;
+        case T_DATA: new OWaveLanDataPacket( end, (const struct ieee_802_11_data_header*) data, this ); break;
+        case T_CTRL: new OWaveLanControlPacket( end, (const struct ieee_802_11_control_header*) data, this ); break;
+        default: odebug << "OWaveLanPacket::OWaveLanPacket(): Warning: Unknown major type = " << type() << oendl;
+    }
+}
+
+OWaveLanPacket::~OWaveLanPacket()
+{
+}
+
+
+int OWaveLanPacket::duration() const
+{
+    return _wlanhdr->duration;
+}
+
+
+OMacAddress OWaveLanPacket::macAddress1() const
+{
+    return OMacAddress( _wlanhdr->mac1 );
+}
+
+
+OMacAddress OWaveLanPacket::macAddress2() const
+{
+    return OMacAddress( _wlanhdr->mac2 );
+}
+
+
+OMacAddress OWaveLanPacket::macAddress3() const
+{
+    return OMacAddress( _wlanhdr->mac3 );
+}
+
+
+OMacAddress OWaveLanPacket::macAddress4() const
+{
+    return OMacAddress( _wlanhdr->mac4 );
+}
+
+
+int OWaveLanPacket::subType() const
+{
+    return FC_SUBTYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+int OWaveLanPacket::type() const
+{
+    return FC_TYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+int OWaveLanPacket::version() const
+{
+    return FC_VERSION( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+bool OWaveLanPacket::fromDS() const
+{
+    return FC_FROM_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+bool OWaveLanPacket::toDS() const
+{
+    return FC_TO_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+bool OWaveLanPacket::usesPowerManagement() const
+{
+    return FC_POWER_MGMT( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+bool OWaveLanPacket::usesWep() const
+{
+    return FC_WEP( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
+}
+
+
+/*======================================================================================
+ * OWaveLanManagementPacket
+ *======================================================================================*/
+
+OWaveLanManagementPacket::OWaveLanManagementPacket( const unsigned char* end, const struct ieee_802_11_mgmt_header* data, OWaveLanPacket* parent )
+                :QObject( parent, "802.11 Management" ), _header( data ),
+                _body( (const struct ieee_802_11_mgmt_body*) (data+1) )
+{
+    odebug << "OWaveLanManagementPacket::OWaveLanManagementPacket(): decoding frame..." << oendl;
+    odebug << "Detected subtype is " << managementType() << oendl;
+
+    // grab tagged values
+    const unsigned char* ptr = (const unsigned char*) (_body+1);
+    while (ptr < end)
+    {
+        switch ( *ptr )
+        {
+            case E_SSID: new OWaveLanManagementSSID( end, (struct ssid_t*) ptr, this ); break;
+            case E_FH: new OWaveLanManagementFH( end, (struct fh_t*) ptr, this ); break;
+            case E_DS: new OWaveLanManagementDS( end, (struct ds_t*) ptr, this ); break;
+            case E_RATES: new OWaveLanManagementRates( end, (struct rates_t*) ptr, this ); break;
+            case E_CF: new OWaveLanManagementCF( end, (struct cf_t*) ptr, this ); break;
+            case E_TIM: new OWaveLanManagementTim( end, (struct tim_t*) ptr, this ); break;
+            case E_IBSS: new OWaveLanManagementIBSS( end, (struct ibss_t*) ptr, this ); break;
+            case E_CHALLENGE: new OWaveLanManagementChallenge( end, (struct challenge_t*) ptr, this ); break;
+        }
+        ptr+= ( ( struct ssid_t* ) ptr )->length; // skip length of tagged value
+        ptr+= 2; // skip tag ID and length
+    }
+}
+
+
+OWaveLanManagementPacket::~OWaveLanManagementPacket()
+{
+}
+
+
+QString OWaveLanManagementPacket::managementType() const
+{
+    switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) )
+    {
+        case ST_ASSOC_REQUEST: return "AssociationRequest"; break;
+        case ST_ASSOC_RESPONSE: return "AssociationResponse"; break;
+        case ST_REASSOC_REQUEST: return "ReassociationRequest"; break;
+        case ST_REASSOC_RESPONSE: return "ReassociationResponse"; break;
+        case ST_PROBE_REQUEST: return "ProbeRequest"; break;
+        case ST_PROBE_RESPONSE: return "ProbeResponse"; break;
+        case ST_BEACON: return "Beacon"; break;
+        case ST_ATIM: return "Atim"; break;
+        case ST_DISASSOC: return "Disassociation"; break;
+        case ST_AUTH: return "Authentication"; break;
+        case ST_DEAUTH: return "Deathentication"; break;
+        default: owarn << "OWaveLanManagementPacket::managementType(): unhandled subtype " << FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) << oendl; return "Unknown";
+    }
+}
+
+
+int OWaveLanManagementPacket::beaconInterval() const
+{
+    return EXTRACT_LE_16BITS( &_body->beacon_interval );
+}
+
+
+int OWaveLanManagementPacket::capabilities() const
+{
+    return EXTRACT_LE_16BITS( &_body->capability_info );
+}
+
+
+bool OWaveLanManagementPacket::canESS() const
+{
+    return CAPABILITY_ESS( EXTRACT_LE_16BITS( &_body->capability_info ) );
+}
+
+
+bool OWaveLanManagementPacket::canIBSS() const
+{
+    return CAPABILITY_IBSS( EXTRACT_LE_16BITS( &_body->capability_info ) );
+}
+
+
+bool OWaveLanManagementPacket::canCFP() const
+{
+    return CAPABILITY_CFP( EXTRACT_LE_16BITS( &_body->capability_info ) );
+}
+
+
+bool OWaveLanManagementPacket::canCFP_REQ() const
+{
+    return CAPABILITY_CFP_REQ( EXTRACT_LE_16BITS( &_body->capability_info ) );
+}
+
+
+bool OWaveLanManagementPacket::canPrivacy() const
+{
+    return CAPABILITY_PRIVACY( EXTRACT_LE_16BITS( &_body->capability_info ) );
+}
+
+
+/*======================================================================================
+ * OWaveLanManagementSSID
+ *======================================================================================*/
+
+OWaveLanManagementSSID::OWaveLanManagementSSID( const unsigned char* end, const struct ssid_t* data, QObject* parent )
+                :QObject( parent, "802.11 SSID" ), _data( data )
+{
+    odebug << "OWaveLanManagementSSID()" << oendl;
+}
+
+
+OWaveLanManagementSSID::~OWaveLanManagementSSID()
+{
+}
+
+
+QString OWaveLanManagementSSID::ID() const
+{
+    int length = _data->length;
+    if ( length > 32 ) length = 32;
+    char essid[length+1];
+    memcpy( &essid, &_data->ssid, length );
+    essid[length] = 0x0;
+    return essid;
+}
+
+
+/*======================================================================================
+ * OWaveLanManagementRates
+ *======================================================================================*/
+
+OWaveLanManagementRates::OWaveLanManagementRates( const unsigned char* end, const struct rates_t* data, QObject* parent )
+                :QObject( parent, "802.11 Rates" ), _data( data )
+{
+    odebug << "OWaveLanManagementRates()" << oendl;
+}
+
+
+OWaveLanManagementRates::~OWaveLanManagementRates()
+{
+}
+
+/*======================================================================================
+ * OWaveLanManagementCF
+ *======================================================================================*/
+
+OWaveLanManagementCF::OWaveLanManagementCF( const unsigned char* end, const struct cf_t* data, QObject* parent )
+                :QObject( parent, "802.11 CF" ), _data( data )
+{
+    odebug << "OWaveLanManagementCF()" << oendl;
+}
+
+
+OWaveLanManagementCF::~OWaveLanManagementCF()
+{
+}
+
+/*======================================================================================
+ * OWaveLanManagementFH
+ *======================================================================================*/
+
+OWaveLanManagementFH::OWaveLanManagementFH( const unsigned char* end, const struct fh_t* data, QObject* parent )
+                :QObject( parent, "802.11 FH" ), _data( data )
+{
+    odebug << "OWaveLanManagementFH()" << oendl;
+}
+
+
+OWaveLanManagementFH::~OWaveLanManagementFH()
+{
+}
+
+/*======================================================================================
+ * OWaveLanManagementDS
+ *======================================================================================*/
+
+OWaveLanManagementDS::OWaveLanManagementDS( const unsigned char* end, const struct ds_t* data, QObject* parent )
+                :QObject( parent, "802.11 DS" ), _data( data )
+{
+    odebug << "OWaveLanManagementDS()" << oendl;
+}
+
+
+OWaveLanManagementDS::~OWaveLanManagementDS()
+{
+}
+
+
+int OWaveLanManagementDS::channel() const
+{
+    return _data->channel;
+}
+
+/*======================================================================================
+ * OWaveLanManagementTim
+ *======================================================================================*/
+
+OWaveLanManagementTim::OWaveLanManagementTim( const unsigned char* end, const struct tim_t* data, QObject* parent )
+                :QObject( parent, "802.11 Tim" ), _data( data )
+{
+    odebug << "OWaveLanManagementTim()" << oendl;
+}
+
+
+OWaveLanManagementTim::~OWaveLanManagementTim()
+{
+}
+
+/*======================================================================================
+ * OWaveLanManagementIBSS
+ *======================================================================================*/
+
+OWaveLanManagementIBSS::OWaveLanManagementIBSS( const unsigned char* end, const struct ibss_t* data, QObject* parent )
+                :QObject( parent, "802.11 IBSS" ), _data( data )
+{
+    odebug << "OWaveLanManagementIBSS()" << oendl;
+}
+
+
+OWaveLanManagementIBSS::~OWaveLanManagementIBSS()
+{
+}
+
+/*======================================================================================
+ * OWaveLanManagementChallenge
+ *======================================================================================*/
+
+OWaveLanManagementChallenge::OWaveLanManagementChallenge( const unsigned char* end, const struct challenge_t* data, QObject* parent )
+                :QObject( parent, "802.11 Challenge" ), _data( data )
+{
+    odebug << "OWaveLanManagementChallenge()" << oendl;
+}
+
+
+OWaveLanManagementChallenge::~OWaveLanManagementChallenge()
+{
+}
+
+/*======================================================================================
+ * OWaveLanDataPacket
+ *======================================================================================*/
+
+OWaveLanDataPacket::OWaveLanDataPacket( const unsigned char* end, const struct ieee_802_11_data_header* data, OWaveLanPacket* parent )
+                :QObject( parent, "802.11 Data" ), _header( data )
+{
+    odebug << "OWaveLanDataPacket::OWaveLanDataPacket(): decoding frame..." << oendl;
+
+    const unsigned char* payload = (const unsigned char*) data + sizeof( struct ieee_802_11_data_header );
+
+    #warning The next line works for most cases, but can not be correct generally!
+    if (!( ( (OWaveLanPacket*) this->parent())->duration() )) payload -= 6; // compensation for missing last address
+
+    new OLLCPacket( end, (const struct ieee_802_11_802_2_header*) payload, this );
+}
+
+
+OWaveLanDataPacket::~OWaveLanDataPacket()
+{
+}
+
+
+/*======================================================================================
+ * OLLCPacket
+ *======================================================================================*/
+
+OLLCPacket::OLLCPacket( const unsigned char* end, const struct ieee_802_11_802_2_header* data, QObject* parent )
+           :QObject( parent, "802.11 LLC" ), _header( data )
+{
+    odebug << "OLLCPacket::OLLCPacket(): decoding frame..." << oendl;
+
+    if ( !(_header->oui[0] || _header->oui[1] || _header->oui[2]) )
+    {
+        owarn << "OLLCPacket::OLLCPacket(): contains an encapsulated Ethernet frame (type = " << EXTRACT_16BITS( &_header->type ) << ")" << oendl;
+
+        switch ( EXTRACT_16BITS( &_header->type ) ) // defined in linux/if_ether.h
+        {
+            case ETH_P_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break;
+            case ETH_P_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break;
+            default: owarn << "OLLCPacket::OLLCPacket(): Unknown Encapsulation type = " << EXTRACT_16BITS( &_header->type ) << oendl;
+        }
+    }
+}
+
+
+OLLCPacket::~OLLCPacket()
+{
+}
+
+
+/*======================================================================================
+ * OWaveLanControlPacket
+ *======================================================================================*/
+
+OWaveLanControlPacket::OWaveLanControlPacket( const unsigned char* end, const struct ieee_802_11_control_header* data, OWaveLanPacket* parent )
+                      :QObject( parent, "802.11 Control" ), _header( data )
+{
+    odebug << "OWaveLanControlPacket::OWaveLanDataControl(): decoding frame..." << oendl;
+    odebug << "Detected subtype is " << controlType() << oendl;
+}
+
+
+OWaveLanControlPacket::~OWaveLanControlPacket()
+{
+}
+
+
+QString OWaveLanControlPacket::controlType() const
+{
+    switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) )
+    {
+        case CTRL_PS_POLL: return "PowerSavePoll"; break;
+        case CTRL_RTS: return "RequestToSend"; break;
+        case CTRL_CTS: return "ClearToSend"; break;
+        case CTRL_ACK: return "Acknowledge"; break;
+        case CTRL_CF_END: return "ContentionFreeEnd"; break;
+        case CTRL_END_ACK: return "AcknowledgeEnd"; break;
+        default:
+            owarn << "OWaveLanControlPacket::managementType(): unhandled subtype " << FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) << oendl;
+            return "Unknown";
+    }
+}
+
+
+/*======================================================================================
+ * OPacketCapturer
+ *======================================================================================*/
+
+OPacketCapturer::OPacketCapturer( QObject* parent, const char* name )
+                :QObject( parent, name ), _name( QString::null ), _open( false ), _pch( 0 ), _pcd( 0 ), _sn( 0 )
+{
+}
+
+
+OPacketCapturer::~OPacketCapturer()
+{
+    if ( _open )
+    {
+        odebug << "OPacketCapturer::~OPacketCapturer(): pcap still open, autoclosing." << oendl;
+        close();
+    }
+}
+
+
+void OPacketCapturer::setBlocking( bool b )
+{
+    if ( pcap_setnonblock( _pch, 1-b, _errbuf ) != -1 )
+    {
+        odebug << "OPacketCapturer::setBlocking(): blocking mode changed successfully." << oendl;
+    }
+    else
+    {
+        odebug << "OPacketCapturer::setBlocking(): can't change blocking mode: " << _errbuf << oendl;
+    }
+}
+
+
+bool OPacketCapturer::blocking() const
+{
+    int b = pcap_getnonblock( _pch, _errbuf );
+    if ( b == -1 )
+    {
+        odebug << "OPacketCapturer::blocking(): can't get blocking mode: " << _errbuf << oendl;
+        return -1;
+    }
+    return !b;
+}
+
+
+void OPacketCapturer::closeDumpFile()
+{
+    if ( _pcd )
+    {
+        pcap_dump_close( _pcd );
+        _pcd = 0;
+    }
+    pcap_close( _pch );
+}
+
+
+void OPacketCapturer::close()
+{
+    if ( _open )
+    {
+        if ( _sn )
+        {
+            _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
+            delete _sn;
+        }
+        closeDumpFile();
+    _open = false;
+    }
+
+    odebug << "OPacketCapturer::close() --- dumping capturing statistics..." << oendl;
+    odebug << "--------------------------------------------------" << oendl;
+    for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it )
+        odebug << it.key() << " = " << it.data() << oendl;
+    odebug << "--------------------------------------------------" << oendl;
+
+}
+
+
+int OPacketCapturer::dataLink() const
+{
+    return pcap_datalink( _pch );
+}
+
+
+void OPacketCapturer::dump( OPacket* p )
+{
+    if ( !_pcd )
+    {
+        owarn << "OPacketCapturer::dump() - cannot dump without open capture file!" << oendl;
+        return;
+    }
+    pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data );
+}
+
+
+int OPacketCapturer::fileno() const
+{
+    if ( _open )
+    {
+        return pcap_fileno( _pch );
+    }
+    else
+    {
+        return -1;
+    }
+}
+
+
+OPacket* OPacketCapturer::next( int time )
+{
+    fd_set fds;
+    struct timeval tv;
+    FD_ZERO( &fds );
+    FD_SET( pcap_fileno( _pch ), &fds );
+    tv.tv_sec = time / 1000;
+    tv.tv_usec = time % 1000;
+    int retval = select( pcap_fileno( _pch )+1, &fds, NULL, NULL, &tv);
+    if ( retval > 0 ) // clear to read!
+        return next();
+    else
+        return 0;
+}
+
+
+OPacket* OPacketCapturer::next()
+{
+    packetheaderstruct header;
+    odebug << "==> OPacketCapturer::next()" << oendl;
+    const unsigned char* pdata = pcap_next( _pch, &header );
+    odebug << "<== OPacketCapturer::next()" << oendl;
+
+    if ( pdata && header.len )
+    {
+        OPacket* p = new OPacket( dataLink(), header, pdata, 0 );
+        // packets shouldn't be inserted in the QObject child-parent hierarchy,
+        // because due to memory constraints they will be deleted as soon
+        // as possible - that is right after they have been processed
+        // by emit() [ see below ]
+        //TODO: make gathering statistics optional, because it takes time
+        p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) );
+        #ifndef NODEBUG
+        p->dumpStructure( const_cast<QObjectList*>( p->children() ) );
+        #endif
+        return p;
+    }
+    else
+    {
+        owarn << "OPacketCapturer::next() - no packet received!" << oendl;
+        return 0;
+    }
+}
+
+
+bool OPacketCapturer::open( const QString& name )
+{
+    if ( _open )
+    {
+        if ( name == _name )    // ignore opening an already openend device
+        {
+            return true;
+        }
+        else                    // close the last opened device
+        {
+            close();
+        }
+    }
+
+    _name = name;
+
+    // open libpcap
+    pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] );
+
+    if ( !handle )
+    {
+        owarn << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl;
+        return false;
+    }
+
+    odebug << "OPacketCapturer::open(): libpcap [" << name << "] opened successfully." << oendl;
+    _pch = handle;
+    _open = true;
+    _stats.clear();
+
+    // in case we have an application object, create a socket notifier
+    if ( qApp ) //TODO: I don't like this here...
+    {
+        _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );
+        connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
+    }
+
+    return true;
+}
+
+
+bool OPacketCapturer::openDumpFile( const QString& filename )
+{
+    pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) );
+    if ( !dump )
+    {
+        owarn << "OPacketCapturer::open(): can't open dump with '" << filename << "': " << _errbuf << oendl;
+        return false;
+    }
+    odebug << "OPacketCapturer::open(): dump [" << filename << "] opened successfully." << oendl;
+    _pcd = dump;
+
+    return true;
+}
+
+
+bool OPacketCapturer::open( const QFile& file )
+{
+    QString name = file.name();
+
+    if ( _open )
+    {
+        close();
+        if ( name == _name )    // ignore opening an already openend device
+        {
+            return true;
+        }
+        else                    // close the last opened device
+        {
+            close();
+        }
+    }
+
+    _name = name;
+
+    pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] );
+
+    if ( handle )
+    {
+        odebug << "OPacketCapturer::open(): libpcap opened successfully." << oendl;
+        _pch = handle;
+        _open = true;
+
+        // in case we have an application object, create a socket notifier
+        if ( qApp )
+        {
+            _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );
+            connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
+        }
+
+        return true;
+    }
+    else
+    {
+        odebug << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl;
+        return false;
+    }
+
+}
+
+
+bool OPacketCapturer::isOpen() const
+{
+    return _open;
+}
+
+
+void OPacketCapturer::readyToReceive()
+{
+    odebug << "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" << oendl;
+    OPacket* p = next();
+    emit receivedPacket( p );
+    // emit is synchronous - packet has been dealt with, now it's safe to delete
+    delete p;
+}
+
+
+const QMap<QString,int>& OPacketCapturer::statistics() const
+{
+    return _stats;
+}
+
+
+int OPacketCapturer::snapShot() const
+{
+    return pcap_snapshot( _pch );
+}
+
+
+bool OPacketCapturer::swapped() const
+{
+    return pcap_is_swapped( _pch );
+}
+
+
+QString OPacketCapturer::version() const
+{
+    return QString().sprintf( "%s.%s", pcap_major_version( _pch ), pcap_minor_version( _pch ) );
+}
+
+
diff --git a/libopie2/opienet/opcap.h b/libopie2/opienet/opcap.h
index 497fd6b..b373c56 100644
--- a/libopie2/opienet/opcap.h
+++ b/libopie2/opienet/opcap.h
@@ -208,384 +208,386 @@ class OWaveLanPacket : public QObject
 };
 
 
 /*======================================================================================
  * OWaveLanManagementPacket - type: management (T_MGMT)
  *======================================================================================*/
 
 class OWaveLanManagementPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementPacket( const unsigned char*, const struct ieee_802_11_mgmt_header*, OWaveLanPacket* parent = 0 );
     virtual ~OWaveLanManagementPacket();
 
     QString managementType() const;
 
     int beaconInterval() const;
     int capabilities() const; // generic
 
     bool canESS() const;
     bool canIBSS() const;
     bool canCFP() const;
     bool canCFP_REQ() const;
     bool canPrivacy() const;
 
   private:
     const struct ieee_802_11_mgmt_header* _header;
     const struct ieee_802_11_mgmt_body* _body;
 };
 
 
 /*======================================================================================
  * OWaveLanManagementSSID
  *======================================================================================*/
 
 class OWaveLanManagementSSID : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementSSID( const unsigned char*, const struct ssid_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementSSID();
 
     QString ID() const;
 
   private:
     const struct ssid_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementRates
  *======================================================================================*/
 
 class OWaveLanManagementRates : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementRates( const unsigned char*, const struct rates_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementRates();
 
   private:
     const struct rates_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementCF
  *======================================================================================*/
 
 class OWaveLanManagementCF : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementCF( const unsigned char*, const struct cf_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementCF();
 
   private:
     const struct cf_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementFH
  *======================================================================================*/
 
 class OWaveLanManagementFH : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementFH( const unsigned char*, const struct fh_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementFH();
 
   private:
     const struct fh_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementDS
  *======================================================================================*/
 
 class OWaveLanManagementDS : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementDS( const unsigned char*, const struct ds_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementDS();
 
     int channel() const;
 
   private:
     const struct ds_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementTim
  *======================================================================================*/
 
 class OWaveLanManagementTim : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementTim( const unsigned char*, const struct tim_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementTim();
 
   private:
     const struct tim_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementIBSS
  *======================================================================================*/
 
 class OWaveLanManagementIBSS : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementIBSS( const unsigned char*, const struct ibss_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementIBSS();
 
   private:
     const struct ibss_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanManagementChallenge
  *======================================================================================*/
 
 class OWaveLanManagementChallenge : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanManagementChallenge( const unsigned char*, const struct challenge_t*, QObject* parent = 0 );
     virtual ~OWaveLanManagementChallenge();
 
   private:
     const struct challenge_t* _data;
 };
 
 /*======================================================================================
  * OWaveLanDataPacket - type: data (T_DATA)
  *======================================================================================*/
 
 class OWaveLanDataPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanDataPacket( const unsigned char*, const struct ieee_802_11_data_header*, OWaveLanPacket* parent = 0 );
     virtual ~OWaveLanDataPacket();
 
   private:
     const struct ieee_802_11_data_header* _header;
 };
 
 /*======================================================================================
  * OWaveLanControlPacket - type: control (T_CTRL)
  *======================================================================================*/
 
 class OWaveLanControlPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OWaveLanControlPacket( const unsigned char*, const struct ieee_802_11_control_header*, OWaveLanPacket* parent = 0 );
     virtual ~OWaveLanControlPacket();
 
+    QString controlType() const;
+
   private:
     const struct ieee_802_11_control_header* _header;
 };
 
 /*======================================================================================
  * OLLCPacket - IEEE 802.2 Link Level Control
  *======================================================================================*/
 
 class OLLCPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OLLCPacket( const unsigned char*, const struct ieee_802_11_802_2_header* data, QObject* parent = 0 );
     virtual ~OLLCPacket();
 
   private:
     const struct ieee_802_11_802_2_header* _header;
 };
 
 /*======================================================================================
  * OIPPacket
  *======================================================================================*/
 
 class OIPPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OIPPacket( const unsigned char*, const struct iphdr*, QObject* parent = 0 );
     virtual ~OIPPacket();
 
     QHostAddress fromIPAddress() const;
     QHostAddress toIPAddress() const;
 
     int tos() const;
     int len() const;
     int id() const;
     int offset() const;
     int ttl() const;
     int protocol() const;
     int checksum() const;
 
   private:
     const struct iphdr* _iphdr;
 };
 
 /*======================================================================================
  * OARPPacket
  *======================================================================================*/
 
 class OARPPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OARPPacket( const unsigned char*, const struct myarphdr*, QObject* parent = 0 );
     virtual ~OARPPacket();
 
     QHostAddress senderIPV4Address() const;
     OMacAddress senderMacAddress() const;
     QHostAddress targetIPV4Address() const;
     OMacAddress targetMacAddress() const;
 
     //int type() const;
     QString type() const;
 
   private:
     const struct myarphdr* _arphdr;
 };
 
 /*======================================================================================
  * OUDPPacket
  *======================================================================================*/
 
 class OUDPPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OUDPPacket( const unsigned char*, const struct udphdr*, QObject* parent = 0 );
     virtual ~OUDPPacket();
 
     int fromPort() const;
     int toPort() const;
     int length() const;
     int checksum() const;
 
   private:
     const struct udphdr* _udphdr;
 };
 
 /*======================================================================================
  * ODHCPPacket
  *======================================================================================*/
 
 class ODHCPPacket : public QObject
 {
   Q_OBJECT
 
   public:
     ODHCPPacket( const unsigned char*, const struct dhcp_packet*, QObject* parent = 0 );
     virtual ~ODHCPPacket();
 
     QHostAddress clientAddress() const;
     QHostAddress yourAddress() const;
     QHostAddress serverAddress() const;
     QHostAddress relayAddress() const;
 
     OMacAddress clientMacAddress() const;
 
     bool isRequest() const;
     bool isReply() const;
     QString type() const;
 
   private:
     const struct dhcp_packet* _dhcphdr;
     unsigned char _type;
 };
 
 /*======================================================================================
  * OTCPPacket
  *======================================================================================*/
 
 class OTCPPacket : public QObject
 {
   Q_OBJECT
 
   public:
     OTCPPacket( const unsigned char*, const struct tcphdr*, QObject* parent = 0 );
     virtual ~OTCPPacket();
 
     int fromPort() const;
     int toPort() const;
     int seq() const;
     int ack() const;
     int window() const;
     int checksum() const;
 
   private:
     const struct tcphdr* _tcphdr;
 };
 
 
 /*======================================================================================
  * OPacketCapturer
  *======================================================================================*/
 
 /**
  * @brief A class based wrapper for network packet capturing.
  *
  * This class is the base of a high-level interface to the well known packet capturing
  * library libpcap.
  * @see http://tcpdump.org
  */
 class OPacketCapturer : public QObject
 {
   Q_OBJECT
 
   public:
     /**
      * Constructor.
      */
     OPacketCapturer( QObject* parent = 0, const char* name = 0 );
     /**
      * Destructor.
      */
     ~OPacketCapturer();
     /**
      * Set the packet capturer to use blocking or non-blocking IO. This can be useful when
      * not using the socket notifier, e.g. without an application object.
      */
     void setBlocking( bool );
     /**
      * @returns true if the packet capturer uses blocking IO calls.
      */
     bool blocking() const;
     /**
      * Close the packet capturer. This is automatically done in the destructor.
      */
     void close();
     /**
      * Close the output capture file.
      */
     void closeDumpFile();
     /**
      * @returns the data link type.
      * @see <pcap.h> for possible values.
      */
     int dataLink() const;
     /**
      * Dump a packet to the output capture file.