a.smali

.class public final Llive/sg/bigo/sdk/network/a/a;
.super Llive/sg/bigo/sdk/network/d/a;
.source "SourceFile"

# interfaces
.implements Llive/sg/bigo/sdk/network/a/c;


# instance fields
.field private A:Landroid/os/Handler;

.field private B:Ljava/lang/Runnable;

.field private C:Ljava/util/concurrent/atomic/AtomicBoolean;

.field private t:Llive/sg/bigo/sdk/network/a/d;

.field private u:Ljava/nio/ByteBuffer;

.field private v:I

.field private w:Ljava/lang/String;

.field private final x:I

.field private final y:I

.field private z:I


# direct methods
.method public constructor <init>(Ljava/net/InetSocketAddress;Llive/sg/bigo/sdk/network/proxy/ProxyInfo;Llive/sg/bigo/sdk/network/d/d;Llive/sg/bigo/sdk/network/d/c;IILjava/lang/String;Llive/sg/bigo/sdk/network/a/d;I)V
    .registers 10

    .line 60
    invoke-direct {p0, p1, p2, p3, p4}, Llive/sg/bigo/sdk/network/d/a;-><init>(Ljava/net/InetSocketAddress;Llive/sg/bigo/sdk/network/proxy/ProxyInfo;Llive/sg/bigo/sdk/network/d/d;Llive/sg/bigo/sdk/network/d/c;)V

    const p1, 0x8000

    .line 36
    invoke-static {p1}, Ljava/nio/ByteBuffer;->allocate(I)Ljava/nio/ByteBuffer;

    move-result-object p1

    iput-object p1, p0, Llive/sg/bigo/sdk/network/a/a;->u:Ljava/nio/ByteBuffer;

    const/4 p1, 0x0

    .line 38
    iput p1, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    .line 69
    invoke-static {}, Llive/sg/bigo/svcapi/util/c;->a()Landroid/os/Handler;

    move-result-object p2

    iput-object p2, p0, Llive/sg/bigo/sdk/network/a/a;->A:Landroid/os/Handler;

    .line 70
    new-instance p2, Llive/sg/bigo/sdk/network/a/a$1;

    invoke-direct {p2, p0}, Llive/sg/bigo/sdk/network/a/a$1;-><init>(Llive/sg/bigo/sdk/network/a/a;)V

    iput-object p2, p0, Llive/sg/bigo/sdk/network/a/a;->B:Ljava/lang/Runnable;

    .line 275
    new-instance p2, Ljava/util/concurrent/atomic/AtomicBoolean;

    invoke-direct {p2, p1}, Ljava/util/concurrent/atomic/AtomicBoolean;-><init>(Z)V

    iput-object p2, p0, Llive/sg/bigo/sdk/network/a/a;->C:Ljava/util/concurrent/atomic/AtomicBoolean;

    .line 61
    iput p5, p0, Llive/sg/bigo/sdk/network/a/a;->x:I

    .line 62
    iput p6, p0, Llive/sg/bigo/sdk/network/a/a;->y:I

    .line 63
    iput-object p7, p0, Llive/sg/bigo/sdk/network/a/a;->w:Ljava/lang/String;

    .line 64
    iput-object p8, p0, Llive/sg/bigo/sdk/network/a/a;->t:Llive/sg/bigo/sdk/network/a/d;

    .line 65
    iput p9, p0, Llive/sg/bigo/sdk/network/a/a;->z:I

    .line 2038
    invoke-static {}, Llive/sg/bigo/sdk/network/a/b$a;->a()Llive/sg/bigo/sdk/network/a/b;

    move-result-object p1

    .line 66
    iget p2, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

    invoke-virtual {p1, p9, p2, p0}, Llive/sg/bigo/sdk/network/a/b;->a(IILlive/sg/bigo/sdk/network/a/c;)V

    return-void
.end method

