TLA  Line data    Source code

       1                 : //
       2                 : // Copyright (c) 2026 Steve Gerbino
       3                 : //
       4                 : // Distributed under the Boost Software License, Version 1.0. (See accompanying
       5                 : // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
       6                 : //
       7                 : // Official repository: https://github.com/cppalliance/corosio
       8                 : //
       9                 : 
      10                 : #ifndef BOOST_COROSIO_NATIVE_DETAIL_EPOLL_EPOLL_ACCEPTOR_HPP
      11                 : #define BOOST_COROSIO_NATIVE_DETAIL_EPOLL_EPOLL_ACCEPTOR_HPP
      12                 : 
      13                 : #include <boost/corosio/detail/platform.hpp>
      14                 : 
      15                 : #if BOOST_COROSIO_HAS_EPOLL
      16                 : 
      17                 : #include <boost/corosio/tcp_acceptor.hpp>
      18                 : #include <boost/capy/ex/executor_ref.hpp>
      19                 : #include <boost/corosio/detail/intrusive.hpp>
      20                 : 
      21                 : #include <boost/corosio/native/detail/epoll/epoll_op.hpp>
      22                 : 
      23                 : #include <memory>
      24                 : 
      25                 : namespace boost::corosio::detail {
      26                 : 
      27                 : class epoll_acceptor_service;
      28                 : 
      29                 : /// Acceptor implementation for epoll backend.
      30                 : class epoll_acceptor final
      31                 :     : public tcp_acceptor::implementation
      32                 :     , public std::enable_shared_from_this<epoll_acceptor>
      33                 :     , public intrusive_list<epoll_acceptor>::node
      34                 : {
      35                 :     friend class epoll_acceptor_service;
      36                 : 
      37                 : public:
      38                 :     explicit epoll_acceptor(epoll_acceptor_service& svc) noexcept;
      39                 : 
      40                 :     std::coroutine_handle<> accept(
      41                 :         std::coroutine_handle<>,
      42                 :         capy::executor_ref,
      43                 :         std::stop_token,
      44                 :         std::error_code*,
      45                 :         io_object::implementation**) override;
      46                 : 
      47                 :     int native_handle() const noexcept
      48                 :     {
      49                 :         return fd_;
      50                 :     }
      51 HIT        4781 :     endpoint local_endpoint() const noexcept override
      52                 :     {
      53            4781 :         return local_endpoint_;
      54                 :     }
      55            4990 :     bool is_open() const noexcept override
      56                 :     {
      57            4990 :         return fd_ >= 0;
      58                 :     }
      59                 :     void cancel() noexcept override;
      60                 :     void cancel_single_op(epoll_op& op) noexcept;
      61                 :     void close_socket() noexcept;
      62              64 :     void set_local_endpoint(endpoint ep) noexcept
      63                 :     {
      64              64 :         local_endpoint_ = ep;
      65              64 :     }
      66                 : 
      67            9473 :     epoll_acceptor_service& service() noexcept
      68                 :     {
      69            9473 :         return svc_;
      70                 :     }
      71                 : 
      72                 :     epoll_accept_op acc_;
      73                 :     descriptor_state desc_state_;
      74                 : 
      75                 : private:
      76                 :     epoll_acceptor_service& svc_;
      77                 :     int fd_ = -1;
      78                 :     endpoint local_endpoint_;
      79                 : };
      80                 : 
      81                 : } // namespace boost::corosio::detail
      82                 : 
      83                 : #endif // BOOST_COROSIO_HAS_EPOLL
      84                 : 
      85                 : #endif // BOOST_COROSIO_NATIVE_DETAIL_EPOLL_EPOLL_ACCEPTOR_HPP