Http2Connection$ReaderRunnable.smali

.class public final Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;
.super Ljava/lang/Object;

# interfaces
.implements Lokhttp3/internal/http2/Http2Reader$Handler;
.implements Lkotlin/jvm/functions/Function0;


# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
    value = Lokhttp3/internal/http2/Http2Connection;
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x11
    name = "ReaderRunnable"
.end annotation

.annotation system Ldalvik/annotation/Signature;
    value = {
        "Ljava/lang/Object;",
        "Lokhttp3/internal/http2/Http2Reader$Handler;",
        "Lkotlin/jvm/functions/Function0<",
        "Lkotlin/Unit;",
        ">;"
    }
.end annotation


# instance fields
.field private final f:Lokhttp3/internal/http2/Http2Reader;

.field final synthetic g:Lokhttp3/internal/http2/Http2Connection;


# direct methods
.method public constructor <init>(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Http2Reader;)V
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lokhttp3/internal/http2/Http2Reader;",
            ")V"
        }
    .end annotation

    const-string v0, "reader"

    invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    iput-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    iput-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->f:Lokhttp3/internal/http2/Http2Reader;

    return-void
.end method


# virtual methods
.method public a()V
    .registers 1

    return-void
.end method

.method public bridge synthetic c()Ljava/lang/Object;
    .registers 2

    invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->q()V

    sget-object v0, Lkotlin/Unit;->a:Lkotlin/Unit;

    return-object v0
.end method

.method public d(ZLokhttp3/internal/http2/Settings;)V
    .registers 14

    const-string v0, "settings"

    invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {v0}, Lokhttp3/internal/http2/Http2Connection;->p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue;

    move-result-object v0

    new-instance v1, Ljava/lang/StringBuilder;

    invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V

    iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v2}, Lokhttp3/internal/http2/Http2Connection;->G()Ljava/lang/String;

    move-result-object v2

    invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    const-string v2, " applyAndAckSettings"

    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

    new-instance v1, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$settings$$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$ReaderRunnable$settings$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection$ReaderRunnable;ZLokhttp3/internal/http2/Settings;)V

    const-wide/16 p1, 0x0

    invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->i(Lokhttp3/internal/concurrent/Task;J)V

    return-void
.end method

