Map logging
This commit is contained in:
parent
8e9ed132d8
commit
902b759e81
|
@ -89,6 +89,7 @@ func (pa *PeerApp) listen() {
|
||||||
case event.ContextAck:
|
case event.ContextAck:
|
||||||
pa.OnAcknowledgement(pa.connection.Hostname(), peerMessage.ID)
|
pa.OnAcknowledgement(pa.connection.Hostname(), peerMessage.ID)
|
||||||
case event.ContextRetVal:
|
case event.ContextRetVal:
|
||||||
|
log.Infof("Loading from map %x", pa.getValRequests)
|
||||||
req, ok := pa.getValRequests.Load(peerMessage.ID)
|
req, ok := pa.getValRequests.Load(peerMessage.ID)
|
||||||
if ok {
|
if ok {
|
||||||
reqStr := []byte(req.(string))
|
reqStr := []byte(req.(string))
|
||||||
|
@ -112,6 +113,7 @@ func (pa *PeerApp) listen() {
|
||||||
// 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) error {
|
func (pa *PeerApp) SendMessage(message model2.PeerMessage) error {
|
||||||
if message.Context == event.ContextGetVal {
|
if message.Context == event.ContextGetVal {
|
||||||
|
log.Infof("Saving to map %x", pa.getValRequests)
|
||||||
pa.getValRequests.Store(message.ID, string(message.Data))
|
pa.getValRequests.Store(message.ID, string(message.Data))
|
||||||
// sync map is apparently not guaranteed to be consistent
|
// sync map is apparently not guaranteed to be consistent
|
||||||
_, ok := pa.getValRequests.Load(message.ID)
|
_, ok := pa.getValRequests.Load(message.ID)
|
||||||
|
|
Loading…
Reference in New Issue