in Sources/NIOHTTP2/ConnectionStateMachine/ConnectionStateMachine.swift [1389:1443]
mutating func sendWindowUpdate(streamID: HTTP2StreamID, windowIncrement: UInt32) -> StateMachineResultWithEffect {
switch self.state {
case .prefaceSent(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.sendWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .prefaceSent(state)
return result
}
case .active(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.sendWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .active(state)
return result
}
case .quiescingPrefaceSent(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.sendWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .quiescingPrefaceSent(state)
return result
}
case .locallyQuiesced(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.sendWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .locallyQuiesced(state)
return result
}
case .remotelyQuiesced(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.sendWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .remotelyQuiesced(state)
return result
}
case .bothQuiescing(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.sendWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .bothQuiescing(state)
return result
}
case .idle, .prefaceReceived, .quiescingPrefaceReceived:
// We're waiting for the preface.
return .init(result: .connectionError(underlyingError: NIOHTTP2Errors.missingPreface(), type: .protocolError), effect: nil)
case .fullyQuiesced:
return .init(result: .connectionError(underlyingError: NIOHTTP2Errors.ioOnClosedConnection(), type: .protocolError), effect: nil)
case .modifying:
preconditionFailure("Must not be left in modifying state")
}
}