Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

重置版本

Browse Source
This commit is contained in:
boyce
2019-10-29 14:35:23 +08:00
parent 37bc5f2256
commit 00e5ec3891
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Test/main.go
View File

@@ -1,7 +1,6 @@
package main package main
import ( import (
"strings"
"github.com/duanhf2012/origin/cluster" "github.com/duanhf2012/origin/cluster"
"github.com/duanhf2012/origin/originnode" "github.com/duanhf2012/origin/originnode"
@@ -9,7 +8,7 @@ import (
) )
func main() { func main() {
strings.ReplaceAll
node := originnode.NewOriginNode() node := originnode.NewOriginNode()
if node == nil { if node == nil {
return return

2
cluster/cluster.go
View File

@@ -113,7 +113,7 @@ func (slf *CCluster) ListenService() error {
func (slf *CCluster) ReSetLocalRpcClient() { func (slf *CCluster) ReSetLocalRpcClient() {
slf.reader, slf.writer = net.Pipe() slf.reader, slf.writer = net.Pipe()
go rpc.ServeConn(slf.reader) go rpc.ServeConn(slf.reader)
slf.LocalRpcClient = rpc.NewClient(slf.writer) slf.LocalRpcClient = rpc.NewClient(slf.writer,true)
} }
type CPing struct { type CPing struct {