summaryrefslogtreecommitdiff
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--libopie2/opienet/opcap.cpp21
-rw-r--r--libopie2/opienet/opcap.h35
2 files changed, 32 insertions, 24 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp
index 7463320..fdd519c 100644
--- a/libopie2/opienet/opcap.cpp
+++ b/libopie2/opienet/opcap.cpp
@@ -17,261 +17,266 @@
17    =_        +     =;=|` MERCHANTABILITY or FITNESS FOR A 17    =_        +     =;=|` MERCHANTABILITY or FITNESS FOR A
18  _.=:.       :    :=>`: PARTICULAR PURPOSE. See the GNU 18  _.=:.       :    :=>`: PARTICULAR PURPOSE. See the GNU
19..}^=.=       =       ; Library General Public License for more 19..}^=.=       =       ; Library General Public License for more
20++=   -.     .`     .: details. 20++=   -.     .`     .: details.
21 :     =  ...= . :.=- 21 :     =  ...= . :.=-
22 -.   .:....=;==+<; You should have received a copy of the GNU 22 -.   .:....=;==+<; You should have received a copy of the GNU
23  -_. . .   )=.  = Library General Public License along with 23  -_. . .   )=.  = Library General Public License along with
24    --        :-=` this library; see the file COPYING.LIB. 24    --        :-=` this library; see the file COPYING.LIB.
25 If not, write to the Free Software Foundation, 25 If not, write to the Free Software Foundation,
26 Inc., 59 Temple Place - Suite 330, 26 Inc., 59 Temple Place - Suite 330,
27 Boston, MA 02111-1307, USA. 27 Boston, MA 02111-1307, USA.
28 28
29*/ 29*/
30 30
31/* OPIE */ 31/* OPIE */
32#include <opie2/opcap.h> 32#include <opie2/opcap.h>
33#include <opie2/odebug.h> 33#include <opie2/odebug.h>
34 34
35/* QT */ 35/* QT */
36#include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects) 36#include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects)
37#include <qsocketnotifier.h> 37#include <qsocketnotifier.h>
38#include <qobjectlist.h> 38#include <qobjectlist.h>
39 39
40/* SYSTEM */ 40/* SYSTEM */
41#include <sys/time.h> 41#include <sys/time.h>
42#include <sys/types.h> 42#include <sys/types.h>
43#include <unistd.h> 43#include <unistd.h>
44 44
45/* LOCAL */ 45/* LOCAL */
46#include "udp_ports.h" 46#include "udp_ports.h"
47 47
48/*====================================================================================== 48/*======================================================================================
49 * OPacket 49 * OPacket
50 *======================================================================================*/ 50 *======================================================================================*/
51 51
52OPacket::OPacket( int datalink, packetheaderstruct header, const unsigned char* data, QObject* parent ) 52OPacket::OPacket( int datalink, packetheaderstruct header, const unsigned char* data, QObject* parent )
53 :QObject( parent, "Generic" ), _hdr( header ), _data( data ) 53 :QObject( parent, "Generic" ), _hdr( header ), _data( data )
54{ 54{
55 //qDebug( "OPacket::OPacket(): (Len %d, CapLen %d)" /*, ctime((const time_t*) header.ts.tv_sec)*/, header.len, header.caplen ); 55 //qDebug( "OPacket::OPacket(): (Len %d, CapLen %d)" /*, ctime((const time_t*) header.ts.tv_sec)*/, header.len, header.caplen );
56 56
57 _end = (unsigned char*) data + header.len; 57 _end = (unsigned char*) data + header.len;
58 //qDebug( "OPacket::data @ %0x, end @ %0x", data, _end ); 58 //qDebug( "OPacket::data @ %0x, end @ %0x", data, _end );
59 59
60 switch ( datalink ) 60 switch ( datalink )
61 { 61 {
62 case DLT_EN10MB: 62 case DLT_EN10MB:
63 odebug << "OPacket::OPacket(): Received Packet. Datalink = ETHERNET" << oendl; 63 odebug << "OPacket::OPacket(): Received Packet. Datalink = ETHERNET" << oendl;
64 new OEthernetPacket( _end, (const struct ether_header*) data, this ); 64 new OEthernetPacket( _end, (const struct ether_header*) data, this );
65 break; 65 break;
66 66
67 case DLT_IEEE802_11: 67 case DLT_IEEE802_11:
68 odebug << "OPacket::OPacket(): Received Packet. Datalink = IEEE802.11" << oendl; 68 odebug << "OPacket::OPacket(): Received Packet. Datalink = IEEE802.11" << oendl;
69 new OWaveLanPacket( _end, (const struct ieee_802_11_header*) data, this ); 69 new OWaveLanPacket( _end, (const struct ieee_802_11_header*) data, this );
70 break; 70 break;
71 71
72 case DLT_PRISM_HEADER: 72 case DLT_PRISM_HEADER:
73 odebug << "OPacket::OPacket(): Received Packet. Datalink = PRISM_HEADER" << oendl; 73 odebug << "OPacket::OPacket(): Received Packet. Datalink = PRISM_HEADER" << oendl;
74 new OPrismHeaderPacket( _end, (const struct prism_hdr*) (unsigned char*) data, this ); 74 new OPrismHeaderPacket( _end, (const struct prism_hdr*) (unsigned char*) data, this );
75 break; 75 break;
76 76
77 default: 77 default:
78 owarn << "OPacket::OPacket(): Received Packet over unsupported datalink, type " << datalink << "!" << oendl; 78 owarn << "OPacket::OPacket(): Received Packet over unsupported datalink, type " << datalink << "!" << oendl;
79 } 79 }
80} 80}
81 81
82 82
83OPacket::~OPacket() 83OPacket::~OPacket()
84{ 84{
85} 85}
86 86
87 87
88timevalstruct OPacket::timeval() const 88timevalstruct OPacket::timeval() const
89{ 89{
90 return _hdr.ts; 90 return _hdr.ts;
91} 91}
92 92
93 93
94int OPacket::caplen() const 94int OPacket::caplen() const
95{ 95{
96 return _hdr.caplen; 96 return _hdr.caplen;
97} 97}
98 98
99 99
100void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l ) 100void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l )
101{ 101{
102 if (!l) return; 102 if (!l) return;
103 QObject* o = l->first(); 103 QObject* o = l->first();
104 while ( o ) 104 while ( o )
105 { 105 {
106 stats[o->name()]++; 106 stats[o->name()]++;
107 updateStats( stats, const_cast<QObjectList*>( o->children() ) ); 107 updateStats( stats, const_cast<QObjectList*>( o->children() ) );
108 o = l->next(); 108 o = l->next();
109 } 109 }
110} 110}
111 111
112 112
113void OPacket::dumpStructure( QObjectList* l ) 113QString OPacket::dumpStructure() const
114{ 114{
115 QString packetString( "[ |" + _dumpStructure( l ) + " ]" ); 115 return "[ |" + _dumpStructure( const_cast<QObjectList*>( this->children() ) ) + " ]";
116 odebug << "OPacket::dumpStructure: " << packetString << oendl;
117} 116}
118 117
119 118
120QString OPacket::_dumpStructure( QObjectList* l ) 119QString OPacket::_dumpStructure( QObjectList* l ) const
121{ 120{
122 if (!l) return QString::null; 121 if (!l) return QString::null;
123 QObject* o = l->first(); 122 QObject* o = l->first();
124 QString str(" "); 123 QString str(" ");
125 124
126 while ( o ) 125 while ( o )
127 { 126 {
128 str.append( o->name() ); 127 str.append( o->name() );
129 str.append( " |" ); 128 str.append( " |" );
130 str += _dumpStructure( const_cast<QObjectList*>( o->children() ) ); 129 str += _dumpStructure( const_cast<QObjectList*>( o->children() ) );
131 o = l->next(); 130 o = l->next();
132 } 131 }
133 return str; 132 return str;
134} 133}
135 134
136QString OPacket::dump( int bpl ) const 135QString OPacket::dump( int bpl ) const
137{ 136{
138 static int index = 0; 137 static int index = 0;
139 index++; 138 index++;
140 int len = _hdr.caplen; 139 int len = _hdr.caplen;
141 QString str; 140 QString str;
142 str.sprintf( "\n<----- Packet #%04d Len = 0x%X (%d) ----->\n\n", index, len, len ); 141 str.sprintf( "\n<----- Packet #%04d Len = 0x%X (%d) ----->\n\n", index, len, len );
143 str.append( "0000: " ); 142 str.append( "0000: " );
144 QString tmp; 143 QString tmp;
145 QString bytes; 144 QString bytes;
146 QString chars; 145 QString chars;
147 146
148 for ( int i = 0; i < len; ++i ) 147 for ( int i = 0; i < len; ++i )
149 { 148 {
150 tmp.sprintf( "%02X ", _data[i] ); bytes.append( tmp ); 149 tmp.sprintf( "%02X ", _data[i] ); bytes.append( tmp );
151 if ( (_data[i] > 31) && (_data[i]<128) ) chars.append( _data[i] ); 150 if ( (_data[i] > 31) && (_data[i]<128) ) chars.append( _data[i] );
152 else chars.append( '.' ); 151 else chars.append( '.' );
153 152
154 if ( !((i+1) % bpl) ) 153 if ( !((i+1) % bpl) )
155 { 154 {
156 str.append( bytes ); 155 str.append( bytes );
157 str.append( ' ' ); 156 str.append( ' ' );
158 str.append( chars ); 157 str.append( chars );
159 str.append( '\n' ); 158 str.append( '\n' );
160 tmp.sprintf( "%04X: ", i+1 ); str.append( tmp ); 159 tmp.sprintf( "%04X: ", i+1 ); str.append( tmp );
161 bytes = ""; 160 bytes = "";
162 chars = ""; 161 chars = "";
163 } 162 }
164 163
165 } 164 }
166 if ( (len % bpl) ) 165 if ( (len % bpl) )
167 { 166 {
168 str.append( bytes.leftJustify( 1 + 3*bpl ) ); 167 str.append( bytes.leftJustify( 1 + 3*bpl ) );
169 str.append( chars ); 168 str.append( chars );
170 } 169 }
171 str.append( '\n' ); 170 str.append( '\n' );
172 return str; 171 return str;
173} 172}
174 173
175 174
176int OPacket::len() const 175int OPacket::len() const
177{ 176{
178 return _hdr.len; 177 return _hdr.len;
179} 178}
180 179
181 180
181QTextStream& operator<<( QTextStream& s, const OPacket& p )
182{
183 s << p.dumpStructure();
184}
185
186
182/*====================================================================================== 187/*======================================================================================
183 * OEthernetPacket 188 * OEthernetPacket
184 *======================================================================================*/ 189 *======================================================================================*/
185 190
186OEthernetPacket::OEthernetPacket( const unsigned char* end, const struct ether_header* data, QObject* parent ) 191OEthernetPacket::OEthernetPacket( const unsigned char* end, const struct ether_header* data, QObject* parent )
187 :QObject( parent, "Ethernet" ), _ether( data ) 192 :QObject( parent, "Ethernet" ), _ether( data )
188{ 193{
189 194
190 odebug << "Source = " << sourceAddress().toString(); 195 odebug << "Source = " << sourceAddress().toString();
191 odebug << "Destination = " << destinationAddress().toString(); 196 odebug << "Destination = " << destinationAddress().toString();
192 197
193 if ( sourceAddress() == OMacAddress::broadcast ) 198 if ( sourceAddress() == OMacAddress::broadcast )
194 odebug << "Source is broadcast address" << oendl; 199 odebug << "Source is broadcast address" << oendl;
195 if ( destinationAddress() == OMacAddress::broadcast ) 200 if ( destinationAddress() == OMacAddress::broadcast )
196 odebug << "Destination is broadcast address" << oendl; 201 odebug << "Destination is broadcast address" << oendl;
197 202
198 switch ( type() ) 203 switch ( type() )
199 { 204 {
200 case ETHERTYPE_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break; 205 case ETHERTYPE_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break;
201 case ETHERTYPE_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break; 206 case ETHERTYPE_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break;
202 case ETHERTYPE_REVARP: { odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = RARP" << oendl; break; } 207 case ETHERTYPE_REVARP: { odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = RARP" << oendl; break; }
203 default: odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = UNKNOWN" << oendl; 208 default: odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = UNKNOWN" << oendl;
204 } 209 }
205 210
206} 211}
207 212
208 213
209OEthernetPacket::~OEthernetPacket() 214OEthernetPacket::~OEthernetPacket()
210{ 215{
211} 216}
212 217
213 218
214OMacAddress OEthernetPacket::sourceAddress() const 219OMacAddress OEthernetPacket::sourceAddress() const
215{ 220{
216 return OMacAddress( _ether->ether_shost ); 221 return OMacAddress( _ether->ether_shost );
217} 222}
218 223
219 224
220OMacAddress OEthernetPacket::destinationAddress() const 225OMacAddress OEthernetPacket::destinationAddress() const
221{ 226{
222 return OMacAddress( _ether->ether_dhost ); 227 return OMacAddress( _ether->ether_dhost );
223} 228}
224 229
225int OEthernetPacket::type() const 230int OEthernetPacket::type() const
226{ 231{
227 return ntohs( _ether->ether_type ); 232 return ntohs( _ether->ether_type );
228} 233}
229 234
230 235
231/*====================================================================================== 236/*======================================================================================
232 * OIPPacket 237 * OIPPacket
233 *======================================================================================*/ 238 *======================================================================================*/
234 239
235 240
236OIPPacket::OIPPacket( const unsigned char* end, const struct iphdr* data, QObject* parent ) 241OIPPacket::OIPPacket( const unsigned char* end, const struct iphdr* data, QObject* parent )
237 :QObject( parent, "IP" ), _iphdr( data ) 242 :QObject( parent, "IP" ), _iphdr( data )
238{ 243{
239 odebug << "OIPPacket::OIPPacket(): decoding IP header..." << oendl; 244 odebug << "OIPPacket::OIPPacket(): decoding IP header..." << oendl;
240 245
241 odebug << "FromAddress = " << fromIPAddress().toString() << oendl; 246 odebug << "FromAddress = " << fromIPAddress().toString() << oendl;
242 odebug << " toAddress = " << toIPAddress().toString() << oendl; 247 odebug << " toAddress = " << toIPAddress().toString() << oendl;
243 248
244 switch ( protocol() ) 249 switch ( protocol() )
245 { 250 {
246 case IPPROTO_UDP: new OUDPPacket( end, (const struct udphdr*) (data+1), this ); break; 251 case IPPROTO_UDP: new OUDPPacket( end, (const struct udphdr*) (data+1), this ); break;
247 case IPPROTO_TCP: new OTCPPacket( end, (const struct tcphdr*) (data+1), this ); break; 252 case IPPROTO_TCP: new OTCPPacket( end, (const struct tcphdr*) (data+1), this ); break;
248 default: odebug << "OIPPacket::OIPPacket(): unknown IP protocol, type = " << protocol() << oendl; 253 default: odebug << "OIPPacket::OIPPacket(): unknown IP protocol, type = " << protocol() << oendl;
249 } 254 }
250 255
251} 256}
252 257
253OIPPacket::~OIPPacket() 258OIPPacket::~OIPPacket()
254{ 259{
255} 260}
256 261
257 262
258QHostAddress OIPPacket::fromIPAddress() const 263QHostAddress OIPPacket::fromIPAddress() const
259{ 264{
260 return EXTRACT_32BITS( &_iphdr->saddr ); 265 return EXTRACT_32BITS( &_iphdr->saddr );
261} 266}
262 267
263 268
264QHostAddress OIPPacket::toIPAddress() const 269QHostAddress OIPPacket::toIPAddress() const
265{ 270{
266 return EXTRACT_32BITS( &_iphdr->saddr ); 271 return EXTRACT_32BITS( &_iphdr->saddr );
267} 272}
268 273
269 274
270int OIPPacket::tos() const 275int OIPPacket::tos() const
271{ 276{
272 return _iphdr->tos; 277 return _iphdr->tos;
273} 278}
274 279
275 280
276int OIPPacket::len() const 281int OIPPacket::len() const
277{ 282{
@@ -636,193 +641,193 @@ OWaveLanPacket::OWaveLanPacket( const unsigned char* end, const struct ieee_802_
636 } 641 }
637} 642}
638 643
639OWaveLanPacket::~OWaveLanPacket() 644OWaveLanPacket::~OWaveLanPacket()
640{ 645{
641} 646}
642 647
643 648
644int OWaveLanPacket::duration() const 649int OWaveLanPacket::duration() const
645{ 650{
646 return _wlanhdr->duration; 651 return _wlanhdr->duration;
647} 652}
648 653
649 654
650OMacAddress OWaveLanPacket::macAddress1() const 655OMacAddress OWaveLanPacket::macAddress1() const
651{ 656{
652 return OMacAddress( _wlanhdr->mac1 ); 657 return OMacAddress( _wlanhdr->mac1 );
653} 658}
654 659
655 660
656OMacAddress OWaveLanPacket::macAddress2() const 661OMacAddress OWaveLanPacket::macAddress2() const
657{ 662{
658 return OMacAddress( _wlanhdr->mac2 ); 663 return OMacAddress( _wlanhdr->mac2 );
659} 664}
660 665
661 666
662OMacAddress OWaveLanPacket::macAddress3() const 667OMacAddress OWaveLanPacket::macAddress3() const
663{ 668{
664 return OMacAddress( _wlanhdr->mac3 ); 669 return OMacAddress( _wlanhdr->mac3 );
665} 670}
666 671
667 672
668OMacAddress OWaveLanPacket::macAddress4() const 673OMacAddress OWaveLanPacket::macAddress4() const
669{ 674{
670 return OMacAddress( _wlanhdr->mac4 ); 675 return OMacAddress( _wlanhdr->mac4 );
671} 676}
672 677
673 678
674int OWaveLanPacket::subType() const 679int OWaveLanPacket::subType() const
675{ 680{
676 return FC_SUBTYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 681 return FC_SUBTYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
677} 682}
678 683
679 684
680int OWaveLanPacket::type() const 685int OWaveLanPacket::type() const
681{ 686{
682 return FC_TYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 687 return FC_TYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
683} 688}
684 689
685 690
686int OWaveLanPacket::version() const 691int OWaveLanPacket::version() const
687{ 692{
688 return FC_VERSION( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 693 return FC_VERSION( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
689} 694}
690 695
691 696
692bool OWaveLanPacket::fromDS() const 697bool OWaveLanPacket::fromDS() const
693{ 698{
694 return FC_FROM_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 699 return FC_FROM_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
695} 700}
696 701
697 702
698bool OWaveLanPacket::toDS() const 703bool OWaveLanPacket::toDS() const
699{ 704{
700 return FC_TO_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 705 return FC_TO_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
701} 706}
702 707
703 708
704bool OWaveLanPacket::usesPowerManagement() const 709bool OWaveLanPacket::usesPowerManagement() const
705{ 710{
706 return FC_POWER_MGMT( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 711 return FC_POWER_MGMT( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
707} 712}
708 713
709 714
710bool OWaveLanPacket::usesWep() const 715bool OWaveLanPacket::usesWep() const
711{ 716{
712 return FC_WEP( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); 717 return FC_WEP( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) );
713} 718}
714 719
715 720
716/*====================================================================================== 721/*======================================================================================
717 * OWaveLanManagementPacket 722 * OWaveLanManagementPacket
718 *======================================================================================*/ 723 *======================================================================================*/
719 724
720OWaveLanManagementPacket::OWaveLanManagementPacket( const unsigned char* end, const struct ieee_802_11_mgmt_header* data, OWaveLanPacket* parent ) 725OWaveLanManagementPacket::OWaveLanManagementPacket( const unsigned char* end, const struct ieee_802_11_mgmt_header* data, OWaveLanPacket* parent )
721 :QObject( parent, "802.11 Management" ), _header( data ), 726 :QObject( parent, "802.11 Management" ), _header( data ),
722 _body( (const struct ieee_802_11_mgmt_body*) (data+1) ) 727 _body( (const struct ieee_802_11_mgmt_body*) (data+1) )
723{ 728{
724 odebug << "OWaveLanManagementPacket::OWaveLanManagementPacket(): decoding frame..." << oendl; 729 odebug << "OWaveLanManagementPacket::OWaveLanManagementPacket(): decoding frame..." << oendl;
725 odebug << "Detected subtype is " << managementType() << oendl; 730 odebug << "Detected subtype is " << managementType() << oendl;
726 731
727 // Grab tagged values. 732 // Grab tagged values.
728 // Beacons contain a 12 byte long fixed parameters set before the tagged parameters come, 733 // Beacons contain a 12 byte long fixed parameters set before the tagged parameters come,
729 // Other management frames don't - which is why we have to inspect the subtype here. 734 // Other management frames don't - which is why we have to inspect the subtype here.
730 735
731 const unsigned char* ptr = managementType() == "Beacon" ? (const unsigned char*) (_body+1) : (const unsigned char*) (_header+1); 736 const unsigned char* ptr = managementType() == "Beacon" ? (const unsigned char*) (_body+1) : (const unsigned char*) (_header+1);
732 737
733 while (ptr < end) 738 while (ptr < end)
734 { 739 {
735 switch ( *ptr ) 740 switch ( *ptr )
736 { 741 {
737 case E_SSID: new OWaveLanManagementSSID( end, (struct ssid_t*) ptr, this ); break; 742 case E_SSID: new OWaveLanManagementSSID( end, (struct ssid_t*) ptr, this ); break;
738 case E_FH: new OWaveLanManagementFH( end, (struct fh_t*) ptr, this ); break; 743 case E_FH: new OWaveLanManagementFH( end, (struct fh_t*) ptr, this ); break;
739 case E_DS: new OWaveLanManagementDS( end, (struct ds_t*) ptr, this ); break; 744 case E_DS: new OWaveLanManagementDS( end, (struct ds_t*) ptr, this ); break;
740 case E_RATES: new OWaveLanManagementRates( end, (struct rates_t*) ptr, this ); break; 745 case E_RATES: new OWaveLanManagementRates( end, (struct rates_t*) ptr, this ); break;
741 case E_CF: new OWaveLanManagementCF( end, (struct cf_t*) ptr, this ); break; 746 case E_CF: new OWaveLanManagementCF( end, (struct cf_t*) ptr, this ); break;
742 case E_TIM: new OWaveLanManagementTim( end, (struct tim_t*) ptr, this ); break; 747 case E_TIM: new OWaveLanManagementTim( end, (struct tim_t*) ptr, this ); break;
743 case E_IBSS: new OWaveLanManagementIBSS( end, (struct ibss_t*) ptr, this ); break; 748 case E_IBSS: new OWaveLanManagementIBSS( end, (struct ibss_t*) ptr, this ); break;
744 case E_CHALLENGE: new OWaveLanManagementChallenge( end, (struct challenge_t*) ptr, this ); break; 749 case E_CHALLENGE: new OWaveLanManagementChallenge( end, (struct challenge_t*) ptr, this ); break;
745 } 750 }
746 ptr+= ( ( struct ssid_t* ) ptr )->length; // skip length of tagged value 751 ptr+= ( ( struct ssid_t* ) ptr )->length; // skip length of tagged value
747 ptr+= 2; // skip tag ID and length 752 ptr+= 2; // skip tag ID and length
748 } 753 }
749} 754}
750 755
751 756
752OWaveLanManagementPacket::~OWaveLanManagementPacket() 757OWaveLanManagementPacket::~OWaveLanManagementPacket()
753{ 758{
754} 759}
755 760
756 761
757QString OWaveLanManagementPacket::managementType() const 762QString OWaveLanManagementPacket::managementType() const
758{ 763{
759 switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) ) 764 switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) )
760 { 765 {
761 case ST_ASSOC_REQUEST: return "AssociationRequest"; break; 766 case ST_ASSOC_REQUEST: return "AssociationRequest"; break;
762 case ST_ASSOC_RESPONSE: return "AssociationResponse"; break; 767 case ST_ASSOC_RESPONSE: return "AssociationResponse"; break;
763 case ST_REASSOC_REQUEST: return "ReassociationRequest"; break; 768 case ST_REASSOC_REQUEST: return "ReassociationRequest"; break;
764 case ST_REASSOC_RESPONSE: return "ReassociationResponse"; break; 769 case ST_REASSOC_RESPONSE: return "ReassociationResponse"; break;
765 case ST_PROBE_REQUEST: return "ProbeRequest"; break; 770 case ST_PROBE_REQUEST: return "ProbeRequest"; break;
766 case ST_PROBE_RESPONSE: return "ProbeResponse"; break; 771 case ST_PROBE_RESPONSE: return "ProbeResponse"; break;
767 case ST_BEACON: return "Beacon"; break; 772 case ST_BEACON: return "Beacon"; break;
768 case ST_ATIM: return "Atim"; break; 773 case ST_ATIM: return "Atim"; break;
769 case ST_DISASSOC: return "Disassociation"; break; 774 case ST_DISASSOC: return "Disassociation"; break;
770 case ST_AUTH: return "Authentication"; break; 775 case ST_AUTH: return "Authentication"; break;
771 case ST_DEAUTH: return "Deathentication"; break; 776 case ST_DEAUTH: return "Deathentication"; break;
772 default: owarn << "OWaveLanManagementPacket::managementType(): unhandled subtype " << FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) << oendl; return "Unknown"; 777 default: owarn << "OWaveLanManagementPacket::managementType(): unhandled subtype " << FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) << oendl; return "Unknown";
773 } 778 }
774} 779}
775 780
776 781
777int OWaveLanManagementPacket::beaconInterval() const 782int OWaveLanManagementPacket::beaconInterval() const
778{ 783{
779 return EXTRACT_LE_16BITS( &_body->beacon_interval ); 784 return EXTRACT_LE_16BITS( &_body->beacon_interval );
780} 785}
781 786
782 787
783int OWaveLanManagementPacket::capabilities() const 788int OWaveLanManagementPacket::capabilities() const
784{ 789{
785 return EXTRACT_LE_16BITS( &_body->capability_info ); 790 return EXTRACT_LE_16BITS( &_body->capability_info );
786} 791}
787 792
788 793
789bool OWaveLanManagementPacket::canESS() const 794bool OWaveLanManagementPacket::canESS() const
790{ 795{
791 return CAPABILITY_ESS( EXTRACT_LE_16BITS( &_body->capability_info ) ); 796 return CAPABILITY_ESS( EXTRACT_LE_16BITS( &_body->capability_info ) );
792} 797}
793 798
794 799
795bool OWaveLanManagementPacket::canIBSS() const 800bool OWaveLanManagementPacket::canIBSS() const
796{ 801{
797 return CAPABILITY_IBSS( EXTRACT_LE_16BITS( &_body->capability_info ) ); 802 return CAPABILITY_IBSS( EXTRACT_LE_16BITS( &_body->capability_info ) );
798} 803}
799 804
800 805
801bool OWaveLanManagementPacket::canCFP() const 806bool OWaveLanManagementPacket::canCFP() const
802{ 807{
803 return CAPABILITY_CFP( EXTRACT_LE_16BITS( &_body->capability_info ) ); 808 return CAPABILITY_CFP( EXTRACT_LE_16BITS( &_body->capability_info ) );
804} 809}
805 810
806 811
807bool OWaveLanManagementPacket::canCFP_REQ() const 812bool OWaveLanManagementPacket::canCFP_REQ() const
808{ 813{
809 return CAPABILITY_CFP_REQ( EXTRACT_LE_16BITS( &_body->capability_info ) ); 814 return CAPABILITY_CFP_REQ( EXTRACT_LE_16BITS( &_body->capability_info ) );
810} 815}
811 816
812 817
813bool OWaveLanManagementPacket::canPrivacy() const 818bool OWaveLanManagementPacket::canPrivacy() const
814{ 819{
815 return CAPABILITY_PRIVACY( EXTRACT_LE_16BITS( &_body->capability_info ) ); 820 return CAPABILITY_PRIVACY( EXTRACT_LE_16BITS( &_body->capability_info ) );
816} 821}
817 822
818 823
819/*====================================================================================== 824/*======================================================================================
820 * OWaveLanManagementSSID 825 * OWaveLanManagementSSID
821 *======================================================================================*/ 826 *======================================================================================*/
822 827
823OWaveLanManagementSSID::OWaveLanManagementSSID( const unsigned char* end, const struct ssid_t* data, QObject* parent ) 828OWaveLanManagementSSID::OWaveLanManagementSSID( const unsigned char* end, const struct ssid_t* data, QObject* parent )
824 :QObject( parent, "802.11 SSID" ), _data( data ) 829 :QObject( parent, "802.11 SSID" ), _data( data )
825{ 830{
826 odebug << "OWaveLanManagementSSID()" << oendl; 831 odebug << "OWaveLanManagementSSID()" << oendl;
827} 832}
828 833
@@ -1095,250 +1100,248 @@ bool OPacketCapturer::blocking() const
1095 1100
1096void OPacketCapturer::closeDumpFile() 1101void OPacketCapturer::closeDumpFile()
1097{ 1102{
1098 if ( _pcd ) 1103 if ( _pcd )
1099 { 1104 {
1100 pcap_dump_close( _pcd ); 1105 pcap_dump_close( _pcd );
1101 _pcd = 0; 1106 _pcd = 0;
1102 } 1107 }
1103 pcap_close( _pch ); 1108 pcap_close( _pch );
1104} 1109}
1105 1110
1106 1111
1107void OPacketCapturer::close() 1112void OPacketCapturer::close()
1108{ 1113{
1109 if ( _open ) 1114 if ( _open )
1110 { 1115 {
1111 if ( _sn ) 1116 if ( _sn )
1112 { 1117 {
1113 _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); 1118 _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
1114 delete _sn; 1119 delete _sn;
1115 } 1120 }
1116 closeDumpFile(); 1121 closeDumpFile();
1117 _open = false; 1122 _open = false;
1118 } 1123 }
1119 1124
1120 odebug << "OPacketCapturer::close() --- dumping capturing statistics..." << oendl; 1125 odebug << "OPacketCapturer::close() --- dumping capturing statistics..." << oendl;
1121 odebug << "--------------------------------------------------" << oendl; 1126 odebug << "--------------------------------------------------" << oendl;
1122 for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) 1127 for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it )
1123 odebug << it.key() << " = " << it.data() << oendl; 1128 odebug << it.key() << " = " << it.data() << oendl;
1124 odebug << "--------------------------------------------------" << oendl; 1129 odebug << "--------------------------------------------------" << oendl;
1125 1130
1126} 1131}
1127 1132
1128 1133
1129int OPacketCapturer::dataLink() const 1134int OPacketCapturer::dataLink() const
1130{ 1135{
1131 return pcap_datalink( _pch ); 1136 return pcap_datalink( _pch );
1132} 1137}
1133 1138
1134 1139
1135void OPacketCapturer::dump( OPacket* p ) 1140void OPacketCapturer::dump( OPacket* p )
1136{ 1141{
1137 if ( !_pcd ) 1142 if ( !_pcd )
1138 { 1143 {
1139 owarn << "OPacketCapturer::dump() - cannot dump without open capture file!" << oendl; 1144 owarn << "OPacketCapturer::dump() - cannot dump without open capture file!" << oendl;
1140 return; 1145 return;
1141 } 1146 }
1142 pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data ); 1147 pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data );
1143} 1148}
1144 1149
1145 1150
1146int OPacketCapturer::fileno() const 1151int OPacketCapturer::fileno() const
1147{ 1152{
1148 if ( _open ) 1153 if ( _open )
1149 { 1154 {
1150 return pcap_fileno( _pch ); 1155 return pcap_fileno( _pch );
1151 } 1156 }
1152 else 1157 else
1153 { 1158 {
1154 return -1; 1159 return -1;
1155 } 1160 }
1156} 1161}
1157 1162
1158 1163
1159OPacket* OPacketCapturer::next( int time ) 1164OPacket* OPacketCapturer::next( int time )
1160{ 1165{
1161 fd_set fds; 1166 fd_set fds;
1162 struct timeval tv; 1167 struct timeval tv;
1163 FD_ZERO( &fds ); 1168 FD_ZERO( &fds );
1164 FD_SET( pcap_fileno( _pch ), &fds ); 1169 FD_SET( pcap_fileno( _pch ), &fds );
1165 tv.tv_sec = time / 1000; 1170 tv.tv_sec = time / 1000;
1166 tv.tv_usec = time % 1000; 1171 tv.tv_usec = time % 1000;
1167 int retval = select( pcap_fileno( _pch )+1, &fds, NULL, NULL, &tv); 1172 int retval = select( pcap_fileno( _pch )+1, &fds, NULL, NULL, &tv);
1168 if ( retval > 0 ) // clear to read! 1173 if ( retval > 0 ) // clear to read!
1169 return next(); 1174 return next();
1170 else 1175 else
1171 return 0; 1176 return 0;
1172} 1177}
1173 1178
1174 1179
1175OPacket* OPacketCapturer::next() 1180OPacket* OPacketCapturer::next()
1176{ 1181{
1177 packetheaderstruct header; 1182 packetheaderstruct header;
1178 odebug << "==> OPacketCapturer::next()" << oendl; 1183 odebug << "==> OPacketCapturer::next()" << oendl;
1179 const unsigned char* pdata = pcap_next( _pch, &header ); 1184 const unsigned char* pdata = pcap_next( _pch, &header );
1180 odebug << "<== OPacketCapturer::next()" << oendl; 1185 odebug << "<== OPacketCapturer::next()" << oendl;
1181 1186
1182 if ( pdata && header.len ) 1187 if ( pdata && header.len )
1183 { 1188 {
1184 OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); 1189 OPacket* p = new OPacket( dataLink(), header, pdata, 0 );
1185 // packets shouldn't be inserted in the QObject child-parent hierarchy, 1190 // packets shouldn't be inserted in the QObject child-parent hierarchy,
1186 // because due to memory constraints they will be deleted as soon 1191 // because due to memory constraints they will be deleted as soon
1187 // as possible - that is right after they have been processed 1192 // as possible - that is right after they have been processed
1188 // by emit() [ see below ] 1193 // by emit() [ see below ]
1189 //TODO: make gathering statistics optional, because it takes time 1194 //TODO: make gathering statistics optional, because it takes time
1190 p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) ); 1195 p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) );
1191 #ifndef NODEBUG 1196 odebug << "OPacket::dumpStructure: " << p->dumpStructure() << oendl;
1192 p->dumpStructure( const_cast<QObjectList*>( p->children() ) );
1193 #endif
1194 return p; 1197 return p;
1195 } 1198 }
1196 else 1199 else
1197 { 1200 {
1198 owarn << "OPacketCapturer::next() - no packet received!" << oendl; 1201 owarn << "OPacketCapturer::next() - no packet received!" << oendl;
1199 return 0; 1202 return 0;
1200 } 1203 }
1201} 1204}
1202 1205
1203 1206
1204bool OPacketCapturer::open( const QString& name ) 1207bool OPacketCapturer::open( const QString& name )
1205{ 1208{
1206 if ( _open ) 1209 if ( _open )
1207 { 1210 {
1208 if ( name == _name ) // ignore opening an already openend device 1211 if ( name == _name ) // ignore opening an already openend device
1209 { 1212 {
1210 return true; 1213 return true;
1211 } 1214 }
1212 else // close the last opened device 1215 else // close the last opened device
1213 { 1216 {
1214 close(); 1217 close();
1215 } 1218 }
1216 } 1219 }
1217 1220
1218 _name = name; 1221 _name = name;
1219 1222
1220 // open libpcap 1223 // open libpcap
1221 pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] ); 1224 pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] );
1222 1225
1223 if ( !handle ) 1226 if ( !handle )
1224 { 1227 {
1225 owarn << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl; 1228 owarn << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl;
1226 return false; 1229 return false;
1227 } 1230 }
1228 1231
1229 odebug << "OPacketCapturer::open(): libpcap [" << name << "] opened successfully." << oendl; 1232 odebug << "OPacketCapturer::open(): libpcap [" << name << "] opened successfully." << oendl;
1230 _pch = handle; 1233 _pch = handle;
1231 _open = true; 1234 _open = true;
1232 _stats.clear(); 1235 _stats.clear();
1233 1236
1234 // in case we have an application object, create a socket notifier 1237 // in case we have an application object, create a socket notifier
1235 if ( qApp ) //TODO: I don't like this here... 1238 if ( qApp ) //TODO: I don't like this here...
1236 { 1239 {
1237 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); 1240 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );
1238 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); 1241 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
1239 } 1242 }
1240 1243
1241 return true; 1244 return true;
1242} 1245}
1243 1246
1244 1247
1245bool OPacketCapturer::openDumpFile( const QString& filename ) 1248bool OPacketCapturer::openDumpFile( const QString& filename )
1246{ 1249{
1247 pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) ); 1250 pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) );
1248 if ( !dump ) 1251 if ( !dump )
1249 { 1252 {
1250 owarn << "OPacketCapturer::open(): can't open dump with '" << filename << "': " << _errbuf << oendl; 1253 owarn << "OPacketCapturer::open(): can't open dump with '" << filename << "': " << _errbuf << oendl;
1251 return false; 1254 return false;
1252 } 1255 }
1253 odebug << "OPacketCapturer::open(): dump [" << filename << "] opened successfully." << oendl; 1256 odebug << "OPacketCapturer::open(): dump [" << filename << "] opened successfully." << oendl;
1254 _pcd = dump; 1257 _pcd = dump;
1255 1258
1256 return true; 1259 return true;
1257} 1260}
1258 1261
1259 1262
1260bool OPacketCapturer::open( const QFile& file ) 1263bool OPacketCapturer::open( const QFile& file )
1261{ 1264{
1262 QString name = file.name(); 1265 QString name = file.name();
1263 1266
1264 if ( _open ) 1267 if ( _open )
1265 { 1268 {
1266 close(); 1269 close();
1267 if ( name == _name ) // ignore opening an already openend device 1270 if ( name == _name ) // ignore opening an already openend device
1268 { 1271 {
1269 return true; 1272 return true;
1270 } 1273 }
1271 else // close the last opened device 1274 else // close the last opened device
1272 { 1275 {
1273 close(); 1276 close();
1274 } 1277 }
1275 } 1278 }
1276 1279
1277 _name = name; 1280 _name = name;
1278 1281
1279 pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] ); 1282 pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] );
1280 1283
1281 if ( handle ) 1284 if ( handle )
1282 { 1285 {
1283 odebug << "OPacketCapturer::open(): libpcap opened successfully." << oendl; 1286 odebug << "OPacketCapturer::open(): libpcap opened successfully." << oendl;
1284 _pch = handle; 1287 _pch = handle;
1285 _open = true; 1288 _open = true;
1286 1289
1287 // in case we have an application object, create a socket notifier 1290 // in case we have an application object, create a socket notifier
1288 if ( qApp ) 1291 if ( qApp )
1289 { 1292 {
1290 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); 1293 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );
1291 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); 1294 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
1292 } 1295 }
1293 1296
1294 return true; 1297 return true;
1295 } 1298 }
1296 else 1299 else
1297 { 1300 {
1298 odebug << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl; 1301 odebug << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl;
1299 return false; 1302 return false;
1300 } 1303 }
1301 1304
1302} 1305}
1303 1306
1304 1307
1305bool OPacketCapturer::isOpen() const 1308bool OPacketCapturer::isOpen() const
1306{ 1309{
1307 return _open; 1310 return _open;
1308} 1311}
1309 1312
1310 1313
1311void OPacketCapturer::readyToReceive() 1314void OPacketCapturer::readyToReceive()
1312{ 1315{
1313 odebug << "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" << oendl; 1316 odebug << "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" << oendl;
1314 OPacket* p = next(); 1317 OPacket* p = next();
1315 emit receivedPacket( p ); 1318 emit receivedPacket( p );
1316 // emit is synchronous - packet has been dealt with, now it's safe to delete 1319 // emit is synchronous - packet has been dealt with, now it's safe to delete
1317 delete p; 1320 delete p;
1318} 1321}
1319 1322
1320 1323
1321const QMap<QString,int>& OPacketCapturer::statistics() const 1324const QMap<QString,int>& OPacketCapturer::statistics() const
1322{ 1325{
1323 return _stats; 1326 return _stats;
1324} 1327}
1325 1328
1326 1329
1327int OPacketCapturer::snapShot() const 1330int OPacketCapturer::snapShot() const
1328{ 1331{
1329 return pcap_snapshot( _pch ); 1332 return pcap_snapshot( _pch );
1330} 1333}
1331 1334
1332 1335
1333bool OPacketCapturer::swapped() const 1336bool OPacketCapturer::swapped() const
1334{ 1337{
1335 return pcap_is_swapped( _pch ); 1338 return pcap_is_swapped( _pch );
1336} 1339}
1337 1340
1338 1341
1339QString OPacketCapturer::version() const 1342QString OPacketCapturer::version() const
1340{ 1343{
1341 return QString().sprintf( "%s.%s", pcap_major_version( _pch ), pcap_minor_version( _pch ) ); 1344 return QString().sprintf( "%d.%d", pcap_major_version( _pch ), pcap_minor_version( _pch ) );
1342} 1345}
1343 1346
1344 1347
diff --git a/libopie2/opienet/opcap.h b/libopie2/opienet/opcap.h
index f5dc5c0..b873b49 100644
--- a/libopie2/opienet/opcap.h
+++ b/libopie2/opienet/opcap.h
@@ -1,238 +1,243 @@
1/* 1/*
2                 This file is part of the Opie Project 2                 This file is part of the Opie Project
3              Copyright (C) 2003 by Michael 'Mickey' Lauer <mickey@Vanille.de> 3              Copyright (C) 2003 by Michael 'Mickey' Lauer <mickey@Vanille.de>
4 =. 4 =.
5 .=l. 5 .=l.
6           .>+-= 6           .>+-=
7 _;:,     .>    :=|. This program is free software; you can 7 _;:,     .>    :=|. This program is free software; you can
8.> <`_,   >  .   <= redistribute it and/or modify it under 8.> <`_,   >  .   <= redistribute it and/or modify it under
9:`=1 )Y*s>-.--   : the terms of the GNU Library General Public 9:`=1 )Y*s>-.--   : the terms of the GNU Library General Public
10.="- .-=="i,     .._ License as published by the Free Software 10.="- .-=="i,     .._ License as published by the Free Software
11 - .   .-<_>     .<> Foundation; either version 2 of the License, 11 - .   .-<_>     .<> Foundation; either version 2 of the License,
12     ._= =}       : or (at your option) any later version. 12     ._= =}       : or (at your option) any later version.
13    .%`+i>       _;_. 13    .%`+i>       _;_.
14    .i_,=:_.      -<s. This program is distributed in the hope that 14    .i_,=:_.      -<s. This program is distributed in the hope that
15     +  .  -:.       = it will be useful, but WITHOUT ANY WARRANTY; 15     +  .  -:.       = it will be useful, but WITHOUT ANY WARRANTY;
16    : ..    .:,     . . . without even the implied warranty of 16    : ..    .:,     . . . without even the implied warranty of
17    =_        +     =;=|` MERCHANTABILITY or FITNESS FOR A 17    =_        +     =;=|` MERCHANTABILITY or FITNESS FOR A
18  _.=:.       :    :=>`: PARTICULAR PURPOSE. See the GNU 18  _.=:.       :    :=>`: PARTICULAR PURPOSE. See the GNU
19..}^=.=       =       ; Library General Public License for more 19..}^=.=       =       ; Library General Public License for more
20++=   -.     .`     .: details. 20++=   -.     .`     .: details.
21 :     =  ...= . :.=- 21 :     =  ...= . :.=-
22 -.   .:....=;==+<; You should have received a copy of the GNU 22 -.   .:....=;==+<; You should have received a copy of the GNU
23  -_. . .   )=.  = Library General Public License along with 23  -_. . .   )=.  = Library General Public License along with
24    --        :-=` this library; see the file COPYING.LIB. 24    --        :-=` this library; see the file COPYING.LIB.
25 If not, write to the Free Software Foundation, 25 If not, write to the Free Software Foundation,
26 Inc., 59 Temple Place - Suite 330, 26 Inc., 59 Temple Place - Suite 330,
27 Boston, MA 02111-1307, USA. 27 Boston, MA 02111-1307, USA.
28 28
29*/ 29*/
30 30
31#ifndef OPCAP_H 31#ifndef OPCAP_H
32#define OPCAP_H 32#define OPCAP_H
33 33
34/* LINUX */ 34/* OPIE */
35extern "C" // work around a bpf/pcap conflict in recent headers 35#include <opie2/onetutils.h>
36{
37 #include <pcap.h>
38}
39#include <netinet/ether.h>
40#include <netinet/ip.h>
41#include <netinet/udp.h>
42#include <netinet/tcp.h>
43#include <time.h>
44 36
45/* QT */ 37/* QT */
46#include <qevent.h> 38#include <qevent.h>
47#include <qfile.h> 39#include <qfile.h>
48#include <qhostaddress.h> 40#include <qhostaddress.h>
49#include <qobject.h> 41#include <qobject.h>
50#include <qstring.h> 42#include <qstring.h>
43#include <qtextstream.h>
51#include <qmap.h> 44#include <qmap.h>
52 45
53/* OPIE */ 46/* STD */
54#include <opie2/onetutils.h> 47extern "C" // work around a bpf/pcap conflict in recent headers
48{
49 #include <pcap.h>
50}
51#include <netinet/ether.h>
52#include <netinet/ip.h>
53#include <netinet/udp.h>
54#include <netinet/tcp.h>
55#include <time.h>
55 56
56/* Custom Network Includes */ 57/* Custom Network Includes (must go here, don't reorder!) */
57#include "802_11_user.h" 58#include "802_11_user.h"
58#include "dhcp.h" 59#include "dhcp.h"
59 60
61
60/* TYPEDEFS */ 62/* TYPEDEFS */
61typedef struct timeval timevalstruct; 63typedef struct timeval timevalstruct;
62typedef struct pcap_pkthdr packetheaderstruct; 64typedef struct pcap_pkthdr packetheaderstruct;
63 65
64/* FORWARDS */ 66/* FORWARDS */
65class OPacketCapturer; 67class OPacketCapturer;
66class QSocketNotifier; 68class QSocketNotifier;
67 69
68/*====================================================================================== 70/*======================================================================================
69 * OPacket - A frame on the wire 71 * OPacket - A frame on the wire
70 *======================================================================================*/ 72 *======================================================================================*/
71 73
72/** @brief A class representing a data frame on the wire. 74/** @brief A class representing a data frame on the wire.
73 * 75 *
74 * The whole family of the packet classes are used when capturing frames from a network. 76 * The whole family of the packet classes are used when capturing frames from a network.
75 * Most standard network protocols in use share a common architecture, which mostly is 77 * Most standard network protocols in use share a common architecture, which mostly is
76 * a packet header and then the packet payload. In layered architectures, each lower layer 78 * a packet header and then the packet payload. In layered architectures, each lower layer
77 * encapsulates data from its upper layer - that is it 79 * encapsulates data from its upper layer - that is it
78 * treats the data from its upper layer as payload and prepends an own header to the packet, 80 * treats the data from its upper layer as payload and prepends an own header to the packet,
79 * which - again - is treated as the payload for the layer below. The figure below is an 81 * which - again - is treated as the payload for the layer below. The figure below is an
80 * example for how such a data frame is composed out of packets, e.g. when sending a mail. 82 * example for how such a data frame is composed out of packets, e.g. when sending a mail.
81 * 83 *
82 * <pre> 84 * <pre>
83 * | User Data | == Mail Data 85 * | User Data | == Mail Data
84 * | SMTP Header | User Data | == SMTP 86 * | SMTP Header | User Data | == SMTP
85 * | TCP Header | SMTP Header | User Data | == TCP 87 * | TCP Header | SMTP Header | User Data | == TCP
86 * | IP Header | TCP Header | SMTP Header | User Data | == IP 88 * | IP Header | TCP Header | SMTP Header | User Data | == IP
87 * | MAC Header | IP Header | TCP Header | SMTP Header | User Data | == MAC 89 * | MAC Header | IP Header | TCP Header | SMTP Header | User Data | == MAC
88 * 90 *
89 * </pre> 91 * </pre>
90 * 92 *
91 * The example is trimmed for simplicity, because the MAC (Medium Access Control) layer 93 * The example is trimmed for simplicity, because the MAC (Medium Access Control) layer
92 * also contains a few more levels of encapsulation. 94 * also contains a few more levels of encapsulation.
93 * Since the type of the payload is more or less independent from the encapsulating protocol, 95 * Since the type of the payload is more or less independent from the encapsulating protocol,
94 * the header must be inspected before attempting to decode the payload. Hence, the 96 * the header must be inspected before attempting to decode the payload. Hence, the
95 * encapsulation level varies and can't be deduced without actually looking into the packets. 97 * encapsulation level varies and can't be deduced without actually looking into the packets.
96 * 98 *
97 * For actually working with captured frames, it's useful to identify the packets via names and 99 * For actually working with captured frames, it's useful to identify the packets via names and
98 * insert them into a parent/child - relationship based on the encapsulation. This is why 100 * insert them into a parent/child - relationship based on the encapsulation. This is why
99 * all packet classes derive from QObject. The amount of overhead caused by the QObject is 101 * all packet classes derive from QObject. The amount of overhead caused by the QObject is
100 * not a problem in this case, because we're talking about a theoratical maximum of about 102 * not a problem in this case, because we're talking about a theoratical maximum of about
101 * 10 packets per captured frame. We need to stuff them into a searchable list anyway and the 103 * 10 packets per captured frame. We need to stuff them into a searchable list anyway and the
102 * QObject also cares about destroying the sub-, (child-) packets. 104 * QObject also cares about destroying the sub-, (child-) packets.
103 * 105 *
104 * This enables us to perform a simple look for packets of a certain type: 106 * This enables us to perform a simple look for packets of a certain type:
105 * @code 107 * @code
106 * OPacketCapturer* pcap = new OPacketCapturer(); 108 * OPacketCapturer* pcap = new OPacketCapturer();
107 * pcap->open( "eth0" ); 109 * pcap->open( "eth0" );
108 * OPacket* p = pcap->next(); 110 * OPacket* p = pcap->next();
109 * OIPPacket* ip = (OIPPacket*) p->child( "IP" ); // returns 0, if no such child exists 111 * OIPPacket* ip = (OIPPacket*) p->child( "IP" ); // returns 0, if no such child exists
110 * odebug << "got ip packet from " << ip->fromIPAddress().toString() << " to " << ip->toIPAddress().toString() << oendl; 112 * odebug << "got ip packet from " << ip->fromIPAddress().toString() << " to " << ip->toIPAddress().toString() << oendl;
111 * 113 *
112 */ 114 */
113 115
114class OPacket : public QObject 116class OPacket : public QObject
115{ 117{
116 Q_OBJECT 118 Q_OBJECT
117 119
118 friend class OPacketCapturer; 120 friend class OPacketCapturer;
121 friend QTextStream& operator<<( QTextStream& s, const OPacket& p );
119 122
120 public: 123 public:
121 OPacket( int datalink, packetheaderstruct, const unsigned char*, QObject* parent ); 124 OPacket( int datalink, packetheaderstruct, const unsigned char*, QObject* parent );
122 virtual ~OPacket(); 125 virtual ~OPacket();
123 126
124 timevalstruct timeval() const; 127 timevalstruct timeval() const;
125 128
126 int caplen() const; 129 int caplen() const;
127 int len() const; 130 int len() const;
128 QString dump( int = 32 ) const; 131 QString dump( int = 32 ) const;
129 132
130 void updateStats( QMap<QString,int>&, QObjectList* ); 133 void updateStats( QMap<QString,int>&, QObjectList* );
131 134
132 private: 135 private:
133 136
134 void dumpStructure( QObjectList* ); 137 QString dumpStructure() const;
135 QString _dumpStructure( QObjectList* ); 138 QString _dumpStructure( QObjectList* ) const;
136 139
137 private: 140 private:
138 const packetheaderstruct _hdr; // pcap packet header 141 const packetheaderstruct _hdr; // pcap packet header
139 const unsigned char* _data; // pcap packet data 142 const unsigned char* _data; // pcap packet data
140 const unsigned char* _end; // end of pcap packet data 143 const unsigned char* _end; // end of pcap packet data
141}; 144};
142 145
146QTextStream& operator<<( QTextStream& s, const OPacket& p );
147
143/*====================================================================================== 148/*======================================================================================
144 * OEthernetPacket - DLT_EN10MB frame 149 * OEthernetPacket - DLT_EN10MB frame
145 *======================================================================================*/ 150 *======================================================================================*/
146 151
147class OEthernetPacket : public QObject 152class OEthernetPacket : public QObject
148{ 153{
149 Q_OBJECT 154 Q_OBJECT
150 155
151 public: 156 public:
152 OEthernetPacket( const unsigned char*, const struct ether_header*, QObject* parent = 0 ); 157 OEthernetPacket( const unsigned char*, const struct ether_header*, QObject* parent = 0 );
153 virtual ~OEthernetPacket(); 158 virtual ~OEthernetPacket();
154 159
155 OMacAddress sourceAddress() const; 160 OMacAddress sourceAddress() const;
156 OMacAddress destinationAddress() const; 161 OMacAddress destinationAddress() const;
157 int type() const; 162 int type() const;
158 163
159 private: 164 private:
160 const struct ether_header* _ether; 165 const struct ether_header* _ether;
161}; 166};
162 167
163/*====================================================================================== 168/*======================================================================================
164 * OPrismHeaderPacket - DLT_PRISM_HEADER frame 169 * OPrismHeaderPacket - DLT_PRISM_HEADER frame
165 *======================================================================================*/ 170 *======================================================================================*/
166 171
167class OPrismHeaderPacket : public QObject 172class OPrismHeaderPacket : public QObject
168{ 173{
169 Q_OBJECT 174 Q_OBJECT
170 175
171 public: 176 public:
172 OPrismHeaderPacket( const unsigned char*, const struct prism_hdr*, QObject* parent = 0 ); 177 OPrismHeaderPacket( const unsigned char*, const struct prism_hdr*, QObject* parent = 0 );
173 virtual ~OPrismHeaderPacket(); 178 virtual ~OPrismHeaderPacket();
174 179
175 unsigned int signalStrength() const; 180 unsigned int signalStrength() const;
176 181
177 private: 182 private:
178 const struct prism_hdr* _header; 183 const struct prism_hdr* _header;
179}; 184};
180 185
181/*====================================================================================== 186/*======================================================================================
182 * OWaveLanPacket - DLT_IEEE802_11 frame 187 * OWaveLanPacket - DLT_IEEE802_11 frame
183 *======================================================================================*/ 188 *======================================================================================*/
184 189
185class OWaveLanPacket : public QObject 190class OWaveLanPacket : public QObject
186{ 191{
187 Q_OBJECT 192 Q_OBJECT
188 193
189 public: 194 public:
190 OWaveLanPacket( const unsigned char*, const struct ieee_802_11_header*, QObject* parent = 0 ); 195 OWaveLanPacket( const unsigned char*, const struct ieee_802_11_header*, QObject* parent = 0 );
191 virtual ~OWaveLanPacket(); 196 virtual ~OWaveLanPacket();
192 197
193 int duration() const; 198 int duration() const;
194 bool fromDS() const; 199 bool fromDS() const;
195 bool toDS() const; 200 bool toDS() const;
196 virtual OMacAddress macAddress1() const; 201 virtual OMacAddress macAddress1() const;
197 virtual OMacAddress macAddress2() const; 202 virtual OMacAddress macAddress2() const;
198 virtual OMacAddress macAddress3() const; 203 virtual OMacAddress macAddress3() const;
199 virtual OMacAddress macAddress4() const; 204 virtual OMacAddress macAddress4() const;
200 bool usesPowerManagement() const; 205 bool usesPowerManagement() const;
201 int type() const; 206 int type() const;
202 int subType() const; 207 int subType() const;
203 int version() const; 208 int version() const;
204 bool usesWep() const; 209 bool usesWep() const;
205 210
206 private: 211 private:
207 const struct ieee_802_11_header* _wlanhdr; 212 const struct ieee_802_11_header* _wlanhdr;
208}; 213};
209 214
210 215
211/*====================================================================================== 216/*======================================================================================
212 * OWaveLanManagementPacket - type: management (T_MGMT) 217 * OWaveLanManagementPacket - type: management (T_MGMT)
213 *======================================================================================*/ 218 *======================================================================================*/
214 219
215class OWaveLanManagementPacket : public QObject 220class OWaveLanManagementPacket : public QObject
216{ 221{
217 Q_OBJECT 222 Q_OBJECT
218 223
219 public: 224 public:
220 OWaveLanManagementPacket( const unsigned char*, const struct ieee_802_11_mgmt_header*, OWaveLanPacket* parent = 0 ); 225 OWaveLanManagementPacket( const unsigned char*, const struct ieee_802_11_mgmt_header*, OWaveLanPacket* parent = 0 );
221 virtual ~OWaveLanManagementPacket(); 226 virtual ~OWaveLanManagementPacket();
222 227
223 QString managementType() const; 228 QString managementType() const;
224 229
225 int beaconInterval() const; 230 int beaconInterval() const;
226 int capabilities() const; // generic 231 int capabilities() const; // generic
227 232
228 bool canESS() const; 233 bool canESS() const;
229 bool canIBSS() const; 234 bool canIBSS() const;
230 bool canCFP() const; 235 bool canCFP() const;
231 bool canCFP_REQ() const; 236 bool canCFP_REQ() const;
232 bool canPrivacy() const; 237 bool canPrivacy() const;
233 238
234 private: 239 private:
235 const struct ieee_802_11_mgmt_header* _header; 240 const struct ieee_802_11_mgmt_header* _header;
236 const struct ieee_802_11_mgmt_body* _body; 241 const struct ieee_802_11_mgmt_body* _body;
237}; 242};
238 243