ServerNetwork.hpp

Go to the documentation of this file.

 
#ifndef RTYPE_SERVER_NETWORK_HPP_
    #define RTYPE_SERVER_NETWORK_HPP_
 
    #include "RType/Network/INetwork.hpp"
    #include "RType/Network/Session.hpp"
    #include "RType/Network/Packet.hpp"
    #include "RType/Network/IEventPublisher.hpp"
    #include "RType/Logger.hpp"
 
    #include <asio.hpp>
    #include <memory>
    #include <unordered_map>
    #include <thread>
    #include <mutex>
    #include <queue>
    #include <optional>
 
namespace rtp::server {
 
    class ServerNetwork : public net::INetwork, public net::IEventPublisher {
        public:
            ServerNetwork(uint16_t port);
 
            ~ServerNetwork() override;
 
            void start(void) override;
 
            void stop(void) override;
 
            void sendPacket(uint32_t sessionId, const net::Packet &packet, net::NetworkMode mode);
 
            void broadcastPacket(const net::Packet &packet, net::NetworkMode mode);
 
            std::optional<net::NetworkEvent> pollEvent(void) override;
 
            void publishEvent(net::NetworkEvent event) override;
 
        private:
            void acceptConnection();
 
            void receiveUdpPacket();
 
        private:
            asio::io_context _ioContext;                       
            asio::ip::tcp::acceptor _acceptor;                 
            asio::ip::udp::socket _udpSocket;                  
            std::thread _ioThread;                             
            std::unordered_map<uint32_t, 
                std::shared_ptr<net::Session>> _sessions; 
            std::mutex _sessionsMutex;                         
            std::queue<net::NetworkEvent> _eventQueue;    
            std::mutex _eventQueueMutex;                       
            uint32_t _nextSessionId;                           
            std::unordered_map<asio::ip::udp::endpoint,
                uint32_t> _udpEndpointToSessionId;             
            std::mutex _udpMapMutex;                           
            std::array<char, 4096> _udpBuffer;                 
            asio::ip::udp::endpoint _udpRemoteEndpoint;        
    };
} 
 
#endif /* !RTYPE_SERVER_NETWORK_HPP_ */