Merge branch 'development' into mueller/mutex-update
This commit is contained in:
commit
1bec19bdd7
@ -49,5 +49,11 @@ ReturnValue_t TaskFactory::delayTask(uint32_t delayMs) {
|
|||||||
return HasReturnvaluesIF::RETURN_OK;
|
return HasReturnvaluesIF::RETURN_OK;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void TaskFactory::printMissedDeadline() {
|
||||||
|
/* TODO: Implement */
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
TaskFactory::TaskFactory() {
|
TaskFactory::TaskFactory() {
|
||||||
}
|
}
|
||||||
|
@ -48,4 +48,9 @@ ReturnValue_t TaskFactory::delayTask(uint32_t delayMs){
|
|||||||
return HasReturnvaluesIF::RETURN_OK;
|
return HasReturnvaluesIF::RETURN_OK;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void TaskFactory::printMissedDeadline() {
|
||||||
|
/* TODO: Implement */
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -68,20 +68,6 @@ void PeriodicPosixTask::taskFunctionality(void) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if(not PosixThread::delayUntil(&lastWakeTime, periodMs)){
|
if(not PosixThread::delayUntil(&lastWakeTime, periodMs)){
|
||||||
char name[20] = {0};
|
|
||||||
int status = pthread_getname_np(pthread_self(), name, sizeof(name));
|
|
||||||
if(status == 0) {
|
|
||||||
#if FSFW_CPP_OSTREAM_ENABLED == 1
|
|
||||||
sif::error << "PeriodicPosixTask " << name << ": Deadline "
|
|
||||||
"missed." << std::endl;
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
#if FSFW_CPP_OSTREAM_ENABLED == 1
|
|
||||||
sif::error << "PeriodicPosixTask X: Deadline missed. " <<
|
|
||||||
status << std::endl;
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
if (this->deadlineMissedFunc != nullptr) {
|
if (this->deadlineMissedFunc != nullptr) {
|
||||||
this->deadlineMissedFunc();
|
this->deadlineMissedFunc();
|
||||||
}
|
}
|
||||||
|
@ -39,5 +39,26 @@ ReturnValue_t TaskFactory::delayTask(uint32_t delayMs){
|
|||||||
return PosixThread::sleep(delayMs*1000000ull);
|
return PosixThread::sleep(delayMs*1000000ull);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
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 */
|
||||||
|
}
|
||||||
|
|
||||||
TaskFactory::TaskFactory() {
|
TaskFactory::TaskFactory() {
|
||||||
}
|
}
|
||||||
|
@ -44,5 +44,10 @@ ReturnValue_t TaskFactory::delayTask(uint32_t delayMs){
|
|||||||
return HasReturnvaluesIF::RETURN_OK;
|
return HasReturnvaluesIF::RETURN_OK;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void TaskFactory::printMissedDeadline() {
|
||||||
|
/* TODO: Implement */
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
TaskFactory::TaskFactory() {
|
TaskFactory::TaskFactory() {
|
||||||
}
|
}
|
||||||
|
@ -62,6 +62,12 @@ public:
|
|||||||
*/
|
*/
|
||||||
static ReturnValue_t delayTask(uint32_t delayMs);
|
static ReturnValue_t delayTask(uint32_t delayMs);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* OS specific implementation to print deadline. In most cases, there is a OS specific
|
||||||
|
* way to retrieve the task name and print it out as well.
|
||||||
|
*/
|
||||||
|
static void printMissedDeadline();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
/**
|
/**
|
||||||
* External instantiation is not allowed.
|
* External instantiation is not allowed.
|
||||||
|
Loading…
Reference in New Issue
Block a user