socket_selector.hpp

Go to the documentation of this file.

// Copyright (c) 2021 MIT Digital Currency Initiative,
//                    Federal Reserve Bank of Boston
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef OPENCBDC_TX_SRC_NETWORK_SOCKET_SELECTOR_H_
#define OPENCBDC_TX_SRC_NETWORK_SOCKET_SELECTOR_H_
 
#include "socket.hpp"
 
#include <array>
 
namespace cbdc::network {
    class socket_selector {
      public:
        socket_selector() = default;
        ~socket_selector();
        socket_selector(const socket_selector&) = delete;
        auto operator=(const socket_selector&) -> socket_selector& = delete;
        socket_selector(socket_selector&&) = delete;
        auto operator=(socket_selector&&) -> socket_selector& = delete;
 
        auto init() -> bool;
 
        auto add(const socket& sock) -> bool;
 
        auto wait() -> bool;
 
        void unblock();
 
      private:
        fd_set m_fds{};
        fd_set m_ready_fds{};
        int m_fd_max{-1};
        std::array<int, 2> m_unblock_fds{-1, -1};
 
        auto add(int fd) -> bool;
    };
}
 
#endif