From b1308823d202bf7646bb1c33603fb4366b8926b8 Mon Sep 17 00:00:00 2001 From: David Wragg Date: Tue, 19 May 2015 11:14:45 +0100 Subject: [PATCH] Eliminate the LocalPeer Start method --- router/local_peer.go | 11 ++++++----- router/router.go | 1 - 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/router/local_peer.go b/router/local_peer.go index 0a15076d..b9ea939b 100644 --- a/router/local_peer.go +++ b/router/local_peer.go @@ -18,13 +18,14 @@ type LocalPeer struct { type LocalPeerAction func() func NewLocalPeer(name PeerName, nickName string, router *Router) *LocalPeer { - return &LocalPeer{Peer: NewPeer(name, nickName, 0, 0), router: router} -} - -func (peer *LocalPeer) Start() { actionChan := make(chan LocalPeerAction, ChannelSize) - peer.actionChan = actionChan + peer := &LocalPeer{ + Peer: NewPeer(name, nickName, 0, 0), + router: router, + actionChan: actionChan, + } go peer.actorLoop(actionChan) + return peer } func (peer *LocalPeer) Forward(dstPeer *Peer, df bool, frame []byte, dec *EthernetDecoder) error { diff --git a/router/router.go b/router/router.go index 01446322..13203bfc 100644 --- a/router/router.go +++ b/router/router.go @@ -83,7 +83,6 @@ func (router *Router) Start() { po, err = NewPcapO(router.Iface.Name) checkFatal(err) } - router.Ourself.Start() router.Routes.Start() router.ConnectionMaker.Start() router.UDPListener = router.listenUDP(router.Port, po)