mirror of
https://github.com/swift-server/async-http-client.git
synced 2026-06-02 07:37:34 +00:00
Fabian FettandGitHub
897d49aa1b
SwiftNIO 2.42.0 has deprecated Lock and replaced it with a new NIOLock. This commit removes all uses of Lock and replaces them with NIOLock. Further, now, we must require SwiftNIO 2.42.0
62 lines
2.2 KiB
Swift
62 lines
2.2 KiB
Swift
//===----------------------------------------------------------------------===//
|
|
//
|
|
// This source file is part of the AsyncHTTPClient open source project
|
|
//
|
|
// Copyright (c) 2021 Apple Inc. and the AsyncHTTPClient project authors
|
|
// Licensed under Apache License v2.0
|
|
//
|
|
// See LICENSE.txt for license information
|
|
// See CONTRIBUTORS.txt for the list of AsyncHTTPClient project authors
|
|
//
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
//
|
|
//===----------------------------------------------------------------------===//
|
|
|
|
import Dispatch
|
|
import Logging
|
|
import NIOConcurrencyHelpers
|
|
import NIOCore
|
|
import NIOSSL
|
|
|
|
final class SSLContextCache {
|
|
private let lock = NIOLock()
|
|
private var sslContextCache = LRUCache<BestEffortHashableTLSConfiguration, NIOSSLContext>()
|
|
private let offloadQueue = DispatchQueue(label: "io.github.swift-server.AsyncHTTPClient.SSLContextCache")
|
|
}
|
|
|
|
extension SSLContextCache {
|
|
func sslContext(tlsConfiguration: TLSConfiguration,
|
|
eventLoop: EventLoop,
|
|
logger: Logger) -> EventLoopFuture<NIOSSLContext> {
|
|
let eqTLSConfiguration = BestEffortHashableTLSConfiguration(wrapping: tlsConfiguration)
|
|
let sslContext = self.lock.withLock {
|
|
self.sslContextCache.find(key: eqTLSConfiguration)
|
|
}
|
|
|
|
if let sslContext = sslContext {
|
|
logger.trace("found SSL context in cache",
|
|
metadata: ["ahc-tls-config": "\(tlsConfiguration)"])
|
|
return eventLoop.makeSucceededFuture(sslContext)
|
|
}
|
|
|
|
logger.trace("creating new SSL context",
|
|
metadata: ["ahc-tls-config": "\(tlsConfiguration)"])
|
|
let newSSLContext = self.offloadQueue.asyncWithFuture(eventLoop: eventLoop) {
|
|
try NIOSSLContext(configuration: tlsConfiguration)
|
|
}
|
|
|
|
newSSLContext.whenSuccess { (newSSLContext: NIOSSLContext) -> Void in
|
|
self.lock.withLock { () -> Void in
|
|
self.sslContextCache.append(key: eqTLSConfiguration,
|
|
value: newSSLContext)
|
|
}
|
|
}
|
|
|
|
return newSSLContext
|
|
}
|
|
}
|
|
|
|
#if swift(>=5.5) && canImport(_Concurrency)
|
|
extension SSLContextCache: @unchecked Sendable {}
|
|
#endif
|