From 4f04056f8b70a467fe17cd989f284b5d23d34ed4 Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期日, 20 十月 2024 16:16:20 +0800 Subject: [PATCH] debug osd --- nvcs/a3.go | 2 +- nvcs/a2.go | 2 +- nvcs/a1.go | 2 +- nvcs/queue.go | 4 ++-- nvcs/nvcs.go | 2 +- nvcs/cache.go | 2 -- 6 files changed, 6 insertions(+), 8 deletions(-) diff --git a/nvcs/a1.go b/nvcs/a1.go index a13b7fe..9dd2d3f 100644 --- a/nvcs/a1.go +++ b/nvcs/a1.go @@ -223,6 +223,6 @@ // RunningCorrectTaskId = "" //} - queue.enqueue(runState) + queue.put(runState) } } diff --git a/nvcs/a2.go b/nvcs/a2.go index 224b290..1fe6954 100644 --- a/nvcs/a2.go +++ b/nvcs/a2.go @@ -110,7 +110,7 @@ RunState: iRunState, } - queue.enqueue(runState) + queue.put(runState) c.JSON(http.StatusOK, "ok") }) diff --git a/nvcs/a3.go b/nvcs/a3.go index 519e68b..e69067d 100644 --- a/nvcs/a3.go +++ b/nvcs/a3.go @@ -45,7 +45,7 @@ RunState: req.Status, } - queue.enqueue(runState) + queue.put(runState) c.JSON(http.StatusOK, "ok") }) diff --git a/nvcs/cache.go b/nvcs/cache.go index 795dd37..55baeef 100644 --- a/nvcs/cache.go +++ b/nvcs/cache.go @@ -41,8 +41,6 @@ } } - c.data.PushBack(data) - // 鏁版嵁搴撲繚瀛樹竴浠� go func() { var d = models.Positions{ diff --git a/nvcs/nvcs.go b/nvcs/nvcs.go index a6d5c0b..2f7ccf6 100644 --- a/nvcs/nvcs.go +++ b/nvcs/nvcs.go @@ -55,7 +55,7 @@ func listenQueue() { for { - data := queue.dequeue() + data := queue.get() cache.store(data) // 娓呯悊杩囨湡鏁版嵁 diff --git a/nvcs/queue.go b/nvcs/queue.go index 423c65d..f1857e5 100644 --- a/nvcs/queue.go +++ b/nvcs/queue.go @@ -10,11 +10,11 @@ } } -func (q *chQueue) enqueue(data elevatorRunData) { +func (q *chQueue) put(data elevatorRunData) { q.data <- data } -func (q *chQueue) dequeue() elevatorRunData { +func (q *chQueue) get() elevatorRunData { data := <-q.data return data } -- Gitblit v1.8.0