EtherGuard-VPN/ipc/uapi_windows.go

81 lines
1.5 KiB
Go
Raw Normal View History

2019-02-04 17:29:52 +01:00
/* SPDX-License-Identifier: MIT
*
* Copyright (C) 2017-2019 WireGuard LLC. All Rights Reserved.
*/
2019-03-03 04:04:41 +01:00
package ipc
2019-02-04 17:29:52 +01:00
import (
"net"
2019-05-14 09:09:52 +02:00
2019-05-23 14:53:44 +02:00
"golang.zx2c4.com/wireguard/ipc/winpipe"
2019-02-04 17:29:52 +01:00
)
2019-06-06 23:00:15 +02:00
// TODO: replace these with actual standard windows error numbers from the win package
2019-02-04 17:29:52 +01:00
const (
2019-03-03 04:04:41 +01:00
IpcErrorIO = -int64(5)
IpcErrorProtocol = -int64(71)
IpcErrorInvalid = -int64(22)
IpcErrorPortInUse = -int64(98)
2019-02-04 17:29:52 +01:00
)
type UAPIListener struct {
listener net.Listener // unix socket listener
connNew chan net.Conn
connErr chan error
kqueueFd int
keventFd int
}
func (l *UAPIListener) Accept() (net.Conn, error) {
for {
select {
case conn := <-l.connNew:
return conn, nil
case err := <-l.connErr:
return nil, err
}
}
}
func (l *UAPIListener) Close() error {
return l.listener.Close()
}
func (l *UAPIListener) Addr() net.Addr {
return l.listener.Addr()
}
/* SDDL_DEVOBJ_SYS_ALL from the WDK */
var UAPISecurityDescriptor = "O:SYD:P(A;;GA;;;SY)"
2019-02-04 17:29:52 +01:00
func UAPIListen(name string) (net.Listener, error) {
2019-05-23 14:53:44 +02:00
config := winpipe.PipeConfig{
SecurityDescriptor: UAPISecurityDescriptor,
2019-02-04 17:29:52 +01:00
}
2019-05-23 14:53:44 +02:00
listener, err := winpipe.ListenPipe("\\\\.\\pipe\\WireGuard\\"+name, &config)
2019-02-04 17:29:52 +01:00
if err != nil {
return nil, err
}
uapi := &UAPIListener{
listener: listener,
connNew: make(chan net.Conn, 1),
connErr: make(chan error, 1),
}
go func(l *UAPIListener) {
for {
conn, err := l.listener.Accept()
if err != nil {
l.connErr <- err
break
}
l.connNew <- conn
}
}(uapi)
return uapi, nil
}