From b747cc64f493bdb9a2de1a04cd3c83da8a1ab73a Mon Sep 17 00:00:00 2001 From: eson <474420502@qq.com> Date: Mon, 13 Nov 2023 21:40:54 +0800 Subject: [PATCH] test --- sm_upate_handler.go | 6 ++++++ 1 file changed, 6 insertions(+) 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