Fixing getVal
This commit is contained in:
parent
963b99b5e6
commit
120ebe1312
|
@ -93,6 +93,7 @@ func (pa *PeerApp) listen() {
|
||||||
switch peerMessage.Context {
|
switch peerMessage.Context {
|
||||||
case event.ContextAck:
|
case event.ContextAck:
|
||||||
pa.OnAcknowledgement(pa.connection.Hostname(), peerMessage.ID)
|
pa.OnAcknowledgement(pa.connection.Hostname(), peerMessage.ID)
|
||||||
|
case event.ContextGetVal:
|
||||||
req, ok := pa.RequestMapLookup(pa.connection.Hostname(), peerMessage.ID)
|
req, ok := pa.RequestMapLookup(pa.connection.Hostname(), peerMessage.ID)
|
||||||
if ok {
|
if ok {
|
||||||
pa.RetValHandler(pa.connection.Hostname(), []byte(req), peerMessage.Data)
|
pa.RetValHandler(pa.connection.Hostname(), []byte(req), peerMessage.Data)
|
||||||
|
|
Loading…
Reference in New Issue