someip_pubsub_client.h

#ifndef SOMEIP_PUBSUB_CLIENT
#define SOMEIP_PUBSUB_CLIENT
 
#include <condition_variable>
#include "../../entry/eventgroup_entry.h"
#include "../../helper/network_layer.h"
#include "../../helper/concurrent_queue.h"
#include "../sd/someip_sd_message.h"
 
namespace ara
{
    namespace com
    {
        namespace someip
        {
            namespace pubsub
            {
                class SomeIpPubSubClient
                {
                private:
                    helper::ConcurrentQueue<sd::SomeIpSdMessage> mMessageBuffer;
                    std::mutex mSubscriptionMutex;
                    std::unique_lock<std::mutex> mSubscriptionLock;
                    std::condition_variable mSubscriptionConditionVariable;
                    helper::NetworkLayer<sd::SomeIpSdMessage> *mCommunicationLayer;
                    uint8_t mCounter;
                    bool mValidNotify;
 
                    void onMessageReceived(sd::SomeIpSdMessage &&message);
 
                public:
                    SomeIpPubSubClient() = delete;
                    ~SomeIpPubSubClient();
 
                    SomeIpPubSubClient(
                        helper::NetworkLayer<sd::SomeIpSdMessage> *networkLayer,
                        uint8_t counter);
 
                    void Subscribe(
                        uint16_t serviceId,
                        uint16_t instanceId,
                        uint8_t majorVersion,
                        uint16_t eventgroupId);
 
                    void Unsubscribe(
                        uint16_t serviceId,
                        uint16_t instanceId,
                        uint8_t majorVersion,
                        uint16_t eventgroupId);
 
                    bool TryGetProcessedSubscription(
                        int duration,
                        sd::SomeIpSdMessage &message);
                };
            }
        }
    }
}
 
#endif