action
container
contrib
controller
coordinates
datalinklayer
datapool
datapoolglob
datapoollocal
devicehandlers
events
fdir
globalfunctions
health
housekeeping
internalError
ipc
memory
modes
monitoring
objectmanager
osal
FreeRTOS
host
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
87 lines
2.8 KiB
C++
87 lines
2.8 KiB
C++
/**
|
|
* @file MultiObjectTask.cpp
|
|
* @brief This file defines the MultiObjectTask class.
|
|
* @date 30.01.2014
|
|
* @author baetz
|
|
*/
|
|
|
|
#include <framework/serviceinterface/ServiceInterfaceStream.h>
|
|
#include <framework/tasks/ExecutableObjectIF.h>
|
|
#include "MultiObjectTask.h"
|
|
|
|
MultiObjectTask::MultiObjectTask(const char *name, rtems_task_priority setPriority,
|
|
size_t setStack, rtems_interval setPeriod, void (*setDeadlineMissedFunc)()) :
|
|
TaskBase(setPriority, setStack, name), periodTicks(
|
|
RtemsBasic::convertMsToTicks(setPeriod)), periodId(0), deadlineMissedFunc(
|
|
setDeadlineMissedFunc) {
|
|
}
|
|
|
|
MultiObjectTask::~MultiObjectTask(void) {
|
|
//Do not delete objects, we were responsible for ptrs only.
|
|
rtems_rate_monotonic_delete(periodId);
|
|
}
|
|
rtems_task MultiObjectTask::taskEntryPoint(rtems_task_argument argument) {
|
|
//The argument is re-interpreted as MultiObjectTask. The Task object is global, so it is found from any place.
|
|
MultiObjectTask *originalTask(reinterpret_cast<MultiObjectTask*>(argument));
|
|
originalTask->taskFunctionality();
|
|
}
|
|
|
|
ReturnValue_t MultiObjectTask::startTask() {
|
|
rtems_status_code status = rtems_task_start(id, MultiObjectTask::taskEntryPoint,
|
|
rtems_task_argument((void *) this));
|
|
if (status != RTEMS_SUCCESSFUL) {
|
|
error << "ObjectTask::startTask for " << std::hex << this->getId()
|
|
<< std::dec << " failed." << std::endl;
|
|
}
|
|
switch(status){
|
|
case RTEMS_SUCCESSFUL:
|
|
//ask started successfully
|
|
return HasReturnvaluesIF::RETURN_OK;
|
|
default:
|
|
/* RTEMS_INVALID_ADDRESS - invalid task entry point
|
|
RTEMS_INVALID_ID - invalid task id
|
|
RTEMS_INCORRECT_STATE - task not in the dormant state
|
|
RTEMS_ILLEGAL_ON_REMOTE_OBJECT - cannot start remote task */
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
}
|
|
}
|
|
|
|
ReturnValue_t MultiObjectTask::sleepFor(uint32_t ms) {
|
|
return TaskBase::sleepFor(ms);
|
|
}
|
|
|
|
void MultiObjectTask::taskFunctionality() {
|
|
TaskBase::setAndStartPeriod(periodTicks,&periodId);
|
|
//The task's "infinite" inner loop is entered.
|
|
while (1) {
|
|
for (ObjectList::iterator it = objectList.begin();
|
|
it != objectList.end(); ++it) {
|
|
(*it)->performOperation();
|
|
}
|
|
rtems_status_code status = TaskBase::restartPeriod(periodTicks,periodId);
|
|
if (status == RTEMS_TIMEOUT) {
|
|
char nameSpace[8] = { 0 };
|
|
char* ptr = rtems_object_get_name(getId(), sizeof(nameSpace),
|
|
nameSpace);
|
|
error << "ObjectTask: " << ptr << " Deadline missed." << std::endl;
|
|
if (this->deadlineMissedFunc != NULL) {
|
|
this->deadlineMissedFunc();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
ReturnValue_t MultiObjectTask::addComponent(object_id_t object) {
|
|
ExecutableObjectIF* newObject = objectManager->get<ExecutableObjectIF>(
|
|
object);
|
|
if (newObject == NULL) {
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
}
|
|
objectList.push_back(newObject);
|
|
return HasReturnvaluesIF::RETURN_OK;
|
|
}
|
|
|
|
uint32_t MultiObjectTask::getPeriodMs() const {
|
|
return RtemsBasic::convertTicksToMs(periodTicks);
|
|
}
|