From 8656dada062e3d2b2d2fefbc5850d43e21645842 Mon Sep 17 00:00:00 2001 From: KOMATA <20227709+HynoR@users.noreply.github.com> Date: Thu, 20 Nov 2025 16:28:03 +0800 Subject: [PATCH] fix: correct suitable log queue size to improve performance (#11008) * fix: Update log queue size to improve performance and ensure proper handling of log entries * fix: Adjust log queue size to maintain consistency with queue size limit --- core/log/config.go | 4 +++- core/log/writer.go | 5 +++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/core/log/config.go b/core/log/config.go index 2757315e7..8a02a54f2 100644 --- a/core/log/config.go +++ b/core/log/config.go @@ -2,10 +2,11 @@ package log import ( "errors" - "github.com/1Panel-dev/1Panel/core/constant" "io" "os" "path" + + "github.com/1Panel-dev/1Panel/core/constant" ) var ( @@ -14,6 +15,7 @@ var ( DefaultFileFlag = os.O_RDWR | os.O_CREATE | os.O_APPEND ErrInvalidArgument = errors.New("error argument invalid") QueueSize = 1024 + LogQueueSize = 1024 ErrClosed = errors.New("error write on close") ) diff --git a/core/log/writer.go b/core/log/writer.go index b0c08b745..17f53803e 100644 --- a/core/log/writer.go +++ b/core/log/writer.go @@ -1,7 +1,6 @@ package log import ( - "github.com/1Panel-dev/1Panel/core/constant" "log" "os" "path" @@ -11,6 +10,8 @@ import ( "sync/atomic" "time" + "github.com/1Panel-dev/1Panel/core/constant" + "github.com/1Panel-dev/1Panel/core/global" ) @@ -98,7 +99,7 @@ func NewWriterFromConfig(c *Config) (RollingWriter, error) { var rollingWriter RollingWriter writer := Writer{ - queue: make(chan []byte, BufferSize), + queue: make(chan []byte, LogQueueSize), m: mng, file: file, absPath: filepath,