.method public f(ZIILjava/util/List;)V
    .registers 21
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(ZII",
            "Ljava/util/List<",
            "Lokhttp3/internal/http2/Header;",
            ">;)V"
        }
    .end annotation

    move-object/from16 v12, p0

    move/from16 v0, p1

    move/from16 v9, p2

    move-object/from16 v10, p4

    const-string v1, "headerBlock"

    invoke-static {v10, v1}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1, v9}, Lokhttp3/internal/http2/Http2Connection;->k0(I)Z

    move-result v1

    if-eqz v1, :cond_1b

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1, v9, v10, v0}, Lokhttp3/internal/http2/Http2Connection;->h0(ILjava/util/List;Z)V

    return-void

    :cond_1b
    iget-object v13, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    monitor-enter v13

    :try_start_1e
    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1, v9}, Lokhttp3/internal/http2/Http2Connection;->T(I)Lokhttp3/internal/http2/Http2Stream;

    move-result-object v8

    if-nez v8, :cond_b0

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {v1}, Lokhttp3/internal/http2/Http2Connection;->r(Lokhttp3/internal/http2/Http2Connection;)Z

    move-result v1
    :try_end_2c
    .catchall {:try_start_1e .. :try_end_2c} :catchall_bb

    if-eqz v1, :cond_30

    monitor-exit v13

    return-void

    :cond_30
    :try_start_30
    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->I()I

    move-result v1
    :try_end_36
    .catchall {:try_start_30 .. :try_end_36} :catchall_bb

    if-gt v9, v1, :cond_3a

    monitor-exit v13

    return-void

    :cond_3a
    :try_start_3a
    rem-int/lit8 v1, v9, 0x2

    iget-object v2, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v2}, Lokhttp3/internal/http2/Http2Connection;->P()I

    move-result v2

    rem-int/lit8 v2, v2, 0x2
    :try_end_44
    .catchall {:try_start_3a .. :try_end_44} :catchall_bb

    if-ne v1, v2, :cond_48

    monitor-exit v13

    return-void

    :cond_48
    :try_start_48
    invoke-static/range {p4 .. p4}, Lokhttp3/internal/Util;->L(Ljava/util/List;)Lokhttp3/Headers;

    move-result-object v6

    new-instance v7, Lokhttp3/internal/http2/Http2Stream;

    iget-object v3, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    const/4 v4, 0x0

    move-object v1, v7

    move/from16 v2, p2

    move/from16 v5, p1

    invoke-direct/range {v1 .. v6}, Lokhttp3/internal/http2/Http2Stream;-><init>(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1, v9}, Lokhttp3/internal/http2/Http2Connection;->o0(I)V

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->U()Ljava/util/Map;

    move-result-object v1

    invoke-static/range {p2 .. p2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v2

    invoke-interface {v1, v2, v7}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {v1}, Lokhttp3/internal/http2/Http2Connection;->o(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskRunner;

    move-result-object v1

    invoke-virtual {v1}, Lokhttp3/internal/concurrent/TaskRunner;->i()Lokhttp3/internal/concurrent/TaskQueue;

    move-result-object v14

    new-instance v1, Ljava/lang/StringBuilder;

    invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V

    iget-object v2, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v2}, Lokhttp3/internal/http2/Http2Connection;->G()Ljava/lang/String;

    move-result-object v2

    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, v9}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;

    const-string v2, "] onStream"

    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 v4

    const-wide/16 v5, 0x0

    const/4 v11, 0x1

    new-instance v15, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$headers$$inlined$synchronized$lambda$1;

    move-object v1, v15

    move-object v2, v4

    move v3, v11

    move v5, v11

    move-object v6, v7

    move-object/from16 v7, p0

    move/from16 v9, p2

    move-object/from16 v10, p4

    move/from16 v11, p1

    invoke-direct/range {v1 .. v11}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$headers$$inlined$synchronized$lambda$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Stream;Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;Lokhttp3/internal/http2/Http2Stream;ILjava/util/List;Z)V

    const-wide/16 v0, 0x0

    invoke-virtual {v14, v15, v0, v1}, Lokhttp3/internal/concurrent/TaskQueue;->i(Lokhttp3/internal/concurrent/Task;J)V
    :try_end_ae
    .catchall {:try_start_48 .. :try_end_ae} :catchall_bb

    monitor-exit v13

    return-void

    :cond_b0
    :try_start_b0
    sget-object v1, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_b2
    .catchall {:try_start_b0 .. :try_end_b2} :catchall_bb

    monitor-exit v13

    invoke-static/range {p4 .. p4}, Lokhttp3/internal/Util;->L(Ljava/util/List;)Lokhttp3/Headers;

    move-result-object v1

    invoke-virtual {v8, v1, v0}, Lokhttp3/internal/http2/Http2Stream;->x(Lokhttp3/Headers;Z)V

    return-void

    :catchall_bb
    move-exception v0

    monitor-exit v13

    throw v0
.end method

.method public g(IJ)V
    .registers 7

    if-nez p1, :cond_25

    iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    monitor-enter p1

    :try_start_5
    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Connection;->X()J

    move-result-wide v1

    add-long/2addr v1, p2

    invoke-static {v0, v1, v2}, Lokhttp3/internal/http2/Http2Connection;->C(Lokhttp3/internal/http2/Http2Connection;J)V

    iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    if-eqz p2, :cond_1a

    invoke-virtual {p2}, Ljava/lang/Object;->notifyAll()V

    sget-object p2, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_18
    .catchall {:try_start_5 .. :try_end_18} :catchall_22

    monitor-exit p1

    goto :goto_38

    :cond_1a
    :try_start_1a
    new-instance p2, Lkotlin/TypeCastException;

    const-string p3, "null cannot be cast to non-null type java.lang.Object"

    invoke-direct {p2, p3}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V

    throw p2
    :try_end_22
    .catchall {:try_start_1a .. :try_end_22} :catchall_22

    :catchall_22
    move-exception p2

    monitor-exit p1

    throw p2

    :cond_25
    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p1}, Lokhttp3/internal/http2/Http2Connection;->T(I)Lokhttp3/internal/http2/Http2Stream;

    move-result-object p1

    if-eqz p1, :cond_38

    monitor-enter p1

    :try_start_2e
    invoke-virtual {p1, p2, p3}, Lokhttp3/internal/http2/Http2Stream;->a(J)V

    sget-object p2, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_33
    .catchall {:try_start_2e .. :try_end_33} :catchall_35

    monitor-exit p1

    goto :goto_38

    :catchall_35
    move-exception p2

    monitor-exit p1

    throw p2

    :cond_38
    :goto_38
    return-void
