-rw-r--r-- | libopie2/opienet/opcap.cpp | 2637 |
1 files changed, 1317 insertions, 1320 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp index 635224c..e9b3b2c 100644 --- a/libopie2/opienet/opcap.cpp +++ b/libopie2/opienet/opcap.cpp | |||
@@ -1,1320 +1,1317 @@ | |||
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 | /* OPIE */ | 31 | /* OPIE */ |
32 | #include <opie2/opcap.h> | 32 | #include <opie2/opcap.h> |
33 | 33 | #include <opie2/odebug.h> | |
34 | /* QT */ | 34 | |
35 | #include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects) | 35 | /* QT */ |
36 | #include <qsocketnotifier.h> | 36 | #include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects) |
37 | #include <qobjectlist.h> | 37 | #include <qsocketnotifier.h> |
38 | 38 | #include <qobjectlist.h> | |
39 | /* SYSTEM */ | 39 | |
40 | #include <sys/time.h> | 40 | /* SYSTEM */ |
41 | #include <sys/types.h> | 41 | #include <sys/time.h> |
42 | #include <unistd.h> | 42 | #include <sys/types.h> |
43 | 43 | #include <unistd.h> | |
44 | /* LOCAL */ | 44 | |
45 | #include "udp_ports.h" | 45 | /* LOCAL */ |
46 | 46 | #include "udp_ports.h" | |
47 | /*====================================================================================== | 47 | |
48 | * OPacket | 48 | /*====================================================================================== |
49 | *======================================================================================*/ | 49 | * OPacket |
50 | 50 | *======================================================================================*/ | |
51 | OPacket::OPacket( int datalink, packetheaderstruct header, const unsigned char* data, QObject* parent ) | 51 | |
52 | :QObject( parent, "Generic" ), _hdr( header ), _data( data ) | 52 | OPacket::OPacket( int datalink, packetheaderstruct header, const unsigned char* data, QObject* parent ) |
53 | { | 53 | :QObject( parent, "Generic" ), _hdr( header ), _data( data ) |
54 | //qDebug( "OPacket::OPacket(): (Len %d, CapLen %d)" /*, ctime((const time_t*) header.ts.tv_sec)*/, header.len, header.caplen ); | 54 | { |
55 | 55 | //qDebug( "OPacket::OPacket(): (Len %d, CapLen %d)" /*, ctime((const time_t*) header.ts.tv_sec)*/, header.len, header.caplen ); | |
56 | _end = (unsigned char*) data + header.len; | 56 | |
57 | //qDebug( "OPacket::data @ %0x, end @ %0x", data, _end ); | 57 | _end = (unsigned char*) data + header.len; |
58 | 58 | //qDebug( "OPacket::data @ %0x, end @ %0x", data, _end ); | |
59 | switch ( datalink ) | 59 | |
60 | { | 60 | switch ( datalink ) |
61 | case DLT_EN10MB: | 61 | { |
62 | qDebug( "OPacket::OPacket(): Received Packet. Datalink = ETHERNET" ); | 62 | case DLT_EN10MB: |
63 | new OEthernetPacket( _end, (const struct ether_header*) data, this ); | 63 | odebug << "OPacket::OPacket(): Received Packet. Datalink = ETHERNET" << oendl; |
64 | break; | 64 | new OEthernetPacket( _end, (const struct ether_header*) data, this ); |
65 | 65 | break; | |
66 | case DLT_IEEE802_11: | 66 | |
67 | qDebug( "OPacket::OPacket(): Received Packet. Datalink = IEEE802.11" ); | 67 | case DLT_IEEE802_11: |
68 | new OWaveLanPacket( _end, (const struct ieee_802_11_header*) data, this ); | 68 | odebug << "OPacket::OPacket(): Received Packet. Datalink = IEEE802.11" << oendl; |
69 | break; | 69 | new OWaveLanPacket( _end, (const struct ieee_802_11_header*) data, this ); |
70 | 70 | break; | |
71 | case DLT_PRISM_HEADER: | 71 | |
72 | qDebug( "OPacket::OPacket(): Received Packet. Datalink = PRISM_HEADER" ); | 72 | case DLT_PRISM_HEADER: |
73 | new OPrismHeaderPacket( _end, (const struct prism_hdr*) (unsigned char*) data, this ); | 73 | odebug << "OPacket::OPacket(): Received Packet. Datalink = PRISM_HEADER" << oendl; |
74 | break; | 74 | new OPrismHeaderPacket( _end, (const struct prism_hdr*) (unsigned char*) data, this ); |
75 | 75 | break; | |
76 | default: | 76 | |
77 | qWarning( "OPacket::OPacket(): Received Packet over unsupported datalink (type %d)!", datalink ); | 77 | default: |
78 | } | 78 | owarn << "OPacket::OPacket(): Received Packet over unsupported datalink, type " << datalink << "!" << oendl; |
79 | } | 79 | } |
80 | 80 | } | |
81 | 81 | ||
82 | OPacket::~OPacket() | 82 | |
83 | { | 83 | OPacket::~OPacket() |
84 | } | 84 | { |
85 | 85 | } | |
86 | 86 | ||
87 | timevalstruct OPacket::timeval() const | 87 | |
88 | { | 88 | timevalstruct OPacket::timeval() const |
89 | return _hdr.ts; | 89 | { |
90 | } | 90 | return _hdr.ts; |
91 | 91 | } | |
92 | 92 | ||
93 | int OPacket::caplen() const | 93 | |
94 | { | 94 | int OPacket::caplen() const |
95 | return _hdr.caplen; | 95 | { |
96 | } | 96 | return _hdr.caplen; |
97 | 97 | } | |
98 | 98 | ||
99 | void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l ) | 99 | |
100 | { | 100 | void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l ) |
101 | if (!l) return; | 101 | { |
102 | QObject* o = l->first(); | 102 | if (!l) return; |
103 | while ( o ) | 103 | QObject* o = l->first(); |
104 | { | 104 | while ( o ) |
105 | stats[o->name()]++; | 105 | { |
106 | updateStats( stats, const_cast<QObjectList*>( o->children() ) ); | 106 | stats[o->name()]++; |
107 | o = l->next(); | 107 | updateStats( stats, const_cast<QObjectList*>( o->children() ) ); |
108 | } | 108 | o = l->next(); |
109 | } | 109 | } |
110 | 110 | } | |
111 | 111 | ||
112 | void OPacket::dumpStructure( QObjectList* l ) | 112 | |
113 | { | 113 | void OPacket::dumpStructure( QObjectList* l ) |
114 | QString packetString( "[ |" + _dumpStructure( l ) + " ]" ); | 114 | { |
115 | qDebug( "OPacket::dumpStructure: %s", (const char*) packetString ); | 115 | QString packetString( "[ |" + _dumpStructure( l ) + " ]" ); |
116 | } | 116 | odebug << "OPacket::dumpStructure: " << packetString << oendl; |
117 | 117 | } | |
118 | 118 | ||
119 | QString OPacket::_dumpStructure( QObjectList* l ) | 119 | |
120 | { | 120 | QString OPacket::_dumpStructure( QObjectList* l ) |
121 | if (!l) return QString::null; | 121 | { |
122 | QObject* o = l->first(); | 122 | if (!l) return QString::null; |
123 | QString str(" "); | 123 | QObject* o = l->first(); |
124 | 124 | QString str(" "); | |
125 | while ( o ) | 125 | |
126 | { | 126 | while ( o ) |
127 | str.append( o->name() ); | 127 | { |
128 | str.append( " |" ); | 128 | str.append( o->name() ); |
129 | str += _dumpStructure( const_cast<QObjectList*>( o->children() ) ); | 129 | str.append( " |" ); |
130 | o = l->next(); | 130 | str += _dumpStructure( const_cast<QObjectList*>( o->children() ) ); |
131 | } | 131 | o = l->next(); |
132 | return str; | 132 | } |
133 | } | 133 | return str; |
134 | 134 | } | |
135 | QString OPacket::dump( int bpl ) const | 135 | |
136 | { | 136 | QString OPacket::dump( int bpl ) const |
137 | static int index = 0; | 137 | { |
138 | index++; | 138 | static int index = 0; |
139 | int len = _hdr.caplen; | 139 | index++; |
140 | QString str; | 140 | int len = _hdr.caplen; |
141 | str.sprintf( "\n<----- Packet #%04d Len = 0x%X (%d) ----->\n\n", index, len, len ); | 141 | QString str; |
142 | str.append( "0000: " ); | 142 | str.sprintf( "\n<----- Packet #%04d Len = 0x%X (%d) ----->\n\n", index, len, len ); |
143 | QString tmp; | 143 | str.append( "0000: " ); |
144 | QString bytes; | 144 | QString tmp; |
145 | QString chars; | 145 | QString bytes; |
146 | 146 | QString chars; | |
147 | for ( int i = 0; i < len; ++i ) | 147 | |
148 | { | 148 | for ( int i = 0; i < len; ++i ) |
149 | tmp.sprintf( "%02X ", _data[i] ); bytes.append( tmp ); | 149 | { |
150 | if ( (_data[i] > 31) && (_data[i]<128) ) chars.append( _data[i] ); | 150 | tmp.sprintf( "%02X ", _data[i] ); bytes.append( tmp ); |
151 | else chars.append( '.' ); | 151 | if ( (_data[i] > 31) && (_data[i]<128) ) chars.append( _data[i] ); |
152 | 152 | else chars.append( '.' ); | |
153 | if ( !((i+1) % bpl) ) | 153 | |
154 | { | 154 | if ( !((i+1) % bpl) ) |
155 | str.append( bytes ); | 155 | { |
156 | str.append( ' ' ); | 156 | str.append( bytes ); |
157 | str.append( chars ); | 157 | str.append( ' ' ); |
158 | str.append( '\n' ); | 158 | str.append( chars ); |
159 | tmp.sprintf( "%04X: ", i+1 ); str.append( tmp ); | 159 | str.append( '\n' ); |
160 | bytes = ""; | 160 | tmp.sprintf( "%04X: ", i+1 ); str.append( tmp ); |
161 | chars = ""; | 161 | bytes = ""; |
162 | } | 162 | chars = ""; |
163 | 163 | } | |
164 | } | 164 | |
165 | if ( (len % bpl) ) | 165 | } |
166 | { | 166 | if ( (len % bpl) ) |
167 | str.append( bytes.leftJustify( 1 + 3*bpl ) ); | 167 | { |
168 | str.append( chars ); | 168 | str.append( bytes.leftJustify( 1 + 3*bpl ) ); |
169 | } | 169 | str.append( chars ); |
170 | str.append( '\n' ); | 170 | } |
171 | return str; | 171 | str.append( '\n' ); |
172 | } | 172 | return str; |
173 | 173 | } | |
174 | 174 | ||
175 | int OPacket::len() const | 175 | |
176 | { | 176 | int OPacket::len() const |
177 | return _hdr.len; | 177 | { |
178 | } | 178 | return _hdr.len; |
179 | 179 | } | |
180 | 180 | ||
181 | /*====================================================================================== | 181 | |
182 | * OEthernetPacket | 182 | /*====================================================================================== |
183 | *======================================================================================*/ | 183 | * OEthernetPacket |
184 | 184 | *======================================================================================*/ | |
185 | OEthernetPacket::OEthernetPacket( const unsigned char* end, const struct ether_header* data, QObject* parent ) | 185 | |
186 | :QObject( parent, "Ethernet" ), _ether( data ) | 186 | OEthernetPacket::OEthernetPacket( const unsigned char* end, const struct ether_header* data, QObject* parent ) |
187 | { | 187 | :QObject( parent, "Ethernet" ), _ether( data ) |
188 | 188 | { | |
189 | qDebug( "Source = %s", (const char*) sourceAddress().toString() ); | 189 | |
190 | qDebug( "Destination = %s", (const char*) destinationAddress().toString() ); | 190 | odebug << "Source = " << sourceAddress().toString(); |
191 | 191 | odebug << "Destination = " << destinationAddress().toString(); | |
192 | if ( sourceAddress() == OMacAddress::broadcast ) | 192 | |
193 | qDebug( "Source is broadcast address" ); | 193 | if ( sourceAddress() == OMacAddress::broadcast ) |
194 | if ( destinationAddress() == OMacAddress::broadcast ) | 194 | odebug << "Source is broadcast address" << oendl; |
195 | qDebug( "Destination is broadcast address" ); | 195 | if ( destinationAddress() == OMacAddress::broadcast ) |
196 | 196 | odebug << "Destination is broadcast address" << oendl; | |
197 | switch ( type() ) | 197 | |
198 | { | 198 | switch ( type() ) |
199 | case ETHERTYPE_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break; | 199 | { |
200 | case ETHERTYPE_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break; | 200 | case ETHERTYPE_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break; |
201 | case ETHERTYPE_REVARP: { qDebug( "OPacket::OPacket(): Received Ethernet Packet : Type = RARP" ); break; } | 201 | case ETHERTYPE_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break; |
202 | default: qDebug( "OPacket::OPacket(): Received Ethernet Packet : Type = UNKNOWN" ); | 202 | case ETHERTYPE_REVARP: { odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = RARP" << oendl; break; } |
203 | } | 203 | default: odebug << "OPacket::OPacket(): Received Ethernet Packet : Type = UNKNOWN" << oendl; |
204 | 204 | } | |
205 | } | 205 | |
206 | 206 | } | |
207 | 207 | ||
208 | OEthernetPacket::~OEthernetPacket() | 208 | |
209 | { | 209 | OEthernetPacket::~OEthernetPacket() |
210 | } | 210 | { |
211 | 211 | } | |
212 | 212 | ||
213 | OMacAddress OEthernetPacket::sourceAddress() const | 213 | |
214 | { | 214 | OMacAddress OEthernetPacket::sourceAddress() const |
215 | return OMacAddress( _ether->ether_shost ); | 215 | { |
216 | } | 216 | return OMacAddress( _ether->ether_shost ); |
217 | 217 | } | |
218 | 218 | ||
219 | OMacAddress OEthernetPacket::destinationAddress() const | 219 | |
220 | { | 220 | OMacAddress OEthernetPacket::destinationAddress() const |
221 | return OMacAddress( _ether->ether_dhost ); | 221 | { |
222 | } | 222 | return OMacAddress( _ether->ether_dhost ); |
223 | 223 | } | |
224 | int OEthernetPacket::type() const | 224 | |
225 | { | 225 | int OEthernetPacket::type() const |
226 | return ntohs( _ether->ether_type ); | 226 | { |
227 | } | 227 | return ntohs( _ether->ether_type ); |
228 | 228 | } | |
229 | 229 | ||
230 | /*====================================================================================== | 230 | |
231 | * OIPPacket | 231 | /*====================================================================================== |
232 | *======================================================================================*/ | 232 | * OIPPacket |
233 | 233 | *======================================================================================*/ | |
234 | 234 | ||
235 | OIPPacket::OIPPacket( const unsigned char* end, const struct iphdr* data, QObject* parent ) | 235 | |
236 | :QObject( parent, "IP" ), _iphdr( data ) | 236 | OIPPacket::OIPPacket( const unsigned char* end, const struct iphdr* data, QObject* parent ) |
237 | { | 237 | :QObject( parent, "IP" ), _iphdr( data ) |
238 | qDebug( "OIPPacket::OIPPacket(): decoding IP header..." ); | 238 | { |
239 | 239 | odebug << "OIPPacket::OIPPacket(): decoding IP header..." << oendl; | |
240 | //qDebug( "FromAddress: %s", (const char*) inet_ntoa( *src ) ); | 240 | |
241 | //qDebug( " ToAddress: %s", (const char*) inet_ntoa( *dst ) ); | 241 | odebug << "FromAddress = " << fromIPAddress().toString(); |
242 | 242 | odebug << " toAddress = " << toIPAddress().toString(); | |
243 | qDebug( "FromAddress: %s", (const char*) fromIPAddress().toString() ); | 243 | |
244 | qDebug( " toAddress: %s", (const char*) toIPAddress().toString() ); | 244 | switch ( protocol() ) |
245 | 245 | { | |
246 | switch ( protocol() ) | 246 | case IPPROTO_UDP: new OUDPPacket( end, (const struct udphdr*) (data+1), this ); break; |
247 | { | 247 | case IPPROTO_TCP: new OTCPPacket( end, (const struct tcphdr*) (data+1), this ); break; |
248 | case IPPROTO_UDP: new OUDPPacket( end, (const struct udphdr*) (data+1), this ); break; | 248 | default: odebug << "OIPPacket::OIPPacket(): unknown IP protocol, type = " << protocol() << oendl; |
249 | case IPPROTO_TCP: new OTCPPacket( end, (const struct tcphdr*) (data+1), this ); break; | 249 | } |
250 | default: qDebug( "OIPPacket::OIPPacket(): unknown IP protocol type = %d", protocol() ); | 250 | |
251 | } | 251 | } |
252 | 252 | ||
253 | } | 253 | OIPPacket::~OIPPacket() |
254 | 254 | { | |
255 | OIPPacket::~OIPPacket() | 255 | } |
256 | { | 256 | |
257 | } | 257 | |
258 | 258 | QHostAddress OIPPacket::fromIPAddress() const | |
259 | 259 | { | |
260 | QHostAddress OIPPacket::fromIPAddress() const | 260 | return EXTRACT_32BITS( &_iphdr->saddr ); |
261 | { | 261 | } |
262 | return EXTRACT_32BITS( &_iphdr->saddr ); | 262 | |
263 | } | 263 | |
264 | 264 | QHostAddress OIPPacket::toIPAddress() const | |
265 | 265 | { | |
266 | QHostAddress OIPPacket::toIPAddress() const | 266 | return EXTRACT_32BITS( &_iphdr->saddr ); |
267 | { | 267 | } |
268 | return EXTRACT_32BITS( &_iphdr->saddr ); | 268 | |
269 | } | 269 | |
270 | 270 | int OIPPacket::tos() const | |
271 | 271 | { | |
272 | int OIPPacket::tos() const | 272 | return _iphdr->tos; |
273 | { | 273 | } |
274 | return _iphdr->tos; | 274 | |
275 | } | 275 | |
276 | 276 | int OIPPacket::len() const | |
277 | 277 | { | |
278 | int OIPPacket::len() const | 278 | return EXTRACT_16BITS( &_iphdr->tot_len ); |
279 | { | 279 | } |
280 | return EXTRACT_16BITS( &_iphdr->tot_len ); | 280 | |
281 | } | 281 | |
282 | 282 | int OIPPacket::id() const | |
283 | 283 | { | |
284 | int OIPPacket::id() const | 284 | return EXTRACT_16BITS( &_iphdr->id ); |
285 | { | 285 | } |
286 | return EXTRACT_16BITS( &_iphdr->id ); | 286 | |
287 | } | 287 | |
288 | 288 | int OIPPacket::offset() const | |
289 | 289 | { | |
290 | int OIPPacket::offset() const | 290 | return EXTRACT_16BITS( &_iphdr->frag_off ); |
291 | { | 291 | } |
292 | return EXTRACT_16BITS( &_iphdr->frag_off ); | 292 | |
293 | } | 293 | |
294 | 294 | int OIPPacket::ttl() const | |
295 | 295 | { | |
296 | int OIPPacket::ttl() const | 296 | return _iphdr->ttl; |
297 | { | 297 | } |
298 | return _iphdr->ttl; | 298 | |
299 | } | 299 | |
300 | 300 | int OIPPacket::protocol() const | |
301 | 301 | { | |
302 | int OIPPacket::protocol() const | 302 | return _iphdr->protocol; |
303 | { | 303 | } |
304 | return _iphdr->protocol; | 304 | |
305 | } | 305 | |
306 | 306 | int OIPPacket::checksum() const | |
307 | 307 | { | |
308 | int OIPPacket::checksum() const | 308 | return EXTRACT_16BITS( &_iphdr->check ); |
309 | { | 309 | } |
310 | return EXTRACT_16BITS( &_iphdr->check ); | 310 | |
311 | } | 311 | /*====================================================================================== |
312 | 312 | * OARPPacket | |
313 | /*====================================================================================== | 313 | *======================================================================================*/ |
314 | * OARPPacket | 314 | |
315 | *======================================================================================*/ | 315 | |
316 | 316 | OARPPacket::OARPPacket( const unsigned char* end, const struct myarphdr* data, QObject* parent ) | |
317 | 317 | :QObject( parent, "ARP" ), _arphdr( data ) | |
318 | OARPPacket::OARPPacket( const unsigned char* end, const struct myarphdr* data, QObject* parent ) | 318 | { |
319 | :QObject( parent, "ARP" ), _arphdr( data ) | 319 | odebug << "OARPPacket::OARPPacket(): decoding ARP header..." << oendl; |
320 | { | 320 | odebug << "ARP type seems to be " << EXTRACT_16BITS( &_arphdr->ar_op ) << " = " << type() << oendl; |
321 | qDebug( "OARPPacket::OARPPacket(): decoding ARP header..." ); | 321 | odebug << "Sender: MAC " << senderMacAddress().toString() << " = IP " << senderIPV4Address().toString() << oendl; |
322 | qDebug( "ARP type seems to be %02d - '%s'", EXTRACT_16BITS( &_arphdr->ar_op ), (const char*) type() ); | 322 | odebug << "Target: MAC " << targetMacAddress().toString() << " = IP " << targetIPV4Address().toString() << oendl; |
323 | qDebug( "Sender: MAC %s = IP %s", (const char*) senderMacAddress().toString(), (const char*) senderIPV4Address().toString() ); | 323 | } |
324 | qDebug( "Target: MAC %s = IP %s", (const char*) targetMacAddress().toString(), (const char*) targetIPV4Address().toString() ); | 324 | |
325 | } | 325 | |
326 | 326 | OARPPacket::~OARPPacket() | |
327 | 327 | { | |
328 | OARPPacket::~OARPPacket() | 328 | } |
329 | { | 329 | |
330 | } | 330 | |
331 | 331 | QString OARPPacket::type() const | |
332 | 332 | { | |
333 | QString OARPPacket::type() const | 333 | switch ( EXTRACT_16BITS( &_arphdr->ar_op ) ) |
334 | { | 334 | { |
335 | switch ( EXTRACT_16BITS( &_arphdr->ar_op ) ) | 335 | case 1: return "REQUEST"; |
336 | { | 336 | case 2: return "REPLY"; |
337 | case 1: return "REQUEST"; | 337 | case 3: return "RREQUEST"; |
338 | case 2: return "REPLY"; | 338 | case 4: return "RREPLY"; |
339 | case 3: return "RREQUEST"; | 339 | case 8: return "InREQUEST"; |
340 | case 4: return "RREPLY"; | 340 | case 9: return "InREPLY"; |
341 | case 8: return "InREQUEST"; | 341 | case 10: return "NAK"; |
342 | case 9: return "InREPLY"; | 342 | default: qWarning( "OARPPacket::type(): invalid ARP type!" ); return "<unknown>"; |
343 | case 10: return "NAK"; | 343 | } |
344 | default: qWarning( "OARPPacket::type(): invalid ARP type!" ); return "<unknown>"; | 344 | } |
345 | } | 345 | |
346 | } | 346 | |
347 | 347 | QHostAddress OARPPacket::senderIPV4Address() const | |
348 | 348 | { | |
349 | QHostAddress OARPPacket::senderIPV4Address() const | 349 | return EXTRACT_32BITS( &_arphdr->ar_sip ); |
350 | { | 350 | } |
351 | return EXTRACT_32BITS( &_arphdr->ar_sip ); | 351 | |
352 | } | 352 | |
353 | 353 | QHostAddress OARPPacket::targetIPV4Address() const | |
354 | 354 | { | |
355 | QHostAddress OARPPacket::targetIPV4Address() const | 355 | return EXTRACT_32BITS( &_arphdr->ar_tip ); |
356 | { | 356 | } |
357 | return EXTRACT_32BITS( &_arphdr->ar_tip ); | 357 | |
358 | } | 358 | |
359 | 359 | OMacAddress OARPPacket::senderMacAddress() const | |
360 | 360 | { | |
361 | OMacAddress OARPPacket::senderMacAddress() const | 361 | return OMacAddress( _arphdr->ar_sha ); |
362 | { | 362 | } |
363 | return OMacAddress( _arphdr->ar_sha ); | 363 | |
364 | } | 364 | |
365 | 365 | OMacAddress OARPPacket::targetMacAddress() const | |
366 | 366 | { | |
367 | OMacAddress OARPPacket::targetMacAddress() const | 367 | return OMacAddress( _arphdr->ar_tha ); |
368 | { | 368 | } |
369 | return OMacAddress( _arphdr->ar_tha ); | 369 | |
370 | } | 370 | |
371 | 371 | /*====================================================================================== | |
372 | 372 | * OUDPPacket | |
373 | /*====================================================================================== | 373 | *======================================================================================*/ |
374 | * OUDPPacket | 374 | |
375 | *======================================================================================*/ | 375 | |
376 | 376 | OUDPPacket::OUDPPacket( const unsigned char* end, const struct udphdr* data, QObject* parent ) | |
377 | 377 | :QObject( parent, "UDP" ), _udphdr( data ) | |
378 | OUDPPacket::OUDPPacket( const unsigned char* end, const struct udphdr* data, QObject* parent ) | 378 | |
379 | :QObject( parent, "UDP" ), _udphdr( data ) | 379 | { |
380 | 380 | odebug << "OUDPPacket::OUDPPacket(): decoding UDP header..." << oendl; | |
381 | { | 381 | odebug << "fromPort = " << fromPort() << oendl; |
382 | qDebug( "OUDPPacket::OUDPPacket(): decoding UDP header..." ); | 382 | odebug << " toPort = " << toPort() << oendl; |
383 | qDebug( "fromPort = %d", fromPort() ); | 383 | |
384 | qDebug( " toPort = %d", toPort() ); | 384 | // TODO: Make this a case or a hash if we know more udp protocols |
385 | 385 | ||
386 | // TODO: Make this a case or a hash if we know more udp protocols | 386 | if ( fromPort() == UDP_PORT_BOOTPS || fromPort() == UDP_PORT_BOOTPC || |
387 | 387 | toPort() == UDP_PORT_BOOTPS || toPort() == UDP_PORT_BOOTPC ) | |
388 | if ( fromPort() == UDP_PORT_BOOTPS || fromPort() == UDP_PORT_BOOTPC || | 388 | { |
389 | toPort() == UDP_PORT_BOOTPS || toPort() == UDP_PORT_BOOTPC ) | 389 | odebug << "seems to be part of a DHCP conversation => creating DHCP packet." << oendl; |
390 | { | 390 | new ODHCPPacket( end, (const struct dhcp_packet*) (data+1), this ); |
391 | qDebug( "seems to be part of a DHCP conversation => creating DHCP packet." ); | 391 | } |
392 | new ODHCPPacket( end, (const struct dhcp_packet*) (data+1), this ); | 392 | } |
393 | } | 393 | |
394 | } | 394 | |
395 | 395 | OUDPPacket::~OUDPPacket() | |
396 | 396 | { | |
397 | OUDPPacket::~OUDPPacket() | 397 | } |
398 | { | 398 | |
399 | } | 399 | |
400 | 400 | int OUDPPacket::fromPort() const | |
401 | 401 | { | |
402 | int OUDPPacket::fromPort() const | 402 | return EXTRACT_16BITS( &_udphdr->source ); |
403 | { | 403 | } |
404 | return EXTRACT_16BITS( &_udphdr->source ); | 404 | |
405 | } | 405 | |
406 | 406 | int OUDPPacket::toPort() const | |
407 | 407 | { | |
408 | int OUDPPacket::toPort() const | 408 | return EXTRACT_16BITS( &_udphdr->dest ); |
409 | { | 409 | } |
410 | return EXTRACT_16BITS( &_udphdr->dest ); | 410 | |
411 | } | 411 | |
412 | 412 | int OUDPPacket::length() const | |
413 | 413 | { | |
414 | int OUDPPacket::length() const | 414 | return EXTRACT_16BITS( &_udphdr->len ); |
415 | { | 415 | } |
416 | return EXTRACT_16BITS( &_udphdr->len ); | 416 | |
417 | } | 417 | |
418 | 418 | int OUDPPacket::checksum() const | |
419 | 419 | { | |
420 | int OUDPPacket::checksum() const | 420 | return EXTRACT_16BITS( &_udphdr->check ); |
421 | { | 421 | } |
422 | return EXTRACT_16BITS( &_udphdr->check ); | 422 | |
423 | } | 423 | |
424 | 424 | /*====================================================================================== | |
425 | 425 | * ODHCPPacket | |
426 | /*====================================================================================== | 426 | *======================================================================================*/ |
427 | * ODHCPPacket | 427 | |
428 | *======================================================================================*/ | 428 | |
429 | 429 | ODHCPPacket::ODHCPPacket( const unsigned char* end, const struct dhcp_packet* data, QObject* parent ) | |
430 | 430 | :QObject( parent, "DHCP" ), _dhcphdr( data ) | |
431 | ODHCPPacket::ODHCPPacket( const unsigned char* end, const struct dhcp_packet* data, QObject* parent ) | 431 | |
432 | :QObject( parent, "DHCP" ), _dhcphdr( data ) | 432 | { |
433 | 433 | odebug << "ODHCPPacket::ODHCPPacket(): decoding DHCP information..." << oendl; | |
434 | { | 434 | odebug << "DHCP opcode seems to be " << _dhcphdr->op << ": " << ( isRequest() ? "REQUEST" : "REPLY" ) << oendl; |
435 | qDebug( "ODHCPPacket::ODHCPPacket(): decoding DHCP information..." ); | 435 | odebug << "clientAddress = " << clientAddress().toString() << oendl; |
436 | qDebug( "DHCP opcode seems to be %02d - '%s'", _dhcphdr->op, isRequest() ? "REQUEST" : "REPLY" ); | 436 | odebug << " yourAddress = " << yourAddress().toString() << oendl; |
437 | qDebug( "clientAddress: %s", (const char*) clientAddress().toString() ); | 437 | odebug << "serverAddress = " << serverAddress().toString() << oendl; |
438 | qDebug( " yourAddress: %s", (const char*) yourAddress().toString() ); | 438 | odebug << " relayAddress = " << relayAddress().toString() << oendl; |
439 | qDebug( "serverAddress: %s", (const char*) serverAddress().toString() ); | 439 | odebug << "parsing DHCP options..." << oendl; |
440 | qDebug( " relayAddress: %s", (const char*) relayAddress().toString() ); | 440 | |
441 | qDebug( "parsing DHCP options..." ); | 441 | _type = 0; |
442 | 442 | ||
443 | _type = 0; | 443 | const unsigned char* option = &_dhcphdr->options[4]; |
444 | 444 | char tag = -1; | |
445 | const unsigned char* option = &_dhcphdr->options[4]; | 445 | char len = -1; |
446 | char tag = -1; | 446 | |
447 | char len = -1; | 447 | while ( ( tag = *option++ ) != -1 /* end of option field */ ) |
448 | 448 | { | |
449 | while ( ( tag = *option++ ) != -1 /* end of option field */ ) | 449 | len = *option++; |
450 | { | 450 | odebug << "recognized DHCP option #" << tag << ", length " << len << oendl; |
451 | len = *option++; | 451 | |
452 | qDebug( "recognized DHCP option #%d, length %d", tag, len ); | 452 | if ( tag == DHO_DHCP_MESSAGE_TYPE ) |
453 | 453 | _type = *option; | |
454 | if ( tag == DHO_DHCP_MESSAGE_TYPE ) | 454 | |
455 | _type = *option; | 455 | option += len; |
456 | 456 | if ( option >= end ) | |
457 | option += len; | 457 | { |
458 | if ( option >= end ) | 458 | owarn << "DHCP parsing ERROR: sanity check says the packet is at its end!" << oendl; |
459 | { | 459 | break; |
460 | qWarning( "DHCP parsing ERROR: sanity check says the packet is at its end!" ); | 460 | } |
461 | break; | 461 | } |
462 | } | 462 | |
463 | } | 463 | odebug << "DHCP type seems to be << " << type() << oendl; |
464 | 464 | } | |
465 | qDebug( "DHCP type seems to be '%s'", (const char*) type() ); | 465 | |
466 | } | 466 | |
467 | 467 | ODHCPPacket::~ODHCPPacket() | |
468 | 468 | { | |
469 | ODHCPPacket::~ODHCPPacket() | 469 | } |
470 | { | 470 | |
471 | } | 471 | |
472 | 472 | bool ODHCPPacket::isRequest() const | |
473 | 473 | { | |
474 | bool ODHCPPacket::isRequest() const | 474 | return ( _dhcphdr->op == 01 ); |
475 | { | 475 | } |
476 | return ( _dhcphdr->op == 01 ); | 476 | |
477 | } | 477 | |
478 | 478 | bool ODHCPPacket::isReply() const | |
479 | 479 | { | |
480 | bool ODHCPPacket::isReply() const | 480 | return ( _dhcphdr->op == 02 ); |
481 | { | 481 | } |
482 | return ( _dhcphdr->op == 02 ); | 482 | |
483 | } | 483 | |
484 | 484 | QString ODHCPPacket::type() const | |
485 | 485 | { | |
486 | QString ODHCPPacket::type() const | 486 | switch ( _type ) |
487 | { | 487 | { |
488 | switch ( _type ) | 488 | case 1: return "DISCOVER"; |
489 | { | 489 | case 2: return "OFFER"; |
490 | case 1: return "DISCOVER"; | 490 | case 3: return "REQUEST"; |
491 | case 2: return "OFFER"; | 491 | case 4: return "DECLINE"; |
492 | case 3: return "REQUEST"; | 492 | case 5: return "ACK"; |
493 | case 4: return "DECLINE"; | 493 | case 6: return "NAK"; |
494 | case 5: return "ACK"; | 494 | case 7: return "RELEASE"; |
495 | case 6: return "NAK"; | 495 | case 8: return "INFORM"; |
496 | case 7: return "RELEASE"; | 496 | default: qWarning( "ODHCPPacket::type(): invalid DHCP type (%d) !", _dhcphdr->op ); return "<unknown>"; |
497 | case 8: return "INFORM"; | 497 | } |
498 | default: qWarning( "ODHCPPacket::type(): invalid DHCP type (%d) !", _dhcphdr->op ); return "<unknown>"; | 498 | } |
499 | } | 499 | |
500 | } | 500 | |
501 | 501 | QHostAddress ODHCPPacket::clientAddress() const | |
502 | 502 | { | |
503 | QHostAddress ODHCPPacket::clientAddress() const | 503 | return EXTRACT_32BITS( &_dhcphdr->ciaddr ); |
504 | { | 504 | } |
505 | return EXTRACT_32BITS( &_dhcphdr->ciaddr ); | 505 | |
506 | } | 506 | |
507 | 507 | QHostAddress ODHCPPacket::yourAddress() const | |
508 | 508 | { | |
509 | QHostAddress ODHCPPacket::yourAddress() const | 509 | return EXTRACT_32BITS( &_dhcphdr->yiaddr ); |
510 | { | 510 | } |
511 | return EXTRACT_32BITS( &_dhcphdr->yiaddr ); | 511 | |
512 | } | 512 | |
513 | 513 | QHostAddress ODHCPPacket::serverAddress() const | |
514 | 514 | { | |
515 | QHostAddress ODHCPPacket::serverAddress() const | 515 | return EXTRACT_32BITS( &_dhcphdr->siaddr ); |
516 | { | 516 | } |
517 | return EXTRACT_32BITS( &_dhcphdr->siaddr ); | 517 | |
518 | } | 518 | |
519 | 519 | QHostAddress ODHCPPacket::relayAddress() const | |
520 | 520 | { | |
521 | QHostAddress ODHCPPacket::relayAddress() const | 521 | return EXTRACT_32BITS( &_dhcphdr->giaddr ); |
522 | { | 522 | } |
523 | return EXTRACT_32BITS( &_dhcphdr->giaddr ); | 523 | |
524 | } | 524 | |
525 | 525 | OMacAddress ODHCPPacket::clientMacAddress() const | |
526 | 526 | { | |
527 | OMacAddress ODHCPPacket::clientMacAddress() const | 527 | return OMacAddress( _dhcphdr->chaddr ); |
528 | { | 528 | } |
529 | return OMacAddress( _dhcphdr->chaddr ); | 529 | |
530 | } | 530 | |
531 | 531 | /*====================================================================================== | |
532 | 532 | * OTCPPacket | |
533 | /*====================================================================================== | 533 | *======================================================================================*/ |
534 | * OTCPPacket | 534 | |
535 | *======================================================================================*/ | 535 | |
536 | 536 | OTCPPacket::OTCPPacket( const unsigned char* end, const struct tcphdr* data, QObject* parent ) | |
537 | 537 | :QObject( parent, "TCP" ), _tcphdr( data ) | |
538 | OTCPPacket::OTCPPacket( const unsigned char* end, const struct tcphdr* data, QObject* parent ) | 538 | |
539 | :QObject( parent, "TCP" ), _tcphdr( data ) | 539 | { |
540 | 540 | odebug << "OTCPPacket::OTCPPacket(): decoding TCP header..." << oendl; | |
541 | { | 541 | } |
542 | qDebug( "OTCPPacket::OTCPPacket(): decoding TCP header..." ); | 542 | |
543 | } | 543 | |
544 | 544 | OTCPPacket::~OTCPPacket() | |
545 | 545 | { | |
546 | OTCPPacket::~OTCPPacket() | 546 | } |
547 | { | 547 | |
548 | } | 548 | |
549 | 549 | int OTCPPacket::fromPort() const | |
550 | 550 | { | |
551 | int OTCPPacket::fromPort() const | 551 | return EXTRACT_16BITS( &_tcphdr->source ); |
552 | { | 552 | } |
553 | return EXTRACT_16BITS( &_tcphdr->source ); | 553 | |
554 | } | 554 | |
555 | 555 | int OTCPPacket::toPort() const | |
556 | 556 | { | |
557 | int OTCPPacket::toPort() const | 557 | return EXTRACT_16BITS( &_tcphdr->dest ); |
558 | { | 558 | } |
559 | return EXTRACT_16BITS( &_tcphdr->dest ); | 559 | |
560 | } | 560 | |
561 | 561 | int OTCPPacket::seq() const | |
562 | 562 | { | |
563 | int OTCPPacket::seq() const | 563 | return EXTRACT_16BITS( &_tcphdr->seq ); |
564 | { | 564 | } |
565 | return EXTRACT_16BITS( &_tcphdr->seq ); | 565 | |
566 | } | 566 | |
567 | 567 | int OTCPPacket::ack() const | |
568 | 568 | { | |
569 | int OTCPPacket::ack() const | 569 | return EXTRACT_16BITS( &_tcphdr->ack_seq ); |
570 | { | 570 | } |
571 | return EXTRACT_16BITS( &_tcphdr->ack_seq ); | 571 | |
572 | } | 572 | |
573 | 573 | int OTCPPacket::window() const | |
574 | 574 | { | |
575 | int OTCPPacket::window() const | 575 | return EXTRACT_16BITS( &_tcphdr->window ); |
576 | { | 576 | } |
577 | return EXTRACT_16BITS( &_tcphdr->window ); | 577 | |
578 | } | 578 | |
579 | 579 | int OTCPPacket::checksum() const | |
580 | 580 | { | |
581 | int OTCPPacket::checksum() const | 581 | return EXTRACT_16BITS( &_tcphdr->check ); |
582 | { | 582 | } |
583 | return EXTRACT_16BITS( &_tcphdr->check ); | 583 | |
584 | } | 584 | /*====================================================================================== |
585 | 585 | * OPrismHeaderPacket | |
586 | /*====================================================================================== | 586 | *======================================================================================*/ |
587 | * OPrismHeaderPacket | 587 | |
588 | *======================================================================================*/ | 588 | |
589 | 589 | OPrismHeaderPacket::OPrismHeaderPacket( const unsigned char* end, const struct prism_hdr* data, QObject* parent ) | |
590 | 590 | :QObject( parent, "Prism" ), _header( data ) | |
591 | OPrismHeaderPacket::OPrismHeaderPacket( const unsigned char* end, const struct prism_hdr* data, QObject* parent ) | 591 | |
592 | :QObject( parent, "Prism" ), _header( data ) | 592 | { |
593 | 593 | odebug << "OPrismHeaderPacket::OPrismHeaderPacket(): decoding PRISM header..." << oendl; | |
594 | { | 594 | |
595 | qDebug( "OPrismHeaderPacket::OPrismHeaderPacket(): decoding PRISM header..." ); | 595 | odebug << "Signal Strength = " << data->signal.data << oendl; |
596 | 596 | ||
597 | qDebug( "Signal Strength = %d", data->signal.data ); | 597 | new OWaveLanPacket( end, (const struct ieee_802_11_header*) (data+1), this ); |
598 | 598 | } | |
599 | new OWaveLanPacket( end, (const struct ieee_802_11_header*) (data+1), this ); | 599 | |
600 | } | 600 | OPrismHeaderPacket::~OPrismHeaderPacket() |
601 | 601 | { | |
602 | OPrismHeaderPacket::~OPrismHeaderPacket() | 602 | } |
603 | { | 603 | |
604 | } | 604 | |
605 | 605 | unsigned int OPrismHeaderPacket::signalStrength() const | |
606 | 606 | { | |
607 | unsigned int OPrismHeaderPacket::signalStrength() const | 607 | return _header->signal.data; |
608 | { | 608 | } |
609 | return _header->signal.data; | 609 | |
610 | } | 610 | /*====================================================================================== |
611 | 611 | * OWaveLanPacket | |
612 | /*====================================================================================== | 612 | *======================================================================================*/ |
613 | * OWaveLanPacket | 613 | |
614 | *======================================================================================*/ | 614 | |
615 | 615 | OWaveLanPacket::OWaveLanPacket( const unsigned char* end, const struct ieee_802_11_header* data, QObject* parent ) | |
616 | 616 | :QObject( parent, "802.11" ), _wlanhdr( data ) | |
617 | OWaveLanPacket::OWaveLanPacket( const unsigned char* end, const struct ieee_802_11_header* data, QObject* parent ) | 617 | |
618 | :QObject( parent, "802.11" ), _wlanhdr( data ) | 618 | { |
619 | 619 | odebug << "OWaveLanPacket::OWaveLanPacket(): decoding IEEE 802.11 header..." << oendl; | |
620 | { | 620 | odebug << "type = " << type() << oendl; |
621 | qDebug( "OWaveLanPacket::OWaveLanPacket(): decoding IEEE 802.11 header..." ); | 621 | odebug << "subType = " << subType() << oendl; |
622 | qDebug( "type: %0X", type() ); | 622 | odebug << "duration = " << duration() << oendl; |
623 | qDebug( "subType: %0X", subType() ); | 623 | odebug << "powermanagement = " << usesPowerManagement() << oendl; |
624 | qDebug( "duration: %d", duration() ); | 624 | odebug << "payload is encrypted = " << ( usesWep() ? "yes" : "no" ) << oendl; |
625 | qDebug( "powermanagement: %d", usesPowerManagement() ); | 625 | odebug << "MAC1 = " << macAddress1().toString() << oendl; |
626 | qDebug( "payload is encrypted: %s", usesWep() ? "yes" : "no" ); | 626 | odebug << "MAC2 = " << macAddress2().toString() << oendl; |
627 | qDebug( "MAC1: %s", (const char*) macAddress1().toString() ); | 627 | odebug << "MAC3 = " << macAddress3().toString() << oendl; |
628 | qDebug( "MAC2: %s", (const char*) macAddress2().toString() ); | 628 | odebug << "MAC4 = " << macAddress4().toString() << oendl; |
629 | qDebug( "MAC3: %s", (const char*) macAddress3().toString() ); | 629 | |
630 | qDebug( "MAC4: %s", (const char*) macAddress4().toString() ); | 630 | switch ( type() ) |
631 | 631 | { | |
632 | switch ( type() ) | 632 | case T_MGMT: new OWaveLanManagementPacket( end, (const struct ieee_802_11_mgmt_header*) data, this ); break; |
633 | { | 633 | case T_DATA: new OWaveLanDataPacket( end, (const struct ieee_802_11_data_header*) data, this ); break; |
634 | case T_MGMT: new OWaveLanManagementPacket( end, (const struct ieee_802_11_mgmt_header*) data, this ); break; | 634 | case T_CTRL: new OWaveLanControlPacket( end, (const struct ieee_802_11_control_header*) data, this ); break; |
635 | case T_DATA: new OWaveLanDataPacket( end, (const struct ieee_802_11_data_header*) data, this ); break; | 635 | default: odebug << "OWaveLanPacket::OWaveLanPacket(): Warning: Unknown major type = " << type() << oendl; |
636 | case T_CTRL: new OWaveLanControlPacket( end, (const struct ieee_802_11_control_header*) data, this ); break; | 636 | } |
637 | default: qDebug( "OWaveLanPacket::OWaveLanPacket(): Warning: Unknown major type '%d'!", type() ); | 637 | } |
638 | } | 638 | |
639 | } | 639 | OWaveLanPacket::~OWaveLanPacket() |
640 | 640 | { | |
641 | OWaveLanPacket::~OWaveLanPacket() | 641 | } |
642 | { | 642 | |
643 | } | 643 | |
644 | 644 | int OWaveLanPacket::duration() const | |
645 | 645 | { | |
646 | int OWaveLanPacket::duration() const | 646 | return _wlanhdr->duration; |
647 | { | 647 | } |
648 | return _wlanhdr->duration; | 648 | |
649 | } | 649 | |
650 | 650 | OMacAddress OWaveLanPacket::macAddress1() const | |
651 | 651 | { | |
652 | OMacAddress OWaveLanPacket::macAddress1() const | 652 | return OMacAddress( _wlanhdr->mac1 ); |
653 | { | 653 | } |
654 | return OMacAddress( _wlanhdr->mac1 ); | 654 | |
655 | } | 655 | |
656 | 656 | OMacAddress OWaveLanPacket::macAddress2() const | |
657 | 657 | { | |
658 | OMacAddress OWaveLanPacket::macAddress2() const | 658 | return OMacAddress( _wlanhdr->mac2 ); |
659 | { | 659 | } |
660 | return OMacAddress( _wlanhdr->mac2 ); | 660 | |
661 | } | 661 | |
662 | 662 | OMacAddress OWaveLanPacket::macAddress3() const | |
663 | 663 | { | |
664 | OMacAddress OWaveLanPacket::macAddress3() const | 664 | return OMacAddress( _wlanhdr->mac3 ); |
665 | { | 665 | } |
666 | return OMacAddress( _wlanhdr->mac3 ); | 666 | |
667 | } | 667 | |
668 | 668 | OMacAddress OWaveLanPacket::macAddress4() const | |
669 | 669 | { | |
670 | OMacAddress OWaveLanPacket::macAddress4() const | 670 | return OMacAddress( _wlanhdr->mac4 ); |
671 | { | 671 | } |
672 | return OMacAddress( _wlanhdr->mac4 ); | 672 | |
673 | } | 673 | |
674 | 674 | int OWaveLanPacket::subType() const | |
675 | 675 | { | |
676 | int OWaveLanPacket::subType() const | 676 | return FC_SUBTYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
677 | { | 677 | } |
678 | return FC_SUBTYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 678 | |
679 | } | 679 | |
680 | 680 | int OWaveLanPacket::type() const | |
681 | 681 | { | |
682 | int OWaveLanPacket::type() const | 682 | return FC_TYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
683 | { | 683 | } |
684 | return FC_TYPE( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 684 | |
685 | } | 685 | |
686 | 686 | int OWaveLanPacket::version() const | |
687 | 687 | { | |
688 | int OWaveLanPacket::version() const | 688 | return FC_VERSION( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
689 | { | 689 | } |
690 | return FC_VERSION( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 690 | |
691 | } | 691 | |
692 | 692 | bool OWaveLanPacket::fromDS() const | |
693 | 693 | { | |
694 | bool OWaveLanPacket::fromDS() const | 694 | return FC_FROM_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
695 | { | 695 | } |
696 | return FC_FROM_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 696 | |
697 | } | 697 | |
698 | 698 | bool OWaveLanPacket::toDS() const | |
699 | 699 | { | |
700 | bool OWaveLanPacket::toDS() const | 700 | return FC_TO_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
701 | { | 701 | } |
702 | return FC_TO_DS( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 702 | |
703 | } | 703 | |
704 | 704 | bool OWaveLanPacket::usesPowerManagement() const | |
705 | 705 | { | |
706 | bool OWaveLanPacket::usesPowerManagement() const | 706 | return FC_POWER_MGMT( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
707 | { | 707 | } |
708 | return FC_POWER_MGMT( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 708 | |
709 | } | 709 | |
710 | 710 | bool OWaveLanPacket::usesWep() const | |
711 | 711 | { | |
712 | bool OWaveLanPacket::usesWep() const | 712 | return FC_WEP( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); |
713 | { | 713 | } |
714 | return FC_WEP( EXTRACT_LE_16BITS( &_wlanhdr->frame_control ) ); | 714 | |
715 | } | 715 | |
716 | 716 | /*====================================================================================== | |
717 | 717 | * OWaveLanManagementPacket | |
718 | /*====================================================================================== | 718 | *======================================================================================*/ |
719 | * OWaveLanManagementPacket | 719 | |
720 | *======================================================================================*/ | 720 | OWaveLanManagementPacket::OWaveLanManagementPacket( const unsigned char* end, const struct ieee_802_11_mgmt_header* data, OWaveLanPacket* parent ) |
721 | 721 | :QObject( parent, "802.11 Management" ), _header( data ), | |
722 | OWaveLanManagementPacket::OWaveLanManagementPacket( const unsigned char* end, const struct ieee_802_11_mgmt_header* data, OWaveLanPacket* parent ) | 722 | _body( (const struct ieee_802_11_mgmt_body*) (data+1) ) |
723 | :QObject( parent, "802.11 Management" ), _header( data ), | 723 | { |
724 | _body( (const struct ieee_802_11_mgmt_body*) (data+1) ) | 724 | odebug << "OWaveLanManagementPacket::OWaveLanManagementPacket(): decoding frame..." << oendl; |
725 | { | 725 | odebug << "Detected subtype is " << managementType() << oendl; |
726 | qDebug( "OWaveLanManagementPacket::OWaveLanManagementPacket(): decoding frame..." ); | 726 | |
727 | qDebug( "Detected subtype is '%s'", (const char*) managementType() ); | 727 | // grab tagged values |
728 | 728 | const unsigned char* ptr = (const unsigned char*) (_body+1); | |
729 | // grab tagged values | 729 | while (ptr < end) |
730 | const unsigned char* ptr = (const unsigned char*) (_body+1); | 730 | { |
731 | while (ptr < end) | 731 | switch ( *ptr ) |
732 | { | 732 | { |
733 | switch ( *ptr ) | 733 | case E_SSID: new OWaveLanManagementSSID( end, (struct ssid_t*) ptr, this ); break; |
734 | { | 734 | case E_FH: new OWaveLanManagementFH( end, (struct fh_t*) ptr, this ); break; |
735 | case E_SSID: new OWaveLanManagementSSID( end, (struct ssid_t*) ptr, this ); break; | 735 | case E_DS: new OWaveLanManagementDS( end, (struct ds_t*) ptr, this ); break; |
736 | case E_FH: new OWaveLanManagementFH( end, (struct fh_t*) ptr, this ); break; | 736 | case E_RATES: new OWaveLanManagementRates( end, (struct rates_t*) ptr, this ); break; |
737 | case E_DS: new OWaveLanManagementDS( end, (struct ds_t*) ptr, this ); break; | 737 | case E_CF: new OWaveLanManagementCF( end, (struct cf_t*) ptr, this ); break; |
738 | case E_RATES: new OWaveLanManagementRates( end, (struct rates_t*) ptr, this ); break; | 738 | case E_TIM: new OWaveLanManagementTim( end, (struct tim_t*) ptr, this ); break; |
739 | case E_CF: new OWaveLanManagementCF( end, (struct cf_t*) ptr, this ); break; | 739 | case E_IBSS: new OWaveLanManagementIBSS( end, (struct ibss_t*) ptr, this ); break; |
740 | case E_TIM: new OWaveLanManagementTim( end, (struct tim_t*) ptr, this ); break; | 740 | case E_CHALLENGE: new OWaveLanManagementChallenge( end, (struct challenge_t*) ptr, this ); break; |
741 | case E_IBSS: new OWaveLanManagementIBSS( end, (struct ibss_t*) ptr, this ); break; | 741 | } |
742 | case E_CHALLENGE: new OWaveLanManagementChallenge( end, (struct challenge_t*) ptr, this ); break; | 742 | ptr+= ( ( struct ssid_t* ) ptr )->length; // skip length of tagged value |
743 | } | 743 | ptr+= 2; // skip tag ID and length |
744 | ptr+= ( ( struct ssid_t* ) ptr )->length; // skip length of tagged value | 744 | } |
745 | ptr+= 2; // skip tag ID and length | 745 | } |
746 | } | 746 | |
747 | } | 747 | |
748 | 748 | OWaveLanManagementPacket::~OWaveLanManagementPacket() | |
749 | 749 | { | |
750 | OWaveLanManagementPacket::~OWaveLanManagementPacket() | 750 | } |
751 | { | 751 | |
752 | } | 752 | |
753 | 753 | QString OWaveLanManagementPacket::managementType() const | |
754 | 754 | { | |
755 | QString OWaveLanManagementPacket::managementType() const | 755 | switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) ) |
756 | { | 756 | { |
757 | switch ( FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) ) | 757 | case ST_ASSOC_REQUEST: return "AssociationRequest"; break; |
758 | { | 758 | case ST_ASSOC_RESPONSE: return "AssociationResponse"; break; |
759 | case ST_ASSOC_REQUEST: return "AssociationRequest"; break; | 759 | case ST_REASSOC_REQUEST: return "ReassociationRequest"; break; |
760 | case ST_ASSOC_RESPONSE: return "AssociationResponse"; break; | 760 | case ST_REASSOC_RESPONSE: return "ReassociationResponse"; break; |
761 | case ST_REASSOC_REQUEST: return "ReassociationRequest"; break; | 761 | case ST_PROBE_REQUEST: return "ProbeRequest"; break; |
762 | case ST_REASSOC_RESPONSE: return "ReassociationResponse"; break; | 762 | case ST_PROBE_RESPONSE: return "ProbeResponse"; break; |
763 | case ST_PROBE_REQUEST: return "ProbeRequest"; break; | 763 | case ST_BEACON: return "Beacon"; break; |
764 | case ST_PROBE_RESPONSE: return "ProbeResponse"; break; | 764 | case ST_ATIM: return "Atim"; break; |
765 | case ST_BEACON: return "Beacon"; break; | 765 | case ST_DISASSOC: return "Disassociation"; break; |
766 | case ST_ATIM: return "Atim"; break; | 766 | case ST_AUTH: return "Authentication"; break; |
767 | case ST_DISASSOC: return "Disassociation"; break; | 767 | case ST_DEAUTH: return "Deathentication"; break; |
768 | case ST_AUTH: return "Authentication"; break; | 768 | default: |
769 | case ST_DEAUTH: return "Deathentication"; break; | 769 | qWarning( "OWaveLanManagementPacket::managementType(): unhandled subtype %d", FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) ); |
770 | default: | 770 | return "Unknown"; |
771 | qWarning( "OWaveLanManagementPacket::managementType(): unhandled subtype %d", FC_SUBTYPE( EXTRACT_LE_16BITS( &_header->fc ) ) ); | 771 | } |
772 | return "Unknown"; | 772 | } |
773 | } | 773 | |
774 | } | 774 | |
775 | 775 | int OWaveLanManagementPacket::beaconInterval() const | |
776 | 776 | { | |
777 | int OWaveLanManagementPacket::beaconInterval() const | 777 | return EXTRACT_LE_16BITS( &_body->beacon_interval ); |
778 | { | 778 | } |
779 | return EXTRACT_LE_16BITS( &_body->beacon_interval ); | 779 | |
780 | } | 780 | |
781 | 781 | int OWaveLanManagementPacket::capabilities() const | |
782 | 782 | { | |
783 | int OWaveLanManagementPacket::capabilities() const | 783 | return EXTRACT_LE_16BITS( &_body->capability_info ); |
784 | { | 784 | } |
785 | return EXTRACT_LE_16BITS( &_body->capability_info ); | 785 | |
786 | } | 786 | |
787 | 787 | bool OWaveLanManagementPacket::canESS() const | |
788 | 788 | { | |
789 | bool OWaveLanManagementPacket::canESS() const | 789 | return CAPABILITY_ESS( EXTRACT_LE_16BITS( &_body->capability_info ) ); |
790 | { | 790 | } |
791 | return CAPABILITY_ESS( EXTRACT_LE_16BITS( &_body->capability_info ) ); | 791 | |
792 | } | 792 | |
793 | 793 | bool OWaveLanManagementPacket::canIBSS() const | |
794 | 794 | { | |
795 | bool OWaveLanManagementPacket::canIBSS() const | 795 | return CAPABILITY_IBSS( EXTRACT_LE_16BITS( &_body->capability_info ) ); |
796 | { | 796 | } |
797 | return CAPABILITY_IBSS( EXTRACT_LE_16BITS( &_body->capability_info ) ); | 797 | |
798 | } | 798 | |
799 | 799 | bool OWaveLanManagementPacket::canCFP() const | |
800 | 800 | { | |
801 | bool OWaveLanManagementPacket::canCFP() const | 801 | return CAPABILITY_CFP( EXTRACT_LE_16BITS( &_body->capability_info ) ); |
802 | { | 802 | } |
803 | return CAPABILITY_CFP( EXTRACT_LE_16BITS( &_body->capability_info ) ); | 803 | |
804 | } | 804 | |
805 | 805 | bool OWaveLanManagementPacket::canCFP_REQ() const | |
806 | 806 | { | |
807 | bool OWaveLanManagementPacket::canCFP_REQ() const | 807 | return CAPABILITY_CFP_REQ( EXTRACT_LE_16BITS( &_body->capability_info ) ); |
808 | { | 808 | } |
809 | return CAPABILITY_CFP_REQ( EXTRACT_LE_16BITS( &_body->capability_info ) ); | 809 | |
810 | } | 810 | |
811 | 811 | bool OWaveLanManagementPacket::canPrivacy() const | |
812 | 812 | { | |
813 | bool OWaveLanManagementPacket::canPrivacy() const | 813 | return CAPABILITY_PRIVACY( EXTRACT_LE_16BITS( &_body->capability_info ) ); |
814 | { | 814 | } |
815 | return CAPABILITY_PRIVACY( EXTRACT_LE_16BITS( &_body->capability_info ) ); | 815 | |
816 | } | 816 | |
817 | 817 | /*====================================================================================== | |
818 | 818 | * OWaveLanManagementSSID | |
819 | /*====================================================================================== | 819 | *======================================================================================*/ |
820 | * OWaveLanManagementSSID | 820 | |
821 | *======================================================================================*/ | 821 | OWaveLanManagementSSID::OWaveLanManagementSSID( const unsigned char* end, const struct ssid_t* data, QObject* parent ) |
822 | 822 | :QObject( parent, "802.11 SSID" ), _data( data ) | |
823 | OWaveLanManagementSSID::OWaveLanManagementSSID( const unsigned char* end, const struct ssid_t* data, QObject* parent ) | 823 | { |
824 | :QObject( parent, "802.11 SSID" ), _data( data ) | 824 | odebug << "OWaveLanManagementSSID()" << oendl; |
825 | { | 825 | } |
826 | qDebug( "OWaveLanManagementSSID()" ); | 826 | |
827 | } | 827 | |
828 | 828 | OWaveLanManagementSSID::~OWaveLanManagementSSID() | |
829 | 829 | { | |
830 | OWaveLanManagementSSID::~OWaveLanManagementSSID() | 830 | } |
831 | { | 831 | |
832 | } | 832 | |
833 | 833 | QString OWaveLanManagementSSID::ID() const | |
834 | 834 | { | |
835 | QString OWaveLanManagementSSID::ID() const | 835 | int length = _data->length; |
836 | { | 836 | if ( length > 32 ) length = 32; |
837 | int length = _data->length; | 837 | char essid[length+1]; |
838 | if ( length > 32 ) length = 32; | 838 | memcpy( &essid, &_data->ssid, length ); |
839 | char essid[length+1]; | 839 | essid[length] = 0x0; |
840 | memcpy( &essid, &_data->ssid, length ); | 840 | return essid; |
841 | essid[length] = 0x0; | 841 | } |
842 | return essid; | 842 | |
843 | } | 843 | |
844 | 844 | /*====================================================================================== | |
845 | 845 | * OWaveLanManagementRates | |
846 | /*====================================================================================== | 846 | *======================================================================================*/ |
847 | * OWaveLanManagementRates | 847 | |
848 | *======================================================================================*/ | 848 | OWaveLanManagementRates::OWaveLanManagementRates( const unsigned char* end, const struct rates_t* data, QObject* parent ) |
849 | 849 | :QObject( parent, "802.11 Rates" ), _data( data ) | |
850 | OWaveLanManagementRates::OWaveLanManagementRates( const unsigned char* end, const struct rates_t* data, QObject* parent ) | 850 | { |
851 | :QObject( parent, "802.11 Rates" ), _data( data ) | 851 | odebug << "OWaveLanManagementRates()" << oendl; |
852 | { | 852 | } |
853 | qDebug( "OWaveLanManagementRates()" ); | 853 | |
854 | } | 854 | |
855 | 855 | OWaveLanManagementRates::~OWaveLanManagementRates() | |
856 | 856 | { | |
857 | OWaveLanManagementRates::~OWaveLanManagementRates() | 857 | } |
858 | { | 858 | |
859 | } | 859 | /*====================================================================================== |
860 | 860 | * OWaveLanManagementCF | |
861 | /*====================================================================================== | 861 | *======================================================================================*/ |
862 | * OWaveLanManagementCF | 862 | |
863 | *======================================================================================*/ | 863 | OWaveLanManagementCF::OWaveLanManagementCF( const unsigned char* end, const struct cf_t* data, QObject* parent ) |
864 | 864 | :QObject( parent, "802.11 CF" ), _data( data ) | |
865 | OWaveLanManagementCF::OWaveLanManagementCF( const unsigned char* end, const struct cf_t* data, QObject* parent ) | 865 | { |
866 | :QObject( parent, "802.11 CF" ), _data( data ) | 866 | odebug << "OWaveLanManagementCF()" << oendl; |
867 | { | 867 | } |
868 | qDebug( "OWaveLanManagementCF()" ); | 868 | |
869 | } | 869 | |
870 | 870 | OWaveLanManagementCF::~OWaveLanManagementCF() | |
871 | 871 | { | |
872 | OWaveLanManagementCF::~OWaveLanManagementCF() | 872 | } |
873 | { | 873 | |
874 | } | 874 | /*====================================================================================== |
875 | 875 | * OWaveLanManagementFH | |
876 | /*====================================================================================== | 876 | *======================================================================================*/ |
877 | * OWaveLanManagementFH | 877 | |
878 | *======================================================================================*/ | 878 | OWaveLanManagementFH::OWaveLanManagementFH( const unsigned char* end, const struct fh_t* data, QObject* parent ) |
879 | 879 | :QObject( parent, "802.11 FH" ), _data( data ) | |
880 | OWaveLanManagementFH::OWaveLanManagementFH( const unsigned char* end, const struct fh_t* data, QObject* parent ) | 880 | { |
881 | :QObject( parent, "802.11 FH" ), _data( data ) | 881 | odebug << "OWaveLanManagementFH()" << oendl; |
882 | { | 882 | } |
883 | qDebug( "OWaveLanManagementFH()" ); | 883 | |
884 | } | 884 | |
885 | 885 | OWaveLanManagementFH::~OWaveLanManagementFH() | |
886 | 886 | { | |
887 | OWaveLanManagementFH::~OWaveLanManagementFH() | 887 | } |
888 | { | 888 | |
889 | } | 889 | /*====================================================================================== |
890 | 890 | * OWaveLanManagementDS | |
891 | /*====================================================================================== | 891 | *======================================================================================*/ |
892 | * OWaveLanManagementDS | 892 | |
893 | *======================================================================================*/ | 893 | OWaveLanManagementDS::OWaveLanManagementDS( const unsigned char* end, const struct ds_t* data, QObject* parent ) |
894 | 894 | :QObject( parent, "802.11 DS" ), _data( data ) | |
895 | OWaveLanManagementDS::OWaveLanManagementDS( const unsigned char* end, const struct ds_t* data, QObject* parent ) | 895 | { |
896 | :QObject( parent, "802.11 DS" ), _data( data ) | 896 | odebug << "OWaveLanManagementDS()" << oendl; |
897 | { | 897 | } |
898 | qDebug( "OWaveLanManagementDS()" ); | 898 | |
899 | } | 899 | |
900 | 900 | OWaveLanManagementDS::~OWaveLanManagementDS() | |
901 | 901 | { | |
902 | OWaveLanManagementDS::~OWaveLanManagementDS() | 902 | } |
903 | { | 903 | |
904 | } | 904 | |
905 | 905 | int OWaveLanManagementDS::channel() const | |
906 | 906 | { | |
907 | int OWaveLanManagementDS::channel() const | 907 | return _data->channel; |
908 | { | 908 | } |
909 | return _data->channel; | 909 | |
910 | } | 910 | /*====================================================================================== |
911 | 911 | * OWaveLanManagementTim | |
912 | /*====================================================================================== | 912 | *======================================================================================*/ |
913 | * OWaveLanManagementTim | 913 | |
914 | *======================================================================================*/ | 914 | OWaveLanManagementTim::OWaveLanManagementTim( const unsigned char* end, const struct tim_t* data, QObject* parent ) |
915 | 915 | :QObject( parent, "802.11 Tim" ), _data( data ) | |
916 | OWaveLanManagementTim::OWaveLanManagementTim( const unsigned char* end, const struct tim_t* data, QObject* parent ) | 916 | { |
917 | :QObject( parent, "802.11 Tim" ), _data( data ) | 917 | odebug << "OWaveLanManagementTim()" << oendl; |
918 | { | 918 | } |
919 | qDebug( "OWaveLanManagementTim()" ); | 919 | |
920 | } | 920 | |
921 | 921 | OWaveLanManagementTim::~OWaveLanManagementTim() | |
922 | 922 | { | |
923 | OWaveLanManagementTim::~OWaveLanManagementTim() | 923 | } |
924 | { | 924 | |
925 | } | 925 | /*====================================================================================== |
926 | 926 | * OWaveLanManagementIBSS | |
927 | /*====================================================================================== | 927 | *======================================================================================*/ |
928 | * OWaveLanManagementIBSS | 928 | |
929 | *======================================================================================*/ | 929 | OWaveLanManagementIBSS::OWaveLanManagementIBSS( const unsigned char* end, const struct ibss_t* data, QObject* parent ) |
930 | 930 | :QObject( parent, "802.11 IBSS" ), _data( data ) | |
931 | OWaveLanManagementIBSS::OWaveLanManagementIBSS( const unsigned char* end, const struct ibss_t* data, QObject* parent ) | 931 | { |
932 | :QObject( parent, "802.11 IBSS" ), _data( data ) | 932 | odebug << "OWaveLanManagementIBSS()" << oendl; |
933 | { | 933 | } |
934 | qDebug( "OWaveLanManagementIBSS()" ); | 934 | |
935 | } | 935 | |
936 | 936 | OWaveLanManagementIBSS::~OWaveLanManagementIBSS() | |
937 | 937 | { | |
938 | OWaveLanManagementIBSS::~OWaveLanManagementIBSS() | 938 | } |
939 | { | 939 | |
940 | } | 940 | /*====================================================================================== |
941 | 941 | * OWaveLanManagementChallenge | |
942 | /*====================================================================================== | 942 | *======================================================================================*/ |
943 | * OWaveLanManagementChallenge | 943 | |
944 | *======================================================================================*/ | 944 | OWaveLanManagementChallenge::OWaveLanManagementChallenge( const unsigned char* end, const struct challenge_t* data, QObject* parent ) |
945 | 945 | :QObject( parent, "802.11 Challenge" ), _data( data ) | |
946 | OWaveLanManagementChallenge::OWaveLanManagementChallenge( const unsigned char* end, const struct challenge_t* data, QObject* parent ) | 946 | { |
947 | :QObject( parent, "802.11 Challenge" ), _data( data ) | 947 | odebug << "OWaveLanManagementChallenge()" << oendl; |
948 | { | 948 | } |
949 | qDebug( "OWaveLanManagementChallenge()" ); | 949 | |
950 | } | 950 | |
951 | 951 | OWaveLanManagementChallenge::~OWaveLanManagementChallenge() | |
952 | 952 | { | |
953 | OWaveLanManagementChallenge::~OWaveLanManagementChallenge() | 953 | } |
954 | { | 954 | |
955 | } | 955 | /*====================================================================================== |
956 | 956 | * OWaveLanDataPacket | |
957 | /*====================================================================================== | 957 | *======================================================================================*/ |
958 | * OWaveLanDataPacket | 958 | |
959 | *======================================================================================*/ | 959 | OWaveLanDataPacket::OWaveLanDataPacket( const unsigned char* end, const struct ieee_802_11_data_header* data, OWaveLanPacket* parent ) |
960 | 960 | :QObject( parent, "802.11 Data" ), _header( data ) | |
961 | OWaveLanDataPacket::OWaveLanDataPacket( const unsigned char* end, const struct ieee_802_11_data_header* data, OWaveLanPacket* parent ) | 961 | { |
962 | :QObject( parent, "802.11 Data" ), _header( data ) | 962 | odebug << "OWaveLanDataPacket::OWaveLanDataPacket(): decoding frame..." << oendl; |
963 | { | 963 | |
964 | qDebug( "OWaveLanDataPacket::OWaveLanDataPacket(): decoding frame..." ); | 964 | const unsigned char* payload = (const unsigned char*) data + sizeof( struct ieee_802_11_data_header ); |
965 | 965 | ||
966 | const unsigned char* payload = (const unsigned char*) data + sizeof( struct ieee_802_11_data_header ); | 966 | #warning The next line works for most cases, but can not be correct generally! |
967 | 967 | if (!( ( (OWaveLanPacket*) this->parent())->duration() )) payload -= 6; // compensation for missing last address | |
968 | #warning The next line works for most cases, but can not be correct generally! | 968 | |
969 | if (!( ( (OWaveLanPacket*) this->parent())->duration() )) payload -= 6; // compensation for missing last address | 969 | new OLLCPacket( end, (const struct ieee_802_11_802_2_header*) payload, this ); |
970 | 970 | } | |
971 | new OLLCPacket( end, (const struct ieee_802_11_802_2_header*) payload, this ); | 971 | |
972 | } | 972 | |
973 | 973 | OWaveLanDataPacket::~OWaveLanDataPacket() | |
974 | 974 | { | |
975 | OWaveLanDataPacket::~OWaveLanDataPacket() | 975 | } |
976 | { | 976 | |
977 | } | 977 | |
978 | 978 | /*====================================================================================== | |
979 | 979 | * OLLCPacket | |
980 | /*====================================================================================== | 980 | *======================================================================================*/ |
981 | * OLLCPacket | 981 | |
982 | *======================================================================================*/ | 982 | OLLCPacket::OLLCPacket( const unsigned char* end, const struct ieee_802_11_802_2_header* data, QObject* parent ) |
983 | 983 | :QObject( parent, "802.11 LLC" ), _header( data ) | |
984 | OLLCPacket::OLLCPacket( const unsigned char* end, const struct ieee_802_11_802_2_header* data, QObject* parent ) | 984 | { |
985 | :QObject( parent, "802.11 LLC" ), _header( data ) | 985 | odebug << "OLLCPacket::OLLCPacket(): decoding frame..." << oendl; |
986 | { | 986 | |
987 | qDebug( "OLLCPacket::OLLCPacket(): decoding frame..." ); | 987 | if ( !(_header->oui[0] || _header->oui[1] || _header->oui[2]) ) |
988 | 988 | { | |
989 | if ( !(_header->oui[0] || _header->oui[1] || _header->oui[2]) ) | 989 | owarn << "OLLCPacket::OLLCPacket(): contains an encapsulated Ethernet frame (type = " << EXTRACT_16BITS( &_header->type ) << ")" << oendl; |
990 | { | 990 | |
991 | qDebug( "OLLCPacket::OLLCPacket(): contains an encapsulated Ethernet frame (type=%04X)", EXTRACT_16BITS( &_header->type ) ); | 991 | switch ( EXTRACT_16BITS( &_header->type ) ) // defined in linux/if_ether.h |
992 | 992 | { | |
993 | switch ( EXTRACT_16BITS( &_header->type ) ) // defined in linux/if_ether.h | 993 | case ETH_P_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break; |
994 | { | 994 | case ETH_P_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break; |
995 | case ETH_P_IP: new OIPPacket( end, (const struct iphdr*) (data+1), this ); break; | 995 | default: owarn << "OLLCPacket::OLLCPacket(): Unknown Encapsulation type = " << EXTRACT_16BITS( &_header->type ) << oendl; |
996 | case ETH_P_ARP: new OARPPacket( end, (const struct myarphdr*) (data+1), this ); break; | 996 | } |
997 | default: qWarning( "OLLCPacket::OLLCPacket(): Unknown Encapsulation (type=%04X)", EXTRACT_16BITS( &_header->type ) ); | 997 | } |
998 | } | 998 | } |
999 | 999 | ||
1000 | } | 1000 | |
1001 | } | 1001 | OLLCPacket::~OLLCPacket() |
1002 | 1002 | { | |
1003 | 1003 | } | |
1004 | OLLCPacket::~OLLCPacket() | 1004 | |
1005 | { | 1005 | |
1006 | } | 1006 | /*====================================================================================== |
1007 | 1007 | * OWaveLanControlPacket | |
1008 | 1008 | *======================================================================================*/ | |
1009 | /*====================================================================================== | 1009 | |
1010 | * OWaveLanControlPacket | 1010 | OWaveLanControlPacket::OWaveLanControlPacket( const unsigned char* end, const struct ieee_802_11_control_header* data, OWaveLanPacket* parent ) |
1011 | *======================================================================================*/ | 1011 | :QObject( parent, "802.11 Control" ), _header( data ) |
1012 | 1012 | { | |
1013 | OWaveLanControlPacket::OWaveLanControlPacket( const unsigned char* end, const struct ieee_802_11_control_header* data, OWaveLanPacket* parent ) | 1013 | odebug << "OWaveLanControlPacket::OWaveLanDataControl(): decoding frame..." << oendl; |
1014 | :QObject( parent, "802.11 Control" ), _header( data ) | 1014 | //TODO: Implement this |
1015 | { | 1015 | } |
1016 | qDebug( "OWaveLanControlPacket::OWaveLanDataControl(): decoding frame..." ); | 1016 | |
1017 | //TODO: Implement this | 1017 | |
1018 | } | 1018 | OWaveLanControlPacket::~OWaveLanControlPacket() |
1019 | 1019 | { | |
1020 | 1020 | } | |
1021 | OWaveLanControlPacket::~OWaveLanControlPacket() | 1021 | |
1022 | { | 1022 | |
1023 | } | 1023 | /*====================================================================================== |
1024 | 1024 | * OPacketCapturer | |
1025 | 1025 | *======================================================================================*/ | |
1026 | /*====================================================================================== | 1026 | |
1027 | * OPacketCapturer | 1027 | OPacketCapturer::OPacketCapturer( QObject* parent, const char* name ) |
1028 | *======================================================================================*/ | 1028 | :QObject( parent, name ), _name( QString::null ), _open( false ), |
1029 | 1029 | _pch( 0 ), _pcd( 0 ), _sn( 0 ) | |
1030 | OPacketCapturer::OPacketCapturer( QObject* parent, const char* name ) | 1030 | { |
1031 | :QObject( parent, name ), _name( QString::null ), _open( false ), | 1031 | } |
1032 | _pch( 0 ), _pcd( 0 ), _sn( 0 ) | 1032 | |
1033 | { | 1033 | |
1034 | } | 1034 | OPacketCapturer::~OPacketCapturer() |
1035 | 1035 | { | |
1036 | 1036 | if ( _open ) | |
1037 | OPacketCapturer::~OPacketCapturer() | 1037 | { |
1038 | { | 1038 | odebug << "OPacketCapturer::~OPacketCapturer(): pcap still open, autoclosing." << oendl; |
1039 | if ( _open ) | 1039 | close(); |
1040 | { | 1040 | } |
1041 | qDebug( "OPacketCapturer::~OPacketCapturer(): pcap still open, autoclosing." ); | 1041 | } |
1042 | close(); | 1042 | |
1043 | } | 1043 | |
1044 | } | 1044 | void OPacketCapturer::setBlocking( bool b ) |
1045 | 1045 | { | |
1046 | 1046 | if ( pcap_setnonblock( _pch, 1-b, _errbuf ) != -1 ) | |
1047 | void OPacketCapturer::setBlocking( bool b ) | 1047 | { |
1048 | { | 1048 | odebug << "OPacketCapturer::setBlocking(): blocking mode changed successfully." << oendl; |
1049 | if ( pcap_setnonblock( _pch, 1-b, _errbuf ) != -1 ) | 1049 | } |
1050 | { | 1050 | else |
1051 | qDebug( "OPacketCapturer::setBlocking(): blocking mode changed successfully." ); | 1051 | { |
1052 | } | 1052 | odebug << "OPacketCapturer::setBlocking(): can't change blocking mode: " << _errbuf << oendl; |
1053 | else | 1053 | } |
1054 | { | 1054 | } |
1055 | qDebug( "OPacketCapturer::setBlocking(): can't change blocking mode: %s", _errbuf ); | 1055 | |
1056 | } | 1056 | |
1057 | } | 1057 | bool OPacketCapturer::blocking() const |
1058 | 1058 | { | |
1059 | 1059 | int b = pcap_getnonblock( _pch, _errbuf ); | |
1060 | bool OPacketCapturer::blocking() const | 1060 | if ( b == -1 ) |
1061 | { | 1061 | { |
1062 | int b = pcap_getnonblock( _pch, _errbuf ); | 1062 | odebug << "OPacketCapturer::blocking(): can't get blocking mode: " << _errbuf << oendl; |
1063 | if ( b == -1 ) | 1063 | return -1; |
1064 | { | 1064 | } |
1065 | qDebug( "OPacketCapturer::blocking(): can't get blocking mode: %s", _errbuf ); | 1065 | return !b; |
1066 | return -1; | 1066 | } |
1067 | } | 1067 | |
1068 | return !b; | 1068 | |
1069 | } | 1069 | void OPacketCapturer::closeDumpFile() |
1070 | 1070 | { | |
1071 | 1071 | if ( _pcd ) | |
1072 | void OPacketCapturer::closeDumpFile() | 1072 | { |
1073 | { | 1073 | pcap_dump_close( _pcd ); |
1074 | if ( _pcd ) | 1074 | _pcd = 0; |
1075 | { | 1075 | } |
1076 | pcap_dump_close( _pcd ); | 1076 | pcap_close( _pch ); |
1077 | _pcd = 0; | 1077 | } |
1078 | } | 1078 | |
1079 | pcap_close( _pch ); | 1079 | |
1080 | } | 1080 | void OPacketCapturer::close() |
1081 | 1081 | { | |
1082 | 1082 | if ( _open ) | |
1083 | void OPacketCapturer::close() | 1083 | { |
1084 | { | 1084 | if ( _sn ) |
1085 | if ( _open ) | 1085 | { |
1086 | { | 1086 | _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); |
1087 | if ( _sn ) | 1087 | delete _sn; |
1088 | { | 1088 | } |
1089 | _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | 1089 | closeDumpFile(); |
1090 | delete _sn; | 1090 | _open = false; |
1091 | } | 1091 | } |
1092 | closeDumpFile(); | 1092 | |
1093 | _open = false; | 1093 | odebug << "OPacketCapturer::close() --- dumping capturing statistics..." << oendl; |
1094 | } | 1094 | odebug << "--------------------------------------------------" << oendl; |
1095 | 1095 | for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) | |
1096 | qDebug( "OPacketCapturer::close() --- dumping capturing statistics..." ); | 1096 | odebug << it.key() << " = " << it.data() << oendl; |
1097 | qDebug( "--------------------------------------------------" ); | 1097 | odebug << "--------------------------------------------------" << oendl; |
1098 | for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) | 1098 | |
1099 | qDebug( "%s : %d", (const char*) it.key(), it.data() ); | 1099 | } |
1100 | qDebug( "--------------------------------------------------" ); | 1100 | |
1101 | 1101 | ||
1102 | } | 1102 | int OPacketCapturer::dataLink() const |
1103 | 1103 | { | |
1104 | 1104 | return pcap_datalink( _pch ); | |
1105 | int OPacketCapturer::dataLink() const | 1105 | } |
1106 | { | 1106 | |
1107 | return pcap_datalink( _pch ); | 1107 | |
1108 | } | 1108 | void OPacketCapturer::dump( OPacket* p ) |
1109 | 1109 | { | |
1110 | 1110 | if ( !_pcd ) | |
1111 | void OPacketCapturer::dump( OPacket* p ) | 1111 | { |
1112 | { | 1112 | qWarning( "OPacketCapturer::dump() - cannot dump without open capture file!" ); |
1113 | if ( !_pcd ) | 1113 | return; |
1114 | { | 1114 | } |
1115 | qWarning( "OPacketCapturer::dump() - cannot dump without open capture file!" ); | 1115 | pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data ); |
1116 | return; | 1116 | } |
1117 | } | 1117 | |
1118 | pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data ); | 1118 | |
1119 | } | 1119 | int OPacketCapturer::fileno() const |
1120 | 1120 | { | |
1121 | 1121 | if ( _open ) | |
1122 | int OPacketCapturer::fileno() const | 1122 | { |
1123 | { | 1123 | return pcap_fileno( _pch ); |
1124 | if ( _open ) | 1124 | } |
1125 | { | 1125 | else |
1126 | return pcap_fileno( _pch ); | 1126 | { |
1127 | } | 1127 | return -1; |
1128 | else | 1128 | } |
1129 | { | 1129 | } |
1130 | return -1; | 1130 | |
1131 | } | 1131 | |
1132 | } | 1132 | OPacket* OPacketCapturer::next( int time ) |
1133 | 1133 | { | |
1134 | 1134 | fd_set fds; | |
1135 | OPacket* OPacketCapturer::next( int time ) | 1135 | struct timeval tv; |
1136 | { | 1136 | FD_ZERO( &fds ); |
1137 | fd_set fds; | 1137 | FD_SET( pcap_fileno( _pch ), &fds ); |
1138 | struct timeval tv; | 1138 | tv.tv_sec = time / 1000; |
1139 | FD_ZERO( &fds ); | 1139 | tv.tv_usec = time % 1000; |
1140 | FD_SET( pcap_fileno( _pch ), &fds ); | 1140 | int retval = select( pcap_fileno( _pch )+1, &fds, NULL, NULL, &tv); |
1141 | tv.tv_sec = time / 1000; | 1141 | if ( retval > 0 ) // clear to read! |
1142 | tv.tv_usec = time % 1000; | 1142 | return next(); |
1143 | int retval = select( pcap_fileno( _pch )+1, &fds, NULL, NULL, &tv); | 1143 | else |
1144 | if ( retval > 0 ) // clear to read! | 1144 | return 0; |
1145 | return next(); | 1145 | } |
1146 | else | 1146 | |
1147 | return 0; | 1147 | |
1148 | } | 1148 | OPacket* OPacketCapturer::next() |
1149 | 1149 | { | |
1150 | 1150 | packetheaderstruct header; | |
1151 | OPacket* OPacketCapturer::next() | 1151 | odebug << "==> OPacketCapturer::next()" << oendl; |
1152 | { | 1152 | const unsigned char* pdata = pcap_next( _pch, &header ); |
1153 | packetheaderstruct header; | 1153 | odebug << "<== OPacketCapturer::next()" << oendl; |
1154 | qDebug( "==> OPacketCapturer::next()" ); | 1154 | |
1155 | const unsigned char* pdata = pcap_next( _pch, &header ); | 1155 | if ( pdata && header.len ) |
1156 | qDebug( "<== OPacketCapturer::next()" ); | 1156 | { |
1157 | 1157 | OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); | |
1158 | if ( pdata && header.len ) | 1158 | // packets shouldn't be inserted in the QObject child-parent hierarchy, |
1159 | { | 1159 | // because due to memory constraints they will be deleted as soon |
1160 | OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); | 1160 | // as possible - that is right after they have been processed |
1161 | // packets shouldn't be inserted in the QObject child-parent hierarchy, | 1161 | // by emit() [ see below ] |
1162 | // because due to memory constraints they will be deleted as soon | 1162 | //TODO: make gathering statistics optional, because it takes time |
1163 | // as possible - that is right after they have been processed | 1163 | p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) ); |
1164 | // by emit() [ see below ] | 1164 | #ifndef NODEBUG |
1165 | //TODO: make gathering statistics optional, because it takes time | 1165 | p->dumpStructure( const_cast<QObjectList*>( p->children() ) ); |
1166 | p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) ); | 1166 | #endif |
1167 | #ifndef NODEBUG | 1167 | return p; |
1168 | p->dumpStructure( const_cast<QObjectList*>( p->children() ) ); | 1168 | } |
1169 | #endif | 1169 | else |
1170 | return p; | 1170 | { |
1171 | } | 1171 | qWarning( "OPacketCapturer::next() - no packet received!" ); |
1172 | else | 1172 | return 0; |
1173 | { | 1173 | } |
1174 | qWarning( "OPacketCapturer::next() - no packet received!" ); | 1174 | } |
1175 | return 0; | 1175 | |
1176 | } | 1176 | |
1177 | } | 1177 | bool OPacketCapturer::open( const QString& name ) |
1178 | 1178 | { | |
1179 | 1179 | if ( _open ) | |
1180 | bool OPacketCapturer::open( const QString& name ) | 1180 | { |
1181 | { | 1181 | if ( name == _name ) // ignore opening an already openend device |
1182 | if ( _open ) | 1182 | { |
1183 | { | 1183 | return true; |
1184 | if ( name == _name ) // ignore opening an already openend device | 1184 | } |
1185 | { | 1185 | else // close the last opened device |
1186 | return true; | 1186 | { |
1187 | } | 1187 | close(); |
1188 | else // close the last opened device | 1188 | } |
1189 | { | 1189 | } |
1190 | close(); | 1190 | |
1191 | } | 1191 | _name = name; |
1192 | } | 1192 | |
1193 | 1193 | // open libpcap | |
1194 | _name = name; | 1194 | pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] ); |
1195 | 1195 | ||
1196 | // open libpcap | 1196 | if ( !handle ) |
1197 | pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] ); | 1197 | { |
1198 | 1198 | owarn << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl; | |
1199 | if ( !handle ) | 1199 | return false; |
1200 | { | 1200 | } |
1201 | qWarning( "OPacketCapturer::open(): can't open libpcap with '%s': %s", (const char*) name, _errbuf ); | 1201 | |
1202 | return false; | 1202 | odebug << "OPacketCapturer::open(): libpcap [" << name << "] opened successfully." << oendl; |
1203 | } | 1203 | _pch = handle; |
1204 | 1204 | _open = true; | |
1205 | qDebug( "OPacketCapturer::open(): libpcap [%s] opened successfully.", (const char*) name ); | 1205 | _stats.clear(); |
1206 | _pch = handle; | 1206 | |
1207 | _open = true; | 1207 | // in case we have an application object, create a socket notifier |
1208 | _stats.clear(); | 1208 | if ( qApp ) //TODO: I don't like this here... |
1209 | 1209 | { | |
1210 | // in case we have an application object, create a socket notifier | 1210 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); |
1211 | if ( qApp ) //TODO: I don't like this here... | 1211 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); |
1212 | { | 1212 | } |
1213 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); | 1213 | |
1214 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | 1214 | return true; |
1215 | } | 1215 | } |
1216 | 1216 | ||
1217 | return true; | 1217 | |
1218 | } | 1218 | bool OPacketCapturer::openDumpFile( const QString& filename ) |
1219 | 1219 | { | |
1220 | 1220 | pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) ); | |
1221 | bool OPacketCapturer::openDumpFile( const QString& filename ) | 1221 | if ( !dump ) |
1222 | { | 1222 | { |
1223 | pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) ); | 1223 | owarn << "OPacketCapturer::open(): can't open dump with '" << filename << "': " << _errbuf << oendl; |
1224 | if ( !dump ) | 1224 | return false; |
1225 | { | 1225 | } |
1226 | qWarning( "OPacketCapturer::open(): can't open dump with '%s': %s", (const char*) filename, _errbuf ); | 1226 | odebug << "OPacketCapturer::open(): dump [" << filename << "] opened successfully." << oendl; |
1227 | return false; | 1227 | _pcd = dump; |
1228 | } | 1228 | |
1229 | qDebug( "OPacketCapturer::open(): dump [%s] opened successfully.", (const char*) filename ); | 1229 | return true; |
1230 | _pcd = dump; | 1230 | } |
1231 | 1231 | ||
1232 | return true; | 1232 | |
1233 | } | 1233 | bool OPacketCapturer::open( const QFile& file ) |
1234 | 1234 | { | |
1235 | 1235 | QString name = file.name(); | |
1236 | bool OPacketCapturer::open( const QFile& file ) | 1236 | |
1237 | { | 1237 | if ( _open ) |
1238 | QString name = file.name(); | 1238 | { |
1239 | 1239 | close(); | |
1240 | if ( _open ) | 1240 | if ( name == _name ) // ignore opening an already openend device |
1241 | { | 1241 | { |
1242 | close(); | 1242 | return true; |
1243 | if ( name == _name ) // ignore opening an already openend device | 1243 | } |
1244 | { | 1244 | else // close the last opened device |
1245 | return true; | 1245 | { |
1246 | } | 1246 | close(); |
1247 | else // close the last opened device | 1247 | } |
1248 | { | 1248 | } |
1249 | close(); | 1249 | |
1250 | } | 1250 | _name = name; |
1251 | } | 1251 | |
1252 | 1252 | pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] ); | |
1253 | _name = name; | 1253 | |
1254 | 1254 | if ( handle ) | |
1255 | pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] ); | 1255 | { |
1256 | 1256 | odebug << "OPacketCapturer::open(): libpcap opened successfully." << oendl; | |
1257 | if ( handle ) | 1257 | _pch = handle; |
1258 | { | 1258 | _open = true; |
1259 | qDebug( "OPacketCapturer::open(): libpcap opened successfully." ); | 1259 | |
1260 | _pch = handle; | 1260 | // in case we have an application object, create a socket notifier |
1261 | _open = true; | 1261 | if ( qApp ) |
1262 | 1262 | { | |
1263 | // in case we have an application object, create a socket notifier | 1263 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); |
1264 | if ( qApp ) | 1264 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); |
1265 | { | 1265 | } |
1266 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); | 1266 | |
1267 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | 1267 | return true; |
1268 | } | 1268 | } |
1269 | 1269 | else | |
1270 | return true; | 1270 | { |
1271 | } | 1271 | odebug << "OPacketCapturer::open(): can't open libpcap with '" << name << "': " << _errbuf << oendl; |
1272 | else | 1272 | return false; |
1273 | { | 1273 | } |
1274 | qDebug( "OPacketCapturer::open(): can't open libpcap with '%s': %s", (const char*) name, _errbuf ); | 1274 | |
1275 | return false; | 1275 | } |
1276 | } | 1276 | |
1277 | 1277 | ||
1278 | } | 1278 | bool OPacketCapturer::isOpen() const |
1279 | 1279 | { | |
1280 | 1280 | return _open; | |
1281 | bool OPacketCapturer::isOpen() const | 1281 | } |
1282 | { | 1282 | |
1283 | return _open; | 1283 | |
1284 | } | 1284 | void OPacketCapturer::readyToReceive() |
1285 | 1285 | { | |
1286 | 1286 | odebug << "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" << oendl; | |
1287 | void OPacketCapturer::readyToReceive() | 1287 | OPacket* p = next(); |
1288 | { | 1288 | emit receivedPacket( p ); |
1289 | qDebug( "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" ); | 1289 | // emit is synchronous - packet has been dealt with, now it's safe to delete |
1290 | OPacket* p = next(); | 1290 | delete p; |
1291 | emit receivedPacket( p ); | 1291 | } |
1292 | // emit is synchronous - packet has been dealt with, now it's safe to delete | 1292 | |
1293 | delete p; | 1293 | |
1294 | } | 1294 | const QMap<QString,int>& OPacketCapturer::statistics() const |
1295 | 1295 | { | |
1296 | 1296 | return _stats; | |
1297 | const QMap<QString,int>& OPacketCapturer::statistics() const | 1297 | } |
1298 | { | 1298 | |
1299 | return _stats; | 1299 | |
1300 | } | 1300 | int OPacketCapturer::snapShot() const |
1301 | 1301 | { | |
1302 | 1302 | return pcap_snapshot( _pch ); | |
1303 | int OPacketCapturer::snapShot() const | 1303 | } |
1304 | { | 1304 | |
1305 | return pcap_snapshot( _pch ); | 1305 | |
1306 | } | 1306 | bool OPacketCapturer::swapped() const |
1307 | 1307 | { | |
1308 | 1308 | return pcap_is_swapped( _pch ); | |
1309 | bool OPacketCapturer::swapped() const | 1309 | } |
1310 | { | 1310 | |
1311 | return pcap_is_swapped( _pch ); | 1311 | |
1312 | } | 1312 | QString OPacketCapturer::version() const |
1313 | 1313 | { | |
1314 | 1314 | return QString().sprintf( "%s.%s", pcap_major_version( _pch ), pcap_minor_version( _pch ) ); | |
1315 | QString OPacketCapturer::version() const | 1315 | } |
1316 | { | 1316 | |
1317 | return QString().sprintf( "%s.%s", pcap_major_version( _pch ), pcap_minor_version( _pch ) ); | 1317 | |
1318 | } | ||
1319 | |||
1320 | |||