Http2Connection.smali
.class public final Lokhttp3/internal/http2/Http2Connection;
.super Ljava/lang/Object;
.source "Http2Connection.kt"
# interfaces
.implements Ljava/io/Closeable;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lokhttp3/internal/http2/Http2Connection$Builder;,
Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;,
Lokhttp3/internal/http2/Http2Connection$Listener;,
Lokhttp3/internal/http2/Http2Connection$Companion;
}
.end annotation
.annotation system Ldalvik/annotation/SourceDebugExtension;
value = "SMAP\nHttp2Connection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection\n+ 2 Util.kt\nokhttp3/internal/Util\n+ 3 TaskQueue.kt\nokhttp3/internal/concurrent/TaskQueue\n+ 4 ArraysJVM.kt\nkotlin/collections/ArraysKt__ArraysJVMKt\n+ 5 _Arrays.kt\nkotlin/collections/ArraysKt___ArraysKt\n*L\n1#1,1002:1\n502#2:1003\n496#2:1004\n496#2:1027\n544#2,4:1028\n369#2,5:1032\n369#2,5:1040\n369#2,5:1046\n369#2,5:1051\n91#3,11:1005\n91#3,11:1016\n91#3,11:1056\n91#3,11:1067\n91#3,11:1078\n91#3,11:1089\n91#3,11:1100\n83#3,4:1111\n37#4,2:1037\n10930#5:1039\n10931#5:1045\n*E\n*S KotlinDebug\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection\n*L\n182#1:1003\n310#1:1004\n401#1:1027\n445#1,4:1028\n447#1,5:1032\n459#1,5:1040\n466#1,5:1046\n471#1,5:1051\n339#1,11:1005\n360#1,11:1016\n550#1,11:1056\n889#1,11:1067\n907#1,11:1078\n934#1,11:1089\n948#1,11:1100\n151#1,4:1111\n452#1,2:1037\n459#1:1039\n459#1:1045\n*E\n"
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000\u00b4\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\t\n\u0002\u0008\u0002\n\u0002\u0010\u000b\n\u0002\u0008\u0003\n\u0002\u0010\u000e\n\u0002\u0008\u0003\n\u0002\u0010#\n\u0002\u0010\u0008\n\u0002\u0008\u000c\n\u0002\u0018\u0002\n\u0002\u0008\u0006\n\u0002\u0018\u0002\n\u0002\u0008\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0007\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010%\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u000b\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0008\u001d\n\u0002\u0018\u0002\n\u0002\u0008\u0014\u0018\u0000 \u0099\u00012\u00020\u0001:\u0008\u0098\u0001\u0099\u0001\u009a\u0001\u009b\u0001B\u000f\u0008\u0000\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u00a2\u0006\u0002\u0010\u0004J\u0006\u0010P\u001a\u00020QJ\u0008\u0010R\u001a\u00020QH\u0016J\'\u0010R\u001a\u00020Q2\u0006\u0010S\u001a\u00020T2\u0006\u0010U\u001a\u00020T2\u0008\u0010V\u001a\u0004\u0018\u00010WH\u0000\u00a2\u0006\u0002\u0008XJ\u0012\u0010Y\u001a\u00020Q2\u0008\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\u000c\u0010b\u001a\u0008\u0012\u0004\u0012\u00020d0c2\u0006\u0010e\u001a\u00020\tH\u0002J\u001c\u0010`\u001a\u00020B2\u000c\u0010b\u001a\u0008\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\u00a2\u0006\u0002\u0008mJ+\u0010n\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u000c\u0010b\u001a\u0008\u0012\u0004\u0012\u00020d0c2\u0006\u0010l\u001a\u00020\tH\u0000\u00a2\u0006\u0002\u0008oJ#\u0010p\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u000c\u0010b\u001a\u0008\u0012\u0004\u0012\u00020d0cH\u0000\u00a2\u0006\u0002\u0008qJ\u001d\u0010r\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010s\u001a\u00020TH\u0000\u00a2\u0006\u0002\u0008tJ$\u0010u\u001a\u00020B2\u0006\u0010a\u001a\u00020\u00122\u000c\u0010b\u001a\u0008\u0012\u0004\u0012\u00020d0c2\u0006\u0010e\u001a\u00020\tJ\u0015\u0010v\u001a\u00020\t2\u0006\u0010h\u001a\u00020\u0012H\u0000\u00a2\u0006\u0002\u0008wJ\u0017\u0010x\u001a\u0004\u0018\u00010B2\u0006\u0010h\u001a\u00020\u0012H\u0000\u00a2\u0006\u0002\u0008yJ\r\u0010z\u001a\u00020QH\u0000\u00a2\u0006\u0002\u0008{J\u000e\u0010|\u001a\u00020Q2\u0006\u0010}\u001a\u00020&J\u000e\u0010~\u001a\u00020Q2\u0006\u0010\u007f\u001a\u00020TJ\u0014\u0010\u0080\u0001\u001a\u00020Q2\t\u0008\u0002\u0010\u0081\u0001\u001a\u00020\tH\u0007J\u0018\u0010\u0082\u0001\u001a\u00020Q2\u0007\u0010\u0083\u0001\u001a\u00020\u0006H\u0000\u00a2\u0006\u0003\u0008\u0084\u0001J,\u0010\u0085\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0007\u0010\u0086\u0001\u001a\u00020\t2\n\u0010\u0087\u0001\u001a\u0005\u0018\u00010\u0088\u00012\u0006\u0010k\u001a\u00020\u0006J/\u0010\u0089\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0007\u0010\u0086\u0001\u001a\u00020\t2\r\u0010\u008a\u0001\u001a\u0008\u0012\u0004\u0012\u00020d0cH\u0000\u00a2\u0006\u0003\u0008\u008b\u0001J\u0007\u0010\u008c\u0001\u001a\u00020QJ\"\u0010\u008c\u0001\u001a\u00020Q2\u0007\u0010\u008d\u0001\u001a\u00020\t2\u0007\u0010\u008e\u0001\u001a\u00020\u00122\u0007\u0010\u008f\u0001\u001a\u00020\u0012J\u0007\u0010\u0090\u0001\u001a\u00020QJ\u001f\u0010\u0091\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010\u007f\u001a\u00020TH\u0000\u00a2\u0006\u0003\u0008\u0092\u0001J\u001f\u0010\u0093\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0006\u0010s\u001a\u00020TH\u0000\u00a2\u0006\u0003\u0008\u0094\u0001J \u0010\u0095\u0001\u001a\u00020Q2\u0006\u0010h\u001a\u00020\u00122\u0007\u0010\u0096\u0001\u001a\u00020\u0006H\u0000\u00a2\u0006\u0003\u0008\u0097\u0001R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0007\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0014\u0010\u0008\u001a\u00020\tX\u0080\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008\n\u0010\u000bR\u0014\u0010\u000c\u001a\u00020\rX\u0080\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008\u000e\u0010\u000fR\u0014\u0010\u0010\u001a\u0008\u0012\u0004\u0012\u00020\u00120\u0011X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0013\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0014\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0015\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0016\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0017\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0018\u001a\u00020\tX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u001a\u0010\u0019\u001a\u00020\u0012X\u0080\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u001a\u0010\u001b\"\u0004\u0008\u001c\u0010\u001dR\u0014\u0010\u001e\u001a\u00020\u001fX\u0080\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008 \u0010!R\u001a\u0010\"\u001a\u00020\u0012X\u0080\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008#\u0010\u001b\"\u0004\u0008$\u0010\u001dR\u0011\u0010%\u001a\u00020&\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008\'\u0010(R\u001a\u0010)\u001a\u00020&X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008*\u0010(\"\u0004\u0008+\u0010,R\u000e\u0010-\u001a\u00020.X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010/\u001a\u000200X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001e\u00102\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u0086\u000e\u00a2\u0006\u0008\n\u0000\u001a\u0004\u00083\u00104R\u001e\u00105\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u0086\u000e\u00a2\u0006\u0008\n\u0000\u001a\u0004\u00086\u00104R\u0015\u00107\u001a\u000608R\u00020\u0000\u00a2\u0006\u0008\n\u0000\u001a\u0004\u00089\u0010:R\u000e\u0010;\u001a\u000200X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0014\u0010<\u001a\u00020=X\u0080\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008>\u0010?R \u0010@\u001a\u000e\u0012\u0004\u0012\u00020\u0012\u0012\u0004\u0012\u00020B0AX\u0080\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008C\u0010DR\u000e\u0010E\u001a\u00020FX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001e\u0010G\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u0086\u000e\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008H\u00104R\u001e\u0010I\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u0006@BX\u0086\u000e\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008J\u00104R\u0011\u0010K\u001a\u00020L\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008M\u0010NR\u000e\u0010O\u001a\u000200X\u0082\u0004\u00a2\u0006\u0002\n\u0000\u00a8\u0006\u009c\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 = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# static fields
.field public static final AWAIT_PING:I = 0x3
.field public static final Companion:Lokhttp3/internal/http2/Http2Connection$Companion;
.field private static final DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings;
.field public static final DEGRADED_PING:I = 0x2
.field public static final DEGRADED_PONG_TIMEOUT_NS:I = 0x3b9aca00
.field public static final INTERVAL_PING:I = 0x1
.field public static final OKHTTP_CLIENT_WINDOW_SIZE:I = 0x1000000
# instance fields
.field private awaitPingsSent:J
.field private awaitPongsReceived:J
.field private final client:Z
.field private final connectionName:Ljava/lang/String;
.field private final currentPushRequests:Ljava/util/Set;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Set<",
"Ljava/lang/Integer;",
">;"
}
.end annotation
.end field
.field private degradedPingsSent:J
.field private degradedPongDeadlineNs:J
.field private degradedPongsReceived:J
.field private intervalPingsSent:J
.field private intervalPongsReceived:J
.field private isShutdown:Z
.field private lastGoodStreamId:I
.field private final listener:Lokhttp3/internal/http2/Http2Connection$Listener;
.field private nextStreamId:I
.field private final okHttpSettings:Lokhttp3/internal/http2/Settings;
.field private peerSettings:Lokhttp3/internal/http2/Settings;
.field private final pushObserver:Lokhttp3/internal/http2/PushObserver;
.field private final pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
.field private readBytesAcknowledged:J
.field private readBytesTotal:J
.field private final readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
.field private final settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue;
.field private final socket:Ljava/net/Socket;
.field private final streams:Ljava/util/Map;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Map<",
"Ljava/lang/Integer;",
"Lokhttp3/internal/http2/Http2Stream;",
">;"
}
.end annotation
.end field
.field private final taskRunner:Lokhttp3/internal/concurrent/TaskRunner;
.field private writeBytesMaximum:J
.field private writeBytesTotal:J
.field private final writer:Lokhttp3/internal/http2/Http2Writer;
.field private final writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
# direct methods
.method static constructor <clinit>()V
.registers 3
new-instance v0, Lokhttp3/internal/http2/Http2Connection$Companion;
const/4 v1, 0x0
invoke-direct {v0, v1}, Lokhttp3/internal/http2/Http2Connection$Companion;-><init>(Lkotlin/jvm/internal/DefaultConstructorMarker;)V
sput-object v0, Lokhttp3/internal/http2/Http2Connection;->Companion:Lokhttp3/internal/http2/Http2Connection$Companion;
.line 991
new-instance v0, Lokhttp3/internal/http2/Settings;
invoke-direct {v0}, Lokhttp3/internal/http2/Settings;-><init>()V
const/4 v1, 0x7
const v2, 0xffff
.line 992
invoke-virtual {v0, v1, v2}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings;
const/4 v1, 0x5
const/16 v2, 0x4000
.line 993
invoke-virtual {v0, v1, v2}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings;
.line 991
sput-object v0, Lokhttp3/internal/http2/Http2Connection;->DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings;
return-void
.end method
.method public constructor <init>(Lokhttp3/internal/http2/Http2Connection$Builder;)V
.registers 11
const-string v0, "builder"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 54
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 68
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getClient$okhttp()Z
move-result v0
iput-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z
.line 71
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getListener$okhttp()Lokhttp3/internal/http2/Http2Connection$Listener;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->listener:Lokhttp3/internal/http2/Http2Connection$Listener;
.line 72
new-instance v0, Ljava/util/LinkedHashMap;
invoke-direct {v0}, Ljava/util/LinkedHashMap;-><init>()V
check-cast v0, Ljava/util/Map;
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
.line 73
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getConnectionName$okhttp()Ljava/lang/String;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
.line 77
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getClient$okhttp()Z
move-result v0
if-eqz v0, :cond_2b
const/4 v0, 0x3
goto :goto_2c
:cond_2b
const/4 v0, 0x2
:goto_2c
iput v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
.line 82
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getTaskRunner$okhttp()Lokhttp3/internal/concurrent/TaskRunner;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->taskRunner:Lokhttp3/internal/concurrent/TaskRunner;
.line 85
invoke-virtual {v0}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
.line 88
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->taskRunner:Lokhttp3/internal/concurrent/TaskRunner;
invoke-virtual {v0}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
.line 91
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->taskRunner:Lokhttp3/internal/concurrent/TaskRunner;
invoke-virtual {v0}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue;
.line 94
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getPushObserver$okhttp()Lokhttp3/internal/http2/PushObserver;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushObserver:Lokhttp3/internal/http2/PushObserver;
.line 108
new-instance v0, Lokhttp3/internal/http2/Settings;
invoke-direct {v0}, Lokhttp3/internal/http2/Settings;-><init>()V
.line 112
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getClient$okhttp()Z
move-result v1
if-eqz v1, :cond_61
const/4 v1, 0x7
const/high16 v2, 0x1000000
.line 113
invoke-virtual {v0, v1, v2}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings;
.line 108
:cond_61
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
.line 121
sget-object v0, Lokhttp3/internal/http2/Http2Connection;->DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings;
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings;
.line 136
invoke-virtual {v0}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I
move-result v0
int-to-long v0, v0
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
.line 139
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getSocket$okhttp()Ljava/net/Socket;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket;
.line 140
new-instance v0, Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getSink$okhttp()Lokio/BufferedSink;
move-result-object v1
iget-boolean v2, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z
invoke-direct {v0, v1, v2}, Lokhttp3/internal/http2/Http2Writer;-><init>(Lokio/BufferedSink;Z)V
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
.line 143
new-instance v0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
new-instance v1, Lokhttp3/internal/http2/Http2Reader;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getSource$okhttp()Lokio/BufferedSource;
move-result-object v2
iget-boolean v3, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z
invoke-direct {v1, v2, v3}, Lokhttp3/internal/http2/Http2Reader;-><init>(Lokio/BufferedSource;Z)V
invoke-direct {v0, p0, v1}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;-><init>(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Http2Reader;)V
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
.line 146
new-instance v0, Ljava/util/LinkedHashSet;
invoke-direct {v0}, Ljava/util/LinkedHashSet;-><init>()V
check-cast v0, Ljava/util/Set;
iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set;
.line 149
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getPingIntervalMillis$okhttp()I
move-result v0
if-eqz v0, :cond_d0
.line 150
sget-object v0, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getPingIntervalMillis$okhttp()I
move-result p1
int-to-long v1, p1
invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/TimeUnit;->toNanos(J)J
move-result-wide v0
.line 151
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
iget-object v3, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " ping"
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v5
.line 1111
new-instance v2, Lokhttp3/internal/http2/Http2Connection$$special$$inlined$schedule$1;
move-object v3, v2
move-object v4, v5
move-object v6, p0
move-wide v7, v0
invoke-direct/range {v3 .. v8}, Lokhttp3/internal/http2/Http2Connection$$special$$inlined$schedule$1;-><init>(Ljava/lang/String;Ljava/lang/String;Lokhttp3/internal/http2/Http2Connection;J)V
check-cast v2, Lokhttp3/internal/concurrent/Task;
invoke-virtual {p1, v2, v0, v1}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
:cond_d0
return-void
.end method
.method public static final synthetic access$failConnection(Lokhttp3/internal/http2/Http2Connection;Ljava/io/IOException;)V
.registers 2
.line 54
invoke-direct {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->failConnection(Ljava/io/IOException;)V
return-void
.end method
.method public static final synthetic access$getAwaitPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;)J
.registers 3
.line 54
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPongsReceived:J
return-wide v0
.end method
.method public static final synthetic access$getCurrentPushRequests$p(Lokhttp3/internal/http2/Http2Connection;)Ljava/util/Set;
.registers 1
.line 54
iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set;
return-object p0
.end method
.method public static final synthetic access$getDEFAULT_SETTINGS$cp()Lokhttp3/internal/http2/Settings;
.registers 1
.line 54
sget-object v0, Lokhttp3/internal/http2/Http2Connection;->DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings;
return-object v0
.end method
.method public static final synthetic access$getDegradedPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;)J
.registers 3
.line 54
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J
return-wide v0
.end method
.method public static final synthetic access$getIntervalPingsSent$p(Lokhttp3/internal/http2/Http2Connection;)J
.registers 3
.line 54
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPingsSent:J
return-wide v0
.end method
.method public static final synthetic access$getIntervalPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;)J
.registers 3
.line 54
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPongsReceived:J
return-wide v0
.end method
.method public static final synthetic access$getPushObserver$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/http2/PushObserver;
.registers 1
.line 54
iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->pushObserver:Lokhttp3/internal/http2/PushObserver;
return-object p0
.end method
.method public static final synthetic access$getSettingsListenerQueue$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue;
.registers 1
.line 54
iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue;
return-object p0
.end method
.method public static final synthetic access$getTaskRunner$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskRunner;
.registers 1
.line 54
iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->taskRunner:Lokhttp3/internal/concurrent/TaskRunner;
return-object p0
.end method
.method public static final synthetic access$getWriteBytesMaximum$p(Lokhttp3/internal/http2/Http2Connection;)J
.registers 3
.line 54
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
return-wide v0
.end method
.method public static final synthetic access$getWriterQueue$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue;
.registers 1
.line 54
iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
return-object p0
.end method
.method public static final synthetic access$isShutdown$p(Lokhttp3/internal/http2/Http2Connection;)Z
.registers 1
.line 54
iget-boolean p0, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
return p0
.end method
.method public static final synthetic access$setAwaitPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;J)V
.registers 3
.line 54
iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPongsReceived:J
return-void
.end method
.method public static final synthetic access$setDegradedPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;J)V
.registers 3
.line 54
iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J
return-void
.end method
.method public static final synthetic access$setIntervalPingsSent$p(Lokhttp3/internal/http2/Http2Connection;J)V
.registers 3
.line 54
iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPingsSent:J
return-void
.end method
.method public static final synthetic access$setIntervalPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;J)V
.registers 3
.line 54
iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPongsReceived:J
return-void
.end method
.method public static final synthetic access$setShutdown$p(Lokhttp3/internal/http2/Http2Connection;Z)V
.registers 2
.line 54
iput-boolean p1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
return-void
.end method
.method public static final synthetic access$setWriteBytesMaximum$p(Lokhttp3/internal/http2/Http2Connection;J)V
.registers 3
.line 54
iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
return-void
.end method
.method private final failConnection(Ljava/io/IOException;)V
.registers 4
.line 482
sget-object v0, Lokhttp3/internal/http2/ErrorCode;->PROTOCOL_ERROR:Lokhttp3/internal/http2/ErrorCode;
sget-object v1, Lokhttp3/internal/http2/ErrorCode;->PROTOCOL_ERROR:Lokhttp3/internal/http2/ErrorCode;
invoke-virtual {p0, v0, v1, p1}, Lokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V
return-void
.end method
.method private final newStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;
.registers 14
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;Z)",
"Lokhttp3/internal/http2/Http2Stream;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
xor-int/lit8 v6, p3, 0x1
const/4 v4, 0x0
.line 239
iget-object v7, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
monitor-enter v7
.line 240
:try_start_6
monitor-enter p0
:try_end_7
.catchall {:try_start_6 .. :try_end_7} :catchall_8c
.line 241
:try_start_7
iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
const v1, 0x3fffffff # 1.9999999f
if-le v0, v1, :cond_13
.line 242
sget-object v0, Lokhttp3/internal/http2/ErrorCode;->REFUSED_STREAM:Lokhttp3/internal/http2/ErrorCode;
invoke-virtual {p0, v0}, Lokhttp3/internal/http2/Http2Connection;->shutdown(Lokhttp3/internal/http2/ErrorCode;)V
.line 244
:cond_13
iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
if-nez v0, :cond_81
.line 247
iget v8, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
.line 248
iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
add-int/lit8 v0, v0, 0x2
iput v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
.line 249
new-instance v9, Lokhttp3/internal/http2/Http2Stream;
const/4 v5, 0x0
move-object v0, v9
move v1, v8
move-object v2, p0
move v3, v6
invoke-direct/range {v0 .. v5}, Lokhttp3/internal/http2/Http2Stream;-><init>(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V
const/4 v0, 0x1
if-eqz p3, :cond_43
.line 252
iget-wide v1, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J
iget-wide v3, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
cmp-long p3, v1, v3
if-gez p3, :cond_43
invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->getWriteBytesTotal()J
move-result-wide v1
invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->getWriteBytesMaximum()J
move-result-wide v3
cmp-long p3, v1, v3
if-ltz p3, :cond_41
goto :goto_43
:cond_41
const/4 p3, 0x0
goto :goto_44
:cond_43
:goto_43
const/4 p3, 0x1
.line 253
:goto_44
invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->isOpen()Z
move-result v1
if-eqz v1, :cond_53
.line 254
iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-static {v8}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
invoke-interface {v1, v2, v9}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 256
:cond_53
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_55
.catchall {:try_start_7 .. :try_end_55} :catchall_89
.line 240
:try_start_55
monitor-exit p0
if-nez p1, :cond_5e
.line 258
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {p1, v6, v8, p2}, Lokhttp3/internal/http2/Http2Writer;->headers(ZILjava/util/List;)V
goto :goto_68
.line 260
:cond_5e
iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z
xor-int/2addr v0, v1
if-eqz v0, :cond_73
.line 262
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v0, p1, v8, p2}, Lokhttp3/internal/http2/Http2Writer;->pushPromise(IILjava/util/List;)V
.line 264
:goto_68
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_6a
.catchall {:try_start_55 .. :try_end_6a} :catchall_8c
.line 239
monitor-exit v7
if-eqz p3, :cond_72
.line 267
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->flush()V
:cond_72
return-object v9
:cond_73
:try_start_73
const-string p1, "client streams shouldn\'t have associated stream IDs"
.line 260
new-instance p2, Ljava/lang/IllegalArgumentException;
invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object p1
invoke-direct {p2, p1}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V
check-cast p2, Ljava/lang/Throwable;
throw p2
:try_end_81
.catchall {:try_start_73 .. :try_end_81} :catchall_8c
.line 245
:cond_81
:try_start_81
new-instance p1, Lokhttp3/internal/http2/ConnectionShutdownException;
invoke-direct {p1}, Lokhttp3/internal/http2/ConnectionShutdownException;-><init>()V
check-cast p1, Ljava/lang/Throwable;
throw p1
:try_end_89
.catchall {:try_start_81 .. :try_end_89} :catchall_89
:catchall_89
move-exception p1
.line 240
:try_start_8a
monitor-exit p0
throw p1
:try_end_8c
.catchall {:try_start_8a .. :try_end_8c} :catchall_8c
:catchall_8c
move-exception p1
.line 239
monitor-exit v7
throw p1
.end method
.method public static synthetic start$default(Lokhttp3/internal/http2/Http2Connection;ZILjava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const/4 p3, 0x1
and-int/2addr p2, p3
if-eqz p2, :cond_5
const/4 p1, 0x1
.line 493
:cond_5
invoke-virtual {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->start(Z)V
return-void
.end method
# virtual methods
.method public final declared-synchronized awaitPong()V
.registers 6
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;
}
.end annotation
monitor-enter p0
.line 400
:goto_1
:try_start_1
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPongsReceived:J
iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPingsSent:J
cmp-long v4, v0, v2
if-gez v4, :cond_10
.line 1027
move-object v0, p0
check-cast v0, Ljava/lang/Object;
invoke-virtual {v0}, Ljava/lang/Object;->wait()V
:try_end_f
.catchall {:try_start_1 .. :try_end_f} :catchall_12
goto :goto_1
.line 403
:cond_10
monitor-exit p0
return-void
:catchall_12
move-exception v0
monitor-exit p0
throw v0
.end method
.method public close()V
.registers 4
.line 437
sget-object v0, Lokhttp3/internal/http2/ErrorCode;->NO_ERROR:Lokhttp3/internal/http2/ErrorCode;
sget-object v1, Lokhttp3/internal/http2/ErrorCode;->CANCEL:Lokhttp3/internal/http2/ErrorCode;
const/4 v2, 0x0
invoke-virtual {p0, v0, v1, v2}, Lokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V
return-void
.end method
.method public final close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V
.registers 7
const-string v0, "connectionCode"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
const-string v0, "streamCode"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 1028
sget-boolean v0, Lokhttp3/internal/Util;->assertionsEnabled:Z
if-eqz v0, :cond_43
invoke-static {p0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_15
goto :goto_43
.line 1029
:cond_15
new-instance p1, Ljava/lang/AssertionError;
new-instance p2, Ljava/lang/StringBuilder;
invoke-direct {p2}, Ljava/lang/StringBuilder;-><init>()V
const-string p3, "Thread "
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object p3
const-string v0, "Thread.currentThread()"
invoke-static {p3, v0}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-virtual {p3}, Ljava/lang/Thread;->getName()Ljava/lang/String;
move-result-object p3
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string p3, " MUST NOT hold lock on "
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p2, p0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-direct {p1, p2}, Ljava/lang/AssertionError;-><init>(Ljava/lang/Object;)V
check-cast p1, Ljava/lang/Throwable;
throw p1
.line 448
:cond_43
:goto_43
:try_start_43
invoke-virtual {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->shutdown(Lokhttp3/internal/http2/ErrorCode;)V
:try_end_46
.catch Ljava/io/IOException; {:try_start_43 .. :try_end_46} :catch_46
:catch_46
const/4 p1, 0x0
.line 451
check-cast p1, [Lokhttp3/internal/http2/Http2Stream;
.line 452
monitor-enter p0
.line 453
:try_start_4a
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->isEmpty()Z
move-result v0
xor-int/lit8 v0, v0, 0x1
const/4 v1, 0x0
if-eqz v0, :cond_73
.line 454
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-interface {p1}, Ljava/util/Map;->values()Ljava/util/Collection;
move-result-object p1
new-array v0, v1, [Lokhttp3/internal/http2/Http2Stream;
.line 1038
invoke-interface {p1, v0}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;
move-result-object p1
if-eqz p1, :cond_6b
check-cast p1, [Lokhttp3/internal/http2/Http2Stream;
.line 455
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->clear()V
goto :goto_73
.line 1038
:cond_6b
new-instance p1, Lkotlin/TypeCastException;
const-string p2, "null cannot be cast to non-null type kotlin.Array<T>"
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
.line 457
:cond_73
:goto_73
sget-object v0, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_75
.catchall {:try_start_4a .. :try_end_75} :catchall_9d
.line 452
monitor-exit p0
if-eqz p1, :cond_83
.line 1039
array-length v0, p1
:goto_79
if-ge v1, v0, :cond_83
aget-object v2, p1, v1
.line 461
:try_start_7d
invoke-virtual {v2, p2, p3}, Lokhttp3/internal/http2/Http2Stream;->close(Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V
:try_end_80
.catch Ljava/io/IOException; {:try_start_7d .. :try_end_80} :catch_80
:catch_80
add-int/lit8 v1, v1, 0x1
goto :goto_79
.line 467
:cond_83
:try_start_83
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->close()V
:try_end_88
.catch Ljava/io/IOException; {:try_start_83 .. :try_end_88} :catch_88
.line 472
:catch_88
:try_start_88
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket;
invoke-virtual {p1}, Ljava/net/Socket;->close()V
:try_end_8d
.catch Ljava/io/IOException; {:try_start_88 .. :try_end_8d} :catch_8d
.line 476
:catch_8d
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->shutdown()V
.line 477
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->shutdown()V
.line 478
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue;
invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->shutdown()V
return-void
:catchall_9d
move-exception p1
.line 452
monitor-exit p0
throw p1
.end method
.method public final flush()V
.registers 2
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
.line 407
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Writer;->flush()V
return-void
.end method
.method public final getClient$okhttp()Z
.registers 2
.line 68
iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z
return v0
.end method
.method public final getConnectionName$okhttp()Ljava/lang/String;
.registers 2
.line 73
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
return-object v0
.end method
.method public final getLastGoodStreamId$okhttp()I
.registers 2
.line 74
iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I
return v0
.end method
.method public final getListener$okhttp()Lokhttp3/internal/http2/Http2Connection$Listener;
.registers 2
.line 71
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->listener:Lokhttp3/internal/http2/Http2Connection$Listener;
return-object v0
.end method
.method public final getNextStreamId$okhttp()I
.registers 2
.line 77
iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
return v0
.end method
.method public final getOkHttpSettings()Lokhttp3/internal/http2/Settings;
.registers 2
.line 108
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
return-object v0
.end method
.method public final getPeerSettings()Lokhttp3/internal/http2/Settings;
.registers 2
.line 121
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings;
return-object v0
.end method
.method public final getReadBytesAcknowledged()J
.registers 3
.line 128
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J
return-wide v0
.end method
.method public final getReadBytesTotal()J
.registers 3
.line 124
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesTotal:J
return-wide v0
.end method
.method public final getReaderRunnable()Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
.registers 2
.line 143
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
return-object v0
.end method
.method public final getSocket$okhttp()Ljava/net/Socket;
.registers 2
.line 139
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket;
return-object v0
.end method
.method public final declared-synchronized getStream(I)Lokhttp3/internal/http2/Http2Stream;
.registers 3
monitor-enter p0
.line 176
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object p1
invoke-interface {v0, p1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Lokhttp3/internal/http2/Http2Stream;
:try_end_d
.catchall {:try_start_1 .. :try_end_d} :catchall_f
monitor-exit p0
return-object p1
:catchall_f
move-exception p1
monitor-exit p0
throw p1
.end method
.method public final getStreams$okhttp()Ljava/util/Map;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/Map<",
"Ljava/lang/Integer;",
"Lokhttp3/internal/http2/Http2Stream;",
">;"
}
.end annotation
.line 72
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
return-object v0
.end method
.method public final getWriteBytesMaximum()J
.registers 3
.line 136
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
return-wide v0
.end method
.method public final getWriteBytesTotal()J
.registers 3
.line 132
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J
return-wide v0
.end method
.method public final getWriter()Lokhttp3/internal/http2/Http2Writer;
.registers 2
.line 140
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
return-object v0
.end method
.method public final declared-synchronized isHealthy(J)Z
.registers 9
monitor-enter p0
.line 521
:try_start_1
iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_1b
const/4 v1, 0x0
if-eqz v0, :cond_8
monitor-exit p0
return v1
.line 524
:cond_8
:try_start_8
iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J
iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J
cmp-long v0, v2, v4
if-gez v0, :cond_18
iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongDeadlineNs:J
:try_end_12
.catchall {:try_start_8 .. :try_end_12} :catchall_1b
cmp-long v0, p1, v2
if-ltz v0, :cond_18
monitor-exit p0
return v1
:cond_18
const/4 p1, 0x1
.line 526
monitor-exit p0
return p1
:catchall_1b
move-exception p1
monitor-exit p0
throw p1
.end method
.method public final newStream(Ljava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;Z)",
"Lokhttp3/internal/http2/Http2Stream;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "requestHeaders"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
const/4 v0, 0x0
.line 224
invoke-direct {p0, v0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->newStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;
move-result-object p1
return-object p1
.end method
.method public final declared-synchronized openStreamCount()I
.registers 2
monitor-enter p0
.line 174
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->size()I
move-result v0
:try_end_7
.catchall {:try_start_1 .. :try_end_7} :catchall_9
monitor-exit p0
return v0
:catchall_9
move-exception v0
monitor-exit p0
throw v0
.end method
.method public final pushDataLater$okhttp(ILokio/BufferedSource;IZ)V
.registers 16
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "source"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 931
new-instance v8, Lokio/Buffer;
invoke-direct {v8}, Lokio/Buffer;-><init>()V
int-to-long v0, p3
.line 932
invoke-interface {p2, v0, v1}, Lokio/BufferedSource;->require(J)V
.line 933
invoke-interface {p2, v8, v0, v1}, Lokio/BufferedSource;->read(Lokio/Buffer;J)J
.line 934
iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v1, 0x5b
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v1, "] onData"
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v4
.line 1093
new-instance v0, Lokhttp3/internal/http2/Http2Connection$pushDataLater$$inlined$execute$1;
const/4 v5, 0x1
move-object v1, v0
move-object v2, v4
move v3, v5
move-object v6, p0
move v7, p1
move v9, p3
move v10, p4
invoke-direct/range {v1 .. v10}, Lokhttp3/internal/http2/Http2Connection$pushDataLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILokio/Buffer;IZ)V
check-cast v0, Lokhttp3/internal/concurrent/Task;
const-wide/16 p3, 0x0
invoke-virtual {p2, v0, p3, p4}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
.end method
.method public final pushHeadersLater$okhttp(ILjava/util/List;Z)V
.registers 16
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;Z)V"
}
.end annotation
const-string v0, "requestHeaders"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 907
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v2, 0x5b
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, "] onHeaders"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v6
.line 1082
new-instance v1, Lokhttp3/internal/http2/Http2Connection$pushHeadersLater$$inlined$execute$1;
const/4 v7, 0x1
move-object v3, v1
move-object v4, v6
move v5, v7
move-object v8, p0
move v9, p1
move-object v10, p2
move v11, p3
invoke-direct/range {v3 .. v11}, Lokhttp3/internal/http2/Http2Connection$pushHeadersLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILjava/util/List;Z)V
check-cast v1, Lokhttp3/internal/concurrent/Task;
const-wide/16 p1, 0x0
invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
.end method
.method public final pushRequestLater$okhttp(ILjava/util/List;)V
.registers 15
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;)V"
}
.end annotation
const-string v0, "requestHeaders"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 882
monitor-enter p0
.line 883
:try_start_6
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
invoke-interface {v0, v1}, Ljava/util/Set;->contains(Ljava/lang/Object;)Z
move-result v0
if-eqz v0, :cond_19
.line 884
sget-object p2, Lokhttp3/internal/http2/ErrorCode;->PROTOCOL_ERROR:Lokhttp3/internal/http2/ErrorCode;
invoke-virtual {p0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->writeSynResetLater$okhttp(ILokhttp3/internal/http2/ErrorCode;)V
:try_end_17
.catchall {:try_start_6 .. :try_end_17} :catchall_54
.line 885
monitor-exit p0
return-void
.line 887
:cond_19
:try_start_19
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
invoke-interface {v0, v1}, Ljava/util/Set;->add(Ljava/lang/Object;)Z
:try_end_22
.catchall {:try_start_19 .. :try_end_22} :catchall_54
.line 882
monitor-exit p0
.line 889
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v2, 0x5b
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, "] onRequest"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v6
const-wide/16 v1, 0x0
const/4 v7, 0x1
.line 1071
new-instance v11, Lokhttp3/internal/http2/Http2Connection$pushRequestLater$$inlined$execute$1;
move-object v3, v11
move-object v4, v6
move v5, v7
move-object v8, p0
move v9, p1
move-object v10, p2
invoke-direct/range {v3 .. v10}, Lokhttp3/internal/http2/Http2Connection$pushRequestLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILjava/util/List;)V
check-cast v11, Lokhttp3/internal/concurrent/Task;
invoke-virtual {v0, v11, v1, v2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
:catchall_54
move-exception p1
.line 882
monitor-exit p0
throw p1
.end method
.method public final pushResetLater$okhttp(ILokhttp3/internal/http2/ErrorCode;)V
.registers 14
const-string v0, "errorCode"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 948
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v2, 0x5b
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, "] onReset"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v6
.line 1104
new-instance v1, Lokhttp3/internal/http2/Http2Connection$pushResetLater$$inlined$execute$1;
const/4 v7, 0x1
move-object v3, v1
move-object v4, v6
move v5, v7
move-object v8, p0
move v9, p1
move-object v10, p2
invoke-direct/range {v3 .. v10}, Lokhttp3/internal/http2/Http2Connection$pushResetLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILokhttp3/internal/http2/ErrorCode;)V
check-cast v1, Lokhttp3/internal/concurrent/Task;
const-wide/16 p1, 0x0
invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
.end method
.method public final pushStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;Z)",
"Lokhttp3/internal/http2/Http2Stream;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "requestHeaders"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 209
iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z
xor-int/lit8 v0, v0, 0x1
if-eqz v0, :cond_10
.line 210
invoke-direct {p0, p1, p2, p3}, Lokhttp3/internal/http2/Http2Connection;->newStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;
move-result-object p1
return-object p1
.line 209
:cond_10
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "Client cannot push requests."
invoke-virtual {p2}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object p2
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast p1, Ljava/lang/Throwable;
throw p1
.end method
.method public final pushedStream$okhttp(I)Z
.registers 3
const/4 v0, 0x1
if-eqz p1, :cond_7
and-int/2addr p1, v0
if-nez p1, :cond_7
goto :goto_8
:cond_7
const/4 v0, 0x0
:goto_8
return v0
.end method
.method public final declared-synchronized removeStream$okhttp(I)Lokhttp3/internal/http2/Http2Stream;
.registers 3
monitor-enter p0
.line 179
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object p1
invoke-interface {v0, p1}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Lokhttp3/internal/http2/Http2Stream;
.line 1003
move-object v0, p0
check-cast v0, Ljava/lang/Object;
invoke-virtual {v0}, Ljava/lang/Object;->notifyAll()V
:try_end_13
.catchall {:try_start_1 .. :try_end_13} :catchall_15
.line 184
monitor-exit p0
return-object p1
:catchall_15
move-exception p1
monitor-exit p0
throw p1
.end method
.method public final sendDegradedPingLater$okhttp()V
.registers 11
.line 545
monitor-enter p0
.line 546
:try_start_1
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J
iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J
:try_end_5
.catchall {:try_start_1 .. :try_end_5} :catchall_47
cmp-long v4, v0, v2
if-gez v4, :cond_b
monitor-exit p0
return-void
.line 547
:cond_b
:try_start_b
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J
const-wide/16 v2, 0x1
add-long/2addr v0, v2
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J
.line 548
invoke-static {}, Ljava/lang/System;->nanoTime()J
move-result-wide v0
const v2, 0x3b9aca00
int-to-long v2, v2
add-long/2addr v0, v2
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongDeadlineNs:J
.line 549
sget-object v0, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_1f
.catchall {:try_start_b .. :try_end_1f} :catchall_47
.line 545
monitor-exit p0
.line 550
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v2, " ping"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v6
const-wide/16 v1, 0x0
const/4 v7, 0x1
.line 1060
new-instance v9, Lokhttp3/internal/http2/Http2Connection$sendDegradedPingLater$$inlined$execute$1;
move-object v3, v9
move-object v4, v6
move v5, v7
move-object v8, p0
invoke-direct/range {v3 .. v8}, Lokhttp3/internal/http2/Http2Connection$sendDegradedPingLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;)V
check-cast v9, Lokhttp3/internal/concurrent/Task;
invoke-virtual {v0, v9, v1, v2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
:catchall_47
move-exception v0
.line 545
monitor-exit p0
throw v0
.end method
.method public final setLastGoodStreamId$okhttp(I)V
.registers 2
.line 74
iput p1, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I
return-void
.end method
.method public final setNextStreamId$okhttp(I)V
.registers 2
.line 77
iput p1, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I
return-void
.end method
.method public final setPeerSettings(Lokhttp3/internal/http2/Settings;)V
.registers 3
const-string v0, "<set-?>"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 121
iput-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings;
return-void
.end method
.method public final setSettings(Lokhttp3/internal/http2/Settings;)V
.registers 4
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "settings"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 508
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
monitor-enter v0
.line 509
:try_start_8
monitor-enter p0
:try_end_9
.catchall {:try_start_8 .. :try_end_9} :catchall_29
.line 510
:try_start_9
iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
if-nez v1, :cond_1e
.line 513
iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
invoke-virtual {v1, p1}, Lokhttp3/internal/http2/Settings;->merge(Lokhttp3/internal/http2/Settings;)V
.line 514
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_14
.catchall {:try_start_9 .. :try_end_14} :catchall_26
.line 509
:try_start_14
monitor-exit p0
.line 515
iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v1, p1}, Lokhttp3/internal/http2/Http2Writer;->settings(Lokhttp3/internal/http2/Settings;)V
.line 516
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_1c
.catchall {:try_start_14 .. :try_end_1c} :catchall_29
.line 508
monitor-exit v0
return-void
.line 511
:cond_1e
:try_start_1e
new-instance p1, Lokhttp3/internal/http2/ConnectionShutdownException;
invoke-direct {p1}, Lokhttp3/internal/http2/ConnectionShutdownException;-><init>()V
check-cast p1, Ljava/lang/Throwable;
throw p1
:try_end_26
.catchall {:try_start_1e .. :try_end_26} :catchall_26
:catchall_26
move-exception p1
.line 509
:try_start_27
monitor-exit p0
throw p1
:try_end_29
.catchall {:try_start_27 .. :try_end_29} :catchall_29
:catchall_29
move-exception p1
.line 508
monitor-exit v0
throw p1
.end method
.method public final shutdown(Lokhttp3/internal/http2/ErrorCode;)V
.registers 6
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "statusCode"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 417
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
monitor-enter v0
.line 419
:try_start_8
monitor-enter p0
:try_end_9
.catchall {:try_start_8 .. :try_end_9} :catchall_26
.line 420
:try_start_9
iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
:try_end_b
.catchall {:try_start_9 .. :try_end_b} :catchall_23
if-eqz v1, :cond_10
.line 421
:try_start_d
monitor-exit p0
:try_end_e
.catchall {:try_start_d .. :try_end_e} :catchall_26
monitor-exit v0
return-void
:cond_10
const/4 v1, 0x1
.line 423
:try_start_11
iput-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z
.line 424
iget v1, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I
.line 425
sget-object v2, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_17
.catchall {:try_start_11 .. :try_end_17} :catchall_23
.line 419
:try_start_17
monitor-exit p0
.line 428
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
sget-object v3, Lokhttp3/internal/Util;->EMPTY_BYTE_ARRAY:[B
invoke-virtual {v2, v1, p1, v3}, Lokhttp3/internal/http2/Http2Writer;->goAway(ILokhttp3/internal/http2/ErrorCode;[B)V
.line 429
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_21
.catchall {:try_start_17 .. :try_end_21} :catchall_26
.line 417
monitor-exit v0
return-void
:catchall_23
move-exception p1
.line 419
:try_start_24
monitor-exit p0
throw p1
:try_end_26
.catchall {:try_start_24 .. :try_end_26} :catchall_26
:catchall_26
move-exception p1
.line 417
monitor-exit v0
throw p1
.end method
.method public final start()V
.registers 4
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const/4 v0, 0x0
const/4 v1, 0x1
const/4 v2, 0x0
invoke-static {p0, v0, v1, v2}, Lokhttp3/internal/http2/Http2Connection;->start$default(Lokhttp3/internal/http2/Http2Connection;ZILjava/lang/Object;)V
return-void
.end method
.method public final start(Z)V
.registers 7
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
if-eqz p1, :cond_21
.line 495
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->connectionPreface()V
.line 496
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
invoke-virtual {p1, v0}, Lokhttp3/internal/http2/Http2Writer;->settings(Lokhttp3/internal/http2/Settings;)V
.line 497
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
invoke-virtual {p1}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I
move-result p1
const v0, 0xffff
if-eq p1, v0, :cond_21
.line 499
iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
const/4 v2, 0x0
sub-int/2addr p1, v0
int-to-long v3, p1
invoke-virtual {v1, v2, v3, v4}, Lokhttp3/internal/http2/Http2Writer;->windowUpdate(IJ)V
.line 502
:cond_21
new-instance p1, Ljava/lang/Thread;
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
check-cast v0, Ljava/lang/Runnable;
iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-direct {p1, v0, v1}, Ljava/lang/Thread;-><init>(Ljava/lang/Runnable;Ljava/lang/String;)V
invoke-virtual {p1}, Ljava/lang/Thread;->start()V
return-void
.end method
.method public final declared-synchronized updateConnectionFlowControl$okhttp(J)V
.registers 6
monitor-enter p0
.line 188
:try_start_1
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesTotal:J
add-long/2addr v0, p1
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesTotal:J
.line 189
iget-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J
sub-long/2addr v0, p1
.line 190
iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
invoke-virtual {p1}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I
move-result p1
div-int/lit8 p1, p1, 0x2
int-to-long p1, p1
cmp-long v2, v0, p1
if-ltz v2, :cond_1f
const/4 p1, 0x0
.line 191
invoke-virtual {p0, p1, v0, v1}, Lokhttp3/internal/http2/Http2Connection;->writeWindowUpdateLater$okhttp(IJ)V
.line 192
iget-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J
add-long/2addr p1, v0
iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J
:try_end_1f
.catchall {:try_start_1 .. :try_end_1f} :catchall_21
.line 194
:cond_1f
monitor-exit p0
return-void
:catchall_21
move-exception p1
monitor-exit p0
throw p1
.end method
.method public final writeData(IZLokio/Buffer;J)V
.registers 15
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const/4 v0, 0x0
const-wide/16 v1, 0x0
cmp-long v3, p4, v1
if-nez v3, :cond_d
.line 303
iget-object p4, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {p4, p2, p1, p3, v0}, Lokhttp3/internal/http2/Http2Writer;->data(ZILokio/Buffer;I)V
return-void
:cond_d
:goto_d
cmp-long v3, p4, v1
if-lez v3, :cond_89
.line 309
new-instance v3, Lkotlin/jvm/internal/Ref$IntRef;
invoke-direct {v3}, Lkotlin/jvm/internal/Ref$IntRef;-><init>()V
.line 310
monitor-enter p0
.line 312
:goto_17
:try_start_17
iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J
iget-wide v6, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
cmp-long v8, v4, v6
if-ltz v8, :cond_3c
.line 315
iget-object v4, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v5
invoke-interface {v4, v5}, Ljava/util/Map;->containsKey(Ljava/lang/Object;)Z
move-result v4
if-eqz v4, :cond_32
.line 1004
move-object v4, p0
check-cast v4, Ljava/lang/Object;
invoke-virtual {v4}, Ljava/lang/Object;->wait()V
goto :goto_17
.line 316
:cond_32
new-instance p1, Ljava/io/IOException;
const-string p2, "stream closed"
invoke-direct {p1, p2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
check-cast p1, Ljava/lang/Throwable;
throw p1
:try_end_3c
.catch Ljava/lang/InterruptedException; {:try_start_17 .. :try_end_3c} :catch_78
.catchall {:try_start_17 .. :try_end_3c} :catchall_76
.line 325
:cond_3c
:try_start_3c
iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J
iget-wide v6, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J
sub-long/2addr v4, v6
invoke-static {p4, p5, v4, v5}, Ljava/lang/Math;->min(JJ)J
move-result-wide v4
long-to-int v5, v4
iput v5, v3, Lkotlin/jvm/internal/Ref$IntRef;->element:I
.line 326
iget v4, v3, Lkotlin/jvm/internal/Ref$IntRef;->element:I
iget-object v5, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v5}, Lokhttp3/internal/http2/Http2Writer;->maxDataLength()I
move-result v5
invoke-static {v4, v5}, Ljava/lang/Math;->min(II)I
move-result v4
iput v4, v3, Lkotlin/jvm/internal/Ref$IntRef;->element:I
.line 327
iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J
iget v6, v3, Lkotlin/jvm/internal/Ref$IntRef;->element:I
int-to-long v6, v6
add-long/2addr v4, v6
iput-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J
.line 328
sget-object v4, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_60
.catchall {:try_start_3c .. :try_end_60} :catchall_76
.line 310
monitor-exit p0
.line 330
iget v4, v3, Lkotlin/jvm/internal/Ref$IntRef;->element:I
int-to-long v4, v4
sub-long/2addr p4, v4
.line 331
iget-object v4, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
if-eqz p2, :cond_6f
cmp-long v5, p4, v1
if-nez v5, :cond_6f
const/4 v5, 0x1
goto :goto_70
:cond_6f
const/4 v5, 0x0
:goto_70
iget v3, v3, Lkotlin/jvm/internal/Ref$IntRef;->element:I
invoke-virtual {v4, v5, p1, p3, v3}, Lokhttp3/internal/http2/Http2Writer;->data(ZILokio/Buffer;I)V
goto :goto_d
:catchall_76
move-exception p1
goto :goto_87
.line 321
:catch_78
:try_start_78
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object p1
invoke-virtual {p1}, Ljava/lang/Thread;->interrupt()V
.line 322
new-instance p1, Ljava/io/InterruptedIOException;
invoke-direct {p1}, Ljava/io/InterruptedIOException;-><init>()V
check-cast p1, Ljava/lang/Throwable;
throw p1
:try_end_87
.catchall {:try_start_78 .. :try_end_87} :catchall_76
.line 310
:goto_87
monitor-exit p0
throw p1
:cond_89
return-void
.end method
.method public final writeHeaders$okhttp(IZLjava/util/List;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(IZ",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;)V"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "alternating"
invoke-static {p3, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 279
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v0, p2, p1, p3}, Lokhttp3/internal/http2/Http2Writer;->headers(ZILjava/util/List;)V
return-void
.end method
.method public final writePing()V
.registers 5
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;
}
.end annotation
.line 391
monitor-enter p0
.line 392
:try_start_1
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPingsSent:J
const-wide/16 v2, 0x1
add-long/2addr v0, v2
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPingsSent:J
:try_end_8
.catchall {:try_start_1 .. :try_end_8} :catchall_12
.line 391
monitor-exit p0
const/4 v0, 0x0
const/4 v1, 0x3
const v2, 0x4f4b6f6b
.line 394
invoke-virtual {p0, v0, v1, v2}, Lokhttp3/internal/http2/Http2Connection;->writePing(ZII)V
return-void
:catchall_12
move-exception v0
.line 391
monitor-exit p0
throw v0
.end method
.method public final writePing(ZII)V
.registers 5
.line 375
:try_start_0
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v0, p1, p2, p3}, Lokhttp3/internal/http2/Http2Writer;->ping(ZII)V
:try_end_5
.catch Ljava/io/IOException; {:try_start_0 .. :try_end_5} :catch_6
goto :goto_a
:catch_6
move-exception p1
.line 377
invoke-direct {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->failConnection(Ljava/io/IOException;)V
:goto_a
return-void
.end method
.method public final writePingAndAwaitPong()V
.registers 1
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;
}
.end annotation
.line 384
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Connection;->writePing()V
.line 385
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Connection;->awaitPong()V
return-void
.end method
.method public final writeSynReset$okhttp(ILokhttp3/internal/http2/ErrorCode;)V
.registers 4
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "statusCode"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 353
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer;
invoke-virtual {v0, p1, p2}, Lokhttp3/internal/http2/Http2Writer;->rstStream(ILokhttp3/internal/http2/ErrorCode;)V
return-void
.end method
.method public final writeSynResetLater$okhttp(ILokhttp3/internal/http2/ErrorCode;)V
.registers 14
const-string v0, "errorCode"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 339
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v2, 0x5b
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, "] writeSynReset"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v6
.line 1009
new-instance v1, Lokhttp3/internal/http2/Http2Connection$writeSynResetLater$$inlined$execute$1;
const/4 v7, 0x1
move-object v3, v1
move-object v4, v6
move v5, v7
move-object v8, p0
move v9, p1
move-object v10, p2
invoke-direct/range {v3 .. v10}, Lokhttp3/internal/http2/Http2Connection$writeSynResetLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILokhttp3/internal/http2/ErrorCode;)V
check-cast v1, Lokhttp3/internal/concurrent/Task;
const-wide/16 p1, 0x0
invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
.end method
.method public final writeWindowUpdateLater$okhttp(IJ)V
.registers 16
.line 360
iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v2, 0x5b
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, "] windowUpdate"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v6
.line 1020
new-instance v1, Lokhttp3/internal/http2/Http2Connection$writeWindowUpdateLater$$inlined$execute$1;
const/4 v7, 0x1
move-object v3, v1
move-object v4, v6
move v5, v7
move-object v8, p0
move v9, p1
move-wide v10, p2
invoke-direct/range {v3 .. v11}, Lokhttp3/internal/http2/Http2Connection$writeWindowUpdateLater$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;IJ)V
check-cast v1, Lokhttp3/internal/concurrent/Task;
const-wide/16 p1, 0x0
invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V
return-void
.end method