fsfw/tcdistribution/CFDPDistributor.h

#ifndef FSFW_TCDISTRIBUTION_CFDPDISTRIBUTOR_H_
#define FSFW_TCDISTRIBUTION_CFDPDISTRIBUTOR_H_

#include "CFDPDistributorIF.h"
#include "TcDistributor.h"
#include "TcPacketCheck.h"

#include "../tmtcpacket/pus/tc.h"
#include "../returnvalues/HasReturnvaluesIF.h"
#include "../tmtcservices/AcceptsTelecommandsIF.h"
#include "../tmtcservices/VerificationReporter.h"

/**
 * This class accepts CFDP Telecommands and forwards them to Application
 * services.
 * @ingroup tc_distribution
 */
class CFDPDistributor:
        public TcDistributor,
        public CFDPDistributorIF,
        public AcceptsTelecommandsIF {
public:
    /**
     * The ctor passes @c set_apid to the checker class and calls the
     * TcDistribution ctor with a certain object id.
     * @param setApid The APID of this receiving Application.
     * @param setObjectId Object ID of the distributor itself
     * @param setPacketSource Object ID of the source of TC packets.
     * Must implement CCSDSDistributorIF.
     */
    CFDPDistributor(uint16_t setApid, object_id_t setObjectId,
            object_id_t setPacketSource);
    /**
     * The destructor is empty.
     */
    virtual ~CFDPDistributor();
    ReturnValue_t registerService(AcceptsTelecommandsIF* service) override;
    MessageQueueId_t getRequestQueue() override;
    ReturnValue_t initialize() override;
    uint16_t getIdentifier() override;

protected:
    /**
     * This attribute contains the class, that performs a formal packet check.
     */
    TcPacketCheck checker;
    /**
     * With this class, verification messages are sent to the
     * TC Verification service.
     */
    VerificationReporter verifyChannel;
    /**
     * The currently handled packet is stored here.
     */
    TcPacketStoredPus* currentPacket = nullptr;
    /**
     * With this variable, the current check status is stored to generate
     * acceptance messages later.
     */
    ReturnValue_t tcStatus;

    const object_id_t packetSource;

    /**
     * This method reads the packet service, checks if such a service is
     * registered and forwards the packet to the destination.
     * It also initiates the formal packet check and sending of verification
     * messages.
     * @return Iterator to map entry of found service id
     * or iterator to @c map.end().
     */
    TcMqMapIter selectDestination() override;
    /**
     * The callback here handles the generation of acceptance
     * success/failure messages.
     */
    ReturnValue_t callbackAfterSending(ReturnValue_t queueStatus) override;
};

#endif /* FSFW_TCDISTRIBUTION_CFDPDISTRIBUTOR_H_ */