socket_rpc_client.h

#ifndef SOCKET_RPC_CLIENT_H
#define SOCKET_RPC_CLIENT_H
 
#include <asyncbsdsocket/poller.h>
#include <asyncbsdsocket/tcp_client.h>
#include "../../helper/concurrent_queue.h"
#include "./rpc_client.h"
 
namespace ara
{
    namespace com
    {
        namespace someip
        {
            namespace rpc
            {
                class SocketRpcClient : public RpcClient
                {
                private:
                    static const size_t cBufferSize{256};
 
                    helper::ConcurrentQueue<std::vector<uint8_t>> mSendingQueue;
                    AsyncBsdSocketLib::Poller *const mPoller;
                    AsyncBsdSocketLib::TcpClient mClient;
 
                    void onSend();
                    void onReceive();
 
                protected:
                    void Send(const std::vector<uint8_t> &payload) override;
 
                public:
                    SocketRpcClient(
                        AsyncBsdSocketLib::Poller *poller,
                        std::string ipAddress,
                        uint16_t port,
                        uint8_t protocolVersion,
                        uint8_t interfaceVersion = 1);
 
                    virtual ~SocketRpcClient() override;
                };
            }
        }
    }
}
 
#endif