PacketWriters.h

Go to the documentation of this file.

 
#pragma once
#include "ConnectionContainer.h"
#include "ConnectionSettings.h"
#include "PacketIoPicker.h"
#include "PeerConnectResult.h"
#include <memory>
 
namespace catapult {
    namespace crypto { class KeyPair; }
    namespace ionet {
        class Node;
        class PacketSocket;
    }
    namespace net { struct Packet; }
    namespace thread { class IoThreadPool; }
}
 
namespace catapult { namespace net {
 
    class PacketWriters : public ConnectionContainer, public PacketIoPicker {
    public:
        using ConnectCallback = consumer<const PeerConnectResult&>;
 
    public:
        virtual size_t numActiveWriters() const = 0;
 
        virtual size_t numAvailableWriters() const = 0;
 
    public:
        virtual void broadcast(const ionet::PacketPayload& payload) = 0;
 
    public:
        virtual void connect(const ionet::Node& node, const ConnectCallback& callback) = 0;
 
        virtual void accept(const std::shared_ptr<ionet::PacketSocket>& pAcceptedSocket, const ConnectCallback& callback) = 0;
 
        virtual void shutdown() = 0;
    };
 
    std::shared_ptr<PacketWriters> CreatePacketWriters(
            const std::shared_ptr<thread::IoThreadPool>& pPool,
            const crypto::KeyPair& keyPair,
            const ConnectionSettings& settings);
}}