From 956707ca86b80cd9d9109776ae99d31246b564c8 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Wed, 14 Jan 2015 18:44:18 +0000 Subject: [PATCH] cosmetic --- router/connection.go | 40 ++++++++++++++++++++-------------------- 1 file changed, 20 insertions(+), 20 deletions(-) diff --git a/router/connection.go b/router/connection.go index 3b367fae..eb340726 100644 --- a/router/connection.go +++ b/router/connection.go @@ -247,27 +247,27 @@ func (conn *LocalConnection) handleSetEstablished() error { old := conn.established conn.established = true conn.Unlock() - if !old { - conn.Router.Ourself.ConnectionEstablished(conn) - if err := conn.ensureForwarders(); err != nil { - return err - } - stopTicker(conn.heartbeat) - conn.heartbeat = time.NewTicker(SlowHeartbeat) - conn.fetchAll = time.NewTicker(FetchAllInterval) - conn.fragTest = time.NewTicker(FragTestInterval) - conn.forwardHeartbeatFrame() // avoid initial wait - // Send a large frame down the DF channel in order to prompt - // PMTU discovery to start. - conn.Forward(true, &ForwardedFrame{ - srcPeer: conn.local, - dstPeer: conn.remote, - frame: PMTUDiscovery}, - nil) - conn.setStackFrag(false) - return conn.handleSendTCP(ProtocolStartFragmentationTestByte) + if old { + return nil } - return nil + conn.Router.Ourself.ConnectionEstablished(conn) + if err := conn.ensureForwarders(); err != nil { + return err + } + stopTicker(conn.heartbeat) + conn.heartbeat = time.NewTicker(SlowHeartbeat) + conn.fetchAll = time.NewTicker(FetchAllInterval) + conn.fragTest = time.NewTicker(FragTestInterval) + conn.forwardHeartbeatFrame() // avoid initial wait + // Send a large frame down the DF channel in order to prompt + // PMTU discovery to start. + conn.Forward(true, &ForwardedFrame{ + srcPeer: conn.local, + dstPeer: conn.remote, + frame: PMTUDiscovery}, + nil) + conn.setStackFrag(false) + return conn.handleSendTCP(ProtocolStartFragmentationTestByte) } func (conn *LocalConnection) handleSendTCP(msg []byte) error {