138 lines
3.3 KiB
C++
138 lines
3.3 KiB
C++
#include "../subsystem/SubsystemBase.h"
|
|
#include "ControllerBase.h"
|
|
#include "../subsystem/SubsystemBase.h"
|
|
#include "../ipc/QueueFactory.h"
|
|
#include "../action/HasActionsIF.h"
|
|
|
|
ControllerBase::ControllerBase(uint32_t setObjectId, uint32_t parentId,
|
|
size_t commandQueueDepth) :
|
|
SystemObject(setObjectId), parentId(parentId), mode(MODE_OFF), submode(
|
|
SUBMODE_NONE), commandQueue(NULL), modeHelper(
|
|
this), healthHelper(this, setObjectId),hkSwitcher(this),executingTask(NULL) {
|
|
commandQueue = QueueFactory::instance()->createMessageQueue(commandQueueDepth);
|
|
|
|
}
|
|
|
|
ControllerBase::~ControllerBase() {
|
|
QueueFactory::instance()->deleteMessageQueue(commandQueue);
|
|
}
|
|
|
|
ReturnValue_t ControllerBase::initialize() {
|
|
ReturnValue_t result = SystemObject::initialize();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
|
|
MessageQueueId_t parentQueue = 0;
|
|
if (parentId != 0) {
|
|
SubsystemBase *parent = objectManager->get<SubsystemBase>(parentId);
|
|
if (parent == NULL) {
|
|
return RETURN_FAILED;
|
|
}
|
|
parentQueue = parent->getCommandQueue();
|
|
|
|
parent->registerChild(getObjectId());
|
|
}
|
|
|
|
result = healthHelper.initialize(parentQueue);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
|
|
result = modeHelper.initialize(parentQueue);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
|
|
result = hkSwitcher.initialize();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
MessageQueueId_t ControllerBase::getCommandQueue() const {
|
|
return commandQueue->getId();
|
|
}
|
|
|
|
void ControllerBase::handleQueue() {
|
|
CommandMessage message;
|
|
ReturnValue_t result;
|
|
for (result = commandQueue->receiveMessage(&message); result == RETURN_OK;
|
|
result = commandQueue->receiveMessage(&message)) {
|
|
|
|
result = modeHelper.handleModeCommand(&message);
|
|
if (result == RETURN_OK) {
|
|
continue;
|
|
}
|
|
|
|
result = healthHelper.handleHealthCommand(&message);
|
|
if (result == RETURN_OK) {
|
|
continue;
|
|
}
|
|
result = handleCommandMessage(&message);
|
|
if (result == RETURN_OK) {
|
|
continue;
|
|
}
|
|
message.setToUnknownCommand();
|
|
commandQueue->reply(&message);
|
|
}
|
|
|
|
}
|
|
|
|
void ControllerBase::startTransition(Mode_t mode, Submode_t submode) {
|
|
changeHK(this->mode, this->submode, false);
|
|
triggerEvent(CHANGING_MODE, mode, submode);
|
|
this->mode = mode;
|
|
this->submode = submode;
|
|
modeHelper.modeChanged(mode, submode);
|
|
modeChanged(mode, submode);
|
|
announceMode(false);
|
|
changeHK(this->mode, this->submode, true);
|
|
}
|
|
|
|
void ControllerBase::getMode(Mode_t* mode, Submode_t* submode) {
|
|
*mode = this->mode;
|
|
*submode = this->submode;
|
|
}
|
|
|
|
void ControllerBase::setToExternalControl() {
|
|
healthHelper.setHealth(EXTERNAL_CONTROL);
|
|
}
|
|
|
|
void ControllerBase::announceMode(bool recursive) {
|
|
triggerEvent(MODE_INFO, mode, submode);
|
|
}
|
|
|
|
ReturnValue_t ControllerBase::performOperation(uint8_t opCode) {
|
|
handleQueue();
|
|
hkSwitcher.performOperation();
|
|
performControlOperation();
|
|
return RETURN_OK;
|
|
}
|
|
|
|
void ControllerBase::modeChanged(Mode_t mode, Submode_t submode) {
|
|
return;
|
|
}
|
|
|
|
ReturnValue_t ControllerBase::setHealth(HealthState health) {
|
|
switch (health) {
|
|
case HEALTHY:
|
|
case EXTERNAL_CONTROL:
|
|
healthHelper.setHealth(health);
|
|
return RETURN_OK;
|
|
default:
|
|
return INVALID_HEALTH_STATE;
|
|
}
|
|
}
|
|
|
|
HasHealthIF::HealthState ControllerBase::getHealth() {
|
|
return healthHelper.getHealth();
|
|
}
|
|
void ControllerBase::setTaskIF(PeriodicTaskIF* task_){
|
|
executingTask = task_;
|
|
}
|
|
|
|
void ControllerBase::changeHK(Mode_t mode, Submode_t submode, bool enable) {
|
|
}
|