aboutsummaryrefslogtreecommitdiffstats
path: root/ipc/uapi_linux.go
diff options
context:
space:
mode:
Diffstat (limited to 'ipc/uapi_linux.go')
-rw-r--r--ipc/uapi_linux.go72
1 files changed, 1 insertions, 71 deletions
diff --git a/ipc/uapi_linux.go b/ipc/uapi_linux.go
index dce6a45..70d4d0c 100644
--- a/ipc/uapi_linux.go
+++ b/ipc/uapi_linux.go
@@ -6,26 +6,13 @@
package ipc
import (
- "errors"
- "fmt"
"net"
"os"
- "path"
"golang.org/x/sys/unix"
"golang.zx2c4.com/wireguard/rwcancel"
)
-var socketDirectory = "/var/run/wireguard"
-
-const (
- IpcErrorIO = -int64(unix.EIO)
- IpcErrorProtocol = -int64(unix.EPROTO)
- IpcErrorInvalid = -int64(unix.EINVAL)
- IpcErrorPortInUse = -int64(unix.EADDRINUSE)
- socketName = "%s.sock"
-)
-
type UAPIListener struct {
listener net.Listener // unix socket listener
connNew chan net.Conn
@@ -84,10 +71,7 @@ func UAPIListen(name string, file *os.File) (net.Listener, error) {
// watch for deletion of socket
- socketPath := path.Join(
- socketDirectory,
- fmt.Sprintf(socketName, name),
- )
+ socketPath := sockPath(name)
uapi.inotifyFd, err = unix.InotifyInit()
if err != nil {
@@ -143,57 +127,3 @@ func UAPIListen(name string, file *os.File) (net.Listener, error) {
return uapi, nil
}
-
-func UAPIOpen(name string) (*os.File, error) {
-
- // check if path exist
-
- if err := os.MkdirAll(socketDirectory, 0755); err != nil {
- return nil, err
- }
-
- // open UNIX socket
-
- socketPath := path.Join(
- socketDirectory,
- fmt.Sprintf(socketName, name),
- )
-
- addr, err := net.ResolveUnixAddr("unix", socketPath)
- if err != nil {
- return nil, err
- }
-
- oldUmask := unix.Umask(0077)
- listener, err := func() (*net.UnixListener, error) {
-
- // initial connection attempt
-
- listener, err := net.ListenUnix("unix", addr)
- if err == nil {
- return listener, nil
- }
-
- // check if socket already active
-
- _, err = net.Dial("unix", socketPath)
- if err == nil {
- return nil, errors.New("unix socket in use")
- }
-
- // cleanup & attempt again
-
- err = os.Remove(socketPath)
- if err != nil {
- return nil, err
- }
- return net.ListenUnix("unix", addr)
- }()
- unix.Umask(oldUmask)
-
- if err != nil {
- return nil, err
- }
-
- return listener.File()
-}