This is an automated email from the ASF dual-hosted git repository.
liuhan pushed a commit to branch reduce-handle-connect-time
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
The following commit(s) were added to refs/heads/reduce-handle-connect-time by
this push:
new a9b6f8f add conntrack new probes
a9b6f8f is described below
commit a9b6f8fd1cae329fd6a2847f4f63fd1cccf28d1e
Author: mrproliu <[email protected]>
AuthorDate: Fri Dec 27 22:28:32 2024 +0800
add conntrack new probes
---
pkg/tools/ip/conntrack.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pkg/tools/ip/conntrack.go b/pkg/tools/ip/conntrack.go
index b9a35ad..b216921 100644
--- a/pkg/tools/ip/conntrack.go
+++ b/pkg/tools/ip/conntrack.go
@@ -52,8 +52,8 @@ func NewConnTrack() (*ConnTrack, error) {
nfct.RegisterFiltered(context.Background(), conntrack.Conntrack,
conntrack.NetlinkCtNew|conntrack.NetlinkCtUpdate|conntrack.NetlinkCtExpectedNew|conntrack.NetlinkCtExpectedUpdate,
nil, func(event conntrack.Con) int {
log.Infof("conntrack event: origin:
%s:%d->%s:%d, reply: %s:%d->%s:%d",
- event.Origin.Src.String(),
event.Origin.Proto.SrcPort, event.Origin.Dst.String(),
event.Origin.Proto.DstPort,
- event.Reply.Src.String(),
event.Reply.Proto.SrcPort, event.Reply.Dst.String(), event.Reply.Proto.DstPort)
+ event.Origin.Src.String(),
*event.Origin.Proto.SrcPort, event.Origin.Dst.String(),
*event.Origin.Proto.DstPort,
+ event.Reply.Src.String(),
*event.Reply.Proto.SrcPort, event.Reply.Dst.String(),
*event.Reply.Proto.DstPort)
return 0
})
}()