summaryrefslogtreecommitdiff
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--libopie2/opienet/opcap.cpp47
-rw-r--r--libopie2/opienet/opcap.h4
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
726OWaveLanControlPacket::~OWaveLanControlPacket() 726OWaveLanControlPacket::~OWaveLanControlPacket()
727{ 727{
728} 728}
729 729
730 730
731/*====================================================================================== 731/*======================================================================================
732 * OPacketCapturer 732 * OPacketCapturer
733 *======================================================================================*/ 733 *======================================================================================*/
734 734
735OPacketCapturer::OPacketCapturer( QObject* parent, const char* name ) 735OPacketCapturer::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
742OPacketCapturer::~OPacketCapturer() 742OPacketCapturer::~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
777void OPacketCapturer::close() 777void 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
817OPacket* OPacketCapturer::next() 822OPacket* 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
843bool OPacketCapturer::open( const QString& name ) 850bool 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
886bool OPacketCapturer::open( const QFile& file ) 901bool 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