fusen/fusen-render
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

输出日志更加合理

Browse Source
This commit is contained in:
eson 2023-11-14 11:45:46 +08:00
parent af8568c8cb
commit 6dd44fff53
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
sm.go
View File

@ -7,6 +7,7 @@ import (
"log"
"runtime"
"sync"
"time"
"github.com/474420502/execute/triggered"
sm "github.com/lni/dragonboat/v4/statemachine"
@ -37,14 +38,13 @@ func NewSMQueue(shardID uint64, replicaID uint64) sm.IStateMachine {
queues: make(map[string]*PriorityQueue[QueueItem]),
counter: triggered.RegisterExecute[int64](func(params *triggered.Params[int64]) {
if params.Value != 0 {
var m runtime.MemStats
runtime.ReadMemStats(&m)
allocMB := float64(m.Alloc) / 1024 / 1024
// totalAllocMB := float64(m.TotalAlloc) / 1024 / 1024
sysMB := float64(m.Sys) / 1024 / 1024
log.Printf("队列堆积数据: %d, Alloc = %.2f MB, Sys = %.2fMB\n", params.Value, allocMB, sysMB)
}
var m runtime.MemStats
runtime.ReadMemStats(&m)
allocMB := float64(m.Alloc) / 1024 / 1024
// totalAllocMB := float64(m.TotalAlloc) / 1024 / 1024
sysMB := float64(m.Sys) / 1024 / 1024
log.Printf("队列堆积数据: %d, Alloc = %.2f MB, Sys = %.2fMB\n", params.Value, allocMB, sysMB)
time.Sleep(time.Second * 10) // 每超过10秒 统计一次
}),
}
}

4
websocket.go
View File

@ -51,9 +51,9 @@ var countPutPop *CountPutPop = &CountPutPop{
var logIntervalTimeHandler = triggered.RegisterExecute[*CountPutPop](func(params *triggered.Params[*CountPutPop]) {
params.Value.Use(func(item *CountPutPop) {
log.Printf("all pop: %d all put: %d\n", item.PutCount, item.PopCount)
log.Printf("all pop count: %d all put count: %d\n", item.PutCount, item.PopCount)
for k, v := range item.SelfCount {
log.Printf("%s pop: %d\n", k, v)
log.Printf("uinty3d[%s] pop count: %d\n", k, v)
}
})
time.Sleep(time.Second * 15)