.method public constructor <init>(Ljava/net/InetSocketAddress;Llive/sg/bigo/sdk/network/proxy/ProxyInfo;Llive/sg/bigo/sdk/network/d/d;Llive/sg/bigo/sdk/network/d/c;Ljava/lang/String;Llive/sg/bigo/sdk/network/a/d;I)V
    .registers 8

    .line 49
    invoke-direct {p0, p1, p2, p3, p4}, Llive/sg/bigo/sdk/network/d/a;-><init>(Ljava/net/InetSocketAddress;Llive/sg/bigo/sdk/network/proxy/ProxyInfo;Llive/sg/bigo/sdk/network/d/d;Llive/sg/bigo/sdk/network/d/c;)V

    const p1, 0x8000

    .line 36
    invoke-static {p1}, Ljava/nio/ByteBuffer;->allocate(I)Ljava/nio/ByteBuffer;

    move-result-object p1

    iput-object p1, p0, Llive/sg/bigo/sdk/network/a/a;->u:Ljava/nio/ByteBuffer;

    const/4 p1, 0x0

    .line 38
    iput p1, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    .line 69
    invoke-static {}, Llive/sg/bigo/svcapi/util/c;->a()Landroid/os/Handler;

    move-result-object p2

    iput-object p2, p0, Llive/sg/bigo/sdk/network/a/a;->A:Landroid/os/Handler;

    .line 70
    new-instance p2, Llive/sg/bigo/sdk/network/a/a$1;

    invoke-direct {p2, p0}, Llive/sg/bigo/sdk/network/a/a$1;-><init>(Llive/sg/bigo/sdk/network/a/a;)V

    iput-object p2, p0, Llive/sg/bigo/sdk/network/a/a;->B:Ljava/lang/Runnable;

    .line 275
    new-instance p2, Ljava/util/concurrent/atomic/AtomicBoolean;

    invoke-direct {p2, p1}, Ljava/util/concurrent/atomic/AtomicBoolean;-><init>(Z)V

    iput-object p2, p0, Llive/sg/bigo/sdk/network/a/a;->C:Ljava/util/concurrent/atomic/AtomicBoolean;

    .line 50
    invoke-static {}, Llive/sg/bigo/svcapi/t;->a()I

    move-result p1

    iput p1, p0, Llive/sg/bigo/sdk/network/a/a;->x:I

    .line 51
    invoke-static {}, Llive/sg/bigo/svcapi/t;->b()I

    move-result p1

    iput p1, p0, Llive/sg/bigo/sdk/network/a/a;->y:I

    .line 52
    iput-object p5, p0, Llive/sg/bigo/sdk/network/a/a;->w:Ljava/lang/String;

    .line 53
    iput-object p6, p0, Llive/sg/bigo/sdk/network/a/a;->t:Llive/sg/bigo/sdk/network/a/d;

    .line 54
    iput p7, p0, Llive/sg/bigo/sdk/network/a/a;->z:I

    .line 1038
    invoke-static {}, Llive/sg/bigo/sdk/network/a/b$a;->a()Llive/sg/bigo/sdk/network/a/b;

    move-result-object p1

    .line 55
    iget p2, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

    invoke-virtual {p1, p7, p2, p0}, Llive/sg/bigo/sdk/network/a/b;->a(IILlive/sg/bigo/sdk/network/a/c;)V

    return-void
.end method

.method static synthetic a(Llive/sg/bigo/sdk/network/a/a;)I
    .registers 1

    .line 28
    iget p0, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    return p0
.end method

