package okhttp3.internal.http2; import h.i; import h.x.d.h; import h.x.d.k; import i.b0; import i.d0; import java.io.IOException; import java.net.ProtocolException; import java.util.ArrayList; import java.util.List; import java.util.Locale; import java.util.concurrent.TimeUnit; import okhttp3.Headers; import okhttp3.OkHttpClient; import okhttp3.Protocol; import okhttp3.Request; import okhttp3.Response; import okhttp3.internal.Util; import okhttp3.internal.connection.RealConnection; import okhttp3.internal.http.ExchangeCodec; import okhttp3.internal.http.HttpHeaders; import okhttp3.internal.http.RealInterceptorChain; import okhttp3.internal.http.RequestLine; import okhttp3.internal.http.StatusLine; /* JADX INFO: compiled from: Http2ExchangeCodec.kt */ /* JADX INFO: loaded from: classes.dex */ @i(bv = {1, 0, 3}, d1 = {"\u0000x\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\u0018\u0000 62\u00020\u0001:\u00016B'\u0012\u0006\u00103\u001a\u000202\u0012\u0006\u0010%\u001a\u00020$\u0012\u0006\u0010\"\u001a\u00020!\u0012\u0006\u0010*\u001a\u00020)¢\u0006\u0004\b4\u00105J\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004J\u001f\u0010\n\u001a\u00020\t2\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\n\u0010\u000bJ\u000f\u0010\f\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\f\u0010\u0004J\u000f\u0010\r\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\r\u0010\u0004J\u0017\u0010\u0011\u001a\u00020\u00102\u0006\u0010\u000f\u001a\u00020\u000eH\u0016¢\u0006\u0004\b\u0011\u0010\u0012J\u0019\u0010\u0016\u001a\u0004\u0018\u00010\u00152\u0006\u0010\u0014\u001a\u00020\u0013H\u0016¢\u0006\u0004\b\u0016\u0010\u0017J\u0017\u0010\u0018\u001a\u00020\u00072\u0006\u0010\u000f\u001a\u00020\u000eH\u0016¢\u0006\u0004\b\u0018\u0010\u0019J\u000f\u0010\u001b\u001a\u00020\u001aH\u0016¢\u0006\u0004\b\u001b\u0010\u001cJ\u0017\u0010\u001d\u001a\u00020\u00022\u0006\u0010\u0006\u001a\u00020\u0005H\u0016¢\u0006\u0004\b\u001d\u0010\u001eR\u0016\u0010\u001f\u001a\u00020\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u001f\u0010 R\u0016\u0010\"\u001a\u00020!8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\"\u0010#R\u001c\u0010%\u001a\u00020$8\u0016@\u0016X\u0096\u0004¢\u0006\f\n\u0004\b%\u0010&\u001a\u0004\b'\u0010(R\u0016\u0010*\u001a\u00020)8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b*\u0010+R\u0016\u0010-\u001a\u00020,8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b-\u0010.R\u0018\u00100\u001a\u0004\u0018\u00010/8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b0\u00101¨\u00067"}, d2 = {"Lokhttp3/internal/http2/Http2ExchangeCodec;", "Lokhttp3/internal/http/ExchangeCodec;", "", "cancel", "()V", "Lokhttp3/Request;", "request", "", "contentLength", "Lokio/Sink;", "createRequestBody", "(Lokhttp3/Request;J)Lokio/Sink;", "finishRequest", "flushRequest", "Lokhttp3/Response;", "response", "Lokio/Source;", "openResponseBodySource", "(Lokhttp3/Response;)Lokio/Source;", "", "expectContinue", "Lokhttp3/Response$Builder;", "readResponseHeaders", "(Z)Lokhttp3/Response$Builder;", "reportedContentLength", "(Lokhttp3/Response;)J", "Lokhttp3/Headers;", "trailers", "()Lokhttp3/Headers;", "writeRequestHeaders", "(Lokhttp3/Request;)V", "canceled", "Z", "Lokhttp3/internal/http/RealInterceptorChain;", "chain", "Lokhttp3/internal/http/RealInterceptorChain;", "Lokhttp3/internal/connection/RealConnection;", Http2ExchangeCodec.CONNECTION, "Lokhttp3/internal/connection/RealConnection;", "getConnection", "()Lokhttp3/internal/connection/RealConnection;", "Lokhttp3/internal/http2/Http2Connection;", "http2Connection", "Lokhttp3/internal/http2/Http2Connection;", "Lokhttp3/Protocol;", "protocol", "Lokhttp3/Protocol;", "Lokhttp3/internal/http2/Http2Stream;", "stream", "Lokhttp3/internal/http2/Http2Stream;", "Lokhttp3/OkHttpClient;", "client", "", "(Lokhttp3/OkHttpClient;Lokhttp3/internal/connection/RealConnection;Lokhttp3/internal/http/RealInterceptorChain;Lokhttp3/internal/http2/Http2Connection;)V", "Companion", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class Http2ExchangeCodec implements ExchangeCodec { private volatile boolean canceled; private final RealInterceptorChain chain; private final RealConnection connection; private final Http2Connection http2Connection; private final Protocol protocol; private volatile Http2Stream stream; public static final Companion Companion = new Companion(null); private static final String CONNECTION = "connection"; private static final String HOST = "host"; private static final String KEEP_ALIVE = "keep-alive"; private static final String PROXY_CONNECTION = "proxy-connection"; private static final String TE = "te"; private static final String TRANSFER_ENCODING = "transfer-encoding"; private static final String ENCODING = "encoding"; private static final String UPGRADE = "upgrade"; private static final List HTTP_2_SKIPPED_REQUEST_HEADERS = Util.immutableListOf(CONNECTION, HOST, KEEP_ALIVE, PROXY_CONNECTION, TE, TRANSFER_ENCODING, ENCODING, UPGRADE, Header.TARGET_METHOD_UTF8, Header.TARGET_PATH_UTF8, Header.TARGET_SCHEME_UTF8, Header.TARGET_AUTHORITY_UTF8); private static final List HTTP_2_SKIPPED_RESPONSE_HEADERS = Util.immutableListOf(CONNECTION, HOST, KEEP_ALIVE, PROXY_CONNECTION, TE, TRANSFER_ENCODING, ENCODING, UPGRADE); /* JADX INFO: compiled from: Http2ExchangeCodec.kt */ @i(bv = {1, 0, 3}, d1 = {"\u00002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u000f\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\u001b\u0010\u001cJ\u001b\u0010\u0005\u001a\b\u0012\u0004\u0012\u00020\u00040\u00032\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0005\u0010\u0006J\u001d\u0010\f\u001a\u00020\u000b2\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010\n\u001a\u00020\t¢\u0006\u0004\b\f\u0010\rR\u0016\u0010\u000f\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u000f\u0010\u0010R\u0016\u0010\u0011\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0011\u0010\u0010R\u0016\u0010\u0012\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0012\u0010\u0010R\u001c\u0010\u0013\u001a\b\u0012\u0004\u0012\u00020\u000e0\u00038\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014R\u001c\u0010\u0015\u001a\b\u0012\u0004\u0012\u00020\u000e0\u00038\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0015\u0010\u0014R\u0016\u0010\u0016\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0016\u0010\u0010R\u0016\u0010\u0017\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0017\u0010\u0010R\u0016\u0010\u0018\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0018\u0010\u0010R\u0016\u0010\u0019\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0019\u0010\u0010R\u0016\u0010\u001a\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u001a\u0010\u0010¨\u0006\u001d"}, d2 = {"Lokhttp3/internal/http2/Http2ExchangeCodec$Companion;", "Lokhttp3/Request;", "request", "", "Lokhttp3/internal/http2/Header;", "http2HeadersList", "(Lokhttp3/Request;)Ljava/util/List;", "Lokhttp3/Headers;", "headerBlock", "Lokhttp3/Protocol;", "protocol", "Lokhttp3/Response$Builder;", "readHttp2HeadersList", "(Lokhttp3/Headers;Lokhttp3/Protocol;)Lokhttp3/Response$Builder;", "", "CONNECTION", "Ljava/lang/String;", "ENCODING", "HOST", "HTTP_2_SKIPPED_REQUEST_HEADERS", "Ljava/util/List;", "HTTP_2_SKIPPED_RESPONSE_HEADERS", "KEEP_ALIVE", "PROXY_CONNECTION", "TE", "TRANSFER_ENCODING", "UPGRADE", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Companion { private Companion() { } public final List
http2HeadersList(Request request) { k.d(request, "request"); Headers headers = request.headers(); ArrayList arrayList = new ArrayList(headers.size() + 4); arrayList.add(new Header(Header.TARGET_METHOD, request.method())); arrayList.add(new Header(Header.TARGET_PATH, RequestLine.INSTANCE.requestPath(request.url()))); String strHeader = request.header("Host"); if (strHeader != null) { arrayList.add(new Header(Header.TARGET_AUTHORITY, strHeader)); } arrayList.add(new Header(Header.TARGET_SCHEME, request.url().scheme())); int size = headers.size(); for (int i2 = 0; i2 < size; i2++) { String strName = headers.name(i2); Locale locale = Locale.US; k.c(locale, "Locale.US"); if (strName == null) { throw new NullPointerException("null cannot be cast to non-null type java.lang.String"); } String lowerCase = strName.toLowerCase(locale); k.c(lowerCase, "(this as java.lang.String).toLowerCase(locale)"); if (!Http2ExchangeCodec.HTTP_2_SKIPPED_REQUEST_HEADERS.contains(lowerCase) || (k.a(lowerCase, Http2ExchangeCodec.TE) && k.a(headers.value(i2), "trailers"))) { arrayList.add(new Header(lowerCase, headers.value(i2))); } } return arrayList; } public final Response.Builder readHttp2HeadersList(Headers headers, Protocol protocol) throws IOException { k.d(headers, "headerBlock"); k.d(protocol, "protocol"); Headers.Builder builder = new Headers.Builder(); int size = headers.size(); StatusLine statusLine = null; for (int i2 = 0; i2 < size; i2++) { String strName = headers.name(i2); String strValue = headers.value(i2); if (k.a(strName, Header.RESPONSE_STATUS_UTF8)) { statusLine = StatusLine.Companion.parse("HTTP/1.1 " + strValue); } else if (!Http2ExchangeCodec.HTTP_2_SKIPPED_RESPONSE_HEADERS.contains(strName)) { builder.addLenient$okhttp(strName, strValue); } } if (statusLine != null) { return new Response.Builder().protocol(protocol).code(statusLine.code).message(statusLine.message).headers(builder.build()); } throw new ProtocolException("Expected ':status' header not present"); } public /* synthetic */ Companion(h hVar) { this(); } } public Http2ExchangeCodec(OkHttpClient okHttpClient, RealConnection realConnection, RealInterceptorChain realInterceptorChain, Http2Connection http2Connection) { k.d(okHttpClient, "client"); k.d(realConnection, CONNECTION); k.d(realInterceptorChain, "chain"); k.d(http2Connection, "http2Connection"); this.connection = realConnection; this.chain = realInterceptorChain; this.http2Connection = http2Connection; this.protocol = okHttpClient.protocols().contains(Protocol.H2_PRIOR_KNOWLEDGE) ? Protocol.H2_PRIOR_KNOWLEDGE : Protocol.HTTP_2; } @Override // okhttp3.internal.http.ExchangeCodec public void cancel() { this.canceled = true; Http2Stream http2Stream = this.stream; if (http2Stream != null) { http2Stream.closeLater(ErrorCode.CANCEL); } } @Override // okhttp3.internal.http.ExchangeCodec public b0 createRequestBody(Request request, long j2) { k.d(request, "request"); Http2Stream http2Stream = this.stream; k.b(http2Stream); return http2Stream.getSink(); } @Override // okhttp3.internal.http.ExchangeCodec public void finishRequest() throws IOException { Http2Stream http2Stream = this.stream; k.b(http2Stream); http2Stream.getSink().close(); } @Override // okhttp3.internal.http.ExchangeCodec public void flushRequest() throws IOException { this.http2Connection.flush(); } @Override // okhttp3.internal.http.ExchangeCodec public RealConnection getConnection() { return this.connection; } @Override // okhttp3.internal.http.ExchangeCodec public d0 openResponseBodySource(Response response) { k.d(response, "response"); Http2Stream http2Stream = this.stream; k.b(http2Stream); return http2Stream.getSource$okhttp(); } @Override // okhttp3.internal.http.ExchangeCodec public Response.Builder readResponseHeaders(boolean z) throws IOException { Http2Stream http2Stream = this.stream; k.b(http2Stream); Response.Builder http2HeadersList = Companion.readHttp2HeadersList(http2Stream.takeHeaders(), this.protocol); if (z && http2HeadersList.getCode$okhttp() == 100) { return null; } return http2HeadersList; } @Override // okhttp3.internal.http.ExchangeCodec public long reportedContentLength(Response response) { k.d(response, "response"); if (HttpHeaders.promisesBody(response)) { return Util.headersContentLength(response); } return 0L; } @Override // okhttp3.internal.http.ExchangeCodec public Headers trailers() { Http2Stream http2Stream = this.stream; k.b(http2Stream); return http2Stream.trailers(); } @Override // okhttp3.internal.http.ExchangeCodec public void writeRequestHeaders(Request request) throws IOException { k.d(request, "request"); if (this.stream != null) { return; } this.stream = this.http2Connection.newStream(Companion.http2HeadersList(request), request.body() != null); if (this.canceled) { Http2Stream http2Stream = this.stream; k.b(http2Stream); http2Stream.closeLater(ErrorCode.CANCEL); throw new IOException("Canceled"); } Http2Stream http2Stream2 = this.stream; k.b(http2Stream2); http2Stream2.readTimeout().timeout(this.chain.getReadTimeoutMillis$okhttp(), TimeUnit.MILLISECONDS); Http2Stream http2Stream3 = this.stream; k.b(http2Stream3); http2Stream3.writeTimeout().timeout(this.chain.getWriteTimeoutMillis$okhttp(), TimeUnit.MILLISECONDS); } }