From c74a8a5318cc11212d946a0e8d336d756a8cf831 Mon Sep 17 00:00:00 2001
From: boyce <boyce.duan@gmail.com>
Date: Tue, 5 Mar 2019 15:40:48 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BC=82=E6=AD=A5=E9=98=9F=E5=88=97=E6=96=B0?=
 =?UTF-8?q?=E5=A2=9EGet=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cluster/cluster.go | 1 -
 util/sync_queue.go | 6 ++++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/cluster/cluster.go b/cluster/cluster.go
index 7da13ad..f2d7caa 100644
--- a/cluster/cluster.go
+++ b/cluster/cluster.go
@@ -209,7 +209,6 @@ func (slf *CCluster) Start() error {
 	return nil
 }
 
-//Node.servicename.methodname
 //servicename.methodname
 //_servicename.methodname
 func (slf *CCluster) Call(NodeServiceMethod string, args interface{}, reply interface{}) error {
diff --git a/util/sync_queue.go b/util/sync_queue.go
index e73d369..186d464 100644
--- a/util/sync_queue.go
+++ b/util/sync_queue.go
@@ -94,3 +94,9 @@ func (q *SyncQueue) IsClose() (v bool) {
 	q.lock.Unlock()
 	return
 }
+
+func (q *SyncQueue) Get(i int) interface{} {
+	q.lock.Lock()
+	defer q.lock.Unlock()
+	return q.buffer.Get(i)
+}