engine

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 21, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LanToWan = iota
	WanToLan
)

Variables

View Source 
var (
	BROADCAST_MAC_ADDR = []byte{0xff, 0xff, 0xff, 0xff, 0xff, 0xff}
)

Functions

func ParseIpAddr 

func ParseIpAddr(ipAddrStr string) ([]byte, error)

func ParseMacAddr 

func ParseMacAddr(macAddrStr string) ([]byte, error)

Types

type Config 

type Config struct {
	DebugLog     bool                  // 调试日志
	NetIfList    []*NetIfConfig        // 网卡列表
	RoutingTable []*RoutingEntryConfig // 路由表
}

type Engine 

type Engine struct {
	DebugLog       bool                                              // 调试日志
	Stop           bool                                              // 停止标志
	NetIfMap       map[string]*NetIf                                 // 网络接口集合 key:接口名 value:接口实例
	RoutingTable   []*RoutingEntry                                   // 路由表
	Ipv4PktFwdHook func(raw []byte, dir int) (drop bool, mod []byte) // ip报文转发钩子
}

func InitEngine 

func InitEngine(config *Config) (*Engine, error)

func (*Engine) GetNetIf 

func (e *Engine) GetNetIf(name string) *NetIf

func (*Engine) RunEngine 

func (e *Engine) RunEngine()

func (*Engine) StopEngine 

func (e *Engine) StopEngine()

type NatFlow added in v1.0.3 

type NatFlow struct {
	NatFlowHash   NatFlowHash // nat流唯一标识
	RemoteIpAddr  uint32      // 远程ip地址
	RemotePort    uint16      // 远程端口
	WanIpAddr     uint32      // wan口ip地址
	WanPort       uint16      // wan口端口
	LanHostIpAddr uint32      // lan口主机ip地址
	LanHostPort   uint16      // lan口主机端口
	LastAliveTime uint32      // 上一次活跃时间
}

type NatFlowHash added in v1.0.3 

type NatFlowHash struct {
	RemoteIpAddr  uint32 // 远程ip地址
	RemotePort    uint16 // 远程端口
	LanHostIpAddr uint32 // lan口主机ip地址
	LanHostPort   uint16 // lan口主机端口
}

func (NatFlowHash) String added in v1.0.3 

func (f NatFlowHash) String() string

type NatWan added in v1.0.3 

type NatWan struct {
	RemoteIpAddr uint32 // 远程ip地址
	RemotePort   uint16 // 远程端口
	WanIpAddr    uint32 // wan口ip地址
	WanPort      uint16 // wan口端口
}

type NetIf 

type NetIf struct {
	Name              string                   // 接口名
	MacAddr           []byte                   // mac地址
	IpAddr            []byte                   // ip地址
	NetworkMask       []byte                   // 子网掩码
	EthRxChan         chan []byte              // 物理层接收管道
	EthTxChan         chan []byte              // 物理层发送管道
	LoChan            chan []byte              // 本地回环管道
	Engine            *Engine                  // 归属Engine指针
	ArpCacheTable     map[uint32]uint64        // arp缓存表 key:ip value:mac
	ArpCacheTableLock sync.RWMutex             // arp缓存表锁
	NatEnable         bool                     // 是否开启nat
	NatFlowWanTable   map[NatWan]*NatFlow      // wan口回程包nat流映射表
	NatFlowTable      map[NatFlowHash]*NatFlow // nat流表
	NatTableLock      sync.RWMutex             // nat表锁
	NatPortAlloc      map[uint32]*PortAlloc    // nat端口分配表 key:目的ip value:端口分配信息
	NatPortAllocLock  sync.RWMutex             // nat端口分配表锁
	HandleUdp         func(udpPayload []byte, udpSrcPort uint16, udpDstPort uint16, ipv4SrcAddr []byte)
}

func (*NetIf) FindRoute added in v1.0.3 

func (i *NetIf) FindRoute(ipv4DstAddr []byte) (nextHopIpAddr []byte, outNetIfName string)

func (*NetIf) GetArpCache 

func (i *NetIf) GetArpCache(ipAddr []byte) (macAddr []byte)

func (*NetIf) HandleArp 

func (i *NetIf) HandleArp(ethPayload []byte, ethSrcMac []byte)

func (*NetIf) MacAddrToU added in v1.0.1 

func (i *NetIf) MacAddrToU(macAddr []byte) (macAddrU uint64)

func (*NetIf) NatAddFlow added in v1.0.3 

