2020-08-13 20:53:35 +02:00
|
|
|
#include "FixedTimeslotTask.h"
|
|
|
|
#include "PeriodicPosixTask.h"
|
2020-12-14 21:46:33 +01:00
|
|
|
|
2020-08-13 20:53:35 +02:00
|
|
|
#include "../../tasks/TaskFactory.h"
|
2021-03-09 21:58:29 +01:00
|
|
|
#include "../../serviceinterface/ServiceInterface.h"
|
2020-08-13 20:53:35 +02:00
|
|
|
#include "../../returnvalues/HasReturnvaluesIF.h"
|
2018-07-13 18:28:26 +02:00
|
|
|
|
|
|
|
//TODO: Different variant than the lazy loading in QueueFactory. What's better and why?
|
|
|
|
TaskFactory* TaskFactory::factoryInstance = new TaskFactory();
|
|
|
|
|
|
|
|
TaskFactory::~TaskFactory() {
|
|
|
|
}
|
|
|
|
|
|
|
|
TaskFactory* TaskFactory::instance() {
|
|
|
|
return TaskFactory::factoryInstance;
|
|
|
|
}
|
|
|
|
|
2020-06-06 15:47:33 +02:00
|
|
|
PeriodicTaskIF* TaskFactory::createPeriodicTask(TaskName name_,
|
|
|
|
TaskPriority taskPriority_,TaskStackSize stackSize_,
|
|
|
|
TaskPeriod periodInSeconds_,
|
|
|
|
TaskDeadlineMissedFunction deadLineMissedFunction_) {
|
|
|
|
return new PeriodicPosixTask(name_, taskPriority_,stackSize_,
|
|
|
|
periodInSeconds_ * 1000, deadLineMissedFunction_);
|
2018-07-13 18:28:26 +02:00
|
|
|
}
|
|
|
|
|
2020-06-06 15:47:33 +02:00
|
|
|
FixedTimeslotTaskIF* TaskFactory::createFixedTimeslotTask(TaskName name_,
|
|
|
|
TaskPriority taskPriority_,TaskStackSize stackSize_,
|
|
|
|
TaskPeriod periodInSeconds_,
|
|
|
|
TaskDeadlineMissedFunction deadLineMissedFunction_) {
|
|
|
|
return new FixedTimeslotTask(name_, taskPriority_,stackSize_,
|
|
|
|
periodInSeconds_*1000);
|
2018-07-13 18:28:26 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
ReturnValue_t TaskFactory::deleteTask(PeriodicTaskIF* task) {
|
|
|
|
//TODO not implemented
|
|
|
|
return HasReturnvaluesIF::RETURN_FAILED;
|
|
|
|
}
|
|
|
|
|
|
|
|
ReturnValue_t TaskFactory::delayTask(uint32_t delayMs){
|
|
|
|
return PosixThread::sleep(delayMs*1000000ull);
|
|
|
|
}
|
|
|
|
|
2021-02-22 18:43:09 +01:00
|
|
|
void TaskFactory::printMissedDeadline() {
|
|
|
|
char name[20] = {0};
|
|
|
|
int status = pthread_getname_np(pthread_self(), name, sizeof(name));
|
|
|
|
#if FSFW_CPP_OSTREAM_ENABLED == 1
|
|
|
|
if(status == 0) {
|
|
|
|
sif::warning << "task::printMissedDeadline: " << name << "" << std::endl;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
sif::warning << "task::printMissedDeadline: Unknown task name" << status <<
|
|
|
|
std::endl;
|
|
|
|
}
|
|
|
|
#else
|
|
|
|
if(status == 0) {
|
|
|
|
sif::printWarning("task::printMissedDeadline: %s\n", name);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
sif::printWarning("task::printMissedDeadline: Unknown task name\n", name);
|
|
|
|
}
|
|
|
|
#endif /* FSFW_CPP_OSTREAM_ENABLED == 1 */
|
|
|
|
}
|
|
|
|
|
2018-07-13 18:28:26 +02:00
|
|
|
TaskFactory::TaskFactory() {
|
|
|
|
}
|