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
|
// 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 <unistd.h> // for unlink()
#include <sys/stat.h> // for chmod()
#include <openvpn/acceptor/base.hpp>
namespace openvpn::Acceptor {
struct Unix : public Base
{
OPENVPN_EXCEPTION(unix_acceptor_error);
typedef RCPtr<Unix> Ptr;
Unix(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::Unix::Ptr sock(new AsioPolySock::Unix(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
{
acceptor.close();
}
static void pre_listen(const std::string &socket_path)
{
// remove previous socket instance
::unlink(socket_path.c_str());
}
// set socket permissions in filesystem
static void set_socket_permissions(const std::string &socket_path,
const mode_t unix_mode)
{
if (unix_mode)
{
if (::chmod(socket_path.c_str(), unix_mode) < 0)
throw unix_acceptor_error("chmod failed on unix socket");
}
}
openvpn_io::local::stream_protocol::endpoint local_endpoint;
openvpn_io::basic_socket_acceptor<openvpn_io::local::stream_protocol> acceptor;
};
} // namespace openvpn::Acceptor
|
