package okhttp3.internal.http2; import j.h0; import j.n; import j.p0.d.a0; import j.p0.d.b0; import j.p0.d.c0; import j.p0.d.j; import j.p0.d.r; import j.w; 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 l.f; import l.g; import l.h; import l.i; import l.p; import okhttp3.HttpUrl; 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; /* JADX INFO: compiled from: Http2Connection.kt */ /* JADX INFO: loaded from: classes.dex */ @n(bv = {1, 0, 3}, d1 = {"\u0000¸\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0018\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u001c\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0010#\n\u0002\b\r\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010%\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0005\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\r\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0003\u0010\u0004J\u000f\u0010\u0005\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0005\u0010\u0004J)\u0010\u0005\u001a\u00020\u00022\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\b\u001a\u00020\u00062\b\u0010\n\u001a\u0004\u0018\u00010\tH\u0000¢\u0006\u0004\b\u000b\u0010\fJ\u0019\u0010\u000e\u001a\u00020\u00022\b\u0010\r\u001a\u0004\u0018\u00010\tH\u0002¢\u0006\u0004\b\u000e\u0010\u000fJ\r\u0010\u0010\u001a\u00020\u0002¢\u0006\u0004\b\u0010\u0010\u0004J\u0017\u0010\u0014\u001a\u0004\u0018\u00010\u00132\u0006\u0010\u0012\u001a\u00020\u0011¢\u0006\u0004\b\u0014\u0010\u0015J\u0015\u0010\u0019\u001a\u00020\u00182\u0006\u0010\u0017\u001a\u00020\u0016¢\u0006\u0004\b\u0019\u0010\u001aJ-\u0010 \u001a\u00020\u00132\u0006\u0010\u001b\u001a\u00020\u00112\f\u0010\u001e\u001a\b\u0012\u0004\u0012\u00020\u001d0\u001c2\u0006\u0010\u001f\u001a\u00020\u0018H\u0002¢\u0006\u0004\b \u0010!J#\u0010 \u001a\u00020\u00132\f\u0010\u001e\u001a\b\u0012\u0004\u0012\u00020\u001d0\u001c2\u0006\u0010\u001f\u001a\u00020\u0018¢\u0006\u0004\b \u0010\"J\r\u0010#\u001a\u00020\u0011¢\u0006\u0004\b#\u0010$J/\u0010,\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u0010'\u001a\u00020&2\u0006\u0010(\u001a\u00020\u00112\u0006\u0010)\u001a\u00020\u0018H\u0000¢\u0006\u0004\b*\u0010+J-\u0010/\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\f\u0010\u001e\u001a\b\u0012\u0004\u0012\u00020\u001d0\u001c2\u0006\u0010)\u001a\u00020\u0018H\u0000¢\u0006\u0004\b-\u0010.J%\u00102\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\f\u0010\u001e\u001a\b\u0012\u0004\u0012\u00020\u001d0\u001cH\u0000¢\u0006\u0004\b0\u00101J\u001f\u00106\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u00103\u001a\u00020\u0006H\u0000¢\u0006\u0004\b4\u00105J+\u00107\u001a\u00020\u00132\u0006\u0010\u001b\u001a\u00020\u00112\f\u0010\u001e\u001a\b\u0012\u0004\u0012\u00020\u001d0\u001c2\u0006\u0010\u001f\u001a\u00020\u0018¢\u0006\u0004\b7\u0010!J\u0017\u0010:\u001a\u00020\u00182\u0006\u0010%\u001a\u00020\u0011H\u0000¢\u0006\u0004\b8\u00109J\u0019\u0010<\u001a\u0004\u0018\u00010\u00132\u0006\u0010%\u001a\u00020\u0011H\u0000¢\u0006\u0004\b;\u0010\u0015J\u000f\u0010>\u001a\u00020\u0002H\u0000¢\u0006\u0004\b=\u0010\u0004J\u0015\u0010A\u001a\u00020\u00022\u0006\u0010@\u001a\u00020?¢\u0006\u0004\bA\u0010BJ\u0015\u0010D\u001a\u00020\u00022\u0006\u0010C\u001a\u00020\u0006¢\u0006\u0004\bD\u0010EJ\u0019\u0010G\u001a\u00020\u00022\b\b\u0002\u0010F\u001a\u00020\u0018H\u0007¢\u0006\u0004\bG\u0010HJ\u0017\u0010L\u001a\u00020\u00022\u0006\u0010I\u001a\u00020\u0016H\u0000¢\u0006\u0004\bJ\u0010KJ/\u0010P\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u0010M\u001a\u00020\u00182\b\u0010O\u001a\u0004\u0018\u00010N2\u0006\u0010(\u001a\u00020\u0016¢\u0006\u0004\bP\u0010QJ-\u0010U\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u0010M\u001a\u00020\u00182\f\u0010R\u001a\b\u0012\u0004\u0012\u00020\u001d0\u001cH\u0000¢\u0006\u0004\bS\u0010TJ\r\u0010V\u001a\u00020\u0002¢\u0006\u0004\bV\u0010\u0004J%\u0010V\u001a\u00020\u00022\u0006\u0010W\u001a\u00020\u00182\u0006\u0010X\u001a\u00020\u00112\u0006\u0010Y\u001a\u00020\u0011¢\u0006\u0004\bV\u0010ZJ\r\u0010[\u001a\u00020\u0002¢\u0006\u0004\b[\u0010\u0004J\u001f\u0010]\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u0010C\u001a\u00020\u0006H\u0000¢\u0006\u0004\b\\\u00105J\u001f\u0010_\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u00103\u001a\u00020\u0006H\u0000¢\u0006\u0004\b^\u00105J\u001f\u0010c\u001a\u00020\u00022\u0006\u0010%\u001a\u00020\u00112\u0006\u0010`\u001a\u00020\u0016H\u0000¢\u0006\u0004\ba\u0010bR\u0016\u0010d\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bd\u0010eR\u0016\u0010f\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bf\u0010eR\u001c\u0010g\u001a\u00020\u00188\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bg\u0010h\u001a\u0004\bi\u0010jR\u001c\u0010l\u001a\u00020k8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bl\u0010m\u001a\u0004\bn\u0010oR\u001c\u0010q\u001a\b\u0012\u0004\u0012\u00020\u00110p8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bq\u0010rR\u0016\u0010s\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bs\u0010eR\u0016\u0010t\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bt\u0010eR\u0016\u0010u\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bu\u0010eR\u0016\u0010v\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bv\u0010eR\u0016\u0010w\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bw\u0010eR\u0016\u0010x\u001a\u00020\u00188\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bx\u0010hR\"\u0010y\u001a\u00020\u00118\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\by\u0010z\u001a\u0004\b{\u0010$\"\u0004\b|\u0010}R\u001f\u0010\u007f\u001a\u00020~8\u0000@\u0000X\u0080\u0004¢\u0006\u000f\n\u0005\b\u007f\u0010\u0080\u0001\u001a\u0006\b\u0081\u0001\u0010\u0082\u0001R&\u0010\u0083\u0001\u001a\u00020\u00118\u0000@\u0000X\u0080\u000e¢\u0006\u0015\n\u0005\b\u0083\u0001\u0010z\u001a\u0005\b\u0084\u0001\u0010$\"\u0005\b\u0085\u0001\u0010}R\u001e\u0010\u0086\u0001\u001a\u00020?8\u0006@\u0006¢\u0006\u0010\n\u0006\b\u0086\u0001\u0010\u0087\u0001\u001a\u0006\b\u0088\u0001\u0010\u0089\u0001R(\u0010\u008a\u0001\u001a\u00020?8\u0006@\u0006X\u0086\u000e¢\u0006\u0017\n\u0006\b\u008a\u0001\u0010\u0087\u0001\u001a\u0006\b\u008b\u0001\u0010\u0089\u0001\"\u0005\b\u008c\u0001\u0010BR\u001a\u0010\u008e\u0001\u001a\u00030\u008d\u00018\u0002@\u0002X\u0082\u0004¢\u0006\b\n\u0006\b\u008e\u0001\u0010\u008f\u0001R\u001a\u0010\u0091\u0001\u001a\u00030\u0090\u00018\u0002@\u0002X\u0082\u0004¢\u0006\b\n\u0006\b\u0091\u0001\u0010\u0092\u0001R)\u0010\u0094\u0001\u001a\u00020\u00162\u0007\u0010\u0093\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e¢\u0006\u000f\n\u0005\b\u0094\u0001\u0010e\u001a\u0006\b\u0095\u0001\u0010\u0096\u0001R)\u0010\u0097\u0001\u001a\u00020\u00162\u0007\u0010\u0093\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e¢\u0006\u000f\n\u0005\b\u0097\u0001\u0010e\u001a\u0006\b\u0098\u0001\u0010\u0096\u0001R#\u0010\u009a\u0001\u001a\u00070\u0099\u0001R\u00020\u00008\u0006@\u0006¢\u0006\u0010\n\u0006\b\u009a\u0001\u0010\u009b\u0001\u001a\u0006\b\u009c\u0001\u0010\u009d\u0001R\u001a\u0010\u009e\u0001\u001a\u00030\u0090\u00018\u0002@\u0002X\u0082\u0004¢\u0006\b\n\u0006\b\u009e\u0001\u0010\u0092\u0001R\"\u0010 \u0001\u001a\u00030\u009f\u00018\u0000@\u0000X\u0080\u0004¢\u0006\u0010\n\u0006\b \u0001\u0010¡\u0001\u001a\u0006\b¢\u0001\u0010£\u0001R.\u0010¥\u0001\u001a\u000f\u0012\u0004\u0012\u00020\u0011\u0012\u0004\u0012\u00020\u00130¤\u00018\u0000@\u0000X\u0080\u0004¢\u0006\u0010\n\u0006\b¥\u0001\u0010¦\u0001\u001a\u0006\b§\u0001\u0010¨\u0001R\u001a\u0010ª\u0001\u001a\u00030©\u00018\u0002@\u0002X\u0082\u0004¢\u0006\b\n\u0006\bª\u0001\u0010«\u0001R)\u0010¬\u0001\u001a\u00020\u00162\u0007\u0010\u0093\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e¢\u0006\u000f\n\u0005\b¬\u0001\u0010e\u001a\u0006\b\u00ad\u0001\u0010\u0096\u0001R)\u0010®\u0001\u001a\u00020\u00162\u0007\u0010\u0093\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e¢\u0006\u000f\n\u0005\b®\u0001\u0010e\u001a\u0006\b¯\u0001\u0010\u0096\u0001R\u001f\u0010±\u0001\u001a\u00030°\u00018\u0006@\u0006¢\u0006\u0010\n\u0006\b±\u0001\u0010²\u0001\u001a\u0006\b³\u0001\u0010´\u0001R\u001a\u0010µ\u0001\u001a\u00030\u0090\u00018\u0002@\u0002X\u0082\u0004¢\u0006\b\n\u0006\bµ\u0001\u0010\u0092\u0001¨\u0006¾\u0001"}, d2 = {"Lokhttp3/internal/http2/Http2Connection;", "Ljava/io/Closeable;", HttpUrl.FRAGMENT_ENCODE_SET, "awaitPong", "()V", "close", "Lokhttp3/internal/http2/ErrorCode;", "connectionCode", "streamCode", "Ljava/io/IOException;", "cause", "close$okhttp", "(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V", "e", "failConnection", "(Ljava/io/IOException;)V", "flush", HttpUrl.FRAGMENT_ENCODE_SET, "id", "Lokhttp3/internal/http2/Http2Stream;", "getStream", "(I)Lokhttp3/internal/http2/Http2Stream;", HttpUrl.FRAGMENT_ENCODE_SET, "nowNs", HttpUrl.FRAGMENT_ENCODE_SET, "isHealthy", "(J)Z", "associatedStreamId", HttpUrl.FRAGMENT_ENCODE_SET, "Lokhttp3/internal/http2/Header;", "requestHeaders", "out", "newStream", "(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;", "(Ljava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;", "openStreamCount", "()I", "streamId", "Lokio/BufferedSource;", "source", "byteCount", "inFinished", "pushDataLater$okhttp", "(ILokio/BufferedSource;IZ)V", "pushDataLater", "pushHeadersLater$okhttp", "(ILjava/util/List;Z)V", "pushHeadersLater", "pushRequestLater$okhttp", "(ILjava/util/List;)V", "pushRequestLater", "errorCode", "pushResetLater$okhttp", "(ILokhttp3/internal/http2/ErrorCode;)V", "pushResetLater", "pushStream", "pushedStream$okhttp", "(I)Z", "pushedStream", "removeStream$okhttp", "removeStream", "sendDegradedPingLater$okhttp", "sendDegradedPingLater", "Lokhttp3/internal/http2/Settings;", "settings", "setSettings", "(Lokhttp3/internal/http2/Settings;)V", "statusCode", "shutdown", "(Lokhttp3/internal/http2/ErrorCode;)V", "sendConnectionPreface", "start", "(Z)V", "read", "updateConnectionFlowControl$okhttp", "(J)V", "updateConnectionFlowControl", "outFinished", "Lokio/Buffer;", "buffer", "writeData", "(IZLokio/Buffer;J)V", "alternating", "writeHeaders$okhttp", "(IZLjava/util/List;)V", "writeHeaders", "writePing", "reply", "payload1", "payload2", "(ZII)V", "writePingAndAwaitPong", "writeSynReset$okhttp", "writeSynReset", "writeSynResetLater$okhttp", "writeSynResetLater", "unacknowledgedBytesRead", "writeWindowUpdateLater$okhttp", "(IJ)V", "writeWindowUpdateLater", "awaitPingsSent", "J", "awaitPongsReceived", "client", "Z", "getClient$okhttp", "()Z", HttpUrl.FRAGMENT_ENCODE_SET, "connectionName", "Ljava/lang/String;", "getConnectionName$okhttp", "()Ljava/lang/String;", HttpUrl.FRAGMENT_ENCODE_SET, "currentPushRequests", "Ljava/util/Set;", "degradedPingsSent", "degradedPongDeadlineNs", "degradedPongsReceived", "intervalPingsSent", "intervalPongsReceived", "isShutdown", "lastGoodStreamId", "I", "getLastGoodStreamId$okhttp", "setLastGoodStreamId$okhttp", "(I)V", "Lokhttp3/internal/http2/Http2Connection$Listener;", "listener", "Lokhttp3/internal/http2/Http2Connection$Listener;", "getListener$okhttp", "()Lokhttp3/internal/http2/Http2Connection$Listener;", "nextStreamId", "getNextStreamId$okhttp", "setNextStreamId$okhttp", "okHttpSettings", "Lokhttp3/internal/http2/Settings;", "getOkHttpSettings", "()Lokhttp3/internal/http2/Settings;", "peerSettings", "getPeerSettings", "setPeerSettings", "Lokhttp3/internal/http2/PushObserver;", "pushObserver", "Lokhttp3/internal/http2/PushObserver;", "Lokhttp3/internal/concurrent/TaskQueue;", "pushQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "", "readBytesAcknowledged", "getReadBytesAcknowledged", "()J", "readBytesTotal", "getReadBytesTotal", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "readerRunnable", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "getReaderRunnable", "()Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "settingsListenerQueue", "Ljava/net/Socket;", "socket", "Ljava/net/Socket;", "getSocket$okhttp", "()Ljava/net/Socket;", HttpUrl.FRAGMENT_ENCODE_SET, "streams", "Ljava/util/Map;", "getStreams$okhttp", "()Ljava/util/Map;", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "Lokhttp3/internal/concurrent/TaskRunner;", "writeBytesMaximum", "getWriteBytesMaximum", "writeBytesTotal", "getWriteBytesTotal", "Lokhttp3/internal/http2/Http2Writer;", "writer", "Lokhttp3/internal/http2/Http2Writer;", "getWriter", "()Lokhttp3/internal/http2/Http2Writer;", "writerQueue", "Lokhttp3/internal/http2/Http2Connection$Builder;", "builder", "", "(Lokhttp3/internal/http2/Http2Connection$Builder;)V", "Companion", "Builder", "Listener", "ReaderRunnable", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class Http2Connection implements Closeable { public static final int AWAIT_PING = 3; public static final Companion Companion = new Companion(null); 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; private final String connectionName; 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; private final Listener listener; private int nextStreamId; private final Settings okHttpSettings; private Settings peerSettings; private final PushObserver pushObserver; private final TaskQueue pushQueue; private long readBytesAcknowledged; private long readBytesTotal; private final ReaderRunnable readerRunnable; private final TaskQueue settingsListenerQueue; private final Socket socket; private final Map streams; private final TaskRunner taskRunner; private long writeBytesMaximum; private long writeBytesTotal; private final Http2Writer writer; private final TaskQueue writerQueue; /* JADX INFO: compiled from: Http2Connection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000N\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b*\n\u0002\u0018\u0002\n\u0002\b\u0007\u0018\u0000B\u0017\u0012\u0006\u0010\u0017\u001a\u00020\u0016\u0012\u0006\u0010B\u001a\u00020A¢\u0006\u0004\bF\u0010GJ\r\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0002\u0010\u0003J\u0015\u0010\u0005\u001a\u00020\u00002\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0005\u0010\u0006J\u0015\u0010\b\u001a\u00020\u00002\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b\b\u0010\tJ\u0015\u0010\u000b\u001a\u00020\u00002\u0006\u0010\u000b\u001a\u00020\n¢\u0006\u0004\b\u000b\u0010\fJ5\u0010\u000e\u001a\u00020\u00002\u0006\u0010\u000e\u001a\u00020\r2\b\b\u0002\u0010\u0010\u001a\u00020\u000f2\b\b\u0002\u0010\u0012\u001a\u00020\u00112\b\b\u0002\u0010\u0014\u001a\u00020\u0013H\u0007¢\u0006\u0004\b\u000e\u0010\u0015R\"\u0010\u0017\u001a\u00020\u00168\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0017\u0010\u0018\u001a\u0004\b\u0019\u0010\u001a\"\u0004\b\u001b\u0010\u001cR\"\u0010\u001d\u001a\u00020\u000f8\u0000@\u0000X\u0080.¢\u0006\u0012\n\u0004\b\u001d\u0010\u001e\u001a\u0004\b\u001f\u0010 \"\u0004\b!\u0010\"R\"\u0010\u0005\u001a\u00020\u00048\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0005\u0010#\u001a\u0004\b$\u0010%\"\u0004\b&\u0010'R\"\u0010\b\u001a\u00020\u00078\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\b\u0010(\u001a\u0004\b)\u0010*\"\u0004\b+\u0010,R\"\u0010\u000b\u001a\u00020\n8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u000b\u0010-\u001a\u0004\b.\u0010/\"\u0004\b0\u00101R\"\u0010\u0014\u001a\u00020\u00138\u0000@\u0000X\u0080.¢\u0006\u0012\n\u0004\b\u0014\u00102\u001a\u0004\b3\u00104\"\u0004\b5\u00106R\"\u0010\u000e\u001a\u00020\r8\u0000@\u0000X\u0080.¢\u0006\u0012\n\u0004\b\u000e\u00107\u001a\u0004\b8\u00109\"\u0004\b:\u0010;R\"\u0010\u0012\u001a\u00020\u00118\u0000@\u0000X\u0080.¢\u0006\u0012\n\u0004\b\u0012\u0010<\u001a\u0004\b=\u0010>\"\u0004\b?\u0010@R\u001c\u0010B\u001a\u00020A8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bB\u0010C\u001a\u0004\bD\u0010E¨\u0006H"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Builder;", "Lokhttp3/internal/http2/Http2Connection;", "build", "()Lokhttp3/internal/http2/Http2Connection;", "Lokhttp3/internal/http2/Http2Connection$Listener;", "listener", "(Lokhttp3/internal/http2/Http2Connection$Listener;)Lokhttp3/internal/http2/Http2Connection$Builder;", HttpUrl.FRAGMENT_ENCODE_SET, "pingIntervalMillis", "(I)Lokhttp3/internal/http2/Http2Connection$Builder;", "Lokhttp3/internal/http2/PushObserver;", "pushObserver", "(Lokhttp3/internal/http2/PushObserver;)Lokhttp3/internal/http2/Http2Connection$Builder;", "Ljava/net/Socket;", "socket", HttpUrl.FRAGMENT_ENCODE_SET, "peerName", "Lokio/BufferedSource;", "source", "Lokio/BufferedSink;", "sink", "(Ljava/net/Socket;Ljava/lang/String;Lokio/BufferedSource;Lokio/BufferedSink;)Lokhttp3/internal/http2/Http2Connection$Builder;", HttpUrl.FRAGMENT_ENCODE_SET, "client", "Z", "getClient$okhttp", "()Z", "setClient$okhttp", "(Z)V", "connectionName", "Ljava/lang/String;", "getConnectionName$okhttp", "()Ljava/lang/String;", "setConnectionName$okhttp", "(Ljava/lang/String;)V", "Lokhttp3/internal/http2/Http2Connection$Listener;", "getListener$okhttp", "()Lokhttp3/internal/http2/Http2Connection$Listener;", "setListener$okhttp", "(Lokhttp3/internal/http2/Http2Connection$Listener;)V", "I", "getPingIntervalMillis$okhttp", "()I", "setPingIntervalMillis$okhttp", "(I)V", "Lokhttp3/internal/http2/PushObserver;", "getPushObserver$okhttp", "()Lokhttp3/internal/http2/PushObserver;", "setPushObserver$okhttp", "(Lokhttp3/internal/http2/PushObserver;)V", "Lokio/BufferedSink;", "getSink$okhttp", "()Lokio/BufferedSink;", "setSink$okhttp", "(Lokio/BufferedSink;)V", "Ljava/net/Socket;", "getSocket$okhttp", "()Ljava/net/Socket;", "setSocket$okhttp", "(Ljava/net/Socket;)V", "Lokio/BufferedSource;", "getSource$okhttp", "()Lokio/BufferedSource;", "setSource$okhttp", "(Lokio/BufferedSource;)V", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "Lokhttp3/internal/concurrent/TaskRunner;", "getTaskRunner$okhttp", "()Lokhttp3/internal/concurrent/TaskRunner;", "", "(ZLokhttp3/internal/concurrent/TaskRunner;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class Builder { private boolean client; public String connectionName; private Listener listener; private int pingIntervalMillis; private PushObserver pushObserver; public g sink; public Socket socket; public h source; private final TaskRunner taskRunner; public Builder(boolean z, TaskRunner taskRunner) { r.g(taskRunner, "taskRunner"); this.client = z; 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, h hVar, g gVar, int i2, Object obj) throws IOException { if ((i2 & 2) != 0) { str = Util.peerName(socket); } if ((i2 & 4) != 0) { hVar = p.d(p.l(socket)); } if ((i2 & 8) != 0) { gVar = p.c(p.h(socket)); } return builder.socket(socket, str, hVar, gVar); } public final Http2Connection build() { return new Http2Connection(this); } public final boolean getClient$okhttp() { return this.client; } public final String getConnectionName$okhttp() { String str = this.connectionName; if (str != null) { return str; } r.t("connectionName"); throw null; } public final Listener getListener$okhttp() { return this.listener; } public final int getPingIntervalMillis$okhttp() { return this.pingIntervalMillis; } public final PushObserver getPushObserver$okhttp() { return this.pushObserver; } public final g getSink$okhttp() { g gVar = this.sink; if (gVar != null) { return gVar; } r.t("sink"); throw null; } public final Socket getSocket$okhttp() { Socket socket = this.socket; if (socket != null) { return socket; } r.t("socket"); throw null; } public final h getSource$okhttp() { h hVar = this.source; if (hVar != null) { return hVar; } r.t("source"); throw null; } public final TaskRunner getTaskRunner$okhttp() { return this.taskRunner; } public final Builder listener(Listener listener) { r.g(listener, "listener"); this.listener = listener; return this; } public final Builder pingIntervalMillis(int i2) { this.pingIntervalMillis = i2; return this; } public final Builder pushObserver(PushObserver pushObserver) { r.g(pushObserver, "pushObserver"); this.pushObserver = pushObserver; return this; } public final void setClient$okhttp(boolean z) { this.client = z; } public final void setConnectionName$okhttp(String str) { r.g(str, ""); this.connectionName = str; } public final void setListener$okhttp(Listener listener) { r.g(listener, ""); this.listener = listener; } public final void setPingIntervalMillis$okhttp(int i2) { this.pingIntervalMillis = i2; } public final void setPushObserver$okhttp(PushObserver pushObserver) { r.g(pushObserver, ""); this.pushObserver = pushObserver; } public final void setSink$okhttp(g gVar) { r.g(gVar, ""); this.sink = gVar; } public final void setSocket$okhttp(Socket socket) { r.g(socket, ""); this.socket = socket; } public final void setSource$okhttp(h hVar) { r.g(hVar, ""); this.source = hVar; } public final Builder socket(Socket socket) throws IOException { return socket$default(this, socket, null, null, null, 14, null); } public final Builder socket(Socket socket, String str) throws IOException { return socket$default(this, socket, str, null, null, 12, null); } public final Builder socket(Socket socket, String str, h hVar) throws IOException { return socket$default(this, socket, str, hVar, null, 8, null); } public final Builder socket(Socket socket, String str, h hVar, g gVar) throws IOException { String str2; r.g(socket, "socket"); r.g(str, "peerName"); r.g(hVar, "source"); r.g(gVar, "sink"); this.socket = socket; if (this.client) { str2 = Util.okHttpName + ' ' + str; } else { str2 = "MockWebServer " + str; } this.connectionName = str2; this.source = hVar; this.sink = gVar; return this; } } /* JADX INFO: compiled from: Http2Connection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000\u0014\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u000b\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\r\u0010\u000eR\u0016\u0010\u0002\u001a\u00020\u00018\u0006@\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u0002\u0010\u0003R\u0019\u0010\u0005\u001a\u00020\u00048\u0006@\u0006¢\u0006\f\n\u0004\b\u0005\u0010\u0006\u001a\u0004\b\u0007\u0010\bR\u0016\u0010\t\u001a\u00020\u00018\u0006@\u0006X\u0086T¢\u0006\u0006\n\u0004\b\t\u0010\u0003R\u0016\u0010\n\u001a\u00020\u00018\u0006@\u0006X\u0086T¢\u0006\u0006\n\u0004\b\n\u0010\u0003R\u0016\u0010\u000b\u001a\u00020\u00018\u0006@\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u000b\u0010\u0003R\u0016\u0010\f\u001a\u00020\u00018\u0006@\u0006X\u0086T¢\u0006\u0006\n\u0004\b\f\u0010\u0003¨\u0006\u000f"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Companion;", HttpUrl.FRAGMENT_ENCODE_SET, "AWAIT_PING", "I", "Lokhttp3/internal/http2/Settings;", "DEFAULT_SETTINGS", "Lokhttp3/internal/http2/Settings;", "getDEFAULT_SETTINGS", "()Lokhttp3/internal/http2/Settings;", "DEGRADED_PING", "DEGRADED_PONG_TIMEOUT_NS", "INTERVAL_PING", "OKHTTP_CLIENT_WINDOW_SIZE", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class Companion { private Companion() { } public final Settings getDEFAULT_SETTINGS() { return Http2Connection.DEFAULT_SETTINGS; } public /* synthetic */ Companion(j jVar) { this(); } } /* JADX INFO: compiled from: Http2Connection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\b&\u0018\u0000 \u000e:\u0001\u000eB\u0007¢\u0006\u0004\b\f\u0010\rJ\u001f\u0010\u0006\u001a\u00020\u00052\u0006\u0010\u0002\u001a\u00020\u00012\u0006\u0010\u0004\u001a\u00020\u0003H\u0016¢\u0006\u0004\b\u0006\u0010\u0007J\u0017\u0010\n\u001a\u00020\u00052\u0006\u0010\t\u001a\u00020\bH&¢\u0006\u0004\b\n\u0010\u000b¨\u0006\u000f"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Listener;", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Settings;", "settings", HttpUrl.FRAGMENT_ENCODE_SET, "onSettings", "(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Settings;)V", "Lokhttp3/internal/http2/Http2Stream;", "stream", "onStream", "(Lokhttp3/internal/http2/Http2Stream;)V", "", "()V", "Companion", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static abstract class Listener { public static final Companion Companion = new Companion(null); 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(Http2Stream http2Stream) throws IOException { r.g(http2Stream, "stream"); http2Stream.close(ErrorCode.REFUSED_STREAM, null); } }; /* JADX INFO: compiled from: Http2Connection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\u0004\u0010\u0005R\u0016\u0010\u0002\u001a\u00020\u00018\u0006@\u0007X\u0087\u0004¢\u0006\u0006\n\u0004\b\u0002\u0010\u0003¨\u0006\u0006"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Listener$Companion;", "Lokhttp3/internal/http2/Http2Connection$Listener;", "REFUSE_INCOMING_STREAMS", "Lokhttp3/internal/http2/Http2Connection$Listener;", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class Companion { private Companion() { } public /* synthetic */ Companion(j jVar) { this(); } } public void onSettings(Http2Connection http2Connection, Settings settings) { r.g(http2Connection, "connection"); r.g(settings, "settings"); } public abstract void onStream(Http2Stream http2Stream) throws IOException; } /* JADX INFO: compiled from: Http2Connection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000`\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0017\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0086\u0004\u0018\u00002\u00020\u00012\u00020\u0002B\u0011\b\u0000\u0012\u0006\u0010?\u001a\u00020>¢\u0006\u0004\bC\u0010DJ\u000f\u0010\u0004\u001a\u00020\u0003H\u0016¢\u0006\u0004\b\u0004\u0010\u0005J?\u0010\u0010\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\f\u001a\u00020\b2\u0006\u0010\r\u001a\u00020\u00062\u0006\u0010\u000f\u001a\u00020\u000eH\u0016¢\u0006\u0004\b\u0010\u0010\u0011J\u001d\u0010\u0016\u001a\u00020\u00032\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0015\u001a\u00020\u0014¢\u0006\u0004\b\u0016\u0010\u0017J/\u0010\u001c\u001a\u00020\u00032\u0006\u0010\u0018\u001a\u00020\u00122\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u001a\u001a\u00020\u00192\u0006\u0010\u001b\u001a\u00020\u0006H\u0016¢\u0006\u0004\b\u001c\u0010\u001dJ'\u0010\"\u001a\u00020\u00032\u0006\u0010\u001e\u001a\u00020\u00062\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010!\u001a\u00020\nH\u0016¢\u0006\u0004\b\"\u0010#J5\u0010(\u001a\u00020\u00032\u0006\u0010\u0018\u001a\u00020\u00122\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010$\u001a\u00020\u00062\f\u0010'\u001a\b\u0012\u0004\u0012\u00020&0%H\u0016¢\u0006\u0004\b(\u0010)J'\u0010-\u001a\u00020\u00032\u0006\u0010*\u001a\u00020\u00122\u0006\u0010+\u001a\u00020\u00062\u0006\u0010,\u001a\u00020\u0006H\u0016¢\u0006\u0004\b-\u0010.J/\u00102\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010/\u001a\u00020\u00062\u0006\u00100\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0012H\u0016¢\u0006\u0004\b2\u00103J-\u00106\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u00104\u001a\u00020\u00062\f\u00105\u001a\b\u0012\u0004\u0012\u00020&0%H\u0016¢\u0006\u0004\b6\u00107J\u001f\u00108\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010 \u001a\u00020\u001fH\u0016¢\u0006\u0004\b8\u00109J\u000f\u0010:\u001a\u00020\u0003H\u0016¢\u0006\u0004\b:\u0010\u0005J\u001f\u0010\u0015\u001a\u00020\u00032\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0015\u001a\u00020\u0014H\u0016¢\u0006\u0004\b\u0015\u0010\u0017J\u001f\u0010<\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010;\u001a\u00020\u000eH\u0016¢\u0006\u0004\b<\u0010=R\u001c\u0010?\u001a\u00020>8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b?\u0010@\u001a\u0004\bA\u0010B¨\u0006E"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "Ljava/lang/Runnable;", "okhttp3/internal/http2/Http2Reader$Handler", HttpUrl.FRAGMENT_ENCODE_SET, "ackSettings", "()V", HttpUrl.FRAGMENT_ENCODE_SET, "streamId", HttpUrl.FRAGMENT_ENCODE_SET, "origin", "Lokio/ByteString;", "protocol", "host", "port", HttpUrl.FRAGMENT_ENCODE_SET, "maxAge", "alternateService", "(ILjava/lang/String;Lokio/ByteString;Ljava/lang/String;IJ)V", HttpUrl.FRAGMENT_ENCODE_SET, "clearPrevious", "Lokhttp3/internal/http2/Settings;", "settings", "applyAndAckSettings", "(ZLokhttp3/internal/http2/Settings;)V", "inFinished", "Lokio/BufferedSource;", "source", "length", "data", "(ZILokio/BufferedSource;I)V", "lastGoodStreamId", "Lokhttp3/internal/http2/ErrorCode;", "errorCode", "debugData", "goAway", "(ILokhttp3/internal/http2/ErrorCode;Lokio/ByteString;)V", "associatedStreamId", HttpUrl.FRAGMENT_ENCODE_SET, "Lokhttp3/internal/http2/Header;", "headerBlock", "headers", "(ZIILjava/util/List;)V", "ack", "payload1", "payload2", "ping", "(ZII)V", "streamDependency", "weight", "exclusive", "priority", "(IIIZ)V", "promisedStreamId", "requestHeaders", "pushPromise", "(IILjava/util/List;)V", "rstStream", "(ILokhttp3/internal/http2/ErrorCode;)V", "run", "windowSizeIncrement", "windowUpdate", "(IJ)V", "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, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class ReaderRunnable implements Runnable, Http2Reader.Handler { private final Http2Reader reader; final /* synthetic */ Http2Connection this$0; public ReaderRunnable(Http2Connection http2Connection, Http2Reader http2Reader) { r.g(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 i2, String str, i iVar, String str2, int i3, long j2) { r.g(str, "origin"); r.g(iVar, "protocol"); r.g(str2, "host"); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Type inference failed for: r2v0, types: [T, okhttp3.internal.http2.Settings] */ public final void applyAndAckSettings(final boolean z, final Settings settings) { Http2Connection http2Connection; T t; r.g(settings, "settings"); final b0 b0Var = new b0(); final c0 c0Var = new c0(); final c0 c0Var2 = new c0(); synchronized (this.this$0.getWriter()) { Http2Connection http2Connection2 = this.this$0; synchronized (http2Connection2) { try { Settings peerSettings = this.this$0.getPeerSettings(); if (z) { c0Var2.b = settings; } else { ?? settings2 = new Settings(); settings2.merge(peerSettings); settings2.merge(settings); c0Var2.b = settings2; } long initialWindowSize = ((long) ((Settings) c0Var2.b).getInitialWindowSize()) - ((long) peerSettings.getInitialWindowSize()); b0Var.b = initialWindowSize; if (initialWindowSize == 0 || this.this$0.getStreams$okhttp().isEmpty()) { t = 0; } else { Object[] array = this.this$0.getStreams$okhttp().values().toArray(new Http2Stream[0]); if (array == null) { throw new w("null cannot be cast to non-null type kotlin.Array"); } t = (Http2Stream[]) array; } c0Var.b = t; this.this$0.setPeerSettings((Settings) c0Var2.b); TaskQueue taskQueue = this.this$0.settingsListenerQueue; final String str = this.this$0.getConnectionName$okhttp() + " onSettings"; final boolean z2 = true; http2Connection = http2Connection2; try { taskQueue.schedule(new Task(str, z2) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$applyAndAckSettings$$inlined$synchronized$lambda$1 /* JADX WARN: Multi-variable type inference failed */ @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.this$0.getListener$okhttp().onSettings(this.this$0, (Settings) c0Var2.b); return -1L; } }, 0L); h0 h0Var = h0.a; try { this.this$0.getWriter().applyAndAckSettings((Settings) c0Var2.b); } catch (IOException e) { this.this$0.failConnection(e); } h0 h0Var2 = h0.a; } catch (Throwable th) { th = th; throw th; } } catch (Throwable th2) { th = th2; http2Connection = http2Connection2; } } } T t2 = c0Var.b; if (((Http2Stream[]) t2) != null) { Http2Stream[] http2StreamArr = (Http2Stream[]) t2; if (http2StreamArr == null) { r.p(); throw null; } for (Http2Stream http2Stream : http2StreamArr) { synchronized (http2Stream) { http2Stream.addBytesToWriteWindow(b0Var.b); h0 h0Var3 = h0.a; } } } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void data(boolean z, int i2, h hVar, int i3) throws IOException { r.g(hVar, "source"); if (this.this$0.pushedStream$okhttp(i2)) { this.this$0.pushDataLater$okhttp(i2, hVar, i3, z); return; } Http2Stream stream = this.this$0.getStream(i2); if (stream == null) { this.this$0.writeSynResetLater$okhttp(i2, ErrorCode.PROTOCOL_ERROR); long j2 = i3; this.this$0.updateConnectionFlowControl$okhttp(j2); hVar.k(j2); return; } stream.receiveData(hVar, i3); if (z) { stream.receiveHeaders(Util.EMPTY_HEADERS, true); } } public final Http2Reader getReader$okhttp() { return this.reader; } @Override // okhttp3.internal.http2.Http2Reader.Handler public void goAway(int i2, ErrorCode errorCode, i iVar) { int i3; Http2Stream[] http2StreamArr; r.g(errorCode, "errorCode"); r.g(iVar, "debugData"); iVar.s(); synchronized (this.this$0) { Object[] array = this.this$0.getStreams$okhttp().values().toArray(new Http2Stream[0]); if (array == null) { throw new w("null cannot be cast to non-null type kotlin.Array"); } http2StreamArr = (Http2Stream[]) array; this.this$0.isShutdown = true; h0 h0Var = h0.a; } for (Http2Stream http2Stream : http2StreamArr) { if (http2Stream.getId() > i2 && http2Stream.isLocallyInitiated()) { http2Stream.receiveRstStream(ErrorCode.REFUSED_STREAM); this.this$0.removeStream$okhttp(http2Stream.getId()); } } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void headers(final boolean z, final int i2, int i3, final List
list) { r.g(list, "headerBlock"); if (this.this$0.pushedStream$okhttp(i2)) { this.this$0.pushHeadersLater$okhttp(i2, list, z); return; } synchronized (this.this$0) { final Http2Stream stream = this.this$0.getStream(i2); if (stream != null) { h0 h0Var = h0.a; stream.receiveHeaders(Util.toHeaders(list), z); return; } if (this.this$0.isShutdown) { return; } if (i2 <= this.this$0.getLastGoodStreamId$okhttp()) { return; } if (i2 % 2 == this.this$0.getNextStreamId$okhttp() % 2) { return; } final Http2Stream http2Stream = new Http2Stream(i2, this.this$0, false, z, Util.toHeaders(list)); this.this$0.setLastGoodStreamId$okhttp(i2); this.this$0.getStreams$okhttp().put(Integer.valueOf(i2), http2Stream); TaskQueue taskQueueNewQueue = this.this$0.taskRunner.newQueue(); final String str = this.this$0.getConnectionName$okhttp() + '[' + i2 + "] onStream"; final boolean z2 = true; taskQueueNewQueue.schedule(new Task(str, z2) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$headers$$inlined$synchronized$lambda$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { this.this$0.getListener$okhttp().onStream(http2Stream); return -1L; } catch (IOException e) { Platform.Companion.get().log("Http2Connection.Listener failure for " + this.this$0.getConnectionName$okhttp(), 4, e); try { http2Stream.close(ErrorCode.PROTOCOL_ERROR, e); return -1L; } catch (IOException unused) { return -1L; } } } }, 0L); } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void ping(boolean z, final int i2, final int i3) { if (!z) { TaskQueue taskQueue = this.this$0.writerQueue; final String str = this.this$0.getConnectionName$okhttp() + " ping"; final boolean z2 = true; taskQueue.schedule(new Task(str, z2) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$ping$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.this$0.writePing(true, i2, i3); return -1L; } }, 0L); return; } synchronized (this.this$0) { if (i2 == 1) { this.this$0.intervalPongsReceived++; } else if (i2 != 2) { if (i2 == 3) { this.this$0.awaitPongsReceived++; Http2Connection http2Connection = this.this$0; if (http2Connection == null) { throw new w("null cannot be cast to non-null type java.lang.Object"); } http2Connection.notifyAll(); } h0 h0Var = h0.a; } else { this.this$0.degradedPongsReceived++; } } } @Override // okhttp3.internal.http2.Http2Reader.Handler public void priority(int i2, int i3, int i4, boolean z) { } @Override // okhttp3.internal.http2.Http2Reader.Handler public void pushPromise(int i2, int i3, List
list) { r.g(list, "requestHeaders"); this.this$0.pushRequestLater$okhttp(i3, list); } @Override // okhttp3.internal.http2.Http2Reader.Handler public void rstStream(int i2, ErrorCode errorCode) { r.g(errorCode, "errorCode"); if (this.this$0.pushedStream$okhttp(i2)) { this.this$0.pushResetLater$okhttp(i2, errorCode); return; } Http2Stream http2StreamRemoveStream$okhttp = this.this$0.removeStream$okhttp(i2); if (http2StreamRemoveStream$okhttp != null) { http2StreamRemoveStream$okhttp.receiveRstStream(errorCode); } } @Override // java.lang.Runnable public void run() throws Throwable { ErrorCode errorCode; ErrorCode errorCode2; ErrorCode errorCode3 = ErrorCode.INTERNAL_ERROR; IOException e = null; try { this.reader.readConnectionPreface(this); while (this.reader.nextFrame(false, this)) { } errorCode = ErrorCode.NO_ERROR; try { try { errorCode2 = ErrorCode.CANCEL; } catch (IOException e2) { e = e2; errorCode = ErrorCode.PROTOCOL_ERROR; errorCode2 = ErrorCode.PROTOCOL_ERROR; } } catch (Throwable th) { th = th; this.this$0.close$okhttp(errorCode, errorCode3, e); Util.closeQuietly(this.reader); throw th; } } catch (IOException e3) { e = e3; } catch (Throwable th2) { th = th2; errorCode = errorCode3; this.this$0.close$okhttp(errorCode, errorCode3, e); Util.closeQuietly(this.reader); throw th; } this.this$0.close$okhttp(errorCode, errorCode2, e); Util.closeQuietly(this.reader); } @Override // okhttp3.internal.http2.Http2Reader.Handler public void settings(final boolean z, final Settings settings) { r.g(settings, "settings"); TaskQueue taskQueue = this.this$0.writerQueue; final String str = this.this$0.getConnectionName$okhttp() + " applyAndAckSettings"; final boolean z2 = true; taskQueue.schedule(new Task(str, z2) { // from class: okhttp3.internal.http2.Http2Connection$ReaderRunnable$settings$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.applyAndAckSettings(z, settings); return -1L; } }, 0L); } @Override // okhttp3.internal.http2.Http2Reader.Handler public void windowUpdate(int i2, long j2) { if (i2 != 0) { Http2Stream stream = this.this$0.getStream(i2); if (stream != null) { synchronized (stream) { stream.addBytesToWriteWindow(j2); h0 h0Var = h0.a; } return; } return; } synchronized (this.this$0) { Http2Connection http2Connection = this.this$0; http2Connection.writeBytesMaximum = http2Connection.getWriteBytesMaximum() + j2; Http2Connection http2Connection2 = this.this$0; if (http2Connection2 == null) { throw new w("null cannot be cast to non-null type java.lang.Object"); } http2Connection2.notifyAll(); h0 h0Var2 = h0.a; } } } static { Settings settings = new Settings(); settings.set(7, Settings.DEFAULT_INITIAL_WINDOW_SIZE); settings.set(5, 16384); DEFAULT_SETTINGS = settings; } public Http2Connection(Builder builder) { r.g(builder, "builder"); this.client = builder.getClient$okhttp(); this.listener = builder.getListener$okhttp(); this.streams = new LinkedHashMap(); this.connectionName = builder.getConnectionName$okhttp(); this.nextStreamId = builder.getClient$okhttp() ? 3 : 2; TaskRunner taskRunner$okhttp = builder.getTaskRunner$okhttp(); this.taskRunner = taskRunner$okhttp; this.writerQueue = taskRunner$okhttp.newQueue(); this.pushQueue = this.taskRunner.newQueue(); this.settingsListenerQueue = this.taskRunner.newQueue(); this.pushObserver = builder.getPushObserver$okhttp(); Settings settings = new Settings(); if (builder.getClient$okhttp()) { settings.set(7, OKHTTP_CLIENT_WINDOW_SIZE); } this.okHttpSettings = settings; this.peerSettings = DEFAULT_SETTINGS; this.writeBytesMaximum = r0.getInitialWindowSize(); this.socket = builder.getSocket$okhttp(); this.writer = new Http2Writer(builder.getSink$okhttp(), this.client); this.readerRunnable = new ReaderRunnable(this, new Http2Reader(builder.getSource$okhttp(), this.client)); this.currentPushRequests = new LinkedHashSet(); if (builder.getPingIntervalMillis$okhttp() != 0) { final long nanos = TimeUnit.MILLISECONDS.toNanos(builder.getPingIntervalMillis$okhttp()); TaskQueue taskQueue = this.writerQueue; final String str = this.connectionName + " ping"; taskQueue.schedule(new Task(str) { // from class: okhttp3.internal.http2.Http2Connection$$special$$inlined$schedule$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { boolean z; synchronized (this) { if (this.intervalPongsReceived < this.intervalPingsSent) { z = true; } else { this.intervalPingsSent++; z = false; } } if (z) { 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 z, int i2, Object obj) throws IOException { if ((i2 & 1) != 0) { z = true; } http2Connection.start(z); } 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(ErrorCode errorCode, ErrorCode errorCode2, IOException iOException) { int i2; r.g(errorCode, "connectionCode"); r.g(errorCode2, "streamCode"); if (Util.assertionsEnabled && Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } try { shutdown(errorCode); } catch (IOException unused) { } Http2Stream[] http2StreamArr = null; synchronized (this) { if (!this.streams.isEmpty()) { Object[] array = this.streams.values().toArray(new Http2Stream[0]); if (array == null) { throw new w("null cannot be cast to non-null type kotlin.Array"); } http2StreamArr = (Http2Stream[]) array; this.streams.clear(); } h0 h0Var = h0.a; } if (http2StreamArr != null) { for (Http2Stream http2Stream : http2StreamArr) { try { http2Stream.close(errorCode2, iOException); } 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(); } public final boolean getClient$okhttp() { return this.client; } public final String getConnectionName$okhttp() { return this.connectionName; } public final int getLastGoodStreamId$okhttp() { return this.lastGoodStreamId; } public final Listener getListener$okhttp() { return this.listener; } public final int getNextStreamId$okhttp() { return this.nextStreamId; } public final Settings getOkHttpSettings() { return this.okHttpSettings; } public final Settings getPeerSettings() { return this.peerSettings; } public final long getReadBytesAcknowledged() { return this.readBytesAcknowledged; } public final long getReadBytesTotal() { return this.readBytesTotal; } public final ReaderRunnable getReaderRunnable() { return this.readerRunnable; } public final Socket getSocket$okhttp() { return this.socket; } public final synchronized Http2Stream getStream(int i2) { return this.streams.get(Integer.valueOf(i2)); } public final Map getStreams$okhttp() { return this.streams; } public final long getWriteBytesMaximum() { return this.writeBytesMaximum; } public final long getWriteBytesTotal() { return this.writeBytesTotal; } public final Http2Writer getWriter() { return this.writer; } public final synchronized boolean isHealthy(long j2) { if (this.isShutdown) { return false; } if (this.degradedPongsReceived < this.degradedPingsSent) { if (j2 >= this.degradedPongDeadlineNs) { return false; } } return true; } public final Http2Stream newStream(List
list, boolean z) throws IOException { r.g(list, "requestHeaders"); return newStream(0, list, z); } public final synchronized int openStreamCount() { return this.streams.size(); } public final void pushDataLater$okhttp(final int i2, h hVar, final int i3, final boolean z) throws IOException { r.g(hVar, "source"); final f fVar = new f(); long j2 = i3; hVar.e0(j2); hVar.read(fVar, j2); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + i2 + "] onData"; final boolean z2 = true; taskQueue.schedule(new Task(str, z2) { // from class: okhttp3.internal.http2.Http2Connection$pushDataLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { boolean zOnData = this.pushObserver.onData(i2, fVar, i3, z); if (zOnData) { this.getWriter().rstStream(i2, ErrorCode.CANCEL); } if (!zOnData && !z) { return -1L; } synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(i2)); } return -1L; } catch (IOException unused) { return -1L; } } }, 0L); } public final void pushHeadersLater$okhttp(final int i2, final List
list, final boolean z) { r.g(list, "requestHeaders"); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + i2 + "] onHeaders"; final boolean z2 = true; taskQueue.schedule(new Task(str, z2) { // from class: okhttp3.internal.http2.Http2Connection$pushHeadersLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { boolean zOnHeaders = this.pushObserver.onHeaders(i2, list, z); if (zOnHeaders) { try { this.getWriter().rstStream(i2, ErrorCode.CANCEL); } catch (IOException unused) { return -1L; } } if (!zOnHeaders && !z) { return -1L; } synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(i2)); } return -1L; } }, 0L); } public final void pushRequestLater$okhttp(final int i2, final List
list) { r.g(list, "requestHeaders"); synchronized (this) { if (this.currentPushRequests.contains(Integer.valueOf(i2))) { writeSynResetLater$okhttp(i2, ErrorCode.PROTOCOL_ERROR); return; } this.currentPushRequests.add(Integer.valueOf(i2)); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + i2 + "] onRequest"; final boolean z = true; taskQueue.schedule(new Task(str, z) { // from class: okhttp3.internal.http2.Http2Connection$pushRequestLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { if (!this.pushObserver.onRequest(i2, list)) { return -1L; } try { this.getWriter().rstStream(i2, ErrorCode.CANCEL); synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(i2)); } return -1L; } catch (IOException unused) { return -1L; } } }, 0L); } } public final void pushResetLater$okhttp(final int i2, final ErrorCode errorCode) { r.g(errorCode, "errorCode"); TaskQueue taskQueue = this.pushQueue; final String str = this.connectionName + '[' + i2 + "] onReset"; final boolean z = true; taskQueue.schedule(new Task(str, z) { // from class: okhttp3.internal.http2.Http2Connection$pushResetLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.pushObserver.onReset(i2, errorCode); synchronized (this) { this.currentPushRequests.remove(Integer.valueOf(i2)); } return -1L; } }, 0L); } public final Http2Stream pushStream(int i2, List
list, boolean z) throws IOException { r.g(list, "requestHeaders"); if (!this.client) { return newStream(i2, list, z); } throw new IllegalStateException("Client cannot push requests.".toString()); } public final boolean pushedStream$okhttp(int i2) { return i2 != 0 && (i2 & 1) == 0; } public final synchronized Http2Stream removeStream$okhttp(int i2) { Http2Stream http2StreamRemove; http2StreamRemove = this.streams.remove(Integer.valueOf(i2)); notifyAll(); return http2StreamRemove; } public final void sendDegradedPingLater$okhttp() { synchronized (this) { if (this.degradedPongsReceived < this.degradedPingsSent) { return; } this.degradedPingsSent++; this.degradedPongDeadlineNs = System.nanoTime() + ((long) DEGRADED_PONG_TIMEOUT_NS); h0 h0Var = h0.a; TaskQueue taskQueue = this.writerQueue; final String str = this.connectionName + " ping"; final boolean z = true; taskQueue.schedule(new Task(str, z) { // from class: okhttp3.internal.http2.Http2Connection$sendDegradedPingLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.writePing(false, 2, 0); return -1L; } }, 0L); } } public final void setLastGoodStreamId$okhttp(int i2) { this.lastGoodStreamId = i2; } public final void setNextStreamId$okhttp(int i2) { this.nextStreamId = i2; } public final void setPeerSettings(Settings settings) { r.g(settings, ""); this.peerSettings = settings; } public final void setSettings(Settings settings) throws IOException { r.g(settings, "settings"); synchronized (this.writer) { synchronized (this) { if (this.isShutdown) { throw new ConnectionShutdownException(); } this.okHttpSettings.merge(settings); h0 h0Var = h0.a; } this.writer.settings(settings); h0 h0Var2 = h0.a; } } public final void shutdown(ErrorCode errorCode) throws IOException { r.g(errorCode, "statusCode"); synchronized (this.writer) { synchronized (this) { if (this.isShutdown) { return; } this.isShutdown = true; int i2 = this.lastGoodStreamId; h0 h0Var = h0.a; this.writer.goAway(i2, errorCode, Util.EMPTY_BYTE_ARRAY); h0 h0Var2 = h0.a; } } } public final void start() throws IOException { start$default(this, false, 1, null); } public final void start(boolean z) throws IOException { if (z) { this.writer.connectionPreface(); this.writer.settings(this.okHttpSettings); if (this.okHttpSettings.getInitialWindowSize() != 65535) { this.writer.windowUpdate(0, r6 - Settings.DEFAULT_INITIAL_WINDOW_SIZE); } } new Thread(this.readerRunnable, this.connectionName).start(); } public final synchronized void updateConnectionFlowControl$okhttp(long j2) { long j3 = this.readBytesTotal + j2; this.readBytesTotal = j3; long j4 = j3 - this.readBytesAcknowledged; if (j4 >= this.okHttpSettings.getInitialWindowSize() / 2) { writeWindowUpdateLater$okhttp(0, j4); this.readBytesAcknowledged += j4; } } public final void writeData(int i2, boolean z, f fVar, long j2) throws IOException { int iMin; if (j2 == 0) { this.writer.data(z, i2, fVar, 0); return; } while (j2 > 0) { a0 a0Var = new a0(); synchronized (this) { while (this.writeBytesTotal >= this.writeBytesMaximum) { try { if (!this.streams.containsKey(Integer.valueOf(i2))) { throw new IOException("stream closed"); } wait(); } catch (InterruptedException unused) { Thread.currentThread().interrupt(); throw new InterruptedIOException(); } } int iMin2 = (int) Math.min(j2, this.writeBytesMaximum - this.writeBytesTotal); a0Var.b = iMin2; iMin = Math.min(iMin2, this.writer.maxDataLength()); a0Var.b = iMin; this.writeBytesTotal += (long) iMin; h0 h0Var = h0.a; } j2 -= (long) iMin; this.writer.data(z && j2 == 0, i2, fVar, a0Var.b); } } public final void writeHeaders$okhttp(int i2, boolean z, List
list) throws IOException { r.g(list, "alternating"); this.writer.headers(z, i2, list); } public final void writePing(boolean z, int i2, int i3) { try { this.writer.ping(z, i2, i3); } catch (IOException e) { failConnection(e); } } public final void writePingAndAwaitPong() throws InterruptedException { writePing(); awaitPong(); } public final void writeSynReset$okhttp(int i2, ErrorCode errorCode) throws IOException { r.g(errorCode, "statusCode"); this.writer.rstStream(i2, errorCode); } public final void writeSynResetLater$okhttp(final int i2, final ErrorCode errorCode) { r.g(errorCode, "errorCode"); TaskQueue taskQueue = this.writerQueue; final String str = this.connectionName + '[' + i2 + "] writeSynReset"; final boolean z = true; taskQueue.schedule(new Task(str, z) { // from class: okhttp3.internal.http2.Http2Connection$writeSynResetLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { this.writeSynReset$okhttp(i2, errorCode); return -1L; } catch (IOException e) { this.failConnection(e); return -1L; } } }, 0L); } public final void writeWindowUpdateLater$okhttp(final int i2, final long j2) { TaskQueue taskQueue = this.writerQueue; final String str = this.connectionName + '[' + i2 + "] windowUpdate"; final boolean z = true; taskQueue.schedule(new Task(str, z) { // from class: okhttp3.internal.http2.Http2Connection$writeWindowUpdateLater$$inlined$execute$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { this.getWriter().windowUpdate(i2, j2); return -1L; } catch (IOException e) { this.failConnection(e); return -1L; } } }, 0L); } private final Http2Stream newStream(int i2, List
list, boolean z) throws IOException { int i3; Http2Stream http2Stream; boolean z2; boolean z3 = !z; synchronized (this.writer) { synchronized (this) { if (this.nextStreamId > 1073741823) { shutdown(ErrorCode.REFUSED_STREAM); } if (this.isShutdown) { throw new ConnectionShutdownException(); } i3 = this.nextStreamId; this.nextStreamId += 2; http2Stream = new Http2Stream(i3, this, z3, false, null); z2 = !z || this.writeBytesTotal >= this.writeBytesMaximum || http2Stream.getWriteBytesTotal() >= http2Stream.getWriteBytesMaximum(); if (http2Stream.isOpen()) { this.streams.put(Integer.valueOf(i3), http2Stream); } h0 h0Var = h0.a; } if (i2 == 0) { this.writer.headers(z3, i3, list); } else { if (!(true ^ this.client)) { throw new IllegalArgumentException("client streams shouldn't have associated stream IDs".toString()); } this.writer.pushPromise(i2, i3, list); } h0 h0Var2 = h0.a; } if (z2) { this.writer.flush(); } return http2Stream; } public final void writePing() throws InterruptedException { synchronized (this) { this.awaitPingsSent++; } writePing(false, 3, 1330343787); } }