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
|
// 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
//
// multi-protocol acceptor classes that handle the protocol-specific
// details of accepting client connections.
#pragma once
#include <vector>
#include <utility>
#include <openvpn/io/io.hpp>
#include <openvpn/common/platform.hpp>
#include <openvpn/common/exception.hpp>
#include <openvpn/common/rc.hpp>
#include <openvpn/common/size.hpp>
#include <openvpn/asio/asiopolysock.hpp>
#ifndef OPENVPN_ACCEPTOR_LISTENER_BASE_RC
#define OPENVPN_ACCEPTOR_LISTENER_BASE_RC RC<thread_unsafe_refcount>
#endif
namespace openvpn::Acceptor {
struct ListenerBase : public OPENVPN_ACCEPTOR_LISTENER_BASE_RC
{
typedef RCPtr<ListenerBase> Ptr;
virtual void handle_accept(AsioPolySock::Base::Ptr sock, const openvpn_io::error_code &error) = 0;
};
struct Base : public RC<thread_unsafe_refcount>
{
typedef RCPtr<Base> Ptr;
virtual void async_accept(ListenerBase *listener,
const size_t acceptor_index,
openvpn_io::io_context &io_context) = 0;
virtual void close() = 0;
};
struct Item
{
enum SSLMode
{
SSLOff,
SSLOn,
#ifdef OPENVPN_POLYSOCK_SUPPORTS_ALT_ROUTING
AltRouting,
#endif
};
Item(Base::Ptr acceptor_arg,
const SSLMode ssl_mode_arg)
: acceptor(std::move(acceptor_arg)),
ssl_mode(ssl_mode_arg)
{
}
Base::Ptr acceptor;
SSLMode ssl_mode;
};
struct Set : public std::vector<Item>
{
void close()
{
for (auto &i : *this)
i.acceptor->close();
}
};
} // namespace openvpn::Acceptor
|
