swift-server/async-http-client
1
0
Fork 0
mirror of https://github.com/swift-server/async-http-client.git synced 2026-06-02 07:37:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Switch over state in HTTPConnectionPool.HTTP2StateMachine.failedToCreateNewConnection (#647)

Browse Source
This commit is contained in:
David Nadoba
2022-11-09 15:30:16 +01:00
committed by GitHub
parent fd03ed01c7
commit 5bee16a799
3 changed files with 61 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Sources/AsyncHTTPClient/ConnectionPool/State Machine/HTTPConnectionPool+HTTP2StateMachine.swift
+22 -13
View File
@@ -404,25 +404,34 @@ extension HTTPConnectionPool {
}
mutating func failedToCreateNewConnection(_ error: Error, connectionID: Connection.ID) -> Action {
// TODO: switch over state https://github.com/swift-server/async-http-client/issues/638
self.failedConsecutiveConnectionAttempts += 1
self.lastConnectFailure = error
guard self.retryConnectionEstablishment else {
guard let (index, _) = self.connections.failConnection(connectionID) else {
switch self.lifecycleState {
case .running:
guard self.retryConnectionEstablishment else {
guard let (index, _) = self.connections.failConnection(connectionID) else {
preconditionFailure("A connection attempt failed, that the state machine knows nothing about. Somewhere state was lost.")
}
self.connections.removeConnection(at: index)
return .init(
request: self.failAllRequests(reason: error),
connection: .none
)
}
let eventLoop = self.connections.backoffNextConnectionAttempt(connectionID)
let backoff = calculateBackoff(failedAttempt: self.failedConsecutiveConnectionAttempts)
return .init(request: .none, connection: .scheduleBackoffTimer(connectionID, backoff: backoff, on: eventLoop))
case .shuttingDown:
guard let (index, context) = self.connections.failConnection(connectionID) else {
preconditionFailure("A connection attempt failed, that the state machine knows nothing about. Somewhere state was lost.")
}
self.connections.removeConnection(at: index)
return .init(
request: self.failAllRequests(reason: error),
connection: .none
)
return self.nextActionForFailedConnection(at: index, on: context.eventLoop)
case .shutDown:
preconditionFailure("If the pool is already shutdown, all connections must have been torn down.")
}
let eventLoop = self.connections.backoffNextConnectionAttempt(connectionID)
let backoff = calculateBackoff(failedAttempt: self.failedConsecutiveConnectionAttempts)
return .init(request: .none, connection: .scheduleBackoffTimer(connectionID, backoff: backoff, on: eventLoop))
}
mutating func waitingForConnectivity(_ error: Error, connectionID: Connection.ID) -> Action {