f.smali
.class public final Lsg/bigo/opensdk/rtm/internal/d/f;
.super Lsg/bigo/opensdk/rtm/internal/d/h;
.source "SourceFile"
# interfaces
.implements Lsg/bigo/opensdk/rtm/internal/d/d;
# static fields
.field public static u:Z = false
# instance fields
.field private final B:Ljava/lang/Object;
.field private C:Ljava/nio/ByteBuffer;
.field private D:Ljava/nio/channels/SocketChannel;
.field private E:Lsg/bigo/sf/SocketFilter;
.field private F:I
# direct methods
.method static constructor <clinit>()V
.registers 2
const-string v0, "openssl"
.line 38
invoke-static {v0}, Lsg/bigo/opensdk/rtm/c;->a(Ljava/lang/String;)Z
move-result v0
if-eqz v0, :cond_14
const-string v0, "filter"
invoke-static {v0}, Lsg/bigo/opensdk/rtm/c;->a(Ljava/lang/String;)Z
move-result v0
if-eqz v0, :cond_14
const/4 v0, 0x1
.line 39
sput-boolean v0, Lsg/bigo/opensdk/rtm/internal/d/f;->u:Z
goto :goto_1b
:cond_14
const-string v0, "tobsdk-net-overwallChannel"
const-string v1, "load filter fail, not support filter"
.line 41
invoke-static {v0, v1}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
.line 44
:goto_1b
sget-boolean v0, Lsg/bigo/opensdk/rtm/internal/d/f;->u:Z
if-eqz v0, :cond_28
.line 45
new-instance v0, Lsg/bigo/opensdk/rtm/internal/d/f$1;
invoke-direct {v0}, Lsg/bigo/opensdk/rtm/internal/d/f$1;-><init>()V
const/4 v1, 0x0
invoke-static {v0, v1, v1}, Lsg/bigo/sf/FilterGlobalSettings;->setLogger(Lsg/bigo/sf/Logger;ZI)V
:cond_28
return-void
.end method
.method constructor <init>(Ljava/net/InetSocketAddress;Lsg/bigo/opensdk/rtm/internal/d/c;Ljava/lang/String;Lsg/bigo/opensdk/rtm/internal/c/a/d;Lsg/bigo/opensdk/rtm/internal/f$a;I)V
.registers 33
move-object/from16 v8, p0
move/from16 v9, p6
const/4 v3, 0x0
move-object/from16 v0, p0
move-object/from16 v1, p1
move-object/from16 v2, p2
move/from16 v4, p6
move-object/from16 v5, p4
move-object/from16 v6, p3
move-object/from16 v7, p5
.line 83
invoke-direct/range {v0 .. v7}, Lsg/bigo/opensdk/rtm/internal/d/h;-><init>(Ljava/net/InetSocketAddress;Lsg/bigo/opensdk/rtm/internal/d/c;Lsg/bigo/opensdk/rtm/a/a/a;ILsg/bigo/opensdk/rtm/internal/c/a/d;Ljava/lang/String;Lsg/bigo/opensdk/rtm/internal/f$a;)V
.line 74
new-instance v0, Ljava/lang/Object;
invoke-direct {v0}, Ljava/lang/Object;-><init>()V
iput-object v0, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->B:Ljava/lang/Object;
const/4 v0, 0x0
.line 79
iput v0, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->F:I
.line 1088
invoke-static {}, Lsg/bigo/overwall/config/OverwallConfigManager;->instance()Lsg/bigo/overwall/config/OverwallConfigManager;
move-result-object v1
if-nez v1, :cond_56
.line 1090
new-instance v0, Lsg/bigo/sf/FilterParam;
move-object v9, v0
const/4 v10, 0x0
const/4 v12, 0x0
const/16 v17, 0x0
const/16 v18, 0x0
const/16 v19, 0x0
const/16 v21, 0x0
const/16 v22, 0x0
const/16 v23, 0x0
new-instance v1, Ljava/util/HashSet;
move-object/from16 v24, v1
invoke-direct {v1}, Ljava/util/HashSet;-><init>()V
new-instance v1, Ljava/util/HashSet;
move-object/from16 v25, v1
invoke-direct {v1}, Ljava/util/HashSet;-><init>()V
const-string v11, ""
const-string v13, ""
const-string v14, ""
const-string v15, ""
const-string v16, ""
const-string v20, ""
invoke-direct/range {v9 .. v25}, Lsg/bigo/sf/FilterParam;-><init>(ZLjava/lang/String;ZLjava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZZLjava/lang/String;ZIILjava/util/HashSet;Ljava/util/HashSet;)V
goto/16 :goto_131
.line 1095
:cond_56
iget-object v2, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->A:Lsg/bigo/opensdk/rtm/internal/f$a;
sget-object v3, Lsg/bigo/opensdk/rtm/internal/f$a;->TLS:Lsg/bigo/opensdk/rtm/internal/f$a;
const/4 v4, 0x1
if-ne v2, v3, :cond_5f
const/4 v10, 0x1
goto :goto_60
:cond_5f
const/4 v10, 0x0
:goto_60
const-string v2, ""
if-eqz v10, :cond_70
.line 1098
invoke-virtual {v1, v9, v4}, Lsg/bigo/overwall/config/OverwallConfigManager;->getTlsConfig(II)Lsg/bigo/overwall/config/ITlsConfig;
move-result-object v3
if-eqz v3, :cond_70
.line 1100
invoke-virtual {v3}, Lsg/bigo/overwall/config/ITlsConfig;->getCert()Ljava/lang/String;
move-result-object v3
move-object v11, v3
goto :goto_71
:cond_70
move-object v11, v2
.line 1104
:goto_71
iget-object v3, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->A:Lsg/bigo/opensdk/rtm/internal/f$a;
sget-object v5, Lsg/bigo/opensdk/rtm/internal/f$a;->HTTP:Lsg/bigo/opensdk/rtm/internal/f$a;
if-ne v3, v5, :cond_79
const/4 v12, 0x1
goto :goto_7a
:cond_79
const/4 v12, 0x0
:goto_7a
if-eqz v12, :cond_98
.line 1110
invoke-virtual {v1, v9, v4}, Lsg/bigo/overwall/config/OverwallConfigManager;->getHttpConfig(II)Lsg/bigo/overwall/config/IHttpConfig;
move-result-object v3
if-eqz v3, :cond_98
.line 1112
invoke-virtual {v3}, Lsg/bigo/overwall/config/IHttpConfig;->getRandomUserAgent()Ljava/lang/String;
move-result-object v5
.line 1113
invoke-virtual {v3}, Lsg/bigo/overwall/config/IHttpConfig;->getRandomHost()Ljava/lang/String;
move-result-object v6
.line 1114
invoke-virtual {v3}, Lsg/bigo/overwall/config/IHttpConfig;->getRandomPath()Ljava/lang/String;
move-result-object v7
.line 1115
invoke-virtual {v3}, Lsg/bigo/overwall/config/IHttpConfig;->getRandomContentType()Ljava/lang/String;
move-result-object v3
move-object/from16 v16, v3
move-object v13, v5
move-object v14, v6
move-object v15, v7
goto :goto_9d
:cond_98
move-object v13, v2
move-object v14, v13
move-object v15, v14
move-object/from16 v16, v15
.line 1119
:goto_9d
invoke-virtual {v1, v9, v0}, Lsg/bigo/overwall/config/OverwallConfigManager;->getProtoPaddingConfig(II)Lsg/bigo/overwall/config/IProtoPaddingConfig;
move-result-object v1
if-eqz v1, :cond_cf
.line 1121
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->getSwitch()I
move-result v3
if-lez v3, :cond_cf
.line 1122
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->isSupportTcp()Z
move-result v3
if-eqz v3, :cond_b5
iget-object v3, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->A:Lsg/bigo/opensdk/rtm/internal/f$a;
sget-object v5, Lsg/bigo/opensdk/rtm/internal/f$a;->NONE:Lsg/bigo/opensdk/rtm/internal/f$a;
if-eq v3, v5, :cond_cd
.line 1123
:cond_b5
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->isSupportHttp()Z
move-result v3
if-eqz v3, :cond_c1
iget-object v3, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->A:Lsg/bigo/opensdk/rtm/internal/f$a;
sget-object v5, Lsg/bigo/opensdk/rtm/internal/f$a;->HTTP:Lsg/bigo/opensdk/rtm/internal/f$a;
if-eq v3, v5, :cond_cd
.line 1124
:cond_c1
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->isSupportTls()Z
move-result v3
if-eqz v3, :cond_cf
iget-object v3, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->A:Lsg/bigo/opensdk/rtm/internal/f$a;
sget-object v5, Lsg/bigo/opensdk/rtm/internal/f$a;->TLS:Lsg/bigo/opensdk/rtm/internal/f$a;
if-ne v3, v5, :cond_cf
:cond_cd
const/4 v3, 0x1
goto :goto_d0
:cond_cf
const/4 v3, 0x0
:goto_d0
if-eqz v3, :cond_e0
.line 1130
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->getIdentity()Ljava/lang/String;
move-result-object v5
.line 1131
invoke-virtual {v5, v2}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z
move-result v2
xor-int/2addr v2, v4
move/from16 v19, v2
move-object/from16 v20, v5
goto :goto_e4
:cond_e0
move-object/from16 v20, v2
const/16 v19, 0x0
:goto_e4
if-eqz v3, :cond_f3
.line 1137
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->getMinLen()I
move-result v2
.line 1138
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->getMaxLen()I
move-result v5
move/from16 v22, v2
move/from16 v23, v5
goto :goto_f7
:cond_f3
const/16 v22, 0x0
const/16 v23, 0x0
.line 1141
:goto_f7
new-instance v2, Ljava/util/HashSet;
invoke-direct {v2}, Ljava/util/HashSet;-><init>()V
.line 1142
new-instance v5, Ljava/util/HashSet;
invoke-direct {v5}, Ljava/util/HashSet;-><init>()V
if-eqz v3, :cond_118
.line 1144
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->getTailUris()Ljava/util/ArrayList;
move-result-object v2
invoke-static {v2}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(Ljava/util/ArrayList;)Ljava/util/HashSet;
move-result-object v2
.line 1145
invoke-virtual {v1}, Lsg/bigo/overwall/config/IProtoPaddingConfig;->getHeadUris()Ljava/util/ArrayList;
move-result-object v1
invoke-static {v1}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(Ljava/util/ArrayList;)Ljava/util/HashSet;
move-result-object v1
move-object/from16 v25, v1
move-object/from16 v24, v2
goto :goto_11c
:cond_118
move-object/from16 v24, v2
move-object/from16 v25, v5
.line 1148
:goto_11c
new-instance v1, Lsg/bigo/sf/FilterParam;
const/16 v17, 0x0
const/16 v18, 0x0
if-gtz v22, :cond_12a
if-lez v23, :cond_127
goto :goto_12a
:cond_127
const/16 v21, 0x0
goto :goto_12c
:cond_12a
:goto_12a
const/16 v21, 0x1
:goto_12c
move-object v9, v1
invoke-direct/range {v9 .. v25}, Lsg/bigo/sf/FilterParam;-><init>(ZLjava/lang/String;ZLjava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZZLjava/lang/String;ZIILjava/util/HashSet;Ljava/util/HashSet;)V
move-object v0, v1
.line 84
:goto_131
invoke-static {v0}, Lsg/bigo/sf/FilterGlobalSettings;->create(Lsg/bigo/sf/FilterParam;)Lsg/bigo/sf/SocketFilter;
move-result-object v0
iput-object v0, v8, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
return-void
.end method
.method private static a(Ljava/util/ArrayList;)Ljava/util/HashSet;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/ArrayList<",
"Ljava/lang/String;",
">;)",
"Ljava/util/HashSet<",
"Ljava/lang/Integer;",
">;"
}
.end annotation
.line 157
new-instance v0, Ljava/util/HashSet;
invoke-direct {v0}, Ljava/util/HashSet;-><init>()V
.line 158
invoke-virtual {p0}, Ljava/util/ArrayList;->iterator()Ljava/util/Iterator;
move-result-object p0
:cond_9
:goto_9
invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_29
invoke-interface {p0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/lang/String;
.line 159
invoke-virtual {v1}, Ljava/lang/String;->isEmpty()Z
move-result v2
if-nez v2, :cond_9
.line 161
:try_start_1b
invoke-static {v1}, Ljava/lang/Integer;->parseInt(Ljava/lang/String;)I
move-result v1
invoke-static {v1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
invoke-virtual {v0, v1}, Ljava/util/HashSet;->add(Ljava/lang/Object;)Z
:try_end_26
.catchall {:try_start_1b .. :try_end_26} :catchall_27
goto :goto_9
:catchall_27
nop
goto :goto_9
:cond_29
return-object v0
.end method
.method private g()V
.registers 3
const/4 v0, 0x6
.line 302
iput v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->w:I
.line 303
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->c:Lsg/bigo/opensdk/rtm/internal/d/c;
if-eqz v0, :cond_12
.line 304
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v0
iput-wide v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->k:J
.line 305
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->c:Lsg/bigo/opensdk/rtm/internal/d/c;
invoke-interface {v0, p0}, Lsg/bigo/opensdk/rtm/internal/d/c;->a(Lsg/bigo/opensdk/rtm/internal/d/a;)V
:cond_12
return-void
.end method
.method private k()Z
.registers 3
.line 310
iget v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->w:I
const/4 v1, 0x6
if-eq v0, v1, :cond_7
const/4 v0, 0x1
return v0
:cond_7
const/4 v0, 0x0
return v0
.end method
.method private l()Z
.registers 3
.line 314
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->lastError()I
move-result v0
if-eqz v0, :cond_2a
.line 315
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "OW Error, errno: "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v1}, Lsg/bigo/sf/SocketFilter;->lastError()I
move-result v1
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, "tobsdk-net-overwallChannel"
invoke-static {v1, v0}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
const/16 v0, 0xe
const-string v1, ""
.line 316
invoke-virtual {p0, v0, v1}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
const/4 v0, 0x0
return v0
:cond_2a
const/4 v0, 0x1
return v0
.end method
# virtual methods
.method public final a(ILjava/lang/String;)V
.registers 3
.line 443
invoke-super {p0, p1, p2}, Lsg/bigo/opensdk/rtm/internal/d/h;->a(ILjava/lang/String;)V
const/16 p2, 0xe
if-ne p1, p2, :cond_17
.line 446
iget-object p1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {p1}, Lsg/bigo/sf/SocketFilter;->lastError()I
move-result p1
const/4 p2, 0x4
if-ne p1, p2, :cond_17
.line 448
invoke-static {}, Lsg/bigo/overwall/config/OverwallConfigManager;->instance()Lsg/bigo/overwall/config/OverwallConfigManager;
move-result-object p1
invoke-virtual {p1}, Lsg/bigo/overwall/config/OverwallConfigManager;->loadingImmediately()V
:cond_17
return-void
.end method
.method public final a()Z
.registers 8
.line 171
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "OW Connecting to: "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
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, Lsg/bigo/opensdk/rtm/internal/d/f;->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, "tobsdk-net-overwallChannel"
invoke-static {v1, v0}, Lsg/bigo/opensdk/d/d;->a(Ljava/lang/String;Ljava/lang/String;)V
.line 173
iget v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->y:I
int-to-long v2, v0
invoke-virtual {p0, v2, v3}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(J)V
.line 175
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v2
iput-wide v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->h:J
const/4 v0, 0x0
.line 177
:try_start_2c
invoke-static {}, Ljava/nio/channels/SocketChannel;->open()Ljava/nio/channels/SocketChannel;
move-result-object v2
iput-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
.line 178
invoke-virtual {v2, v0}, Ljava/nio/channels/SocketChannel;->configureBlocking(Z)Ljava/nio/channels/SelectableChannel;
.line 179
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-virtual {v2}, Ljava/nio/channels/SocketChannel;->socket()Ljava/net/Socket;
move-result-object v2
iget v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->z:I
invoke-virtual {v2, v3}, Ljava/net/Socket;->setSoTimeout(I)V
.line 180
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-virtual {v2}, Ljava/nio/channels/SocketChannel;->socket()Ljava/net/Socket;
move-result-object v2
const/4 v3, 0x1
invoke-virtual {v2, v3}, Ljava/net/Socket;->setTcpNoDelay(Z)V
.line 181
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
iget-object v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v2, v4}, Ljava/nio/channels/SocketChannel;->connect(Ljava/net/SocketAddress;)Z
.line 182
iput v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->w:I
const/4 v2, 0x0
.line 183
iput-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
.line 1254
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-static {v2}, Lsg/bigo/opensdk/rtm/internal/d/g;->a(Ljava/nio/channels/SocketChannel;)I
move-result v2
invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
.line 185
check-cast v2, Ljava/lang/Integer;
invoke-virtual {v2}, Ljava/lang/Integer;->intValue()I
move-result v2
iput v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->F:I
.line 187
invoke-static {}, Lsg/bigo/opensdk/rtm/internal/d/e;->a()Lsg/bigo/opensdk/rtm/internal/d/e;
move-result-object v2
const/16 v4, 0x8
invoke-virtual {v2, p0, v4}, Lsg/bigo/opensdk/rtm/internal/d/e;->a(Lsg/bigo/opensdk/rtm/internal/d/d;I)V
:try_end_71
.catchall {:try_start_2c .. :try_end_71} :catchall_72
return v3
:catchall_72
move-exception v2
.line 190
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v3
iget-wide v5, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->h:J
sub-long/2addr v3, v5
long-to-int v4, v3
.line 191
new-instance v3, Ljava/lang/StringBuilder;
const-string v5, "OW connect to "
invoke-direct {v3, v5}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v5, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v3, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
const-string v5, " failed, time use "
invoke-virtual {v3, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v3
invoke-static {v1, v3}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
.line 192
invoke-virtual {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->h()V
.line 193
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->t:Lsg/bigo/opensdk/rtm/internal/c/a/d;
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->x:Ljava/lang/String;
sget-byte v4, Lsg/bigo/opensdk/rtm/internal/c/a/c;->k:B
invoke-virtual {v1, v3, v4}, Lsg/bigo/opensdk/rtm/internal/c/a/d;->c(Ljava/lang/String;B)V
const/16 v1, 0xa
.line 194
invoke-virtual {v2}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;
move-result-object v2
invoke-virtual {p0, v1, v2}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
return v0
.end method
.method public final bridge synthetic a(Ljava/nio/ByteBuffer;)Z
.registers 2
.line 30
invoke-super {p0, p1}, Lsg/bigo/opensdk/rtm/internal/d/h;->a(Ljava/nio/ByteBuffer;)Z
move-result p1
return p1
.end method
.method public final aW_()Z
.registers 6
.line 202
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "OW onConnected fd="
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->F:I
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v1, " connId = "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->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, "tobsdk-net-overwallChannel"
invoke-static {v2, v0}, Lsg/bigo/opensdk/d/d;->a(Ljava/lang/String;Ljava/lang/String;)V
const/4 v0, 0x0
.line 204
:try_start_20
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-virtual {v3}, Ljava/nio/channels/SocketChannel;->isConnectionPending()Z
move-result v3
if-nez v3, :cond_40
const-string v1, "OW is not in connection pending state."
.line 205
invoke-static {v2, v1}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
.line 206
invoke-virtual {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->h()V
.line 207
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->t:Lsg/bigo/opensdk/rtm/internal/c/a/d;
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->x:Ljava/lang/String;
sget-byte v4, Lsg/bigo/opensdk/rtm/internal/c/a/c;->m:B
invoke-virtual {v1, v3, v4}, Lsg/bigo/opensdk/rtm/internal/c/a/d;->c(Ljava/lang/String;B)V
const/16 v1, 0xc
const/4 v3, 0x0
.line 208
invoke-virtual {p0, v1, v3}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
return v0
.line 212
:cond_40
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-virtual {v3}, Ljava/nio/channels/SocketChannel;->finishConnect()Z
move-result v3
if-nez v3, :cond_64
.line 213
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, "OW still connecting..."
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v3, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->e:I
invoke-virtual {v3, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
return v0
.line 216
:cond_64
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, "OW Connected to: "
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v3, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->e:I
invoke-virtual {v3, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1}, Lsg/bigo/opensdk/d/d;->a(Ljava/lang/String;Ljava/lang/String;)V
.line 217
invoke-virtual {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->h()V
.line 219
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v1}, Lsg/bigo/sf/SocketFilter;->status()I
move-result v1
if-nez v1, :cond_b3
.line 220
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
iget v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->F:I
invoke-virtual {v1, v3}, Lsg/bigo/sf/SocketFilter;->init(I)Z
move-result v1
if-nez v1, :cond_b3
.line 221
new-instance v1, Ljava/lang/StringBuilder;
const-string v3, "init Failed, errno: "
invoke-direct {v1, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v3}, Lsg/bigo/sf/SocketFilter;->lastError()I
move-result v3
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
const/16 v1, 0xd
const-string v3, "Init OW Failed"
.line 222
invoke-virtual {p0, v1, v3}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
return v0
.line 227
:cond_b3
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v1}, Lsg/bigo/sf/SocketFilter;->onConnect()V
.line 229
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v1}, Lsg/bigo/sf/SocketFilter;->lastError()I
move-result v1
if-eqz v1, :cond_df
.line 230
new-instance v1, Ljava/lang/StringBuilder;
const-string v3, "OW connect error, errno: "
invoke-direct {v1, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v3}, Lsg/bigo/sf/SocketFilter;->lastError()I
move-result v3
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
const/16 v1, 0xe
const-string v3, ""
.line 231
invoke-virtual {p0, v1, v3}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
return v0
.line 235
:cond_df
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v1}, Lsg/bigo/sf/SocketFilter;->status()I
move-result v1
const/4 v3, 0x4
if-ne v1, v3, :cond_eb
.line 236
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->g()V
.line 239
:cond_eb
invoke-static {}, Lsg/bigo/opensdk/rtm/internal/d/e;->a()Lsg/bigo/opensdk/rtm/internal/d/e;
move-result-object v1
const/4 v3, 0x5
invoke-virtual {v1, p0, v3}, Lsg/bigo/opensdk/rtm/internal/d/e;->a(Lsg/bigo/opensdk/rtm/internal/d/d;I)V
.line 240
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v3
iput-wide v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->i:J
:try_end_f9
.catchall {:try_start_20 .. :try_end_f9} :catchall_fb
const/4 v0, 0x1
return v0
:catchall_fb
move-exception v1
.line 245
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, "OW onConnected exception connId = "
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->e:I
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v4, " fd="
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->F:I
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v3
invoke-static {v2, v3, v1}, Lsg/bigo/opensdk/d/d;->b(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V
.line 246
invoke-virtual {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->h()V
.line 247
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->t:Lsg/bigo/opensdk/rtm/internal/c/a/d;
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->x:Ljava/lang/String;
sget-byte v4, Lsg/bigo/opensdk/rtm/internal/c/a/c;->p:B
invoke-virtual {v2, v3, v4}, Lsg/bigo/opensdk/rtm/internal/c/a/d;->c(Ljava/lang/String;B)V
const/16 v2, 0xa
.line 248
invoke-virtual {v1}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;
move-result-object v1
invoke-virtual {p0, v2, v1}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
return v0
.end method
.method public final aX_()V
.registers 9
.line 259
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
const-string v1, " connId = "
const-string v2, "tobsdk-net-overwallChannel"
if-nez v0, :cond_24
.line 260
new-instance v0, Ljava/lang/StringBuilder;
const-string v3, "OW trying to read null channel "
invoke-direct {v0, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v0, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->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
invoke-static {v2, v0}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
return-void
.line 264
:cond_24
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->k()Z
move-result v0
if-eqz v0, :cond_43
.line 265
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->onConnect()V
.line 267
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->l()Z
move-result v0
if-nez v0, :cond_36
return-void
.line 271
:cond_36
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->status()I
move-result v0
const/4 v1, 0x4
if-ne v0, v1, :cond_42
.line 272
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->g()V
:cond_42
return-void
.line 278
:cond_43
:try_start_43
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->read()[B
move-result-object v0
.line 279
array-length v3, v0
if-nez v3, :cond_77
.line 282
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->l()Z
move-result v0
if-nez v0, :cond_76
.line 283
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->t:Lsg/bigo/opensdk/rtm/internal/c/a/d;
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->x:Ljava/lang/String;
sget-byte v4, Lsg/bigo/opensdk/rtm/internal/c/a/c;->c:B
invoke-virtual {v0, v3, v4}, Lsg/bigo/opensdk/rtm/internal/c/a/d;->c(Ljava/lang/String;B)V
.line 284
new-instance v0, Ljava/lang/StringBuilder;
const-string v3, "OW read -1, server close conn: "
invoke-direct {v0, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v0, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->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
invoke-static {v2, v0}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
:cond_76
return-void
.line 289
:cond_77
new-instance v1, Ljava/lang/StringBuilder;
const-string v4, "receive: "
invoke-direct {v1, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v4, " Byte"
invoke-virtual {v1, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {}, Lsg/bigo/opensdk/d/d;->b()V
.line 290
invoke-static {v3}, Ljava/nio/ByteBuffer;->allocate(I)Ljava/nio/ByteBuffer;
move-result-object v1
.line 291
invoke-virtual {v1, v0}, Ljava/nio/ByteBuffer;->put([B)Ljava/nio/ByteBuffer;
.line 292
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v4
iput-wide v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->r:J
.line 293
iget-wide v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->o:J
int-to-long v6, v3
add-long/2addr v4, v6
iput-wide v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->o:J
.line 294
invoke-virtual {v1}, Ljava/nio/ByteBuffer;->flip()Ljava/nio/Buffer;
.line 295
invoke-virtual {p0, v1}, Lsg/bigo/opensdk/rtm/internal/d/f;->c(Ljava/nio/ByteBuffer;)V
:try_end_a2
.catch Ljava/lang/NullPointerException; {:try_start_43 .. :try_end_a2} :catch_a3
return-void
:catch_a3
move-exception v0
.line 297
new-instance v1, Ljava/lang/StringBuilder;
const-string v3, "OW onRead exception "
invoke-direct {v1, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1, v0}, Lsg/bigo/opensdk/d/d;->b(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V
return-void
.end method
.method public final aY_()V
.registers 3
.line 324
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
if-nez v0, :cond_24
.line 325
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "OW trying to write null channel "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
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, Lsg/bigo/opensdk/rtm/internal/d/f;->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, "tobsdk-net-overwallChannel"
invoke-static {v1, v0}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
return-void
.line 329
:cond_24
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->k()Z
move-result v0
if-eqz v0, :cond_43
.line 330
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->onConnect()V
.line 331
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->l()Z
move-result v0
if-nez v0, :cond_36
return-void
.line 335
:cond_36
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->status()I
move-result v0
const/4 v1, 0x4
if-ne v0, v1, :cond_42
.line 336
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->g()V
:cond_42
return-void
.line 342
:cond_43
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->B:Ljava/lang/Object;
monitor-enter v0
.line 343
:try_start_46
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
if-nez v1, :cond_4c
.line 344
monitor-exit v0
return-void
.line 346
:cond_4c
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
invoke-virtual {v1}, Ljava/nio/ByteBuffer;->capacity()I
move-result v1
.line 347
monitor-exit v0
:try_end_53
.catchall {:try_start_46 .. :try_end_53} :catchall_67
.line 349
invoke-static {v1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v0
const-string v1, "onWrite send buffer, len:"
invoke-virtual {v1, v0}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object v0
const-string v1, "tobsdk-net-overwallChannel"
invoke-static {v1, v0}, Lsg/bigo/opensdk/d/d;->a(Ljava/lang/String;Ljava/lang/String;)V
const/4 v0, 0x0
.line 350
invoke-virtual {p0, v0}, Lsg/bigo/opensdk/rtm/internal/d/f;->b(Ljava/nio/ByteBuffer;)I
return-void
:catchall_67
move-exception v1
.line 347
:try_start_68
monitor-exit v0
:try_end_69
.catchall {:try_start_68 .. :try_end_69} :catchall_67
throw v1
.end method
.method final b(Ljava/nio/ByteBuffer;)I
.registers 9
if-nez p1, :cond_8
.line 354
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
if-nez v0, :cond_8
const/4 p1, -0x2
return p1
:cond_8
const/4 v0, -0x1
.line 359
:try_start_9
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
if-eqz v1, :cond_125
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-virtual {v1}, Ljava/nio/channels/SocketChannel;->isConnected()Z
move-result v1
if-nez v1, :cond_17
goto/16 :goto_125
.line 365
:cond_17
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->B:Ljava/lang/Object;
monitor-enter v1
:try_end_1a
.catchall {:try_start_9 .. :try_end_1a} :catchall_145
.line 367
:try_start_1a
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
const/4 v3, 0x0
if-eqz v2, :cond_5a
const-string v2, "tobsdk-net-overwallChannel"
.line 368
new-instance v4, Ljava/lang/StringBuilder;
const-string v5, "send buffer data len: "
invoke-direct {v4, v5}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v5, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
invoke-virtual {v5}, Ljava/nio/ByteBuffer;->capacity()I
move-result v5
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v4
invoke-static {v2, v4}, Lsg/bigo/opensdk/d/d;->b(Ljava/lang/String;Ljava/lang/String;)V
if-eqz p1, :cond_55
.line 371
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
invoke-virtual {v2}, Ljava/nio/ByteBuffer;->capacity()I
move-result v2
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->capacity()I
move-result v4
add-int/2addr v2, v4
invoke-static {v2}, Ljava/nio/ByteBuffer;->allocate(I)Ljava/nio/ByteBuffer;
move-result-object v2
.line 372
iget-object v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
invoke-virtual {v2, v4}, Ljava/nio/ByteBuffer;->put(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
.line 373
invoke-virtual {v2, p1}, Ljava/nio/ByteBuffer;->put(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
.line 374
invoke-virtual {v2}, Ljava/nio/ByteBuffer;->flip()Ljava/nio/Buffer;
goto :goto_57
.line 376
:cond_55
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
.line 379
:goto_57
iput-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
goto :goto_5b
:cond_5a
move-object v2, v3
:goto_5b
const/4 v4, 0x0
if-nez v2, :cond_5f
goto :goto_66
:cond_5f
if-eqz p1, :cond_65
.line 385
iput-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
.line 386
monitor-exit v1
return v4
:cond_65
move-object p1, v2
:goto_66
if-eqz p1, :cond_119
.line 391
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->remaining()I
move-result v2
const/16 v5, 0x4000
if-le v2, v5, :cond_7c
new-array v2, v5, [B
.line 393
invoke-virtual {p1, v2, v4, v5}, Ljava/nio/ByteBuffer;->get([BII)Ljava/nio/ByteBuffer;
.line 394
iget-object v4, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v4, v2}, Lsg/bigo/sf/SocketFilter;->write([B)I
move-result v2
goto :goto_86
.line 396
:cond_7c
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->array()[B
move-result-object v4
invoke-virtual {v2, v4}, Lsg/bigo/sf/SocketFilter;->write([B)I
move-result v2
:goto_86
if-nez v2, :cond_b8
.line 399
invoke-direct {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->l()Z
move-result v4
if-nez v4, :cond_b8
.line 400
iget-object p1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->t:Lsg/bigo/opensdk/rtm/internal/c/a/d;
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->x:Ljava/lang/String;
sget-byte v3, Lsg/bigo/opensdk/rtm/internal/c/a/c;->j:B
invoke-virtual {p1, v2, v3}, Lsg/bigo/opensdk/rtm/internal/c/a/d;->c(Ljava/lang/String;B)V
const-string p1, "tobsdk-net-overwallChannel"
.line 401
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "OW write failed, server close conn: "
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
const-string v3, " connId = "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->e:I
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
invoke-static {p1, v2}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
.line 402
monitor-exit v1
return v0
.line 405
:cond_b8
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->capacity()I
move-result v4
if-eq v2, v4, :cond_117
const-string v4, "tobsdk-net-overwallChannel"
.line 406
new-instance v5, Ljava/lang/StringBuilder;
const-string v6, "send data partly: "
invoke-direct {v5, v6}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v5, v2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v6, "/"
invoke-virtual {v5, v6}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->capacity()I
move-result v6
invoke-virtual {v5, v6}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v5}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v5
invoke-static {v4, v5}, Lsg/bigo/opensdk/d/d;->b(Ljava/lang/String;Ljava/lang/String;)V
.line 408
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->capacity()I
move-result v4
sub-int/2addr v4, v2
const/high16 v5, 0x100000
if-le v4, v5, :cond_fd
const-string p1, "tobsdk-net-overwallChannel"
const-string v2, "send buffer over limit"
.line 410
invoke-static {p1, v2}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
.line 412
iget-object p1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->t:Lsg/bigo/opensdk/rtm/internal/c/a/d;
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->x:Ljava/lang/String;
sget-byte v4, Lsg/bigo/opensdk/rtm/internal/c/a/c;->i:B
invoke-virtual {p1, v2, v4}, Lsg/bigo/opensdk/rtm/internal/c/a/d;->c(Ljava/lang/String;B)V
const/16 p1, 0x8
.line 413
invoke-virtual {p0, p1, v3}, Lsg/bigo/opensdk/rtm/internal/d/f;->a(ILjava/lang/String;)V
.line 414
monitor-exit v1
return v0
.line 417
:cond_fd
invoke-static {v4}, Ljava/nio/ByteBuffer;->allocate(I)Ljava/nio/ByteBuffer;
move-result-object v3
iput-object v3, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
.line 418
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->array()[B
move-result-object p1
invoke-virtual {v3, p1, v2, v4}, Ljava/nio/ByteBuffer;->put([BII)Ljava/nio/ByteBuffer;
.line 419
iget-object p1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
invoke-virtual {p1}, Ljava/nio/ByteBuffer;->flip()Ljava/nio/Buffer;
.line 421
invoke-static {}, Lsg/bigo/opensdk/rtm/internal/d/e;->a()Lsg/bigo/opensdk/rtm/internal/d/e;
move-result-object p1
const/4 v3, 0x5
invoke-virtual {p1, p0, v3}, Lsg/bigo/opensdk/rtm/internal/d/e;->a(Lsg/bigo/opensdk/rtm/internal/d/d;I)V
.line 424
:cond_117
monitor-exit v1
return v2
:cond_119
const-string p1, "tobsdk-net-overwallChannel"
const-string v2, "OW doSend crypt failed"
.line 426
invoke-static {p1, v2}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
.line 427
monitor-exit v1
return v4
:catchall_122
move-exception p1
.line 429
monitor-exit v1
:try_end_124
.catchall {:try_start_1a .. :try_end_124} :catchall_122
:try_start_124
throw p1
:cond_125
:goto_125
const-string p1, "tobsdk-net-overwallChannel"
.line 360
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "OW trying to write null or not connected channel "
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
const-string v2, " connId = "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->e:I
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {p1, v1}, Lsg/bigo/opensdk/d/d;->c(Ljava/lang/String;Ljava/lang/String;)V
:try_end_144
.catchall {:try_start_124 .. :try_end_144} :catchall_145
return v0
:catchall_145
move-exception p1
.line 431
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "OW doSend exception, "
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
const-string v2, "tobsdk-net-overwallChannel"
invoke-static {v2, v1, p1}, Lsg/bigo/opensdk/d/d;->b(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V
return v0
.end method
.method public final b()V
.registers 4
.line 455
iget v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->w:I
const/4 v1, 0x7
if-eq v0, v1, :cond_46
.line 456
iput v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->w:I
.line 457
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "OW close channel: "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->a:Ljava/net/InetSocketAddress;
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, Lsg/bigo/opensdk/rtm/internal/d/f;->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, "tobsdk-net-overwallChannel"
invoke-static {v1, v0}, Lsg/bigo/opensdk/d/d;->a(Ljava/lang/String;Ljava/lang/String;)V
.line 458
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->E:Lsg/bigo/sf/SocketFilter;
invoke-virtual {v0}, Lsg/bigo/sf/SocketFilter;->deinit()V
.line 459
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
const/4 v1, 0x0
if-eqz v0, :cond_3b
.line 460
invoke-static {}, Lsg/bigo/opensdk/rtm/internal/d/e;->a()Lsg/bigo/opensdk/rtm/internal/d/e;
move-result-object v0
iget-object v2, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
invoke-virtual {v0, v2}, Lsg/bigo/opensdk/rtm/internal/d/e;->a(Ljava/nio/channels/SocketChannel;)V
.line 461
iput-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
.line 463
:cond_3b
invoke-virtual {p0}, Lsg/bigo/opensdk/rtm/internal/d/f;->h()V
.line 464
iput-object v1, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->C:Ljava/nio/ByteBuffer;
.line 465
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v0
iput-wide v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->m:J
:cond_46
return-void
.end method
.method public final c()Ljava/nio/channels/SelectableChannel;
.registers 2
.line 438
iget-object v0, p0, Lsg/bigo/opensdk/rtm/internal/d/f;->D:Ljava/nio/channels/SocketChannel;
return-object v0
.end method