.method private b(Ljava/nio/ByteBuffer;)I
    .registers 9

    if-nez p1, :cond_4

    const/4 p1, -0x2

    return p1

    .line 265
    :cond_4
    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->t:Llive/sg/bigo/sdk/network/a/d;

    if-eqz v0, :cond_24

    .line 4038
    invoke-static {}, Llive/sg/bigo/sdk/network/a/b$a;->a()Llive/sg/bigo/sdk/network/a/b;

    move-result-object v0

    .line 4062
    iget-boolean v0, v0, Llive/sg/bigo/sdk/network/a/b;->a:Z

    if-nez v0, :cond_11

    goto :goto_24

    .line 269
    :cond_11
    invoke-virtual {p1}, Ljava/nio/ByteBuffer;->limit()I

    move-result v0

    .line 270
    iget-object v1, p0, Llive/sg/bigo/sdk/network/a/a;->t:Llive/sg/bigo/sdk/network/a/d;

    iget v3, p0, Llive/sg/bigo/sdk/network/a/a;->z:I

    iget v4, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

    invoke-static {}, Ljava/lang/System;->currentTimeMillis()J

    move-result-wide v5

    move-object v2, p1

    invoke-interface/range {v1 .. v6}, Llive/sg/bigo/sdk/network/a/d;->a(Ljava/nio/ByteBuffer;IIJ)I

    return v0

    .line 266
    :cond_24
    :goto_24
    new-instance p1, Ljava/lang/StringBuilder;

    const-string v0, "FCM trying to write null or not connected channel connId = "

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

    iget v0, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

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

    invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    const-string v0, "yysdk-net-fcm"

    invoke-static {v0, p1}, Lsg/bigo/log/TraceLog;->e(Ljava/lang/String;Ljava/lang/String;)I

    const/4 p1, -0x1

    return p1
.end method

.method static synthetic b(Llive/sg/bigo/sdk/network/a/a;)Ljava/net/InetSocketAddress;
    .registers 1

    .line 28
    iget-object p0, p0, Llive/sg/bigo/sdk/network/a/a;->a:Ljava/net/InetSocketAddress;

    return-object p0
.end method

.method static synthetic c(Llive/sg/bigo/sdk/network/a/a;)Ljava/lang/String;
    .registers 1

    .line 28
    iget-object p0, p0, Llive/sg/bigo/sdk/network/a/a;->w:Ljava/lang/String;

    return-object p0
.end method

.method private q()V
    .registers 3

    .line 88
    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->A:Landroid/os/Handler;

    if-eqz v0, :cond_9

    .line 89
    iget-object v1, p0, Llive/sg/bigo/sdk/network/a/a;->B:Ljava/lang/Runnable;

    invoke-virtual {v0, v1}, Landroid/os/Handler;->removeCallbacks(Ljava/lang/Runnable;)V

    :cond_9
    return-void
.end method


# virtual methods
.method public final a(ILjava/lang/String;)V
    .registers 5

    .line 286
    new-instance v0, Ljava/lang/StringBuilder;

    const-string v1, "FCM error happens: "

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

    iget-object v1, p0, Llive/sg/bigo/sdk/network/a/a;->a:Ljava/net/InetSocketAddress;

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

    const-string v1, " proxy="

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

    iget-object v1, p0, Llive/sg/bigo/sdk/network/a/a;->b:Llive/sg/bigo/sdk/network/proxy/ProxyInfo;

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

    const-string v1, " connId= "

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

    iget v1, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

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

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

    move-result-object v0

    const-string v1, "yysdk-net-fcm"

    invoke-static {v1, v0}, Lsg/bigo/log/TraceLog;->e(Ljava/lang/String;Ljava/lang/String;)I

    .line 287
    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->c:Llive/sg/bigo/sdk/network/d/d;

    if-eqz v0, :cond_3b

    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->b:Llive/sg/bigo/sdk/network/proxy/ProxyInfo;

    if-eqz v0, :cond_3b

    iget v0, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    const/4 v1, 0x4

    if-ge v0, v1, :cond_3b

    .line 288
    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->c:Llive/sg/bigo/sdk/network/d/d;

    invoke-interface {v0, p0}, Llive/sg/bigo/sdk/network/d/d;->c(Llive/sg/bigo/sdk/network/d/a;)V

    .line 290
    :cond_3b
    invoke-virtual {p0}, Llive/sg/bigo/sdk/network/a/a;->b()V

    .line 291
    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->c:Llive/sg/bigo/sdk/network/d/d;

    if-eqz v0, :cond_47

    .line 292
    iget-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->c:Llive/sg/bigo/sdk/network/d/d;

    invoke-interface {v0, p0, p1, p2}, Llive/sg/bigo/sdk/network/d/d;->a(Llive/sg/bigo/sdk/network/d/a;ILjava/lang/String;)V

    :cond_47
    return-void
