diff --git a/core/log/config.go b/core/log/config.go index 2757315e722d..8a02a54f2320 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 b0c08b745faa..17f53803ec01 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,