From 62c6242840cc605e4ed0988b4fe552ae25161b4d Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Wed, 25 Feb 2015 17:13:52 +0000 Subject: [PATCH] remove dead code --- router/local_peer.go | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/router/local_peer.go b/router/local_peer.go index 3d532378..10fe70ed 100644 --- a/router/local_peer.go +++ b/router/local_peer.go @@ -120,7 +120,6 @@ const ( PAddConnection = iota PConnectionEstablished PDeleteConnection - PSendProtocolMsg ) // Sync. @@ -148,13 +147,6 @@ func (peer *LocalPeer) DeleteConnection(conn *LocalConnection) { <-resultChan } -// Async. -func (peer *LocalPeer) SendProtocolMsg(m ProtocolMsg) { - peer.queryChan <- &PeerInteraction{ - Interaction: Interaction{code: PSendProtocolMsg}, - payload: m} -} - // ACTOR server func (peer *LocalPeer) queryLoop(queryChan <-chan *PeerInteraction) { @@ -183,8 +175,6 @@ func (peer *LocalPeer) queryLoop(queryChan <-chan *PeerInteraction) { conn.log("connection deleted") } query.resultChan <- nil - case PSendProtocolMsg: - peer.handleSendProtocolMsg(query.payload.(ProtocolMsg)) } case <-gossipTimer: peer.Router.SendAllGossip() @@ -263,12 +253,6 @@ func (peer *LocalPeer) handleDeleteConnection(conn Connection) bool { return true } -func (peer *LocalPeer) handleSendProtocolMsg(m ProtocolMsg) { - peer.ForEachConnection(func(_ PeerName, conn Connection) { - conn.(ProtocolSender).SendProtocolMsg(m) - }) -} - func (peer *LocalPeer) broadcastPeerUpdate(peers ...*Peer) { peer.Router.Routes.Recalculate() // TODO We should just be invoking TopologyGossip.GossipBroadcast