package okhttp3.internal.http2; import androidx.media3.exoplayer.rtsp.SessionDescription; import com.google.android.gms.measurement.internal.u1; import com.pichillilorenzo.flutter_inappwebview_android.credential_database.URLProtectionSpaceContract; import java.io.Closeable; import java.io.IOException; import java.io.InterruptedIOException; import java.net.Socket; import java.util.LinkedHashMap; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; import kd.e; import kotlin.Metadata; import kotlin.jvm.JvmField; import kotlin.jvm.JvmOverloads; import kotlin.jvm.internal.Ref$IntRef; import kotlin.jvm.internal.Ref$ObjectRef; import kotlin.jvm.internal.SourceDebugExtension; import kotlin.jvm.internal.d; import nb.g; import okhttp3.internal.Util; import okhttp3.internal.concurrent.Task; import okhttp3.internal.concurrent.TaskQueue; import okhttp3.internal.concurrent.TaskRunner; import okhttp3.internal.http2.Http2Reader; import okhttp3.internal.platform.Platform; import okio.Buffer; import okio.BufferedSink; import okio.BufferedSource; import okio.ByteString; import okio.Okio; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import sd.a; import tv.danmaku.ijk.media.player.IjkMediaMeta; import xyz.stream.download.config.InnerConstant; /* JADX INFO: loaded from: classes.dex */ @Metadata(d1 = {"\u0000¸\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0016\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010%\n\u0002\b\u0004\n\u0002\u0010\u000e\n\u0002\b\u000f\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u001c\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010#\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\b\u0018\u0000 ²\u00012\u00020\u0001:\b³\u0001²\u0001´\u0001µ\u0001B\u0015\b\u0000\u0012\b\u0010¯\u0001\u001a\u00030®\u0001¢\u0006\u0006\b°\u0001\u0010±\u0001J\u0006\u0010\u0003\u001a\u00020\u0002J\u0010\u0010\u0006\u001a\u0004\u0018\u00010\u00052\u0006\u0010\u0004\u001a\u00020\u0002J\u0019\u0010\n\u001a\u0004\u0018\u00010\u00052\u0006\u0010\u0007\u001a\u00020\u0002H\u0000¢\u0006\u0004\b\b\u0010\tJ\u0017\u0010\u0010\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0000¢\u0006\u0004\b\u000e\u0010\u000fJ$\u0010\u0017\u001a\u00020\u00052\u0006\u0010\u0011\u001a\u00020\u00022\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u00130\u00122\u0006\u0010\u0016\u001a\u00020\u0015J\u001c\u0010\u0018\u001a\u00020\u00052\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u00130\u00122\u0006\u0010\u0016\u001a\u00020\u0015J-\u0010\u001d\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010\u0019\u001a\u00020\u00152\f\u0010\u001a\u001a\b\u0012\u0004\u0012\u00020\u00130\u0012H\u0000¢\u0006\u0004\b\u001b\u0010\u001cJ(\u0010!\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010\u0019\u001a\u00020\u00152\b\u0010\u001f\u001a\u0004\u0018\u00010\u001e2\u0006\u0010 \u001a\u00020\u000bJ\u001f\u0010&\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010#\u001a\u00020\"H\u0000¢\u0006\u0004\b$\u0010%J\u001f\u0010)\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010'\u001a\u00020\"H\u0000¢\u0006\u0004\b(\u0010%J\u001f\u0010-\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010*\u001a\u00020\u000bH\u0000¢\u0006\u0004\b+\u0010,J\u001e\u00101\u001a\u00020\r2\u0006\u0010.\u001a\u00020\u00152\u0006\u0010/\u001a\u00020\u00022\u0006\u00100\u001a\u00020\u0002J\u0006\u00102\u001a\u00020\rJ\u0006\u00101\u001a\u00020\rJ\u0006\u00103\u001a\u00020\rJ\u0006\u00104\u001a\u00020\rJ\u000e\u00105\u001a\u00020\r2\u0006\u0010'\u001a\u00020\"J\b\u00106\u001a\u00020\rH\u0016J)\u00106\u001a\u00020\r2\u0006\u00107\u001a\u00020\"2\u0006\u00108\u001a\u00020\"2\b\u0010:\u001a\u0004\u0018\u000109H\u0000¢\u0006\u0004\b;\u0010H\u0007J\u000e\u0010C\u001a\u00020\r2\u0006\u0010B\u001a\u00020AJ\u000e\u0010E\u001a\u00020\u00152\u0006\u0010D\u001a\u00020\u000bJ\u000f\u0010H\u001a\u00020\rH\u0000¢\u0006\u0004\bF\u0010GJ\u0017\u0010K\u001a\u00020\u00152\u0006\u0010\u0007\u001a\u00020\u0002H\u0000¢\u0006\u0004\bI\u0010JJ%\u0010N\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u00130\u0012H\u0000¢\u0006\u0004\bL\u0010MJ-\u0010R\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u00130\u00122\u0006\u0010O\u001a\u00020\u0015H\u0000¢\u0006\u0004\bP\u0010QJ/\u0010W\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010T\u001a\u00020S2\u0006\u0010 \u001a\u00020\u00022\u0006\u0010O\u001a\u00020\u0015H\u0000¢\u0006\u0004\bU\u0010VJ\u001f\u0010Y\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00022\u0006\u0010#\u001a\u00020\"H\u0000¢\u0006\u0004\bX\u0010%J&\u0010\u0018\u001a\u00020\u00052\u0006\u0010\u0011\u001a\u00020\u00022\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u00130\u00122\u0006\u0010\u0016\u001a\u00020\u0015H\u0002J\u0012\u0010[\u001a\u00020\r2\b\u0010Z\u001a\u0004\u0018\u000109H\u0002R\u001a\u0010\\\u001a\u00020\u00158\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\\\u0010]\u001a\u0004\b^\u0010_R\u001a\u0010a\u001a\u00020`8\u0000X\u0080\u0004¢\u0006\f\n\u0004\ba\u0010b\u001a\u0004\bc\u0010dR&\u0010f\u001a\u000e\u0012\u0004\u0012\u00020\u0002\u0012\u0004\u0012\u00020\u00050e8\u0000X\u0080\u0004¢\u0006\f\n\u0004\bf\u0010g\u001a\u0004\bh\u0010iR\u001a\u0010k\u001a\u00020j8\u0000X\u0080\u0004¢\u0006\f\n\u0004\bk\u0010l\u001a\u0004\bm\u0010nR\"\u0010o\u001a\u00020\u00028\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bo\u0010p\u001a\u0004\bq\u0010r\"\u0004\bs\u0010tR\"\u0010u\u001a\u00020\u00028\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bu\u0010p\u001a\u0004\bv\u0010r\"\u0004\bw\u0010tR\u0016\u0010x\u001a\u00020\u00158\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bx\u0010]R\u0014\u0010?\u001a\u00020>8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b?\u0010yR\u0014\u0010{\u001a\u00020z8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b{\u0010|R\u0014\u0010}\u001a\u00020z8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b}\u0010|R\u0014\u0010~\u001a\u00020z8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b~\u0010|R\u0017\u0010\u0080\u0001\u001a\u00020\u007f8\u0002X\u0082\u0004¢\u0006\b\n\u0006\b\u0080\u0001\u0010\u0081\u0001R\u0019\u0010\u0082\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0082\u0001\u0010\u0083\u0001R\u0019\u0010\u0084\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0084\u0001\u0010\u0083\u0001R\u0019\u0010\u0085\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0085\u0001\u0010\u0083\u0001R\u0019\u0010\u0086\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0086\u0001\u0010\u0083\u0001R\u0019\u0010\u0087\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0087\u0001\u0010\u0083\u0001R\u0019\u0010\u0088\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0088\u0001\u0010\u0083\u0001R\u0019\u0010\u0089\u0001\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0089\u0001\u0010\u0083\u0001R\u001c\u0010\u008a\u0001\u001a\u00020A8\u0006¢\u0006\u0010\n\u0006\b\u008a\u0001\u0010\u008b\u0001\u001a\u0006\b\u008c\u0001\u0010\u008d\u0001R)\u0010\u008e\u0001\u001a\u00020A8\u0006@\u0006X\u0086\u000e¢\u0006\u0018\n\u0006\b\u008e\u0001\u0010\u008b\u0001\u001a\u0006\b\u008f\u0001\u0010\u008d\u0001\"\u0006\b\u0090\u0001\u0010\u0091\u0001R*\u0010\u0093\u0001\u001a\u00020\u000b2\u0007\u0010\u0092\u0001\u001a\u00020\u000b8\u0006@BX\u0086\u000e¢\u0006\u0010\n\u0006\b\u0093\u0001\u0010\u0083\u0001\u001a\u0006\b\u0094\u0001\u0010\u0095\u0001R*\u0010\u0096\u0001\u001a\u00020\u000b2\u0007\u0010\u0092\u0001\u001a\u00020\u000b8\u0006@BX\u0086\u000e¢\u0006\u0010\n\u0006\b\u0096\u0001\u0010\u0083\u0001\u001a\u0006\b\u0097\u0001\u0010\u0095\u0001R*\u0010\u0098\u0001\u001a\u00020\u000b2\u0007\u0010\u0092\u0001\u001a\u00020\u000b8\u0006@BX\u0086\u000e¢\u0006\u0010\n\u0006\b\u0098\u0001\u0010\u0083\u0001\u001a\u0006\b\u0099\u0001\u0010\u0095\u0001R*\u0010\u009a\u0001\u001a\u00020\u000b2\u0007\u0010\u0092\u0001\u001a\u00020\u000b8\u0006@BX\u0086\u000e¢\u0006\u0010\n\u0006\b\u009a\u0001\u0010\u0083\u0001\u001a\u0006\b\u009b\u0001\u0010\u0095\u0001R \u0010\u009d\u0001\u001a\u00030\u009c\u00018\u0000X\u0080\u0004¢\u0006\u0010\n\u0006\b\u009d\u0001\u0010\u009e\u0001\u001a\u0006\b\u009f\u0001\u0010 \u0001R\u001d\u0010¢\u0001\u001a\u00030¡\u00018\u0006¢\u0006\u0010\n\u0006\b¢\u0001\u0010£\u0001\u001a\u0006\b¤\u0001\u0010¥\u0001R!\u0010§\u0001\u001a\u00070¦\u0001R\u00020\u00008\u0006¢\u0006\u0010\n\u0006\b§\u0001\u0010¨\u0001\u001a\u0006\b©\u0001\u0010ª\u0001R\u001e\u0010¬\u0001\u001a\t\u0012\u0004\u0012\u00020\u00020«\u00018\u0002X\u0082\u0004¢\u0006\b\n\u0006\b¬\u0001\u0010\u00ad\u0001¨\u0006¶\u0001"}, d2 = {"Lokhttp3/internal/http2/Http2Connection;", "Ljava/io/Closeable;", "", "openStreamCount", InnerConstant.Db.f36069id, "Lokhttp3/internal/http2/Http2Stream;", "getStream", "streamId", "removeStream$okhttp", "(I)Lokhttp3/internal/http2/Http2Stream;", "removeStream", "", "read", "Lkd/e;", "updateConnectionFlowControl$okhttp", "(J)V", "updateConnectionFlowControl", "associatedStreamId", "", "Lokhttp3/internal/http2/Header;", "requestHeaders", "", "out", "pushStream", "newStream", "outFinished", "alternating", "writeHeaders$okhttp", "(IZLjava/util/List;)V", "writeHeaders", "Lokio/Buffer;", "buffer", "byteCount", "writeData", "Lokhttp3/internal/http2/ErrorCode;", "errorCode", "writeSynResetLater$okhttp", "(ILokhttp3/internal/http2/ErrorCode;)V", "writeSynResetLater", "statusCode", "writeSynReset$okhttp", "writeSynReset", "unacknowledgedBytesRead", "writeWindowUpdateLater$okhttp", "(IJ)V", "writeWindowUpdateLater", "reply", "payload1", "payload2", "writePing", "writePingAndAwaitPong", "awaitPong", "flush", "shutdown", "close", "connectionCode", "streamCode", "Ljava/io/IOException;", "cause", "close$okhttp", "(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V", "sendConnectionPreface", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "start", "Lokhttp3/internal/http2/Settings;", "settings", "setSettings", "nowNs", "isHealthy", "sendDegradedPingLater$okhttp", "()V", "sendDegradedPingLater", "pushedStream$okhttp", "(I)Z", "pushedStream", "pushRequestLater$okhttp", "(ILjava/util/List;)V", "pushRequestLater", "inFinished", "pushHeadersLater$okhttp", "(ILjava/util/List;Z)V", "pushHeadersLater", "Lokio/BufferedSource;", "source", "pushDataLater$okhttp", "(ILokio/BufferedSource;IZ)V", "pushDataLater", "pushResetLater$okhttp", "pushResetLater", "e", "failConnection", "client", "Z", "getClient$okhttp", "()Z", "Lokhttp3/internal/http2/Http2Connection$Listener;", "listener", "Lokhttp3/internal/http2/Http2Connection$Listener;", "getListener$okhttp", "()Lokhttp3/internal/http2/Http2Connection$Listener;", "", IjkMediaMeta.IJKM_KEY_STREAMS, "Ljava/util/Map;", "getStreams$okhttp", "()Ljava/util/Map;", "", "connectionName", "Ljava/lang/String;", "getConnectionName$okhttp", "()Ljava/lang/String;", "lastGoodStreamId", "I", "getLastGoodStreamId$okhttp", "()I", "setLastGoodStreamId$okhttp", "(I)V", "nextStreamId", "getNextStreamId$okhttp", "setNextStreamId$okhttp", "isShutdown", "Lokhttp3/internal/concurrent/TaskRunner;", "Lokhttp3/internal/concurrent/TaskQueue;", "writerQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "pushQueue", "settingsListenerQueue", "Lokhttp3/internal/http2/PushObserver;", "pushObserver", "Lokhttp3/internal/http2/PushObserver;", "intervalPingsSent", "J", "intervalPongsReceived", "degradedPingsSent", "degradedPongsReceived", "awaitPingsSent", "awaitPongsReceived", "degradedPongDeadlineNs", "okHttpSettings", "Lokhttp3/internal/http2/Settings;", "getOkHttpSettings", "()Lokhttp3/internal/http2/Settings;", "peerSettings", "getPeerSettings", "setPeerSettings", "(Lokhttp3/internal/http2/Settings;)V", "", "readBytesTotal", "getReadBytesTotal", "()J", "readBytesAcknowledged", "getReadBytesAcknowledged", "writeBytesTotal", "getWriteBytesTotal", "writeBytesMaximum", "getWriteBytesMaximum", "Ljava/net/Socket;", "socket", "Ljava/net/Socket;", "getSocket$okhttp", "()Ljava/net/Socket;", "Lokhttp3/internal/http2/Http2Writer;", "writer", "Lokhttp3/internal/http2/Http2Writer;", "getWriter", "()Lokhttp3/internal/http2/Http2Writer;", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "readerRunnable", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "getReaderRunnable", "()Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "", "currentPushRequests", "Ljava/util/Set;", "Lokhttp3/internal/http2/Http2Connection$Builder;", "builder", "", "(Lokhttp3/internal/http2/Http2Connection$Builder;)V", "Companion", "Builder", "Listener", "ReaderRunnable", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nHttp2Connection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection\n+ 2 TaskQueue.kt\nokhttp3/internal/concurrent/TaskQueue\n+ 3 Util.kt\nokhttp3/internal/Util\n+ 4 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 5 ArraysJVM.kt\nkotlin/collections/ArraysKt__ArraysJVMKt\n+ 6 _Arrays.kt\nkotlin/collections/ArraysKt___ArraysKt\n*L\n1#1,1006:1\n84#2,4:1007\n90#2,13:1014\n90#2,13:1027\n90#2,13:1069\n90#2,13:1082\n90#2,13:1095\n90#2,13:1108\n90#2,13:1121\n90#2,13:1134\n563#3:1011\n557#3:1013\n557#3:1040\n615#3,4:1041\n402#3,5:1045\n402#3,5:1053\n402#3,5:1059\n402#3,5:1064\n1#4:1012\n37#5,2:1050\n13309#6:1052\n13310#6:1058\n*S KotlinDebug\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection\n*L\n152#1:1007,4\n340#1:1014,13\n361#1:1027,13\n506#1:1069,13\n554#1:1082,13\n893#1:1095,13\n911#1:1108,13\n938#1:1121,13\n952#1:1134,13\n183#1:1011\n319#1:1013\n402#1:1040\n446#1:1041,4\n448#1:1045,5\n461#1:1053,5\n467#1:1059,5\n472#1:1064,5\n455#1:1050,2\n460#1:1052\n460#1:1058\n*E\n"}) public final class Http2Connection implements Closeable { public static final int AWAIT_PING = 3; /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */ @NotNull public static final Companion INSTANCE = new Companion(null); @NotNull private static final Settings DEFAULT_SETTINGS; public static final int DEGRADED_PING = 2; public static final int DEGRADED_PONG_TIMEOUT_NS = 1000000000; public static final int INTERVAL_PING = 1; public static final int OKHTTP_CLIENT_WINDOW_SIZE = 16777216; private long awaitPingsSent; private long awaitPongsReceived; private final boolean client; @NotNull private final String connectionName; @NotNull private final Set currentPushRequests; private long degradedPingsSent; private long degradedPongDeadlineNs; private long degradedPongsReceived; private long intervalPingsSent; private long intervalPongsReceived; private boolean isShutdown; private int lastGoodStreamId; @NotNull private final Listener listener; private int nextStreamId; @NotNull private final Settings okHttpSettings; @NotNull private Settings peerSettings; @NotNull private final PushObserver pushObserver; @NotNull private final TaskQueue pushQueue; private long readBytesAcknowledged; private long readBytesTotal; @NotNull private final ReaderRunnable readerRunnable; @NotNull private final TaskQueue settingsListenerQueue; @NotNull private final Socket socket; @NotNull private final Map streams; @NotNull private final TaskRunner taskRunner; private long writeBytesMaximum; private long writeBytesTotal; @NotNull private final Http2Writer writer; @NotNull private final TaskQueue writerQueue; @Metadata(d1 = {"\u0000X\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\u000e\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\b\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0002\u0018\u00002\u00020\u0001B\u0015\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006J\u0006\u00107\u001a\u000208J\u000e\u0010\u0011\u001a\u00020\u00002\u0006\u0010\u0011\u001a\u00020\u0012J\u000e\u0010\u0017\u001a\u00020\u00002\u0006\u0010\u0017\u001a\u00020\u0018J\u000e\u0010\u001d\u001a\u00020\u00002\u0006\u0010\u001d\u001a\u00020\u001eJ.\u0010)\u001a\u00020\u00002\u0006\u0010)\u001a\u00020*2\b\b\u0002\u00109\u001a\u00020\f2\b\b\u0002\u0010/\u001a\u0002002\b\b\u0002\u0010#\u001a\u00020$H\u0007R\u001a\u0010\u0002\u001a\u00020\u0003X\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0007\u0010\b\"\u0004\b\t\u0010\nR\u001a\u0010\u000b\u001a\u00020\fX\u0080.¢\u0006\u000e\n\u0000\u001a\u0004\b\r\u0010\u000e\"\u0004\b\u000f\u0010\u0010R\u001a\u0010\u0011\u001a\u00020\u0012X\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0013\u0010\u0014\"\u0004\b\u0015\u0010\u0016R\u001a\u0010\u0017\u001a\u00020\u0018X\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0019\u0010\u001a\"\u0004\b\u001b\u0010\u001cR\u001a\u0010\u001d\u001a\u00020\u001eX\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u001f\u0010 \"\u0004\b!\u0010\"R\u001a\u0010#\u001a\u00020$X\u0080.¢\u0006\u000e\n\u0000\u001a\u0004\b%\u0010&\"\u0004\b'\u0010(R\u001a\u0010)\u001a\u00020*X\u0080.¢\u0006\u000e\n\u0000\u001a\u0004\b+\u0010,\"\u0004\b-\u0010.R\u001a\u0010/\u001a\u000200X\u0080.¢\u0006\u000e\n\u0000\u001a\u0004\b1\u00102\"\u0004\b3\u00104R\u0014\u0010\u0004\u001a\u00020\u0005X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b5\u00106¨\u0006:"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Builder;", "", "client", "", "taskRunner", "Lokhttp3/internal/concurrent/TaskRunner;", "(ZLokhttp3/internal/concurrent/TaskRunner;)V", "getClient$okhttp", "()Z", "setClient$okhttp", "(Z)V", "connectionName", "", "getConnectionName$okhttp", "()Ljava/lang/String;", "setConnectionName$okhttp", "(Ljava/lang/String;)V", "listener", "Lokhttp3/internal/http2/Http2Connection$Listener;", "getListener$okhttp", "()Lokhttp3/internal/http2/Http2Connection$Listener;", "setListener$okhttp", "(Lokhttp3/internal/http2/Http2Connection$Listener;)V", "pingIntervalMillis", "", "getPingIntervalMillis$okhttp", "()I", "setPingIntervalMillis$okhttp", "(I)V", "pushObserver", "Lokhttp3/internal/http2/PushObserver;", "getPushObserver$okhttp", "()Lokhttp3/internal/http2/PushObserver;", "setPushObserver$okhttp", "(Lokhttp3/internal/http2/PushObserver;)V", "sink", "Lokio/BufferedSink;", "getSink$okhttp", "()Lokio/BufferedSink;", "setSink$okhttp", "(Lokio/BufferedSink;)V", "socket", "Ljava/net/Socket;", "getSocket$okhttp", "()Ljava/net/Socket;", "setSocket$okhttp", "(Ljava/net/Socket;)V", "source", "Lokio/BufferedSource;", "getSource$okhttp", "()Lokio/BufferedSource;", "setSource$okhttp", "(Lokio/BufferedSource;)V", "getTaskRunner$okhttp", "()Lokhttp3/internal/concurrent/TaskRunner;", "build", "Lokhttp3/internal/http2/Http2Connection;", "peerName", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class Builder { private boolean client; public String connectionName; @NotNull private Listener listener; private int pingIntervalMillis; @NotNull private PushObserver pushObserver; public BufferedSink sink; public Socket socket; public BufferedSource source; @NotNull private final TaskRunner taskRunner; public Builder(boolean z10, @NotNull TaskRunner taskRunner) { g.i(taskRunner, "taskRunner"); this.client = z10; this.taskRunner = taskRunner; this.listener = Listener.REFUSE_INCOMING_STREAMS; this.pushObserver = PushObserver.CANCEL; } public static /* synthetic */ Builder socket$default(Builder builder, Socket socket, String str, BufferedSource bufferedSource, BufferedSink bufferedSink, int i10, Object obj) throws IOException { if ((i10 & 2) != 0) { str = Util.peerName(socket); } if ((i10 & 4) != 0) { bufferedSource = Okio.buffer(Okio.source(socket)); } if ((i10 & 8) != 0) { bufferedSink = Okio.buffer(Okio.sink(socket)); } return builder.socket(socket, str, bufferedSource, bufferedSink); } @NotNull public final Http2Connection build() { return new Http2Connection(this); } /* JADX INFO: renamed from: getClient$okhttp, reason: from getter */ public final boolean getClient() { return this.client; } @NotNull public final String getConnectionName$okhttp() { String str = this.connectionName; if (str != null) { return str; } g.U("connectionName"); throw null; } @NotNull /* JADX INFO: renamed from: getListener$okhttp, reason: from getter */ public final Listener getListener() { return this.listener; } /* JADX INFO: renamed from: getPingIntervalMillis$okhttp, reason: from getter */ public final int getPingIntervalMillis() { return this.pingIntervalMillis; } @NotNull /* JADX INFO: renamed from: getPushObserver$okhttp, reason: from getter */ public final PushObserver getPushObserver() { return this.pushObserver; } @NotNull public final BufferedSink getSink$okhttp() { BufferedSink bufferedSink = this.sink; if (bufferedSink != null) { return bufferedSink; } g.U("sink"); throw null; } @NotNull public final Socket getSocket$okhttp() { Socket socket = this.socket; if (socket != null) { return socket; } g.U("socket"); throw null; } @NotNull public final BufferedSource getSource$okhttp() { BufferedSource bufferedSource = this.source; if (bufferedSource != null) { return bufferedSource; } g.U("source"); throw null; } @NotNull /* JADX INFO: renamed from: getTaskRunner$okhttp, reason: from getter */ public final TaskRunner getTaskRunner() { return this.taskRunner; } @NotNull public final Builder listener(@NotNull Listener listener) { g.i(listener, "listener"); this.listener = listener; return this; } @NotNull public final Builder pingIntervalMillis(int pingIntervalMillis) { this.pingIntervalMillis = pingIntervalMillis; return this; } @NotNull public final Builder pushObserver(@NotNull PushObserver pushObserver) { g.i(pushObserver, "pushObserver"); this.pushObserver = pushObserver; return this; } public final void setClient$okhttp(boolean z10) { this.client = z10; } public final void setConnectionName$okhttp(@NotNull String str) { g.i(str, ""); this.connectionName = str; } public final void setListener$okhttp(@NotNull Listener listener) { g.i(listener, ""); this.listener = listener; } public final void setPingIntervalMillis$okhttp(int i10) { this.pingIntervalMillis = i10; } public final void setPushObserver$okhttp(@NotNull PushObserver pushObserver) { g.i(pushObserver, ""); this.pushObserver = pushObserver; } public final void setSink$okhttp(@NotNull BufferedSink bufferedSink) { g.i(bufferedSink, ""); this.sink = bufferedSink; } public final void setSocket$okhttp(@NotNull Socket socket) { g.i(socket, ""); this.socket = socket; } public final void setSource$okhttp(@NotNull BufferedSource bufferedSource) { g.i(bufferedSource, ""); this.source = bufferedSource; } @JvmOverloads @NotNull public final Builder socket(@NotNull Socket socket) throws IOException { g.i(socket, "socket"); return socket$default(this, socket, null, null, null, 14, null); } @JvmOverloads @NotNull public final Builder socket(@NotNull Socket socket, @NotNull String str) throws IOException { g.i(socket, "socket"); g.i(str, "peerName"); return socket$default(this, socket, str, null, null, 12, null); } @JvmOverloads @NotNull public final Builder socket(@NotNull Socket socket, @NotNull String str, @NotNull BufferedSource bufferedSource) throws IOException { g.i(socket, "socket"); g.i(str, "peerName"); g.i(bufferedSource, "source"); return socket$default(this, socket, str, bufferedSource, null, 8, null); } @JvmOverloads @NotNull public final Builder socket(@NotNull Socket socket, @NotNull String peerName, @NotNull BufferedSource source, @NotNull BufferedSink sink) throws IOException { String strConcat; g.i(socket, "socket"); g.i(peerName, "peerName"); g.i(source, "source"); g.i(sink, "sink"); setSocket$okhttp(socket); if (this.client) { strConcat = Util.okHttpName + ' ' + peerName; } else { strConcat = "MockWebServer ".concat(peerName); } setConnectionName$okhttp(strConcat); setSource$okhttp(source); setSink$okhttp(sink); return this; } } @Metadata(d1 = {"\u0000\u001a\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0086\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002R\u000e\u0010\u0003\u001a\u00020\u0004X\u0086T¢\u0006\u0002\n\u0000R\u0011\u0010\u0005\u001a\u00020\u0006¢\u0006\b\n\u0000\u001a\u0004\b\u0007\u0010\bR\u000e\u0010\t\u001a\u00020\u0004X\u0086T¢\u0006\u0002\n\u0000R\u000e\u0010\n\u001a\u00020\u0004X\u0086T¢\u0006\u0002\n\u0000R\u000e\u0010\u000b\u001a\u00020\u0004X\u0086T¢\u0006\u0002\n\u0000R\u000e\u0010\f\u001a\u00020\u0004X\u0086T¢\u0006\u0002\n\u0000¨\u0006\r"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Companion;", "", "()V", "AWAIT_PING", "", "DEFAULT_SETTINGS", "Lokhttp3/internal/http2/Settings;", "getDEFAULT_SETTINGS", "()Lokhttp3/internal/http2/Settings;", "DEGRADED_PING", "DEGRADED_PONG_TIMEOUT_NS", "INTERVAL_PING", "OKHTTP_CLIENT_WINDOW_SIZE", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class Companion { private Companion() { } public /* synthetic */ Companion(d dVar) { this(); } @NotNull public final Settings getDEFAULT_SETTINGS() { return Http2Connection.DEFAULT_SETTINGS; } } @Metadata(d1 = {"\u0000\"\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\b&\u0018\u0000 \r2\u00020\u0001:\u0001\rB\u0007¢\u0006\u0004\b\u000b\u0010\fJ\u0010\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H&J\u0018\u0010\n\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\bH\u0016¨\u0006\u000e"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Listener;", "", "Lokhttp3/internal/http2/Http2Stream;", "stream", "Lkd/e;", "onStream", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Settings;", "settings", "onSettings", "", "()V", "Companion", "okhttp"}, k = 1, mv = {1, 8, 0}) public static abstract class Listener { @JvmField @NotNull public static final Listener REFUSE_INCOMING_STREAMS = new Listener() { // from class: okhttp3.internal.http2.Http2Connection$Listener$Companion$REFUSE_INCOMING_STREAMS$1 @Override // okhttp3.internal.http2.Http2Connection.Listener public void onStream(@NotNull Http2Stream http2Stream) throws IOException { g.i(http2Stream, "stream"); http2Stream.close(ErrorCode.REFUSED_STREAM, null); } }; public void onSettings(@NotNull Http2Connection http2Connection, @NotNull Settings settings) { g.i(http2Connection, "connection"); g.i(settings, "settings"); } public abstract void onStream(@NotNull Http2Stream http2Stream) throws IOException; } @Metadata(d1 = {"\u0000b\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\t\n\u0002\u0010\u000e\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0086\u0004\u0018\u00002\u00020\u00012\b\u0012\u0004\u0012\u00020\u00030\u0002B\u0011\b\u0000\u0012\u0006\u00104\u001a\u000203¢\u0006\u0004\b8\u00109J\t\u0010\u0004\u001a\u00020\u0003H\u0096\u0002J(\u0010\f\u001a\u00020\u00032\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010\n\u001a\u00020\t2\u0006\u0010\u000b\u001a\u00020\u0007H\u0016J.\u0010\u0011\u001a\u00020\u00032\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010\r\u001a\u00020\u00072\f\u0010\u0010\u001a\b\u0012\u0004\u0012\u00020\u000f0\u000eH\u0016J\u0018\u0010\u0014\u001a\u00020\u00032\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010\u0013\u001a\u00020\u0012H\u0016J\u0018\u0010\u0017\u001a\u00020\u00032\u0006\u0010\u0015\u001a\u00020\u00052\u0006\u0010\u0017\u001a\u00020\u0016H\u0016J\u0016\u0010\u0018\u001a\u00020\u00032\u0006\u0010\u0015\u001a\u00020\u00052\u0006\u0010\u0017\u001a\u00020\u0016J\b\u0010\u0019\u001a\u00020\u0003H\u0016J \u0010\u001d\u001a\u00020\u00032\u0006\u0010\u001a\u001a\u00020\u00052\u0006\u0010\u001b\u001a\u00020\u00072\u0006\u0010\u001c\u001a\u00020\u0007H\u0016J \u0010!\u001a\u00020\u00032\u0006\u0010\u001e\u001a\u00020\u00072\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010 \u001a\u00020\u001fH\u0016J\u0018\u0010$\u001a\u00020\u00032\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010#\u001a\u00020\"H\u0016J(\u0010(\u001a\u00020\u00032\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010%\u001a\u00020\u00072\u0006\u0010&\u001a\u00020\u00072\u0006\u0010'\u001a\u00020\u0005H\u0016J&\u0010+\u001a\u00020\u00032\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010)\u001a\u00020\u00072\f\u0010*\u001a\b\u0012\u0004\u0012\u00020\u000f0\u000eH\u0016J8\u00102\u001a\u00020\u00032\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010-\u001a\u00020,2\u0006\u0010.\u001a\u00020\u001f2\u0006\u0010/\u001a\u00020,2\u0006\u00100\u001a\u00020\u00072\u0006\u00101\u001a\u00020\"H\u0016R\u001a\u00104\u001a\u0002038\u0000X\u0080\u0004¢\u0006\f\n\u0004\b4\u00105\u001a\u0004\b6\u00107¨\u0006:"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "Lokhttp3/internal/http2/Http2Reader$Handler;", "Lkotlin/Function0;", "Lkd/e;", "invoke", "", "inFinished", "", "streamId", "Lokio/BufferedSource;", "source", SessionDescription.ATTR_LENGTH, "data", "associatedStreamId", "", "Lokhttp3/internal/http2/Header;", "headerBlock", "headers", "Lokhttp3/internal/http2/ErrorCode;", "errorCode", "rstStream", "clearPrevious", "Lokhttp3/internal/http2/Settings;", "settings", "applyAndAckSettings", "ackSettings", "ack", "payload1", "payload2", "ping", "lastGoodStreamId", "Lokio/ByteString;", "debugData", "goAway", "", "windowSizeIncrement", "windowUpdate", "streamDependency", "weight", "exclusive", "priority", "promisedStreamId", "requestHeaders", "pushPromise", "", "origin", URLProtectionSpaceContract.FeedEntry.COLUMN_NAME_PROTOCOL, URLProtectionSpaceContract.FeedEntry.COLUMN_NAME_HOST, "port", "maxAge", "alternateService", "Lokhttp3/internal/http2/Http2Reader;", "reader", "Lokhttp3/internal/http2/Http2Reader;", "getReader$okhttp", "()Lokhttp3/internal/http2/Http2Reader;", "", "(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Http2Reader;)V", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nHttp2Connection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection$ReaderRunnable\n+ 2 TaskQueue.kt\nokhttp3/internal/concurrent/TaskQueue\n+ 3 ArraysJVM.kt\nkotlin/collections/ArraysKt__ArraysJVMKt\n+ 4 Util.kt\nokhttp3/internal/Util\n*L\n1#1,1006:1\n90#2,13:1007\n90#2,13:1020\n90#2,13:1035\n90#2,13:1049\n37#3,2:1033\n37#3,2:1062\n563#4:1048\n563#4:1064\n*S KotlinDebug\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection$ReaderRunnable\n*L\n687#1:1007,13\n715#1:1020,13\n758#1:1035,13\n806#1:1049,13\n753#1:1033,2\n824#1:1062,2\n797#1:1048\n841#1:1064\n*E\n"}) public final class ReaderRunnable implements Http2Reader.Handler, a { @NotNull private final Http2Reader reader; final /* synthetic */ Http2Connection this$0; public ReaderRunnable(@NotNull Http2Connection http2Connection, Http2Reader http2Reader) { g.i(http2Reader, "reader"); this.this$0 = http2Connection; this.reader = http2Reader; } @Override // okhttp3.internal.http2.Http2Reader.Handler public void ackSettings() { } @Override // okhttp3.internal.http2.Http2Reader.Handler public void alternateService(int i10, @NotNull String str, @NotNull ByteString byteString, @NotNull String str2, int i11, long j10) { g.i(str, "origin"); g.i(byteString, URLProtectionSpaceContract.FeedEntry.COLUMN_NAME_PROTOCOL); g.i(str2, URLProtectionSpaceContract.FeedEntry.COLUMN_NAME_HOST); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Type inference failed for: r13v1 */ /* JADX WARN: Type inference failed for: r13v2, types: [T, okhttp3.internal.http2.Settings] */ /* JADX WARN: Type inference failed for: r13v3 */ public final void applyAndAckSettings(boolean z10, @NotNull Settings settings) { ?? r13; long initialWindowSize; int i10; Http2Stream[] http2StreamArr; g.i(settings, "settings"); final Ref$ObjectRef ref$ObjectRef = new Ref$ObjectRef(); Http2Writer writer = this.this$0.getWriter(); final Http2Connection http2Connection = this.this$0; synchronized (writer) { synchronized (http2Connection) { try { Settings peerSettings = http2Connection.getPeerSettings(); if (z10) { r13 = settings; } else { Settings settings2 = new Settings(); settings2.merge(peerSettings); settings2.merge(settings); r13 = settings2; } ref$ObjectRef.element = r13; initialWindowSize = ((long) r13.getInitialWindowSize()) - ((long) peerSettings.getInitialWindowSize()); http2StreamArr = (initialWindowSize == 0 || http2Connection.getStreams$okhttp().isEmpty()) ? null : (Http2Stream[]) http2Connection.getStreams$okhttp().values().toArray(new Http2Stream[0]); http2Connection.setPeerSettings((Settings) ref$ObjectRef.element); TaskQueue taskQueue = http2Connection.settingsListenerQueue; final String str = http2Connection.getConnectionName() + " onSettings"; final boolean z11 = true; taskQueue.schedule(new Task(str, z11) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$applyAndAckSettings$lambda$7$lambda$6$$inlined$execute$default$1 /* JADX WARN: Multi-variable type inference failed */ @Override // okhttp3.internal.concurrent.Task public long runOnce() { http2Connection.getListener().onSettings(http2Connection, (Settings) ref$ObjectRef.element); return -1L; } }, 0L); } catch (Throwable th) { throw th; } } try { http2Connection.getWriter().applyAndAckSettings((Settings) ref$ObjectRef.element); } catch (IOException e10) { http2Connection.failConnection(e10); } } if (http2StreamArr != null) { for (Http2Stream http2Stream : http2StreamArr) { synchronized (http2Stream) { http2Stream.addBytesToWriteWindow(initialWindowSize); } } } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void data(boolean z10, int i10, @NotNull BufferedSource bufferedSource, int i11) throws IOException { g.i(bufferedSource, "source"); if (this.this$0.pushedStream$okhttp(i10)) { this.this$0.pushDataLater$okhttp(i10, bufferedSource, i11, z10); return; } Http2Stream stream = this.this$0.getStream(i10); if (stream == null) { this.this$0.writeSynResetLater$okhttp(i10, ErrorCode.PROTOCOL_ERROR); long j10 = i11; this.this$0.updateConnectionFlowControl$okhttp(j10); bufferedSource.skip(j10); return; } stream.receiveData(bufferedSource, i11); if (z10) { stream.receiveHeaders(Util.EMPTY_HEADERS, true); } } @NotNull /* JADX INFO: renamed from: getReader$okhttp, reason: from getter */ public final Http2Reader getReader() { return this.reader; } @Override // okhttp3.internal.http2.Http2Reader.Handler public void goAway(int i10, @NotNull ErrorCode errorCode, @NotNull ByteString byteString) { int i11; Object[] array; g.i(errorCode, "errorCode"); g.i(byteString, "debugData"); byteString.size(); Http2Connection http2Connection = this.this$0; synchronized (http2Connection) { array = http2Connection.getStreams$okhttp().values().toArray(new Http2Stream[0]); http2Connection.isShutdown = true; } for (Http2Stream http2Stream : (Http2Stream[]) array) { if (http2Stream.getId() > i10 && http2Stream.isLocallyInitiated()) { http2Stream.receiveRstStream(ErrorCode.REFUSED_STREAM); this.this$0.removeStream$okhttp(http2Stream.getId()); } } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void headers(boolean z10, int i10, int i11, @NotNull List
list) { g.i(list, "headerBlock"); if (this.this$0.pushedStream$okhttp(i10)) { this.this$0.pushHeadersLater$okhttp(i10, list, z10); return; } final Http2Connection http2Connection = this.this$0; synchronized (http2Connection) { Http2Stream stream = http2Connection.getStream(i10); if (stream != null) { stream.receiveHeaders(Util.toHeaders(list), z10); return; } if (http2Connection.isShutdown) { return; } if (i10 <= http2Connection.getLastGoodStreamId()) { return; } if (i10 % 2 == http2Connection.getNextStreamId() % 2) { return; } final Http2Stream http2Stream = new Http2Stream(i10, http2Connection, false, z10, Util.toHeaders(list)); http2Connection.setLastGoodStreamId$okhttp(i10); http2Connection.getStreams$okhttp().put(Integer.valueOf(i10), http2Stream); TaskQueue taskQueueNewQueue = http2Connection.taskRunner.newQueue(); final String str = http2Connection.getConnectionName() + '[' + i10 + "] onStream"; final boolean z11 = true; taskQueueNewQueue.schedule(new Task(str, z11) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$headers$lambda$2$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { http2Connection.getListener().onStream(http2Stream); return -1L; } catch (IOException e10) { Platform.INSTANCE.get().log("Http2Connection.Listener failure for " + http2Connection.getConnectionName(), 4, e10); try { http2Stream.close(ErrorCode.PROTOCOL_ERROR, e10); return -1L; } catch (IOException unused) { return -1L; } } } }, 0L); } } @Override // sd.a public /* bridge */ /* synthetic */ Object invoke() throws Throwable { m145invoke(); return e.f29109a; } @Override // okhttp3.internal.http2.Http2Reader.Handler public void ping(boolean z10, final int i10, final int i11) { if (!z10) { TaskQueue taskQueue = this.this$0.writerQueue; final String str = this.this$0.getConnectionName() + " ping"; final Http2Connection http2Connection = this.this$0; final boolean z11 = true; taskQueue.schedule(new Task(str, z11) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$ping$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { http2Connection.writePing(true, i10, i11); return -1L; } }, 0L); return; } Http2Connection http2Connection2 = this.this$0; synchronized (http2Connection2) { try { if (i10 == 1) { http2Connection2.intervalPongsReceived++; } else if (i10 == 2) { http2Connection2.degradedPongsReceived++; } else if (i10 == 3) { http2Connection2.awaitPongsReceived++; g.g(http2Connection2, "null cannot be cast to non-null type java.lang.Object"); http2Connection2.notifyAll(); } } catch (Throwable th) { throw th; } } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void priority(int i10, int i11, int i12, boolean z10) { } @Override // okhttp3.internal.http2.Http2Reader.Handler public void pushPromise(int i10, int i11, @NotNull List
list) { g.i(list, "requestHeaders"); this.this$0.pushRequestLater$okhttp(i11, list); } @Override // okhttp3.internal.http2.Http2Reader.Handler public void rstStream(int i10, @NotNull ErrorCode errorCode) { g.i(errorCode, "errorCode"); if (this.this$0.pushedStream$okhttp(i10)) { this.this$0.pushResetLater$okhttp(i10, errorCode); return; } Http2Stream http2StreamRemoveStream$okhttp = this.this$0.removeStream$okhttp(i10); if (http2StreamRemoveStream$okhttp != null) { http2StreamRemoveStream$okhttp.receiveRstStream(errorCode); } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void settings(final boolean z10, @NotNull final Settings settings) { g.i(settings, "settings"); TaskQueue taskQueue = this.this$0.writerQueue; final String str = this.this$0.getConnectionName() + " applyAndAckSettings"; final boolean z11 = true; taskQueue.schedule(new Task(str, z11) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$settings$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.applyAndAckSettings(z10, settings); return -1L; } }, 0L); } @Override // okhttp3.internal.http2.Http2Reader.Handler public void windowUpdate(int i10, long j10) { if (i10 == 0) { Http2Connection http2Connection = this.this$0; synchronized (http2Connection) { http2Connection.writeBytesMaximum = http2Connection.getWriteBytesMaximum() + j10; http2Connection.notifyAll(); } return; } Http2Stream stream = this.this$0.getStream(i10); if (stream != null) { synchronized (stream) { stream.addBytesToWriteWindow(j10); } } } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Type inference failed for: r0v0, types: [okhttp3.internal.http2.ErrorCode] */ /* JADX WARN: Type inference failed for: r0v3 */ /* JADX WARN: Type inference failed for: r0v5, types: [java.io.Closeable, okhttp3.internal.http2.Http2Reader] */ /* JADX WARN: Type inference fix 'apply assigned field type' failed java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593) at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35) at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94) */ /* JADX INFO: renamed from: invoke, reason: collision with other method in class */ public void m145invoke() throws Throwable { ErrorCode errorCode; ErrorCode errorCode2 = ErrorCode.INTERNAL_ERROR; IOException e10 = null; try { try { this.reader.readConnectionPreface(this); while (this.reader.nextFrame(false, this)) { } ErrorCode errorCode3 = ErrorCode.NO_ERROR; try { this.this$0.close$okhttp(errorCode3, ErrorCode.CANCEL, null); errorCode = errorCode3; } catch (IOException e11) { e10 = e11; ErrorCode errorCode4 = ErrorCode.PROTOCOL_ERROR; Http2Connection http2Connection = this.this$0; http2Connection.close$okhttp(errorCode4, errorCode4, e10); errorCode = http2Connection; } } catch (Throwable th) { th = th; this.this$0.close$okhttp(errorCode, errorCode2, e10); Util.closeQuietly(this.reader); throw th; } } catch (IOException e12) { e10 = e12; } catch (Throwable th2) { th = th2; errorCode = errorCode2; this.this$0.close$okhttp(errorCode, errorCode2, e10); Util.closeQuietly(this.reader); throw th; } errorCode2 = this.reader; Util.closeQuietly((Closeable) errorCode2); } } static { Settings settings = new Settings(); settings.set(7, 65535); settings.set(5, 16384); DEFAULT_SETTINGS = settings; } public Http2Connection(@NotNull Builder builder) { g.i(builder, "builder"); boolean client = builder.getClient(); this.client = client; this.listener = builder.getListener(); this.streams = new LinkedHashMap(); String connectionName$okhttp = builder.getConnectionName$okhttp(); this.connectionName = connectionName$okhttp; this.nextStreamId = builder.getClient() ? 3 : 2; TaskRunner taskRunner = builder.getTaskRunner(); this.taskRunner = taskRunner; TaskQueue taskQueueNewQueue = taskRunner.newQueue(); this.writerQueue = taskQueueNewQueue; this.pushQueue = taskRunner.newQueue(); this.settingsListenerQueue = taskRunner.newQueue(); this.pushObserver = builder.getPushObserver(); Settings settings = new Settings(); if (builder.getClient()) { settings.set(7, OKHTTP_CLIENT_WINDOW_SIZE); } this.okHttpSettings = settings; this.peerSettings = DEFAULT_SETTINGS; this.writeBytesMaximum = r2.getInitialWindowSize(); this.socket = builder.getSocket$okhttp(); this.writer = new Http2Writer(builder.getSink$okhttp(), client); this.readerRunnable = new ReaderRunnable(this, new Http2Reader(builder.getSource$okhttp(), client)); this.currentPushRequests = new LinkedHashSet(); if (builder.getPingIntervalMillis() != 0) { final long nanos = TimeUnit.MILLISECONDS.toNanos(builder.getPingIntervalMillis()); final String strJ = u1.j(connectionName$okhttp, " ping"); taskQueueNewQueue.schedule(new Task(strJ) { // from class: okhttp3.internal.http2.Http2Connection$special$$inlined$schedule$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { boolean z10; synchronized (this) { if (this.intervalPongsReceived < this.intervalPingsSent) { z10 = true; } else { this.intervalPingsSent++; z10 = false; } } if (z10) { this.failConnection(null); return -1L; } this.writePing(false, 1, 0); return nanos; } }, nanos); } } /* JADX INFO: Access modifiers changed from: private */ public final void failConnection(IOException iOException) { ErrorCode errorCode = ErrorCode.PROTOCOL_ERROR; close$okhttp(errorCode, errorCode, iOException); } public static /* synthetic */ void start$default(Http2Connection http2Connection, boolean z10, TaskRunner taskRunner, int i10, Object obj) throws IOException { if ((i10 & 1) != 0) { z10 = true; } if ((i10 & 2) != 0) { taskRunner = TaskRunner.INSTANCE; } http2Connection.start(z10, taskRunner); } public final synchronized void awaitPong() throws InterruptedException { while (this.awaitPongsReceived < this.awaitPingsSent) { wait(); } } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { close$okhttp(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null); } public final void close$okhttp(@NotNull ErrorCode connectionCode, @NotNull ErrorCode streamCode, @Nullable IOException cause) { int i10; Object[] array; g.i(connectionCode, "connectionCode"); g.i(streamCode, "streamCode"); if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } try { shutdown(connectionCode); } catch (IOException unused) { } synchronized (this) { if (!this.streams.isEmpty()) { array = this.streams.values().toArray(new Http2Stream[0]); this.streams.clear(); } else { array = null; } } Http2Stream[] http2StreamArr = (Http2Stream[]) array; if (http2StreamArr != null) { for (Http2Stream http2Stream : http2StreamArr) { try { http2Stream.close(streamCode, cause); } catch (IOException unused2) { } } } try { this.writer.close(); } catch (IOException unused3) { } try { this.socket.close(); } catch (IOException unused4) { } this.writerQueue.shutdown(); this.pushQueue.shutdown(); this.settingsListenerQueue.shutdown(); } public final void flush() throws IOException { this.writer.flush(); } /* JADX INFO: renamed from: getClient$okhttp, reason: from getter */ public final boolean getClient() { return this.client; } @NotNull /* JADX INFO: renamed from: getConnectionName$okhttp, reason: from getter */ public final String getConnectionName() { return this.connectionName; } /* JADX INFO: renamed from: getLastGoodStreamId$okhttp, reason: from getter */ public final int getLastGoodStreamId() { return this.lastGoodStreamId; } @NotNull /* JADX INFO: renamed from: getListener$okhttp, reason: from getter */ public final Listener getListener() { return this.listener; } /* JADX INFO: renamed from: getNextStreamId$okhttp, reason: from getter */ public final int getNextStreamId() { return this.nextStreamId; } @NotNull public final Settings getOkHttpSettings() { return this.okHttpSettings; } @NotNull public final Settings getPeerSettings() { return this.peerSettings; } public final long getReadBytesAcknowledged() { return this.readBytesAcknowledged; } public final long getReadBytesTotal() { return this.readBytesTotal; } @NotNull public final ReaderRunnable getReaderRunnable() { return this.readerRunnable; } @NotNull /* JADX INFO: renamed from: getSocket$okhttp, reason: from getter */ public final Socket getSocket() { return this.socket; } @Nullable public final synchronized Http2Stream getStream(int id2) { return this.streams.get(Integer.valueOf(id2)); } @NotNull public final Map getStreams$okhttp() { return this.streams; } public final long getWriteBytesMaximum() { return this.writeBytesMaximum; } public final long getWriteBytesTotal() { return this.writeBytesTotal; } @NotNull public final Http2Writer getWriter() { return this.writer; } public final synchronized boolean isHealthy(long nowNs) { if (this.isShutdown) { return false; } if (this.degradedPongsReceived < this.degradedPingsSent) { if (nowNs >= this.degradedPongDeadlineNs) { return false; } } return true; } @NotNull public final Http2Stream newStream(@NotNull List
requestHeaders, boolean out) throws IOException { g.i(requestHeaders, "requestHeaders"); return newStream(0, requestHeaders, out); } public final synchronized int openStreamCount() { return this.streams.size(); } public final void pushDataLater$okhttp(final int streamId, @NotNull BufferedSource source, final int byteCount, final boolean inFinished) throws IOException { g.i(source, "source"); final Buffer buffer = new Buffer(); long j10 = byteCount; source.require(j10); source.read(buffer, j10); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + streamId + "] onData"; final boolean z10 = true; taskQueue.schedule(new Task(str, z10) { // from class: okhttp3.internal.http2.Http2Connection$pushDataLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { boolean zOnData = this.pushObserver.onData(streamId, buffer, byteCount, inFinished); if (zOnData) { this.getWriter().rstStream(streamId, ErrorCode.CANCEL); } if (!zOnData && !inFinished) { return -1L; } synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(streamId)); } return -1L; } catch (IOException unused) { return -1L; } } }, 0L); } public final void pushHeadersLater$okhttp(final int streamId, @NotNull final List
requestHeaders, final boolean inFinished) { g.i(requestHeaders, "requestHeaders"); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + streamId + "] onHeaders"; final boolean z10 = true; taskQueue.schedule(new Task(str, z10) { // from class: okhttp3.internal.http2.Http2Connection$pushHeadersLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { boolean zOnHeaders = this.pushObserver.onHeaders(streamId, requestHeaders, inFinished); if (zOnHeaders) { try { this.getWriter().rstStream(streamId, ErrorCode.CANCEL); } catch (IOException unused) { return -1L; } } if (!zOnHeaders && !inFinished) { return -1L; } synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(streamId)); } return -1L; } }, 0L); } public final void pushRequestLater$okhttp(final int streamId, @NotNull final List
requestHeaders) { g.i(requestHeaders, "requestHeaders"); synchronized (this) { if (this.currentPushRequests.contains(Integer.valueOf(streamId))) { writeSynResetLater$okhttp(streamId, ErrorCode.PROTOCOL_ERROR); return; } this.currentPushRequests.add(Integer.valueOf(streamId)); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + streamId + "] onRequest"; final boolean z10 = true; taskQueue.schedule(new Task(str, z10) { // from class: okhttp3.internal.http2.Http2Connection$pushRequestLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { if (!this.pushObserver.onRequest(streamId, requestHeaders)) { return -1L; } try { this.getWriter().rstStream(streamId, ErrorCode.CANCEL); synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(streamId)); } return -1L; } catch (IOException unused) { return -1L; } } }, 0L); } } public final void pushResetLater$okhttp(final int streamId, @NotNull final ErrorCode errorCode) { g.i(errorCode, "errorCode"); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + streamId + "] onReset"; final boolean z10 = true; taskQueue.schedule(new Task(str, z10) { // from class: okhttp3.internal.http2.Http2Connection$pushResetLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.pushObserver.onReset(streamId, errorCode); synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(streamId)); } return -1L; } }, 0L); } @NotNull public final Http2Stream pushStream(int associatedStreamId, @NotNull List
requestHeaders, boolean out) throws IOException { g.i(requestHeaders, "requestHeaders"); if (!this.client) { return newStream(associatedStreamId, requestHeaders, out); } throw new IllegalStateException("Client cannot push requests.".toString()); } public final boolean pushedStream$okhttp(int streamId) { return streamId != 0 && (streamId & 1) == 0; } @Nullable public final synchronized Http2Stream removeStream$okhttp(int streamId) { Http2Stream http2StreamRemove; http2StreamRemove = this.streams.remove(Integer.valueOf(streamId)); notifyAll(); return http2StreamRemove; } public final void sendDegradedPingLater$okhttp() { synchronized (this) { long j10 = this.degradedPongsReceived; long j11 = this.degradedPingsSent; if (j10 < j11) { return; } this.degradedPingsSent = j11 + 1; this.degradedPongDeadlineNs = System.nanoTime() + ((long) DEGRADED_PONG_TIMEOUT_NS); TaskQueue taskQueue = this.writerQueue; final String strO = defpackage.e.o(new StringBuilder(), this.connectionName, " ping"); final boolean z10 = true; taskQueue.schedule(new Task(strO, z10) { // from class: okhttp3.internal.http2.Http2Connection$sendDegradedPingLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.writePing(false, 2, 0); return -1L; } }, 0L); } } public final void setLastGoodStreamId$okhttp(int i10) { this.lastGoodStreamId = i10; } public final void setNextStreamId$okhttp(int i10) { this.nextStreamId = i10; } public final void setPeerSettings(@NotNull Settings settings) { g.i(settings, ""); this.peerSettings = settings; } public final void setSettings(@NotNull Settings settings) throws IOException { g.i(settings, "settings"); synchronized (this.writer) { synchronized (this) { if (this.isShutdown) { throw new ConnectionShutdownException(); } this.okHttpSettings.merge(settings); } this.writer.settings(settings); } } public final void shutdown(@NotNull ErrorCode errorCode) throws IOException { g.i(errorCode, "statusCode"); synchronized (this.writer) { Ref$IntRef ref$IntRef = new Ref$IntRef(); synchronized (this) { if (this.isShutdown) { return; } this.isShutdown = true; int i10 = this.lastGoodStreamId; ref$IntRef.element = i10; this.writer.goAway(i10, errorCode, Util.EMPTY_BYTE_ARRAY); } } } @JvmOverloads public final void start() throws IOException { start$default(this, false, null, 3, null); } public final synchronized void updateConnectionFlowControl$okhttp(long read) { long j10 = this.readBytesTotal + read; this.readBytesTotal = j10; long j11 = j10 - this.readBytesAcknowledged; if (j11 >= this.okHttpSettings.getInitialWindowSize() / 2) { writeWindowUpdateLater$okhttp(0, j11); this.readBytesAcknowledged += j11; } } /* JADX WARN: Code restructure failed: missing block: B:19:0x0035, code lost: r2 = java.lang.Math.min((int) java.lang.Math.min(r12, r6 - r4), r8.writer.maxDataLength()); r6 = r2; r8.writeBytesTotal += r6; */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void writeData(int i10, boolean z10, @Nullable Buffer buffer, long j10) throws IOException { int iMin; long j11; if (j10 == 0) { this.writer.data(z10, i10, buffer, 0); return; } while (j10 > 0) { synchronized (this) { while (true) { try { try { long j12 = this.writeBytesTotal; long j13 = this.writeBytesMaximum; if (j12 < j13) { break; } else { if (!this.streams.containsKey(Integer.valueOf(i10))) { throw new IOException("stream closed"); } wait(); } } catch (InterruptedException unused) { Thread.currentThread().interrupt(); throw new InterruptedIOException(); } } catch (Throwable th) { throw th; } } } j10 -= j11; this.writer.data(z10 && j10 == 0, i10, buffer, iMin); } } public final void writeHeaders$okhttp(int streamId, boolean outFinished, @NotNull List
alternating) throws IOException { g.i(alternating, "alternating"); this.writer.headers(outFinished, streamId, alternating); } public final void writePing(boolean z10, int i10, int i11) { try { this.writer.ping(z10, i10, i11); } catch (IOException e10) { failConnection(e10); } } public final void writePingAndAwaitPong() throws InterruptedException { writePing(); awaitPong(); } public final void writeSynReset$okhttp(int streamId, @NotNull ErrorCode statusCode) throws IOException { g.i(statusCode, "statusCode"); this.writer.rstStream(streamId, statusCode); } public final void writeSynResetLater$okhttp(final int streamId, @NotNull final ErrorCode errorCode) { g.i(errorCode, "errorCode"); TaskQueue taskQueue = this.writerQueue; final String str = this.connectionName + '[' + streamId + "] writeSynReset"; final boolean z10 = true; taskQueue.schedule(new Task(str, z10) { // from class: okhttp3.internal.http2.Http2Connection$writeSynResetLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { this.writeSynReset$okhttp(streamId, errorCode); return -1L; } catch (IOException e10) { this.failConnection(e10); return -1L; } } }, 0L); } public final void writeWindowUpdateLater$okhttp(final int streamId, final long unacknowledgedBytesRead) { TaskQueue taskQueue = this.writerQueue; final String str = this.connectionName + '[' + streamId + "] windowUpdate"; final boolean z10 = true; taskQueue.schedule(new Task(str, z10) { // from class: okhttp3.internal.http2.Http2Connection$writeWindowUpdateLater$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { this.getWriter().windowUpdate(streamId, unacknowledgedBytesRead); return -1L; } catch (IOException e10) { this.failConnection(e10); return -1L; } } }, 0L); } private final Http2Stream newStream(int associatedStreamId, List
requestHeaders, boolean out) throws IOException { int i10; Http2Stream http2Stream; boolean z10; boolean z11 = !out; synchronized (this.writer) { try { synchronized (this) { try { if (this.nextStreamId > 1073741823) { shutdown(ErrorCode.REFUSED_STREAM); } if (this.isShutdown) { throw new ConnectionShutdownException(); } i10 = this.nextStreamId; this.nextStreamId = i10 + 2; http2Stream = new Http2Stream(i10, this, z11, false, null); z10 = !out || this.writeBytesTotal >= this.writeBytesMaximum || http2Stream.getWriteBytesTotal() >= http2Stream.getWriteBytesMaximum(); if (http2Stream.isOpen()) { this.streams.put(Integer.valueOf(i10), http2Stream); } } finally { } } if (associatedStreamId == 0) { this.writer.headers(z11, i10, requestHeaders); } else { if (!(true ^ this.client)) { throw new IllegalArgumentException("client streams shouldn't have associated stream IDs".toString()); } this.writer.pushPromise(associatedStreamId, i10, requestHeaders); } } catch (Throwable th) { throw th; } } if (z10) { this.writer.flush(); } return http2Stream; } @JvmOverloads public final void start(boolean z10) throws IOException { start$default(this, z10, null, 2, null); } @JvmOverloads public final void start(boolean z10, @NotNull TaskRunner taskRunner) throws IOException { g.i(taskRunner, "taskRunner"); if (z10) { this.writer.connectionPreface(); this.writer.settings(this.okHttpSettings); if (this.okHttpSettings.getInitialWindowSize() != 65535) { this.writer.windowUpdate(0, r5 - 65535); } } taskRunner.newQueue().schedule(new TaskQueue.AnonymousClass1(this.connectionName, true, this.readerRunnable), 0L); } public final void writePing() throws InterruptedException { synchronized (this) { this.awaitPingsSent++; } writePing(false, 3, 1330343787); } }