summaryrefslogtreecommitdiff
path: root/libopie2/opienet/opcap.cpp
Unidiff
Diffstat (limited to 'libopie2/opienet/opcap.cpp') (more/less context) (ignore whitespace changes)
-rw-r--r--libopie2/opienet/opcap.cpp40
1 files changed, 36 insertions, 4 deletions
diff --git a/libopie2/opienet/opcap.cpp b/libopie2/opienet/opcap.cpp
index 5c464cf..6a3dc26 100644
--- a/libopie2/opienet/opcap.cpp
+++ b/libopie2/opienet/opcap.cpp
@@ -38,8 +38,9 @@
38/* QT */ 38/* QT */
39 39
40#include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects) 40#include <qapplication.h> // don't use oapplication here (will decrease reusability in other projects)
41#include <qsocketnotifier.h> 41#include <qsocketnotifier.h>
42#include <qobjectlist.h>
42 43
43/*====================================================================================== 44/*======================================================================================
44 * OPacket 45 * OPacket
45 *======================================================================================*/ 46 *======================================================================================*/
@@ -86,8 +87,21 @@ int OPacket::caplen() const
86 return _hdr.caplen; 87 return _hdr.caplen;
87} 88}
88 89
89 90
91void OPacket::updateStats( QMap<QString,int>& stats, QObjectList* l )
92{
93 if (!l) return;
94 QObject* o = l->first();
95 while ( o )
96 {
97 stats[o->name()]++;
98 updateStats( stats, const_cast<QObjectList*>( o->children() ) );
99 o = l->next();
100 }
101}
102
103
90QString OPacket::dump( int bpl ) const 104QString OPacket::dump( int bpl ) const
91{ 105{
92 static int index = 0; 106 static int index = 0;
93 index++; 107 index++;
@@ -126,14 +140,14 @@ QString OPacket::dump( int bpl ) const
126 return str; 140 return str;
127} 141}
128 142
129 143
130
131int OPacket::len() const 144int OPacket::len() const
132{ 145{
133 return _hdr.len; 146 return _hdr.len;
134} 147}
135 148
149
136/*====================================================================================== 150/*======================================================================================
137 * OEthernetPacket 151 * OEthernetPacket
138 *======================================================================================*/ 152 *======================================================================================*/
139 153
@@ -771,8 +785,15 @@ void OPacketCapturer::close()
771 } 785 }
772 pcap_close( _pch ); 786 pcap_close( _pch );
773 _open = false; 787 _open = false;
774 } 788 }
789
790 qDebug( "OPacketCapturer::close() --- dumping capturing statistics..." );
791 qDebug( "--------------------------------------------------" );
792 for( QMap<QString,int>::Iterator it = _stats.begin(); it != _stats.end(); ++it )
793 qDebug( "%s : %d", (const char*) it.key(), it.data() );
794 qDebug( "--------------------------------------------------" );
795
775} 796}
776 797
777 798
778int OPacketCapturer::dataLink() const 799int OPacketCapturer::dataLink() const
@@ -792,9 +813,8 @@ int OPacketCapturer::fileno() const
792 return -1; 813 return -1;
793 } 814 }
794} 815}
795 816
796
797OPacket* OPacketCapturer::next() 817OPacket* OPacketCapturer::next()
798{ 818{
799 packetheaderstruct header; 819 packetheaderstruct header;
800 qDebug( "==> OPacketCapturer::next()" ); 820 qDebug( "==> OPacketCapturer::next()" );
@@ -802,13 +822,18 @@ OPacket* OPacketCapturer::next()
802 qDebug( "<== OPacketCapturer::next()" ); 822 qDebug( "<== OPacketCapturer::next()" );
803 823
804 if ( header.len ) 824 if ( header.len )
805 { 825 {
806 return new OPacket( dataLink(), header, pdata, 0 ); 826 OPacket* p = new OPacket( dataLink(), header, pdata, 0 );
807 // packets shouldn't be inserted in the QObject child-parent hierarchy, 827 // packets shouldn't be inserted in the QObject child-parent hierarchy,
808 // because due to memory constraints they will be deleted as soon 828 // because due to memory constraints they will be deleted as soon
809 // as possible - that is right after they have been processed 829 // as possible - that is right after they have been processed
810 // by emit() [ see below ] 830 // by emit() [ see below ]
831
832 //TODO: make gathering statistics optional, because it takes time
833 p->updateStats( _stats, const_cast<QObjectList*>( p->children() ) );
834
835 return p;
811 } 836 }
812 else 837 else
813 { 838 {
814 return 0; 839 return 0;
@@ -838,8 +863,9 @@ bool OPacketCapturer::open( const QString& name )
838 { 863 {
839 qDebug( "OPacketCapturer::open(): libpcap opened successfully." ); 864 qDebug( "OPacketCapturer::open(): libpcap opened successfully." );
840 _pch = handle; 865 _pch = handle;
841 _open = true; 866 _open = true;
867 _stats.clear();
842 868
843 // in case we have an application object, create a socket notifier 869 // in case we have an application object, create a socket notifier
844 if ( qApp ) 870 if ( qApp )
845 { 871 {
@@ -865,11 +891,17 @@ bool OPacketCapturer::isOpen() const
865 891
866 892
867void OPacketCapturer::readyToReceive() 893void OPacketCapturer::readyToReceive()
868{ 894{
869 qDebug( "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(...)'" ); 895 qDebug( "OPacketCapturer::readyToReceive(): about to emit 'receivePacket(p)'" );
870 OPacket* p = next(); 896 OPacket* p = next();
871 emit receivedPacket( p ); 897 emit receivedPacket( p );
872 // emit is synchronous - packet has been dealt with, now it's safe to delete 898 // emit is synchronous - packet has been dealt with, now it's safe to delete
873 delete p; 899 delete p;
874} 900}
875 901
902
903const QMap<QString,int>& OPacketCapturer::statistics() const
904{
905 return _stats;
906}
907