Report deserialization error...
This commit is contained in:
parent
edd130b56f
commit
85a45a27f6
|
@ -591,8 +591,7 @@ func (e *engine) sendPeerMessage(handle string, message model3.PeerMessage) erro
|
||||||
if err == nil {
|
if err == nil {
|
||||||
peerApp, ok := (conn.App()).(*PeerApp)
|
peerApp, ok := (conn.App()).(*PeerApp)
|
||||||
if ok {
|
if ok {
|
||||||
peerApp.SendMessage(message)
|
return peerApp.SendMessage(message)
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
log.Errorf("could not send peer message: %v", err)
|
log.Errorf("could not send peer message: %v", err)
|
||||||
|
|
|
@ -108,10 +108,14 @@ func (pa *PeerApp) listen() {
|
||||||
|
|
||||||
// SendMessage sends the peer a preformatted message
|
// SendMessage sends the peer a preformatted message
|
||||||
// NOTE: This is a stub, we will likely want to extend this to better reflect the desired protocol
|
// NOTE: This is a stub, we will likely want to extend this to better reflect the desired protocol
|
||||||
func (pa *PeerApp) SendMessage(message model2.PeerMessage) {
|
func (pa *PeerApp) SendMessage(message model2.PeerMessage) error {
|
||||||
if message.Context == event.ContextGetVal {
|
if message.Context == event.ContextGetVal {
|
||||||
pa.getValRequests.Store(message.ID, string(message.Data))
|
pa.getValRequests.Store(message.ID, string(message.Data))
|
||||||
}
|
}
|
||||||
serialized, _ := json.Marshal(message)
|
serialized, err := json.Marshal(message)
|
||||||
pa.connection.Send(serialized)
|
if err == nil {
|
||||||
|
pa.connection.Send(serialized)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue