Transport.h

Go to the documentation of this file.

/*************************************************************************
 * odil - Copyright (C) Universite de Strasbourg
 * Distributed under the terms of the CeCILL-B license, as published by
 * the CEA-CNRS-INRIA. Refer to the LICENSE file or to
 * http://www.cecill.info/licences/Licence_CeCILL-B_V1-en.html
 * for details.
 ************************************************************************/
 
#ifndef _1619bae8_acba_4bf8_8205_aa8dd0085c66
#define _1619bae8_acba_4bf8_8205_aa8dd0085c66
 
#include <memory>
#include <string>
 
#include <boost/asio.hpp>
#include <boost/date_time.hpp>
 
// NOTE: the io_service type alias has been removed in boost 1.87.0
#if BOOST_VERSION >= 108700
namespace boost
{
namespace asio
{
using io_service = io_context;
}
}
#endif
 
#include "odil/odil.h"
 
namespace odil
{
 
namespace dul
{
 
struct ODIL_API Transport
{
    typedef boost::asio::ip::tcp::socket Socket;
 
    typedef boost::asio::deadline_timer::duration_type duration_type;
 
    Transport();
 
    ~Transport();
 
    boost::asio::io_service const & get_service() const;
 
    boost::asio::io_service & get_service();
 
    std::shared_ptr<Socket const> get_socket() const;
 
    std::shared_ptr<Socket> get_socket();
 
    duration_type get_timeout() const;
 
    void set_timeout(duration_type timeout);
 
    bool is_open() const;
 
    void connect(Socket::endpoint_type const & peer_endpoint);
 
    void receive(Socket::endpoint_type const & endpoint);
 
    void close();
 
    std::string read(std::size_t length);
 
    void write(std::string const & data);
 
private:
    boost::asio::io_service _service;
    std::shared_ptr<Socket> _socket;
    duration_type _timeout;
    boost::asio::deadline_timer _deadline;
 
    std::shared_ptr<boost::asio::ip::tcp::acceptor> _acceptor;
 
    enum class Source
    {
        NONE,
        TIMER,
        OPERATION,
    };
 
    void _start_deadline(Source & source, boost::system::error_code & error);
    void _stop_deadline();
 
    void _run(Source & source, boost::system::error_code & error);
};
 
}
 
}
 
#endif // _1619bae8_acba_4bf8_8205_aa8dd0085c66