eeva/jamulus
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

first working version of testbench

Browse source
This commit is contained in:
Volker Fischer 2009-05-09 20:55:25 +00:00
parent e7e158d630
commit 57c8677879
2 changed files with 85 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/main.cpp
View file

@ -29,13 +29,7 @@
#include "llconclientdlg.h" #include "llconclientdlg.h"
#include "llconserverdlg.h" #include "llconserverdlg.h"
#include "settings.h" #include "settings.h"
#include "testbench.h"
// TEST -> activate the following two lines to activate the test bench,
#if 0
# include "testbench.h"
CTestbench Testbench;
#endif
// Implementation ************************************************************** // Implementation **************************************************************
@ -159,6 +153,11 @@ int main ( int argc, char** argv )
extern int qInitResources(); extern int qInitResources();
qInitResources(); qInitResources();
// TEST -> activate the following line to activate the test bench,
//CTestbench Testbench;
try try
{ {
if ( bIsClient ) if ( bIsClient )

88
src/testbench.h
View file

@ -41,8 +41,15 @@ class CTestbench : public QObject
Q_OBJECT Q_OBJECT
public: public:
CTestbench() : Socket ( NULL, 22222 ) CTestbench()
{ {
// bind socket
UdpSocket.bind ( QHostAddress ( QHostAddress::Any ), 22222 );
// connect protocol signal
QObject::connect ( &Protocol, SIGNAL ( MessReadyForSending ( CVector<uint8_t> ) ),
this, SLOT ( OnSendProtMessage ( CVector<uint8_t> ) ) );
// connect and start the timer (testbench heartbeat) // connect and start the timer (testbench heartbeat)
QObject::connect ( &Timer, SIGNAL ( timeout() ), QObject::connect ( &Timer, SIGNAL ( timeout() ),
this, SLOT ( OnTimer() ) ); this, SLOT ( OnTimer() ) );
@ -53,22 +60,85 @@ protected:
int GenRandomIntInRange ( const int iStart, const int iEnd ) const int GenRandomIntInRange ( const int iStart, const int iEnd ) const
{ {
return static_cast<int> ( iStart + return static_cast<int> ( iStart +
( ( static_cast<double> ( iEnd - iStart) * rand() ) / RAND_MAX ) ); ( ( static_cast<double> ( iEnd - iStart + 1 ) * rand() ) / RAND_MAX ) );
} }
QTimer Timer; QTimer Timer;
CSocket Socket; CProtocol Protocol;
CProtocol Protocol; QUdpSocket UdpSocket;
public slots: public slots:
void OnTimer() void OnTimer()
{ {
// generate random protocol message
switch ( GenRandomIntInRange ( 0, 11 ) )
{
case 0:
Protocol.CreateJitBufMes ( GenRandomIntInRange ( 0, 10 ) );
break;
// TEST check if random number generator works as expected case 1:
static FILE* pFile = fopen ( "test.txt", "w" ); Protocol.CreateReqJitBufMes();
fprintf ( pFile, "%d\n", GenRandomIntInRange ( 2, 5 ) ); break;
fflush ( pFile );
case 2:
Protocol.CreateNetwBlSiFactMes ( GenRandomIntInRange ( 0, 10 ) );
break;
case 3:
Protocol.CreateChanGainMes ( GenRandomIntInRange ( 0, 20 ),
GenRandomIntInRange ( -100, 100 ) );
break;
case 4:
Protocol.CreateServerFullMes();
break;
case 5:
Protocol.CreateReqConnClientsList();
break;
case 6:
Protocol.CreateChanNameMes ( QString ( "test%1" ).arg (
GenRandomIntInRange ( 0, 1000 ) ) );
break;
case 7:
Protocol.CreateChatTextMes ( QString ( "test%1" ).arg (
GenRandomIntInRange ( 0, 1000 ) ) );
break;
case 8:
Protocol.CreatePingMes ( GenRandomIntInRange ( 0, 100000 ) );
break;
case 9:
Protocol.CreateReqNetwTranspPropsMes();
break;
case 10:
Protocol.CreateAndSendAcknMess ( GenRandomIntInRange ( -10, 100 ),
GenRandomIntInRange ( -100, 100 ) );
break;
case 11:
// arbitrary "audio" packet (with random sizes)
CVector<uint8_t> vecMessage ( GenRandomIntInRange ( 1, 1000 ) );
OnSendProtMessage ( vecMessage );
break;
}
}
void OnSendProtMessage ( CVector<uint8_t> vecMessage )
{
UdpSocket.writeDatagram (
(const char*) &( (CVector<uint8_t>) vecMessage )[0],
vecMessage.Size(), QHostAddress ( "127.0.0.1" ),
LLCON_DEFAULT_PORT_NUMBER );
// reset protocol so that we do not have to wait for an acknowledge to
// send the next message
Protocol.Reset();
} }
}; };