socket_rpc_server.h

#ifndef SOCKET_RPC_SERVER_H
#define SOCKET_RPC_SERVER_H
 
#include <asyncbsdsocket/poller.h>
#include "../../helper/concurrent_queue.h"
#include "./rpc_server.h"
 
namespace ara
{
    namespace com
    {
        namespace someip
        {
            namespace rpc
            {
                class SocketRpcServer : public RpcServer
                {
                private:
                    static const size_t cBufferSize{256};
 
                    helper::ConcurrentQueue<std::vector<uint8_t>> mSendingQueue;
                    AsyncBsdSocketLib::Poller *const mPoller;
                    AsyncBsdSocketLib::TcpListener mServer;
 
                    void onAccept();
                    void onReceive();
                    void onSend();
 
                public:
                    SocketRpcServer(
                        AsyncBsdSocketLib::Poller *poller,
                        std::string ipAddress,
                        uint16_t port,
                        uint8_t protocolVersion,
                        uint8_t interfaceVersion = 1);
 
                    virtual ~SocketRpcServer() override;
                };
            }
        }
    }
}
 
#endif