transport.hpp

#pragma once

#include "dangerous/snmp/context.hpp"

#include <chrono>
#include <memory>
#include <stdexcept>
#include <string>
#include <vector>

namespace dangerous { namespace snmp {

class ByteStream;


class Transport {
protected:
    Transport( std::weak_ptr<Context::PrivateData> context );
    
public:
    virtual ~Transport();

    unsigned int maximumIncomingMessageSize() { return _maximumIncomingMessageSize; }
    unsigned int maximumOutgoingMessageSize() { return _maximumOutgoingMessageSize; }

    virtual bool isConnected();

    virtual void connect();

    virtual void disconnect();

    std::shared_ptr<ByteStream> readerStream;

    std::shared_ptr<ByteStream> writerStream;
    void commitWrite();

protected:
    unsigned int _maximumIncomingMessageSize;
    unsigned int _maximumOutgoingMessageSize;

    std::weak_ptr<Context::PrivateData> context;

    void registerReadWriteStreams( int readHandle, int writeHandle );
    void unregisterReadWriteStreams( int readHandle, int writeHandle );
};

} }