95 lines
3.0 KiB
C++
95 lines
3.0 KiB
C++
#include <framework/serviceinterface/ServiceInterfaceStream.h>
|
|
#include <framework/tcdistribution/CCSDSDistributorIF.h>
|
|
#include <framework/tcdistribution/PUSDistributor.h>
|
|
#include <framework/tmtcpacket/pus/TcPacketStored.h>
|
|
#include <framework/tmtcservices/PusVerificationReport.h>
|
|
|
|
PUSDistributor::PUSDistributor(uint16_t setApid, object_id_t setObjectId, object_id_t setPacketSource) :
|
|
TcDistributor(setObjectId), checker(setApid), verifyChannel(), currentPacket(), tcStatus(
|
|
RETURN_FAILED), packetSource(setPacketSource) {
|
|
|
|
}
|
|
|
|
PUSDistributor::~PUSDistributor() {
|
|
|
|
}
|
|
|
|
iterator_t PUSDistributor::selectDestination() {
|
|
sif::debug << "PUSDistributor::handlePacket received "<<std::endl;// << this->currentPacket.store_index << ", " << this->current_packet_id.packet_index << std::endl;
|
|
iterator_t queueMapIt = this->queueMap.end();
|
|
this->currentPacket.setStoreAddress(this->currentMessage.getStorageId());
|
|
if (currentPacket.getWholeData() != NULL) {
|
|
tcStatus = checker.checkPacket(¤tPacket);
|
|
// info << "PUSDistributor::handlePacket: packetCheck returned with " << (int)tc_status << std::endl;
|
|
uint32_t queue_id = currentPacket.getService();
|
|
queueMapIt = this->queueMap.find(queue_id);
|
|
} else {
|
|
tcStatus = PACKET_LOST;
|
|
}
|
|
if (queueMapIt == this->queueMap.end()) {
|
|
tcStatus = DESTINATION_NOT_FOUND;
|
|
}
|
|
|
|
if (tcStatus != RETURN_OK) {
|
|
sif::debug << "PUSDistributor::handlePacket: error with " << (int) tcStatus
|
|
<< std::endl;
|
|
return this->queueMap.end();
|
|
} else {
|
|
return queueMapIt;
|
|
}
|
|
|
|
}
|
|
|
|
//uint16_t PUSDistributor::createDestination( uint8_t service_id, uint8_t subservice_id ) {
|
|
// return ( service_id << 8 ) + subservice_id;
|
|
//}
|
|
|
|
ReturnValue_t PUSDistributor::registerService(AcceptsTelecommandsIF* service) {
|
|
ReturnValue_t returnValue = RETURN_OK;
|
|
bool errorCode = true;
|
|
uint16_t serviceId = service->getIdentifier();
|
|
MessageQueueId_t queue = service->getRequestQueue();
|
|
errorCode = this->queueMap.insert(
|
|
std::pair<uint32_t, MessageQueueId_t>(serviceId, queue)).second;
|
|
if (errorCode == false) {
|
|
//TODO Return Code
|
|
returnValue = MessageQueueIF::NO_QUEUE;
|
|
}
|
|
return returnValue;
|
|
}
|
|
|
|
MessageQueueId_t PUSDistributor::getRequestQueue() {
|
|
return tcQueue->getId();
|
|
}
|
|
|
|
ReturnValue_t PUSDistributor::callbackAfterSending(ReturnValue_t queueStatus) {
|
|
if (queueStatus != RETURN_OK) {
|
|
tcStatus = queueStatus;
|
|
}
|
|
if (tcStatus != RETURN_OK) {
|
|
this->verifyChannel.sendFailureReport(TC_VERIFY::ACCEPTANCE_FAILURE,
|
|
¤tPacket, tcStatus);
|
|
//A failed packet is deleted immediately after reporting, otherwise it will block memory.
|
|
currentPacket.deletePacket();
|
|
return RETURN_FAILED;
|
|
} else {
|
|
this->verifyChannel.sendSuccessReport(TC_VERIFY::ACCEPTANCE_SUCCESS,
|
|
¤tPacket);
|
|
return RETURN_OK;
|
|
}
|
|
}
|
|
|
|
uint16_t PUSDistributor::getIdentifier() {
|
|
return checker.getApid();
|
|
}
|
|
|
|
ReturnValue_t PUSDistributor::initialize() {
|
|
CCSDSDistributorIF* ccsdsDistributor =
|
|
objectManager->get<CCSDSDistributorIF>(packetSource);
|
|
if (ccsdsDistributor == NULL) {
|
|
return RETURN_FAILED;
|
|
} else {
|
|
return ccsdsDistributor->registerApplication(this);
|
|
}
|
|
}
|