func (i *NetIf) NatAddFlow(ipv4SrcAddr []byte, ipv4DstAddr []byte, srcPort uint16, dstPort uint16) *NatFlow

func (*NetIf) NatGetFlowByHash added in v1.0.3 

func (i *NetIf) NatGetFlowByHash(natFlowHash NatFlowHash) *NatFlow

func (*NetIf) NatGetFlowByWan added in v1.0.3 

func (i *NetIf) NatGetFlowByWan(remoteIpAddr []byte, remotePort uint16, wanIpAddr []byte, wanPort uint16) *NatFlow

func (*NetIf) NatTableClear added in v1.0.2 

func (i *NetIf) NatTableClear()

func (*NetIf) PacketHandle 

func (i *NetIf) PacketHandle()

func (*NetIf) RxEthernet added in v1.0.1 

func (i *NetIf) RxEthernet(ethFrm []byte)

func (*NetIf) RxIcmp 

func (i *NetIf) RxIcmp(ipv4Payload []byte, ipv4SrcAddr []byte)

func (*NetIf) RxIpv4 

func (i *NetIf) RxIpv4(ethPayload []byte)

func (*NetIf) RxTcp 

func (i *NetIf) RxTcp()

func (*NetIf) RxUdp 

func (i *NetIf) RxUdp(ipv4Payload []byte, ipv4SrcAddr []byte)

func (*NetIf) SendUdpPktByFlow added in v1.0.3 

func (i *NetIf) SendUdpPktByFlow(natFlowHash NatFlowHash, dir int, udpPayload []byte)

func (*NetIf) SetArpCache 

func (i *NetIf) SetArpCache(ipAddr []byte, macAddr []byte)

func (*NetIf) TxEthernet added in v1.0.1 

func (i *NetIf) TxEthernet(ethPayload []byte, ethDstMac []byte, ethProto uint16) []byte

func (*NetIf) TxIcmp 

func (i *NetIf) TxIcmp(icmpPayload []byte, seq uint16, ipv4DstAddr []byte) []byte

func (*NetIf) TxIpv4 

func (i *NetIf) TxIpv4(ipv4Payload []byte, ipv4HeadProto uint8, ipv4DstAddr []byte) []byte

func (*NetIf) TxTcpAck 

func (i *NetIf) TxTcpAck(tcpSrcPort uint16, tcpDstPort uint16, ipv4DstAddr []byte) []byte

func (*NetIf) TxTcpSyn 

func (i *NetIf) TxTcpSyn(tcpSrcPort uint16, tcpDstPort uint16, ipv4DstAddr []byte) []byte

func (*NetIf) TxTcpSynAck 

func (i *NetIf) TxTcpSynAck(tcpSrcPort uint16, tcpDstPort uint16, ipv4DstAddr []byte) []byte

func (*NetIf) TxUdp 

func (i *NetIf) TxUdp(udpPayload []byte, udpSrcPort uint16, udpDstPort uint16, ipv4DstAddr []byte) []byte

func (*NetIf) UToMacAddr added in v1.0.1 

func (i *NetIf) UToMacAddr(macAddrU uint64) (macAddr []byte)

type NetIfConfig 

type NetIfConfig struct {
	Name        string      // 网卡名
	MacAddr     string      // mac地址
	IpAddr      string      // ip地址
	NetworkMask string      // 子网掩码
	NatEnable   bool        // 网络地址转换
	EthRxChan   chan []byte // 物理层接收管道
	EthTxChan   chan []byte // 物理层发送管道
}

type PortAlloc added in v1.0.2 

type PortAlloc struct {
	Lock          sync.RWMutex        // 锁
	AllocPortMap  map[SrcAddr]uint16  // 分配端口集合 key:源地址 value:端口
	RemainPortMap map[uint16]struct{} // 剩余端口集合 key:端口
}

type RoutingEntry added in v1.0.1 

type RoutingEntry struct {
	DstIpAddr   []byte // 目的ip地址
	NetworkMask []byte // 网络掩码
	NextHop     []byte // 下一跳
	NetIf       string // 出接口
}

type RoutingEntryConfig added in v1.0.1 

type RoutingEntryConfig struct {
	DstIpAddr   string // 目的ip地址
	NetworkMask string // 网络掩码
	NextHop     string // 下一跳
	NetIf       string // 出接口
}

type SrcAddr added in v1.0.2 

type SrcAddr struct {
	IpAddr uint32 // ip地址
	Port   uint16 // 端口
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.