apps/kubevpn
1
0
Fork 0
mirror of https://github.com/kubenetworks/kubevpn.git synced 2025-12-24 11:51:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add log if drop packet (#527)

Browse Source 
* feat: add log if drop packet
This commit is contained in:
naison
2025-04-09 22:19:37 +08:00
committed by GitHub
parent f303616554
commit cd66bb7907
4 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/core/gvisortunendpoint.go
View File

@@ -107,6 +107,7 @@ func (h *gvisorTCPHandler) readFromTCPConnWriteToEndpoint(ctx context.Context, c
Data: buf[:],
}, func(v *DatagramPacket) {
config.LPool.Put(v.Data[:])
plog.G(context.Background()).Errorf("Drop packet, SRC: %s, DST: %s, Length: %d", src, dst, v.DataLength)
})
continue
}

5
pkg/core/tcphandler.go
View File

@@ -71,8 +71,8 @@ func (h *UDPOverTCPHandler) Handle(ctx context.Context, tcpConn net.Conn) {
return
}
var src net.IP
src, _, err = util.ParseIP(packet.Data[:packet.DataLength])
var src, dst net.IP
src, dst, err = util.ParseIP(packet.Data[:packet.DataLength])
if err != nil {
plog.G(ctx).Errorf("[TCP] Unknown packet")
config.LPool.Put(buf[:])
@@ -89,6 +89,7 @@ func (h *UDPOverTCPHandler) Handle(ctx context.Context, tcpConn net.Conn) {
}
util.SafeWrite(h.packetChan, packet, func(v *DatagramPacket) {
config.LPool.Put(v.Data[:])
plog.G(context.Background()).Errorf("Drop packet, SRC: %s, DST: %s, Length: %d", src, dst, v.DataLength)
})
}
}

1
pkg/core/tunhandler.go
View File

@@ -104,6 +104,7 @@ func (d *Device) readFromTUN(ctx context.Context) {
dst: dst,
}, func(v *Packet) {
config.LPool.Put(v.data[:])
plog.G(context.Background()).Errorf("Drop packet, SRC: %s, DST: %s, Length: %d", v.src, v.dst, v.length)
})
}
}

3
pkg/core/tunhandlerclient.go
View File

@@ -96,6 +96,7 @@ func transportTunPacketClient(ctx context.Context, tunInbound <-chan *Packet, tu
if packet.src.Equal(packet.dst) {
util.SafeWrite(tunOutbound, packet, func(v *Packet) {
config.LPool.Put(v.data[:])
plog.G(context.Background()).Errorf("Drop packet, SRC: %s, DST: %s, Length: %d", v.src, v.dst, v.length)
})
continue
}
@@ -120,6 +121,7 @@ func transportTunPacketClient(ctx context.Context, tunInbound <-chan *Packet, tu
}
util.SafeWrite(tunOutbound, &Packet{data: buf[:], length: n}, func(v *Packet) {
config.LPool.Put(v.data[:])
plog.G(context.Background()).Errorf("Drop packet, LocalAddr: %s, Remote: %s, Length: %d", packetConn.LocalAddr(), remoteAddr, v.length)
})
}
}()
@@ -155,6 +157,7 @@ func (d *ClientDevice) readFromTun(ctx context.Context) {
plog.G(context.Background()).Debugf("[TUN-CLIENT] SRC: %s, DST: %s, Length: %d", src.String(), dst, n)
util.SafeWrite(d.tunInbound, NewPacket(buf[:], n, src, dst), func(v *Packet) {
config.LPool.Put(v.data[:])
plog.G(context.Background()).Errorf("Drop packet, SRC: %s, DST: %s, Length: %d", v.src, v.dst, v.length)
})
}
}