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 a41ce10  fix
a41ce10 is described below

commit a41ce100dd07c7a6eb1c1f21c7079484fd14f97d
Author: mrproliu <[email protected]>
AuthorDate: Fri Dec 27 23:10:17 2024 +0800

    fix
---
 pkg/tools/ip/conntrack.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/pkg/tools/ip/conntrack.go b/pkg/tools/ip/conntrack.go
index b216921..83b5b60 100644
--- a/pkg/tools/ip/conntrack.go
+++ b/pkg/tools/ip/conntrack.go
@@ -48,6 +48,11 @@ func NewConnTrack() (*ConnTrack, error) {
        if err != nil {
                return nil, err
        }
+
+       nfct1, err := conntrack.Open(&conntrack.Config{})
+       if err != nil {
+               return nil, err
+       }
        go func() {
                nfct.RegisterFiltered(context.Background(), conntrack.Conntrack,
                        
conntrack.NetlinkCtNew|conntrack.NetlinkCtUpdate|conntrack.NetlinkCtExpectedNew|conntrack.NetlinkCtExpectedUpdate,
 nil, func(event conntrack.Con) int {
@@ -57,7 +62,7 @@ func NewConnTrack() (*ConnTrack, error) {
                                return 0
                        })
        }()
-       return &ConnTrack{tracker: nfct}, nil
+       return &ConnTrack{tracker: nfct1}, nil
 }
 
 func (c *ConnTrack) UpdateRealPeerAddress(addr *SocketPair) bool {

Reply via email to