fsfw-example-common/example/test/FsfwExampleTask.cpp

#include "FsfwExampleTask.h"

#include <fsfw/ipc/CommandMessage.h>
#include <fsfw/ipc/QueueFactory.h>
#include <fsfw/objectmanager/ObjectManager.h>
#include <fsfw/serviceinterface.h>
#include <fsfw/tasks/TaskFactory.h>

#include "OBSWConfig.h"
#include "commonSystemObjects.h"
#include "objects/systemObjectList.h"

FsfwExampleTask::FsfwExampleTask(object_id_t objectId)
    : SystemObject(objectId),
      poolManager(this, nullptr),
      demoSet(this),
      monitor(objectId, MONITOR_ID, gp_id_t(objectId, FsfwDemoSet::VARIABLE_LIMIT), 30, 10) {
  commandQueue = QueueFactory::instance()->createMessageQueue(10, CommandMessage::MAX_MESSAGE_SIZE);
}

FsfwExampleTask::~FsfwExampleTask() {}

ReturnValue_t FsfwExampleTask::performOperation(uint8_t operationCode) {
  if (operationCode == OpCodes::DELAY_SHORT) {
    TaskFactory::delayTask(5);
  }

  // TODO: Move this to new test controller?
  ReturnValue_t result = performMonitoringDemo();
  if (result != HasReturnvaluesIF::RETURN_OK) {
    return result;
  }

  if (operationCode == OpCodes::SEND_RAND_NUM) {
    result = performSendOperation();
    if (result != HasReturnvaluesIF::RETURN_OK) {
      return result;
    }
  }

  if (operationCode == OpCodes::RECEIVE_RAND_NUM) {
    result = performReceiveOperation();
  }

  return 0;
}

object_id_t FsfwExampleTask::getNextRecipient() {
  switch (this->getObjectId()) {
    case (objects::TEST_DUMMY_1): {
      return objects::TEST_DUMMY_2;
    }
    case (objects::TEST_DUMMY_2): {
      return objects::TEST_DUMMY_3;
    }
    case (objects::TEST_DUMMY_3): {
      return objects::TEST_DUMMY_1;
    }
    default:
      return objects::TEST_DUMMY_1;
  }
}

object_id_t FsfwExampleTask::getSender() {
  switch (this->getObjectId()) {
    case (objects::TEST_DUMMY_1): {
      return objects::TEST_DUMMY_3;
    }
    case (objects::TEST_DUMMY_2): {
      return objects::TEST_DUMMY_1;
    }
    case (objects::TEST_DUMMY_3): {
      return objects::TEST_DUMMY_2;
    }
    default:
      return objects::TEST_DUMMY_1;
  }
}

ReturnValue_t FsfwExampleTask::initialize() {
  // Get the dataset of the sender. Will be cached for later checks.
  object_id_t sender = getSender();
  auto* senderIF = ObjectManager::instance()->get<HasLocalDataPoolIF>(sender);
  if (senderIF == nullptr) {
    FSFW_LOGE("initialize: Sender object invalid\n");
    return HasReturnvaluesIF::RETURN_FAILED;
  }

  // we need a private copy of the previous dataset.. or we use the shared dataset.
  senderSet = new FsfwDemoSet(senderIF);
  if (senderSet == nullptr) {
    FSFW_LOGE("initialize: Sender dataset invalid\n");
    return HasReturnvaluesIF::RETURN_FAILED;
  }
  return poolManager.initialize(commandQueue);
}

ReturnValue_t FsfwExampleTask::initializeAfterTaskCreation() {
  return poolManager.initializeAfterTaskCreation();
}

object_id_t FsfwExampleTask::getObjectId() const { return SystemObject::getObjectId(); }

MessageQueueId_t FsfwExampleTask::getMessageQueueId() { return commandQueue->getId(); }

void FsfwExampleTask::setTaskIF(PeriodicTaskIF* task) { this->task = task; }

LocalPoolDataSetBase* FsfwExampleTask::getDataSetHandle(sid_t sid) { return &demoSet; }

uint32_t FsfwExampleTask::getPeriodicOperationFrequency() const { return task->getPeriodMs(); }

