mirror of
https://github.com/MetaCubeX/mihomo.git
synced 2024-09-19 15:12:33 +00:00
42 lines
849 B
Go
42 lines
849 B
Go
//go:build !linux && !windows
|
|
|
|
package fdbased
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/Dreamacro/clash/listener/tun/device"
|
|
"github.com/Dreamacro/clash/listener/tun/device/iobased"
|
|
)
|
|
|
|
func open(fd int, mtu uint32) (device.Device, error) {
|
|
f := &FD{fd: fd, mtu: mtu}
|
|
|
|
return f, nil
|
|
}
|
|
|
|
func (f *FD) useEndpoint() error {
|
|
ep, err := iobased.New(os.NewFile(uintptr(f.fd), f.Name()), f.mtu, 0)
|
|
if err != nil {
|
|
return fmt.Errorf("create endpoint: %w", err)
|
|
}
|
|
f.LinkEndpoint = ep
|
|
return nil
|
|
}
|
|
|
|
func (f *FD) useIOBased() error {
|
|
f.file = os.NewFile(uintptr(f.fd), f.Name())
|
|
if f.file == nil {
|
|
return fmt.Errorf("create IOBased failed, can not open file: %s", f.Name())
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (f *FD) Read(packet []byte) (int, error) {
|
|
return f.file.Read(packet)
|
|
}
|
|
|
|
func (f *FD) Write(packet []byte) (int, error) {
|
|
return f.file.Write(packet)
|
|
}
|