[GH-ISSUE #329] 源代码中看不到创建连接池 #243

New issue

Closed

opened 2026-05-05 12:02:15 -06:00 by gitea-mirror · 5 comments

gitea-mirror commented

2026-05-05 12:02:15 -06:00

Owner

Originally created by @FunTCode on GitHub (May 22, 2017).
Original GitHub issue: https://github.com/fatedier/frp/issues/329

connectionPoolManager函数里只看到往ctlMsgChan放入1，到看不到frps向frpc发送请求，代码如下：

// check if we need more work connections and send messages to frpc to get more
time.Sleep(time.Duration(2) * time.Second)
select {
// if the channel closed, it means the proxy is closed, so just return
case <-closeCh:
log.Info("ProxyName [%s], connectionPoolManager exit", p.Name)
return
default:
curWorkConnNum := int64(len(p.workConnChan))
diff := p.PoolCount - curWorkConnNum
if diff > 0 {
if diff < p.PoolCount/5 {
diff = p.PoolCount4/5 + 1
} else if diff < p.PoolCount/2 {
diff = p.PoolCount/4 + 1
} else if diff < p.PoolCount4/5 {
diff = p.PoolCount/5 + 1
} else {
diff = p.PoolCount/10 + 1
}
if diff+curWorkConnNum > p.PoolCount {
diff = p.PoolCount - curWorkConnNum
}
for i := 0; i < int(diff); i++ {
p.ctlMsgChan <- 1
}

Originally created by @FunTCode on GitHub (May 22, 2017). Original GitHub issue: https://github.com/fatedier/frp/issues/329 connectionPoolManager函数里只看到往ctlMsgChan放入1，到看不到frps向frpc发送请求，代码如下： // check if we need more work connections and send messages to frpc to get more time.Sleep(time.Duration(2) * time.Second) select { // if the channel closed, it means the proxy is closed, so just return case <-closeCh: log.Info("ProxyName [%s], connectionPoolManager exit", p.Name) return default: curWorkConnNum := int64(len(p.workConnChan)) diff := p.PoolCount - curWorkConnNum if diff > 0 { if diff < p.PoolCount/5 { diff = p.PoolCount*4/5 + 1 } else if diff < p.PoolCount/2 { diff = p.PoolCount/4 + 1 } else if diff < p.PoolCount*4/5 { diff = p.PoolCount/5 + 1 } else { diff = p.PoolCount/10 + 1 } if diff+curWorkConnNum > p.PoolCount { diff = p.PoolCount - curWorkConnNum } for i := 0; i < int(diff); i++ { p.ctlMsgChan <- 1 }