You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
147 lines
3.4 KiB
147 lines
3.4 KiB
/*
|
|
|
|
Copyright (C) 2001 Stefan Westerfeld
|
|
stefan@space.twc.de
|
|
|
|
This library is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU Library General Public
|
|
License as published by the Free Software Foundation; either
|
|
version 2 of the License, or (at your option) any later version.
|
|
|
|
This library is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Library General Public License for more details.
|
|
|
|
You should have received a copy of the GNU Library General Public License
|
|
along with this library; see the file COPYING.LIB. If not, write to
|
|
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
|
|
Boston, MA 02110-1301, USA.
|
|
|
|
*/
|
|
|
|
#include "notification.h"
|
|
#include "dispatcher.h"
|
|
#include "test.h"
|
|
|
|
using namespace Arts;
|
|
using namespace std;
|
|
|
|
static string messagesReceived;
|
|
static long messagesAlive;
|
|
|
|
static void destroyString(const Notification& n)
|
|
{
|
|
messagesAlive--;
|
|
delete (string *)n.data;
|
|
}
|
|
|
|
class Receiver : public NotificationClient {
|
|
private:
|
|
long alive;
|
|
|
|
public:
|
|
Receiver() { alive = 42; }
|
|
virtual ~Receiver() {
|
|
NotificationManager::the()->removeClient(this);
|
|
alive = 0;
|
|
}
|
|
|
|
void notify(const Notification& n) {
|
|
if(alive != 42) messagesReceived += "<dead>";
|
|
|
|
string *data = (string *)n.data;
|
|
messagesReceived += *data;
|
|
destroyString(n);
|
|
|
|
if(alive != 42) messagesReceived += "</dead>";
|
|
}
|
|
};
|
|
|
|
struct TestNotification : public TestCase
|
|
{
|
|
TESTCASE(TestNotification);
|
|
|
|
Dispatcher dispatcher;
|
|
|
|
void setUp() {
|
|
messagesReceived = "";
|
|
messagesAlive = 0;
|
|
}
|
|
void tearDown() {
|
|
}
|
|
void sendNotification(Receiver& r, string text)
|
|
{
|
|
messagesAlive++;
|
|
Notification n;
|
|
n.receiver = &r;
|
|
n.data = new string(text);
|
|
n.internal = 0;
|
|
n.setDestroy(destroyString);
|
|
NotificationManager::the()->send(n);
|
|
}
|
|
|
|
/* sending a notification (should be asynchronous) */
|
|
TEST(send) {
|
|
Receiver r1;
|
|
sendNotification(r1,"r1");
|
|
|
|
testEquals(1,messagesAlive);
|
|
testEquals("",messagesReceived);
|
|
testEquals(true, NotificationManager::the()->pending());
|
|
|
|
NotificationManager::the()->run();
|
|
|
|
testEquals("r1",messagesReceived);
|
|
testEquals(false, NotificationManager::the()->pending());
|
|
testEquals(0,messagesAlive);
|
|
}
|
|
|
|
/* order of sending notifications (first-in-first-out) */
|
|
TEST(sendOrder) {
|
|
Receiver r1,r2;
|
|
|
|
sendNotification(r1,"r1");
|
|
sendNotification(r2,"r2");
|
|
|
|
testEquals(2,messagesAlive);
|
|
testEquals("",messagesReceived);
|
|
testEquals(true, NotificationManager::the()->pending());
|
|
|
|
NotificationManager::the()->run();
|
|
|
|
testEquals(false, NotificationManager::the()->pending());
|
|
testEquals(0,messagesAlive);
|
|
testEquals("r1r2",messagesReceived);
|
|
}
|
|
|
|
/* deletion of unprocessed notifications once a client dies */
|
|
TEST(clientDeletion) {
|
|
Receiver *r1 = new Receiver,
|
|
*r2 = new Receiver,
|
|
*r3 = new Receiver,
|
|
*r4 = new Receiver;
|
|
|
|
sendNotification(*r1,"r1");
|
|
sendNotification(*r2,"r2");
|
|
sendNotification(*r3,"r3");
|
|
sendNotification(*r4,"r4");
|
|
|
|
testEquals(4,messagesAlive);
|
|
testEquals("",messagesReceived);
|
|
|
|
delete r2;
|
|
delete r4;
|
|
|
|
testEquals(2,messagesAlive);
|
|
testEquals("",messagesReceived);
|
|
|
|
NotificationManager::the()->run();
|
|
|
|
testEquals("r1r3",messagesReceived);
|
|
testEquals(0,messagesAlive);
|
|
}
|
|
};
|
|
|
|
TESTMAIN(TestNotification);
|