WIP: somethings wrong.. #19
@ -15,8 +15,8 @@ TmTcBridge::TmTcBridge(object_id_t objectId_,
|
|||||||
object_id_t ccsdsPacketDistributor_): SystemObject(objectId_),
|
object_id_t ccsdsPacketDistributor_): SystemObject(objectId_),
|
||||||
ccsdsPacketDistributor(ccsdsPacketDistributor_)
|
ccsdsPacketDistributor(ccsdsPacketDistributor_)
|
||||||
{
|
{
|
||||||
TmTcReceptionQueue = QueueFactory::instance()->
|
TmTcReceptionQueue = QueueFactory::instance()->
|
||||||
createMessageQueue(TMTC_RECEPTION_QUEUE_DEPTH);
|
createMessageQueue(TMTC_RECEPTION_QUEUE_DEPTH);
|
||||||
}
|
}
|
||||||
|
|
||||||
TmTcBridge::~TmTcBridge() {}
|
TmTcBridge::~TmTcBridge() {}
|
||||||
@ -73,8 +73,8 @@ ReturnValue_t TmTcBridge::handleTm() {
|
|||||||
|
|
||||||
ReturnValue_t TmTcBridge::readTmQueue() {
|
ReturnValue_t TmTcBridge::readTmQueue() {
|
||||||
TmTcMessage message;
|
TmTcMessage message;
|
||||||
const uint8_t* data = nullptr;
|
const uint8_t* data = nullptr;
|
||||||
size_t size = 0;
|
size_t size = 0;
|
||||||
for (ReturnValue_t result = TmTcReceptionQueue->receiveMessage(&message);
|
for (ReturnValue_t result = TmTcReceptionQueue->receiveMessage(&message);
|
||||||
result == RETURN_OK; result = TmTcReceptionQueue->receiveMessage(&message))
|
result == RETURN_OK; result = TmTcReceptionQueue->receiveMessage(&message))
|
||||||
{
|
{
|
||||||
@ -124,8 +124,8 @@ ReturnValue_t TmTcBridge::sendStoredTm() {
|
|||||||
info << "TMTC Bridge: Sending stored TM data. There are "
|
info << "TMTC Bridge: Sending stored TM data. There are "
|
||||||
<< (int) fifo.size() << " left to send\r\n" << std::flush;
|
<< (int) fifo.size() << " left to send\r\n" << std::flush;
|
||||||
store_address_t storeId;
|
store_address_t storeId;
|
||||||
const uint8_t* data = NULL;
|
const uint8_t* data = NULL;
|
||||||
size_t size = 0;
|
size_t size = 0;
|
||||||
fifo.retrieve(&storeId);
|
fifo.retrieve(&storeId);
|
||||||
result = tmStore->getData(storeId, &data, &size);
|
result = tmStore->getData(storeId, &data, &size);
|
||||||
sendTm(data,size);
|
sendTm(data,size);
|
||||||
|
Loading…
Reference in New Issue
Block a user