src/corosio/src/tcp_acceptor.cpp

89.6% Lines (43/48) 100.0% List of functions (9/9)

[ ] prev/next file n p prev/next uncovered line

tcp_acceptor.cpp

f(x) Functions (9)

Function Calls Lines Blocks

Line	Hits	Source Code
1		//
2		// Copyright (c) 2025 Vinnie Falco ([email protected])
3		// Copyright (c) 2026 Steve Gerbino
4		//
5		// Distributed under the Boost Software License, Version 1.0. (See accompanying
6		// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
7		//
8		// Official repository: https://github.com/cppalliance/corosio
9		//
10
11		#include <boost/corosio/tcp_acceptor.hpp>
12		#include <boost/corosio/socket_option.hpp>
13		#include <boost/corosio/detail/platform.hpp>
14
15		#if BOOST_COROSIO_HAS_IOCP
16		#include <boost/corosio/native/detail/iocp/win_tcp_acceptor_service.hpp>
17		#else
18		#include <boost/corosio/detail/tcp_acceptor_service.hpp>
19		#endif
20
21		#include <boost/corosio/detail/except.hpp>
22
23		namespace boost::corosio {
24
25	1210x	tcp_acceptor::~tcp_acceptor()
26		{
27	1210x	close();
28	1210x	}
29
30	1204x	tcp_acceptor::tcp_acceptor(capy::execution_context& ctx)
31		#if BOOST_COROSIO_HAS_IOCP
32		: io_object(create_handle<detail::win_tcp_acceptor_service>(ctx))
33		#else
34	1204x	: io_object(create_handle<detail::tcp_acceptor_service>(ctx))
35		#endif
36		{
37	1204x	}
38
39	13x	tcp_acceptor::tcp_acceptor(
40	13x	capy::execution_context& ctx, endpoint ep, int backlog)
41	13x	: tcp_acceptor(ctx)
42		{
43	13x	open(ep.is_v6() ? tcp::v6() : tcp::v4());
44	13x	set_option(socket_option::reuse_address(true));
45	13x	if (auto ec = bind(ep))
46	1x	detail::throw_system_error(ec, "tcp_acceptor");
47	12x	if (auto ec = listen(backlog))
48	✗	detail::throw_system_error(ec, "tcp_acceptor");
49	13x	}
50
51		void
52	1205x	tcp_acceptor::open(tcp proto)
53		{
54	1205x	if (is_open())
55	2x	return;
56
57		#if BOOST_COROSIO_HAS_IOCP
58		auto& svc = static_cast<detail::win_tcp_acceptor_service&>(h_.service());
59		#else
60	1203x	auto& svc = static_cast<detail::tcp_acceptor_service&>(h_.service());
61		#endif
62	2406x	std::error_code ec = svc.open_acceptor_socket(
63	1203x	static_cast<tcp_acceptor::implementation>(h_.get()), proto.family(),
64		proto.type(), proto.protocol());
65	1203x	if (ec)
66	✗	detail::throw_system_error(ec, "tcp_acceptor::open");
67		}
68
69		std::error_code
70	1203x	tcp_acceptor::bind(endpoint ep)
71		{
72	1203x	if (!is_open())
73	2x	detail::throw_logic_error("bind: acceptor not open");
74		#if BOOST_COROSIO_HAS_IOCP
75		auto& svc = static_cast<detail::win_tcp_acceptor_service&>(h_.service());
76		#else
77	1201x	auto& svc = static_cast<detail::tcp_acceptor_service&>(h_.service());
78		#endif
79	1201x	return svc.bind_acceptor(
80	2402x	static_cast<tcp_acceptor::implementation>(h_.get()), ep);
81		}
82
83		std::error_code
84	1193x	tcp_acceptor::listen(int backlog)
85		{
86	1193x	if (!is_open())
87	✗	detail::throw_logic_error("listen: acceptor not open");
88		#if BOOST_COROSIO_HAS_IOCP
89		auto& svc = static_cast<detail::win_tcp_acceptor_service&>(h_.service());
90		#else
91	1193x	auto& svc = static_cast<detail::tcp_acceptor_service&>(h_.service());
92		#endif
93	1193x	return svc.listen_acceptor(
94	2386x	static_cast<tcp_acceptor::implementation>(h_.get()), backlog);
95		}
96
97		void
98	2403x	tcp_acceptor::close()
99		{
100	2403x	if (!is_open())
101	1200x	return;
102	1203x	h_.service().close(h_);
103		}
104
105		void
106	4x	tcp_acceptor::cancel()
107		{
108	4x	if (!is_open())
109	✗	return;
110	4x	get().cancel();
111		}
112
113		endpoint
114	1189x	tcp_acceptor::local_endpoint() const noexcept
115		{
116	1189x	if (!is_open())
117	✗	return endpoint{};
118	1189x	return get().local_endpoint();
119		}
120
121		} // namespace boost::corosio
122