Skip to content

Commit ff4ae88

Browse files
committed
Important fix!
1 parent ac76fa0 commit ff4ae88

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Sources/ConnectionPoolModule/ConnectionPoolManager.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,10 +139,10 @@ public final class ConnectionPoolManager<
139139
public func leaseConnection(_ request: Request) {
140140
if let executorID = Executor.getExecutorID(), let pool = self.pools[executorID] {
141141
pool.leaseConnection(request)
142+
return
142143
}
143144

144145
let index = self.roundRobinCounter.loadThenWrappingIncrement(ordering: .relaxed) % self.roundRobinPools.count
145-
146146
self.roundRobinPools[index].leaseConnection(request)
147147
}
148148

0 commit comments

Comments
 (0)