(skywalking-rover) branch tmp_disable_reading updated: batch sending logs

[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 96ffdb6  batch sending logs
96ffdb6 is described below

commit 96ffdb62bcadaf592d89a8f8fa08c8f5d720c909
Author: mrproliu <741550...@qq.com>
AuthorDate: Fri Dec 20 12:59:09 2024 +0800

    batch sending logs
---
 pkg/accesslog/runner.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pkg/accesslog/runner.go b/pkg/accesslog/runner.go
index 18577de..240804e 100644
--- a/pkg/accesslog/runner.go
+++ b/pkg/accesslog/runner.go
@@ -204,7 +204,7 @@ func (r *Runner) buildProtocolLogs(protocols chan 
*common.ProtocolLog, result ma
 }
 
 func (r *Runner) sendLogs(allLogs map[*common.ConnectionInfo]*connectionLogs) 
error {
-       timeout, cancelFunc := context.WithTimeout(r.ctx, time.Second*20)
+       timeout, cancelFunc := context.WithTimeout(r.ctx, time.Second*30)
        defer cancelFunc()
        streaming, err := r.alsClient.Collect(timeout)
        if err != nil {
@@ -244,7 +244,7 @@ func (r *Runner) sendLogs(allLogs 
map[*common.ConnectionInfo]*connectionLogs) er
 
 func (r *Runner) sendLogToTheStream(streaming 
v3.EBPFAccessLogService_CollectClient, logMsg *v3.EBPFAccessLogMessage) {
        if err := streaming.Send(logMsg); err != nil {
-               log.Warnf("send access log failure: %v", err)
+               log.Warnf("send access log message failure: %v", err)
        }
 }