You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@skywalking.apache.org by li...@apache.org on 2024/12/13 10:16:15 UTC
(skywalking-rover) branch missing-details updated: test
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 <74...@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
}