-rw-r--r-- | libopie2/opienet/opcap.cpp | 47 | ||||
-rw-r--r-- | libopie2/opienet/opcap.h | 4 |
2 files changed, 34 insertions, 17 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp index 30f6208..04b1bb1 100644 --- a/libopie2/opienet/opcap.cpp +++ b/libopie2/opienet/opcap.cpp | |||
@@ -725,25 +725,25 @@ OWaveLanControlPacket::OWaveLanControlPacket( const unsigned char* end, const st | |||
725 | 725 | ||
726 | OWaveLanControlPacket::~OWaveLanControlPacket() | 726 | OWaveLanControlPacket::~OWaveLanControlPacket() |
727 | { | 727 | { |
728 | } | 728 | } |
729 | 729 | ||
730 | 730 | ||
731 | /*====================================================================================== | 731 | /*====================================================================================== |
732 | * OPacketCapturer | 732 | * OPacketCapturer |
733 | *======================================================================================*/ | 733 | *======================================================================================*/ |
734 | 734 | ||
735 | OPacketCapturer::OPacketCapturer( QObject* parent, const char* name ) | 735 | OPacketCapturer::OPacketCapturer( QObject* parent, const char* name ) |
736 | :QObject( parent, name ), _name( QString::null ), _open( false ), | 736 | :QObject( parent, name ), _name( QString::null ), _open( false ), |
737 | _pch( 0 ), _sn( 0 ) | 737 | _pch( 0 ), _pcd( 0 ), _sn( 0 ) |
738 | { | 738 | { |
739 | } | 739 | } |
740 | 740 | ||
741 | 741 | ||
742 | OPacketCapturer::~OPacketCapturer() | 742 | OPacketCapturer::~OPacketCapturer() |
743 | { | 743 | { |
744 | if ( _open ) | 744 | if ( _open ) |
745 | { | 745 | { |
746 | qDebug( "OPacketCapturer::~OPacketCapturer(): pcap still open, autoclosing." ); | 746 | qDebug( "OPacketCapturer::~OPacketCapturer(): pcap still open, autoclosing." ); |
747 | close(); | 747 | close(); |
748 | } | 748 | } |
749 | } | 749 | } |
@@ -774,24 +774,29 @@ bool OPacketCapturer::blocking() const | |||
774 | } | 774 | } |
775 | 775 | ||
776 | 776 | ||
777 | void OPacketCapturer::close() | 777 | void OPacketCapturer::close() |
778 | { | 778 | { |
779 | if ( _open ) | 779 | if ( _open ) |
780 | { | 780 | { |
781 | if ( _sn ) | 781 | if ( _sn ) |
782 | { | 782 | { |
783 | _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | 783 | _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); |
784 | delete _sn; | 784 | delete _sn; |
785 | } | 785 | } |
786 | if ( _pcd ) | ||
787 | { | ||
788 | pcap_dump_close( _pcd ); | ||
789 | _pcd = 0; | ||
790 | } | ||
786 | pcap_close( _pch ); | 791 | pcap_close( _pch ); |
787 | _open = false; | 792 | _open = false; |
788 | } | 793 | } |
789 | 794 | ||
790 | qDebug( "OPacketCapturer::close() --- dumping capturing statistics..." ); | 795 | qDebug( "OPacketCapturer::close() --- dumping capturing statistics..." ); |
791 | qDebug( "--------------------------------------------------" ); | 796 | qDebug( "--------------------------------------------------" ); |
792 | for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) | 797 | for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) |
793 | qDebug( "%s : %d", (const char*) it.key(), it.data() ); | 798 | qDebug( "%s : %d", (const char*) it.key(), it.data() ); |
794 | qDebug( "--------------------------------------------------" ); | 799 | qDebug( "--------------------------------------------------" ); |
795 | 800 | ||
796 | } | 801 | } |
797 | 802 | ||
@@ -811,84 +816,94 @@ int OPacketCapturer::fileno() const | |||
811 | else | 816 | else |
812 | { | 817 | { |
813 | return -1; | 818 | return -1; |
814 | } | 819 | } |
815 | } | 820 | } |
816 | 821 | ||
817 | OPacket* OPacketCapturer::next() | 822 | OPacket* OPacketCapturer::next() |
818 | { | 823 | { |
819 | packetheaderstruct header; | 824 | packetheaderstruct header; |
820 | qDebug( "==> OPacketCapturer::next()" ); | 825 | qDebug( "==> OPacketCapturer::next()" ); |
821 | const unsigned char* pdata = pcap_next( _pch, &header ); | 826 | const unsigned char* pdata = pcap_next( _pch, &header ); |
822 | qDebug( "<== OPacketCapturer::next()" ); | 827 | qDebug( "<== OPacketCapturer::next()" ); |
828 | if ( _pcd ) | ||
829 | pcap_dump( (u_char*) _pcd, &header, pdata ); | ||
823 | 830 | ||
824 | if ( header.len ) | 831 | if ( header.len ) |
825 | { | 832 | { |
826 | OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); | 833 | OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); |
827 | // packets shouldn't be inserted in the QObject child-parent hierarchy, | 834 | // packets shouldn't be inserted in the QObject child-parent hierarchy, |
828 | // because due to memory constraints they will be deleted as soon | 835 | // because due to memory constraints they will be deleted as soon |
829 | // as possible - that is right after they have been processed | 836 | // as possible - that is right after they have been processed |
830 | // by emit() [ see below ] | 837 | // by emit() [ see below ] |
831 | //TODO: make gathering statistics optional, because it takes time | 838 | //TODO: make gathering statistics optional, because it takes time |
832 | p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) ); | 839 | p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) ); |
833 | 840 | ||
834 | return p; | 841 | return p; |
835 | } | 842 | } |
836 | else | 843 | else |
837 | { | 844 | { |
838 | return 0; | 845 | return 0; |
839 | } | 846 | } |
840 | } | 847 | } |
841 | 848 | ||
842 | 849 | ||
843 | bool OPacketCapturer::open( const QString& name ) | 850 | bool OPacketCapturer::open( const QString& name, const QString& filename ) |
844 | { | 851 | { |
845 | if ( _open ) | 852 | if ( _open ) |
846 | { | 853 | { |
847 | if ( name == _name ) // ignore opening an already openend device | 854 | if ( name == _name ) // ignore opening an already openend device |
848 | { | 855 | { |
849 | return true; | 856 | return true; |
850 | } | 857 | } |
851 | else // close the last opened device | 858 | else // close the last opened device |
852 | { | 859 | { |
853 | close(); | 860 | close(); |
854 | } | 861 | } |
855 | } | 862 | } |
856 | 863 | ||
857 | _name = name; | 864 | _name = name; |
858 | 865 | ||
866 | // open libpcap | ||
859 | pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] ); | 867 | pcap_t* handle = pcap_open_live( const_cast<char*>( (const char*) name ), 1024, 0, 0, &_errbuf[0] ); |
860 | 868 | ||
861 | if ( handle ) | 869 | if ( !handle ) |
862 | { | 870 | { |
863 | qDebug( "OPacketCapturer::open(): libpcap opened successfully." ); | 871 | qWarning( "OPacketCapturer::open(): can't open libpcap with '%s': %s", (const char*) name, _errbuf ); |
864 | _pch = handle; | 872 | return false; |
865 | _open = true; | 873 | } |
866 | _stats.clear(); | ||
867 | 874 | ||
868 | // in case we have an application object, create a socket notifier | 875 | qDebug( "OPacketCapturer::open(): libpcap [%s] opened successfully.", (const char*) name ); |
869 | if ( qApp ) | 876 | _pch = handle; |
870 | { | 877 | _open = true; |
871 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); | 878 | _stats.clear(); |
872 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | ||
873 | } | ||
874 | 879 | ||
875 | return true; | 880 | // in case we have an application object, create a socket notifier |
881 | if ( qApp ) //TODO: I don't like this here... | ||
882 | { | ||
883 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); | ||
884 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | ||
876 | } | 885 | } |
877 | else | 886 | |
887 | // if requested, open a dump | ||
888 | pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) ); | ||
889 | if ( !dump ) | ||
878 | { | 890 | { |
879 | qDebug( "OPacketCapturer::open(): can't open libpcap with '%s': %s", (const char*) name, _errbuf ); | 891 | qWarning( "OPacketCapturer::open(): can't open dump with '%s': %s", (const char*) filename, _errbuf ); |
880 | return false; | 892 | return false; |
881 | } | 893 | } |
894 | qDebug( "OPacketCapturer::open(): dump [%s] opened successfully.", (const char*) filename ); | ||
895 | _pcd = dump; | ||
882 | 896 | ||
897 | return true; | ||
883 | } | 898 | } |
884 | 899 | ||
885 | 900 | ||
886 | bool OPacketCapturer::open( const QFile& file ) | 901 | bool OPacketCapturer::open( const QFile& file ) |
887 | { | 902 | { |
888 | QString name = file.name(); | 903 | QString name = file.name(); |
889 | 904 | ||
890 | if ( _open ) | 905 | if ( _open ) |
891 | { | 906 | { |
892 | close(); | 907 | close(); |
893 | if ( name == _name ) // ignore opening an already openend device | 908 | if ( name == _name ) // ignore opening an already openend device |
894 | { | 909 | { |
diff --git a/libopie2/opienet/opcap.h b/libopie2/opienet/opcap.h index 6c3ac6d..99631ba 100644 --- a/libopie2/opienet/opcap.h +++ b/libopie2/opienet/opcap.h | |||
@@ -461,45 +461,47 @@ class OPacketCapturer : public QObject | |||
461 | /** | 461 | /** |
462 | * @returns the filedescriptor of the packet capturer. This is only useful, if | 462 | * @returns the filedescriptor of the packet capturer. This is only useful, if |
463 | * not using the socket notifier, e.g. without an application object. | 463 | * not using the socket notifier, e.g. without an application object. |
464 | */ | 464 | */ |
465 | int fileno() const; | 465 | int fileno() const; |
466 | /** | 466 | /** |
467 | * @returns the next @ref OPacket from the packet capturer. | 467 | * @returns the next @ref OPacket from the packet capturer. |
468 | * @note If blocking mode is true then this call might block. | 468 | * @note If blocking mode is true then this call might block. |
469 | */ | 469 | */ |
470 | OPacket* next(); | 470 | OPacket* next(); |
471 | /** | 471 | /** |
472 | * Open the packet capturer to capture packets in live-mode from @a interface. | 472 | * Open the packet capturer to capture packets in live-mode from @a interface. |
473 | * If a @a filename is given, all captured packets are output to a tcpdump-compatible capture file. | ||
473 | */ | 474 | */ |
474 | bool open( const QString& interface ); | 475 | bool open( const QString& interface, const QString& filename = QString::null ); |
475 | /** | 476 | /** |
476 | * Open the packet capturer to capture packets in offline-mode from @a file. | 477 | * Open the packet capturer to capture packets in offline-mode from @a file. |
477 | */ | 478 | */ |
478 | bool open( const QFile& file ); | 479 | bool open( const QFile& file ); |
479 | /** | 480 | /** |
480 | * @returns true if the packet capturer is open | 481 | * @returns true if the packet capturer is open |
481 | */ | 482 | */ |
482 | bool isOpen() const; | 483 | bool isOpen() const; |
483 | 484 | ||
484 | const QMap<QString,int>& statistics() const; | 485 | const QMap<QString,int>& statistics() const; |
485 | 486 | ||
486 | signals: | 487 | signals: |
487 | /** | 488 | /** |
488 | * This signal is emitted, when a packet has been received. | 489 | * This signal is emitted, when a packet has been received. |
489 | */ | 490 | */ |
490 | void receivedPacket( OPacket* ); | 491 | void receivedPacket( OPacket* ); |
491 | 492 | ||
492 | protected slots: | 493 | protected slots: |
493 | void readyToReceive(); | 494 | void readyToReceive(); |
494 | 495 | ||
495 | protected: | 496 | protected: |
496 | QString _name; // devicename | 497 | QString _name; // devicename |
497 | bool _open; // check this before doing pcap calls | 498 | bool _open; // check this before doing pcap calls |
498 | pcap_t* _pch; // pcap library handle | 499 | pcap_t* _pch; // pcap library handle |
500 | pcap_dumper_t* _pcd; // pcap dumper handle | ||
499 | QSocketNotifier* _sn; // socket notifier for main loop | 501 | QSocketNotifier* _sn; // socket notifier for main loop |
500 | mutable char _errbuf[PCAP_ERRBUF_SIZE]; // holds error strings from libpcap | 502 | mutable char _errbuf[PCAP_ERRBUF_SIZE]; // holds error strings from libpcap |
501 | QMap<QString, int> _stats; // statistics; | 503 | QMap<QString, int> _stats; // statistics; |
502 | }; | 504 | }; |
503 | 505 | ||
504 | #endif // OPCAP_H | 506 | #endif // OPCAP_H |
505 | 507 | ||