(skywalking-rover) branch tmp_disable_reading updated: update last check delete time

[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 337f7d7  update last check delete time
337f7d7 is described below

commit 337f7d71250e288a0a5e44336384facfa446f482
Author: mrproliu <741550...@qq.com>
AuthorDate: Thu Dec 19 17:26:17 2024 +0800

    update last check delete time
---
 pkg/accesslog/collector/protocols/queue.go | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/pkg/accesslog/collector/protocols/queue.go 
b/pkg/accesslog/collector/protocols/queue.go
index 37af48d..2cd2035 100644
--- a/pkg/accesslog/collector/protocols/queue.go
+++ b/pkg/accesslog/collector/protocols/queue.go
@@ -129,12 +129,13 @@ type PartitionContext struct {
 func newPartitionConnection(protocolMgr *ProtocolManager, conID, randomID 
uint64,
        protocol enums.ConnectionProtocol, currentDataID uint64) 
*PartitionConnection {
        connection := &PartitionConnection{
-               connectionID:     conID,
-               randomID:         randomID,
-               dataBuffers:      
make(map[enums.ConnectionProtocol]*buffer.Buffer),
-               protocol:         make(map[enums.ConnectionProtocol]uint64),
-               protocolAnalyzer: make(map[enums.ConnectionProtocol]Protocol),
-               protocolMetrics:  
make(map[enums.ConnectionProtocol]ProtocolMetrics),
+               connectionID:       conID,
+               randomID:           randomID,
+               dataBuffers:        
make(map[enums.ConnectionProtocol]*buffer.Buffer),
+               protocol:           make(map[enums.ConnectionProtocol]uint64),
+               protocolAnalyzer:   make(map[enums.ConnectionProtocol]Protocol),
+               protocolMetrics:    
make(map[enums.ConnectionProtocol]ProtocolMetrics),
+               lastCheckCloseTime: time.Now(),
        }
        connection.appendProtocolIfNeed(protocolMgr, conID, randomID, protocol, 
currentDataID)
        return connection