Robin Mueller
b503836a3d
All checks were successful
EIVE/eive-obsw/pipeline/pr-develop This commit looks good
654 lines
21 KiB
C++
654 lines
21 KiB
C++
#include "PlocSupvHelper.h"
|
|
|
|
#include <cmath>
|
|
#include <filesystem>
|
|
#include <fstream>
|
|
|
|
#include "OBSWConfig.h"
|
|
#ifdef XIPHOS_Q7S
|
|
#include "bsp_q7s/memory/FilesystemHelper.h"
|
|
#include "bsp_q7s/memory/SdCardManager.h"
|
|
#endif
|
|
|
|
#include "fsfw/globalfunctions/CRC.h"
|
|
#include "fsfw/tasks/TaskFactory.h"
|
|
#include "fsfw/timemanager/Countdown.h"
|
|
#include "mission/utility/Filenaming.h"
|
|
#include "mission/utility/ProgressPrinter.h"
|
|
#include "mission/utility/Timestamp.h"
|
|
|
|
PlocSupvHelper::PlocSupvHelper(object_id_t objectId) : SystemObject(objectId) {
|
|
spParams.maxSize = sizeof(commandBuffer);
|
|
resetSpParams();
|
|
}
|
|
|
|
PlocSupvHelper::~PlocSupvHelper() {}
|
|
|
|
ReturnValue_t PlocSupvHelper::initialize() {
|
|
#ifdef XIPHOS_Q7S
|
|
sdcMan = SdCardManager::instance();
|
|
if (sdcMan == nullptr) {
|
|
sif::warning << "PlocSupvHelper::initialize: Invalid SD Card Manager" << std::endl;
|
|
return RETURN_FAILED;
|
|
}
|
|
#endif
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::performOperation(uint8_t operationCode) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
semaphore.acquire();
|
|
while (true) {
|
|
switch (internalState) {
|
|
case InternalState::IDLE: {
|
|
semaphore.acquire();
|
|
break;
|
|
}
|
|
case InternalState::UPDATE: {
|
|
result = performUpdate();
|
|
if (result == RETURN_OK) {
|
|
triggerEvent(SUPV_UPDATE_SUCCESSFUL, result);
|
|
} else if (result == PROCESS_TERMINATED) {
|
|
// Event already triggered
|
|
} else {
|
|
triggerEvent(SUPV_UPDATE_FAILED, result);
|
|
}
|
|
internalState = InternalState::IDLE;
|
|
break;
|
|
}
|
|
case InternalState::CONTINUE_UPDATE: {
|
|
result = continueUpdate();
|
|
if (result == RETURN_OK) {
|
|
triggerEvent(SUPV_CONTINUE_UPDATE_SUCCESSFUL, result);
|
|
} else if (result == PROCESS_TERMINATED) {
|
|
// Event already triggered
|
|
} else {
|
|
triggerEvent(SUPV_CONTINUE_UPDATE_FAILED, result);
|
|
}
|
|
internalState = InternalState::IDLE;
|
|
break;
|
|
}
|
|
case InternalState::REQUEST_EVENT_BUFFER: {
|
|
result = performEventBufferRequest();
|
|
if (result == RETURN_OK) {
|
|
triggerEvent(SUPV_EVENT_BUFFER_REQUEST_SUCCESSFUL, result);
|
|
} else if (result == PROCESS_TERMINATED) {
|
|
// Event already triggered
|
|
break;
|
|
} else {
|
|
triggerEvent(SUPV_EVENT_BUFFER_REQUEST_FAILED, result);
|
|
}
|
|
internalState = InternalState::IDLE;
|
|
break;
|
|
}
|
|
default:
|
|
sif::debug << "PlocSupvHelper::performOperation: Invalid state" << std::endl;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::setComIF(UartComIF* uartComIF_) {
|
|
if (uartComIF_ == nullptr) {
|
|
sif::warning << "PlocSupvHelper::initialize: Provided invalid uart com if" << std::endl;
|
|
return RETURN_FAILED;
|
|
}
|
|
uartComIF = uartComIF_;
|
|
return RETURN_OK;
|
|
}
|
|
|
|
void PlocSupvHelper::setComCookie(CookieIF* comCookie_) { comCookie = comCookie_; }
|
|
|
|
ReturnValue_t PlocSupvHelper::startUpdate(std::string file, uint8_t memoryId,
|
|
uint32_t startAddress) {
|
|
return performUpdate(file, memoryId, startAddress, 0, 1);
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::performUpdate(std::string file, uint8_t memoryId,
|
|
uint32_t startAddress, size_t startBytesWritten,
|
|
uint16_t initSeqCount) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
#ifdef XIPHOS_Q7S
|
|
result = FilesystemHelper::checkPath(file);
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::startUpdate: File " << file << " does not exist" << std::endl;
|
|
return result;
|
|
}
|
|
result = FilesystemHelper::fileExists(file);
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::startUpdate: The file " << file << " does not exist"
|
|
<< std::endl;
|
|
return result;
|
|
}
|
|
#endif
|
|
#ifdef TE0720_1CFA
|
|
if (not std::filesystem::exists(file)) {
|
|
sif::warning << "PlocSupvHelper::startUpdate: The file " << file << " does not exist"
|
|
<< std::endl;
|
|
return RETURN_FAILED;
|
|
}
|
|
#endif
|
|
update.file = file;
|
|
update.length = getFileSize(update.file);
|
|
update.memoryId = memoryId;
|
|
update.startAddress = startAddress;
|
|
update.progressPercent = 0;
|
|
update.bytesWritten = startBytesWritten;
|
|
update.packetNum = 1;
|
|
update.sequenceCount = initSeqCount;
|
|
internalState = InternalState::UPDATE;
|
|
uartComIF->flushUartTxAndRxBuf(comCookie);
|
|
semaphore.release();
|
|
return result;
|
|
}
|
|
|
|
void PlocSupvHelper::initiateUpdateContinuation() {
|
|
internalState = InternalState::CONTINUE_UPDATE;
|
|
semaphore.release();
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::startEventbBufferRequest(std::string path) {
|
|
#ifdef XIPHOS_Q7S
|
|
ReturnValue_t result = FilesystemHelper::checkPath(path);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
#endif
|
|
if (not std::filesystem::exists(path)) {
|
|
return PATH_NOT_EXISTS;
|
|
}
|
|
eventBufferReq.path = path;
|
|
internalState = InternalState::REQUEST_EVENT_BUFFER;
|
|
uartComIF->flushUartTxAndRxBuf(comCookie);
|
|
semaphore.release();
|
|
return RETURN_OK;
|
|
}
|
|
|
|
void PlocSupvHelper::stopProcess() { terminate = true; }
|
|
|
|
ReturnValue_t PlocSupvHelper::performUpdate() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
sif::info << "PlocSupvHelper::performUpdate: Calculating Image CRC" << std::endl;
|
|
result = calcImageCrc();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
sif::info << "PlocSupvHelper::performUpdate: Selecting Memory" << std::endl;
|
|
result = selectMemory();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
sif::info << "PlocSupvHelper::performUpdate: Preparing Update" << std::endl;
|
|
result = prepareUpdate();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
sif::info << "PlocSupvHelper::performUpdate: Erasing Memory" << std::endl;
|
|
result = eraseMemory();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return updateOperation();
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::continueUpdate() {
|
|
ReturnValue_t result = prepareUpdate();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return updateOperation();
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::updateOperation() {
|
|
sif::info << "PlocSupvHelper::performUpdate: Writing Update Packets" << std::endl;
|
|
auto result = writeUpdatePackets();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
sif::info << "PlocSupvHelper::performUpdate: Memory Check" << std::endl;
|
|
return handleCheckMemoryCommand();
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::writeUpdatePackets() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
#if OBSW_DEBUG_PLOC_SUPERVISOR == 1
|
|
ProgressPrinter progressPrinter("Supervisor update", update.length,
|
|
ProgressPrinter::HALF_PERCENT);
|
|
#endif /* OBSW_DEBUG_PLOC_SUPERVISOR == 1 */
|
|
uint8_t tempData[supv::WriteMemory::CHUNK_MAX + 1]{};
|
|
std::ifstream file(update.file, std::ifstream::binary);
|
|
uint16_t dataLength = 0;
|
|
ccsds::SequenceFlags seqFlags;
|
|
while (update.bytesWritten < update.length) {
|
|
if (terminate) {
|
|
terminate = false;
|
|
triggerEvent(TERMINATED_UPDATE_PROCEDURE);
|
|
return PROCESS_TERMINATED;
|
|
}
|
|
size_t remainingSize = update.length - update.bytesWritten;
|
|
bool lastSegment = false;
|
|
if (remainingSize > supv::WriteMemory::CHUNK_MAX) {
|
|
dataLength = supv::WriteMemory::CHUNK_MAX;
|
|
} else {
|
|
lastSegment = true;
|
|
dataLength = static_cast<uint16_t>(remainingSize);
|
|
}
|
|
if (file.is_open()) {
|
|
file.seekg(update.bytesWritten, std::ios::beg);
|
|
file.read(reinterpret_cast<char*>(tempData), dataLength);
|
|
if (!file) {
|
|
sif::warning << "PlocSupvHelper::performUpdate: Read only " << file.gcount() << " of "
|
|
<< dataLength << " bytes" << std::endl;
|
|
sif::info << "PlocSupvHelper::performUpdate: Failed when trying to read byte "
|
|
<< update.bytesWritten << std::endl;
|
|
}
|
|
} else {
|
|
return FILE_CLOSED_ACCIDENTALLY;
|
|
}
|
|
if (update.bytesWritten == 0) {
|
|
seqFlags = ccsds::SequenceFlags::FIRST_SEGMENT;
|
|
} else if (lastSegment) {
|
|
seqFlags = ccsds::SequenceFlags::LAST_SEGMENT;
|
|
} else {
|
|
seqFlags = ccsds::SequenceFlags::CONTINUATION;
|
|
}
|
|
resetSpParams();
|
|
float progress = static_cast<float>(update.bytesWritten) / update.length;
|
|
uint8_t progPercent = std::floor(progress * 100);
|
|
if (progPercent > update.progressPercent) {
|
|
update.progressPercent = progPercent;
|
|
if (progPercent % 5 == 0) {
|
|
// Useful to allow restarting the update
|
|
triggerEvent(SUPV_UPDATE_PROGRESS, update.bytesWritten, update.sequenceCount);
|
|
}
|
|
}
|
|
supv::WriteMemory packet(spParams);
|
|
result = packet.buildPacket(seqFlags, update.sequenceCount, update.memoryId,
|
|
update.startAddress + update.bytesWritten, dataLength, tempData);
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(WRITE_MEMORY_FAILED, update.bytesWritten, update.sequenceCount);
|
|
return result;
|
|
}
|
|
result = handlePacketTransmission(packet);
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(WRITE_MEMORY_FAILED, update.bytesWritten, update.sequenceCount);
|
|
return result;
|
|
}
|
|
update.sequenceCount++;
|
|
update.packetNum += 1;
|
|
update.bytesWritten += dataLength;
|
|
|
|
#if OBSW_DEBUG_PLOC_SUPERVISOR == 1
|
|
progressPrinter.print(update.bytesWritten);
|
|
#endif /* OBSW_DEBUG_PLOC_SUPERVISOR == 1 */
|
|
}
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::performEventBufferRequest() {
|
|
using namespace supv;
|
|
ReturnValue_t result = RETURN_OK;
|
|
resetSpParams();
|
|
RequestLoggingData packet(spParams);
|
|
result = packet.buildPacket(RequestLoggingData::Sa::REQUEST_EVENT_BUFFERS);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = sendCommand(packet);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handleAck();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handleEventBufferReception();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handleExe();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::selectMemory() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
resetSpParams();
|
|
supv::MPSoCBootSelect packet(spParams);
|
|
result = packet.buildPacket(update.memoryId);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handlePacketTransmission(packet);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::prepareUpdate() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
resetSpParams();
|
|
supv::ApidOnlyPacket packet(spParams, supv::APID_PREPARE_UPDATE);
|
|
result = packet.buildPacket();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handlePacketTransmission(packet, PREPARE_UPDATE_EXECUTION_REPORT);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::eraseMemory() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
resetSpParams();
|
|
supv::EraseMemory eraseMemory(spParams);
|
|
result = eraseMemory.buildPacket(update.memoryId, update.startAddress, update.length);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handlePacketTransmission(eraseMemory, supv::recv_timeout::ERASE_MEMORY);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::handlePacketTransmission(ploc::SpTcBase& packet,
|
|
uint32_t timeoutExecutionReport) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
result = sendCommand(packet);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handleAck();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handleExe(timeoutExecutionReport);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::sendCommand(ploc::SpTcBase& packet) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
rememberApid = packet.getApid();
|
|
result = uartComIF->sendMessage(comCookie, packet.getFullPacket(), packet.getFullPacketLen());
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::sendCommand: Failed to send command" << std::endl;
|
|
triggerEvent(SUPV_SENDING_COMMAND_FAILED, result, static_cast<uint32_t>(internalState));
|
|
return result;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::handleAck() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
|
|
result = handleTmReception(supv::SIZE_ACK_REPORT);
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(ACK_RECEPTION_FAILURE, result, static_cast<uint32_t>(rememberApid));
|
|
sif::warning << "PlocSupvHelper::handleAck: Error in reception of acknowledgment report"
|
|
<< std::endl;
|
|
return result;
|
|
}
|
|
supv::AcknowledgmentReport ackReport(tmBuf.data(), tmBuf.size());
|
|
result = checkReceivedTm(ackReport);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = ackReport.checkApid();
|
|
if (result != RETURN_OK) {
|
|
if (result == SupvReturnValuesIF::RECEIVED_ACK_FAILURE) {
|
|
triggerEvent(SUPV_ACK_FAILURE_REPORT, static_cast<uint32_t>(ackReport.getRefApid()));
|
|
} else if (result == SupvReturnValuesIF::INVALID_APID) {
|
|
triggerEvent(SUPV_ACK_INVALID_APID, static_cast<uint32_t>(rememberApid));
|
|
}
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::handleExe(uint32_t timeout) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
|
|
result = handleTmReception(supv::SIZE_EXE_REPORT, timeout);
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(EXE_RECEPTION_FAILURE, result, static_cast<uint32_t>(rememberApid));
|
|
sif::warning << "PlocSupvHelper::handleExe: Error in reception of execution report"
|
|
<< std::endl;
|
|
return result;
|
|
}
|
|
supv::ExecutionReport exeReport(tmBuf.data(), tmBuf.size());
|
|
result = checkReceivedTm(exeReport);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = exeReport.checkApid();
|
|
if (result != RETURN_OK) {
|
|
if (result == SupvReturnValuesIF::RECEIVED_EXE_FAILURE) {
|
|
triggerEvent(SUPV_EXE_FAILURE_REPORT, static_cast<uint32_t>(exeReport.getRefApid()));
|
|
} else if (result == SupvReturnValuesIF::INVALID_APID) {
|
|
triggerEvent(SUPV_EXE_INVALID_APID, static_cast<uint32_t>(rememberApid));
|
|
}
|
|
return result;
|
|
}
|
|
return RETURN_OK;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::handleTmReception(size_t remainingBytes, uint32_t timeout) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
size_t readBytes = 0;
|
|
size_t currentBytes = 0;
|
|
Countdown countdown(timeout);
|
|
while (!countdown.hasTimedOut()) {
|
|
result = receive(tmBuf.data() + readBytes, ¤tBytes, remainingBytes);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
readBytes += currentBytes;
|
|
remainingBytes = remainingBytes - currentBytes;
|
|
if (remainingBytes == 0) {
|
|
break;
|
|
}
|
|
}
|
|
if (remainingBytes != 0) {
|
|
sif::warning << "PlocSupvHelper::handleTmReception: Failed to read " << std::dec
|
|
<< remainingBytes << " bytes" << std::endl;
|
|
return RETURN_FAILED;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::checkReceivedTm(ploc::SpTmReader& reader) {
|
|
ReturnValue_t result = reader.checkSize();
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(SUPV_REPLY_SIZE_MISSMATCH, rememberApid);
|
|
return result;
|
|
}
|
|
result = reader.checkCrc();
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(SUPV_REPLY_CRC_MISSMATCH, rememberApid);
|
|
return result;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::receive(uint8_t* data, size_t* readBytes, size_t requestBytes) {
|
|
ReturnValue_t result = RETURN_OK;
|
|
uint8_t* buffer = nullptr;
|
|
result = uartComIF->requestReceiveMessage(comCookie, requestBytes);
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::receive: Failed to request reply" << std::endl;
|
|
triggerEvent(SUPV_HELPER_REQUESTING_REPLY_FAILED, result,
|
|
static_cast<uint32_t>(static_cast<uint32_t>(internalState)));
|
|
return RETURN_FAILED;
|
|
}
|
|
result = uartComIF->readReceivedMessage(comCookie, &buffer, readBytes);
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::receive: Failed to read received message" << std::endl;
|
|
triggerEvent(SUPV_HELPER_READING_REPLY_FAILED, result, static_cast<uint32_t>(internalState));
|
|
return RETURN_FAILED;
|
|
}
|
|
if (*readBytes > 0) {
|
|
std::memcpy(data, buffer, *readBytes);
|
|
} else {
|
|
TaskFactory::delayTask(40);
|
|
}
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::calcImageCrc() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
#ifdef XIPHOS_Q7S
|
|
result = FilesystemHelper::checkPath(update.file);
|
|
#endif
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::calcImageCrc: File " << update.file << " does not exist"
|
|
<< std::endl;
|
|
return result;
|
|
}
|
|
std::ifstream file(update.file, std::ifstream::binary);
|
|
uint16_t remainder = CRC16_INIT;
|
|
uint8_t input;
|
|
#if OBSW_DEBUG_PLOC_SUPERVISOR == 1
|
|
ProgressPrinter progress("Supervisor update crc calculation", update.length,
|
|
ProgressPrinter::ONE_PERCENT);
|
|
#endif /* OBSW_DEBUG_PLOC_SUPERVISOR == 1 */
|
|
uint32_t byteCount = 0;
|
|
for (byteCount = 0; byteCount < update.length; byteCount++) {
|
|
file.seekg(byteCount, file.beg);
|
|
file.read(reinterpret_cast<char*>(&input), 1);
|
|
remainder = CRC::crc16ccitt(&input, sizeof(input), remainder);
|
|
#if OBSW_DEBUG_PLOC_SUPERVISOR == 1
|
|
progress.print(byteCount);
|
|
#endif /* OBSW_DEBUG_PLOC_SUPERVISOR == 1 */
|
|
}
|
|
#if OBSW_DEBUG_PLOC_SUPERVISOR == 1
|
|
progress.print(byteCount);
|
|
#endif /* OBSW_DEBUG_PLOC_SUPERVISOR == 1 */
|
|
file.close();
|
|
update.crc = remainder;
|
|
return result;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::handleCheckMemoryCommand() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
resetSpParams();
|
|
// Verification of update write procedure
|
|
supv::CheckMemory packet(spParams);
|
|
result = packet.buildPacket(update.memoryId, update.startAddress, update.length);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = sendCommand(packet);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = handleAck();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
|
|
// Will hold status report for later processing
|
|
std::array<uint8_t, 32> statusReportBuf{};
|
|
{
|
|
supv::UpdateStatusReport updateStatusReport(tmBuf.data(), tmBuf.size());
|
|
result = handleTmReception(static_cast<size_t>(updateStatusReport.getNominalSize()),
|
|
supv::recv_timeout::UPDATE_STATUS_REPORT);
|
|
if (result != RETURN_OK) {
|
|
sif::warning
|
|
<< "PlocSupvHelper::handleCheckMemoryCommand: Failed to receive update status report"
|
|
<< std::endl;
|
|
return result;
|
|
}
|
|
result = updateStatusReport.checkCrc();
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::handleTmReception: CRC check failed" << std::endl;
|
|
return result;
|
|
}
|
|
// We need to copy this into another buffer. Otherwise, it will be overwritten
|
|
// when reading the execution report.
|
|
std::memcpy(statusReportBuf.data(), tmBuf.data(), updateStatusReport.getNominalSize());
|
|
}
|
|
|
|
result = handleExe(CRC_EXECUTION_TIMEOUT);
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
// Now process the status report
|
|
supv::UpdateStatusReport statusReportCopy(statusReportBuf.data(), statusReportBuf.size());
|
|
result = statusReportCopy.parseDataField();
|
|
if (result != RETURN_OK) {
|
|
return result;
|
|
}
|
|
result = statusReportCopy.verifycrc(update.crc);
|
|
if (result != RETURN_OK) {
|
|
sif::warning << "PlocSupvHelper::handleCheckMemoryCommand: CRC failure. Expected CRC 0x"
|
|
<< std::hex << update.crc << " but received CRC 0x" << statusReportCopy.getCrc()
|
|
<< std::endl;
|
|
return result;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
uint32_t PlocSupvHelper::getFileSize(std::string filename) {
|
|
std::ifstream file(filename, std::ifstream::binary);
|
|
file.seekg(0, file.end);
|
|
uint32_t size = file.tellg();
|
|
file.close();
|
|
return size;
|
|
}
|
|
|
|
ReturnValue_t PlocSupvHelper::handleEventBufferReception() {
|
|
ReturnValue_t result = RETURN_OK;
|
|
std::string filename = Filenaming::generateAbsoluteFilename(
|
|
eventBufferReq.path, eventBufferReq.filename, timestamping);
|
|
std::ofstream file(filename, std::ios_base::app | std::ios_base::out);
|
|
uint32_t packetsRead = 0;
|
|
size_t requestLen = 0;
|
|
ploc::SpTmReader tmReader(tmBuf.data(), tmBuf.size());
|
|
for (packetsRead = 0; packetsRead < NUM_EVENT_BUFFER_PACKETS; packetsRead++) {
|
|
if (terminate) {
|
|
triggerEvent(SUPV_EVENT_BUFFER_REQUEST_TERMINATED, packetsRead - 1);
|
|
file.close();
|
|
return PROCESS_TERMINATED;
|
|
}
|
|
if (packetsRead == NUM_EVENT_BUFFER_PACKETS - 1) {
|
|
requestLen = SIZE_EVENT_BUFFER_LAST_PACKET;
|
|
} else {
|
|
requestLen = SIZE_EVENT_BUFFER_FULL_PACKET;
|
|
}
|
|
result = handleTmReception(requestLen);
|
|
if (result != RETURN_OK) {
|
|
sif::debug << "PlocSupvHelper::handleEventBufferReception: Failed while trying to read packet"
|
|
<< " " << packetsRead + 1 << std::endl;
|
|
file.close();
|
|
return result;
|
|
}
|
|
ReturnValue_t result = tmReader.checkCrc();
|
|
if (result != RETURN_OK) {
|
|
triggerEvent(SUPV_REPLY_CRC_MISSMATCH, rememberApid);
|
|
return result;
|
|
}
|
|
uint16_t apid = tmReader.getApid();
|
|
if (apid != supv::APID_MRAM_DUMP_TM) {
|
|
sif::warning << "PlocSupvHelper::handleEventBufferReception: Did not expect space packet "
|
|
<< "with APID 0x" << std::hex << apid << std::endl;
|
|
file.close();
|
|
return EVENT_BUFFER_REPLY_INVALID_APID;
|
|
}
|
|
file.write(reinterpret_cast<const char*>(tmReader.getPacketData()),
|
|
tmReader.getPayloadDataLength());
|
|
}
|
|
return result;
|
|
}
|
|
|
|
void PlocSupvHelper::resetSpParams() { spParams.buf = commandBuffer; }
|