in Sources/NIOHTTP2/ConnectionStateMachine/ConnectionStateMachine.swift [1332:1386]
mutating func receiveWindowUpdate(streamID: HTTP2StreamID, windowIncrement: UInt32) -> StateMachineResultWithEffect {
switch self.state {
case .prefaceReceived(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.receiveWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .prefaceReceived(state)
return result
}
case .active(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.receiveWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .active(state)
return result
}
case .quiescingPrefaceReceived(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.receiveWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .quiescingPrefaceReceived(state)
return result
}
case .locallyQuiesced(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.receiveWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .locallyQuiesced(state)
return result
}
case .remotelyQuiesced(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.receiveWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .remotelyQuiesced(state)
return result
}
case .bothQuiescing(var state):
return self.avoidingStateMachineCoW { newState in
let result = state.receiveWindowUpdate(streamID: streamID, increment: windowIncrement)
newState = .bothQuiescing(state)
return result
}
case .idle, .prefaceSent, .quiescingPrefaceSent:
// 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")
}
}