From e52daf1a39889b5bf45084da558064dcf8a535d7 Mon Sep 17 00:00:00 2001 From: Andy Wang Date: Wed, 8 Apr 2020 15:13:49 +0100 Subject: [PATCH] Set defaults properly --- internal/multiplex/session.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/multiplex/session.go b/internal/multiplex/session.go index 4cbb847..e16f90c 100644 --- a/internal/multiplex/session.go +++ b/internal/multiplex/session.go @@ -72,20 +72,20 @@ func MakeSession(id uint32, config SessionConfig) *Session { sesh.addrs.Store([]net.Addr{nil, nil}) if config.Valve == nil { - config.Valve = UNLIMITED_VALVE + sesh.Valve = UNLIMITED_VALVE } if config.SendBufferSize <= 0 { - config.SendBufferSize = defaultSendRecvBufSize + sesh.SendBufferSize = defaultSendRecvBufSize } if config.ReceiveBufferSize <= 0 { - config.ReceiveBufferSize = defaultSendRecvBufSize + sesh.ReceiveBufferSize = defaultSendRecvBufSize } sbConfig := switchboardConfig{ - Valve: config.Valve, - recvBufferSize: config.ReceiveBufferSize, + Valve: sesh.Valve, + recvBufferSize: sesh.ReceiveBufferSize, } - if config.Unordered { + if sesh.Unordered { log.Debug("Connection is unordered") sbConfig.strategy = UNIFORM_SPREAD } else {