Robin Mueller
9e719d455a
All checks were successful
EIVE/eive-obsw/pipeline/head This commit looks good
103 lines
3.4 KiB
C++
103 lines
3.4 KiB
C++
#include "ArcsecDatalinkLayer.h"
|
|
|
|
ArcsecDatalinkLayer::ArcsecDatalinkLayer() : decodeRingBuf(4096, true) { slipInit(); }
|
|
|
|
ArcsecDatalinkLayer::~ArcsecDatalinkLayer() {}
|
|
|
|
ReturnValue_t ArcsecDatalinkLayer::checkRingBufForFrame(const uint8_t** decodedFrame,
|
|
size_t& frameLen) {
|
|
size_t currentLen = decodeRingBuf.getAvailableReadData();
|
|
decodeRingBuf.readData(decodedRxFrame, currentLen);
|
|
for (size_t idx = 0; idx < currentLen; idx++) {
|
|
enum arc_dec_result decResult =
|
|
arc_transport_decode_body(decodedRxFrame[idx], &slipInfo, decodedRxFrame, &rxFrameSize);
|
|
switch (decResult) {
|
|
case ARC_DEC_INPROGRESS: {
|
|
break;
|
|
}
|
|
case ARC_DEC_ERROR_FRAME_SHORT: {
|
|
decodeRingBuf.deleteData(idx);
|
|
return REPLY_TOO_SHORT;
|
|
}
|
|
case ARC_DEC_ERROR_CHECKSUM:
|
|
decodeRingBuf.deleteData(idx);
|
|
return CRC_FAILURE;
|
|
case ARC_DEC_ASYNC:
|
|
case ARC_DEC_SYNC: {
|
|
// Reset length of SLIP struct for next frame
|
|
slipInfo.length = 0;
|
|
if (decodedFrame != nullptr) {
|
|
*decodedFrame = decodedRxFrame;
|
|
}
|
|
frameLen = rxFrameSize;
|
|
decodeRingBuf.deleteData(idx);
|
|
return returnvalue::OK;
|
|
}
|
|
default:
|
|
sif::debug << "ArcsecDatalinkLayer::decodeFrame: Unknown result code" << std::endl;
|
|
break;
|
|
return returnvalue::FAILED;
|
|
}
|
|
}
|
|
decodeRingBuf.deleteData(currentLen);
|
|
return DEC_IN_PROGRESS;
|
|
}
|
|
|
|
ReturnValue_t ArcsecDatalinkLayer::feedData(const uint8_t* rawData, size_t rawDataLen) {
|
|
if (rawDataLen > 4096) {
|
|
sif::error << "ArcsecDatalinklayer: Can not write more than 4096 bytes to ring buffer"
|
|
<< std::endl;
|
|
return returnvalue::FAILED;
|
|
}
|
|
return decodeRingBuf.writeData(rawData, rawDataLen);
|
|
}
|
|
|
|
void ArcsecDatalinkLayer::slipInit() {
|
|
slipInfo.buffer = rxBuffer;
|
|
slipInfo.maxlength = startracker::MAX_FRAME_SIZE;
|
|
slipInfo.length = 0;
|
|
slipInfo.unescape_next = 0;
|
|
slipInfo.prev_state = SLIP_COMPLETE;
|
|
}
|
|
|
|
// ReturnValue_t ArcsecDatalinkLayer::decodeFrame(const uint8_t* rawData, size_t rawDataSize,
|
|
// size_t* bytesLeft) {
|
|
// size_t bytePos = 0;
|
|
// for (bytePos = 0; bytePos < rawDataSize; bytePos++) {
|
|
// enum arc_dec_result decResult =
|
|
// arc_transport_decode_body(*(rawData + bytePos), &slipInfo, decodedRxFrame, &rxFrameSize);
|
|
// *bytesLeft = rawDataSize - bytePos - 1;
|
|
// switch (decResult) {
|
|
// case ARC_DEC_INPROGRESS: {
|
|
// if (bytePos == rawDataSize - 1) {
|
|
// return DEC_IN_PROGRESS;
|
|
// }
|
|
// continue;
|
|
// }
|
|
// case ARC_DEC_ERROR_FRAME_SHORT:
|
|
// return REPLY_TOO_SHORT;
|
|
// case ARC_DEC_ERROR_CHECKSUM:
|
|
// return CRC_FAILURE;
|
|
// case ARC_DEC_ASYNC:
|
|
// case ARC_DEC_SYNC: {
|
|
// // Reset length of SLIP struct for next frame
|
|
// slipInfo.length = 0;
|
|
// return returnvalue::OK;
|
|
// }
|
|
// default:
|
|
// sif::debug << "ArcsecDatalinkLayer::decodeFrame: Unknown result code" << std::endl;
|
|
// break;
|
|
// return returnvalue::FAILED;
|
|
// }
|
|
// }
|
|
// return returnvalue::FAILED;
|
|
// }
|
|
|
|
void ArcsecDatalinkLayer::encodeFrame(const uint8_t* data, size_t length, const uint8_t** txFrame,
|
|
size_t& size) {
|
|
arc_transport_encode_body(data, length, txEncoded, &size);
|
|
if (txFrame != nullptr) {
|
|
*txFrame = txEncoded;
|
|
}
|
|
}
|