(code)
| 54045 | this[kSocket][kError] = err; |
| 54046 | onError(this[kClient], err); |
| 54047 | } |
| 54048 | } |
| 54049 | function onHttp2SessionEnd() { |
| 54050 | util4.destroy(this, new SocketError("other side closed")); |
| 54051 | util4.destroy(this[kSocket], new SocketError("other side closed")); |
| 54052 | } |
| 54053 | function onHTTP2GoAway(code) { |
| 54054 | const client = this[kClient]; |
| 54055 | const err = new InformationalError(`HTTP/2: "GOAWAY" frame received with code ${code}`); |
| 54056 | client[kSocket] = null; |
| 54057 | client[kHTTP2Session] = null; |
| 54058 | if (client.destroyed) { |
| 54059 | assert2(this[kPending] === 0); |
| 54060 | const requests = client[kQueue].splice(client[kRunningIdx]); |
| 54061 | for (let i3 = 0; i3 < requests.length; i3++) { |
| 54062 | const request3 = requests[i3]; |
| 54063 | errorRequest(this, request3, err); |
| 54064 | } |
| 54065 | } else if (client[kRunning] > 0) { |
| 54066 | const request3 = client[kQueue][client[kRunningIdx]]; |
| 54067 | client[kQueue][client[kRunningIdx]++] = null; |
| 54068 | errorRequest(client, request3, err); |
| 54069 | } |
| 54070 | client[kPendingIdx] = client[kRunningIdx]; |
| 54071 | assert2(client[kRunning] === 0); |
| 54072 | client.emit( |
| 54073 | "disconnect", |
| 54074 | client[kUrl], |
| 54075 | [client], |
| 54076 | err |
nothing calls this directly
no test coverage detected
searching dependent graphs…