remove dead code

This commit is contained in:
Matthias Radestock committed 2015-02-25 17:13:52 +00:00
1 parent eafe17255b
commit 62c6242840
1 file changed
-16
-16
View File
@@ -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