Routing
This commit is contained in:
parent
7b95b9df71
commit
7489ffffcb
@ -146,7 +146,7 @@ func (id *Identity) PackForSending(encryptedMessage []byte, signature []byte) (f
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Outbound helper function
|
// Outbound helper function
|
||||||
func (id *Identity) ProcessOut(peerPublicKey string, msg *meowlib.FromServerMessage) (fromServerMessage []byte, err error) {
|
func (id *Identity) ProcessOutbound(peerPublicKey string, msg *meowlib.FromServerMessage) (fromServerMessage []byte, err error) {
|
||||||
encoded_srv_fromServerMessage, err := id.SerializeFromServerMessage(msg)
|
encoded_srv_fromServerMessage, err := id.SerializeFromServerMessage(msg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
@ -67,10 +67,11 @@ func (r *RedisRouter) Route(msg *meowlib.ToServerMessage) (*meowlib.FromServerMe
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
if len(msg.KnownServers) > 0 {
|
||||||
|
|
||||||
}
|
}
|
||||||
/*
|
/*
|
||||||
case "q": // query messages
|
|
||||||
break
|
|
||||||
|
|
||||||
case "s": // servers list
|
case "s": // servers list
|
||||||
breakmsgs
|
breakmsgs
|
||||||
|
Loading…
Reference in New Issue
Block a user