Skip to content

Commit

Permalink
disable sending bundle message to maintain compatibility
Browse files Browse the repository at this point in the history
  • Loading branch information
cedricfung committed Sep 13, 2022
1 parent 58232e1 commit 91ff824
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions network/peer.go
Original file line number Diff line number Diff line change
Expand Up @@ -335,13 +335,11 @@ func (me *Peer) openPeerStream(p *Peer, resend *ChanMsg) (*ChanMsg, error) {
me.snapshotsCaches.store(msgs[0].key, time.Now())
}
} else {
data := buildBundleMessage(msgs)
err := client.Send(data)
if err != nil {
key := crypto.NewHash(data)
return &ChanMsg{key[:], data}, err
}
for _, msg := range msgs {
err := client.Send(msg.data)
if err != nil {
return msg, err
}
if msg.key != nil {
me.snapshotsCaches.store(msg.key, time.Now())
}
Expand Down

0 comments on commit 91ff824

Please sign in to comment.