g.smali
.class public final Li/e0/i/g;
.super Ljava/lang/Object;
.source ""
# interfaces
.implements Ljava/io/Closeable;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Li/e0/i/g$h;,
Li/e0/i/g$j;,
Li/e0/i/g$g;,
Li/e0/i/g$i;
}
.end annotation
# static fields
.field private static final y:Ljava/util/concurrent/ExecutorService;
# instance fields
.field final e:Z
.field final f:Li/e0/i/g$h;
.field final g:Ljava/util/Map;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Map<",
"Ljava/lang/Integer;",
"Li/e0/i/i;",
">;"
}
.end annotation
.end field
.field final h:Ljava/lang/String;
.field i:I
.field j:I
.field k:Z
.field private final l:Ljava/util/concurrent/ScheduledExecutorService;
.field private final m:Ljava/util/concurrent/ExecutorService;
.field final n:Li/e0/i/l;
.field private o:Z
.field p:J
.field q:J
.field r:Li/e0/i/m;
.field final s:Li/e0/i/m;
.field t:Z
.field final u:Ljava/net/Socket;
.field final v:Li/e0/i/j;
.field final w:Li/e0/i/g$j;
.field final x:Ljava/util/Set;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Set<",
"Ljava/lang/Integer;",
">;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 9
const-class v0, Li/e0/i/g;
new-instance v0, Ljava/util/concurrent/ThreadPoolExecutor;
const/4 v2, 0x0
const v3, 0x7fffffff
const-wide/16 v4, 0x3c
sget-object v6, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
new-instance v7, Ljava/util/concurrent/SynchronousQueue;
invoke-direct {v7}, Ljava/util/concurrent/SynchronousQueue;-><init>()V
const/4 v1, 0x1
const-string v8, "OkHttp Http2Connection"
invoke-static {v8, v1}, Li/e0/c;->G(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory;
move-result-object v8
move-object v1, v0
invoke-direct/range {v1 .. v8}, Ljava/util/concurrent/ThreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V
sput-object v0, Li/e0/i/g;->y:Ljava/util/concurrent/ExecutorService;
return-void
.end method
.method constructor <init>(Li/e0/i/g$g;)V
.registers 26
move-object/from16 v0, p0
move-object/from16 v1, p1
invoke-direct/range {p0 .. p0}, Ljava/lang/Object;-><init>()V
new-instance v2, Ljava/util/LinkedHashMap;
invoke-direct {v2}, Ljava/util/LinkedHashMap;-><init>()V
iput-object v2, v0, Li/e0/i/g;->g:Ljava/util/Map;
const-wide/16 v2, 0x0
iput-wide v2, v0, Li/e0/i/g;->p:J
new-instance v2, Li/e0/i/m;
invoke-direct {v2}, Li/e0/i/m;-><init>()V
iput-object v2, v0, Li/e0/i/g;->r:Li/e0/i/m;
new-instance v2, Li/e0/i/m;
invoke-direct {v2}, Li/e0/i/m;-><init>()V
iput-object v2, v0, Li/e0/i/g;->s:Li/e0/i/m;
const/4 v3, 0x0
iput-boolean v3, v0, Li/e0/i/g;->t:Z
new-instance v4, Ljava/util/LinkedHashSet;
invoke-direct {v4}, Ljava/util/LinkedHashSet;-><init>()V
iput-object v4, v0, Li/e0/i/g;->x:Ljava/util/Set;
iget-object v4, v1, Li/e0/i/g$g;->f:Li/e0/i/l;
iput-object v4, v0, Li/e0/i/g;->n:Li/e0/i/l;
iget-boolean v4, v1, Li/e0/i/g$g;->g:Z
iput-boolean v4, v0, Li/e0/i/g;->e:Z
iget-object v5, v1, Li/e0/i/g$g;->e:Li/e0/i/g$h;
iput-object v5, v0, Li/e0/i/g;->f:Li/e0/i/g$h;
const/4 v5, 0x2
const/4 v6, 0x1
if-eqz v4, :cond_3c
const/4 v7, 0x1
goto :goto_3d
:cond_3c
const/4 v7, 0x2
:goto_3d
iput v7, v0, Li/e0/i/g;->j:I
if-eqz v4, :cond_44
add-int/2addr v7, v5
iput v7, v0, Li/e0/i/g;->j:I
:cond_44
const/4 v5, 0x7
if-eqz v4, :cond_4e
iget-object v7, v0, Li/e0/i/g;->r:Li/e0/i/m;
const/high16 v8, 0x1000000
invoke-virtual {v7, v5, v8}, Li/e0/i/m;->i(II)Li/e0/i/m;
:cond_4e
iget-object v7, v1, Li/e0/i/g$g;->b:Ljava/lang/String;
iput-object v7, v0, Li/e0/i/g;->h:Ljava/lang/String;
new-instance v8, Ljava/util/concurrent/ScheduledThreadPoolExecutor;
new-array v9, v6, [Ljava/lang/Object;
aput-object v7, v9, v3
const-string v10, "OkHttp %s Writer"
invoke-static {v10, v9}, Li/e0/c;->r(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
move-result-object v9
invoke-static {v9, v3}, Li/e0/c;->G(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory;
move-result-object v9
invoke-direct {v8, v6, v9}, Ljava/util/concurrent/ScheduledThreadPoolExecutor;-><init>(ILjava/util/concurrent/ThreadFactory;)V
iput-object v8, v0, Li/e0/i/g;->l:Ljava/util/concurrent/ScheduledExecutorService;
iget v9, v1, Li/e0/i/g$g;->h:I
if-eqz v9, :cond_7c
new-instance v9, Li/e0/i/g$i;
invoke-direct {v9, v0, v3, v3, v3}, Li/e0/i/g$i;-><init>(Li/e0/i/g;ZII)V
iget v10, v1, Li/e0/i/g$g;->h:I
int-to-long v11, v10
int-to-long v13, v10
sget-object v15, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit;
move-wide v10, v11
move-wide v12, v13
move-object v14, v15
invoke-interface/range {v8 .. v14}, Ljava/util/concurrent/ScheduledExecutorService;->scheduleAtFixedRate(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
:cond_7c
new-instance v8, Ljava/util/concurrent/ThreadPoolExecutor;
const/16 v17, 0x0
const/16 v18, 0x1
const-wide/16 v19, 0x3c
sget-object v21, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
new-instance v22, Ljava/util/concurrent/LinkedBlockingQueue;
invoke-direct/range {v22 .. v22}, Ljava/util/concurrent/LinkedBlockingQueue;-><init>()V
new-array v9, v6, [Ljava/lang/Object;
aput-object v7, v9, v3
const-string v3, "OkHttp %s Push Observer"
invoke-static {v3, v9}, Li/e0/c;->r(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
move-result-object v3
invoke-static {v3, v6}, Li/e0/c;->G(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory;
move-result-object v23
move-object/from16 v16, v8
invoke-direct/range {v16 .. v23}, Ljava/util/concurrent/ThreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V
iput-object v8, v0, Li/e0/i/g;->m:Ljava/util/concurrent/ExecutorService;
const v3, 0xffff
invoke-virtual {v2, v5, v3}, Li/e0/i/m;->i(II)Li/e0/i/m;
const/4 v3, 0x5
const/16 v5, 0x4000
invoke-virtual {v2, v3, v5}, Li/e0/i/m;->i(II)Li/e0/i/m;
invoke-virtual {v2}, Li/e0/i/m;->d()I
move-result v2
int-to-long v2, v2
iput-wide v2, v0, Li/e0/i/g;->q:J
iget-object v2, v1, Li/e0/i/g$g;->a:Ljava/net/Socket;
iput-object v2, v0, Li/e0/i/g;->u:Ljava/net/Socket;
new-instance v2, Li/e0/i/j;
iget-object v3, v1, Li/e0/i/g$g;->d:Lj/d;
invoke-direct {v2, v3, v4}, Li/e0/i/j;-><init>(Lj/d;Z)V
iput-object v2, v0, Li/e0/i/g;->v:Li/e0/i/j;
new-instance v2, Li/e0/i/g$j;
new-instance v3, Li/e0/i/h;
iget-object v1, v1, Li/e0/i/g$g;->c:Lj/e;
invoke-direct {v3, v1, v4}, Li/e0/i/h;-><init>(Lj/e;Z)V
invoke-direct {v2, v0, v3}, Li/e0/i/g$j;-><init>(Li/e0/i/g;Li/e0/i/h;)V
iput-object v2, v0, Li/e0/i/g;->w:Li/e0/i/g$j;
return-void
.end method
.method private N()V
.registers 2
:try_start_0
sget-object v0, Li/e0/i/b;->g:Li/e0/i/b;
invoke-virtual {p0, v0, v0}, Li/e0/i/g;->G(Li/e0/i/b;Li/e0/i/b;)V
:try_end_5
.catch Ljava/io/IOException; {:try_start_0 .. :try_end_5} :catch_5
:catch_5
return-void
.end method
.method private a0(ILjava/util/List;Z)Li/e0/i/i;
.registers 14
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Li/e0/i/c;",
">;Z)",
"Li/e0/i/i;"
}
.end annotation
xor-int/lit8 v6, p3, 0x1
const/4 v4, 0x0
iget-object v7, p0, Li/e0/i/g;->v:Li/e0/i/j;
monitor-enter v7
:try_start_6
monitor-enter p0
:try_end_7
.catchall {:try_start_6 .. :try_end_7} :catchall_76
:try_start_7
iget v0, p0, Li/e0/i/g;->j:I
const v1, 0x3fffffff # 1.9999999f
if-le v0, v1, :cond_13
sget-object v0, Li/e0/i/b;->j:Li/e0/i/b;
invoke-virtual {p0, v0}, Li/e0/i/g;->v0(Li/e0/i/b;)V
:cond_13
iget-boolean v0, p0, Li/e0/i/g;->k:Z
if-nez v0, :cond_6d
iget v8, p0, Li/e0/i/g;->j:I
add-int/lit8 v0, v8, 0x2
iput v0, p0, Li/e0/i/g;->j:I
new-instance v9, Li/e0/i/i;
const/4 v5, 0x0
move-object v0, v9
move v1, v8
move-object v2, p0
move v3, v6
invoke-direct/range {v0 .. v5}, Li/e0/i/i;-><init>(ILi/e0/i/g;ZZLi/r;)V
if-eqz p3, :cond_3a
iget-wide v0, p0, Li/e0/i/g;->q:J
const-wide/16 v2, 0x0
cmp-long p3, v0, v2
if-eqz p3, :cond_3a
iget-wide v0, v9, Li/e0/i/i;->b:J
cmp-long p3, v0, v2
if-nez p3, :cond_38
goto :goto_3a
:cond_38
const/4 p3, 0x0
goto :goto_3b
:cond_3a
:goto_3a
const/4 p3, 0x1
:goto_3b
invoke-virtual {v9}, Li/e0/i/i;->m()Z
move-result v0
if-eqz v0, :cond_4a
iget-object v0, p0, Li/e0/i/g;->g:Ljava/util/Map;
invoke-static {v8}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
invoke-interface {v0, v1, v9}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
:cond_4a
monitor-exit p0
:try_end_4b
.catchall {:try_start_7 .. :try_end_4b} :catchall_73
if-nez p1, :cond_53
:try_start_4d
iget-object v0, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {v0, v6, v8, p1, p2}, Li/e0/i/j;->p0(ZIILjava/util/List;)V
goto :goto_5c
:cond_53
iget-boolean v0, p0, Li/e0/i/g;->e:Z
if-nez v0, :cond_65
iget-object v0, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {v0, p1, v8, p2}, Li/e0/i/j;->a0(IILjava/util/List;)V
:goto_5c
monitor-exit v7
:try_end_5d
.catchall {:try_start_4d .. :try_end_5d} :catchall_76
if-eqz p3, :cond_64
iget-object p1, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {p1}, Li/e0/i/j;->flush()V
:cond_64
return-object v9
:cond_65
:try_start_65
new-instance p1, Ljava/lang/IllegalArgumentException;
const-string p2, "client streams shouldn\'t have associated stream IDs"
invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V
throw p1
:try_end_6d
.catchall {:try_start_65 .. :try_end_6d} :catchall_76
:cond_6d
:try_start_6d
new-instance p1, Li/e0/i/a;
invoke-direct {p1}, Li/e0/i/a;-><init>()V
throw p1
:catchall_73
move-exception p1
monitor-exit p0
:try_end_75
.catchall {:try_start_6d .. :try_end_75} :catchall_73
:try_start_75
throw p1
:catchall_76
move-exception p1
monitor-exit v7
:try_end_78
.catchall {:try_start_75 .. :try_end_78} :catchall_76
throw p1
.end method
.method static synthetic k(Li/e0/i/g;)V
.registers 1
invoke-direct {p0}, Li/e0/i/g;->N()V
return-void
.end method
.method static synthetic m()Ljava/util/concurrent/ExecutorService;
.registers 1
sget-object v0, Li/e0/i/g;->y:Ljava/util/concurrent/ExecutorService;
return-object v0
.end method
.method private declared-synchronized p0(Li/e0/b;)V
.registers 3
monitor-enter p0
:try_start_1
invoke-virtual {p0}, Li/e0/i/g;->R()Z
move-result v0
if-nez v0, :cond_c
iget-object v0, p0, Li/e0/i/g;->m:Ljava/util/concurrent/ExecutorService;
invoke-interface {v0, p1}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V
:try_end_c
.catchall {:try_start_1 .. :try_end_c} :catchall_e
:cond_c
monitor-exit p0
return-void
:catchall_e
move-exception p1
monitor-exit p0
throw p1
.end method
.method static synthetic r(Li/e0/i/g;)Ljava/util/concurrent/ScheduledExecutorService;
.registers 1
iget-object p0, p0, Li/e0/i/g;->l:Ljava/util/concurrent/ScheduledExecutorService;
return-object p0
.end method
.method static synthetic x(Li/e0/i/g;Z)Z
.registers 2
iput-boolean p1, p0, Li/e0/i/g;->o:Z
return p1
.end method
# virtual methods
.method A0(ZII)V
.registers 6
if-nez p1, :cond_12
monitor-enter p0
:try_start_3
iget-boolean v0, p0, Li/e0/i/g;->o:Z
const/4 v1, 0x1
iput-boolean v1, p0, Li/e0/i/g;->o:Z
monitor-exit p0
:try_end_9
.catchall {:try_start_3 .. :try_end_9} :catchall_f
if-eqz v0, :cond_12
invoke-direct {p0}, Li/e0/i/g;->N()V
return-void
:catchall_f
move-exception p1
:try_start_10
monitor-exit p0
:try_end_11
.catchall {:try_start_10 .. :try_end_11} :catchall_f
throw p1
:cond_12
:try_start_12
iget-object v0, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {v0, p1, p2, p3}, Li/e0/i/j;->X(ZII)V
:try_end_17
.catch Ljava/io/IOException; {:try_start_12 .. :try_end_17} :catch_18
goto :goto_1b
:catch_18
invoke-direct {p0}, Li/e0/i/g;->N()V
:goto_1b
return-void
.end method
.method B0(ILi/e0/i/b;)V
.registers 4
iget-object v0, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {v0, p1, p2}, Li/e0/i/j;->h0(ILi/e0/i/b;)V
return-void
.end method
.method C0(ILi/e0/i/b;)V
.registers 11
:try_start_0
iget-object v0, p0, Li/e0/i/g;->l:Ljava/util/concurrent/ScheduledExecutorService;
new-instance v7, Li/e0/i/g$a;
const-string v3, "OkHttp %s stream %d"
const/4 v1, 0x2
new-array v4, v1, [Ljava/lang/Object;
const/4 v1, 0x0
iget-object v2, p0, Li/e0/i/g;->h:Ljava/lang/String;
aput-object v2, v4, v1
const/4 v1, 0x1
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
aput-object v2, v4, v1
move-object v1, v7
move-object v2, p0
move v5, p1
move-object v6, p2
invoke-direct/range {v1 .. v6}, Li/e0/i/g$a;-><init>(Li/e0/i/g;Ljava/lang/String;[Ljava/lang/Object;ILi/e0/i/b;)V
invoke-interface {v0, v7}, Ljava/util/concurrent/ScheduledExecutorService;->execute(Ljava/lang/Runnable;)V
:try_end_1f
.catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_0 .. :try_end_1f} :catch_1f
:catch_1f
return-void
.end method
.method D0(IJ)V
.registers 13
:try_start_0
iget-object v0, p0, Li/e0/i/g;->l:Ljava/util/concurrent/ScheduledExecutorService;
new-instance v8, Li/e0/i/g$b;
const-string v3, "OkHttp Window Update %s stream %d"
const/4 v1, 0x2
new-array v4, v1, [Ljava/lang/Object;
const/4 v1, 0x0
iget-object v2, p0, Li/e0/i/g;->h:Ljava/lang/String;
aput-object v2, v4, v1
const/4 v1, 0x1
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
aput-object v2, v4, v1
move-object v1, v8
move-object v2, p0
move v5, p1
move-wide v6, p2
invoke-direct/range {v1 .. v7}, Li/e0/i/g$b;-><init>(Li/e0/i/g;Ljava/lang/String;[Ljava/lang/Object;IJ)V
invoke-interface {v0, v8}, Ljava/util/concurrent/ScheduledExecutorService;->execute(Ljava/lang/Runnable;)V
:try_end_1f
.catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_0 .. :try_end_1f} :catch_1f
:catch_1f
return-void
.end method
.method G(Li/e0/i/b;Li/e0/i/b;)V
.registers 7
const/4 v0, 0x0
:try_start_1
invoke-virtual {p0, p1}, Li/e0/i/g;->v0(Li/e0/i/b;)V
:try_end_4
.catch Ljava/io/IOException; {:try_start_1 .. :try_end_4} :catch_6
move-object p1, v0
goto :goto_7
:catch_6
move-exception p1
:goto_7
monitor-enter p0
:try_start_8
iget-object v1, p0, Li/e0/i/g;->g:Ljava/util/Map;
invoke-interface {v1}, Ljava/util/Map;->isEmpty()Z
move-result v1
if-nez v1, :cond_29
iget-object v0, p0, Li/e0/i/g;->g:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->values()Ljava/util/Collection;
move-result-object v0
iget-object v1, p0, Li/e0/i/g;->g:Ljava/util/Map;
invoke-interface {v1}, Ljava/util/Map;->size()I
move-result v1
new-array v1, v1, [Li/e0/i/i;
invoke-interface {v0, v1}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;
move-result-object v0
check-cast v0, [Li/e0/i/i;
iget-object v1, p0, Li/e0/i/g;->g:Ljava/util/Map;
invoke-interface {v1}, Ljava/util/Map;->clear()V
:cond_29
monitor-exit p0
:try_end_2a
.catchall {:try_start_8 .. :try_end_2a} :catchall_5c
if-eqz v0, :cond_3d
array-length v1, v0
const/4 v2, 0x0
:goto_2e
if-ge v2, v1, :cond_3d
aget-object v3, v0, v2
:try_start_32
invoke-virtual {v3, p2}, Li/e0/i/i;->f(Li/e0/i/b;)V
:try_end_35
.catch Ljava/io/IOException; {:try_start_32 .. :try_end_35} :catch_36
goto :goto_3a
:catch_36
move-exception v3
if-eqz p1, :cond_3a
move-object p1, v3
:cond_3a
:goto_3a
add-int/lit8 v2, v2, 0x1
goto :goto_2e
:cond_3d
:try_start_3d
iget-object p2, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {p2}, Li/e0/i/j;->close()V
:try_end_42
.catch Ljava/io/IOException; {:try_start_3d .. :try_end_42} :catch_43
goto :goto_47
:catch_43
move-exception p2
if-nez p1, :cond_47
move-object p1, p2
:cond_47
:goto_47
:try_start_47
iget-object p2, p0, Li/e0/i/g;->u:Ljava/net/Socket;
invoke-virtual {p2}, Ljava/net/Socket;->close()V
:try_end_4c
.catch Ljava/io/IOException; {:try_start_47 .. :try_end_4c} :catch_4d
goto :goto_4e
:catch_4d
move-exception p1
:goto_4e
iget-object p2, p0, Li/e0/i/g;->l:Ljava/util/concurrent/ScheduledExecutorService;
invoke-interface {p2}, Ljava/util/concurrent/ScheduledExecutorService;->shutdown()V
iget-object p2, p0, Li/e0/i/g;->m:Ljava/util/concurrent/ExecutorService;
invoke-interface {p2}, Ljava/util/concurrent/ExecutorService;->shutdown()V
if-nez p1, :cond_5b
return-void
:cond_5b
throw p1
:catchall_5c
move-exception p1
:try_start_5d
monitor-exit p0
:try_end_5e
.catchall {:try_start_5d .. :try_end_5e} :catchall_5c
goto :goto_60
:goto_5f
throw p1
:goto_60
goto :goto_5f
.end method
.method declared-synchronized O(I)Li/e0/i/i;
.registers 3
monitor-enter p0
:try_start_1
iget-object v0, p0, Li/e0/i/g;->g: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, Li/e0/i/i;
: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 declared-synchronized R()Z
.registers 2
monitor-enter p0
:try_start_1
iget-boolean v0, p0, Li/e0/i/g;->k:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized X()I
.registers 3
monitor-enter p0
:try_start_1
iget-object v0, p0, Li/e0/i/g;->s:Li/e0/i/m;
const v1, 0x7fffffff
invoke-virtual {v0, v1}, Li/e0/i/m;->e(I)I
move-result v0
:try_end_a
.catchall {:try_start_1 .. :try_end_a} :catchall_c
monitor-exit p0
return v0
:catchall_c
move-exception v0
monitor-exit p0
throw v0
.end method
.method public close()V
.registers 3
sget-object v0, Li/e0/i/b;->f:Li/e0/i/b;
sget-object v1, Li/e0/i/b;->k:Li/e0/i/b;
invoke-virtual {p0, v0, v1}, Li/e0/i/g;->G(Li/e0/i/b;Li/e0/i/b;)V
return-void
.end method
.method public flush()V
.registers 2
iget-object v0, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {v0}, Li/e0/i/j;->flush()V
return-void
.end method
.method public h0(Ljava/util/List;Z)Li/e0/i/i;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Li/e0/i/c;",
">;Z)",
"Li/e0/i/i;"
}
.end annotation
const/4 v0, 0x0
invoke-direct {p0, v0, p1, p2}, Li/e0/i/g;->a0(ILjava/util/List;Z)Li/e0/i/i;
move-result-object p1
return-object p1
.end method
.method i0(ILj/e;IZ)V
.registers 13
new-instance v5, Lj/c;
invoke-direct {v5}, Lj/c;-><init>()V
int-to-long v0, p3
invoke-interface {p2, v0, v1}, Lj/e;->j0(J)V
invoke-interface {p2, v5, v0, v1}, Lj/s;->e0(Lj/c;J)J
invoke-virtual {v5}, Lj/c;->size()J
move-result-wide v2
cmp-long p2, v2, v0
if-nez p2, :cond_33
new-instance p2, Li/e0/i/g$e;
const/4 v0, 0x2
new-array v3, v0, [Ljava/lang/Object;
const/4 v0, 0x0
iget-object v1, p0, Li/e0/i/g;->h:Ljava/lang/String;
aput-object v1, v3, v0
const/4 v0, 0x1
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
aput-object v1, v3, v0
const-string v2, "OkHttp %s Push Data[%s]"
move-object v0, p2
move-object v1, p0
move v4, p1
move v6, p3
move v7, p4
invoke-direct/range {v0 .. v7}, Li/e0/i/g$e;-><init>(Li/e0/i/g;Ljava/lang/String;[Ljava/lang/Object;ILj/c;IZ)V
invoke-direct {p0, p2}, Li/e0/i/g;->p0(Li/e0/b;)V
return-void
:cond_33
new-instance p1, Ljava/io/IOException;
new-instance p2, Ljava/lang/StringBuilder;
invoke-direct {p2}, Ljava/lang/StringBuilder;-><init>()V
invoke-virtual {v5}, Lj/c;->size()J
move-result-wide v0
invoke-virtual {p2, v0, v1}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
const-string p4, " != "
invoke-virtual {p2, p4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-direct {p1, p2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method q0(ILjava/util/List;Z)V
.registers 12
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Li/e0/i/c;",
">;Z)V"
}
.end annotation
:try_start_0
new-instance v7, Li/e0/i/g$d;
const-string v2, "OkHttp %s Push Headers[%s]"
const/4 v0, 0x2
new-array v3, v0, [Ljava/lang/Object;
const/4 v0, 0x0
iget-object v1, p0, Li/e0/i/g;->h:Ljava/lang/String;
aput-object v1, v3, v0
const/4 v0, 0x1
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
aput-object v1, v3, v0
move-object v0, v7
move-object v1, p0
move v4, p1
move-object v5, p2
move v6, p3
invoke-direct/range {v0 .. v6}, Li/e0/i/g$d;-><init>(Li/e0/i/g;Ljava/lang/String;[Ljava/lang/Object;ILjava/util/List;Z)V
invoke-direct {p0, v7}, Li/e0/i/g;->p0(Li/e0/b;)V
:try_end_1e
.catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_0 .. :try_end_1e} :catch_1e
:catch_1e
return-void
.end method
.method r0(ILjava/util/List;)V
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Ljava/util/List<",
"Li/e0/i/c;",
">;)V"
}
.end annotation
monitor-enter p0
:try_start_1
iget-object v0, p0, Li/e0/i/g;->x: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_14
sget-object p2, Li/e0/i/b;->g:Li/e0/i/b;
invoke-virtual {p0, p1, p2}, Li/e0/i/g;->C0(ILi/e0/i/b;)V
monitor-exit p0
return-void
:cond_14
iget-object v0, p0, Li/e0/i/g;->x: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
monitor-exit p0
:try_end_1e
.catchall {:try_start_1 .. :try_end_1e} :catchall_3c
:try_start_1e
new-instance v0, Li/e0/i/g$c;
const-string v4, "OkHttp %s Push Request[%s]"
const/4 v1, 0x2
new-array v5, v1, [Ljava/lang/Object;
const/4 v1, 0x0
iget-object v2, p0, Li/e0/i/g;->h:Ljava/lang/String;
aput-object v2, v5, v1
const/4 v1, 0x1
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
aput-object v2, v5, v1
move-object v2, v0
move-object v3, p0
move v6, p1
move-object v7, p2
invoke-direct/range {v2 .. v7}, Li/e0/i/g$c;-><init>(Li/e0/i/g;Ljava/lang/String;[Ljava/lang/Object;ILjava/util/List;)V
invoke-direct {p0, v0}, Li/e0/i/g;->p0(Li/e0/b;)V
:try_end_3b
.catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_1e .. :try_end_3b} :catch_3b
:catch_3b
return-void
:catchall_3c
move-exception p1
:try_start_3d
monitor-exit p0
:try_end_3e
.catchall {:try_start_3d .. :try_end_3e} :catchall_3c
throw p1
.end method
.method s0(ILi/e0/i/b;)V
.registers 10
new-instance v6, Li/e0/i/g$f;
const/4 v0, 0x2
new-array v3, v0, [Ljava/lang/Object;
iget-object v0, p0, Li/e0/i/g;->h:Ljava/lang/String;
const/4 v1, 0x0
aput-object v0, v3, v1
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
const/4 v1, 0x1
aput-object v0, v3, v1
const-string v2, "OkHttp %s Push Reset[%s]"
move-object v0, v6
move-object v1, p0
move v4, p1
move-object v5, p2
invoke-direct/range {v0 .. v5}, Li/e0/i/g$f;-><init>(Li/e0/i/g;Ljava/lang/String;[Ljava/lang/Object;ILi/e0/i/b;)V
invoke-direct {p0, v6}, Li/e0/i/g;->p0(Li/e0/b;)V
return-void
.end method
.method t0(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 declared-synchronized u0(I)Li/e0/i/i;
.registers 3
monitor-enter p0
:try_start_1
iget-object v0, p0, Li/e0/i/g;->g: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, Li/e0/i/i;
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
:try_end_10
.catchall {:try_start_1 .. :try_end_10} :catchall_12
monitor-exit p0
return-object p1
:catchall_12
move-exception p1
monitor-exit p0
throw p1
.end method
.method public v0(Li/e0/i/b;)V
.registers 6
iget-object v0, p0, Li/e0/i/g;->v:Li/e0/i/j;
monitor-enter v0
:try_start_3
monitor-enter p0
:try_end_4
.catchall {:try_start_3 .. :try_end_4} :catchall_1d
:try_start_4
iget-boolean v1, p0, Li/e0/i/g;->k:Z
if-eqz v1, :cond_b
monitor-exit p0
:try_end_9
.catchall {:try_start_4 .. :try_end_9} :catchall_1a
:try_start_9
monitor-exit v0
:try_end_a
.catchall {:try_start_9 .. :try_end_a} :catchall_1d
return-void
:cond_b
const/4 v1, 0x1
:try_start_c
iput-boolean v1, p0, Li/e0/i/g;->k:Z
iget v1, p0, Li/e0/i/g;->i:I
monitor-exit p0
:try_end_11
.catchall {:try_start_c .. :try_end_11} :catchall_1a
:try_start_11
iget-object v2, p0, Li/e0/i/g;->v:Li/e0/i/j;
sget-object v3, Li/e0/c;->a:[B
invoke-virtual {v2, v1, p1, v3}, Li/e0/i/j;->N(ILi/e0/i/b;[B)V
monitor-exit v0
:try_end_19
.catchall {:try_start_11 .. :try_end_19} :catchall_1d
return-void
:catchall_1a
move-exception p1
:try_start_1b
monitor-exit p0
:try_end_1c
.catchall {:try_start_1b .. :try_end_1c} :catchall_1a
:try_start_1c
throw p1
:catchall_1d
move-exception p1
monitor-exit v0
:try_end_1f
.catchall {:try_start_1c .. :try_end_1f} :catchall_1d
throw p1
.end method
.method public w0()V
.registers 2
const/4 v0, 0x1
invoke-virtual {p0, v0}, Li/e0/i/g;->x0(Z)V
return-void
.end method
.method x0(Z)V
.registers 7
if-eqz p1, :cond_21
iget-object p1, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {p1}, Li/e0/i/j;->m()V
iget-object p1, p0, Li/e0/i/g;->v:Li/e0/i/j;
iget-object v0, p0, Li/e0/i/g;->r:Li/e0/i/m;
invoke-virtual {p1, v0}, Li/e0/i/j;->i0(Li/e0/i/m;)V
iget-object p1, p0, Li/e0/i/g;->r:Li/e0/i/m;
invoke-virtual {p1}, Li/e0/i/m;->d()I
move-result p1
const v0, 0xffff
if-eq p1, v0, :cond_21
iget-object v1, p0, Li/e0/i/g;->v:Li/e0/i/j;
const/4 v2, 0x0
sub-int/2addr p1, v0
int-to-long v3, p1
invoke-virtual {v1, v2, v3, v4}, Li/e0/i/j;->q0(IJ)V
:cond_21
new-instance p1, Ljava/lang/Thread;
iget-object v0, p0, Li/e0/i/g;->w:Li/e0/i/g$j;
invoke-direct {p1, v0}, Ljava/lang/Thread;-><init>(Ljava/lang/Runnable;)V
invoke-virtual {p1}, Ljava/lang/Thread;->start()V
return-void
.end method
.method declared-synchronized y0(J)V
.registers 6
monitor-enter p0
:try_start_1
iget-wide v0, p0, Li/e0/i/g;->p:J
add-long/2addr v0, p1
iput-wide v0, p0, Li/e0/i/g;->p:J
iget-object p1, p0, Li/e0/i/g;->r:Li/e0/i/m;
invoke-virtual {p1}, Li/e0/i/m;->d()I
move-result p1
div-int/lit8 p1, p1, 0x2
int-to-long p1, p1
cmp-long v2, v0, p1
if-ltz v2, :cond_1d
const/4 p1, 0x0
iget-wide v0, p0, Li/e0/i/g;->p:J
invoke-virtual {p0, p1, v0, v1}, Li/e0/i/g;->D0(IJ)V
const-wide/16 p1, 0x0
iput-wide p1, p0, Li/e0/i/g;->p:J
:try_end_1d
.catchall {:try_start_1 .. :try_end_1d} :catchall_1f
:cond_1d
monitor-exit p0
return-void
:catchall_1f
move-exception p1
monitor-exit p0
throw p1
.end method
.method public z0(IZLj/c;J)V
.registers 14
const/4 v0, 0x0
const-wide/16 v1, 0x0
cmp-long v3, p4, v1
if-nez v3, :cond_d
iget-object p4, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {p4, p2, p1, p3, v0}, Li/e0/i/j;->r(ZILj/c;I)V
return-void
:cond_d
:goto_d
cmp-long v3, p4, v1
if-lez v3, :cond_67
monitor-enter p0
:goto_12
:try_start_12
iget-wide v3, p0, Li/e0/i/g;->q:J
cmp-long v5, v3, v1
if-gtz v5, :cond_30
iget-object v3, p0, Li/e0/i/g;->g:Ljava/util/Map;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v4
invoke-interface {v3, v4}, Ljava/util/Map;->containsKey(Ljava/lang/Object;)Z
move-result v3
if-eqz v3, :cond_28
invoke-virtual {p0}, Ljava/lang/Object;->wait()V
goto :goto_12
:cond_28
new-instance p1, Ljava/io/IOException;
const-string p2, "stream closed"
invoke-direct {p1, p2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw p1
:try_end_30
.catch Ljava/lang/InterruptedException; {:try_start_12 .. :try_end_30} :catch_58
.catchall {:try_start_12 .. :try_end_30} :catchall_56
:cond_30
:try_start_30
invoke-static {p4, p5, v3, v4}, Ljava/lang/Math;->min(JJ)J
move-result-wide v3
long-to-int v4, v3
iget-object v3, p0, Li/e0/i/g;->v:Li/e0/i/j;
invoke-virtual {v3}, Li/e0/i/j;->R()I
move-result v3
invoke-static {v4, v3}, Ljava/lang/Math;->min(II)I
move-result v3
iget-wide v4, p0, Li/e0/i/g;->q:J
int-to-long v6, v3
sub-long/2addr v4, v6
iput-wide v4, p0, Li/e0/i/g;->q:J
monitor-exit p0
:try_end_46
.catchall {:try_start_30 .. :try_end_46} :catchall_56
sub-long/2addr p4, v6
iget-object v4, p0, Li/e0/i/g;->v:Li/e0/i/j;
if-eqz p2, :cond_51
cmp-long v5, p4, v1
if-nez v5, :cond_51
const/4 v5, 0x1
goto :goto_52
:cond_51
const/4 v5, 0x0
:goto_52
invoke-virtual {v4, v5, p1, p3, v3}, Li/e0/i/j;->r(ZILj/c;I)V
goto :goto_d
:catchall_56
move-exception p1
goto :goto_65
:catch_58
:try_start_58
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object p1
invoke-virtual {p1}, Ljava/lang/Thread;->interrupt()V
new-instance p1, Ljava/io/InterruptedIOException;
invoke-direct {p1}, Ljava/io/InterruptedIOException;-><init>()V
throw p1
:goto_65
monitor-exit p0
:try_end_66
.catchall {:try_start_58 .. :try_end_66} :catchall_56
throw p1
:cond_67
return-void
.end method