.end method

.method public i(ZILokio/BufferedSource;I)V
    .registers 7
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Ljava/io/IOException;
        }
    .end annotation

    const-string v0, "source"

    invoke-static {p3, v0}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p2}, Lokhttp3/internal/http2/Http2Connection;->k0(I)Z

    move-result v0

    if-eqz v0, :cond_13

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p2, p3, p4, p1}, Lokhttp3/internal/http2/Http2Connection;->g0(ILokio/BufferedSource;IZ)V

    return-void

    :cond_13
    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p2}, Lokhttp3/internal/http2/Http2Connection;->T(I)Lokhttp3/internal/http2/Http2Stream;

    move-result-object v0

    if-nez v0, :cond_2c

    iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    sget-object v0, Lokhttp3/internal/http2/ErrorCode;->h:Lokhttp3/internal/http2/ErrorCode;

    invoke-virtual {p1, p2, v0}, Lokhttp3/internal/http2/Http2Connection;->H0(ILokhttp3/internal/http2/ErrorCode;)V

    iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    int-to-long v0, p4

    invoke-virtual {p1, v0, v1}, Lokhttp3/internal/http2/Http2Connection;->z0(J)V

    invoke-interface {p3, v0, v1}, Lokio/BufferedSource;->N0(J)V

    return-void

    :cond_2c
    invoke-virtual {v0, p3, p4}, Lokhttp3/internal/http2/Http2Stream;->w(Lokio/BufferedSource;I)V

    if-eqz p1, :cond_37

    sget-object p1, Lokhttp3/internal/Util;->b:Lokhttp3/Headers;

    const/4 p2, 0x1

    invoke-virtual {v0, p1, p2}, Lokhttp3/internal/http2/Http2Stream;->x(Lokhttp3/Headers;Z)V

    :cond_37
    return-void
.end method

.method public j(ZII)V
    .registers 15

    if-eqz p1, :cond_47

    iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    monitor-enter p1

    const/4 p3, 0x1

    const-wide/16 v0, 0x1

    if-eq p2, p3, :cond_38

    const/4 p3, 0x2

    if-eq p2, p3, :cond_2d

    const/4 p3, 0x3

    if-eq p2, p3, :cond_13

    :goto_10
    :try_start_10
    sget-object p2, Lkotlin/Unit;->a:Lkotlin/Unit;

    goto :goto_42

    :cond_13
    iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {p2}, Lokhttp3/internal/http2/Http2Connection;->b(Lokhttp3/internal/http2/Http2Connection;)J

    move-result-wide v2

    add-long/2addr v2, v0

    invoke-static {p2, v2, v3}, Lokhttp3/internal/http2/Http2Connection;->s(Lokhttp3/internal/http2/Http2Connection;J)V

    iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    if-eqz p2, :cond_25

    invoke-virtual {p2}, Ljava/lang/Object;->notifyAll()V

    goto :goto_10

    :cond_25
    new-instance p2, Lkotlin/TypeCastException;

    const-string p3, "null cannot be cast to non-null type java.lang.Object"

    invoke-direct {p2, p3}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V

    throw p2

    :cond_2d
    iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {p2}, Lokhttp3/internal/http2/Http2Connection;->f(Lokhttp3/internal/http2/Http2Connection;)J

    move-result-wide v2

    add-long/2addr v2, v0

    invoke-static {p2, v2, v3}, Lokhttp3/internal/http2/Http2Connection;->t(Lokhttp3/internal/http2/Http2Connection;J)V

    goto :goto_42

    :cond_38
    iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {p2}, Lokhttp3/internal/http2/Http2Connection;->j(Lokhttp3/internal/http2/Http2Connection;)J

    move-result-wide v2

    add-long/2addr v2, v0

    invoke-static {p2, v2, v3}, Lokhttp3/internal/http2/Http2Connection;->v(Lokhttp3/internal/http2/Http2Connection;J)V
    :try_end_42
    .catchall {:try_start_10 .. :try_end_42} :catchall_44

    :goto_42
    monitor-exit p1

    goto :goto_75

    :catchall_44
    move-exception p2

    monitor-exit p1

    throw p2

    :cond_47
    iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {p1}, Lokhttp3/internal/http2/Http2Connection;->p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue;

    move-result-object p1

    new-instance v0, Ljava/lang/StringBuilder;

    invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V

    iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->G()Ljava/lang/String;

    move-result-object v1

    invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    const-string v1, " ping"

    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 v5

    const-wide/16 v0, 0x0

    const/4 v6, 0x1

    new-instance v10, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$ping$$inlined$execute$1;

    move-object v2, v10

    move-object v3, v5

    move v4, v6

    move-object v7, p0

    move v8, p2

    move v9, p3

    invoke-direct/range {v2 .. v9}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$ping$$inlined$execute$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection$ReaderRunnable;II)V

    invoke-virtual {p1, v10, v0, v1}, Lokhttp3/internal/concurrent/TaskQueue;->i(Lokhttp3/internal/concurrent/Task;J)V

    :goto_75
    return-void
