From 6cda74d49fbb54fb61d2e9491bd441c5fff69518 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Sat, 4 Apr 2015 15:36:42 +0100 Subject: [PATCH] refactor: inline --- router/gossip.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/router/gossip.go b/router/gossip.go index ada37663..d683e22e 100644 --- a/router/gossip.go +++ b/router/gossip.go @@ -201,7 +201,8 @@ func (c *GossipChannel) sendGossipDown(conn Connection, data GossipData) { sender, found := c.senders[conn] if !found { sender = NewGossipSender(func(pending GossipData) { - conn.(ProtocolSender).SendProtocolMsg(c.gossipMsg(pending.Encode())) + protocolMsg := ProtocolMsg{ProtocolGossip, GobEncode(c.hash, c.ourself.Name, pending.Encode())} + conn.(ProtocolSender).SendProtocolMsg(protocolMsg) }) c.senders[conn] = sender sender.Start() @@ -209,10 +210,6 @@ func (c *GossipChannel) sendGossipDown(conn Connection, data GossipData) { sender.Send(data) } -func (c *GossipChannel) gossipMsg(buf []byte) ProtocolMsg { - return ProtocolMsg{ProtocolGossip, GobEncode(c.hash, c.ourself.Name, buf)} -} - func (c *GossipChannel) GossipUnicast(dstPeerName PeerName, buf []byte) error { return c.relayGossipUnicast(dstPeerName, GobEncode(c.hash, c.ourself.Name, dstPeerName, buf)) }