vacp2p/mvds
1
0
Fork 0
mirror of https://github.com/vacp2p/mvds.git synced 2026-01-09 12:07:55 -05:00
Code Issues Packages Projects Releases 22 Wiki Activity

updated

Browse Source
This commit is contained in:
decanus
2019-06-10 10:39:41 -07:00
parent ffd8e7843b
commit 6fd11bc7da
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
node.go
View File

@@ -233,18 +233,18 @@ func (n *Node) onRequest(group GroupID, sender PeerID, msg protobuf.Request) []*
continue
}
// @todo this should only be added when we retransmit messages, we don't wanna resend offers imo if they have been requested
//s, err := n.syncState.Get(group, id, sender)
//if err != nil {
// log.Printf("error (%s) getting sync state group: %x id: %x peer: %x", err.Error(), group[:4], id[:4], sender[:4])
// continue
//}
//
//err = n.syncState.Set(group, id, sender, n.updateSendEpoch(s))
//if err != nil {
// log.Printf("error (%s) setting sync state group: %x id: %x peer: %x", err.Error(), group[:4], id[:4], sender[:4])
// continue
//}
// @todo this probably change the sync state to retransmit messages rather than offers
s, err := n.syncState.Get(group, id, sender)
if err != nil {
log.Printf("error (%s) getting sync state group: %x id: %x peer: %x", err.Error(), group[:4], id[:4], sender[:4])
continue
}
err = n.syncState.Set(group, id, sender, n.updateSendEpoch(s))
if err != nil {
log.Printf("error (%s) setting sync state group: %x id: %x peer: %x", err.Error(), group[:4], id[:4], sender[:4])
continue
}
m = append(m, &message)