/*
	$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);
}