PacketReaders.h

Go to the documentation of this file.

 
#pragma once
#include "ConnectionContainer.h"
#include "ConnectionSettings.h"
#include "PeerConnectResult.h"
#include "catapult/ionet/PacketHandlers.h"
#include <functional>
#include <memory>
 
namespace catapult {
    namespace crypto { class KeyPair; }
    namespace ionet {
        class AcceptedPacketSocketInfo;
        class PacketIo;
        class PacketSocket;
    }
    namespace thread { class IoThreadPool; }
}
 
namespace catapult { namespace net {
 
    class PacketReaders : public ConnectionContainer {
    public:
        using AcceptCallback = consumer<const PeerConnectResult&>;
 
    public:
        virtual size_t numActiveReaders() const = 0;
 
    public:
        virtual void accept(const ionet::AcceptedPacketSocketInfo& socketInfo, const AcceptCallback& callback) = 0;
 
        virtual void shutdown() = 0;
    };
 
    std::shared_ptr<PacketReaders> CreatePacketReaders(
            const std::shared_ptr<thread::IoThreadPool>& pPool,
            const ionet::ServerPacketHandlers& handlers,
            const crypto::KeyPair& keyPair,
            const ConnectionSettings& settings,
            uint32_t maxConnectionsPerIdentity);
}}