scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-10 07:01:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove leftover Receive() method from gossip implementation

Browse source
This commit is contained in:
Travis 2017-04-20 15:14:11 -05:00
parent 95bd4913c8
commit a4921ac55a
No known key found for this signature in database
GPG key ID: 7F08008DFD9314C9
1 changed files with 1 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
gossip/gossip.go
View file

@ -154,13 +154,6 @@ func (g *GossipNodeSet) SendAsync(pb proto.Message) error {
return nil
}
func (g *GossipNodeSet) Receive(pb proto.Message) error {
if err := g.handler.ReceiveMessage(pb); err != nil {
return err
}
return nil
}
// implementation of the memberlist.Delegate interface
func (g *GossipNodeSet) NodeMeta(limit int) []byte {
return []byte{}
@ -172,7 +165,7 @@ func (g *GossipNodeSet) NotifyMsg(b []byte) {
g.logger().Printf("unmarshal message error: %s", err)
return
}
if err := g.Receive(m); err != nil {
if err := g.handler.ReceiveMessage(m); err != nil {
g.logger().Printf("receive message error: %s", err)
return
}