black-internet-days-ahead/Xray-core
1
0
Fork 0
mirror of https://github.com/XTLS/Xray-core.git synced 2024-11-22 16:41:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Export PacketConnWrapper

Browse source
This commit is contained in:
世界 2021-09-19 14:14:03 +08:00
parent a3023e43ef
commit 625cf7361a
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 14 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
transport/internet/system_dialer.go
View file

@ -65,8 +65,8 @@ func (d *DefaultSystemDialer) Dial(ctx context.Context, src net.Address, dest ne
return nil, err return nil, err
} }
return &PacketConnWrapper{ return &PacketConnWrapper{
conn: packetConn, Conn: packetConn,
dest: destAddr, Dest: destAddr,
}, nil }, nil
} }
@ -102,49 +102,49 @@ func (d *DefaultSystemDialer) Dial(ctx context.Context, src net.Address, dest ne
} }
type PacketConnWrapper struct { type PacketConnWrapper struct {
conn net.PacketConn Conn net.PacketConn
dest net.Addr Dest net.Addr
} }
func (c *PacketConnWrapper) Close() error { func (c *PacketConnWrapper) Close() error {
return c.conn.Close() return c.Conn.Close()
} }
func (c *PacketConnWrapper) LocalAddr() net.Addr { func (c *PacketConnWrapper) LocalAddr() net.Addr {
return c.conn.LocalAddr() return c.Conn.LocalAddr()
} }
func (c *PacketConnWrapper) RemoteAddr() net.Addr { func (c *PacketConnWrapper) RemoteAddr() net.Addr {
return c.dest return c.Dest
} }
func (c *PacketConnWrapper) Write(p []byte) (int, error) { func (c *PacketConnWrapper) Write(p []byte) (int, error) {
return c.conn.WriteTo(p, c.dest) return c.Conn.WriteTo(p, c.Dest)
} }
func (c *PacketConnWrapper) Read(p []byte) (int, error) { func (c *PacketConnWrapper) Read(p []byte) (int, error) {
n, _, err := c.conn.ReadFrom(p) n, _, err := c.Conn.ReadFrom(p)
return n, err return n, err
} }
func (c *PacketConnWrapper) WriteTo(p []byte, d net.Addr) (int, error) { func (c *PacketConnWrapper) WriteTo(p []byte, d net.Addr) (int, error) {
return c.conn.WriteTo(p, d) return c.Conn.WriteTo(p, d)
} }
func (c *PacketConnWrapper) ReadFrom(p []byte) (int, net.Addr, error) { func (c *PacketConnWrapper) ReadFrom(p []byte) (int, net.Addr, error) {
return c.conn.ReadFrom(p) return c.Conn.ReadFrom(p)
} }
func (c *PacketConnWrapper) SetDeadline(t time.Time) error { func (c *PacketConnWrapper) SetDeadline(t time.Time) error {
return c.conn.SetDeadline(t) return c.Conn.SetDeadline(t)
} }
func (c *PacketConnWrapper) SetReadDeadline(t time.Time) error { func (c *PacketConnWrapper) SetReadDeadline(t time.Time) error {
return c.conn.SetReadDeadline(t) return c.Conn.SetReadDeadline(t)
} }
func (c *PacketConnWrapper) SetWriteDeadline(t time.Time) error { func (c *PacketConnWrapper) SetWriteDeadline(t time.Time) error {
return c.conn.SetWriteDeadline(t) return c.Conn.SetWriteDeadline(t)
} }
type SystemDialerAdapter interface { type SystemDialerAdapter interface {