.end method

.method public final a()Z
    .registers 5

    .line 94
    new-instance v0, Ljava/lang/StringBuilder;

    const-string v1, "FCM Connecting :  connId = "

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

    iget v1, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

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

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

    move-result-object v0

    const-string v1, "yysdk-net-fcm"

    invoke-static {v1, v0}, Lsg/bigo/log/TraceLog;->i(Ljava/lang/String;Ljava/lang/String;)I

    .line 96
    iget v0, p0, Llive/sg/bigo/sdk/network/a/a;->x:I

    int-to-long v0, v0

    .line 2083
    iget-object v2, p0, Llive/sg/bigo/sdk/network/a/a;->A:Landroid/os/Handler;

    iget-object v3, p0, Llive/sg/bigo/sdk/network/a/a;->B:Ljava/lang/Runnable;

    invoke-virtual {v2, v3}, Landroid/os/Handler;->removeCallbacks(Ljava/lang/Runnable;)V

    .line 2084
    iget-object v2, p0, Llive/sg/bigo/sdk/network/a/a;->A:Landroid/os/Handler;

    iget-object v3, p0, Llive/sg/bigo/sdk/network/a/a;->B:Ljava/lang/Runnable;

    invoke-virtual {v2, v3, v0, v1}, Landroid/os/Handler;->postDelayed(Ljava/lang/Runnable;J)Z

    .line 98
    invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J

    move-result-wide v0

    iput-wide v0, p0, Llive/sg/bigo/sdk/network/a/a;->h:J

    const/4 v0, 0x1

    .line 99
    iput v0, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    .line 3038
    invoke-static {}, Llive/sg/bigo/sdk/network/a/b$a;->a()Llive/sg/bigo/sdk/network/a/b;

    move-result-object v1

    .line 3062
    iget-boolean v1, v1, Llive/sg/bigo/sdk/network/a/b;->a:Z

    if-eqz v1, :cond_54

    .line 101
    new-instance v1, Llive/sg/bigo/sdk/network/g/a/b;

    invoke-direct {v1}, Llive/sg/bigo/sdk/network/g/a/b;-><init>()V

    .line 102
    new-instance v2, Llive/sg/bigo/sdk/network/j/k;

    invoke-direct {v2}, Llive/sg/bigo/sdk/network/j/k;-><init>()V

    .line 4017
    iget-object v2, v2, Llive/sg/bigo/sdk/network/j/k;->a:Ljava/util/concurrent/atomic/AtomicInteger;

    invoke-virtual {v2}, Ljava/util/concurrent/atomic/AtomicInteger;->incrementAndGet()I

    move-result v2

    .line 102
    iput v2, v1, Llive/sg/bigo/sdk/network/g/a/b;->a:I

    const v2, 0x104201

    .line 103
    invoke-static {v2, v1}, Lsg/bigo/svcapi/proto/ProtoHelper;->protoToByteBuffer(ILsg/bigo/svcapi/proto/Marshallable;)Ljava/nio/ByteBuffer;

    move-result-object v1

    invoke-virtual {p0, v1}, Llive/sg/bigo/sdk/network/a/a;->a(Ljava/nio/ByteBuffer;)Z

    return v0

    .line 106
    :cond_54
    invoke-direct {p0}, Llive/sg/bigo/sdk/network/a/a;->q()V

    .line 107
    invoke-static {}, Llive/sg/bigo/sdk/network/i/g;->a()Llive/sg/bigo/sdk/network/i/g;

    move-result-object v0

    iget-object v1, p0, Llive/sg/bigo/sdk/network/a/a;->w:Ljava/lang/String;

    sget-byte v2, Llive/sg/bigo/sdk/network/i/f;->k:B

    invoke-virtual {v0, v1, v2}, Llive/sg/bigo/sdk/network/i/g;->c(Ljava/lang/String;B)V

    const/16 v0, 0xa

    const-string v1, "OuterChannel not enabled"

    .line 108
    invoke-virtual {p0, v0, v1}, Llive/sg/bigo/sdk/network/a/a;->a(ILjava/lang/String;)V

    const/4 v0, 0x0

    return v0
