mirror of
https://github.com/hanzokv/go.git
synced 2026-09-24 00:31:51 +00:00
chore: remove unused queue channel from ConnPool (#3826)
This commit is contained in:
@@ -388,7 +388,6 @@ type ConnPool struct {
|
||||
dialErrorsNum uint32 // atomic
|
||||
lastDialError atomic.Value
|
||||
|
||||
queue chan struct{}
|
||||
dialsInProgress chan struct{}
|
||||
dialsQueue *wantConnQueue
|
||||
// Fast semaphore for connection limiting with eventual fairness
|
||||
@@ -420,7 +419,6 @@ func NewConnPool(opt *Options) *ConnPool {
|
||||
p := &ConnPool{
|
||||
cfg: opt,
|
||||
semaphore: internal.NewFastSemaphore(opt.PoolSize),
|
||||
queue: make(chan struct{}, opt.PoolSize),
|
||||
conns: make(map[uint64]*Conn),
|
||||
dialsInProgress: make(chan struct{}, opt.MaxConcurrentDials),
|
||||
dialsQueue: newWantConnQueue(),
|
||||
|
||||
Reference in New Issue
Block a user