.end method

.method public k(IIIZ)V
    .registers 5

    return-void
.end method

.method public l(ILokhttp3/internal/http2/ErrorCode;)V
    .registers 4

    const-string v0, "errorCode"

    invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p1}, Lokhttp3/internal/http2/Http2Connection;->k0(I)Z

    move-result v0

    if-eqz v0, :cond_13

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->j0(ILokhttp3/internal/http2/ErrorCode;)V

    return-void

    :cond_13
    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0, p1}, Lokhttp3/internal/http2/Http2Connection;->l0(I)Lokhttp3/internal/http2/Http2Stream;

    move-result-object p1

    if-eqz p1, :cond_1e

    invoke-virtual {p1, p2}, Lokhttp3/internal/http2/Http2Stream;->y(Lokhttp3/internal/http2/ErrorCode;)V

    :cond_1e
    return-void
.end method

.method public n(IILjava/util/List;)V
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(II",
            "Ljava/util/List<",
            "Lokhttp3/internal/http2/Header;",
            ">;)V"
        }
    .end annotation

    const-string p1, "requestHeaders"

    invoke-static {p3, p1}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {p1, p2, p3}, Lokhttp3/internal/http2/Http2Connection;->i0(ILjava/util/List;)V

    return-void
.end method

.method public o(ILokhttp3/internal/http2/ErrorCode;Lokio/ByteString;)V
    .registers 7

    const-string v0, "errorCode"

    invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    const-string p2, "debugData"

    invoke-static {p3, p2}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    invoke-virtual {p3}, Lokio/ByteString;->Q()I

    iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    monitor-enter p2

    :try_start_10
    iget-object p3, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {p3}, Lokhttp3/internal/http2/Http2Connection;->U()Ljava/util/Map;

    move-result-object p3

    invoke-interface {p3}, Ljava/util/Map;->values()Ljava/util/Collection;

    move-result-object p3

    const/4 v0, 0x0

    new-array v1, v0, [Lokhttp3/internal/http2/Http2Stream;

    invoke-interface {p3, v1}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;

    move-result-object p3

    if-eqz p3, :cond_51

    check-cast p3, [Lokhttp3/internal/http2/Http2Stream;

    iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    const/4 v2, 0x1

    invoke-static {v1, v2}, Lokhttp3/internal/http2/Http2Connection;->x(Lokhttp3/internal/http2/Http2Connection;Z)V

    sget-object v1, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_2d
    .catchall {:try_start_10 .. :try_end_2d} :catchall_59

    monitor-exit p2

    array-length p2, p3

    :goto_2f
    if-ge v0, p2, :cond_50

    aget-object v1, p3, v0

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Stream;->j()I

    move-result v2

    if-le v2, p1, :cond_4d

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Stream;->t()Z

    move-result v2

    if-eqz v2, :cond_4d

    sget-object v2, Lokhttp3/internal/http2/ErrorCode;->k:Lokhttp3/internal/http2/ErrorCode;

    invoke-virtual {v1, v2}, Lokhttp3/internal/http2/Http2Stream;->y(Lokhttp3/internal/http2/ErrorCode;)V

    iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Stream;->j()I

    move-result v1

    invoke-virtual {v2, v1}, Lokhttp3/internal/http2/Http2Connection;->l0(I)Lokhttp3/internal/http2/Http2Stream;

    :cond_4d
    add-int/lit8 v0, v0, 0x1

    goto :goto_2f

    :cond_50
    return-void

    :cond_51
    :try_start_51
    new-instance p1, Lkotlin/TypeCastException;

    const-string p3, "null cannot be cast to non-null type kotlin.Array<T>"

    invoke-direct {p1, p3}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V

    throw p1
    :try_end_59
    .catchall {:try_start_51 .. :try_end_59} :catchall_59

    :catchall_59
    move-exception p1

    monitor-exit p2

    throw p1
.end method

.method public final p(ZLokhttp3/internal/http2/Settings;)V
    .registers 25

    move-object/from16 v12, p0

    move-object/from16 v0, p2

    const-string v1, "settings"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/Intrinsics;->c(Ljava/lang/Object;Ljava/lang/String;)V

    new-instance v13, Lkotlin/jvm/internal/Ref$LongRef;

    invoke-direct {v13}, Lkotlin/jvm/internal/Ref$LongRef;-><init>()V

    new-instance v14, Lkotlin/jvm/internal/Ref$ObjectRef;

    invoke-direct {v14}, Lkotlin/jvm/internal/Ref$ObjectRef;-><init>()V

    new-instance v15, Lkotlin/jvm/internal/Ref$ObjectRef;

    invoke-direct {v15}, Lkotlin/jvm/internal/Ref$ObjectRef;-><init>()V

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->Y()Lokhttp3/internal/http2/Http2Writer;

    move-result-object v16

    monitor-enter v16

    :try_start_1f
    iget-object v11, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    monitor-enter v11
    :try_end_22
    .catchall {:try_start_1f .. :try_end_22} :catchall_111

    :try_start_22
    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->S()Lokhttp3/internal/http2/Settings;

    move-result-object v1

    if-eqz p1, :cond_2d

    iput-object v0, v15, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    goto :goto_3a

    :cond_2d
    new-instance v2, Lokhttp3/internal/http2/Settings;

    invoke-direct {v2}, Lokhttp3/internal/http2/Settings;-><init>()V

    invoke-virtual {v2, v1}, Lokhttp3/internal/http2/Settings;->g(Lokhttp3/internal/http2/Settings;)V

    invoke-virtual {v2, v0}, Lokhttp3/internal/http2/Settings;->g(Lokhttp3/internal/http2/Settings;)V

    iput-object v2, v15, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    :goto_3a
    iget-object v2, v15, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    check-cast v2, Lokhttp3/internal/http2/Settings;

    invoke-virtual {v2}, Lokhttp3/internal/http2/Settings;->c()I

    move-result v2

    int-to-long v2, v2

    invoke-virtual {v1}, Lokhttp3/internal/http2/Settings;->c()I

    move-result v1

    int-to-long v4, v1

    sub-long/2addr v2, v4

    iput-wide v2, v13, Lkotlin/jvm/internal/Ref$LongRef;->f:J

    const/4 v10, 0x0

    const/16 v17, 0x0

    const-wide/16 v8, 0x0

    cmp-long v1, v2, v8

    if-eqz v1, :cond_7e

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->U()Ljava/util/Map;

    move-result-object v1

    invoke-interface {v1}, Ljava/util/Map;->isEmpty()Z

    move-result v1

    if-eqz v1, :cond_61

    goto :goto_7e

    :cond_61
    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Connection;->U()Ljava/util/Map;

    move-result-object v1

    invoke-interface {v1}, Ljava/util/Map;->values()Ljava/util/Collection;

    move-result-object v1

    new-array v2, v10, [Lokhttp3/internal/http2/Http2Stream;

    invoke-interface {v1, v2}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;

    move-result-object v1

    if-eqz v1, :cond_76

    check-cast v1, [Lokhttp3/internal/http2/Http2Stream;

    goto :goto_80

    :cond_76
    new-instance v0, Lkotlin/TypeCastException;

    const-string v1, "null cannot be cast to non-null type kotlin.Array<T>"

    invoke-direct {v0, v1}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V

    throw v0

    :cond_7e
    :goto_7e
    move-object/from16 v1, v17

    :goto_80
    iput-object v1, v14, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    iget-object v2, v15, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    check-cast v2, Lokhttp3/internal/http2/Settings;

    invoke-virtual {v1, v2}, Lokhttp3/internal/http2/Http2Connection;->p0(Lokhttp3/internal/http2/Settings;)V

    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {v1}, Lokhttp3/internal/http2/Http2Connection;->n(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue;

    move-result-object v7

    new-instance v1, Ljava/lang/StringBuilder;

    invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V

    iget-object v2, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v2}, Lokhttp3/internal/http2/Http2Connection;->G()Ljava/lang/String;

    move-result-object v2

    invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    const-string v2, " onSettings"

    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 v4

    const/4 v5, 0x1

    new-instance v6, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$applyAndAckSettings$$inlined$synchronized$lambda$1;
    :try_end_ab
    .catchall {:try_start_22 .. :try_end_ab} :catchall_10c

    move-object v1, v6

    move-object v2, v4

    move v3, v5

    move-object/from16 v18, v6

    move-object/from16 v6, p0

    move-object/from16 v19, v7

    move/from16 v7, p1

    move-object v8, v15

    move-object/from16 v9, p2

    const/16 v20, 0x0

    move-object v10, v13

    move-object/from16 v21, v11

    move-object v11, v14

    :try_start_bf
    invoke-direct/range {v1 .. v11}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable$applyAndAckSettings$$inlined$synchronized$lambda$1;-><init>(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection$ReaderRunnable;ZLkotlin/jvm/internal/Ref$ObjectRef;Lokhttp3/internal/http2/Settings;Lkotlin/jvm/internal/Ref$LongRef;Lkotlin/jvm/internal/Ref$ObjectRef;)V

    move-object/from16 v1, v18

    move-object/from16 v0, v19

    const-wide/16 v2, 0x0

    invoke-virtual {v0, v1, v2, v3}, Lokhttp3/internal/concurrent/TaskQueue;->i(Lokhttp3/internal/concurrent/Task;J)V

    sget-object v0, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_cd
    .catchall {:try_start_bf .. :try_end_cd} :catchall_10a

    :try_start_cd
    monitor-exit v21
    :try_end_ce
    .catchall {:try_start_cd .. :try_end_ce} :catchall_111

    :try_start_ce
    iget-object v0, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Connection;->Y()Lokhttp3/internal/http2/Http2Writer;

    move-result-object v0

    iget-object v1, v15, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    check-cast v1, Lokhttp3/internal/http2/Settings;

    invoke-virtual {v0, v1}, Lokhttp3/internal/http2/Http2Writer;->a(Lokhttp3/internal/http2/Settings;)V
    :try_end_db
    .catch Ljava/io/IOException; {:try_start_ce .. :try_end_db} :catch_dc
    .catchall {:try_start_ce .. :try_end_db} :catchall_111

    goto :goto_e2

    :catch_dc
    move-exception v0

    :try_start_dd
    iget-object v1, v12, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-static {v1, v0}, Lokhttp3/internal/http2/Http2Connection;->a(Lokhttp3/internal/http2/Http2Connection;Ljava/io/IOException;)V

    :goto_e2
    sget-object v0, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_e4
    .catchall {:try_start_dd .. :try_end_e4} :catchall_111

    monitor-exit v16

    iget-object v0, v14, Lkotlin/jvm/internal/Ref$ObjectRef;->f:Ljava/lang/Object;

    move-object v1, v0

    check-cast v1, [Lokhttp3/internal/http2/Http2Stream;

    if-eqz v1, :cond_109

    check-cast v0, [Lokhttp3/internal/http2/Http2Stream;

    if-eqz v0, :cond_105

    array-length v1, v0

    const/4 v10, 0x0

    :goto_f2
    if-ge v10, v1, :cond_109

    aget-object v2, v0, v10

    monitor-enter v2

    :try_start_f7
    iget-wide v3, v13, Lkotlin/jvm/internal/Ref$LongRef;->f:J

    invoke-virtual {v2, v3, v4}, Lokhttp3/internal/http2/Http2Stream;->a(J)V

    sget-object v3, Lkotlin/Unit;->a:Lkotlin/Unit;
    :try_end_fe
    .catchall {:try_start_f7 .. :try_end_fe} :catchall_102

    monitor-exit v2

    add-int/lit8 v10, v10, 0x1

    goto :goto_f2

    :catchall_102
    move-exception v0

    monitor-exit v2

    throw v0

    :cond_105
    invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->h()V

    throw v17

    :cond_109
    return-void

    :catchall_10a
    move-exception v0

    goto :goto_10f

    :catchall_10c
    move-exception v0

    move-object/from16 v21, v11

    :goto_10f
    :try_start_10f
    monitor-exit v21

    throw v0
    :try_end_111
    .catchall {:try_start_10f .. :try_end_111} :catchall_111

    :catchall_111
    move-exception v0

    monitor-exit v16

    throw v0
.end method

.method public q()V
    .registers 6

    sget-object v0, Lokhttp3/internal/http2/ErrorCode;->i:Lokhttp3/internal/http2/ErrorCode;

    const/4 v1, 0x0

    :try_start_3
    iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->f:Lokhttp3/internal/http2/Http2Reader;

    invoke-virtual {v2, p0}, Lokhttp3/internal/http2/Http2Reader;->d(Lokhttp3/internal/http2/Http2Reader$Handler;)V

    :goto_8
    iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->f:Lokhttp3/internal/http2/Http2Reader;

    const/4 v3, 0x0

    invoke-virtual {v2, v3, p0}, Lokhttp3/internal/http2/Http2Reader;->b(ZLokhttp3/internal/http2/Http2Reader$Handler;)Z

    move-result v2

    if-eqz v2, :cond_12

    goto :goto_8

    :cond_12
    sget-object v2, Lokhttp3/internal/http2/ErrorCode;->g:Lokhttp3/internal/http2/ErrorCode;
    :try_end_14
    .catch Ljava/io/IOException; {:try_start_3 .. :try_end_14} :catch_1c
    .catchall {:try_start_3 .. :try_end_14} :catchall_19

    :try_start_14
    sget-object v0, Lokhttp3/internal/http2/ErrorCode;->l:Lokhttp3/internal/http2/ErrorCode;
    :try_end_16
    .catch Ljava/io/IOException; {:try_start_14 .. :try_end_16} :catch_17
    .catchall {:try_start_14 .. :try_end_16} :catchall_2d

    goto :goto_22

    :catch_17
    move-exception v1

    goto :goto_1e

    :catchall_19
    move-exception v3

    move-object v2, v0

    goto :goto_2e

    :catch_1c
    move-exception v1

    move-object v2, v0

    :goto_1e
    :try_start_1e
    sget-object v2, Lokhttp3/internal/http2/ErrorCode;->h:Lokhttp3/internal/http2/ErrorCode;

    sget-object v0, Lokhttp3/internal/http2/ErrorCode;->h:Lokhttp3/internal/http2/ErrorCode;
    :try_end_22
    .catchall {:try_start_1e .. :try_end_22} :catchall_2d

    :goto_22
    iget-object v3, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v3, v2, v0, v1}, Lokhttp3/internal/http2/Http2Connection;->D(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->f:Lokhttp3/internal/http2/Http2Reader;

    invoke-static {v0}, Lokhttp3/internal/Util;->j(Ljava/io/Closeable;)V

    return-void

    :catchall_2d
    move-exception v3

    :goto_2e
    iget-object v4, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->g:Lokhttp3/internal/http2/Http2Connection;

    invoke-virtual {v4, v2, v0, v1}, Lokhttp3/internal/http2/Http2Connection;->D(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V

    iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->f:Lokhttp3/internal/http2/Http2Reader;

    invoke-static {v0}, Lokhttp3/internal/Util;->j(Ljava/io/Closeable;)V

    throw v3
.end method