日志监控

src/server/pkg/github.com/name5566/leaf/log/log.go

@@ -6,6 +6,7 @@ import (
 	"log"
 	"os"
 	"path"
+	"runtime"
 	"strings"
 	"sync"
 	"time"
@@ -240,6 +241,11 @@ func Error(format string, a ...interface{}) {
 	if gLogger == nil {
 		return
 	}
+	// Capture the stack trace
+	stack := make([]byte, 1024)
+	length := runtime.Stack(stack, false)
+	format = fmt.Sprintf("%s\nStack trace:\n%s", format, stack[:length])
+
 	gLogger.doPrintf(errorLevel, printErrorLevel, format, a...)
 }
 

src/server/pkg/github.com/name5566/leaf/module/skeleton.go

@@ -3,7 +3,8 @@ package module
 import (
 	"server/pkg/github.com/name5566/leaf/chanrpc"
 	"server/pkg/github.com/name5566/leaf/console"
-	"server/pkg/github.com/name5566/leaf/go"
+	g "server/pkg/github.com/name5566/leaf/go"
+	logger "server/pkg/github.com/name5566/leaf/log"
 	"server/pkg/github.com/name5566/leaf/timer"
 	"time"
 )
@@ -43,9 +44,15 @@ func (s *Skeleton) Init() {
 }
 
 func (s *Skeleton) Run(closeSig chan bool) {
+	defer func() {
+		if err := recover(); err != nil {
+			logger.Error("skeleton run panic: %v", err)
+		}
+	}()
 	for {
 		select {
 		case <-closeSig:
+			logger.Debug("close signal received")
 			s.commandServer.Close()
 			s.server.Close()
 			for !s.g.Idle() || !s.client.Idle() {