.end method

.method public final a(Ljava/nio/ByteBuffer;)Z
    .registers 7

    .line 251
    invoke-direct {p0, p1}, Llive/sg/bigo/sdk/network/a/a;->b(Ljava/nio/ByteBuffer;)I

    move-result p1

    const/4 v0, 0x1

    if-lez p1, :cond_12

    .line 253
    iget-wide v1, p0, Llive/sg/bigo/sdk/network/a/a;->n:J

    int-to-long v3, p1

    add-long/2addr v1, v3

    iput-wide v1, p0, Llive/sg/bigo/sdk/network/a/a;->n:J

    .line 254
    iget v1, p0, Llive/sg/bigo/sdk/network/a/a;->p:I

    add-int/2addr v1, v0

    iput v1, p0, Llive/sg/bigo/sdk/network/a/a;->p:I

    :cond_12
    if-lez p1, :cond_15

    return v0

    :cond_15
    const/4 p1, 0x0

    return p1
.end method

.method public final b()V
    .registers 5

    .line 298
    iget v0, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    const/4 v1, 0x7

    if-eq v0, v1, :cond_47

    .line 299
    new-instance v0, Ljava/lang/StringBuilder;

    const-string v2, "FCM close channel: "

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

    iget-object v2, p0, Llive/sg/bigo/sdk/network/a/a;->a:Ljava/net/InetSocketAddress;

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

    const-string v2, " proxy="

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

    iget-object v2, p0, Llive/sg/bigo/sdk/network/a/a;->b:Llive/sg/bigo/sdk/network/proxy/ProxyInfo;

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

    const-string v2, " connId= "

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

    iget v2, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

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

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

    move-result-object v0

    const-string v2, "yysdk-net-fcm"

    invoke-static {v2, v0}, Lsg/bigo/log/TraceLog;->i(Ljava/lang/String;Ljava/lang/String;)I

    const/4 v0, 0x0

    .line 300
    iput-object v0, p0, Llive/sg/bigo/sdk/network/a/a;->t:Llive/sg/bigo/sdk/network/a/d;

    .line 5038
    invoke-static {}, Llive/sg/bigo/sdk/network/a/b$a;->a()Llive/sg/bigo/sdk/network/a/b;

    move-result-object v0

    .line 301
    iget v2, p0, Llive/sg/bigo/sdk/network/a/a;->z:I

    iget v3, p0, Llive/sg/bigo/sdk/network/a/a;->e:I

    invoke-virtual {v0, v2, v3}, Llive/sg/bigo/sdk/network/a/b;->a(II)V

    .line 302
    invoke-direct {p0}, Llive/sg/bigo/sdk/network/a/a;->q()V

    .line 303
    iput v1, p0, Llive/sg/bigo/sdk/network/a/a;->v:I

    .line 304
    invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J

    move-result-wide v0

    iput-wide v0, p0, Llive/sg/bigo/sdk/network/a/a;->m:J

    :cond_47
    return-void
.end method

.method public final c()Z
    .registers 2

    const/4 v0, 0x0

    return v0
.end method

.method public final d()Ljava/lang/String;
    .registers 2

    const-string v0, "FCMChannel"

    return-object v0
.end method