diff --git a/sm_upate_handler.go b/sm_upate_handler.go index ba917ae..192186e 100644 --- a/sm_upate_handler.go +++ b/sm_upate_handler.go @@ -2,12 +2,15 @@ package fusenrender import ( "context" + "log" "github.com/474420502/execute/triggered" "github.com/474420502/passer" sm "github.com/lni/dragonboat/v4/statemachine" ) +var putCount int = 0 + // 结构体异步传递后, 执行的注册函数, 实际上就是update的handler var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] { @@ -35,6 +38,9 @@ var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] { Value: cmd.Item, }) + putCount++ + log.Println("put", putCount) + var result sm.Result dequeueHandler.Notify(dequeueHandler.NULL) // 通知可以执行update return result, nil