action
container
contrib
controller
coordinates
datalinklayer
datapool
devicehandlers
events
fdir
globalfunctions
health
internalError
ipc
memory
modes
monitoring
objectmanager
osal
FreeRTOS
linux
rtems
Clock.cpp
CpuUsage.cpp
CpuUsage.h
InitTask.cpp
InitTask.h
InternalErrorCodes.cpp
Interrupt.cpp
Interrupt.h
MessageQueue.cpp
MessageQueue.h
MultiObjectTask.cpp
MultiObjectTask.h
Mutex.cpp
Mutex.h
MutexFactory.cpp
PollingTask.cpp
PollingTask.h
QueueFactory.cpp
RtemsBasic.cpp
RtemsBasic.h
TaskBase.cpp
TaskBase.h
TaskFactory.cpp
Endiness.h
InternalErrorCodes.h
parameters
power
returnvalues
rmap
serialize
serviceinterface
storagemanager
subsystem
tasks
tcdistribution
thermal
timemanager
tmstorage
tmtcpacket
tmtcservices
.gitignore
LICENSE
NOTICE
framework.mk
60 lines
1.5 KiB
C++
60 lines
1.5 KiB
C++
#include <framework/ipc/QueueFactory.h>
|
|
#include "MessageQueue.h"
|
|
#include "RtemsBasic.h"
|
|
|
|
QueueFactory* QueueFactory::factoryInstance = NULL;
|
|
|
|
|
|
ReturnValue_t MessageQueueSenderIF::sendMessage(MessageQueueId_t sendTo,
|
|
MessageQueueMessage* message, MessageQueueId_t sentFrom,bool ignoreFault) {
|
|
//TODO add ignoreFault functionality
|
|
message->setSender(sentFrom);
|
|
rtems_status_code result = rtems_message_queue_send(sendTo, message->getBuffer(),
|
|
message->messageSize);
|
|
switch(result){
|
|
case RTEMS_SUCCESSFUL:
|
|
//message sent successfully
|
|
return HasReturnvaluesIF::RETURN_OK;
|
|
case RTEMS_INVALID_ID:
|
|
//invalid queue id
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
case RTEMS_INVALID_SIZE:
|
|
// invalid message size
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
case RTEMS_INVALID_ADDRESS:
|
|
//buffer is NULL
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
case RTEMS_UNSATISFIED:
|
|
//out of message buffers
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
case RTEMS_TOO_MANY:
|
|
//queue's limit has been reached
|
|
return MessageQueueIF::FULL;
|
|
|
|
default:
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
}
|
|
}
|
|
|
|
QueueFactory* QueueFactory::instance() {
|
|
if (factoryInstance == NULL) {
|
|
factoryInstance = new QueueFactory;
|
|
}
|
|
return factoryInstance;
|
|
}
|
|
|
|
QueueFactory::QueueFactory() {
|
|
}
|
|
|
|
QueueFactory::~QueueFactory() {
|
|
}
|
|
|
|
MessageQueueIF* QueueFactory::createMessageQueue(uint32_t message_depth,
|
|
uint32_t max_message_size) {
|
|
return new MessageQueue(message_depth, max_message_size);
|
|
}
|
|
|
|
void QueueFactory::deleteMessageQueue(MessageQueueIF* queue) {
|
|
delete queue;
|
|
}
|