75 lines
1.5 KiB
Go
75 lines
1.5 KiB
Go
package process
|
|
|
|
import (
|
|
"errors"
|
|
"net"
|
|
"net/netip"
|
|
"runtime"
|
|
|
|
"github.com/Dreamacro/clash/common/nnip"
|
|
C "github.com/Dreamacro/clash/constant"
|
|
)
|
|
|
|
var (
|
|
ErrInvalidNetwork = errors.New("invalid network")
|
|
ErrPlatformNotSupport = errors.New("not support on this platform")
|
|
ErrNotFound = errors.New("process not found")
|
|
)
|
|
|
|
const (
|
|
TCP = "tcp"
|
|
UDP = "udp"
|
|
)
|
|
|
|
func FindProcessName(network string, srcIP netip.Addr, srcPort int) (string, error) {
|
|
return findProcessName(network, srcIP, srcPort)
|
|
}
|
|
|
|
func ShouldFindProcess(metadata *C.Metadata) bool {
|
|
if runtime.GOOS == "android" {
|
|
return false
|
|
}
|
|
if metadata.Process != "" || metadata.ProcessPath != "" {
|
|
return false
|
|
}
|
|
for _, ip := range localIPs {
|
|
if ip == metadata.SrcIP {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
func AppendLocalIPs(ip ...netip.Addr) {
|
|
localIPs = append(ip, localIPs...)
|
|
}
|
|
|
|
func getLocalIPs() []netip.Addr {
|
|
ips := []netip.Addr{netip.IPv4Unspecified(), netip.IPv6Unspecified()}
|
|
|
|
netInterfaces, err := net.Interfaces()
|
|
if err != nil {
|
|
ips = append(ips, netip.AddrFrom4([4]byte{127, 0, 0, 1}), nnip.IpToAddr(net.IPv6loopback))
|
|
return ips
|
|
}
|
|
|
|
for i := 0; i < len(netInterfaces); i++ {
|
|
if (netInterfaces[i].Flags & net.FlagUp) != 0 {
|
|
adds, _ := netInterfaces[i].Addrs()
|
|
|
|
for _, address := range adds {
|
|
if ipNet, ok := address.(*net.IPNet); ok {
|
|
ips = append(ips, nnip.IpToAddr(ipNet.IP))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return ips
|
|
}
|
|
|
|
var localIPs []netip.Addr
|
|
|
|
func init() {
|
|
localIPs = getLocalIPs()
|
|
}
|