From 00e5ec389134a8a0f5f4977387904ba11d3fecfe Mon Sep 17 00:00:00 2001 From: boyce Date: Tue, 29 Oct 2019 14:35:23 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E7=BD=AE=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Test/main.go | 3 +-- cluster/cluster.go | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/Test/main.go b/Test/main.go index 88dca87..03be717 100644 --- a/Test/main.go +++ b/Test/main.go @@ -1,7 +1,6 @@ package main import ( - "strings" "github.com/duanhf2012/origin/cluster" "github.com/duanhf2012/origin/originnode" @@ -9,7 +8,7 @@ import ( ) func main() { - strings.ReplaceAll + node := originnode.NewOriginNode() if node == nil { return diff --git a/cluster/cluster.go b/cluster/cluster.go index 8ef7f6b..b8c3aea 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -113,7 +113,7 @@ func (slf *CCluster) ListenService() error { func (slf *CCluster) ReSetLocalRpcClient() { slf.reader, slf.writer = net.Pipe() go rpc.ServeConn(slf.reader) - slf.LocalRpcClient = rpc.NewClient(slf.writer) + slf.LocalRpcClient = rpc.NewClient(slf.writer,true) } type CPing struct {