HimbeerserverDE
/
multiserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Implement #49

master
HimbeerserverDE 2021-03-17 17:48:03 +01:00
parent 6b996f06b0
commit 4e5b424297
No known key found for this signature in database
GPG Key ID: 1A651504791E6A8B
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
rpc.go
View File

@ -193,7 +193,22 @@ func processRpc(p *Peer, pkt rudp.Pkt) bool {
rpcSrvMu.Lock()
for srv := range rpcSrvs {
if srv.Addr().String() != p.Addr().String() {
go srv.doRpc("->MT2MT "+msg, "--")
go srv.doRpc("->MT2MT true "+msg, "--")
}
}
rpcSrvMu.Unlock()
case "<-MSG2MT":
tosrv := strings.Split(msg, " ")[2]
addr, ok := ConfKey("servers:" + tosrv + ":address").(string)
if !ok || addr == p.Addr().String() {
return true
}
msg := strings.Join(strings.Split(msg, " ")[3:], " ")
rpcSrvMu.Lock()
for srv := range rpcSrvs {
if srv.Addr().String() == addr {
go srv.doRpc("->MT2MT false "+msg, "--")
}
}
rpcSrvMu.Unlock()