-rw-r--r-- | libopie2/opienet/opcap.cpp | 42 | ||||
-rw-r--r-- | libopie2/opienet/opcap.h | 21 |
2 files changed, 48 insertions, 15 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp index bef9182..1de7124 100644 --- a/libopie2/opienet/opcap.cpp +++ b/libopie2/opienet/opcap.cpp | |||
@@ -861,28 +861,34 @@ bool OPacketCapturer::blocking() const | |||
861 | return -1; | 861 | return -1; |
862 | } | 862 | } |
863 | return !b; | 863 | return !b; |
864 | } | 864 | } |
865 | 865 | ||
866 | 866 | ||
867 | void OPacketCapturer::closeDumpFile() | ||
868 | { | ||
869 | if ( _pcd ) | ||
870 | { | ||
871 | pcap_dump_close( _pcd ); | ||
872 | _pcd = 0; | ||
873 | } | ||
874 | pcap_close( _pch ); | ||
875 | } | ||
876 | |||
877 | |||
867 | void OPacketCapturer::close() | 878 | void OPacketCapturer::close() |
868 | { | 879 | { |
869 | if ( _open ) | 880 | if ( _open ) |
870 | { | 881 | { |
871 | if ( _sn ) | 882 | if ( _sn ) |
872 | { | 883 | { |
873 | _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | 884 | _sn->disconnect( SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); |
874 | delete _sn; | 885 | delete _sn; |
875 | } | 886 | } |
876 | if ( _pcd ) | 887 | closeDumpFile(); |
877 | { | 888 | _open = false; |
878 | pcap_dump_close( _pcd ); | ||
879 | _pcd = 0; | ||
880 | } | ||
881 | pcap_close( _pch ); | ||
882 | _open = false; | ||
883 | } | 889 | } |
884 | 890 | ||
885 | qDebug( "OPacketCapturer::close() --- dumping capturing statistics..." ); | 891 | qDebug( "OPacketCapturer::close() --- dumping capturing statistics..." ); |
886 | qDebug( "--------------------------------------------------" ); | 892 | qDebug( "--------------------------------------------------" ); |
887 | for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) | 893 | for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it ) |
888 | qDebug( "%s : %d", (const char*) it.key(), it.data() ); | 894 | qDebug( "%s : %d", (const char*) it.key(), it.data() ); |
@@ -894,12 +900,23 @@ void OPacketCapturer::close() | |||
894 | int OPacketCapturer::dataLink() const | 900 | int OPacketCapturer::dataLink() const |
895 | { | 901 | { |
896 | return pcap_datalink( _pch ); | 902 | return pcap_datalink( _pch ); |
897 | } | 903 | } |
898 | 904 | ||
899 | 905 | ||
906 | void OPacketCapturer::dump( OPacket* p ) | ||
907 | { | ||
908 | if ( !_pcd ) | ||
909 | { | ||
910 | qWarning( "OPacketCapturer::dump() - cannot dump without open capture file!" ); | ||
911 | return; | ||
912 | } | ||
913 | pcap_dump( (u_char*) _pcd, &p->_hdr, p->_data ); | ||
914 | } | ||
915 | |||
916 | |||
900 | int OPacketCapturer::fileno() const | 917 | int OPacketCapturer::fileno() const |
901 | { | 918 | { |
902 | if ( _open ) | 919 | if ( _open ) |
903 | { | 920 | { |
904 | return pcap_fileno( _pch ); | 921 | return pcap_fileno( _pch ); |
905 | } | 922 | } |
@@ -912,14 +929,12 @@ int OPacketCapturer::fileno() const | |||
912 | OPacket* OPacketCapturer::next() | 929 | OPacket* OPacketCapturer::next() |
913 | { | 930 | { |
914 | packetheaderstruct header; | 931 | packetheaderstruct header; |
915 | qDebug( "==> OPacketCapturer::next()" ); | 932 | qDebug( "==> OPacketCapturer::next()" ); |
916 | const unsigned char* pdata = pcap_next( _pch, &header ); | 933 | const unsigned char* pdata = pcap_next( _pch, &header ); |
917 | qDebug( "<== OPacketCapturer::next()" ); | 934 | qDebug( "<== OPacketCapturer::next()" ); |
918 | if ( _pcd ) | ||
919 | pcap_dump( (u_char*) _pcd, &header, pdata ); | ||
920 | 935 | ||
921 | if ( pdata && header.len ) | 936 | if ( pdata && header.len ) |
922 | { | 937 | { |
923 | OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); | 938 | OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); |
924 | // packets shouldn't be inserted in the QObject child-parent hierarchy, | 939 | // packets shouldn't be inserted in the QObject child-parent hierarchy, |
925 | // because due to memory constraints they will be deleted as soon | 940 | // because due to memory constraints they will be deleted as soon |
@@ -935,13 +950,13 @@ OPacket* OPacketCapturer::next() | |||
935 | qWarning( "OPacketCapturer::next() - no packet received!" ); | 950 | qWarning( "OPacketCapturer::next() - no packet received!" ); |
936 | return 0; | 951 | return 0; |
937 | } | 952 | } |
938 | } | 953 | } |
939 | 954 | ||
940 | 955 | ||
941 | bool OPacketCapturer::open( const QString& name, const QString& filename ) | 956 | bool OPacketCapturer::open( const QString& name ) |
942 | { | 957 | { |
943 | if ( _open ) | 958 | if ( _open ) |
944 | { | 959 | { |
945 | if ( name == _name ) // ignore opening an already openend device | 960 | if ( name == _name ) // ignore opening an already openend device |
946 | { | 961 | { |
947 | return true; | 962 | return true; |
@@ -972,13 +987,18 @@ bool OPacketCapturer::open( const QString& name, const QString& filename ) | |||
972 | if ( qApp ) //TODO: I don't like this here... | 987 | if ( qApp ) //TODO: I don't like this here... |
973 | { | 988 | { |
974 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); | 989 | _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); |
975 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); | 990 | connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); |
976 | } | 991 | } |
977 | 992 | ||
978 | // if requested, open a dump | 993 | return true; |
994 | } | ||
995 | |||
996 | |||
997 | bool OPacketCapturer::openDumpFile( const QString& filename ) | ||
998 | { | ||
979 | pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) ); | 999 | pcap_dumper_t* dump = pcap_dump_open( _pch, const_cast<char*>( (const char*) filename ) ); |
980 | if ( !dump ) | 1000 | if ( !dump ) |
981 | { | 1001 | { |
982 | qWarning( "OPacketCapturer::open(): can't open dump with '%s': %s", (const char*) filename, _errbuf ); | 1002 | qWarning( "OPacketCapturer::open(): can't open dump with '%s': %s", (const char*) filename, _errbuf ); |
983 | return false; | 1003 | return false; |
984 | } | 1004 | } |
diff --git a/libopie2/opienet/opcap.h b/libopie2/opienet/opcap.h index ad5b07c..9119972 100644 --- a/libopie2/opienet/opcap.h +++ b/libopie2/opienet/opcap.h | |||
@@ -112,12 +112,14 @@ class QSocketNotifier; | |||
112 | */ | 112 | */ |
113 | 113 | ||
114 | class OPacket : public QObject | 114 | class OPacket : public QObject |
115 | { | 115 | { |
116 | Q_OBJECT | 116 | Q_OBJECT |
117 | 117 | ||
118 | friend class OPacketCapturer; | ||
119 | |||
118 | public: | 120 | public: |
119 | OPacket( int datalink, packetheaderstruct, const unsigned char*, QObject* parent ); | 121 | OPacket( int datalink, packetheaderstruct, const unsigned char*, QObject* parent ); |
120 | virtual ~OPacket(); | 122 | virtual ~OPacket(); |
121 | 123 | ||
122 | timevalstruct timeval() const; | 124 | timevalstruct timeval() const; |
123 | 125 | ||
@@ -521,49 +523,60 @@ class OPacketCapturer : public QObject | |||
521 | OPacketCapturer( QObject* parent = 0, const char* name = 0 ); | 523 | OPacketCapturer( QObject* parent = 0, const char* name = 0 ); |
522 | /** | 524 | /** |
523 | * Destructor. | 525 | * Destructor. |
524 | */ | 526 | */ |
525 | ~OPacketCapturer(); | 527 | ~OPacketCapturer(); |
526 | /** | 528 | /** |
527 | * Setting the packet capturer to use blocking IO calls can be useful when | 529 | * Set the packet capturer to use blocking or non-blocking IO. This can be useful when |
528 | * not using the socket notifier, e.g. without an application object. | 530 | * not using the socket notifier, e.g. without an application object. |
529 | */ | 531 | */ |
530 | void setBlocking( bool ); | 532 | void setBlocking( bool ); |
531 | /** | 533 | /** |
532 | * @returns true if the packet capturer uses blocking IO calls. | 534 | * @returns true if the packet capturer uses blocking IO calls. |
533 | */ | 535 | */ |
534 | bool blocking() const; | 536 | bool blocking() const; |
535 | /** | 537 | /** |
536 | * Closes the packet capturer. This is automatically done in the destructor. | 538 | * Close the packet capturer. This is automatically done in the destructor. |
537 | */ | 539 | */ |
538 | void close(); | 540 | void close(); |
539 | /** | 541 | /** |
542 | * Close the output capture file. | ||
543 | */ | ||
544 | void closeDumpFile(); | ||
545 | /** | ||
540 | * @returns the data link type. | 546 | * @returns the data link type. |
541 | * @see <pcap.h> for possible values. | 547 | * @see <pcap.h> for possible values. |
542 | */ | 548 | */ |
543 | int dataLink() const; | 549 | int dataLink() const; |
544 | /** | 550 | /** |
551 | * Dump a packet to the output capture file. | ||
552 | */ | ||
553 | void dump( OPacket* ); | ||
554 | /** | ||
545 | * @returns the file descriptor of the packet capturer. This is only useful, if | 555 | * @returns the file descriptor of the packet capturer. This is only useful, if |
546 | * not using the socket notifier, e.g. without an application object. | 556 | * not using the socket notifier, e.g. without an application object. |
547 | */ | 557 | */ |
548 | int fileno() const; | 558 | int fileno() const; |
549 | /** | 559 | /** |
550 | * @returns the next @ref OPacket from the packet capturer. | 560 | * @returns the next @ref OPacket from the packet capturer. |
551 | * @note If blocking mode is true then this call might block. | 561 | * @note If blocking mode is true then this call might block. |
552 | */ | 562 | */ |
553 | OPacket* next(); | 563 | OPacket* next(); |
554 | /** | 564 | /** |
555 | * Open the packet capturer to capture packets in live-mode from @a interface. | 565 | * Open the packet capturer to capture packets in live-mode from @a interface. |
556 | * If a @a filename is given, all captured packets are output to a tcpdump-compatible capture file. | ||
557 | */ | 566 | */ |
558 | bool open( const QString& interface, const QString& filename = QString::null ); | 567 | bool open( const QString& interface ); |
559 | /** | 568 | /** |
560 | * Open the packet capturer to capture packets in offline-mode from @a file. | 569 | * Open the packet capturer to capture packets in offline-mode from @a file. |
561 | */ | 570 | */ |
562 | bool open( const QFile& file ); | 571 | bool open( const QFile& file ); |
563 | /** | 572 | /** |
573 | * Open a prerecorded tcpdump compatible capture file for use with @ref dump() | ||
574 | */ | ||
575 | bool openDumpFile( const QString& filename ); | ||
576 | /** | ||
564 | * @returns true if the packet capturer is open | 577 | * @returns true if the packet capturer is open |
565 | */ | 578 | */ |
566 | bool isOpen() const; | 579 | bool isOpen() const; |
567 | /** | 580 | /** |
568 | * @returns the snapshot length of this packet capturer | 581 | * @returns the snapshot length of this packet capturer |
569 | */ | 582 | */ |