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 3b5de67 pre-sending to the connection mgr
3b5de67 is described below
commit 3b5de679bf6ffbc6528c1e65ba15062dc074f0d3
Author: mrproliu <[email protected]>
AuthorDate: Fri Dec 20 10:45:04 2024 +0800
pre-sending to the connection mgr
---
pkg/accesslog/forwarder/connect.go | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/pkg/accesslog/forwarder/connect.go
b/pkg/accesslog/forwarder/connect.go
index 2058d25..667a4db 100644
--- a/pkg/accesslog/forwarder/connect.go
+++ b/pkg/accesslog/forwarder/connect.go
@@ -31,10 +31,13 @@ func init() {
}
func SendConnectEvent(context *common.AccessLogContext, event
*events.SocketConnectEvent, socketPair *ip.SocketPair) {
- context.Queue.AppendKernelLog(common.LogTypeConnect,
&common.ConnectEventWithSocket{
+ connect := &common.ConnectEventWithSocket{
SocketConnectEvent: event,
SocketPair: socketPair,
- })
+ }
+ context.Queue.AppendKernelLog(common.LogTypeConnect, connect)
+ // pre-sending to the connection mgr to building the connection
+ context.ConnectionMgr.Find(connect)
}
func connectLogBuilder(event events.Event) *v3.AccessLogKernelLog {
