CrackMe.apk
Download file
package okhttp3.internal.http2;
import com.google.android.gms.common.internal.ServiceSpecificExtraArgs;
import java.io.Closeable;
import java.io.IOException;
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 kotlin.Metadata;
import kotlin.Unit;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import okhttp3.internal.Util;
import okhttp3.internal.concurrent.TaskQueue;
import okhttp3.internal.concurrent.TaskQueue$execute$1;
import okhttp3.internal.concurrent.TaskRunner;
import okhttp3.internal.http2.Http2Reader;
import okio.Buffer;
import okio.BufferedSink;
import okio.BufferedSource;
import okio.ByteString;
import okio.Okio;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000´\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0010#\n\u0002\u0010\b\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010%\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u001d\n\u0002\u0018\u0002\n\u0002\b\u0014\u0018\u0000 \u00012\u00020\u0001:\b\u0001\u0001\u0001\u0001B\u000f\b\u0000\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0002\u0010\u0004J\u0006\u0010P\u001a\u00020QJ\b\u0010R\u001a\u00020QH\u0016J'\u0010R\u001a\u00020Q2\u0006\u0010S\u001a\u00020T2\u0006\u0010U\u001a\u00020T2\b\u0010V\u001a\u0004\u0018\u00010WH\u0000¢\u0006\u0002\bXJ\u0012\u0010Y\u001a\u00020Q2\b\u0010Z\u001a\u0004\u0018\u00010WH\u0002J\u0006\u0010[\u001a\u00020QJ\u0010\u0010\\\u001a\u0004\u0018\u00010B2\u0006\u0010]\u001a\u00020\u0012J\u000e\u0010^\u001a\u00020\t2\u0006\u0010_\u001a\u00020\u0006J&\u0010`\u001a\u00020B2\u0006\u0010a\u001a\u00020\u00122\f\u0010b\u001a\b\u0012\u0004\u0012\u00020d0c2\u0006\u0010e\u001a\u00020\tH\u0002J\u001c\u0010`\u001a\u00020B2\f\u0010b\u001a\b\u0012\u0004\u0012\u00020d0c2\u0006\u0010e\u001a\u00020\tJ\u0006\u0010f\u001a\u00020\u0012J-\u0010g\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010i\u001a\u00020j2\u0006\u0010k\u001a\u00020\u00122\u0006\u0010l\u001a\u00020\tH\u0000¢\u0006\u0002\bmJ+\u0010n\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\f\u0010b\u001a\b\u0012\u0004\u0012\u00020d0c2\u0006\u0010l\u001a\u00020\tH\u0000¢\u0006\u0002\boJ#\u0010p\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\f\u0010b\u001a\b\u0012\u0004\u0012\u00020d0cH\u0000¢\u0006\u0002\bqJ\u001d\u0010r\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010s\u001a\u00020TH\u0000¢\u0006\u0002\btJ$\u0010u\u001a\u00020B2\u0006\u0010a\u001a\u00020\u00122\f\u0010b\u001a\b\u0012\u0004\u0012\u00020d0c2\u0006\u0010e\u001a\u00020\tJ\u0015\u0010v\u001a\u00020\t2\u0006\u0010h\u001a\u00020\u0012H\u0000¢\u0006\u0002\bwJ\u0017\u0010x\u001a\u0004\u0018\u00010B2\u0006\u0010h\u001a\u00020\u0012H\u0000¢\u0006\u0002\byJ\r\u0010z\u001a\u00020QH\u0000¢\u0006\u0002\b{J\u000e\u0010|\u001a\u00020Q2\u0006\u0010}\u001a\u00020&J\u000e\u0010~\u001a\u00020Q2\u0006\u0010\u001a\u00020TJ\u001e\u0010\u0001\u001a\u00020Q2\t\b\u0002\u0010\u0001\u001a\u00020\t2\b\b\u0002\u0010E\u001a\u00020FH\u0007J\u0018\u0010\u0001\u001a\u00020Q2\u0007\u0010\u0001\u001a\u00020\u0006H\u0000¢\u0006\u0003\b\u0001J,\u0010
\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0007\u0010\u0001\u001a\u00020\t2\n\u0010\u0001\u001a\u0005\u0018\u00010\u00012\u0006\u0010k\u001a\u00020\u0006J/\u0010\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0007\u0010\u0001\u001a\u00020\t2\r\u0010\u0001\u001a\b\u0012\u0004\u0012\u00020d0cH\u0000¢\u0006\u0003\b\u0001J\u0007\u0010\u0001\u001a\u00020QJ\"\u0010\u0001\u001a\u00020Q2\u0007\u0010\u0001\u001a\u00020\t2\u0007\u0010\u0001\u001a\u00020\u00122\u0007\u0010\u0001\u001a\u00020\u0012J\u0007\u0010\u0001\u001a\u00020QJ\u001f\u0010\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010\u001a\u00020TH\u0000¢\u0006\u0003\b\u0001J\u001f\u0010\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010s\u001a\u00020TH\u0000¢\u0006\u0003\b\u0001J \u0010\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0007\u0010\u0001\u001a\u00020\u0006H\u0000¢\u0006\u0003\b\u0001R\u000e\u0010\u0005\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0007\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u0014\u0010\b\u001a\u00020\tX\u0004¢\u0006\b\n\u0000\u001a\u0004\b\n\u0010\u000bR\u0014\u0010\f\u001a\u00020\rX\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u000e\u0010\u000fR\u0014\u0010\u0010\u001a\b\u0012\u0004\u0012\u00020\u00120\u0011X\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0013\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0014\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0015\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0016\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0017\u001a\u00020\u0006X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0018\u001a\u00020\tX\u000e¢\u0006\u0002\n\u0000R\u001a\u0010\u0019\u001a\u00020\u0012X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u001a\u0010\u001b\"\u0004\b\u001c\u0010\u001dR\u0014\u0010\u001e\u001a\u00020\u001fX\u0004¢\u0006\b\n\u0000\u001a\u0004\b \u0010!R\u001a\u0010\"\u001a\u00020\u0012X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b#\u0010\u001b\"\u0004\b$\u0010\u001dR\u0011\u0010%\u001a\u00020&¢\u0006\b\n\u0000\u001a\u0004\b'\u0010(R\u001a\u0010)\u001a\u00020&X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b*\u0010(\"\u0004\b+\u0010,R\u000e\u0010-\u001a\u00020.X\u0004¢\u0006\u0002\n\u0000R\u000e\u0010/\u001a\u000200X\u0004¢\u0006\u0002\n\u0000R\u001e\u00102\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u000e¢\u0006\b\n\u0000\u001a\u0004\b3\u00104R\u001e\u00105\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u000e¢\u0006\b\n\u0000\u001a\u0004\b6\u00104R\u0015\u00107\u001a\u000608R\u00020\u0000¢\u0006\b\n\u0000\u001a\u0004\b9\u0010:R\u000e\u0010;\u001a\u000200X\u0004¢\u0006\u0002\n\u0000R\u0014\u0010<\u001a\u00020=X\u0004¢\u0006\b\n\u0000\u001a\u0004\b>\u0010?R \u0010@\u001a\u000e\u0012\u0004\u0012\u00020\u0012\u0012\u0004\u0012\u00020B0AX\u0004¢\u0006\b\n\u0000\u001a\u0004\bC\u0010DR\u000e\u0010E\u001a\u00020FX\u0004¢\u0006\u0002\n\u0000R\u001e\u0010G\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u000e¢\u0006\b\n\u0000\u001a\u0004\bH\u00104R\u001e\u0010I\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u000e¢\u0006\b\n\u0000\u001a\u0004\bJ\u00104R\u0011\u0010K\u001a\u00020L¢\u0006\b\n\u0000\u001a\u0004\bM\u0010NR\u000e\u0010O\u001a\u000200X\u0004¢\u0006\u0002\n\u0000¨\u0006\u0001"}, d2 = {"Lokhttp3/internal/http2/Http2Connection;", "Ljava/io/Closeable;", "builder", "Lokhttp3/internal/http2/Http2Connection$Builder;", "(Lokhttp3/internal/http2/Http2Connection$Builder;)V", "awaitPingsSent", "", "awaitPongsReceived", "client", "", "getClient$okhttp", "()Z", "connectionName", "", "getConnectionName$okhttp", "()Ljava/lang/String;", "currentPushRequests", "", "", "degradedPingsSent", "degradedPongDeadlineNs", "degradedPongsReceived", "intervalPingsSent", "intervalPongsReceived", "isShutdown", "lastGoodStreamId", "getLastGoodStreamId$okhttp", "()I", "setLastGoodStreamId$okhttp", "(I)V", "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/Settings;)V", "pushObserver", "Lokhttp3/internal/http2/PushObserver;", "pushQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "<set-?>", "readBytesAcknowledged", "getReadBytesAcknowledged", "()J", "readBytesTotal", "getReadBytesTotal", "readerRunnable", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "getReaderRunnable", "()Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "settingsListenerQueue", "socket", "Ljava/net/Socket;", "getSocket$okhttp", "()Ljava/net/Socket;", "streams", "", "Lokhttp3/internal/http2/Http2Stream;", "getStreams$okhttp", "()Ljava/util/Map;", "taskRunner", "Lokhttp3/internal/concurrent/TaskRunner;", "writeBytesMaximum", "getWriteBytesMaximum", "writeBytesTotal", "getWriteBytesTotal", "writer", "Lokhttp3/internal/http2/Http2Writer;", "getWriter", "()Lokhttp3/internal/http2/Http2Writer;", "writerQueue", "awaitPong", "", "close", "connectionCode", "Lokhttp3/internal/http2/ErrorCode;", "streamCode", "cause", "Ljava/io/IOException;", "close$okhttp", "failConnection", "e", "flush", "getStream", "id", "isHealthy", "nowNs", "newStream", "associatedStreamId", "requestHeaders", "", "Lokhttp3/internal/http2/Header;", "out", "openStreamCount", "pushDataLater", "streamId", "source", "Lokio/BufferedSource;", "byteCount", "inFinished", "pushDataLater$okhttp", "pushHeadersLater", "pushHeadersLater$okhttp", "pushRequestLater", "pushRequestLater$okhttp", "pushResetLater", "errorCode", "pushResetLater$okhttp", "pushStream", "pushedStream", "pushedStream$okhttp", "removeStream", "removeStream$okhttp", "sendDegradedPingLater", "sendDegradedPingLater$okhttp", "setSettings", "settings", "shutdown", "statusCode", "start", "sendConnectionPreface", "updateConnectionFlowControl", "read", "updateConnectionFlowControl$okhttp", "writeData", "outFinished", "buffer", "Lokio/Buffer;", "writeHeaders", "alternating", "writeHeaders$okhttp", "writePing", "reply", "payload1", "payload2", "writePingAndAwaitPong", "writeSynReset", "writeSynReset$okhttp", "writeSynResetLater", "writeSynResetLater$okhttp", "writeWindowUpdateLater", "unacknowledgedBytesRead", "writeWindowUpdateLater$okhttp", "Builder", "Companion", "Listener", "ReaderRunnable", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Connection.kt */
public final class Http2Connection implements Closeable {
public static final int AWAIT_PING = 3;
public static final Companion Companion = new Companion((DefaultConstructorMarker) null);
/* access modifiers changed from: private */
public 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;
/* access modifiers changed from: private */
public long awaitPongsReceived;
private final boolean client;
private final String connectionName;
/* access modifiers changed from: private */
public final Set<Integer> currentPushRequests;
private long degradedPingsSent;
private long degradedPongDeadlineNs;
/* access modifiers changed from: private */
public long degradedPongsReceived;
/* access modifiers changed from: private */
public long intervalPingsSent;
/* access modifiers changed from: private */
public long intervalPongsReceived;
/* access modifiers changed from: private */
public boolean isShutdown;
private int lastGoodStreamId;
private final Listener listener;
private int nextStreamId;
private final Settings okHttpSettings;
private Settings peerSettings;
/* access modifiers changed from: private */
public final PushObserver pushObserver;
private final TaskQueue pushQueue;
private long readBytesAcknowledged;
private long readBytesTotal;
private final ReaderRunnable readerRunnable;
/* access modifiers changed from: private */
public final TaskQueue settingsListenerQueue;
private final Socket socket;
private final Map<Integer, Http2Stream> streams = new LinkedHashMap();
/* access modifiers changed from: private */
public final TaskRunner taskRunner;
/* access modifiers changed from: private */
public long writeBytesMaximum;
private long writeBytesTotal;
private final Http2Writer writer;
/* access modifiers changed from: private */
public final TaskQueue writerQueue;
public final boolean pushedStream$okhttp(int i) {
return i != 0 && (i & 1) == 0;
}
public final void start() throws IOException {
start$default(this, false, (TaskRunner) null, 3, (Object) null);
}
public final void start(boolean z) throws IOException {
start$default(this, z, (TaskRunner) null, 2, (Object) null);
}
public Http2Connection(Builder builder) {
Intrinsics.checkNotNullParameter(builder, "builder");
boolean client$okhttp = builder.getClient$okhttp();
this.client = client$okhttp;
this.listener = builder.getListener$okhttp();
String connectionName$okhttp = builder.getConnectionName$okhttp();
this.connectionName = connectionName$okhttp;
this.nextStreamId = builder.getClient$okhttp() ? 3 : 2;
TaskRunner taskRunner$okhttp = builder.getTaskRunner$okhttp();
this.taskRunner = taskRunner$okhttp;
TaskQueue newQueue = taskRunner$okhttp.newQueue();
this.writerQueue = newQueue;
this.pushQueue = taskRunner$okhttp.newQueue();
this.settingsListenerQueue = taskRunner$okhttp.newQueue();
this.pushObserver = builder.getPushObserver$okhttp();
Settings settings = new Settings();
if (builder.getClient$okhttp()) {
settings.set(7, 16777216);
}
Unit unit = Unit.INSTANCE;
this.okHttpSettings = settings;
Settings settings2 = DEFAULT_SETTINGS;
this.peerSettings = settings2;
this.writeBytesMaximum = (long) settings2.getInitialWindowSize();
this.socket = builder.getSocket$okhttp();
this.writer = new Http2Writer(builder.getSink$okhttp(), client$okhttp);
this.readerRunnable = new ReaderRunnable(this, new Http2Reader(builder.getSource$okhttp(), client$okhttp));
this.currentPushRequests = new LinkedHashSet();
if (builder.getPingIntervalMillis$okhttp() != 0) {
long nanos = TimeUnit.MILLISECONDS.toNanos((long) builder.getPingIntervalMillis$okhttp());
String str = connectionName$okhttp + " ping";
newQueue.schedule(new Http2Connection$$special$$inlined$schedule$1(str, str, this, nanos), nanos);
}
}
public final boolean getClient$okhttp() {
return this.client;
}
public final Listener getListener$okhttp() {
return this.listener;
}
public final Map<Integer, Http2Stream> getStreams$okhttp() {
return this.streams;
}
public final String getConnectionName$okhttp() {
return this.connectionName;
}
public final int getLastGoodStreamId$okhttp() {
return this.lastGoodStreamId;
}
public final void setLastGoodStreamId$okhttp(int i) {
this.lastGoodStreamId = i;
}
public final int getNextStreamId$okhttp() {
return this.nextStreamId;
}
public final void setNextStreamId$okhttp(int i) {
this.nextStreamId = i;
}
public final Settings getOkHttpSettings() {
return this.okHttpSettings;
}
public final Settings getPeerSettings() {
return this.peerSettings;
}
public final void setPeerSettings(Settings settings) {
Intrinsics.checkNotNullParameter(settings, "<set-?>");
this.peerSettings = settings;
}
public final long getReadBytesTotal() {
return this.readBytesTotal;
}
public final long getReadBytesAcknowledged() {
return this.readBytesAcknowledged;
}
public final long getWriteBytesTotal() {
return this.writeBytesTotal;
}
public final long getWriteBytesMaximum() {
return this.writeBytesMaximum;
}
public final Socket getSocket$okhttp() {
return this.socket;
}
public final Http2Writer getWriter() {
return this.writer;
}
public final ReaderRunnable getReaderRunnable() {
return this.readerRunnable;
}
public final synchronized int openStreamCount() {
return this.streams.size();
}
public final synchronized Http2Stream getStream(int i) {
return this.streams.get(Integer.valueOf(i));
}
public final synchronized Http2Stream removeStream$okhttp(int i) {
Http2Stream remove;
remove = this.streams.remove(Integer.valueOf(i));
notifyAll();
return remove;
}
public final synchronized void updateConnectionFlowControl$okhttp(long j) {
long j2 = this.readBytesTotal + j;
this.readBytesTotal = j2;
long j3 = j2 - this.readBytesAcknowledged;
if (j3 >= ((long) (this.okHttpSettings.getInitialWindowSize() / 2))) {
writeWindowUpdateLater$okhttp(0, j3);
this.readBytesAcknowledged += j3;
}
}
public final Http2Stream pushStream(int i, List<Header> list, boolean z) throws IOException {
Intrinsics.checkNotNullParameter(list, "requestHeaders");
if (!this.client) {
return newStream(i, list, z);
}
throw new IllegalStateException("Client cannot push requests.".toString());
}
public final Http2Stream newStream(List<Header> list, boolean z) throws IOException {
Intrinsics.checkNotNullParameter(list, "requestHeaders");
return newStream(0, list, z);
}
/* JADX WARNING: Removed duplicated region for block: B:21:0x0048 */
/* Code decompiled incorrectly, please refer to instructions dump. */
private final okhttp3.internal.http2.Http2Stream newStream(int r11, java.util.List<okhttp3.internal.http2.Header> r12, boolean r13) throws java.io.IOException {
/*
r10 = this;
r6 = r13 ^ 1
r4 = 0
okhttp3.internal.http2.Http2Writer r7 = r10.writer
monitor-enter(r7)
monitor-enter(r10) // Catch:{ all -> 0x008a }
int r0 = r10.nextStreamId // Catch:{ all -> 0x0087 }
r1 = 1073741823(0x3fffffff, float:1.9999999)
if (r0 <= r1) goto L_0x0013
okhttp3.internal.http2.ErrorCode r0 = okhttp3.internal.http2.ErrorCode.REFUSED_STREAM // Catch:{ all -> 0x0087 }
r10.shutdown(r0) // Catch:{ all -> 0x0087 }
L_0x0013:
boolean r0 = r10.isShutdown // Catch:{ all -> 0x0087 }
if (r0 != 0) goto L_0x007f
int r8 = r10.nextStreamId // Catch:{ all -> 0x0087 }
int r0 = r8 + 2
r10.nextStreamId = r0 // Catch:{ all -> 0x0087 }
okhttp3.internal.http2.Http2Stream r9 = new okhttp3.internal.http2.Http2Stream // Catch:{ all -> 0x0087 }
r5 = 0
r0 = r9
r1 = r8
r2 = r10
r3 = r6
r0.<init>(r1, r2, r3, r4, r5) // Catch:{ all -> 0x0087 }
r0 = 1
if (r13 == 0) goto L_0x0041
long r1 = r10.writeBytesTotal // Catch:{ all -> 0x0087 }
long r3 = r10.writeBytesMaximum // Catch:{ all -> 0x0087 }
int r13 = (r1 > r3 ? 1 : (r1 == r3 ? 0 : -1))
if (r13 >= 0) goto L_0x0041
long r1 = r9.getWriteBytesTotal() // Catch:{ all -> 0x0087 }
long r3 = r9.getWriteBytesMaximum() // Catch:{ all -> 0x0087 }
int r13 = (r1 > r3 ? 1 : (r1 == r3 ? 0 : -1))
if (r13 < 0) goto L_0x003f
goto L_0x0041
L_0x003f:
r13 = 0
goto L_0x0042
L_0x0041:
r13 = 1
L_0x0042:
boolean r1 = r9.isOpen() // Catch:{ all -> 0x0087 }
if (r1 == 0) goto L_0x0051
java.util.Map<java.lang.Integer, okhttp3.internal.http2.Http2Stream> r1 = r10.streams // Catch:{ all -> 0x0087 }
java.lang.Integer r2 = java.lang.Integer.valueOf(r8) // Catch:{ all -> 0x0087 }
r1.put(r2, r9) // Catch:{ all -> 0x0087 }
L_0x0051:
kotlin.Unit r1 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x0087 }
monitor-exit(r10) // Catch:{ all -> 0x008a }
if (r11 != 0) goto L_0x005c
okhttp3.internal.http2.Http2Writer r11 = r10.writer // Catch:{ all -> 0x008a }
r11.headers(r6, r8, r12) // Catch:{ all -> 0x008a }
goto L_0x0066
L_0x005c:
boolean r1 = r10.client // Catch:{ all -> 0x008a }
r0 = r0 ^ r1
if (r0 == 0) goto L_0x0071
okhttp3.internal.http2.Http2Writer r0 = r10.writer // Catch:{ all -> 0x008a }
r0.pushPromise(r11, r8, r12) // Catch:{ all -> 0x008a }
L_0x0066:
kotlin.Unit r11 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x008a }
monitor-exit(r7)
if (r13 == 0) goto L_0x0070
okhttp3.internal.http2.Http2Writer r11 = r10.writer
r11.flush()
L_0x0070:
return r9
L_0x0071:
java.lang.String r11 = "client streams shouldn't have associated stream IDs"
java.lang.IllegalArgumentException r12 = new java.lang.IllegalArgumentException // Catch:{ all -> 0x008a }
java.lang.String r11 = r11.toString() // Catch:{ all -> 0x008a }
r12.<init>(r11) // Catch:{ all -> 0x008a }
java.lang.Throwable r12 = (java.lang.Throwable) r12 // Catch:{ all -> 0x008a }
throw r12 // Catch:{ all -> 0x008a }
L_0x007f:
okhttp3.internal.http2.ConnectionShutdownException r11 = new okhttp3.internal.http2.ConnectionShutdownException // Catch:{ all -> 0x0087 }
r11.<init>() // Catch:{ all -> 0x0087 }
java.lang.Throwable r11 = (java.lang.Throwable) r11 // Catch:{ all -> 0x0087 }
throw r11 // Catch:{ all -> 0x0087 }
L_0x0087:
r11 = move-exception
monitor-exit(r10) // Catch:{ all -> 0x008a }
throw r11 // Catch:{ all -> 0x008a }
L_0x008a:
r11 = move-exception
monitor-exit(r7)
throw r11
*/
throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.http2.Http2Connection.newStream(int, java.util.List, boolean):okhttp3.internal.http2.Http2Stream");
}
public final void writeHeaders$okhttp(int i, boolean z, List<Header> list) throws IOException {
Intrinsics.checkNotNullParameter(list, "alternating");
this.writer.headers(z, i, list);
}
/* JADX WARNING: Can't wrap try/catch for region: R(3:27|28|29) */
/* JADX WARNING: Code restructure failed: missing block: B:17:?, code lost:
r3 = java.lang.Math.min((int) java.lang.Math.min(r12, r5 - r3), r8.writer.maxDataLength());
r6 = (long) r3;
r8.writeBytesTotal += r6;
r4 = kotlin.Unit.INSTANCE;
*/
/* JADX WARNING: Code restructure failed: missing block: B:28:?, code lost:
java.lang.Thread.currentThread().interrupt();
*/
/* JADX WARNING: Code restructure failed: missing block: B:29:0x0070, code lost:
throw new java.io.InterruptedIOException();
*/
/* JADX WARNING: Missing exception handler attribute for start block: B:27:0x0062 */
/* Code decompiled incorrectly, please refer to instructions dump. */
public final void writeData(int r9, boolean r10, okio.Buffer r11, long r12) throws java.io.IOException {
/*
r8 = this;
r0 = 0
r1 = 0
int r3 = (r12 > r1 ? 1 : (r12 == r1 ? 0 : -1))
if (r3 != 0) goto L_0x000d
okhttp3.internal.http2.Http2Writer r12 = r8.writer
r12.data(r10, r9, r11, r0)
return
L_0x000d:
int r3 = (r12 > r1 ? 1 : (r12 == r1 ? 0 : -1))
if (r3 <= 0) goto L_0x0073
monitor-enter(r8)
L_0x0012:
long r3 = r8.writeBytesTotal // Catch:{ InterruptedException -> 0x0062 }
long r5 = r8.writeBytesMaximum // Catch:{ InterruptedException -> 0x0062 }
int r7 = (r3 > r5 ? 1 : (r3 == r5 ? 0 : -1))
if (r7 < 0) goto L_0x0037
java.util.Map<java.lang.Integer, okhttp3.internal.http2.Http2Stream> r3 = r8.streams // Catch:{ InterruptedException -> 0x0062 }
java.lang.Integer r4 = java.lang.Integer.valueOf(r9) // Catch:{ InterruptedException -> 0x0062 }
boolean r3 = r3.containsKey(r4) // Catch:{ InterruptedException -> 0x0062 }
if (r3 == 0) goto L_0x002d
r3 = r8
java.lang.Object r3 = (java.lang.Object) r3 // Catch:{ InterruptedException -> 0x0062 }
r3.wait() // Catch:{ InterruptedException -> 0x0062 }
goto L_0x0012
L_0x002d:
java.io.IOException r9 = new java.io.IOException // Catch:{ InterruptedException -> 0x0062 }
java.lang.String r10 = "stream closed"
r9.<init>(r10) // Catch:{ InterruptedException -> 0x0062 }
java.lang.Throwable r9 = (java.lang.Throwable) r9 // Catch:{ InterruptedException -> 0x0062 }
throw r9 // Catch:{ InterruptedException -> 0x0062 }
L_0x0037:
long r5 = r5 - r3
long r3 = java.lang.Math.min(r12, r5) // Catch:{ all -> 0x0060 }
int r4 = (int) r3 // Catch:{ all -> 0x0060 }
okhttp3.internal.http2.Http2Writer r3 = r8.writer // Catch:{ all -> 0x0060 }
int r3 = r3.maxDataLength() // Catch:{ all -> 0x0060 }
int r3 = java.lang.Math.min(r4, r3) // Catch:{ all -> 0x0060 }
long r4 = r8.writeBytesTotal // Catch:{ all -> 0x0060 }
long r6 = (long) r3 // Catch:{ all -> 0x0060 }
long r4 = r4 + r6
r8.writeBytesTotal = r4 // Catch:{ all -> 0x0060 }
kotlin.Unit r4 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x0060 }
monitor-exit(r8)
long r12 = r12 - r6
okhttp3.internal.http2.Http2Writer r4 = r8.writer
if (r10 == 0) goto L_0x005b
int r5 = (r12 > r1 ? 1 : (r12 == r1 ? 0 : -1))
if (r5 != 0) goto L_0x005b
r5 = 1
goto L_0x005c
L_0x005b:
r5 = 0
L_0x005c:
r4.data(r5, r9, r11, r3)
goto L_0x000d
L_0x0060:
r9 = move-exception
goto L_0x0071
L_0x0062:
java.lang.Thread r9 = java.lang.Thread.currentThread() // Catch:{ all -> 0x0060 }
r9.interrupt() // Catch:{ all -> 0x0060 }
java.io.InterruptedIOException r9 = new java.io.InterruptedIOException // Catch:{ all -> 0x0060 }
r9.<init>() // Catch:{ all -> 0x0060 }
java.lang.Throwable r9 = (java.lang.Throwable) r9 // Catch:{ all -> 0x0060 }
throw r9 // Catch:{ all -> 0x0060 }
L_0x0071:
monitor-exit(r8)
throw r9
L_0x0073:
return
*/
throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.http2.Http2Connection.writeData(int, boolean, okio.Buffer, long):void");
}
public final void writeSynResetLater$okhttp(int i, ErrorCode errorCode) {
Intrinsics.checkNotNullParameter(errorCode, "errorCode");
String str = this.connectionName + '[' + i + "] writeSynReset";
this.writerQueue.schedule(new Http2Connection$writeSynResetLater$$inlined$execute$1(str, true, str, true, this, i, errorCode), 0);
}
public final void writeSynReset$okhttp(int i, ErrorCode errorCode) throws IOException {
Intrinsics.checkNotNullParameter(errorCode, "statusCode");
this.writer.rstStream(i, errorCode);
}
public final void writeWindowUpdateLater$okhttp(int i, long j) {
String str = this.connectionName + '[' + i + "] windowUpdate";
this.writerQueue.schedule(new Http2Connection$writeWindowUpdateLater$$inlined$execute$1(str, true, str, true, this, i, j), 0);
}
public final void writePing(boolean z, int i, int i2) {
try {
this.writer.ping(z, i, i2);
} catch (IOException e) {
failConnection(e);
}
}
public final void writePingAndAwaitPong() throws InterruptedException {
writePing();
awaitPong();
}
public final void writePing() throws InterruptedException {
synchronized (this) {
this.awaitPingsSent++;
}
writePing(false, 3, 1330343787);
}
public final synchronized void awaitPong() throws InterruptedException {
while (this.awaitPongsReceived < this.awaitPingsSent) {
wait();
}
}
public final void flush() throws IOException {
this.writer.flush();
}
public final void shutdown(ErrorCode errorCode) throws IOException {
Intrinsics.checkNotNullParameter(errorCode, "statusCode");
synchronized (this.writer) {
synchronized (this) {
if (!this.isShutdown) {
this.isShutdown = true;
int i = this.lastGoodStreamId;
Unit unit = Unit.INSTANCE;
this.writer.goAway(i, errorCode, Util.EMPTY_BYTE_ARRAY);
Unit unit2 = Unit.INSTANCE;
}
}
}
}
public void close() {
close$okhttp(ErrorCode.NO_ERROR, ErrorCode.CANCEL, (IOException) null);
}
/* access modifiers changed from: private */
public final void failConnection(IOException iOException) {
close$okhttp(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, iOException);
}
public static /* synthetic */ void start$default(Http2Connection http2Connection, boolean z, TaskRunner taskRunner2, int i, Object obj) throws IOException {
if ((i & 1) != 0) {
z = true;
}
if ((i & 2) != 0) {
taskRunner2 = TaskRunner.INSTANCE;
}
http2Connection.start(z, taskRunner2);
}
public final void start(boolean z, TaskRunner taskRunner2) throws IOException {
Intrinsics.checkNotNullParameter(taskRunner2, "taskRunner");
if (z) {
this.writer.connectionPreface();
this.writer.settings(this.okHttpSettings);
int initialWindowSize = this.okHttpSettings.getInitialWindowSize();
if (initialWindowSize != 65535) {
this.writer.windowUpdate(0, (long) (initialWindowSize - 65535));
}
}
TaskQueue newQueue = taskRunner2.newQueue();
String str = this.connectionName;
newQueue.schedule(new TaskQueue$execute$1(this.readerRunnable, str, true, str, true), 0);
}
public final void setSettings(Settings settings) throws IOException {
Intrinsics.checkNotNullParameter(settings, "settings");
synchronized (this.writer) {
synchronized (this) {
if (!this.isShutdown) {
this.okHttpSettings.merge(settings);
Unit unit = Unit.INSTANCE;
} else {
throw new ConnectionShutdownException();
}
}
this.writer.settings(settings);
Unit unit2 = Unit.INSTANCE;
}
}
public final synchronized boolean isHealthy(long j) {
if (this.isShutdown) {
return false;
}
if (this.degradedPongsReceived >= this.degradedPingsSent || j < this.degradedPongDeadlineNs) {
return true;
}
return false;
}
public final void sendDegradedPingLater$okhttp() {
synchronized (this) {
long j = this.degradedPongsReceived;
long j2 = this.degradedPingsSent;
if (j >= j2) {
this.degradedPingsSent = j2 + 1;
this.degradedPongDeadlineNs = System.nanoTime() + ((long) DEGRADED_PONG_TIMEOUT_NS);
Unit unit = Unit.INSTANCE;
String str = this.connectionName + " ping";
this.writerQueue.schedule(new Http2Connection$sendDegradedPingLater$$inlined$execute$1(str, true, str, true, this), 0);
}
}
}
@Metadata(bv = {1, 0, 3}, 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\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0007\u0010\b\"\u0004\b\t\u0010\nR\u001a\u0010\u000b\u001a\u00020\fX.¢\u0006\u000e\n\u0000\u001a\u0004\b\r\u0010\u000e\"\u0004\b\u000f\u0010\u0010R\u001a\u0010\u0011\u001a\u00020\u0012X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0013\u0010\u0014\"\u0004\b\u0015\u0010\u0016R\u001a\u0010\u0017\u001a\u00020\u0018X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0019\u0010\u001a\"\u0004\b\u001b\u0010\u001cR\u001a\u0010\u001d\u001a\u00020\u001eX\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u001f\u0010 \"\u0004\b!\u0010\"R\u001a\u0010#\u001a\u00020$X.¢\u0006\u000e\n\u0000\u001a\u0004\b%\u0010&\"\u0004\b'\u0010(R\u001a\u0010)\u001a\u00020*X.¢\u0006\u000e\n\u0000\u001a\u0004\b+\u0010,\"\u0004\b-\u0010.R\u001a\u0010/\u001a\u000200X.¢\u0006\u000e\n\u0000\u001a\u0004\b1\u00102\"\u0004\b3\u00104R\u0014\u0010\u0004\u001a\u00020\u0005X\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, 4, 0})
/* compiled from: Http2Connection.kt */
public static final class Builder {
private boolean client;
public String connectionName;
private Listener listener = Listener.REFUSE_INCOMING_STREAMS;
private int pingIntervalMillis;
private PushObserver pushObserver = PushObserver.CANCEL;
public BufferedSink sink;
public Socket socket;
public BufferedSource source;
private final TaskRunner taskRunner;
public final Builder socket(Socket socket2) throws IOException {
return socket$default(this, socket2, (String) null, (BufferedSource) null, (BufferedSink) null, 14, (Object) null);
}
public final Builder socket(Socket socket2, String str) throws IOException {
return socket$default(this, socket2, str, (BufferedSource) null, (BufferedSink) null, 12, (Object) null);
}
public final Builder socket(Socket socket2, String str, BufferedSource bufferedSource) throws IOException {
return socket$default(this, socket2, str, bufferedSource, (BufferedSink) null, 8, (Object) null);
}
public Builder(boolean z, TaskRunner taskRunner2) {
Intrinsics.checkNotNullParameter(taskRunner2, "taskRunner");
this.client = z;
this.taskRunner = taskRunner2;
}
public final boolean getClient$okhttp() {
return this.client;
}
public final void setClient$okhttp(boolean z) {
this.client = z;
}
public final TaskRunner getTaskRunner$okhttp() {
return this.taskRunner;
}
public final Socket getSocket$okhttp() {
Socket socket2 = this.socket;
if (socket2 == null) {
Intrinsics.throwUninitializedPropertyAccessException("socket");
}
return socket2;
}
public final void setSocket$okhttp(Socket socket2) {
Intrinsics.checkNotNullParameter(socket2, "<set-?>");
this.socket = socket2;
}
public final String getConnectionName$okhttp() {
String str = this.connectionName;
if (str == null) {
Intrinsics.throwUninitializedPropertyAccessException("connectionName");
}
return str;
}
public final void setConnectionName$okhttp(String str) {
Intrinsics.checkNotNullParameter(str, "<set-?>");
this.connectionName = str;
}
public final BufferedSource getSource$okhttp() {
BufferedSource bufferedSource = this.source;
if (bufferedSource == null) {
Intrinsics.throwUninitializedPropertyAccessException("source");
}
return bufferedSource;
}
public final void setSource$okhttp(BufferedSource bufferedSource) {
Intrinsics.checkNotNullParameter(bufferedSource, "<set-?>");
this.source = bufferedSource;
}
public final BufferedSink getSink$okhttp() {
BufferedSink bufferedSink = this.sink;
if (bufferedSink == null) {
Intrinsics.throwUninitializedPropertyAccessException("sink");
}
return bufferedSink;
}
public final void setSink$okhttp(BufferedSink bufferedSink) {
Intrinsics.checkNotNullParameter(bufferedSink, "<set-?>");
this.sink = bufferedSink;
}
public final Listener getListener$okhttp() {
return this.listener;
}
public final void setListener$okhttp(Listener listener2) {
Intrinsics.checkNotNullParameter(listener2, "<set-?>");
this.listener = listener2;
}
public final PushObserver getPushObserver$okhttp() {
return this.pushObserver;
}
public final void setPushObserver$okhttp(PushObserver pushObserver2) {
Intrinsics.checkNotNullParameter(pushObserver2, "<set-?>");
this.pushObserver = pushObserver2;
}
public final int getPingIntervalMillis$okhttp() {
return this.pingIntervalMillis;
}
public final void setPingIntervalMillis$okhttp(int i) {
this.pingIntervalMillis = i;
}
public static /* synthetic */ Builder socket$default(Builder builder, Socket socket2, String str, BufferedSource bufferedSource, BufferedSink bufferedSink, int i, Object obj) throws IOException {
if ((i & 2) != 0) {
str = Util.peerName(socket2);
}
if ((i & 4) != 0) {
bufferedSource = Okio.buffer(Okio.source(socket2));
}
if ((i & 8) != 0) {
bufferedSink = Okio.buffer(Okio.sink(socket2));
}
return builder.socket(socket2, str, bufferedSource, bufferedSink);
}
public final Builder socket(Socket socket2, String str, BufferedSource bufferedSource, BufferedSink bufferedSink) throws IOException {
String str2;
Intrinsics.checkNotNullParameter(socket2, "socket");
Intrinsics.checkNotNullParameter(str, "peerName");
Intrinsics.checkNotNullParameter(bufferedSource, "source");
Intrinsics.checkNotNullParameter(bufferedSink, "sink");
Builder builder = this;
this.socket = socket2;
if (this.client) {
str2 = Util.okHttpName + ' ' + str;
} else {
str2 = "MockWebServer " + str;
}
this.connectionName = str2;
this.source = bufferedSource;
this.sink = bufferedSink;
return this;
}
public final Builder listener(Listener listener2) {
Intrinsics.checkNotNullParameter(listener2, ServiceSpecificExtraArgs.CastExtraArgs.LISTENER);
Builder builder = this;
this.listener = listener2;
return this;
}
public final Builder pushObserver(PushObserver pushObserver2) {
Intrinsics.checkNotNullParameter(pushObserver2, "pushObserver");
Builder builder = this;
this.pushObserver = pushObserver2;
return this;
}
public final Builder pingIntervalMillis(int i) {
Builder builder = this;
this.pingIntervalMillis = i;
return this;
}
public final Http2Connection build() {
return new Http2Connection(this);
}
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000`\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\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\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0010\b\u0004\u0018\u00002\u00020\u00012\b\u0012\u0004\u0012\u00020\u00030\u0002B\u000f\b\u0000\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006J\b\u0010\t\u001a\u00020\u0003H\u0016J8\u0010\n\u001a\u00020\u00032\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010\r\u001a\u00020\u000e2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0011\u001a\u00020\u000e2\u0006\u0010\u0012\u001a\u00020\f2\u0006\u0010\u0013\u001a\u00020\u0014H\u0016J\u0016\u0010\u0015\u001a\u00020\u00032\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u0018\u001a\u00020\u0019J(\u0010\u001a\u001a\u00020\u00032\u0006\u0010\u001b\u001a\u00020\u00172\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010\u001c\u001a\u00020\u001d2\u0006\u0010\u001e\u001a\u00020\fH\u0016J \u0010\u001f\u001a\u00020\u00032\u0006\u0010 \u001a\u00020\f2\u0006\u0010!\u001a\u00020\"2\u0006\u0010#\u001a\u00020\u0010H\u0016J.\u0010$\u001a\u00020\u00032\u0006\u0010\u001b\u001a\u00020\u00172\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010%\u001a\u00020\f2\f\u0010&\u001a\b\u0012\u0004\u0012\u00020(0'H\u0016J\t\u0010)\u001a\u00020\u0003H\u0002J \u0010*\u001a\u00020\u00032\u0006\u0010+\u001a\u00020\u00172\u0006\u0010,\u001a\u00020\f2\u0006\u0010-\u001a\u00020\fH\u0016J(\u0010.\u001a\u00020\u00032\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010/\u001a\u00020\f2\u0006\u00100\u001a\u00020\f2\u0006\u00101\u001a\u00020\u0017H\u0016J&\u00102\u001a\u00020\u00032\u0006\u0010\u000b\u001a\u00020\f2\u0006\u00103\u001a\u00020\f2\f\u00104\u001a\b\u0012\u0004\u0012\u00020(0'H\u0016J\u0018\u00105\u001a\u00020\u00032\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010!\u001a\u00020\"H\u0016J\u0018\u0010\u0018\u001a\u00020\u00032\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u0018\u001a\u00020\u0019H\u0016J\u0018\u00106\u001a\u00020\u00032\u0006\u0010\u000b\u001a\u00020\f2\u0006\u00107\u001a\u00020\u0014H\u0016R\u0014\u0010\u0004\u001a\u00020\u0005X\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0007\u0010\b¨\u00068"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "Lokhttp3/internal/http2/Http2Reader$Handler;", "Lkotlin/Function0;", "", "reader", "Lokhttp3/internal/http2/Http2Reader;", "(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Http2Reader;)V", "getReader$okhttp", "()Lokhttp3/internal/http2/Http2Reader;", "ackSettings", "alternateService", "streamId", "", "origin", "", "protocol", "Lokio/ByteString;", "host", "port", "maxAge", "", "applyAndAckSettings", "clearPrevious", "", "settings", "Lokhttp3/internal/http2/Settings;", "data", "inFinished", "source", "Lokio/BufferedSource;", "length", "goAway", "lastGoodStreamId", "errorCode", "Lokhttp3/internal/http2/ErrorCode;", "debugData", "headers", "associatedStreamId", "headerBlock", "", "Lokhttp3/internal/http2/Header;", "invoke", "ping", "ack", "payload1", "payload2", "priority", "streamDependency", "weight", "exclusive", "pushPromise", "promisedStreamId", "requestHeaders", "rstStream", "windowUpdate", "windowSizeIncrement", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Connection.kt */
public final class ReaderRunnable implements Http2Reader.Handler, Function0<Unit> {
private final Http2Reader reader;
final /* synthetic */ Http2Connection this$0;
public void ackSettings() {
}
public void alternateService(int i, String str, ByteString byteString, String str2, int i2, long j) {
Intrinsics.checkNotNullParameter(str, "origin");
Intrinsics.checkNotNullParameter(byteString, "protocol");
Intrinsics.checkNotNullParameter(str2, "host");
}
public void priority(int i, int i2, int i3, boolean z) {
}
public ReaderRunnable(Http2Connection http2Connection, Http2Reader http2Reader) {
Intrinsics.checkNotNullParameter(http2Reader, "reader");
this.this$0 = http2Connection;
this.reader = http2Reader;
}
public final Http2Reader getReader$okhttp() {
return this.reader;
}
public void invoke() {
ErrorCode errorCode;
ErrorCode errorCode2 = ErrorCode.INTERNAL_ERROR;
ErrorCode errorCode3 = ErrorCode.INTERNAL_ERROR;
IOException e = null;
IOException iOException = null;
try {
this.reader.readConnectionPreface(this);
while (this.reader.nextFrame(false, this)) {
}
errorCode2 = ErrorCode.NO_ERROR;
errorCode = ErrorCode.CANCEL;
} catch (IOException e2) {
e = e2;
errorCode2 = ErrorCode.PROTOCOL_ERROR;
errorCode = ErrorCode.PROTOCOL_ERROR;
} catch (Throwable th) {
this.this$0.close$okhttp(errorCode2, errorCode3, e);
Util.closeQuietly((Closeable) this.reader);
throw th;
}
this.this$0.close$okhttp(errorCode2, errorCode, e);
Util.closeQuietly((Closeable) this.reader);
}
public void data(boolean z, int i, BufferedSource bufferedSource, int i2) throws IOException {
Intrinsics.checkNotNullParameter(bufferedSource, "source");
if (this.this$0.pushedStream$okhttp(i)) {
this.this$0.pushDataLater$okhttp(i, bufferedSource, i2, z);
return;
}
Http2Stream stream = this.this$0.getStream(i);
if (stream == null) {
this.this$0.writeSynResetLater$okhttp(i, ErrorCode.PROTOCOL_ERROR);
long j = (long) i2;
this.this$0.updateConnectionFlowControl$okhttp(j);
bufferedSource.skip(j);
return;
}
stream.receiveData(bufferedSource, i2);
if (z) {
stream.receiveHeaders(Util.EMPTY_HEADERS, true);
}
}
public void headers(boolean z, int i, int i2, List<Header> list) {
boolean z2 = z;
int i3 = i;
List<Header> list2 = list;
Intrinsics.checkNotNullParameter(list2, "headerBlock");
if (this.this$0.pushedStream$okhttp(i3)) {
this.this$0.pushHeadersLater$okhttp(i3, list2, z2);
return;
}
synchronized (this.this$0) {
Http2Stream stream = this.this$0.getStream(i3);
if (stream != null) {
Unit unit = Unit.INSTANCE;
stream.receiveHeaders(Util.toHeaders(list), z2);
} else if (!this.this$0.isShutdown) {
if (i3 > this.this$0.getLastGoodStreamId$okhttp()) {
if (i3 % 2 != this.this$0.getNextStreamId$okhttp() % 2) {
Http2Stream http2Stream = new Http2Stream(i, this.this$0, false, z, Util.toHeaders(list));
this.this$0.setLastGoodStreamId$okhttp(i3);
this.this$0.getStreams$okhttp().put(Integer.valueOf(i), http2Stream);
String str = this.this$0.getConnectionName$okhttp() + '[' + i3 + "] onStream";
this.this$0.taskRunner.newQueue().schedule(new Http2Connection$ReaderRunnable$headers$$inlined$synchronized$lambda$1(str, true, str, true, http2Stream, this, stream, i, list, z), 0);
}
}
}
}
}
public void rstStream(int i, ErrorCode errorCode) {
Intrinsics.checkNotNullParameter(errorCode, "errorCode");
if (this.this$0.pushedStream$okhttp(i)) {
this.this$0.pushResetLater$okhttp(i, errorCode);
return;
}
Http2Stream removeStream$okhttp = this.this$0.removeStream$okhttp(i);
if (removeStream$okhttp != null) {
removeStream$okhttp.receiveRstStream(errorCode);
}
}
public void settings(boolean z, Settings settings) {
Intrinsics.checkNotNullParameter(settings, "settings");
String str = this.this$0.getConnectionName$okhttp() + " applyAndAckSettings";
this.this$0.writerQueue.schedule(new Http2Connection$ReaderRunnable$settings$$inlined$execute$1(str, true, str, true, this, z, settings), 0);
}
/* JADX ERROR: IndexOutOfBoundsException in pass: RegionMakerVisitor
java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at java.util.ArrayList.rangeCheck(ArrayList.java:659)
at java.util.ArrayList.get(ArrayList.java:435)
at jadx.core.dex.nodes.InsnNode.getArg(InsnNode.java:101)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:611)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.traverseMonitorExits(RegionMaker.java:619)
at jadx.core.dex.visitors.regions.RegionMaker.processMonitorEnter(RegionMaker.java:561)
at jadx.core.dex.visitors.regions.RegionMaker.traverse(RegionMaker.java:133)
at jadx.core.dex.visitors.regions.RegionMaker.makeRegion(RegionMaker.java:86)
at jadx.core.dex.visitors.regions.RegionMaker.processMonitorEnter(RegionMaker.java:598)
at jadx.core.dex.visitors.regions.RegionMaker.traverse(RegionMaker.java:133)
at jadx.core.dex.visitors.regions.RegionMaker.makeRegion(RegionMaker.java:86)
at jadx.core.dex.visitors.regions.RegionMakerVisitor.visit(RegionMakerVisitor.java:49)
*/
public final void applyAndAckSettings(boolean r22, okhttp3.internal.http2.Settings r23) {
/*
r21 = this;
r12 = r21
r0 = r23
java.lang.String r1 = "settings"
kotlin.jvm.internal.Intrinsics.checkNotNullParameter(r0, r1)
kotlin.jvm.internal.Ref$LongRef r13 = new kotlin.jvm.internal.Ref$LongRef
r13.<init>()
kotlin.jvm.internal.Ref$ObjectRef r14 = new kotlin.jvm.internal.Ref$ObjectRef
r14.<init>()
kotlin.jvm.internal.Ref$ObjectRef r15 = new kotlin.jvm.internal.Ref$ObjectRef
r15.<init>()
okhttp3.internal.http2.Http2Connection r1 = r12.this$0
okhttp3.internal.http2.Http2Writer r16 = r1.getWriter()
monitor-enter(r16)
okhttp3.internal.http2.Http2Connection r11 = r12.this$0 // Catch:{ all -> 0x0110 }
monitor-enter(r11) // Catch:{ all -> 0x0110 }
okhttp3.internal.http2.Http2Connection r1 = r12.this$0 // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Settings r1 = r1.getPeerSettings() // Catch:{ all -> 0x010b }
if (r22 == 0) goto L_0x002c
r2 = r0
goto L_0x0039
L_0x002c:
okhttp3.internal.http2.Settings r2 = new okhttp3.internal.http2.Settings // Catch:{ all -> 0x010b }
r2.<init>() // Catch:{ all -> 0x010b }
r2.merge(r1) // Catch:{ all -> 0x010b }
r2.merge(r0) // Catch:{ all -> 0x010b }
kotlin.Unit r3 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x010b }
L_0x0039:
r15.element = r2 // Catch:{ all -> 0x010b }
T r2 = r15.element // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Settings r2 = (okhttp3.internal.http2.Settings) r2 // Catch:{ all -> 0x010b }
int r2 = r2.getInitialWindowSize() // Catch:{ all -> 0x010b }
long r2 = (long) r2 // Catch:{ all -> 0x010b }
int r1 = r1.getInitialWindowSize() // Catch:{ all -> 0x010b }
long r4 = (long) r1 // Catch:{ all -> 0x010b }
long r2 = r2 - r4
r13.element = r2 // Catch:{ all -> 0x010b }
long r1 = r13.element // Catch:{ all -> 0x010b }
r10 = 0
r8 = 0
int r3 = (r1 > r8 ? 1 : (r1 == r8 ? 0 : -1))
if (r3 == 0) goto L_0x007f
okhttp3.internal.http2.Http2Connection r1 = r12.this$0 // Catch:{ all -> 0x010b }
java.util.Map r1 = r1.getStreams$okhttp() // Catch:{ all -> 0x010b }
boolean r1 = r1.isEmpty() // Catch:{ all -> 0x010b }
if (r1 == 0) goto L_0x0062
goto L_0x007f
L_0x0062:
okhttp3.internal.http2.Http2Connection r1 = r12.this$0 // Catch:{ all -> 0x010b }
java.util.Map r1 = r1.getStreams$okhttp() // Catch:{ all -> 0x010b }
java.util.Collection r1 = r1.values() // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Http2Stream[] r2 = new okhttp3.internal.http2.Http2Stream[r10] // Catch:{ all -> 0x010b }
java.lang.Object[] r1 = r1.toArray(r2) // Catch:{ all -> 0x010b }
if (r1 == 0) goto L_0x0077
okhttp3.internal.http2.Http2Stream[] r1 = (okhttp3.internal.http2.Http2Stream[]) r1 // Catch:{ all -> 0x010b }
goto L_0x0080
L_0x0077:
java.lang.NullPointerException r0 = new java.lang.NullPointerException // Catch:{ all -> 0x010b }
java.lang.String r1 = "null cannot be cast to non-null type kotlin.Array<T>"
r0.<init>(r1) // Catch:{ all -> 0x010b }
throw r0 // Catch:{ all -> 0x010b }
L_0x007f:
r1 = 0
L_0x0080:
r14.element = r1 // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Http2Connection r1 = r12.this$0 // Catch:{ all -> 0x010b }
T r2 = r15.element // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Settings r2 = (okhttp3.internal.http2.Settings) r2 // Catch:{ all -> 0x010b }
r1.setPeerSettings(r2) // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Http2Connection r1 = r12.this$0 // Catch:{ all -> 0x010b }
okhttp3.internal.concurrent.TaskQueue r7 = r1.settingsListenerQueue // Catch:{ all -> 0x010b }
java.lang.StringBuilder r1 = new java.lang.StringBuilder // Catch:{ all -> 0x010b }
r1.<init>() // Catch:{ all -> 0x010b }
okhttp3.internal.http2.Http2Connection r2 = r12.this$0 // Catch:{ all -> 0x010b }
java.lang.String r2 = r2.getConnectionName$okhttp() // Catch:{ all -> 0x010b }
r1.append(r2) // Catch:{ all -> 0x010b }
java.lang.String r2 = " onSettings"
r1.append(r2) // Catch:{ all -> 0x010b }
java.lang.String r4 = r1.toString() // Catch:{ all -> 0x010b }
r5 = 1
okhttp3.internal.http2.Http2Connection$ReaderRunnable$applyAndAckSettings$$inlined$synchronized$lambda$1 r17 = new okhttp3.internal.http2.Http2Connection$ReaderRunnable$applyAndAckSettings$$inlined$synchronized$lambda$1 // Catch:{ all -> 0x010b }
r1 = r17
r2 = r4
r3 = r5
r6 = r21
r18 = r7
r7 = r15
r8 = r22
r9 = r23
r19 = 0
r10 = r13
r20 = r11
r11 = r14
r1.<init>(r2, r3, r4, r5, r6, r7, r8, r9, r10, r11) // Catch:{ all -> 0x0109 }
r0 = r17
okhttp3.internal.concurrent.Task r0 = (okhttp3.internal.concurrent.Task) r0 // Catch:{ all -> 0x0109 }
r1 = r18
r2 = 0
r1.schedule(r0, r2) // Catch:{ all -> 0x0109 }
kotlin.Unit r0 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x0109 }
monitor-exit(r20) // Catch:{ all -> 0x0110 }
okhttp3.internal.http2.Http2Connection r0 = r12.this$0 // Catch:{ IOException -> 0x00dd }
okhttp3.internal.http2.Http2Writer r0 = r0.getWriter() // Catch:{ IOException -> 0x00dd }
T r1 = r15.element // Catch:{ IOException -> 0x00dd }
okhttp3.internal.http2.Settings r1 = (okhttp3.internal.http2.Settings) r1 // Catch:{ IOException -> 0x00dd }
r0.applyAndAckSettings(r1) // Catch:{ IOException -> 0x00dd }
goto L_0x00e3
L_0x00dd:
r0 = move-exception
okhttp3.internal.http2.Http2Connection r1 = r12.this$0 // Catch:{ all -> 0x0110 }
r1.failConnection(r0) // Catch:{ all -> 0x0110 }
L_0x00e3:
kotlin.Unit r0 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x0110 }
monitor-exit(r16)
T r0 = r14.element
okhttp3.internal.http2.Http2Stream[] r0 = (okhttp3.internal.http2.Http2Stream[]) r0
if (r0 == 0) goto L_0x0108
T r0 = r14.element
okhttp3.internal.http2.Http2Stream[] r0 = (okhttp3.internal.http2.Http2Stream[]) r0
kotlin.jvm.internal.Intrinsics.checkNotNull(r0)
int r1 = r0.length
r10 = 0
L_0x00f5:
if (r10 >= r1) goto L_0x0108
r2 = r0[r10]
monitor-enter(r2)
long r3 = r13.element // Catch:{ all -> 0x0105 }
r2.addBytesToWriteWindow(r3) // Catch:{ all -> 0x0105 }
kotlin.Unit r3 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x0105 }
monitor-exit(r2)
int r10 = r10 + 1
goto L_0x00f5
L_0x0105:
r0 = move-exception
monitor-exit(r2)
throw r0
L_0x0108:
return
L_0x0109:
r0 = move-exception
goto L_0x010e
L_0x010b:
r0 = move-exception
r20 = r11
L_0x010e:
monitor-exit(r20) // Catch:{ all -> 0x0110 }
throw r0 // Catch:{ all -> 0x0110 }
L_0x0110:
r0 = move-exception
monitor-exit(r16)
throw r0
*/
throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.http2.Http2Connection.ReaderRunnable.applyAndAckSettings(boolean, okhttp3.internal.http2.Settings):void");
}
public void ping(boolean z, int i, int i2) {
if (z) {
synchronized (this.this$0) {
if (i == 1) {
Http2Connection http2Connection = this.this$0;
long access$getIntervalPongsReceived$p = http2Connection.intervalPongsReceived;
http2Connection.intervalPongsReceived = 1 + access$getIntervalPongsReceived$p;
Long.valueOf(access$getIntervalPongsReceived$p);
} else if (i != 2) {
if (i == 3) {
Http2Connection http2Connection2 = this.this$0;
http2Connection2.awaitPongsReceived = http2Connection2.awaitPongsReceived + 1;
Http2Connection http2Connection3 = this.this$0;
if (http2Connection3 != null) {
http2Connection3.notifyAll();
} else {
throw new NullPointerException("null cannot be cast to non-null type java.lang.Object");
}
}
Unit unit = Unit.INSTANCE;
} else {
Http2Connection http2Connection4 = this.this$0;
long access$getDegradedPongsReceived$p = http2Connection4.degradedPongsReceived;
http2Connection4.degradedPongsReceived = 1 + access$getDegradedPongsReceived$p;
Long.valueOf(access$getDegradedPongsReceived$p);
}
}
return;
}
String str = this.this$0.getConnectionName$okhttp() + " ping";
this.this$0.writerQueue.schedule(new Http2Connection$ReaderRunnable$ping$$inlined$execute$1(str, true, str, true, this, i, i2), 0);
}
public void goAway(int i, ErrorCode errorCode, ByteString byteString) {
int i2;
Http2Stream[] http2StreamArr;
Intrinsics.checkNotNullParameter(errorCode, "errorCode");
Intrinsics.checkNotNullParameter(byteString, "debugData");
byteString.size();
synchronized (this.this$0) {
Object[] array = this.this$0.getStreams$okhttp().values().toArray(new Http2Stream[0]);
if (array != null) {
http2StreamArr = (Http2Stream[]) array;
this.this$0.isShutdown = true;
Unit unit = Unit.INSTANCE;
} else {
throw new NullPointerException("null cannot be cast to non-null type kotlin.Array<T>");
}
}
for (Http2Stream http2Stream : http2StreamArr) {
if (http2Stream.getId() > i && http2Stream.isLocallyInitiated()) {
http2Stream.receiveRstStream(ErrorCode.REFUSED_STREAM);
this.this$0.removeStream$okhttp(http2Stream.getId());
}
}
}
public void windowUpdate(int i, long j) {
if (i == 0) {
synchronized (this.this$0) {
Http2Connection http2Connection = this.this$0;
http2Connection.writeBytesMaximum = http2Connection.getWriteBytesMaximum() + j;
Http2Connection http2Connection2 = this.this$0;
if (http2Connection2 != null) {
http2Connection2.notifyAll();
Unit unit = Unit.INSTANCE;
} else {
throw new NullPointerException("null cannot be cast to non-null type java.lang.Object");
}
}
return;
}
Http2Stream stream = this.this$0.getStream(i);
if (stream != null) {
synchronized (stream) {
stream.addBytesToWriteWindow(j);
Unit unit2 = Unit.INSTANCE;
}
}
}
public void pushPromise(int i, int i2, List<Header> list) {
Intrinsics.checkNotNullParameter(list, "requestHeaders");
this.this$0.pushRequestLater$okhttp(i2, list);
}
}
public final void pushRequestLater$okhttp(int i, List<Header> list) {
Intrinsics.checkNotNullParameter(list, "requestHeaders");
synchronized (this) {
if (this.currentPushRequests.contains(Integer.valueOf(i))) {
writeSynResetLater$okhttp(i, ErrorCode.PROTOCOL_ERROR);
return;
}
this.currentPushRequests.add(Integer.valueOf(i));
String str = this.connectionName + '[' + i + "] onRequest";
this.pushQueue.schedule(new Http2Connection$pushRequestLater$$inlined$execute$1(str, true, str, true, this, i, list), 0);
}
}
public final void pushHeadersLater$okhttp(int i, List<Header> list, boolean z) {
Intrinsics.checkNotNullParameter(list, "requestHeaders");
String str = this.connectionName + '[' + i + "] onHeaders";
this.pushQueue.schedule(new Http2Connection$pushHeadersLater$$inlined$execute$1(str, true, str, true, this, i, list, z), 0);
}
public final void pushDataLater$okhttp(int i, BufferedSource bufferedSource, int i2, boolean z) throws IOException {
Intrinsics.checkNotNullParameter(bufferedSource, "source");
Buffer buffer = new Buffer();
long j = (long) i2;
bufferedSource.require(j);
bufferedSource.read(buffer, j);
String str = this.connectionName + '[' + i + "] onData";
this.pushQueue.schedule(new Http2Connection$pushDataLater$$inlined$execute$1(str, true, str, true, this, i, buffer, i2, z), 0);
}
public final void pushResetLater$okhttp(int i, ErrorCode errorCode) {
Intrinsics.checkNotNullParameter(errorCode, "errorCode");
String str = this.connectionName + '[' + i + "] onReset";
this.pushQueue.schedule(new Http2Connection$pushResetLater$$inlined$execute$1(str, true, str, true, this, i, errorCode), 0);
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000(\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\b&\u0018\u0000 \f2\u00020\u0001:\u0001\fB\u0005¢\u0006\u0002\u0010\u0002J\u0018\u0010\u0003\u001a\u00020\u00042\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\bH\u0016J\u0010\u0010\t\u001a\u00020\u00042\u0006\u0010\n\u001a\u00020\u000bH&¨\u0006\r"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Listener;", "", "()V", "onSettings", "", "connection", "Lokhttp3/internal/http2/Http2Connection;", "settings", "Lokhttp3/internal/http2/Settings;", "onStream", "stream", "Lokhttp3/internal/http2/Http2Stream;", "Companion", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Connection.kt */
public static abstract class Listener {
public static final Companion Companion = new Companion((DefaultConstructorMarker) null);
public static final Listener REFUSE_INCOMING_STREAMS = new Http2Connection$Listener$Companion$REFUSE_INCOMING_STREAMS$1();
public void onSettings(Http2Connection http2Connection, Settings settings) {
Intrinsics.checkNotNullParameter(http2Connection, "connection");
Intrinsics.checkNotNullParameter(settings, "settings");
}
public abstract void onStream(Http2Stream http2Stream) throws IOException;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\u0012\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\b\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002R\u0010\u0010\u0003\u001a\u00020\u00048\u0006X\u0004¢\u0006\u0002\n\u0000¨\u0006\u0005"}, d2 = {"Lokhttp3/internal/http2/Http2Connection$Listener$Companion;", "", "()V", "REFUSE_INCOMING_STREAMS", "Lokhttp3/internal/http2/Http2Connection$Listener;", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Connection.kt */
public static final class Companion {
private Companion() {
}
public /* synthetic */ Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
}
@Metadata(bv = {1, 0, 3}, 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\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002R\u000e\u0010\u0003\u001a\u00020\u0004XT¢\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\u0004XT¢\u0006\u0002\n\u0000R\u000e\u0010\n\u001a\u00020\u0004XT¢\u0006\u0002\n\u0000R\u000e\u0010\u000b\u001a\u00020\u0004XT¢\u0006\u0002\n\u0000R\u000e\u0010\f\u001a\u00020\u0004XT¢\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, 4, 0})
/* compiled from: Http2Connection.kt */
public static final class Companion {
private Companion() {
}
public /* synthetic */ Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
public final Settings getDEFAULT_SETTINGS() {
return Http2Connection.DEFAULT_SETTINGS;
}
}
static {
Settings settings = new Settings();
settings.set(7, 65535);
settings.set(5, 16384);
DEFAULT_SETTINGS = settings;
}
/* JADX WARNING: Failed to process nested try/catch */
/* JADX WARNING: Missing exception handler attribute for start block: B:31:0x0089 */
/* Code decompiled incorrectly, please refer to instructions dump. */
public final void close$okhttp(okhttp3.internal.http2.ErrorCode r4, okhttp3.internal.http2.ErrorCode r5, java.io.IOException r6) {
/*
r3 = this;
java.lang.String r0 = "connectionCode"
kotlin.jvm.internal.Intrinsics.checkNotNullParameter(r4, r0)
java.lang.String r0 = "streamCode"
kotlin.jvm.internal.Intrinsics.checkNotNullParameter(r5, r0)
boolean r0 = okhttp3.internal.Util.assertionsEnabled
if (r0 == 0) goto L_0x0043
boolean r0 = java.lang.Thread.holdsLock(r3)
if (r0 != 0) goto L_0x0015
goto L_0x0043
L_0x0015:
java.lang.AssertionError r4 = new java.lang.AssertionError
java.lang.StringBuilder r5 = new java.lang.StringBuilder
r5.<init>()
java.lang.String r6 = "Thread "
r5.append(r6)
java.lang.Thread r6 = java.lang.Thread.currentThread()
java.lang.String r0 = "Thread.currentThread()"
kotlin.jvm.internal.Intrinsics.checkNotNullExpressionValue(r6, r0)
java.lang.String r6 = r6.getName()
r5.append(r6)
java.lang.String r6 = " MUST NOT hold lock on "
r5.append(r6)
r5.append(r3)
java.lang.String r5 = r5.toString()
r4.<init>(r5)
java.lang.Throwable r4 = (java.lang.Throwable) r4
throw r4
L_0x0043:
r3.shutdown(r4) // Catch:{ IOException -> 0x0046 }
L_0x0046:
r4 = 0
r0 = r4
okhttp3.internal.http2.Http2Stream[] r0 = (okhttp3.internal.http2.Http2Stream[]) r0
monitor-enter(r3)
java.util.Map<java.lang.Integer, okhttp3.internal.http2.Http2Stream> r0 = r3.streams // Catch:{ all -> 0x009e }
boolean r0 = r0.isEmpty() // Catch:{ all -> 0x009e }
r0 = r0 ^ 1
r1 = 0
if (r0 == 0) goto L_0x0074
java.util.Map<java.lang.Integer, okhttp3.internal.http2.Http2Stream> r4 = r3.streams // Catch:{ all -> 0x009e }
java.util.Collection r4 = r4.values() // Catch:{ all -> 0x009e }
okhttp3.internal.http2.Http2Stream[] r0 = new okhttp3.internal.http2.Http2Stream[r1] // Catch:{ all -> 0x009e }
java.lang.Object[] r4 = r4.toArray(r0) // Catch:{ all -> 0x009e }
if (r4 == 0) goto L_0x006c
okhttp3.internal.http2.Http2Stream[] r4 = (okhttp3.internal.http2.Http2Stream[]) r4 // Catch:{ all -> 0x009e }
java.util.Map<java.lang.Integer, okhttp3.internal.http2.Http2Stream> r0 = r3.streams // Catch:{ all -> 0x009e }
r0.clear() // Catch:{ all -> 0x009e }
goto L_0x0074
L_0x006c:
java.lang.NullPointerException r4 = new java.lang.NullPointerException // Catch:{ all -> 0x009e }
java.lang.String r5 = "null cannot be cast to non-null type kotlin.Array<T>"
r4.<init>(r5) // Catch:{ all -> 0x009e }
throw r4 // Catch:{ all -> 0x009e }
L_0x0074:
kotlin.Unit r0 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x009e }
monitor-exit(r3)
if (r4 == 0) goto L_0x0084
int r0 = r4.length
L_0x007a:
if (r1 >= r0) goto L_0x0084
r2 = r4[r1]
r2.close(r5, r6) // Catch:{ IOException -> 0x0081 }
L_0x0081:
int r1 = r1 + 1
goto L_0x007a
L_0x0084:
okhttp3.internal.http2.Http2Writer r4 = r3.writer // Catch:{ IOException -> 0x0089 }
r4.close() // Catch:{ IOException -> 0x0089 }
L_0x0089:
java.net.Socket r4 = r3.socket // Catch:{ IOException -> 0x008e }
r4.close() // Catch:{ IOException -> 0x008e }
L_0x008e:
okhttp3.internal.concurrent.TaskQueue r4 = r3.writerQueue
r4.shutdown()
okhttp3.internal.concurrent.TaskQueue r4 = r3.pushQueue
r4.shutdown()
okhttp3.internal.concurrent.TaskQueue r4 = r3.settingsListenerQueue
r4.shutdown()
return
L_0x009e:
r4 = move-exception
monitor-exit(r3)
throw r4
*/
throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.http2.Http2Connection.close$okhttp(okhttp3.internal.http2.ErrorCode, okhttp3.internal.http2.ErrorCode, java.io.IOException):void");
}
}
Download file