(skywalking-rover) branch tmp_disable_reading updated: rebuild the connection when have update

[liuhan]

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 919a237  rebuild the connection when have update
919a237 is described below

commit 919a2374e682e9bf427cfb890c6e8972fed27571
Author: mrproliu <741550...@qq.com>
AuthorDate: Sat Dec 21 22:03:52 2024 +0800

    rebuild the connection when have update
---
 pkg/accesslog/sender/logs.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/accesslog/sender/logs.go b/pkg/accesslog/sender/logs.go
index d381671..246adaf 100644
--- a/pkg/accesslog/sender/logs.go
+++ b/pkg/accesslog/sender/logs.go
@@ -76,7 +76,7 @@ func (l *BatchLogs) splitBatchLogs() []*BatchLogs {
        currentCount := 0
        var currentBatch *BatchLogs
        for connection, logs := range l.logs {
-               if currentCount == 0 {
+               if currentCount%maxLogsPerSend == 0 {
                        currentBatch = newBatchLogs()
                        result = append(result, currentBatch)
                        currentCount = 0