mirror of
https://github.com/VCMP-SqMod/SqMod.git
synced 2025-03-04 19:27:29 +01:00
4a6bfc086c
Switched to POCO library for unified platform/library interface. Deprecated the external module API. It was creating more problems than solving. Removed most built-in libraries in favor of system libraries for easier maintenance. Cleaned and secured code with help from static analyzers.
272 lines
6.9 KiB
C++
272 lines
6.9 KiB
C++
//
|
|
// TimedNotificationQueueTest.cpp
|
|
//
|
|
// Copyright (c) 2009, Applied Informatics Software Engineering GmbH.
|
|
// and Contributors.
|
|
//
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
//
|
|
|
|
|
|
#include "TimedNotificationQueueTest.h"
|
|
#include "CppUnit/TestCaller.h"
|
|
#include "CppUnit/TestSuite.h"
|
|
#include "Poco/TimedNotificationQueue.h"
|
|
#include "Poco/Notification.h"
|
|
#include "Poco/Timestamp.h"
|
|
#include "Poco/Clock.h"
|
|
|
|
|
|
using Poco::TimedNotificationQueue;
|
|
using Poco::Notification;
|
|
using Poco::Timestamp;
|
|
using Poco::Clock;
|
|
|
|
|
|
namespace
|
|
{
|
|
class QTestNotification: public Notification
|
|
{
|
|
public:
|
|
QTestNotification(const std::string& data): _data(data)
|
|
{
|
|
}
|
|
~QTestNotification()
|
|
{
|
|
}
|
|
const std::string& data() const
|
|
{
|
|
return _data;
|
|
}
|
|
|
|
private:
|
|
std::string _data;
|
|
};
|
|
}
|
|
|
|
|
|
TimedNotificationQueueTest::TimedNotificationQueueTest(const std::string& name): CppUnit::TestCase(name)
|
|
{
|
|
}
|
|
|
|
|
|
TimedNotificationQueueTest::~TimedNotificationQueueTest()
|
|
{
|
|
}
|
|
|
|
|
|
void TimedNotificationQueueTest::testDequeue()
|
|
{
|
|
TimedNotificationQueue queue;
|
|
assertTrue (queue.empty());
|
|
assertTrue (queue.size() == 0);
|
|
Notification* pNf = queue.dequeueNotification();
|
|
assertNullPtr(pNf);
|
|
queue.enqueueNotification(new Notification, Timestamp());
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 1);
|
|
pNf = queue.dequeueNotification();
|
|
assertNotNullPtr(pNf);
|
|
assertTrue (queue.empty());
|
|
assertTrue (queue.size() == 0);
|
|
pNf->release();
|
|
|
|
Poco::Clock ts1;
|
|
ts1 += 100000;
|
|
Poco::Clock ts2;
|
|
ts2 += 200000;
|
|
Poco::Clock ts3;
|
|
ts3 += 300000;
|
|
Poco::Clock ts4;
|
|
ts4 += 400000;
|
|
|
|
queue.enqueueNotification(new QTestNotification("first"), ts1);
|
|
queue.enqueueNotification(new QTestNotification("fourth"), ts4);
|
|
queue.enqueueNotification(new QTestNotification("third"), ts3);
|
|
queue.enqueueNotification(new QTestNotification("second"), ts2);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 4);
|
|
QTestNotification* pTNf = 0;
|
|
while (!pTNf)
|
|
{
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.dequeueNotification());
|
|
}
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "first");
|
|
pTNf->release();
|
|
assertTrue (ts1.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 3);
|
|
|
|
pTNf = 0;
|
|
while (!pTNf)
|
|
{
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.dequeueNotification());
|
|
}
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "second");
|
|
pTNf->release();
|
|
assertTrue (ts2.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 2);
|
|
|
|
pTNf = 0;
|
|
while (!pTNf)
|
|
{
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.dequeueNotification());
|
|
}
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "third");
|
|
pTNf->release();
|
|
assertTrue (ts3.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 1);
|
|
|
|
pTNf = 0;
|
|
while (!pTNf)
|
|
{
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.dequeueNotification());
|
|
}
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "fourth");
|
|
pTNf->release();
|
|
assertTrue (ts4.elapsed() >= 0);
|
|
assertTrue (queue.empty());
|
|
assertTrue (queue.size() == 0);
|
|
|
|
pNf = queue.dequeueNotification();
|
|
assertNullPtr(pNf);
|
|
}
|
|
|
|
|
|
void TimedNotificationQueueTest::testWaitDequeue()
|
|
{
|
|
TimedNotificationQueue queue;
|
|
|
|
Poco::Timestamp ts1;
|
|
ts1 += 100000;
|
|
Poco::Timestamp ts2;
|
|
ts2 += 200000;
|
|
Poco::Timestamp ts3;
|
|
ts3 += 300000;
|
|
Poco::Timestamp ts4;
|
|
ts4 += 400000;
|
|
|
|
queue.enqueueNotification(new QTestNotification("first"), ts1);
|
|
queue.enqueueNotification(new QTestNotification("fourth"), ts4);
|
|
queue.enqueueNotification(new QTestNotification("third"), ts3);
|
|
queue.enqueueNotification(new QTestNotification("second"), ts2);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 4);
|
|
QTestNotification* pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification());
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "first");
|
|
pTNf->release();
|
|
assertTrue (ts1.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 3);
|
|
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification());
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "second");
|
|
pTNf->release();
|
|
assertTrue (ts2.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 2);
|
|
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification());
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "third");
|
|
pTNf->release();
|
|
assertTrue (ts3.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 1);
|
|
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification());
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "fourth");
|
|
pTNf->release();
|
|
assertTrue (ts4.elapsed() >= 0);
|
|
assertTrue (queue.empty());
|
|
assertTrue (queue.size() == 0);
|
|
}
|
|
|
|
|
|
void TimedNotificationQueueTest::testWaitDequeueTimeout()
|
|
{
|
|
TimedNotificationQueue queue;
|
|
|
|
Poco::Timestamp ts1;
|
|
ts1 += 200000;
|
|
Poco::Timestamp ts2;
|
|
ts2 += 400000;
|
|
Poco::Timestamp ts3;
|
|
ts3 += 600000;
|
|
Poco::Timestamp ts4;
|
|
ts4 += 800000;
|
|
|
|
queue.enqueueNotification(new QTestNotification("first"), ts1);
|
|
queue.enqueueNotification(new QTestNotification("fourth"), ts4);
|
|
queue.enqueueNotification(new QTestNotification("third"), ts3);
|
|
queue.enqueueNotification(new QTestNotification("second"), ts2);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 4);
|
|
QTestNotification* pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification(10));
|
|
assertNullPtr(pTNf);
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification(20));
|
|
assertNullPtr(pTNf);
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification(200));
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "first");
|
|
pTNf->release();
|
|
assertTrue (ts1.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 3);
|
|
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification(220));
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "second");
|
|
pTNf->release();
|
|
assertTrue (ts2.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 2);
|
|
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification(220));
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "third");
|
|
pTNf->release();
|
|
assertTrue (ts3.elapsed() >= 0);
|
|
assertTrue (!queue.empty());
|
|
assertTrue (queue.size() == 1);
|
|
|
|
pTNf = dynamic_cast<QTestNotification*>(queue.waitDequeueNotification(220));
|
|
assertNotNullPtr(pTNf);
|
|
assertTrue (pTNf->data() == "fourth");
|
|
pTNf->release();
|
|
assertTrue (ts1.elapsed() >= 0);
|
|
assertTrue (queue.empty());
|
|
assertTrue (queue.size() == 0);
|
|
}
|
|
|
|
|
|
void TimedNotificationQueueTest::setUp()
|
|
{
|
|
}
|
|
|
|
|
|
void TimedNotificationQueueTest::tearDown()
|
|
{
|
|
}
|
|
|
|
|
|
CppUnit::Test* TimedNotificationQueueTest::suite()
|
|
{
|
|
CppUnit::TestSuite* pSuite = new CppUnit::TestSuite("TimedNotificationQueueTest");
|
|
|
|
CppUnit_addTest(pSuite, TimedNotificationQueueTest, testDequeue);
|
|
CppUnit_addTest(pSuite, TimedNotificationQueueTest, testWaitDequeue);
|
|
CppUnit_addTest(pSuite, TimedNotificationQueueTest, testWaitDequeueTimeout);
|
|
|
|
return pSuite;
|
|
}
|