someip_sd_server.h

#ifndef SOMEIP_SD_SERVER
#define SOMEIP_SD_SERVER
 
#include "../../helper/concurrent_queue.h"
#include "../../helper/ipv4_address.h"
#include "../../entry/service_entry.h"
#include "../../option/ipv4_endpoint_option.h"
#include "./fsm/notready_state.h"
#include "./fsm/initial_wait_state.h"
#include "./fsm/repetition_state.h"
#include "./fsm/main_state.h"
#include "./someip_sd_agent.h"
 
namespace ara
{
    namespace com
    {
        namespace someip
        {
            namespace sd
            {
                class SomeIpSdServer : public SomeIpSdAgent<helper::SdServerState>
                {
                private:
                    helper::ConcurrentQueue<SomeIpSdMessage> mMessageBuffer;
                    SomeIpSdMessage mOfferServiceMessage;
                    SomeIpSdMessage mStopOfferMessage;
                    fsm::NotReadyState mNotReadyState;
                    fsm::InitialWaitState<helper::SdServerState> mInitialWaitState;
                    fsm::RepetitionState<helper::SdServerState> mRepetitionState;
                    fsm::MainState mMainState;
                    const uint16_t mServiceId;
                    const uint16_t mInstanceId;
                    const uint8_t mMajorVersion;
                    const uint32_t mMinorVersion;
 
                    void sendOffer();
                    bool matchOfferingService(const SomeIpSdMessage &message) const;
                    void receiveFind(SomeIpSdMessage &&message);
                    void onServiceStopped();
 
                protected:
                    void StartAgent(helper::SdServerState state) override;
                    void StopAgent() override;
 
                public:
                    SomeIpSdServer() = delete;
 
                    SomeIpSdServer(
                        helper::NetworkLayer<SomeIpSdMessage> *networkLayer,
                        uint16_t serviceId,
                        uint16_t instanceId,
                        uint8_t majorVersion,
                        uint32_t minorVersion,
                        helper::Ipv4Address ipAddress,
                        uint16_t port,
                        int initialDelayMin,
                        int initialDelayMax,
                        int repetitionBaseDelay = 30,
                        int cycleOfferDelay = 1000,
                        uint32_t repetitionMax = 3);
 
                    ~SomeIpSdServer() override;
                };
            }
        }
    }
}
 
#endif