Matthias Radestock
dc9f8762ca
This is mostly a matter of moving some files, changing package names, changing some imports, and changing some type references. We duplicate the odd constant & global var, and the intmac/macint functions, since neither 'router' or 'mesh' nor, really,' common' are a natural home for them.
42 lines
964 B
Go
42 lines
964 B
Go
package mesh
|
|
|
|
type SurrogateGossipData struct {
|
|
messages [][]byte
|
|
}
|
|
|
|
func NewSurrogateGossipData(msg []byte) *SurrogateGossipData {
|
|
return &SurrogateGossipData{messages: [][]byte{msg}}
|
|
}
|
|
|
|
func (d *SurrogateGossipData) Encode() [][]byte {
|
|
return d.messages
|
|
}
|
|
|
|
func (d *SurrogateGossipData) Merge(other GossipData) {
|
|
d.messages = append(d.messages, other.(*SurrogateGossipData).messages...)
|
|
}
|
|
|
|
// SurrogateGossiper ignores unicasts and relays broadcasts and gossips.
|
|
|
|
type SurrogateGossiper struct{}
|
|
|
|
func (*SurrogateGossiper) OnGossipUnicast(sender PeerName, msg []byte) error {
|
|
return nil
|
|
}
|
|
|
|
func (*SurrogateGossiper) OnGossipBroadcast(_ PeerName, update []byte) (GossipData, error) {
|
|
return NewSurrogateGossipData(update), nil
|
|
}
|
|
|
|
func (*SurrogateGossiper) Gossip() GossipData {
|
|
return nil
|
|
}
|
|
|
|
func (*SurrogateGossiper) OnGossip(update []byte) (GossipData, error) {
|
|
return NewSurrogateGossipData(update), nil
|
|
}
|
|
|
|
var (
|
|
surrogateGossiper SurrogateGossiper
|
|
)
|