TunnelSession Struct Reference

Inheritance diagram for TunnelSession:

Public Member Functions
	TunnelSession (tcp::socket c, tcp::socket r)
void	start ()

Public Attributes
tcp::socket	client_
tcp::socket	remote_
std::array< char, 64 *1024 >	cbuf_ {}
std::array< char, 64 *1024 >	rbuf_ {}

Private Member Functions
void	pump_c2r ()
void	pump_r2c ()
void	shutdown ()

Private Attributes
std::atomic< bool >	closed_ {false}

Detailed Description

Definition at line 185 of file bastionguard_cef.cpp.

Constructor & Destructor Documentation

TunnelSession()

TunnelSession::TunnelSession ( tcp::socket c, tcp::socket r )

inline

Definition at line 191 of file bastionguard_cef.cpp.

        : client_(std::move(c)), remote_(std::move(r)) {}

References client_, and remote_.

Member Function Documentation

pump_c2r()

void TunnelSession::pump_c2r ( )

inlineprivate

Definition at line 197 of file bastionguard_cef.cpp.

                    {
        auto self = shared_from_this();
        client_.async_read_some(asio::buffer(cbuf_),
            [this, self](boost::system::error_code ec, std::size_t n) {
                if (ec || n == 0) { shutdown(); return; }
                asio::async_write(remote_, asio::buffer(cbuf_.data(), n),
                    [this, self](boost::system::error_code wec, std::size_t) {
                        if (wec) { shutdown(); return; }
                        pump_c2r();
                    });
            });
    }

References cbuf_, client_, pump_c2r(), remote_, and shutdown().

Referenced by pump_c2r(), and start().

pump_r2c()

void TunnelSession::pump_r2c ( )

inlineprivate

Definition at line 210 of file bastionguard_cef.cpp.

                    {
        auto self = shared_from_this();
        remote_.async_read_some(asio::buffer(rbuf_),
            [this, self](boost::system::error_code ec, std::size_t n) {
                if (ec || n == 0) { shutdown(); return; }
                asio::async_write(client_, asio::buffer(rbuf_.data(), n),
                    [this, self](boost::system::error_code wec, std::size_t) {
                        if (wec) { shutdown(); return; }
                        pump_r2c();
                    });
            });
    }

References client_, pump_r2c(), rbuf_, remote_, and shutdown().

Referenced by pump_r2c(), and start().

shutdown()

void TunnelSession::shutdown ( )

inlineprivate

Definition at line 223 of file bastionguard_cef.cpp.

                    {
        if (closed_.exchange(true)) return;
        boost::system::error_code ignore;
        client_.close(ignore);
        remote_.close(ignore);
    }

References client_, closed_, and remote_.

Referenced by pump_c2r(), and pump_r2c().

start()

void TunnelSession::start ( )

inline

Definition at line 194 of file bastionguard_cef.cpp.

{ pump_c2r(); pump_r2c(); }

References pump_c2r(), and pump_r2c().

Member Data Documentation

cbuf_

std::array<char, 64 * 1024> TunnelSession::cbuf_ {}

Definition at line 188 of file bastionguard_cef.cpp.

Referenced by pump_c2r().

client_

tcp::socket TunnelSession::client_

Definition at line 186 of file bastionguard_cef.cpp.

Referenced by pump_c2r(), pump_r2c(), shutdown(), and TunnelSession().

closed_

std::atomic<bool> TunnelSession::closed_ {false}

private

Definition at line 230 of file bastionguard_cef.cpp.

Referenced by shutdown().

rbuf_

std::array<char, 64 * 1024> TunnelSession::rbuf_ {}

Definition at line 189 of file bastionguard_cef.cpp.

Referenced by pump_r2c().

remote_

tcp::socket TunnelSession::remote_

Definition at line 187 of file bastionguard_cef.cpp.

Referenced by pump_c2r(), pump_r2c(), shutdown(), and TunnelSession().

---

The documentation for this struct was generated from the following file:

• BastionGuard/src/cef/bastionguard_cef.cpp