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) +}