head:HTTPRequestHead,

metadata:RequestFramingMetadata

guard case.idle=self.stateelse{

switchself.state{

case.initialized,.closing,.inRequest:

// These states are unreachable as the connection pool state machine has put the

// connection into these states. In other words the connection pool state machine must

// be aware about these states before the connection itself. For this reason the

// connection pool state machine must not send a new request to the connection, if the

// connection is `.initialized`, `.closing` or `.inRequest`

preconditionFailure("Invalid state:\(self.state)")

varrequestStateMachine=HTTPRequestStateMachine(isChannelWritable:self.isChannelWritable)

letaction= requestStateMachine.startRequest(head: head, metadata: metadata)

case.closed:

// The remote may have closed the connection and the connection pool state machine

// was not updated yet because of a race condition. New request vs. marking connection

// as closed.

//

// TODO: AHC should support a fast rescheduling mechanism here.

return.failRequest(HTTPClientError.remoteConnectionClosed,.none)

case.idle:

varrequestStateMachine=HTTPRequestStateMachine(isChannelWritable:self.isChannelWritable)

letaction= requestStateMachine.startRequest(head: head, metadata: metadata)

// by default we assume a persistent connection. however in `requestVerified`, we read the

// "connection" header.

self.state=.inRequest(requestStateMachine, close: metadata.connectionClose)

returnself.state.modify(with: action)

// by default we assume a persistent connection. however in `requestVerified`, we read the

// "connection" header.

self.state=.inRequest(requestStateMachine, close: metadata.connectionClose)

returnself.state.modify(with: action)

case.modifying:

preconditionFailure("Invalid state:\(self.state)")

mutatingfunc requestStreamPartReceived(_ part:IOData)->Action{

("testConnectionIsClosedIfErrorHappensWhileInRequest", testConnectionIsClosedIfErrorHappensWhileInRequest),

("testConnectionIsClosedAfterSwitchingProtocols", testConnectionIsClosedAfterSwitchingProtocols),

("testWeDontCrashAfterEarlyHintsAndConnectionClose", testWeDontCrashAfterEarlyHintsAndConnectionClose),

("testWeDontCrashInRaceBetweenSchedulingNewRequestAndConnectionClose", testWeDontCrashInRaceBetweenSchedulingNewRequestAndConnectionClose),

XCTAssertEqual(state.channelRead(.head(responseHead)),.wait)

XCTAssertEqual(state.channelInactive(),.failRequest(HTTPClientError.remoteConnectionClosed,.none))

func testWeDontCrashInRaceBetweenSchedulingNewRequestAndConnectionClose(){

XCTAssertEqual(state.channelActive(isWritable:true),.fireChannelActive)

XCTAssertEqual(state.channelInactive(),.fireChannelInactive)

letrequestHead=HTTPRequestHead(version:.http1_1, method:.GET, uri:"/")

letmetadata=RequestFramingMetadata(connectionClose:false, body:.fixedSize(0))

letnewRequestAction= state.runNewRequest(head: requestHead, metadata: metadata)

guard case.failRequest(let error,.none)= newRequestActionelse{

XCTAssertEqual(erroras?HTTPClientError,.remoteConnectionClosed)