(skywalking-rover) branch missing-details updated: test

[liuhan]

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


The following commit(s) were added to refs/heads/missing-details by this push:
     new 8bfdab1  test
8bfdab1 is described below

commit 8bfdab1260beaa94f22ef687a1deeba8c3025964
Author: mrproliu <741550...@qq.com>
AuthorDate: Fri Dec 13 18:16:06 2024 +0800

    test
---
 pkg/accesslog/collector/connection.go      | 4 ++--
 pkg/accesslog/collector/protocols/http1.go | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/pkg/accesslog/collector/connection.go 
b/pkg/accesslog/collector/connection.go
index 04ee6b1..eeeb7dd 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), 10, func() interface{} {
+       c.eventQueue.RegisterReceiver(ctx.BPF.SocketConnectionEventQueue, 
int(perCPUBufferSize), 15, 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), 10, func() interface{} {
+       c.eventQueue.RegisterReceiver(ctx.BPF.SocketCloseEventQueue, 
int(perCPUBufferSize), 15, func() interface{} {
                return &events.SocketCloseEvent{}
        }, func(data interface{}) string {
                return fmt.Sprintf("%d", 
data.(*events.SocketCloseEvent).ConnectionID)
diff --git a/pkg/accesslog/collector/protocols/http1.go 
b/pkg/accesslog/collector/protocols/http1.go
index 0052b7f..f11090f 100644
--- a/pkg/accesslog/collector/protocols/http1.go
+++ b/pkg/accesslog/collector/protocols/http1.go
@@ -34,7 +34,7 @@ import (
 )
 
 var http1Log = logger.GetLogger("accesslog", "collector", "protocols", "http1")
-var http1AnalyzeMaxRetryCount = 5
+var http1AnalyzeMaxRetryCount = 3
 
 type HTTP1ProtocolAnalyze func(metrics *HTTP1Metrics, request *reader.Request, 
response *reader.Response) error
 
@@ -194,7 +194,7 @@ func (p *HTTP1Protocol) handleUnFinishedEvents(m 
*HTTP1Metrics) {
                err := p.analyze(m, unFinished.request, unFinished.response)
                if err != nil {
                        unFinished.retryCount++
-                       if unFinished.retryCount <= http1AnalyzeMaxRetryCount {
+                       if unFinished.retryCount < http1AnalyzeMaxRetryCount {
                                element = element.Next()
                                continue
                        }