AsyncTcpServer.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/ionet/PacketSocket.h"
 
namespace catapult { namespace thread { class IoThreadPool; } }
 
namespace catapult { namespace net {
 
    using AcceptHandler = consumer<const ionet::AcceptedPacketSocketInfo&>;
 
    using ConfigureSocketHandler = consumer<ionet::socket&>;
 
    struct AsyncTcpServerSettings {
    public:
        explicit AsyncTcpServerSettings(const AcceptHandler& accept);
 
    public:
        const AcceptHandler Accept;
 
        // The configure socket handler.
        ConfigureSocketHandler ConfigureSocket;
 
        ionet::PacketSocketOptions PacketSocketOptions;
 
        // The maximum number of pending connections (backlog size).
        uint16_t MaxPendingConnections = 100;
 
        // The maximum number of active connections.
        uint32_t MaxActiveConnections = 25;
 
        bool AllowAddressReuse = false;
    };
 
    class AsyncTcpServer {
    public:
        virtual ~AsyncTcpServer() = default;
 
    public:
        virtual uint32_t numPendingAccepts() const = 0;
 
        virtual uint32_t numCurrentConnections() const = 0;
 
        virtual uint32_t numLifetimeConnections() const = 0;
 
    public:
        virtual void shutdown() = 0;
    };
 
    std::shared_ptr<AsyncTcpServer> CreateAsyncTcpServer(
            const std::shared_ptr<thread::IoThreadPool>& pPool,
            const boost::asio::ip::tcp::endpoint& endpoint,
            const AsyncTcpServerSettings& settings);
}}