let max_pool_count valid
@@ -137,6 +137,10 @@ func NewControl(rc *controller.ResourceController, pxyManager *proxy.ProxyManage
statsCollector stats.Collector, ctlConn net.Conn, loginMsg *msg.Login,
serverCfg config.ServerCommonConf) *Control {
+ poolCount := loginMsg.PoolCount
+ if poolCount > int(serverCfg.MaxPoolCount) {
+ poolCount = int(serverCfg.MaxPoolCount)
+ }
return &Control{
rc: rc,
pxyManager: pxyManager,
@@ -145,9 +149,9 @@ func NewControl(rc *controller.ResourceController, pxyManager *proxy.ProxyManage
loginMsg: loginMsg,
sendCh: make(chan msg.Message, 10),
readCh: make(chan msg.Message, 10),
- workConnCh: make(chan net.Conn, loginMsg.PoolCount+10),
+ workConnCh: make(chan net.Conn, poolCount+10),
proxies: make(map[string]proxy.Proxy),
- poolCount: loginMsg.PoolCount,
+ poolCount: poolCount,
portsUsedNum: 0,
lastPing: time.Now(),
runId: loginMsg.RunId,
