diff --git a/p2p/connection.go b/p2p/connection.go index 30452e49d..9fcb9831f 100644 --- a/p2p/connection.go +++ b/p2p/connection.go @@ -129,11 +129,11 @@ func NewMConnection(conn net.Conn, chDescs []*ChannelDescriptor, onReceive recei func (c *MConnection) AfterStart() { c.quit = make(chan struct{}) - go c.sendRoutine() - go c.recvRoutine() c.flushTimer = NewThrottleTimer("flush", flushThrottleMS*time.Millisecond) c.pingTimer = NewRepeatTimer("ping", pingTimeoutSeconds*time.Second) c.chStatsTimer = NewRepeatTimer("chStats", updateStatsSeconds*time.Second) + go c.sendRoutine() + go c.recvRoutine() } func (c *MConnection) AfterStop() {