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