111

Author: lvan100

plugin_logger.go

@@ -17,6 +17,7 @@
 package log
 
 import (
+	"sort"
 	"sync/atomic"
 
 	"github.com/go-spring/spring-base/util"
@@ -124,6 +125,23 @@ type AppenderRefs struct {
 	AppenderRefs []*AppenderRef `PluginElement:"AppenderRef"`
 }
 
+// sortByLevel sorts appender references by level.
+func (c *AppenderRefs) sortByLevel() {
+
+	// Sort appender references by level
+	sort.Slice(c.AppenderRefs, func(i, j int) bool {
+		iCode := c.AppenderRefs[i].Level.MinLevel.code
+		jCode := c.AppenderRefs[j].Level.MinLevel.code
+		return iCode < jCode
+	})
+
+	for i := len(c.AppenderRefs) - 1; i >= 1; i-- {
+		if c.AppenderRefs[i-1].Level.MaxLevel == MaxLevel {
+			c.AppenderRefs[i-1].Level.MaxLevel = c.AppenderRefs[i].Level.MinLevel
+		}
+	}
+}
+
 // Append forwards events to each child appender.
 func (c *AppenderRefs) sendToAppenders(e *Event) {
 	for _, r := range c.AppenderRefs {
@@ -148,8 +166,10 @@ type SyncLogger struct {
 	AppenderRefs
 }
 
-func (c *SyncLogger) Start() error { return nil }
-func (c *SyncLogger) Stop()        {}
+func (c *SyncLogger) Start() error {
+	c.AppenderRefs.sortByLevel()
+	return nil
+}
 
 // Append sends the event directly to appenders (blocking).
 func (c *SyncLogger) Append(e *Event) {
@@ -169,6 +189,8 @@ func (c *SyncLogger) Write(b []byte) {
 	c.writeToAppenders(MaxLevel, b)
 }
 
+func (c *SyncLogger) Stop() {}
+
 // BufferFullPolicy specifies what to do when an async buffer is full.
 type BufferFullPolicy int
 
@@ -218,10 +240,13 @@ func (c *AsyncLogger) Start() error {
 	if c.BufferSize < 100 {
 		return util.FormatError(nil, "bufferSize is too small")
 	}
+
 	c.buf = make(chan any, c.BufferSize)
 	c.wait = make(chan struct{})
 	c.stop = &Event{}
 
+	c.AppenderRefs.sortByLevel()
+
 	// Worker goroutine to process buffered items
 	go func() {
 		for v := range c.buf {