This is an automated email from the ASF dual-hosted git repository.
liuhan pushed a commit to branch tmp_disable_reading
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
The following commit(s) were added to refs/heads/tmp_disable_reading by this
push:
new c599dbd delete exclude connection map
c599dbd is described below
commit c599dbdd04f4a7e8db5906bc936efe82ffc85fb1
Author: mrproliu <[email protected]>
AuthorDate: Wed Dec 18 13:05:15 2024 +0800
delete exclude connection map
---
pkg/accesslog/common/connection.go | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/pkg/accesslog/common/connection.go
b/pkg/accesslog/common/connection.go
index 13ba399..195fd08 100644
--- a/pkg/accesslog/common/connection.go
+++ b/pkg/accesslog/common/connection.go
@@ -192,8 +192,10 @@ func (c *ConnectionManager) Start(ctx context.Context,
accessLogContext *AccessL
// if the connection is not existed,
then delete it
if err :=
c.activeConnectionMap.Delete(conID); err != nil {
- log.Warnf("failed to delete the
active connection, pid: %d, fd: %d, connection ID: %d, random ID: %d, error:
%v",
- pid, fd, conID,
activateConn.RandomID, err)
+ if !errors.Is(err,
ebpf.ErrKeyNotExist) {
+ log.Warnf("failed to
delete the active connection, pid: %d, fd: %d, connection ID: %d, random ID:
%d, error: %v",
+ pid, fd, conID,
activateConn.RandomID, err)
+ }
continue
}
log.Debugf("deleted the active
connection as not exist in file system, pid: %d, fd: %d, connection ID: %d,
random ID: %d",