From 11c51e82d44d0dd3e9c8e235a8e0eb4aded77d7e Mon Sep 17 00:00:00 2001
From: eson <9673575+githubcontent@user.noreply.gitee.com>
Date: Wed, 16 Aug 2023 15:29:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go             | 2 ++
 sm_upate_handler.go | 1 +
 websocket_test.go   | 5 +++--
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/main.go b/main.go
index ad706fe..43f44fb 100644
--- a/main.go
+++ b/main.go
@@ -9,6 +9,7 @@ import (
 	"path/filepath"
 	"runtime"
 	"syscall"
+	"time"
 
 	"github.com/474420502/execute/triggered"
 	"github.com/lni/dragonboat/v4"
@@ -31,6 +32,7 @@ var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[boo
 				break
 			}
 			if item == nil {
+				time.Sleep(time.Millisecond * 100)
 				return
 			}
 
diff --git a/sm_upate_handler.go b/sm_upate_handler.go
index 0850d19..85fe0e2 100644
--- a/sm_upate_handler.go
+++ b/sm_upate_handler.go
@@ -12,6 +12,7 @@ import (
 var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] {
 
 	fsPasser := passer.NewPasser[sm.Result]()
+
 	fsPasser.RegisterPasser(&CmdEnqueue{}, func(cxt context.Context, obj any) (sm.Result, error) {
 
 		var smqueue = cxt.Value(ctxSMQueue{}).(*SMQueue)
diff --git a/websocket_test.go b/websocket_test.go
index 6e8f754..09412e9 100644
--- a/websocket_test.go
+++ b/websocket_test.go
@@ -38,8 +38,9 @@ func TestWebsocketC(t *testing.T) {
 	fusenrender.StartNode(svc)
 }
 
-// var addr = "api.fusen.3718.cn:4050"
-var addr = "localhost:4050"
+var addr = "api.fusen.3718.cn:4050"
+
+// var addr = "localhost:4050"
 
 func TestWebsocketCient(t *testing.T) {
 	// u := url.URL{Scheme: "ws", Host: addr, Path: "/ws/pop/queue"}