We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f08b1a6 commit 43df969Copy full SHA for 43df969
1 file changed
Sources/ClickHouseVapor/Application+ClickHouseNIO.swift
@@ -87,12 +87,13 @@ extension Application {
87
}
88
89
internal var pool: EventLoopGroupConnectionPool<ClickHouseConfiguration> {
90
+ let lock = self.application.locks.lock(for: PoolKey.self)
91
+ lock.lock()
92
+ defer { lock.unlock() }
93
+
94
if let existing = self.application.storage[PoolKey.self] {
95
return existing
96
} else {
- let lock = self.application.locks.lock(for: PoolKey.self)
- lock.lock()
- defer { lock.unlock() }
97
guard let configuration = self.configuration else {
98
fatalError("ClickHouse not configured. Use app.clickHouse.configuration = ...")
99
0 commit comments