This is an automated email from the ASF dual-hosted git repository. liuhan pushed a commit to branch missing-details in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
commit 16d3269a38375ac2ca2cc4c8955d7f40643c8f80 Author: mrproliu <[email protected]> AuthorDate: Fri Dec 13 15:59:37 2024 +0800 tmp upgrade parsing count --- pkg/accesslog/collector/connection.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/accesslog/collector/connection.go b/pkg/accesslog/collector/connection.go index 8e8aba1..04ee6b1 100644 --- a/pkg/accesslog/collector/connection.go +++ b/pkg/accesslog/collector/connection.go @@ -77,12 +77,12 @@ func (c *ConnectCollector) Start(_ *module.Manager, ctx *common.AccessLogContext c.eventQueue = btf.NewEventQueue(ctx.Config.ConnectionAnalyze.Parallels, ctx.Config.ConnectionAnalyze.QueueSize, func(num int) btf.PartitionContext { return newConnectionPartitionContext(ctx, track) }) - c.eventQueue.RegisterReceiver(ctx.BPF.SocketConnectionEventQueue, int(perCPUBufferSize), 1, func() interface{} { + c.eventQueue.RegisterReceiver(ctx.BPF.SocketConnectionEventQueue, int(perCPUBufferSize), 10, func() interface{} { return &events.SocketConnectEvent{} }, func(data interface{}) string { return fmt.Sprintf("%d", data.(*events.SocketConnectEvent).ConID) }) - c.eventQueue.RegisterReceiver(ctx.BPF.SocketCloseEventQueue, int(perCPUBufferSize), 1, func() interface{} { + c.eventQueue.RegisterReceiver(ctx.BPF.SocketCloseEventQueue, int(perCPUBufferSize), 10, func() interface{} { return &events.SocketCloseEvent{} }, func(data interface{}) string { return fmt.Sprintf("%d", data.(*events.SocketCloseEvent).ConnectionID)