ReturnValue_t FsfwExampleTask::initializeLocalDataPool(localpool::DataPool& localDataPoolMap,
                                                       LocalDataPoolManager& poolManager) {
  localDataPoolMap.emplace(FsfwDemoSet::PoolIds::VARIABLE, new PoolEntry<uint32_t>({0}));
  localDataPoolMap.emplace(FsfwDemoSet::PoolIds::VARIABLE_LIMIT, new PoolEntry<uint16_t>({0}));
  return HasReturnvaluesIF::RETURN_OK;
}

ReturnValue_t FsfwExampleTask::performMonitoringDemo() {
  ReturnValue_t result = demoSet.variableLimit.read(MutexIF::TimeoutType::WAITING, 20);
  if (result != HasReturnvaluesIF::RETURN_OK) {
    /* Configuration error */
    FSFW_LOGE("DummyObject::performOperation: Could not read variableLimit\n");
    return result;
  }
  if (this->getObjectId() == objects::TEST_DUMMY_5) {
    if (demoSet.variableLimit.value > 20) {
      demoSet.variableLimit.value = 0;
    }
    demoSet.variableLimit.value++;
    demoSet.variableLimit.commit(true);
    monitor.check();
  }
  return HasReturnvaluesIF::RETURN_OK;
}

ReturnValue_t FsfwExampleTask::performSendOperation() {
  object_id_t nextRecipient = getNextRecipient();
  auto* target = ObjectManager::instance()->get<FsfwExampleTask>(nextRecipient);
  if (target == nullptr) {
    /* Configuration error */
    FSFW_LOGE("performSendOperation: Next recipient does not exist\n");
    return HasReturnvaluesIF::RETURN_FAILED;
  }

  uint32_t randomNumber = rand() % 100;
  CommandMessage message;
  message.setParameter(randomNumber);
  message.setParameter2(this->getMessageQueueId());

  /* Send message using own message queue */
  ReturnValue_t result = commandQueue->sendMessage(target->getMessageQueueId(), &message);
  if (result != HasReturnvaluesIF::RETURN_OK && result != MessageQueueIF::FULL) {
    FSFW_LOGE("performSendOperation: Send failed with {:#06x}\n", result);
  }

  /* Send message without via MessageQueueSenderIF */
  result = MessageQueueSenderIF::sendMessage(target->getMessageQueueId(), &message,
                                             commandQueue->getId());
  if (result != HasReturnvaluesIF::RETURN_OK && result != MessageQueueIF::FULL) {
    FSFW_LOGE("performSendOperation: Send failed with {:#06x}\n", result);
  }

  demoSet.variableWrite.value = randomNumber;
  result = demoSet.variableWrite.commit(true);

  return result;
}

ReturnValue_t FsfwExampleTask::performReceiveOperation() {
  ReturnValue_t result = HasReturnvaluesIF::RETURN_OK;
  while (result != MessageQueueIF::EMPTY) {
    CommandMessage receivedMessage;
    result = commandQueue->receiveMessage(&receivedMessage);
    if (result != HasReturnvaluesIF::RETURN_OK && result != MessageQueueIF::EMPTY) {
      FSFW_LOGD("performReceiveOperation: Receive failed with {}\n", result);
      break;
    }
    if (result != MessageQueueIF::EMPTY) {
#if FSFW_CPP_OSTREAM_ENABLED == 1
#if OBSW_VERBOSE_LEVEL >= 2
      sif::debug << "Message Received by " << getObjectId() << " from Queue "
                 << receivedMessage.getSender() << " ObjectId " << receivedMessage.getParameter()
                 << " Queue " << receivedMessage.getParameter2() << std::endl;
#endif
#endif

      if (senderSet == nullptr) {
        return HasReturnvaluesIF::RETURN_FAILED;
      }

      result = senderSet->variableRead.read(MutexIF::TimeoutType::WAITING, 20);
      if (result != HasReturnvaluesIF::RETURN_OK) {
        return result;
      }
      if (senderSet->variableRead.value != receivedMessage.getParameter()) {
        FSFW_LOGE(
            "FsfwDemoTask::performReceiveOperation: Variable {} has wrong value {}, expected {}\n",
            senderSet->variableRead.getDataPoolId(), demoSet.variableRead.value,
            receivedMessage.getParameter());
      }
    }
  }
  return result;
}

MessageQueueId_t FsfwExampleTask::getCommandQueue() const { return commandQueue->getId(); }

LocalDataPoolManager* FsfwExampleTask::getHkManagerHandle() { return &poolManager; }