(skywalking-rover) branch tmp_disable_reading updated: update tmp log

[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 6d805fc  update tmp log
6d805fc is described below

commit 6d805fc912ee8194c5004aaf904cbf08796129d5
Author: mrproliu <741550...@qq.com>
AuthorDate: Thu Dec 19 14:51:13 2024 +0800

    update tmp log
---
 pkg/accesslog/collector/protocols/queue.go |  9 ++++++---
 pkg/logger/settings.go                     | 10 +++++++---
 2 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/pkg/accesslog/collector/protocols/queue.go 
b/pkg/accesslog/collector/protocols/queue.go
index 32269eb..d071fe7 100644
--- a/pkg/accesslog/collector/protocols/queue.go
+++ b/pkg/accesslog/collector/protocols/queue.go
@@ -252,6 +252,9 @@ func (p *PartitionContext) 
getConnectionContext(connectionID, randomID uint64,
        protocol enums.ConnectionProtocol, currentDataID uint64) 
*PartitionConnection {
        conKey := p.buildConnectionKey(connectionID, randomID)
        conn, exist := p.connections.Get(conKey)
+       log.Infof("get the connection context, connection ID: %d, random ID: 
%d, partition number: %d, connection exist: %t"+
+               "protoocl: %d, current data ID: %d, partition context: %p",
+               connectionID, randomID, p.partitionNum, exist, protocol, 
currentDataID, p)
        if exist {
                connection := conn.(*PartitionConnection)
                connection.appendProtocolIfNeed(p.protocolMgr, connectionID, 
randomID, protocol, currentDataID)
@@ -259,9 +262,9 @@ func (p *PartitionContext) 
getConnectionContext(connectionID, randomID uint64,
        }
        result := newPartitionConnection(p.protocolMgr, connectionID, randomID, 
protocol, currentDataID)
        p.connections.Set(conKey, result)
-       log.Infof("create the new connection context, connection ID: %d, random 
ID: %d, partition number: %d"+
-               "protoocl: %d, current data ID: %d",
-               connectionID, randomID, p.partitionNum, protocol, currentDataID)
+       log.Infof("create the new connection context, connection ID: %d, random 
ID: %d, partition number: %d, "+
+               "protoocl: %d, current data ID: %d, partition context: %p",
+               connectionID, randomID, p.partitionNum, protocol, 
currentDataID, p)
        return result
 }
 
diff --git a/pkg/logger/settings.go b/pkg/logger/settings.go
index a56c6ab..c4905e0 100644
--- a/pkg/logger/settings.go
+++ b/pkg/logger/settings.go
@@ -17,7 +17,10 @@
 
 package logger
 
-import "github.com/sirupsen/logrus"
+import (
+       "github.com/sirupsen/logrus"
+       "time"
+)
 
 const (
        DefaultLoggerLevel = logrus.InfoLevel
@@ -45,8 +48,9 @@ func initializeDefaultLogger() *logrus.Logger {
        l := logrus.New()
        l.SetLevel(DefaultLoggerLevel)
        l.SetFormatter(&logrus.TextFormatter{
-               FullTimestamp: true,
-               DisableColors: true,
+               FullTimestamp:   true,
+               DisableColors:   true,
+               TimestampFormat: time.RFC3339Nano,
        })
        return l
 }