"strconv"
"strings"
"sync/atomic"
- "syscall"
"time"
)
-const (
- ipcErrorIO = syscall.EIO
- ipcErrorNoPeer = syscall.EPROTO
- ipcErrorNoKeyValue = syscall.EPROTO
- ipcErrorInvalidKey = syscall.EPROTO
- ipcErrorInvalidValue = syscall.EPROTO
-)
-
type IPCError struct {
- Code syscall.Errno
+ Code int64
}
func (s *IPCError) Error() string {
return fmt.Sprintf("IPC error: %d", s.Code)
}
-func (s *IPCError) ErrorCode() uintptr {
- return uintptr(s.Code)
+func (s *IPCError) ErrorCode() int64 {
+ return s.Code
}
func ipcGetOperation(device *Device, socket *bufio.ReadWriter) *IPCError {
package main
+/* Implementation of the TUN device interface for linux
+ */
+
import (
"encoding/binary"
"errors"
+ "golang.org/x/sys/unix"
"os"
"strings"
- "syscall"
"unsafe"
)
-/* Implementation of the TUN device interface for linux
- */
-
const CloneDevicePath = "/dev/net/tun"
type NativeTun struct {
// open datagram socket
- fd, err := syscall.Socket(
- syscall.AF_INET,
- syscall.SOCK_DGRAM,
+ fd, err := unix.Socket(
+ unix.AF_INET,
+ unix.SOCK_DGRAM,
0,
)
return err
}
- defer syscall.Close(fd)
+ defer unix.Close(fd)
// do ioctl call
var ifr [64]byte
copy(ifr[:], tun.name)
binary.LittleEndian.PutUint32(ifr[16:20], uint32(n))
- _, _, errno := syscall.Syscall(
- syscall.SYS_IOCTL,
+ _, _, errno := unix.Syscall(
+ unix.SYS_IOCTL,
uintptr(fd),
- uintptr(syscall.SIOCSIFMTU),
+ uintptr(unix.SIOCSIFMTU),
uintptr(unsafe.Pointer(&ifr[0])),
)
// open datagram socket
- fd, err := syscall.Socket(
- syscall.AF_INET,
- syscall.SOCK_DGRAM,
+ fd, err := unix.Socket(
+ unix.AF_INET,
+ unix.SOCK_DGRAM,
0,
)
return 0, err
}
- defer syscall.Close(fd)
+ defer unix.Close(fd)
// do ioctl call
var ifr [64]byte
copy(ifr[:], tun.name)
- _, _, errno := syscall.Syscall(
- syscall.SYS_IOCTL,
+ _, _, errno := unix.Syscall(
+ unix.SYS_IOCTL,
uintptr(fd),
- uintptr(syscall.SIOCGIFMTU),
+ uintptr(unix.SIOCGIFMTU),
uintptr(unsafe.Pointer(&ifr[0])),
)
if errno != 0 {
// create new device
var ifr [64]byte
- var flags uint16 = syscall.IFF_TUN | syscall.IFF_NO_PI
+ var flags uint16 = unix.IFF_TUN | unix.IFF_NO_PI
nameBytes := []byte(name)
- if len(nameBytes) >= syscall.IFNAMSIZ {
+ if len(nameBytes) >= unix.IFNAMSIZ {
return nil, errors.New("Name size too long")
}
copy(ifr[:], nameBytes)
binary.LittleEndian.PutUint16(ifr[16:], flags)
- _, _, errno := syscall.Syscall(
- syscall.SYS_IOCTL,
+ _, _, errno := unix.Syscall(
+ unix.SYS_IOCTL,
uintptr(fd.Fd()),
- uintptr(syscall.TUNSETIFF),
+ uintptr(unix.TUNSETIFF),
uintptr(unsafe.Pointer(&ifr[0])),
)
if errno != 0 {
import (
"fmt"
+ "golang.org/x/sys/unix"
"net"
"os"
"time"
)
+const (
+ ipcErrorIO = int64(unix.EIO)
+ ipcErrorNoPeer = int64(unix.EPROTO)
+ ipcErrorNoKeyValue = int64(unix.EPROTO)
+ ipcErrorInvalidKey = int64(unix.EPROTO)
+ ipcErrorInvalidValue = int64(unix.EPROTO)
+)
+
/* TODO:
* This code can be improved by using fsnotify once:
* https://github.com/fsnotify/fsnotify/pull/205