Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-03-13 11:37:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

rpc服务监听任务ip

Browse Source
This commit is contained in:
duanhf2012
2020-04-28 15:32:24 +08:00
parent 43f2d428a8
commit 272412fc8f
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
rpc/server.go
View File

@@ -36,7 +36,6 @@ func (slf *Call) Done() *Call{
type Server struct { type Server struct {
functions map[interface{}]interface{} functions map[interface{}]interface{}
listenAddr string //ip:port
cmdchannel chan *Call cmdchannel chan *Call
@@ -63,9 +62,7 @@ func (slf *Server) Start(listenAddr string) {
if len(splitAddr)!=2{ if len(splitAddr)!=2{
log.Fatal("listen addr is error :%s",listenAddr) log.Fatal("listen addr is error :%s",listenAddr)
} }
slf.rpcserver.Addr = ":"+splitAddr[1]
slf.listenAddr = ":"+splitAddr[1]
slf.rpcserver.Addr = listenAddr
slf.rpcserver.LenMsgLen = 2 //uint16 slf.rpcserver.LenMsgLen = 2 //uint16
slf.rpcserver.MinMsgLen = 2 slf.rpcserver.MinMsgLen = 2
slf.rpcserver.MaxMsgLen = math.MaxUint16 slf.rpcserver.MaxMsgLen = math.MaxUint16