$Id: MessageQueueTestCase.cpp 383 2002-07-22 09:28:00Z tylerdauwalder $
This file implements a base class for testing BMessageQueue functionality.
*/
#include "MessageQueueTestCase.h"
#include <MessageQueue.h>
#include "MessageQueue.h"
int testMessageClass::messageDestructorCount = 0;
MessageQueueTestCase::MessageQueueTestCase(
std::string name) : BThreadedTestCase(name),
theMessageQueue(new BMessageQueue())
{
}
MessageQueueTestCase::~MessageQueueTestCase()
{
delete theMessageQueue;
theMessageQueue = NULL;
}
void MessageQueueTestCase::CheckQueueAgainstList(void)
{
SafetyLock theSafetyLock(theMessageQueue);
if (theMessageQueue->Lock()) {
CPPUNIT_ASSERT(theMessageQueue->CountMessages() == messageList.CountItems());
int i;
for (i = 0; i < theMessageQueue->CountMessages(); i++) {
CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)i) ==
messageList.ItemAt(i));
}
theMessageQueue->Unlock();
}
}
void MessageQueueTestCase::AddMessage(BMessage *message)
{
if (theMessageQueue->Lock()) {
theMessageQueue->AddMessage(message);
messageList.AddItem(message);
theMessageQueue->Unlock();
}
}
void MessageQueueTestCase::RemoveMessage(BMessage *message)
{
if (theMessageQueue->Lock()) {
theMessageQueue->RemoveMessage(message);
messageList.RemoveItem((void *)message);
theMessageQueue->Unlock();
}
}
BMessage *MessageQueueTestCase::NextMessage(void)
{
SafetyLock theSafetyLock(theMessageQueue);
BMessage *result = NULL;
if (theMessageQueue->Lock()) {
result = theMessageQueue->NextMessage();
CPPUNIT_ASSERT(result == messageList.RemoveItem((int32)0));
theMessageQueue->Unlock();
}
return(result);
}
BMessage *MessageQueueTestCase::FindMessage(uint32 what, int index)
{
int listCount = messageList.CountItems();
int i;
for (i = 0; i < listCount; i++) {
BMessage *theMessage = (BMessage *)messageList.ItemAt(i);
if (theMessage->what == what) {
if (index == 0) {
return(theMessage);
}
index--;
}
}
return(NULL);
}
