1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
// OpenVPN -- An application to securely tunnel IP networks
// over a single port, with support for SSL/TLS-based
// session authentication and key exchange,
// packet encryption, packet authentication, and
// packet compression.
//
// Copyright (C) 2012- OpenVPN Inc.
//
// SPDX-License-Identifier: MPL-2.0 OR AGPL-3.0-only WITH openvpn3-openssl-exception
//
#pragma once
#include <openvpn/acceptor/base.hpp>
#include <openvpn/ssl/sslconsts.hpp>
namespace openvpn::Acceptor {
struct TCP : public Base
{
typedef RCPtr<TCP> Ptr;
TCP(openvpn_io::io_context &io_context)
: acceptor(io_context)
{
}
void async_accept(ListenerBase *listener,
const size_t acceptor_index,
openvpn_io::io_context &io_context) override
{
AsioPolySock::TCP::Ptr sock(new AsioPolySock::TCP(io_context, acceptor_index));
acceptor.async_accept(sock->socket,
[listener = ListenerBase::Ptr(listener), sock](const openvpn_io::error_code &error) mutable
{ listener->handle_accept(std::move(sock), error); });
}
void close() override
{
#ifdef OPENVPN_DEBUG_ACCEPT
OPENVPN_LOG("ACCEPTOR CLOSE " << local_endpoint);
#endif
acceptor.close();
}
enum
{
// start at (1<<24) to avoid conflicting with SSLConst flags
DISABLE_REUSE_ADDR = (1 << 24),
REUSE_PORT = (1 << 25),
FIRST = DISABLE_REUSE_ADDR
};
void set_socket_options(unsigned int flags)
{
static_assert(int(FIRST) > int(SSLConst::LAST), "TCP flags in conflict with SSL flags");
#if defined(OPENVPN_PLATFORM_WIN)
// set Windows socket flags
if (!(flags & DISABLE_REUSE_ADDR))
acceptor.set_option(openvpn_io::ip::tcp::acceptor::reuse_address(true));
#else
// set Unix socket flags
{
const int fd = acceptor.native_handle();
if (flags & REUSE_PORT)
SockOpt::reuseport(fd);
if (!(flags & DISABLE_REUSE_ADDR))
SockOpt::reuseaddr(fd);
SockOpt::set_cloexec(fd);
}
#endif
}
// filter all but socket option flags
static unsigned int sockopt_flags(const unsigned int flags)
{
return flags & (DISABLE_REUSE_ADDR | REUSE_PORT);
}
openvpn_io::ip::tcp::endpoint local_endpoint;
openvpn_io::ip::tcp::acceptor acceptor;
};
} // namespace openvpn::Acceptor
|
