liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

处理rpcx双向通信处理流找不到的情况

Browse Source
This commit is contained in:
liwei1dao 2022-10-20 11:17:37 +08:00
parent 800d0203d1
commit f126833315
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lego/sys/rpcx/rpcx.go
View File

@ -38,7 +38,7 @@ type RPCX struct {
func (this *RPCX) Start() (err error) { func (this *RPCX) Start() (err error) {
this.service.Start() this.service.Start()
this.client.Start() this.client.Start()
return return
} }
@ -54,16 +54,20 @@ func (this *RPCX) GetServiceTags() []string {
} }
func (this *RPCX) RegisterFunction(fn interface{}) (err error) { func (this *RPCX) RegisterFunction(fn interface{}) (err error) {
this.service.RegisterFunction(fn) this.service.RegisterFunction(fn)
this.client.RegisterFunction(fn)
return return
} }
func (this *RPCX) RegisterFunctionName(name string, fn interface{}) (err error) { func (this *RPCX) RegisterFunctionName(name string, fn interface{}) (err error) {
this.service.RegisterFunctionName(name, fn) this.service.RegisterFunctionName(name, fn)
this.client.RegisterFunctionName(name, fn)
return return
} }
func (this *RPCX) UnregisterAll() (err error) { func (this *RPCX) UnregisterAll() (err error) {
return this.service.UnregisterAll() err = this.service.UnregisterAll()
err = this.client.UnregisterAll()
return
} }
//同步调用 //同步调用