#include <iostream>#include "rutil/Log.hxx"#include "rutil/Fifo.hxx"#include "rutil/FiniteFifo.hxx"#include "rutil/TimeLimitFifo.hxx"#include "rutil/Data.hxx"#include "rutil/ThreadIf.hxx"#include "rutil/Timer.hxx"#include <unistd.h>
Include dependency graph for testFifo.cxx:
Go to the source code of this file.
Classes | |
| class | Foo |
| class | Consumer |
| class | Producer |
Functions | |
| void | sleepMS (unsigned int ms) |
| bool | isNear (int value, int reference, int epsilon=250) |
| int | main () |
Function Documentation
| bool isNear | ( | int | value, |
| int | reference, | ||
| int | epsilon = 250 |
||
| ) |
Definition at line 150 of file testFifo.cxx.
{
int diff = ::abs(value-reference);
return (diff < epsilon);
}
| int main | ( | void | ) |
Definition at line 157 of file testFifo.cxx.
References resip::TimeLimitFifo< Msg >::add(), resip::AbstractFifo< T >::empty(), resip::Fifo< Msg >::getNext(), resip::TimeLimitFifo< Msg >::getNext(), resip::ThreadIf::join(), Foo::mVal, resip::ThreadIf::run(), resip::ThreadIf::shutdown(), resip::AbstractFifo< T >::size(), sleepMS(), and resip::TimeLimitFifo< Msg >::timeDepth().
{
Log::initialize(Log::Cout, Log::Debug, Data::Empty);
{
cerr << "!! test getNext(ms) empty fifo timing" << endl;
Fifo<Foo> fifo;
UInt64 begin(Timer::getTimeMs());
fifo.getNext(2000);
UInt64 end(Timer::getTimeMs());
cerr << begin << " " << end << " " << end-begin << endl;
int offMark = 2000 - (end - begin);
assert(abs(offMark) < 200);
}
Fifo<Foo> f;
FiniteFifo<Foo> ff(5);
{
cerr << "!! test basic" << endl;
bool c;
TimeLimitFifo<Foo> tlf(5, 10); // 5 seconds or 10 count limit
assert(tlf.empty());
assert(tlf.size() == 0);
assert(tlf.timeDepth() == 0);
c = tlf.add(new Foo("first"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
#ifdef VERBOSE
cerr << __LINE__ << endl;
#endif
assert(!tlf.empty());
assert(tlf.size() == 1);
#ifdef VERBOSE
cerr << tlf.timeDepth() << endl;
#endif
assert(tlf.timeDepth() == 0);
#ifdef VERBOSE
cerr << __LINE__ << endl;
#endif
sleepMS(2000);
assert(!tlf.empty());
assert(tlf.size() == 1);
assert(tlf.timeDepth() > 1);
delete tlf.getNext();
assert(tlf.empty());
assert(tlf.size() == 0);
assert(tlf.timeDepth() == 0);
#ifdef VERBOSE
cerr << __LINE__ << endl;
#endif
c = tlf.add(new Foo("first"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
sleepMS(3000);
c = tlf.add(new Foo("second"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
sleepMS(3000);
c = tlf.add(new Foo("nope"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(!c);
c = tlf.add(new Foo("yep"), TimeLimitFifo<Foo>::IgnoreTimeDepth);
assert(c);
c = tlf.add(new Foo("internal"), TimeLimitFifo<Foo>::InternalElement);
assert(c);
cerr << __LINE__ << endl;
Foo* fp = tlf.getNext();
assert(fp->mVal == "first");
delete fp;
c = tlf.add(new Foo("third"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
}
{
cerr << "!! Test time depth" << endl;
TimeLimitFifo<Foo> tlfNS(5, 0); // 5 seconds, no count limit
bool c;
assert(tlfNS.empty());
assert(tlfNS.size() == 0);
assert(tlfNS.timeDepth() == 0);
c = tlfNS.add(new Foo("first"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
sleepMS(3000);
c = tlfNS.add(new Foo("second"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
sleepMS(3000);
c = tlfNS.add(new Foo("nope"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(!c);
Foo* fp = tlfNS.getNext();
assert(fp->mVal == "first");
delete fp;
c = tlfNS.add(new Foo("third"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
}
{
TimeLimitFifo<Foo> tlfNS(5, 0); // 5 seconds, no count limit
bool c;
assert(tlfNS.empty());
assert(tlfNS.size() == 0);
assert(tlfNS.timeDepth() == 0);
for (int i = 0; i < 100; ++i)
{
c = tlfNS.add(new Foo(Data("element") + Data(i)), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
}
sleepMS(6000);
c = tlfNS.add(new Foo("nope"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(!c);
c = tlfNS.add(new Foo("yep"), TimeLimitFifo<Foo>::IgnoreTimeDepth);
assert(c);
assert(tlfNS.size() == 101);
while (!tlfNS.empty())
{
delete tlfNS.getNext();
}
c = tlfNS.add(new Foo("first"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
}
{
cerr << "!! Test reserved" << endl;
TimeLimitFifo<Foo> tlfNS(5, 10); // 5 seconds, limit 10 (2 reserved)
bool c;
assert(tlfNS.empty());
assert(tlfNS.size() == 0);
assert(tlfNS.timeDepth() == 0);
for (int i = 0; i < 8; ++i)
{
c = tlfNS.add(new Foo(Data("element") + Data(i)), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
}
c = tlfNS.add(new Foo("nope"), TimeLimitFifo<Foo>::IgnoreTimeDepth);
assert(!c);
assert(tlfNS.size() == 8);
c = tlfNS.add(new Foo("yep"), TimeLimitFifo<Foo>::InternalElement);
assert(c);
c = tlfNS.add(new Foo("yepAgain"), TimeLimitFifo<Foo>::InternalElement);
assert(c);
c = tlfNS.add(new Foo("hard nope!"), TimeLimitFifo<Foo>::InternalElement);
assert(!c);
while (!tlfNS.empty())
{
delete tlfNS.getNext();
}
c = tlfNS.add(new Foo("first"), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
}
{
cerr << "!! Test unlimited" << endl;
TimeLimitFifo<Foo> tlfNS(0, 0); // unlimited
bool c;
assert(tlfNS.empty());
assert(tlfNS.size() == 0);
assert(tlfNS.timeDepth() == 0);
for (int i = 0; i < 100; ++i)
{
c = tlfNS.add(new Foo(Data("element") + Data(i)), TimeLimitFifo<Foo>::EnforceTimeDepth);
assert(c);
sleepMS(1000);
}
}
{
cerr << "!! Test produce consumer" << endl;
TimeLimitFifo<Foo> tlfNS(20, 5000);
Producer prod(tlfNS);
Consumer cons(tlfNS);
cons.run();
prod.run();
#ifdef VERBOSE
cerr << "Producer and consumer threads are running" << endl;
#endif
prod.join();
#ifdef VERBOSE
cerr << "Producer thread finished" << endl;
#endif
cons.shutdown();
cons.join();
#ifdef VERBOSE
cerr << "Consumer thread finished" << endl;
#endif
}
{
cerr << "!! Test producers consumers" << endl;
TimeLimitFifo<Foo> tlfNS(20, 50000);
Producer prod1(tlfNS);
Producer prod2(tlfNS);
Producer prod3(tlfNS);
Producer prod4(tlfNS);
Producer prod5(tlfNS);
Producer prod6(tlfNS);
Producer prod7(tlfNS);
Producer prod8(tlfNS);
Producer prod9(tlfNS);
Producer prod10(tlfNS);
Consumer cons1(tlfNS);
Consumer cons2(tlfNS);
Consumer cons3(tlfNS);
Consumer cons4(tlfNS);
Consumer cons5(tlfNS);
Consumer cons6(tlfNS);
Consumer cons7(tlfNS);
Consumer cons8(tlfNS);
Consumer cons9(tlfNS);
Consumer cons10(tlfNS);
cons1.run();
cons2.run();
cons3.run();
cons4.run();
cons5.run();
cons6.run();
cons7.run();
cons8.run();
cons9.run();
cons10.run();
#ifdef VERBOSE
cerr << "before getNext(1000) " << Timer::getTimeMs() << endl;
#endif
tlfNS.getNext(1000);
#ifdef VERBOSE
cerr << "after getNext(1000) " << Timer::getTimeMs() << endl;
#endif
prod1.run();
#ifdef VERBOSE
cerr << "before getNext(1000) " << Timer::getTimeMs() << endl;
#endif
tlfNS.getNext(1000);
#ifdef VERBOSE
cerr << "after getNext(1000) " << Timer::getTimeMs() << endl;
#endif
prod2.run();
prod3.run();
prod4.run();
prod5.run();
prod6.run();
prod7.run();
prod8.run();
prod9.run();
prod10.run();
// Wait for producers to finish
prod1.join();
prod2.join();
prod3.join();
prod4.join();
prod5.join();
prod6.join();
prod7.join();
prod8.join();
prod9.join();
prod10.join();
// Give some time for consumers to finish consuming, before shutting down
sleepMS(1000);
}
cerr << "All OK" << endl;
return 0;
}
Here is the call graph for this function:
| void sleepMS | ( | unsigned int | ms | ) |
Definition at line 18 of file testFifo.cxx.
Referenced by main(), Consumer::thread(), TestThread::thread(), and Producer::thread().
{
#ifdef WIN32
Sleep(ms);
#else
usleep(ms*1000);
#endif
}
