85 lines
2.3 KiB
C++
85 lines
2.3 KiB
C++
/**
|
|
* Copyright - See the COPYRIGHT that is included with this distribution.
|
|
* EPICS pvData is distributed subject to a Software License Agreement found
|
|
* in file LICENSE that is included with this distribution.
|
|
*/
|
|
/*
|
|
* testMessageQueue.cpp
|
|
*
|
|
* Created on: 2010.12
|
|
* Author: Marty Kraimer
|
|
*/
|
|
|
|
#include <cstddef>
|
|
#include <cstdlib>
|
|
#include <cstddef>
|
|
#include <string>
|
|
#include <cstdio>
|
|
|
|
#include <epicsUnitTest.h>
|
|
#include <testMain.h>
|
|
|
|
#include <pv/lock.h>
|
|
#include <pv/timeStamp.h>
|
|
#include <pv/requester.h>
|
|
#include <pv/messageQueue.h>
|
|
#include <pv/event.h>
|
|
|
|
|
|
using namespace epics::pvData;
|
|
|
|
static void testBasic() {
|
|
int queueSize = 3;
|
|
StringArray messages;
|
|
messages.reserve(5);
|
|
messages.push_back("1");
|
|
messages.push_back("2");
|
|
messages.push_back("3");
|
|
messages.push_back("4");
|
|
messages.push_back("5");
|
|
MessageQueuePtr queue = MessageQueue::create(queueSize);
|
|
bool result;
|
|
MessageNodePtr messageNode;
|
|
result = queue->isEmpty();
|
|
testOk1(result);
|
|
result = queue->put(messages[0],infoMessage,true);
|
|
testOk1(result);
|
|
result = queue->put(messages[1],infoMessage,true);
|
|
testOk1(result);
|
|
result = queue->put(messages[2],warningMessage,true);
|
|
testOk1(result);
|
|
testOk1(queue->isFull());
|
|
result = queue->put(messages[3],infoMessage,true);
|
|
testOk1(result==true);
|
|
messageNode = queue->get();
|
|
testOk1(messageNode.get()!=NULL);
|
|
printf("message %s messageType %s\n",
|
|
messageNode->getMessage().c_str(),
|
|
getMessageTypeName(messageNode->getMessageType()).c_str());
|
|
testOk1(messageNode->getMessage().compare(messages[0])==0);
|
|
queue->release();
|
|
messageNode = queue->get();
|
|
testOk1(messageNode.get()!=NULL);
|
|
testOk1(messageNode->getMessage().compare(messages[1])==0);
|
|
queue->release();
|
|
messageNode = queue->get();
|
|
testOk1(messageNode.get()!=NULL);
|
|
printf("message %s messageType %s\n",
|
|
messageNode->getMessage().c_str(),
|
|
getMessageTypeName(messageNode->getMessageType()).c_str());
|
|
testOk1(messageNode->getMessage().compare(messages[3])==0);
|
|
queue->release();
|
|
result = queue->isEmpty();
|
|
testOk1(result);
|
|
printf("PASSED\n");
|
|
}
|
|
|
|
MAIN(testMessageQueue)
|
|
{
|
|
testPlan(13);
|
|
testDiag("Tests messageQueue");
|
|
testBasic();
|
|
return testDone();
|
|
}
|
|
|