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

hotfix: heartbeats with gen icmp packet (#683)

Browse Source
This commit is contained in:
naison
2025-08-04 21:16:38 +08:00
committed by GitHub
parent 6a82b12646
commit c4d28fd497
1 changed files with 27 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
pkg/core/tunhandlerclient.go
View File

@@ -204,15 +204,39 @@ func (d *ClientDevice) heartbeats(ctx context.Context) {
ticker := time.NewTicker(config.KeepAliveTime) ticker := time.NewTicker(config.KeepAliveTime)
defer ticker.Stop() defer ticker.Stop()
var bytes, bytes6 []byte
for ; ctx.Err() == nil; <-ticker.C { for ; ctx.Err() == nil; <-ticker.C {
if srcIPv4 != nil { if srcIPv4 != nil {
util.Ping(ctx, srcIPv4.String(), config.RouterIP.String()) bytes, err = util.GenICMPPacket(srcIPv4, config.RouterIP)
if err != nil {
plog.G(ctx).Errorf("Failed to generate IPv4 packet: %v", err)
} else {
data := config.LPool.Get().([]byte)[:]
length := copy(data[1:], bytes)
data[0] = 1
util.SafeWrite(d.tunInbound, &Packet{
data: data[:],
length: length + 1,
})
}
} }
if srcIPv6 != nil { if srcIPv6 != nil {
util.Ping(ctx, srcIPv6.String(), config.RouterIP6.String()) bytes6, err = util.GenICMPPacketIPv6(srcIPv6, config.RouterIP6)
if err != nil {
plog.G(ctx).Errorf("Failed to generate IPv6 packet: %v", err)
} else {
data := config.LPool.Get().([]byte)[:]
length := copy(data[1:], bytes6)
data[0] = 1
util.SafeWrite(d.tunInbound, &Packet{
data: data[:],
length: length + 1,
})
}
} }
if dockerSrcIPv4 != nil { if dockerSrcIPv4 != nil {
util.Ping(ctx, dockerSrcIPv4.String(), config.DockerRouterIP.String()) _, _ = util.Ping(ctx, dockerSrcIPv4.String(), config.DockerRouterIP.String())
} }
} }
} }