summaryrefslogtreecommitdiff
authormickeyl <mickeyl>2003-04-10 15:47:23 (UTC)
committer mickeyl <mickeyl>2003-04-10 15:47:23 (UTC)
commit3733471135ea180709fcf4695607cce0c5fc7fb5 (patch) (unidiff)
tree792c96ad5351b9396a0c129738b5cff9e2b00614
parent101e039ba53d4ccbe5b46575bb56c07f6f544db6 (diff)
downloadopie-3733471135ea180709fcf4695607cce0c5fc7fb5.zip
opie-3733471135ea180709fcf4695607cce0c5fc7fb5.tar.gz
opie-3733471135ea180709fcf4695607cce0c5fc7fb5.tar.bz2
add support for working with capture files (e.g. from tcpdump, ethereal, et.al.)
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--libopie2/opienet/opcap.cpp48
-rw-r--r--libopie2/opienet/opcap.h64
2 files changed, 101 insertions, 11 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp
index 6a3dc26..30f6208 100644
--- a/libopie2/opienet/opcap.cpp
+++ b/libopie2/opienet/opcap.cpp
@@ -815,33 +815,32 @@ int OPacketCapturer::fileno() const
815} 815}
816 816
817OPacket* OPacketCapturer::next() 817OPacket* OPacketCapturer::next()
818{ 818{
819 packetheaderstruct header; 819 packetheaderstruct header;
820 qDebug( "==> OPacketCapturer::next()" ); 820 qDebug( "==> OPacketCapturer::next()" );
821 const unsigned char* pdata = pcap_next( _pch, &header ); 821 const unsigned char* pdata = pcap_next( _pch, &header );
822 qDebug( "<== OPacketCapturer::next()" ); 822 qDebug( "<== OPacketCapturer::next()" );
823 823
824 if ( header.len ) 824 if ( header.len )
825 { 825 {
826 OPacket* p = new OPacket( dataLink(), header, pdata, 0 ); 826 OPacket* p = new OPacket( dataLink(), header, pdata, 0 );
827 // packets shouldn't be inserted in the QObject child-parent hierarchy, 827 // packets shouldn't be inserted in the QObject child-parent hierarchy,
828 // because due to memory constraints they will be deleted as soon 828 // because due to memory constraints they will be deleted as soon
829 // as possible - that is right after they have been processed 829 // as possible - that is right after they have been processed
830 // by emit() [ see below ] 830 // by emit() [ see below ]
831
832 //TODO: make gathering statistics optional, because it takes time 831 //TODO: make gathering statistics optional, because it takes time
833 p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) ); 832 p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) );
834 833
835 return p; 834 return p;
836 } 835 }
837 else 836 else
838 { 837 {
839 return 0; 838 return 0;
840 } 839 }
841} 840}
842 841
843 842
844bool OPacketCapturer::open( const QString& name ) 843bool OPacketCapturer::open( const QString& name )
845{ 844{
846 if ( _open ) 845 if ( _open )
847 { 846 {
@@ -864,33 +863,78 @@ bool OPacketCapturer::open( const QString& name )
864 qDebug( "OPacketCapturer::open(): libpcap opened successfully." ); 863 qDebug( "OPacketCapturer::open(): libpcap opened successfully." );
865 _pch = handle; 864 _pch = handle;
866 _open = true; 865 _open = true;
867 _stats.clear(); 866 _stats.clear();
868 867
869 // in case we have an application object, create a socket notifier 868 // in case we have an application object, create a socket notifier
870 if ( qApp ) 869 if ( qApp )
871 { 870 {
872 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read ); 871 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );
873 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) ); 872 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
874 } 873 }
875 874
876 return true; 875 return true;
877 } 876 }
878 else 877 else
879 { 878 {
880 qDebug( "OPacketCapturer::open(): can't open libpcap: %s", _errbuf ); 879 qDebug( "OPacketCapturer::open(): can't open libpcap with '%s': %s", (const char*) name, _errbuf );
880 return false;
881 }
882
883}
884
885
886bool OPacketCapturer::open( const QFile& file )
887{
888 QString name = file.name();
889
890 if ( _open )
891 {
892 close();
893 if ( name == _name ) // ignore opening an already openend device
894 {
895 return true;
896 }
897 else // close the last opened device
898 {
899 close();
900 }
901 }
902
903 _name = name;
904
905 pcap_t* handle = pcap_open_offline( const_cast<char*>( (const char*) name ), &_errbuf[0] );
906
907 if ( handle )
908 {
909 qDebug( "OPacketCapturer::open(): libpcap opened successfully." );
910 _pch = handle;
911 _open = true;
912
913 // in case we have an application object, create a socket notifier
914 if ( qApp )
915 {
916 _sn = new QSocketNotifier( fileno(), QSocketNotifier::Read );
917 connect( _sn, SIGNAL( activated(int) ), this, SLOT( readyToReceive() ) );
918 }
919
920 return true;
921 }
922 else
923 {
924 qDebug( "OPacketCapturer::open(): can't open libpcap with '%s': %s", (const char*) name, _errbuf );
881 return false; 925 return false;
882 } 926 }
883 927
884} 928}
885 929
886 930
887bool OPacketCapturer::isOpen() const 931bool OPacketCapturer::isOpen() const
888{ 932{
889 return _open; 933 return _open;
890} 934}
891 935
892 936
893void OPacketCapturer::readyToReceive() 937void OPacketCapturer::readyToReceive()
894{ 938{
895 qDebug( "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" ); 939 qDebug( "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" );
896 OPacket* p = next(); 940 OPacket* p = next();
diff --git a/libopie2/opienet/opcap.h b/libopie2/opienet/opcap.h
index c9b0624..6c3ac6d 100644
--- a/libopie2/opienet/opcap.h
+++ b/libopie2/opienet/opcap.h
@@ -34,32 +34,33 @@
34#ifndef OPCAP_H 34#ifndef OPCAP_H
35#define OPCAP_H 35#define OPCAP_H
36 36
37/* LINUX */ 37/* LINUX */
38extern "C" // work around a bpf/pcap conflict in recent headers 38extern "C" // work around a bpf/pcap conflict in recent headers
39{ 39{
40 #include <pcap.h> 40 #include <pcap.h>
41} 41}
42#include <netinet/ether.h> 42#include <netinet/ether.h>
43#include <netinet/ip.h> 43#include <netinet/ip.h>
44#include <netinet/udp.h> 44#include <netinet/udp.h>
45#include <netinet/tcp.h> 45#include <netinet/tcp.h>
46#include <time.h> 46#include <time.h>
47 47
48/* QT */ 48/* QT */
49#include <qevent.h> 49#include <qevent.h>
50#include <qfile.h>
50#include <qhostaddress.h> 51#include <qhostaddress.h>
51#include <qobject.h> 52#include <qobject.h>
52#include <qstring.h> 53#include <qstring.h>
53#include <qmap.h> 54#include <qmap.h>
54 55
55/* OPIE */ 56/* OPIE */
56#include <opie2/onetutils.h> 57#include <opie2/onetutils.h>
57#include "802_11_user.h" 58#include "802_11_user.h"
58 59
59/* TYPEDEFS */ 60/* TYPEDEFS */
60typedef struct timeval timevalstruct; 61typedef struct timeval timevalstruct;
61typedef struct pcap_pkthdr packetheaderstruct; 62typedef struct pcap_pkthdr packetheaderstruct;
62 63
63/* FORWARDS */ 64/* FORWARDS */
64class OPacketCapturer; 65class OPacketCapturer;
65class QSocketNotifier; 66class QSocketNotifier;
@@ -407,53 +408,98 @@ class OTCPPacket : public QObject
407 public: 408 public:
408 OTCPPacket( const unsigned char*, const struct tcphdr*, QObject* parent = 0 ); 409 OTCPPacket( const unsigned char*, const struct tcphdr*, QObject* parent = 0 );
409 virtual ~OTCPPacket(); 410 virtual ~OTCPPacket();
410 411
411 int fromPort() const; 412 int fromPort() const;
412 int toPort() const; 413 int toPort() const;
413 414
414 private: 415 private:
415 const struct tcphdr* _tcphdr; 416 const struct tcphdr* _tcphdr;
416}; 417};
417 418
418 419
419/*====================================================================================== 420/*======================================================================================
420 * OPacketCapturer 421 * OPacketCapturer
421 *======================================================================================*/ 422 *======================================================================================*/
422 423
424/**
425 * @brief A class based wrapper for network packet capturing.
426 *
427 * This class is the base of a high-level interface to the well known packet capturing
428 * library libpcap. ...
429 */
423class OPacketCapturer : public QObject 430class OPacketCapturer : public QObject
424{ 431{
425 Q_OBJECT 432 Q_OBJECT
426 433
427 public: 434 public:
435 /**
436 * Constructor.
437 */
428 OPacketCapturer( QObject* parent = 0, const char* name = 0 ); 438 OPacketCapturer( QObject* parent = 0, const char* name = 0 );
439 /**
440 * Destructor.
441 */
429 ~OPacketCapturer(); 442 ~OPacketCapturer();
430 443 /**
444 * Setting the packet capturer to use blocking IO calls can be useful when
445 * not using the socket notifier, e.g. without an application object.
446 */
431 void setBlocking( bool ); 447 void setBlocking( bool );
448 /**
449 * @returns true if the packet capturer uses blocking IO calls.
450 */
432 bool blocking() const; 451 bool blocking() const;
433 452 /**
453 * Closes the packet capturer. This is automatically done in the destructor.
454 */
434 void close(); 455 void close();
456 /**
457 * @returns the data link type.
458 * @see <pcap.h> for possible values.
459 */
435 int dataLink() const; 460 int dataLink() const;
461 /**
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.
464 */
436 int fileno() const; 465 int fileno() const;
466 /**
467 * @returns the next @ref OPacket from the packet capturer.
468 * @note If blocking mode is true then this call might block.
469 */
437 OPacket* next(); 470 OPacket* next();
438 bool open( const QString& name ); 471 /**
472 * Open the packet capturer to capture packets in live-mode from @a interface.
473 */
474 bool open( const QString& interface );
475 /**
476 * Open the packet capturer to capture packets in offline-mode from @a file.
477 */
478 bool open( const QFile& file );
479 /**
480 * @returns true if the packet capturer is open
481 */
439 bool isOpen() const; 482 bool isOpen() const;
440 483
441 const QMap<QString,int>& statistics() const; 484 const QMap<QString,int>& statistics() const;
442 485
443 signals: 486 signals:
487 /**
488 * This signal is emitted, when a packet has been received.
489 */
444 void receivedPacket( OPacket* ); 490 void receivedPacket( OPacket* );
445 491
446 protected slots: 492 protected slots:
447 void readyToReceive(); 493 void readyToReceive();
448 494
449 protected: 495 protected:
450 QString _name; // devicename 496 QString _name; // devicename
451 bool _open; // check this before doing pcap calls 497 bool _open; // check this before doing pcap calls
452 pcap_t* _pch; // pcap library handle 498 pcap_t* _pch; // pcap library handle
453 QSocketNotifier* _sn; // socket notifier for main loop 499 QSocketNotifier* _sn; // socket notifier for main loop
454 mutable char _errbuf[PCAP_ERRBUF_SIZE]; 500 mutable char _errbuf[PCAP_ERRBUF_SIZE]; // holds error strings from libpcap
455 QMap<QString, int> _stats; // statistics; 501 QMap<QString, int> _stats; // statistics;
456}; 502};
457 503
458#endif // OPCAP_H 504#endif // OPCAP_H
459 505