-rw-r--r-- | libopie2/opienet/opcap.cpp | 82 | ||||
-rw-r--r-- | libopie2/opienet/opcap.h | 10 |
2 files changed, 92 insertions, 0 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp index f1f2b4b..7a6f61b 100644 --- a/libopie2/opienet/opcap.cpp +++ b/libopie2/opienet/opcap.cpp | |||
@@ -348,136 +348,218 @@ OMacAddress OARPPacket::targetMacAddress() const | |||
348 | 348 | ||
349 | /*====================================================================================== | 349 | /*====================================================================================== |
350 | * OUDPPacket | 350 | * OUDPPacket |
351 | *======================================================================================*/ | 351 | *======================================================================================*/ |
352 | 352 | ||
353 | 353 | ||
354 | OUDPPacket::OUDPPacket( const unsigned char* end, const struct udphdr* data, QObject* parent ) | 354 | OUDPPacket::OUDPPacket( const unsigned char* end, const struct udphdr* data, QObject* parent ) |
355 | :QObject( parent, "UDP" ), _udphdr( data ) | 355 | :QObject( parent, "UDP" ), _udphdr( data ) |
356 | 356 | ||
357 | { | 357 | { |
358 | qDebug( "OUDPPacket::OUDPPacket(): decoding UDP header..." ); | 358 | qDebug( "OUDPPacket::OUDPPacket(): decoding UDP header..." ); |
359 | qDebug( "fromPort = %d", fromPort() ); | 359 | qDebug( "fromPort = %d", fromPort() ); |
360 | qDebug( " toPort = %d", toPort() ); | 360 | qDebug( " toPort = %d", toPort() ); |
361 | 361 | ||
362 | // TODO: Make this a case or a hash if we know more udp protocols | 362 | // TODO: Make this a case or a hash if we know more udp protocols |
363 | 363 | ||
364 | if ( fromPort() == UDP_PORT_BOOTPS || fromPort() == UDP_PORT_BOOTPC || | 364 | if ( fromPort() == UDP_PORT_BOOTPS || fromPort() == UDP_PORT_BOOTPC || |
365 | toPort() == UDP_PORT_BOOTPS || toPort() == UDP_PORT_BOOTPC ) | 365 | toPort() == UDP_PORT_BOOTPS || toPort() == UDP_PORT_BOOTPC ) |
366 | { | 366 | { |
367 | qDebug( "seems to be part of a DHCP conversation => creating DHCP packet." ); | 367 | qDebug( "seems to be part of a DHCP conversation => creating DHCP packet." ); |
368 | new ODHCPPacket( end, (const struct dhcp_packet*) (data+1), this ); | 368 | new ODHCPPacket( end, (const struct dhcp_packet*) (data+1), this ); |
369 | } | 369 | } |
370 | } | 370 | } |
371 | 371 | ||
372 | 372 | ||
373 | OUDPPacket::~OUDPPacket() | 373 | OUDPPacket::~OUDPPacket() |
374 | { | 374 | { |
375 | } | 375 | } |
376 | 376 | ||
377 | 377 | ||
378 | int OUDPPacket::fromPort() const | 378 | int OUDPPacket::fromPort() const |
379 | { | 379 | { |
380 | return EXTRACT_16BITS( &_udphdr->source ); | 380 | return EXTRACT_16BITS( &_udphdr->source ); |
381 | } | 381 | } |
382 | 382 | ||
383 | 383 | ||
384 | int OUDPPacket::toPort() const | 384 | int OUDPPacket::toPort() const |
385 | { | 385 | { |
386 | return EXTRACT_16BITS( &_udphdr->dest ); | 386 | return EXTRACT_16BITS( &_udphdr->dest ); |
387 | } | 387 | } |
388 | 388 | ||
389 | 389 | ||
390 | int OUDPPacket::length() const | 390 | int OUDPPacket::length() const |
391 | { | 391 | { |
392 | return EXTRACT_16BITS( &_udphdr->len ); | 392 | return EXTRACT_16BITS( &_udphdr->len ); |
393 | } | 393 | } |
394 | 394 | ||
395 | 395 | ||
396 | int OUDPPacket::checksum() const | 396 | int OUDPPacket::checksum() const |
397 | { | 397 | { |
398 | return EXTRACT_16BITS( &_udphdr->check ); | 398 | return EXTRACT_16BITS( &_udphdr->check ); |
399 | } | 399 | } |
400 | 400 | ||
401 | 401 | ||
402 | /*====================================================================================== | 402 | /*====================================================================================== |
403 | * ODHCPPacket | 403 | * ODHCPPacket |
404 | *======================================================================================*/ | 404 | *======================================================================================*/ |
405 | 405 | ||
406 | 406 | ||
407 | ODHCPPacket::ODHCPPacket( const unsigned char* end, const struct dhcp_packet* data, QObject* parent ) | 407 | ODHCPPacket::ODHCPPacket( const unsigned char* end, const struct dhcp_packet* data, QObject* parent ) |
408 | :QObject( parent, "DHCP" ), _dhcphdr( data ) | 408 | :QObject( parent, "DHCP" ), _dhcphdr( data ) |
409 | 409 | ||
410 | { | 410 | { |
411 | qDebug( "ODHCPPacket::ODHCPPacket(): decoding DHCP information..." ); | 411 | qDebug( "ODHCPPacket::ODHCPPacket(): decoding DHCP information..." ); |
412 | qDebug( "DHCP opcode seems to be %02d - '%s'", _dhcphdr->op, isRequest() ? "REQUEST" : "REPLY" ); | ||
413 | qDebug( "clientAddress: %s", (const char*) clientAddress().toString() ); | ||
414 | qDebug( " yourAddress: %s", (const char*) yourAddress().toString() ); | ||
415 | qDebug( "serverAddress: %s", (const char*) serverAddress().toString() ); | ||
416 | qDebug( " relayAddress: %s", (const char*) relayAddress().toString() ); | ||
417 | qDebug( "parsing DHCP options..." ); | ||
418 | |||
419 | _type = 0; | ||
420 | |||
421 | const unsigned char* option = &_dhcphdr->options[4]; | ||
422 | char tag = -1; | ||
423 | char len = -1; | ||
424 | |||
425 | while ( ( tag = *option++ ) != -1 /* end of option field */ ) | ||
426 | { | ||
427 | len = *option++; | ||
428 | qDebug( "recognized DHCP option #%d, length %d", tag, len ); | ||
429 | |||
430 | if ( tag == DHO_DHCP_MESSAGE_TYPE ) | ||
431 | _type = *option; | ||
432 | |||
433 | option += len; | ||
434 | if ( option >= end ) | ||
435 | { | ||
436 | qWarning( "DHCP parsing ERROR: sanity check says the packet is at its end!" ); | ||
437 | break; | ||
438 | } | ||
439 | } | ||
440 | |||
441 | qDebug( "DHCP type seems to be '%s'", (const char*) type() ); | ||
412 | } | 442 | } |
413 | 443 | ||
414 | 444 | ||
415 | ODHCPPacket::~ODHCPPacket() | 445 | ODHCPPacket::~ODHCPPacket() |
416 | { | 446 | { |
417 | } | 447 | } |
418 | 448 | ||
419 | 449 | ||
450 | bool ODHCPPacket::isRequest() const | ||
451 | { | ||
452 | return ( _dhcphdr->op == 01 ); | ||
453 | } | ||
454 | |||
455 | |||
456 | bool ODHCPPacket::isReply() const | ||
457 | { | ||
458 | return ( _dhcphdr->op == 02 ); | ||
459 | } | ||
460 | |||
461 | |||
462 | QString ODHCPPacket::type() const | ||
463 | { | ||
464 | switch ( _type ) | ||
465 | { | ||
466 | case 1: return "DISCOVER"; | ||
467 | case 2: return "OFFER"; | ||
468 | case 3: return "REQUEST"; | ||
469 | case 4: return "DECLINE"; | ||
470 | case 5: return "ACK"; | ||
471 | case 6: return "NAK"; | ||
472 | case 7: return "RELEASE"; | ||
473 | case 8: return "INFORM"; | ||
474 | default: qWarning( "ODHCPPacket::type(): invalid DHCP type (%d) !", _dhcphdr->op ); return "<unknown>"; | ||
475 | } | ||
476 | } | ||
477 | |||
478 | |||
479 | QHostAddress ODHCPPacket::clientAddress() const | ||
480 | { | ||
481 | return EXTRACT_32BITS( &_dhcphdr->ciaddr ); | ||
482 | } | ||
483 | |||
484 | |||
485 | QHostAddress ODHCPPacket::yourAddress() const | ||
486 | { | ||
487 | return EXTRACT_32BITS( &_dhcphdr->yiaddr ); | ||
488 | } | ||
489 | |||
490 | |||
491 | QHostAddress ODHCPPacket::serverAddress() const | ||
492 | { | ||
493 | return EXTRACT_32BITS( &_dhcphdr->siaddr ); | ||
494 | } | ||
495 | |||
496 | |||
497 | QHostAddress ODHCPPacket::relayAddress() const | ||
498 | { | ||
499 | return EXTRACT_32BITS( &_dhcphdr->giaddr ); | ||
500 | } | ||
501 | |||
420 | /*====================================================================================== | 502 | /*====================================================================================== |
421 | * OTCPPacket | 503 | * OTCPPacket |
422 | *======================================================================================*/ | 504 | *======================================================================================*/ |
423 | 505 | ||
424 | 506 | ||
425 | OTCPPacket::OTCPPacket( const unsigned char* end, const struct tcphdr* data, QObject* parent ) | 507 | OTCPPacket::OTCPPacket( const unsigned char* end, const struct tcphdr* data, QObject* parent ) |
426 | :QObject( parent, "TCP" ), _tcphdr( data ) | 508 | :QObject( parent, "TCP" ), _tcphdr( data ) |
427 | 509 | ||
428 | { | 510 | { |
429 | qDebug( "OTCPPacket::OTCPPacket(): decoding TCP header..." ); | 511 | qDebug( "OTCPPacket::OTCPPacket(): decoding TCP header..." ); |
430 | } | 512 | } |
431 | 513 | ||
432 | 514 | ||
433 | OTCPPacket::~OTCPPacket() | 515 | OTCPPacket::~OTCPPacket() |
434 | { | 516 | { |
435 | } | 517 | } |
436 | 518 | ||
437 | 519 | ||
438 | int OTCPPacket::fromPort() const | 520 | int OTCPPacket::fromPort() const |
439 | { | 521 | { |
440 | return EXTRACT_16BITS( &_tcphdr->source ); | 522 | return EXTRACT_16BITS( &_tcphdr->source ); |
441 | } | 523 | } |
442 | 524 | ||
443 | 525 | ||
444 | int OTCPPacket::toPort() const | 526 | int OTCPPacket::toPort() const |
445 | { | 527 | { |
446 | return EXTRACT_16BITS( &_tcphdr->dest ); | 528 | return EXTRACT_16BITS( &_tcphdr->dest ); |
447 | } | 529 | } |
448 | 530 | ||
449 | 531 | ||
450 | int OTCPPacket::seq() const | 532 | int OTCPPacket::seq() const |
451 | { | 533 | { |
452 | return EXTRACT_16BITS( &_tcphdr->seq ); | 534 | return EXTRACT_16BITS( &_tcphdr->seq ); |
453 | } | 535 | } |
454 | 536 | ||
455 | 537 | ||
456 | int OTCPPacket::ack() const | 538 | int OTCPPacket::ack() const |
457 | { | 539 | { |
458 | return EXTRACT_16BITS( &_tcphdr->ack_seq ); | 540 | return EXTRACT_16BITS( &_tcphdr->ack_seq ); |
459 | } | 541 | } |
460 | 542 | ||
461 | 543 | ||
462 | int OTCPPacket::window() const | 544 | int OTCPPacket::window() const |
463 | { | 545 | { |
464 | return EXTRACT_16BITS( &_tcphdr->window ); | 546 | return EXTRACT_16BITS( &_tcphdr->window ); |
465 | } | 547 | } |
466 | 548 | ||
467 | 549 | ||
468 | int OTCPPacket::checksum() const | 550 | int OTCPPacket::checksum() const |
469 | { | 551 | { |
470 | return EXTRACT_16BITS( &_tcphdr->check ); | 552 | return EXTRACT_16BITS( &_tcphdr->check ); |
471 | } | 553 | } |
472 | 554 | ||
473 | /*====================================================================================== | 555 | /*====================================================================================== |
474 | * OPrismHeaderPacket | 556 | * OPrismHeaderPacket |
475 | *======================================================================================*/ | 557 | *======================================================================================*/ |
476 | 558 | ||
477 | 559 | ||
478 | OPrismHeaderPacket::OPrismHeaderPacket( const unsigned char* end, const struct prism_hdr* data, QObject* parent ) | 560 | OPrismHeaderPacket::OPrismHeaderPacket( const unsigned char* end, const struct prism_hdr* data, QObject* parent ) |
479 | :QObject( parent, "Prism" ), _header( data ) | 561 | :QObject( parent, "Prism" ), _header( data ) |
480 | 562 | ||
481 | { | 563 | { |
482 | qDebug( "OPrismHeaderPacket::OPrismHeaderPacket(): decoding PRISM header..." ); | 564 | qDebug( "OPrismHeaderPacket::OPrismHeaderPacket(): decoding PRISM header..." ); |
483 | 565 | ||
diff --git a/libopie2/opienet/opcap.h b/libopie2/opienet/opcap.h index 0c9e7da..a031dd1 100644 --- a/libopie2/opienet/opcap.h +++ b/libopie2/opienet/opcap.h | |||
@@ -438,130 +438,140 @@ class OIPPacket : public QObject | |||
438 | int protocol() const; | 438 | int protocol() const; |
439 | int checksum() const; | 439 | int checksum() const; |
440 | 440 | ||
441 | private: | 441 | private: |
442 | const struct iphdr* _iphdr; | 442 | const struct iphdr* _iphdr; |
443 | }; | 443 | }; |
444 | 444 | ||
445 | /*====================================================================================== | 445 | /*====================================================================================== |
446 | * OARPPacket | 446 | * OARPPacket |
447 | *======================================================================================*/ | 447 | *======================================================================================*/ |
448 | 448 | ||
449 | class OARPPacket : public QObject | 449 | class OARPPacket : public QObject |
450 | { | 450 | { |
451 | Q_OBJECT | 451 | Q_OBJECT |
452 | 452 | ||
453 | public: | 453 | public: |
454 | OARPPacket( const unsigned char*, const struct myarphdr*, QObject* parent = 0 ); | 454 | OARPPacket( const unsigned char*, const struct myarphdr*, QObject* parent = 0 ); |
455 | virtual ~OARPPacket(); | 455 | virtual ~OARPPacket(); |
456 | 456 | ||
457 | QHostAddress senderIPV4Address() const; | 457 | QHostAddress senderIPV4Address() const; |
458 | OMacAddress senderMacAddress() const; | 458 | OMacAddress senderMacAddress() const; |
459 | QHostAddress targetIPV4Address() const; | 459 | QHostAddress targetIPV4Address() const; |
460 | OMacAddress targetMacAddress() const; | 460 | OMacAddress targetMacAddress() const; |
461 | 461 | ||
462 | //int type() const; | 462 | //int type() const; |
463 | QString type() const; | 463 | QString type() const; |
464 | 464 | ||
465 | private: | 465 | private: |
466 | const struct myarphdr* _arphdr; | 466 | const struct myarphdr* _arphdr; |
467 | }; | 467 | }; |
468 | 468 | ||
469 | /*====================================================================================== | 469 | /*====================================================================================== |
470 | * OUDPPacket | 470 | * OUDPPacket |
471 | *======================================================================================*/ | 471 | *======================================================================================*/ |
472 | 472 | ||
473 | class OUDPPacket : public QObject | 473 | class OUDPPacket : public QObject |
474 | { | 474 | { |
475 | Q_OBJECT | 475 | Q_OBJECT |
476 | 476 | ||
477 | public: | 477 | public: |
478 | OUDPPacket( const unsigned char*, const struct udphdr*, QObject* parent = 0 ); | 478 | OUDPPacket( const unsigned char*, const struct udphdr*, QObject* parent = 0 ); |
479 | virtual ~OUDPPacket(); | 479 | virtual ~OUDPPacket(); |
480 | 480 | ||
481 | int fromPort() const; | 481 | int fromPort() const; |
482 | int toPort() const; | 482 | int toPort() const; |
483 | int length() const; | 483 | int length() const; |
484 | int checksum() const; | 484 | int checksum() const; |
485 | 485 | ||
486 | private: | 486 | private: |
487 | const struct udphdr* _udphdr; | 487 | const struct udphdr* _udphdr; |
488 | }; | 488 | }; |
489 | 489 | ||
490 | /*====================================================================================== | 490 | /*====================================================================================== |
491 | * ODHCPPacket | 491 | * ODHCPPacket |
492 | *======================================================================================*/ | 492 | *======================================================================================*/ |
493 | 493 | ||
494 | class ODHCPPacket : public QObject | 494 | class ODHCPPacket : public QObject |
495 | { | 495 | { |
496 | Q_OBJECT | 496 | Q_OBJECT |
497 | 497 | ||
498 | public: | 498 | public: |
499 | ODHCPPacket( const unsigned char*, const struct dhcp_packet*, QObject* parent = 0 ); | 499 | ODHCPPacket( const unsigned char*, const struct dhcp_packet*, QObject* parent = 0 ); |
500 | virtual ~ODHCPPacket(); | 500 | virtual ~ODHCPPacket(); |
501 | 501 | ||
502 | QHostAddress clientAddress() const; | ||
503 | QHostAddress yourAddress() const; | ||
504 | QHostAddress serverAddress() const; | ||
505 | QHostAddress relayAddress() const; | ||
506 | |||
507 | bool isRequest() const; | ||
508 | bool isReply() const; | ||
509 | QString type() const; | ||
510 | |||
502 | private: | 511 | private: |
503 | const struct dhcp_packet* _dhcphdr; | 512 | const struct dhcp_packet* _dhcphdr; |
513 | unsigned char _type; | ||
504 | }; | 514 | }; |
505 | 515 | ||
506 | /*====================================================================================== | 516 | /*====================================================================================== |
507 | * OTCPPacket | 517 | * OTCPPacket |
508 | *======================================================================================*/ | 518 | *======================================================================================*/ |
509 | 519 | ||
510 | class OTCPPacket : public QObject | 520 | class OTCPPacket : public QObject |
511 | { | 521 | { |
512 | Q_OBJECT | 522 | Q_OBJECT |
513 | 523 | ||
514 | public: | 524 | public: |
515 | OTCPPacket( const unsigned char*, const struct tcphdr*, QObject* parent = 0 ); | 525 | OTCPPacket( const unsigned char*, const struct tcphdr*, QObject* parent = 0 ); |
516 | virtual ~OTCPPacket(); | 526 | virtual ~OTCPPacket(); |
517 | 527 | ||
518 | int fromPort() const; | 528 | int fromPort() const; |
519 | int toPort() const; | 529 | int toPort() const; |
520 | int seq() const; | 530 | int seq() const; |
521 | int ack() const; | 531 | int ack() const; |
522 | int window() const; | 532 | int window() const; |
523 | int checksum() const; | 533 | int checksum() const; |
524 | 534 | ||
525 | private: | 535 | private: |
526 | const struct tcphdr* _tcphdr; | 536 | const struct tcphdr* _tcphdr; |
527 | }; | 537 | }; |
528 | 538 | ||
529 | 539 | ||
530 | /*====================================================================================== | 540 | /*====================================================================================== |
531 | * OPacketCapturer | 541 | * OPacketCapturer |
532 | *======================================================================================*/ | 542 | *======================================================================================*/ |
533 | 543 | ||
534 | /** | 544 | /** |
535 | * @brief A class based wrapper for network packet capturing. | 545 | * @brief A class based wrapper for network packet capturing. |
536 | * | 546 | * |
537 | * This class is the base of a high-level interface to the well known packet capturing | 547 | * This class is the base of a high-level interface to the well known packet capturing |
538 | * library libpcap. | 548 | * library libpcap. |
539 | * @see http://tcpdump.org | 549 | * @see http://tcpdump.org |
540 | */ | 550 | */ |
541 | class OPacketCapturer : public QObject | 551 | class OPacketCapturer : public QObject |
542 | { | 552 | { |
543 | Q_OBJECT | 553 | Q_OBJECT |
544 | 554 | ||
545 | public: | 555 | public: |
546 | /** | 556 | /** |
547 | * Constructor. | 557 | * Constructor. |
548 | */ | 558 | */ |
549 | OPacketCapturer( QObject* parent = 0, const char* name = 0 ); | 559 | OPacketCapturer( QObject* parent = 0, const char* name = 0 ); |
550 | /** | 560 | /** |
551 | * Destructor. | 561 | * Destructor. |
552 | */ | 562 | */ |
553 | ~OPacketCapturer(); | 563 | ~OPacketCapturer(); |
554 | /** | 564 | /** |
555 | * Set the packet capturer to use blocking or non-blocking IO. This can be useful when | 565 | * Set the packet capturer to use blocking or non-blocking IO. This can be useful when |
556 | * not using the socket notifier, e.g. without an application object. | 566 | * not using the socket notifier, e.g. without an application object. |
557 | */ | 567 | */ |
558 | void setBlocking( bool ); | 568 | void setBlocking( bool ); |
559 | /** | 569 | /** |
560 | * @returns true if the packet capturer uses blocking IO calls. | 570 | * @returns true if the packet capturer uses blocking IO calls. |
561 | */ | 571 | */ |
562 | bool blocking() const; | 572 | bool blocking() const; |
563 | /** | 573 | /** |
564 | * Close the packet capturer. This is automatically done in the destructor. | 574 | * Close the packet capturer. This is automatically done in the destructor. |
565 | */ | 575 | */ |
566 | void close(); | 576 | void close(); |
567 | /** | 577 | /** |