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 {