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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
/* SPDX-License-Identifier: Apache-2.0
*
* Copyright (C) 2017-2019 Jason A. Donenfeld <Jason@zx2c4.com>. All Rights Reserved.
* Copyright (C) 2021 Mullvad VPN AB. All Rights Reserved.
*/
package main
import (
"C"
"bufio"
"strings"
"unsafe"
"golang.org/x/sys/unix"
"golang.zx2c4.com/wireguard/conn"
"golang.zx2c4.com/wireguard/device"
"golang.zx2c4.com/wireguard/tun"
"github.com/mullvad/mullvadvpn-app/wireguard/libwg/logging"
"github.com/mullvad/mullvadvpn-app/wireguard/libwg/tunnelcontainer"
)
// Redefined here because otherwise the compiler doesn't realize it's a type alias for a type that's safe to export.
// Taken from the contained logging package.
type LogSink = unsafe.Pointer
type LogContext = unsafe.Pointer
//export wgTurnOn
func wgTurnOn(cSettings *C.char, fd int, logSink LogSink, logContext LogContext) int32 {
logger := logging.NewLogger(logSink, logContext)
if cSettings == nil {
logger.Errorf("cSettings is null\n")
return ERROR_GENERAL_FAILURE
}
settings := C.GoString(cSettings)
tunDevice, _, err := tun.CreateUnmonitoredTUNFromFD(fd)
if err != nil {
logger.Errorf("%s\n", err)
unix.Close(fd)
if err.Error() == "bad file descriptor" {
return ERROR_INTERMITTENT_FAILURE
}
return ERROR_GENERAL_FAILURE
}
device := device.NewDevice(tunDevice, conn.NewStdNetBind(), logger)
setErr := device.IpcSetOperation(bufio.NewReader(strings.NewReader(settings)))
if setErr != nil {
logger.Errorf("%s\n", setErr)
device.Close()
return ERROR_INTERMITTENT_FAILURE
}
device.DisableSomeRoamingForBrokenMobileSemantics()
device.Up()
context := tunnelcontainer.Context{
Device: device,
Logger: logger,
}
handle, err := tunnels.Insert(context)
if err != nil {
logger.Errorf("%s\n", err)
device.Close()
return ERROR_GENERAL_FAILURE
}
return handle
}
//export wgGetSocketV4
func wgGetSocketV4(tunnelHandle int32) int32 {
tunnel, err := tunnels.Get(tunnelHandle)
if err != nil {
return ERROR_GENERAL_FAILURE
}
peek := tunnel.Device.Bind().(conn.PeekLookAtSocketFd)
fd, err := peek.PeekLookAtSocketFd4()
if err != nil {
return ERROR_GENERAL_FAILURE
}
return int32(fd)
}
//export wgGetSocketV6
func wgGetSocketV6(tunnelHandle int32) int32 {
tunnel, err := tunnels.Get(tunnelHandle)
if err != nil {
return ERROR_GENERAL_FAILURE
}
peek := tunnel.Device.Bind().(conn.PeekLookAtSocketFd)
fd, err := peek.PeekLookAtSocketFd6()
if err != nil {
return ERROR_GENERAL_FAILURE
}
return int32(fd)
}
|
