a.smali
.class public final Lfc/a;
.super Ljava/lang/Object;
.source "CoreServer.kt"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lfc/a$a;
}
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000\u00a8\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u000b\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0008\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0010\u0002\n\u0002\u0008\u000f\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\u0008\u00c6\u0002\u0018\u00002\u00020\u0001:\u0001VB\u0007\u0008\u0002\u00a2\u0006\u0002\u0010\u0002J\u000e\u00101\u001a\u0002022\u0006\u00103\u001a\u00020\u0011J\u0006\u00104\u001a\u000202J\u0011\u00105\u001a\u00020\u0017H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u00106J\u0010\u00107\u001a\u00020*2\u0006\u00108\u001a\u00020\u0017H\u0002J\u000e\u00109\u001a\u0002022\u0006\u0010:\u001a\u00020\u0017J\u0011\u0010;\u001a\u00020\u0017H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u00106J\u0008\u0010<\u001a\u000202H\u0002J\u0012\u0010=\u001a\u0002022\u0008\u0008\u0002\u0010:\u001a\u00020\u0017H\u0002J\u0016\u0010>\u001a\u0002022\u0006\u0010?\u001a\u00020\u00042\u0006\u0010@\u001a\u00020\nJ\u0010\u0010A\u001a\u00020B2\u0006\u0010C\u001a\u00020BH\u0002J\u0008\u0010D\u001a\u00020EH\u0002J\u0010\u0010F\u001a\u0002022\u0006\u0010\u0016\u001a\u00020\u0017H\u0002J\u0008\u0010G\u001a\u000202H\u0002J\u0012\u0010H\u001a\u0002022\u0008\u0010I\u001a\u0004\u0018\u00010JH\u0002J\u000e\u0010K\u001a\u0002022\u0006\u00103\u001a\u00020\u0011J*\u0010L\u001a\u00020#2\u0006\u0010M\u001a\u00020N2\u0008\u0010O\u001a\u0004\u0018\u00010P2\u0006\u0010Q\u001a\u00020P2\u0008\u0010R\u001a\u0004\u0018\u00010SJ\u0010\u0010T\u001a\u00020U2\u0006\u0010I\u001a\u00020JH\u0002R\u001c\u0010\u0003\u001a\u0004\u0018\u00010\u0004X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u0005\u0010\u0006\"\u0004\u0008\u0007\u0010\u0008R\u001a\u0010\t\u001a\u00020\nX\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u000b\u0010\u000c\"\u0004\u0008\r\u0010\u000eR\u0014\u0010\u000f\u001a\u0008\u0012\u0004\u0012\u00020\u00110\u0010X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0011\u0010\u0012\u001a\u00020\u0013\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008\u0014\u0010\u0015R\u0011\u0010\u0016\u001a\u00020\u00178F\u00a2\u0006\u0006\u001a\u0004\u0008\u0016\u0010\u0018R\u0011\u0010\u0019\u001a\u00020\u00178F\u00a2\u0006\u0006\u001a\u0004\u0008\u0019\u0010\u0018R\u000e\u0010\u001a\u001a\u00020\u0017X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u001a\u0010\u001b\u001a\u000e\u0012\n\u0012\u0008\u0012\u0004\u0012\u00020\u00170\u001c0\u0010X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u001d\u001a\u00020\u001eX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001a\u0010\u001f\u001a\u000e\u0012\n\u0012\u0008\u0012\u0004\u0012\u00020\u00170\u001c0\u0010X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010 \u001a\u00020!X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\"\u001a\u00020#X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010$\u001a\u00020\u0017X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010%\u001a\u00020&X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0010\u0010\'\u001a\u0004\u0018\u00010(X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010)\u001a\u0004\u0018\u00010*X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u001b\u0010+\u001a\u00020,8FX\u0086\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008/\u00100\u001a\u0004\u0008-\u0010.\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u0006W"
}
d2 = {
"Lcom/shopee/app/network/CoreServer;",
"",
"()V",
"applicationContext",
"Landroid/content/Context;",
"getApplicationContext",
"()Landroid/content/Context;",
"setApplicationContext",
"(Landroid/content/Context;)V",
"config",
"Lcom/shopee/app/network/CoreServerConfigProvider;",
"getConfig",
"()Lcom/shopee/app/network/CoreServerConfigProvider;",
"setConfig",
"(Lcom/shopee/app/network/CoreServerConfigProvider;)V",
"connectionStatusListenerList",
"Ljava/util/concurrent/ConcurrentLinkedQueue;",
"Lcom/shopee/app/network/CoreServer$ConnectionStatusListener;",
"executor",
"Ljava/util/concurrent/ScheduledExecutorService;",
"getExecutor",
"()Ljava/util/concurrent/ScheduledExecutorService;",
"isConnected",
"",
"()Z",
"isConnecting",
"isInited",
"mConnectCoroutineCallbackList",
"Lkotlin/coroutines/Continuation;",
"mConnectionManager",
"Lcom/garena/oktcp/ConnectionManager;",
"mDisconnectCoroutineCallbackList",
"mPushInterceptor",
"Lcom/garena/oktcp/PushInterceptor;",
"mRequestTimeout",
"",
"mRetry",
"mRetryManager",
"Lcom/beetalklib/network/app/client/RetryPolicyManager;",
"mServerManager",
"Lcom/shopee/app/manager/ServerManager;",
"mTcpClient",
"Lcom/garena/oktcp/OkTcpClient;",
"printGson",
"Lcom/google/gson/Gson;",
"getPrintGson",
"()Lcom/google/gson/Gson;",
"printGson$delegate",
"Lkotlin/Lazy;",
"addConnectionStatusListener",
"",
"listener",
"connect",
"connectSync",
"(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"createTcpClient",
"allowLogs",
"disconnect",
"retry",
"disconnectSync",
"doConnect",
"doDisconnect",
"init",
"context",
"serverConfig",
"interceptPush",
"Lcom/garena/oktcp/internal/PushChain;",
"chain",
"newConnection",
"Lcom/garena/tcpcore/tcp/TcpConnection;",
"notifyConnectStatusForCoroutine",
"onConnected",
"onDisconnected",
"error",
"Lcom/garena/tcpcore/exception/TCPError;",
"removeConnectionStatusListener",
"sendData",
"packet",
"Lcom/beetalklib/network/tcp/TCPPacket;",
"name",
"",
"requestId",
"protoMessage",
"Lcom/squareup/wire/Message;",
"shouldRetry",
"Lcom/garena/oktcp/RetryPolicy;",
"ConnectionStatusListener",
"coreserver_release"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# static fields
.field public static final a:Ljava/util/concurrent/ScheduledExecutorService;
.field public static b:Lec/b;
.field public static final c:Ln0/a;
.field public static d:Lj2/d;
.field public static e:I
.field public static f:Landroid/content/Context;
.field public static g:Z
.field public static h:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Lkotlin/coroutines/Continuation<",
"Ljava/lang/Boolean;",
">;>;"
}
.end annotation
.end field
.field public static i:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Lkotlin/coroutines/Continuation<",
"Ljava/lang/Boolean;",
">;>;"
}
.end annotation
.end field
.field public static j:Lfc/b;
.field public static k:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Lfc/a$a;",
">;"
}
.end annotation
.end field
.field public static final l:Lkotlin/Lazy;
.field public static final m:Lj2/e;
.field public static final n:Lj2/b;
.field public static final o:Lfc/a;
# direct methods
.method public static constructor <clinit>()V
.registers 2
new-instance v0, Lfc/a;
invoke-direct {v0}, Lfc/a;-><init>()V
sput-object v0, Lfc/a;->o:Lfc/a;
invoke-static {}, Ljava/util/concurrent/Executors;->newSingleThreadScheduledExecutor()Ljava/util/concurrent/ScheduledExecutorService;
move-result-object v0
const-string v1, "Executors.newSingleThreadScheduledExecutor()"
invoke-static {v0, v1}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
sput-object v0, Lfc/a;->a:Ljava/util/concurrent/ScheduledExecutorService;
new-instance v0, Ln0/a;
new-instance v1, Lfc/h;
invoke-direct {v1}, Lfc/h;-><init>()V
invoke-direct {v0, v1}, Ln0/a;-><init>(Lo0/a;)V
sput-object v0, Lfc/a;->c:Ln0/a;
const/16 v0, 0x7530
sput v0, Lfc/a;->e:I
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
sput-object v0, Lfc/a;->h:Ljava/util/concurrent/ConcurrentLinkedQueue;
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
sput-object v0, Lfc/a;->i:Ljava/util/concurrent/ConcurrentLinkedQueue;
new-instance v0, Lfc/b;
invoke-direct {v0}, Lfc/b;-><init>()V
sput-object v0, Lfc/a;->j:Lfc/b;
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
sput-object v0, Lfc/a;->k:Ljava/util/concurrent/ConcurrentLinkedQueue;
sget-object v0, Lfc/a$h;->a:Lfc/a$h;
invoke-static {v0}, Lkotlin/LazyKt__LazyJVMKt;->lazy(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
sput-object v0, Lfc/a;->l:Lkotlin/Lazy;
sget-object v0, Lfc/a$f;->a:Lfc/a$f;
sput-object v0, Lfc/a;->m:Lj2/e;
new-instance v0, Lfc/a$e;
invoke-direct {v0}, Lfc/a$e;-><init>()V
sput-object v0, Lfc/a;->n:Lj2/b;
return-void
.end method
.method public constructor <init>()V
.registers 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
.method public static final synthetic a(Lfc/a;Lk2/e;)Lk2/e;
.registers 2
invoke-virtual {p0, p1}, Lfc/a;->a(Lk2/e;)Lk2/e;
move-result-object p0
return-object p0
.end method
.method public static final synthetic a(Lfc/a;)V
.registers 1
invoke-virtual {p0}, Lfc/a;->b()V
return-void
.end method
.method public static final synthetic a(Lfc/a;Lcom/garena/tcpcore/exception/TCPError;)V
.registers 2
invoke-virtual {p0, p1}, Lfc/a;->a(Lcom/garena/tcpcore/exception/TCPError;)V
return-void
.end method
.method public static final synthetic a(Lfc/a;Z)V
.registers 2
invoke-virtual {p0, p1}, Lfc/a;->c(Z)V
return-void
.end method
.method public static synthetic a(Lfc/a;ZILjava/lang/Object;)V
.registers 4
const/4 p3, 0x1
and-int/2addr p2, p3
if-eqz p2, :cond_5
const/4 p1, 0x1
:cond_5
invoke-virtual {p0, p1}, Lfc/a;->c(Z)V
return-void
.end method
.method public static final synthetic b(Lfc/a;Lcom/garena/tcpcore/exception/TCPError;)Lj2/g;
.registers 2
invoke-virtual {p0, p1}, Lfc/a;->b(Lcom/garena/tcpcore/exception/TCPError;)Lj2/g;
move-result-object p0
return-object p0
.end method
.method public static final synthetic b(Lfc/a;)Ln2/a;
.registers 1
invoke-virtual {p0}, Lfc/a;->h()Ln2/a;
move-result-object p0
return-object p0
.end method
.method public static final synthetic c(Lfc/a;)V
.registers 1
invoke-virtual {p0}, Lfc/a;->i()V
return-void
.end method
# virtual methods
.method public final a(Lu0/f;Ljava/lang/String;Ljava/lang/String;Lcom/squareup/wire/Message;)I
.registers 8
sget-boolean v0, Lfc/a;->g:Z
const/4 v1, 0x0
if-nez v0, :cond_f
sget-object p1, Lsc/a;->d:Lsc/a;
new-array p2, v1, [Ljava/lang/Object;
const-string p3, "CoreServer is not inited"
invoke-virtual {p1, p3, p2}, Lsc/a;->b(Ljava/lang/String;[Ljava/lang/Object;)V
return v1
:cond_f
new-instance v0, Lj2/i$b;
invoke-direct {v0}, Lj2/i$b;-><init>()V
new-instance v2, Lpc/a;
invoke-direct {v2, p3, p4, p1}, Lpc/a;-><init>(Ljava/lang/String;Lcom/squareup/wire/Message;Lu0/f;)V
invoke-virtual {v0, v2}, Lj2/i$b;->a(Ll2/e;)Lj2/i$b;
invoke-virtual {v0, p2}, Lj2/i$b;->a(Ljava/lang/String;)Lj2/i$b;
sget p1, Lfc/a;->e:I
invoke-virtual {v0, p1}, Lj2/i$b;->a(I)Lj2/i$b;
invoke-virtual {v0}, Lj2/i$b;->a()Lj2/i;
move-result-object p1
sget-object p2, Lsc/a;->d:Lsc/a;
new-instance p3, Ljava/lang/StringBuilder;
invoke-direct {p3}, Ljava/lang/StringBuilder;-><init>()V
const-string p4, "sendData Request(RequestId=requestId), packet : "
invoke-virtual {p3, p4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Lj2/i;->b()Ll2/e;
move-result-object p4
if-eqz p4, :cond_6a
check-cast p4, Lpc/a;
invoke-virtual {p4}, Lpc/a;->d()Ljava/lang/String;
move-result-object p4
invoke-virtual {p3, p4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p3
new-array p4, v1, [Ljava/lang/Object;
invoke-virtual {p2, p3, p4}, Lsc/a;->d(Ljava/lang/String;[Ljava/lang/Object;)V
sget-object p2, Lsc/a;->d:Lsc/a;
const-string p3, "request"
invoke-static {p1, p3}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-virtual {p2, p1}, Lsc/a;->a(Lj2/i;)V
sget-object p2, Lfc/a;->d:Lj2/d;
if-eqz p2, :cond_68
invoke-virtual {p2, p1}, Lj2/d;->a(Lj2/i;)Lj2/h;
move-result-object p1
if-eqz p1, :cond_68
new-instance p2, Lfc/a$i;
invoke-direct {p2}, Lfc/a$i;-><init>()V
invoke-interface {p1, p2}, Lj2/h;->a(Lj2/f;)V
:cond_68
const/4 p1, 0x1
return p1
:cond_6a
new-instance p1, Lkotlin/TypeCastException;
const-string p2, "null cannot be cast to non-null type com.shopee.app.network.tcp.ClientPacket"
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public final a(Z)Lj2/d;
.registers 5
new-instance v0, Lj2/d$b;
invoke-direct {v0}, Lj2/d$b;-><init>()V
sget-object v1, Lfc/a;->n:Lj2/b;
invoke-virtual {v0, v1}, Lj2/d$b;->a(Lj2/b;)Lj2/d$b;
new-instance v1, Lpc/b;
invoke-direct {v1}, Lpc/b;-><init>()V
invoke-virtual {v0, v1}, Lj2/d$b;->a(Ll2/f;)Lj2/d$b;
sget-object v1, Lfc/a;->m:Lj2/e;
invoke-virtual {v0, v1}, Lj2/d$b;->a(Lj2/e;)Lj2/d$b;
if-eqz p1, :cond_42
new-instance p1, Lpc/c;
invoke-virtual {p0}, Lfc/a;->f()Lcom/google/gson/Gson;
move-result-object v1
invoke-direct {p1, v1}, Lpc/c;-><init>(Lcom/google/gson/Gson;)V
invoke-virtual {v0, p1}, Lj2/d$b;->a(Lj2/c;)Lj2/d$b;
const-class p1, Lcom/shopee/android/debugonly/service/IBaseDebugOnlyService;
invoke-static {p1}, Ltb/b;->b(Ljava/lang/Class;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Lcom/shopee/android/debugonly/service/IBaseDebugOnlyService;
if-eqz p1, :cond_42
new-instance v1, Lfc/a$c;
invoke-direct {v1}, Lfc/a$c;-><init>()V
invoke-interface {p1, v1}, Lcom/shopee/android/debugonly/service/IBaseDebugOnlyService;->getShopeeStethoInterceptor(Ln9/a;)Lj2/c;
move-result-object v2
invoke-virtual {v0, v2}, Lj2/d$b;->a(Lj2/c;)Lj2/d$b;
invoke-interface {p1, v1}, Lcom/shopee/android/debugonly/service/IBaseDebugOnlyService;->getShopeeStethoPushInterceptor(Ln9/a;)Lj2/e;
move-result-object p1
invoke-virtual {v0, p1}, Lj2/d$b;->a(Lj2/e;)Lj2/d$b;
:cond_42
sget-object p1, Lfc/a;->j:Lfc/b;
invoke-virtual {p1}, Lfc/b;->g()Ljava/util/List;
move-result-object p1
if-eqz p1, :cond_5e
invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object p1
:goto_4e
invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_5e
invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lj2/c;
invoke-virtual {v0, v1}, Lj2/d$b;->a(Lj2/c;)Lj2/d$b;
goto :goto_4e
:cond_5e
sget-object p1, Lfc/a;->j:Lfc/b;
invoke-virtual {p1}, Lfc/b;->k()Ljava/util/List;
move-result-object p1
if-eqz p1, :cond_7a
invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object p1
:goto_6a
invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_7a
invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lj2/e;
invoke-virtual {v0, v1}, Lj2/d$b;->a(Lj2/e;)Lj2/d$b;
goto :goto_6a
:cond_7a
invoke-virtual {v0}, Lj2/d$b;->a()Lj2/d;
move-result-object p1
const-string v0, "builder.build()"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
return-object p1
.end method
.method public final a(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkotlin/coroutines/Continuation<",
"-",
"Ljava/lang/Boolean;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
new-instance v0, Lkotlin/coroutines/SafeContinuation;
invoke-static {p1}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsJvmKt;->intercepted(Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation;
move-result-object v1
invoke-direct {v0, v1}, Lkotlin/coroutines/SafeContinuation;-><init>(Lkotlin/coroutines/Continuation;)V
sget-object v1, Lsc/a;->d:Lsc/a;
const/4 v2, 0x0
new-array v3, v2, [Ljava/lang/Object;
const-string v4, "connectSync"
invoke-virtual {v1, v4, v3}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
sget-boolean v1, Lfc/a;->g:Z
if-nez v1, :cond_24
invoke-static {v2}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object v1
sget-object v2, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v1}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
:cond_24
sget-object v1, Lfc/a;->o:Lfc/a;
invoke-virtual {v1}, Lfc/a;->g()Z
move-result v1
const/4 v2, 0x1
if-eqz v1, :cond_3b
invoke-static {v2}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object v1
sget-object v2, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v1}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
goto :goto_61
:cond_3b
sget-object v1, Lfc/a;->o:Lfc/a;
monitor-enter v1
:try_start_3e
sget-object v3, Lfc/a;->o:Lfc/a;
invoke-virtual {v3}, Lfc/a;->g()Z
move-result v3
if-eqz v3, :cond_54
invoke-static {v2}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object v2
sget-object v3, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v2}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v2
invoke-interface {v0, v2}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
goto :goto_5e
:cond_54
sget-object v2, Lfc/a;->h:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v2, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
sget-object v2, Lfc/a;->o:Lfc/a;
invoke-virtual {v2}, Lfc/a;->b()V
:goto_5e
sget-object v2, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_60
.catchall {:try_start_3e .. :try_end_60} :catchall_6f
monitor-exit v1
:goto_61
invoke-virtual {v0}, Lkotlin/coroutines/SafeContinuation;->getOrThrow()Ljava/lang/Object;
move-result-object v0
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
if-ne v0, v1, :cond_6e
invoke-static {p1}, Lkotlin/coroutines/jvm/internal/DebugProbesKt;->probeCoroutineSuspended(Lkotlin/coroutines/Continuation;)V
:cond_6e
return-object v0
:catchall_6f
move-exception p1
monitor-exit v1
throw p1
.end method
.method public final a(Lk2/e;)Lk2/e;
.registers 7
invoke-virtual {p1}, Lk2/e;->a()Lj2/j;
move-result-object v0
invoke-virtual {v0}, Lj2/j;->b()Ll2/e;
move-result-object v0
if-eqz v0, :cond_82
check-cast v0, Lpc/a;
invoke-virtual {v0}, Lpc/a;->e()Lu0/f;
move-result-object v1
invoke-virtual {v1}, Lu0/f;->b()[B
move-result-object v2
if-eqz v2, :cond_17
goto :goto_1a
:cond_17
const/4 v2, 0x0
new-array v2, v2, [B
:goto_1a
sget-object v3, Lfc/d;->f:Lfc/d;
invoke-virtual {v1}, Lu0/f;->a()I
move-result v4
invoke-virtual {v3, v4}, Lfc/d;->b(I)Lgc/a;
move-result-object v3
if-nez v3, :cond_6c
invoke-static {}, Lp0/c;->a()Lp0/c;
move-result-object p1
invoke-virtual {v1}, Lu0/f;->a()I
move-result v0
array-length v3, v2
invoke-virtual {p1, v0, v2, v3}, Lp0/c;->a(I[BI)V
sget-object p1, Lfc/f;->b:Lfc/f;
invoke-virtual {p1}, Lfc/f;->a()[Ljava/lang/Integer;
move-result-object p1
invoke-virtual {v1}, Lu0/f;->a()I
move-result v0
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
invoke-static {p1, v0}, Lkotlin/collections/ArraysKt___ArraysKt;->contains([Ljava/lang/Object;Ljava/lang/Object;)Z
move-result p1
if-nez p1, :cond_65
sget-object p1, Lfc/e;->b:Lfc/e;
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v2, "CoreServer commandId "
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Lu0/f;->a()I
move-result v1
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v1, " processor is null"
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 v0
invoke-virtual {p1, v0}, Lfc/e;->a(Ljava/lang/String;)V
:cond_65
new-instance p1, Lk2/e;
const/4 v0, 0x0
invoke-direct {p1, v0}, Lk2/e;-><init>(Lj2/j;)V
return-object p1
:cond_6c
instance-of v3, v3, Llc/a;
if-eqz v3, :cond_81
invoke-static {}, Lp0/c;->a()Lp0/c;
move-result-object v3
invoke-virtual {v1}, Lu0/f;->a()I
move-result v1
array-length v4, v2
invoke-virtual {v3, v1, v2, v4}, Lp0/c;->a(I[BI)V
sget-object v1, Lsc/a;->d:Lsc/a;
invoke-virtual {v1, v0}, Lsc/a;->c(Lpc/a;)V
:cond_81
return-object p1
:cond_82
new-instance p1, Lkotlin/TypeCastException;
const-string v0, "null cannot be cast to non-null type com.shopee.app.network.tcp.ClientPacket"
invoke-direct {p1, v0}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public final a()V
.registers 3
sget-boolean v0, Lfc/a;->g:Z
if-nez v0, :cond_5
return-void
:cond_5
sget-object v0, Lfc/a;->a:Ljava/util/concurrent/ScheduledExecutorService;
sget-object v1, Lfc/a$b;->a:Lfc/a$b;
invoke-interface {v0, v1}, Ljava/util/concurrent/ScheduledExecutorService;->execute(Ljava/lang/Runnable;)V
return-void
.end method
.method public final a(Landroid/content/Context;Lfc/b;)V
.registers 6
sput-object p1, Lfc/a;->f:Landroid/content/Context;
sput-object p2, Lfc/a;->j:Lfc/b;
sget-object p1, Lsc/a;->d:Lsc/a;
sget-object v0, Lfc/a;->j:Lfc/b;
invoke-virtual {v0}, Lfc/b;->h()Z
move-result v0
invoke-virtual {p1, v0}, Lsc/a;->a(Z)V
sget-object p1, Lfc/a;->j:Lfc/b;
invoke-virtual {p1}, Lfc/b;->e()I
move-result p1
sput p1, Lfc/a;->e:I
sget-object p1, Ltc/a;->c:Ltc/a;
sget-object v0, Lfc/a;->j:Lfc/b;
invoke-virtual {v0}, Lfc/b;->f()J
move-result-wide v0
invoke-virtual {p1, v0, v1}, Ltc/a;->a(J)V
new-instance p1, Lec/b;
sget-object v0, Lfc/a;->j:Lfc/b;
invoke-virtual {v0}, Lfc/b;->c()Ljava/lang/String;
move-result-object v0
sget-object v1, Lfc/a;->j:Lfc/b;
invoke-virtual {v1}, Lfc/b;->d()Ljava/lang/String;
move-result-object v1
sget-object v2, Lfc/a;->j:Lfc/b;
invoke-virtual {v2}, Lfc/b;->b()Ljava/util/List;
move-result-object v2
invoke-direct {p1, v0, v1, v2}, Lec/b;-><init>(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
sput-object p1, Lfc/a;->b:Lec/b;
sget-object p1, Lfc/a;->j:Lfc/b;
invoke-virtual {p1}, Lfc/b;->j()Z
move-result p1
invoke-virtual {p0, p1}, Lfc/a;->a(Z)Lj2/d;
move-result-object p1
sput-object p1, Lfc/a;->d:Lj2/d;
sget-object p1, Lfc/c;->d:Lfc/c;
invoke-virtual {p1, p2}, Lfc/c;->a(Lfc/b;)V
const/4 p1, 0x1
sput-boolean p1, Lfc/a;->g:Z
return-void
.end method
.method public final declared-synchronized a(Lcom/garena/tcpcore/exception/TCPError;)V
.registers 5
monitor-enter p0
:try_start_1
sget-object p1, Lsc/a;->d:Lsc/a;
const-string v0, "onDisconnected"
const/4 v1, 0x0
new-array v2, v1, [Ljava/lang/Object;
invoke-virtual {p1, v0, v2}, Lsc/a;->d(Ljava/lang/String;[Ljava/lang/Object;)V
sget-object p1, Lfc/a;->c:Ln0/a;
invoke-virtual {p1}, Ln0/a;->e()V
invoke-virtual {p0, v1}, Lfc/a;->d(Z)V
invoke-static {}, Lp0/c;->a()Lp0/c;
move-result-object p1
const/16 v0, 0xec
new-array v2, v1, [B
invoke-virtual {p1, v0, v2, v1}, Lp0/c;->a(I[BI)V
sget-object p1, Lfc/a;->k:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object p1
:goto_24
invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_34
invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lfc/a$a;
invoke-interface {v0}, Lfc/a$a;->onDisconnected()V
goto :goto_24
:cond_34
sget-object p1, Ltc/a;->c:Ltc/a;
invoke-virtual {p1}, Ltc/a;->e()V
:try_end_39
.catchall {:try_start_1 .. :try_end_39} :catchall_3b
monitor-exit p0
return-void
:catchall_3b
move-exception p1
monitor-exit p0
goto :goto_3f
:goto_3e
throw p1
:goto_3f
goto :goto_3e
.end method
.method public final a(Lfc/a$a;)V
.registers 3
sget-object v0, Lfc/a;->k:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->contains(Ljava/lang/Object;)Z
move-result v0
if-eqz v0, :cond_9
return-void
:cond_9
sget-object v0, Lfc/a;->k:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
return-void
.end method
.method public final b(Lcom/garena/tcpcore/exception/TCPError;)Lj2/g;
.registers 6
sget-object v0, Lfc/a;->c:Ln0/a;
invoke-virtual {v0}, Ln0/a;->b()Z
move-result v0
const/4 v1, 0x0
if-eqz v0, :cond_57
sget-object v0, Lcom/garena/tcpcore/exception/TCPError;->UNKNOWN_HOST:Lcom/garena/tcpcore/exception/TCPError;
if-eq p1, v0, :cond_15
sget-object p1, Lfc/a;->c:Ln0/a;
invoke-virtual {p1}, Ln0/a;->c()Z
move-result p1
if-eqz p1, :cond_2a
:cond_15
sget-object p1, Lsc/a;->d:Lsc/a;
new-array v0, v1, [Ljava/lang/Object;
const-string v2, "Switch Server"
invoke-virtual {p1, v2, v0}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
sget-object p1, Lfc/a;->b:Lec/b;
if-eqz p1, :cond_25
invoke-virtual {p1}, Lec/b;->a()V
:cond_25
sget-object p1, Lfc/a;->c:Ln0/a;
invoke-virtual {p1}, Ln0/a;->f()Z
:cond_2a
sget-object p1, Lfc/a;->c:Ln0/a;
invoke-virtual {p1}, Ln0/a;->a()I
move-result p1
sget-object v0, Lsc/a;->d:Lsc/a;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
const-string v3, "Delay Retry | In: "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v3, "ms"
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
new-array v1, v1, [Ljava/lang/Object;
invoke-virtual {v0, v2, v1}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
invoke-static {p1}, Lj2/g;->a(I)Lj2/g;
move-result-object p1
const-string v0, "RetryPolicy.retryIn(delay)"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
goto :goto_67
:cond_57
sget-object p1, Lsc/a;->d:Lsc/a;
new-array v0, v1, [Ljava/lang/Object;
const-string v1, "Closed Forever"
invoke-virtual {p1, v1, v0}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
sget-object p1, Lj2/g;->c:Lj2/g;
const-string v0, "RetryPolicy.NO_RETRY"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
:goto_67
return-object p1
.end method
.method public final b(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkotlin/coroutines/Continuation<",
"-",
"Ljava/lang/Boolean;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
new-instance v0, Lkotlin/coroutines/SafeContinuation;
invoke-static {p1}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsJvmKt;->intercepted(Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation;
move-result-object v1
invoke-direct {v0, v1}, Lkotlin/coroutines/SafeContinuation;-><init>(Lkotlin/coroutines/Continuation;)V
sget-object v1, Lsc/a;->d:Lsc/a;
const/4 v2, 0x0
new-array v3, v2, [Ljava/lang/Object;
const-string v4, "disconnectSync"
invoke-virtual {v1, v4, v3}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
sget-boolean v1, Lfc/a;->g:Z
const/4 v3, 0x1
if-nez v1, :cond_25
invoke-static {v3}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object v1
sget-object v4, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v1}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
:cond_25
sget-object v1, Lfc/a;->o:Lfc/a;
invoke-virtual {v1}, Lfc/a;->g()Z
move-result v1
if-nez v1, :cond_3b
invoke-static {v3}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object v1
sget-object v2, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v1}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
goto :goto_62
:cond_3b
sget-object v1, Lfc/a;->o:Lfc/a;
monitor-enter v1
:try_start_3e
sget-object v4, Lfc/a;->o:Lfc/a;
invoke-virtual {v4}, Lfc/a;->g()Z
move-result v4
if-nez v4, :cond_54
invoke-static {v3}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object v2
sget-object v3, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v2}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v2
invoke-interface {v0, v2}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
goto :goto_5f
:cond_54
sget-object v4, Lfc/a;->i:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v4, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
sget-object v4, Lfc/a;->o:Lfc/a;
const/4 v5, 0x0
invoke-static {v4, v2, v3, v5}, Lfc/a;->a(Lfc/a;ZILjava/lang/Object;)V
:goto_5f
sget-object v2, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_61
.catchall {:try_start_3e .. :try_end_61} :catchall_70
monitor-exit v1
:goto_62
invoke-virtual {v0}, Lkotlin/coroutines/SafeContinuation;->getOrThrow()Ljava/lang/Object;
move-result-object v0
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
if-ne v0, v1, :cond_6f
invoke-static {p1}, Lkotlin/coroutines/jvm/internal/DebugProbesKt;->probeCoroutineSuspended(Lkotlin/coroutines/Continuation;)V
:cond_6f
return-object v0
:catchall_70
move-exception p1
monitor-exit v1
throw p1
.end method
.method public final declared-synchronized b()V
.registers 4
monitor-enter p0
:try_start_1
sget-object v0, Lfc/a;->c:Ln0/a;
const/4 v1, 0x1
invoke-virtual {v0, v1}, Ln0/a;->a(Z)V
sget-object v0, Lfc/a;->d:Lj2/d;
if-eqz v0, :cond_e
invoke-virtual {v0}, Lj2/d;->a()V
:cond_e
sget-object v0, Lsc/a;->d:Lsc/a;
const-string v1, "Do Connect"
const/4 v2, 0x0
new-array v2, v2, [Ljava/lang/Object;
invoke-virtual {v0, v1, v2}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
:try_end_18
.catchall {:try_start_1 .. :try_end_18} :catchall_1a
monitor-exit p0
return-void
:catchall_1a
move-exception v0
monitor-exit p0
throw v0
.end method
.method public final b(Z)V
.registers 4
sget-boolean v0, Lfc/a;->g:Z
if-nez v0, :cond_5
return-void
:cond_5
sget-object v0, Lfc/a;->a:Ljava/util/concurrent/ScheduledExecutorService;
new-instance v1, Lfc/a$d;
invoke-direct {v1, p1}, Lfc/a$d;-><init>(Z)V
invoke-interface {v0, v1}, Ljava/util/concurrent/ScheduledExecutorService;->execute(Ljava/lang/Runnable;)V
return-void
.end method
.method public final c()Landroid/content/Context;
.registers 2
sget-object v0, Lfc/a;->f:Landroid/content/Context;
return-object v0
.end method
.method public final declared-synchronized c(Z)V
.registers 5
monitor-enter p0
:try_start_1
sget-boolean v0, Lfc/a;->g:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_35
if-nez v0, :cond_7
monitor-exit p0
return-void
:cond_7
:try_start_7
sget-object v0, Lfc/a;->c:Ln0/a;
invoke-virtual {v0, p1}, Ln0/a;->a(Z)V
sget-object v0, Lfc/a;->d:Lj2/d;
if-eqz v0, :cond_13
invoke-virtual {v0}, Lj2/d;->b()V
:cond_13
sget-object v0, Lsc/a;->d:Lsc/a;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
const-string v2, "Do Disconnect | Retry: "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
if-eqz p1, :cond_24
const-string p1, "YES"
goto :goto_26
:cond_24
const-string p1, "NO"
:goto_26
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
const/4 v1, 0x0
new-array v1, v1, [Ljava/lang/Object;
invoke-virtual {v0, p1, v1}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
:try_end_33
.catchall {:try_start_7 .. :try_end_33} :catchall_35
monitor-exit p0
return-void
:catchall_35
move-exception p1
monitor-exit p0
throw p1
.end method
.method public final d()Lfc/b;
.registers 2
sget-object v0, Lfc/a;->j:Lfc/b;
return-object v0
.end method
.method public final declared-synchronized d(Z)V
.registers 6
monitor-enter p0
:try_start_1
sget-object v0, Lfc/a;->h:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_7
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_26
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lkotlin/coroutines/Continuation;
const-string v2, "it"
invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-static {p1}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v2
sget-object v3, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v2}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v2
invoke-interface {v1, v2}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
goto :goto_7
:cond_26
sget-object v0, Lfc/a;->h:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->clear()V
sget-object v0, Lfc/a;->i:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_31
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_55
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lkotlin/coroutines/Continuation;
const-string v2, "it"
invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
if-nez p1, :cond_46
const/4 v2, 0x1
goto :goto_47
:cond_46
const/4 v2, 0x0
:goto_47
invoke-static {v2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v2
sget-object v3, Lkotlin/Result;->Companion:Lkotlin/Result$Companion;
invoke-static {v2}, Lkotlin/Result;->constructor-impl(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v2
invoke-interface {v1, v2}, Lkotlin/coroutines/Continuation;->resumeWith(Ljava/lang/Object;)V
goto :goto_31
:cond_55
sget-object p1, Lfc/a;->i:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->clear()V
:try_end_5a
.catchall {:try_start_1 .. :try_end_5a} :catchall_5c
monitor-exit p0
return-void
:catchall_5c
move-exception p1
monitor-exit p0
goto :goto_60
:goto_5f
throw p1
:goto_60
goto :goto_5f
.end method
.method public final e()Ljava/util/concurrent/ScheduledExecutorService;
.registers 2
sget-object v0, Lfc/a;->a:Ljava/util/concurrent/ScheduledExecutorService;
return-object v0
.end method
.method public final f()Lcom/google/gson/Gson;
.registers 2
sget-object v0, Lfc/a;->l:Lkotlin/Lazy;
invoke-interface {v0}, Lkotlin/Lazy;->getValue()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcom/google/gson/Gson;
return-object v0
.end method
.method public final g()Z
.registers 2
sget-object v0, Lfc/a;->d:Lj2/d;
if-eqz v0, :cond_9
invoke-virtual {v0}, Lj2/d;->c()Z
move-result v0
goto :goto_a
:cond_9
const/4 v0, 0x0
:goto_a
return v0
.end method
.method public final h()Ln2/a;
.registers 10
sget-object v0, Lfc/a;->b:Lec/b;
if-eqz v0, :cond_b
invoke-virtual {v0}, Lec/b;->b()Ljava/lang/String;
move-result-object v0
if-eqz v0, :cond_b
goto :goto_11
:cond_b
sget-object v0, Lfc/a;->j:Lfc/b;
invoke-virtual {v0}, Lfc/b;->c()Ljava/lang/String;
move-result-object v0
:goto_11
sget-object v1, Lsc/a;->d:Lsc/a;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
const-string v3, "newConnection "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
const/4 v3, 0x0
new-array v4, v3, [Ljava/lang/Object;
invoke-virtual {v1, v2, v4}, Lsc/a;->a(Ljava/lang/String;[Ljava/lang/Object;)V
new-instance v1, Lkotlin/text/Regex;
const-string v2, ":"
invoke-direct {v1, v2}, Lkotlin/text/Regex;-><init>(Ljava/lang/String;)V
invoke-virtual {v1, v0, v3}, Lkotlin/text/Regex;->split(Ljava/lang/CharSequence;I)Ljava/util/List;
move-result-object v1
new-array v2, v3, [Ljava/lang/String;
invoke-interface {v1, v2}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;
move-result-object v1
if-eqz v1, :cond_c1
check-cast v1, [Ljava/lang/String;
const/16 v2, 0x4fdb
array-length v4, v1
const/4 v5, 0x1
if-eq v4, v5, :cond_90
const/4 v6, 0x2
if-eq v4, v6, :cond_63
sget-object v1, Lsc/a;->d:Lsc/a;
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4}, Ljava/lang/StringBuilder;-><init>()V
const-string v5, "invalid url and portno "
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
new-array v3, v3, [Ljava/lang/Object;
invoke-virtual {v1, v0, v3}, Lsc/a;->b(Ljava/lang/String;[Ljava/lang/Object;)V
const-string v0, ""
goto :goto_9b
:cond_63
aget-object v0, v1, v3
:try_start_65
aget-object v4, v1, v5
invoke-static {v4}, Ljava/lang/Integer;->parseInt(Ljava/lang/String;)I
move-result v2
:try_end_6b
.catch Ljava/lang/Exception; {:try_start_65 .. :try_end_6b} :catch_6c
goto :goto_9b
:catch_6c
move-exception v4
sget-object v6, Lsc/a;->d:Lsc/a;
new-instance v7, Ljava/lang/StringBuilder;
invoke-direct {v7}, Ljava/lang/StringBuilder;-><init>()V
const-string v8, "invalid port number "
invoke-virtual {v7, v8}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
aget-object v1, v1, v5
invoke-virtual {v7, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const/16 v1, 0x3a
invoke-virtual {v7, v1}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
invoke-virtual {v7, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v7}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
new-array v3, v3, [Ljava/lang/Object;
invoke-virtual {v6, v1, v3}, Lsc/a;->e(Ljava/lang/String;[Ljava/lang/Object;)V
goto :goto_9b
:cond_90
sget-object v0, Lsc/a;->d:Lsc/a;
new-array v4, v3, [Ljava/lang/Object;
const-string v5, "only have url, use default port"
invoke-virtual {v0, v5, v4}, Lsc/a;->e(Ljava/lang/String;[Ljava/lang/Object;)V
aget-object v0, v1, v3
:goto_9b
sget-object v1, Lfc/a;->j:Lfc/b;
invoke-virtual {v1}, Lfc/b;->i()Z
move-result v1
if-eqz v1, :cond_b9
:try_start_a3
invoke-static {}, Ljavax/net/ssl/SSLSocketFactory;->getDefault()Ljavax/net/SocketFactory;
move-result-object v1
new-instance v3, Ln2/a;
const-string v4, "FOODY_CORE_SERVER_SSL"
invoke-virtual {v1, v0, v2}, Ljavax/net/SocketFactory;->createSocket(Ljava/lang/String;I)Ljava/net/Socket;
move-result-object v1
invoke-direct {v3, v4, v0, v2, v1}, Ln2/a;-><init>(Ljava/lang/String;Ljava/lang/String;ILjava/net/Socket;)V
:try_end_b2
.catch Ljava/lang/Exception; {:try_start_a3 .. :try_end_b2} :catch_b3
return-object v3
:catch_b3
move-exception v1
sget-object v3, Lsc/a;->d:Lsc/a;
invoke-virtual {v3, v1}, Lsc/a;->a(Ljava/lang/Throwable;)V
:cond_b9
new-instance v1, Ln2/a;
const-string v3, "FOODY_CORE_SERVER"
invoke-direct {v1, v3, v0, v2}, Ln2/a;-><init>(Ljava/lang/String;Ljava/lang/String;I)V
return-object v1
:cond_c1
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
.end method
.method public final declared-synchronized i()V
.registers 8
monitor-enter p0
:try_start_1
sget-object v0, Lsc/a;->d:Lsc/a;
const-string v1, "onConnected"
const/4 v2, 0x0
new-array v3, v2, [Ljava/lang/Object;
invoke-virtual {v0, v1, v3}, Lsc/a;->d(Ljava/lang/String;[Ljava/lang/Object;)V
sget-object v0, Lfc/a;->c:Ln0/a;
invoke-virtual {v0}, Ln0/a;->d()V
const/4 v0, 0x1
invoke-virtual {p0, v0}, Lfc/a;->d(Z)V
invoke-static {}, Lp0/c;->a()Lp0/c;
move-result-object v0
const/16 v1, 0xeb
new-array v3, v2, [B
invoke-virtual {v0, v1, v3, v2}, Lp0/c;->a(I[BI)V
sget-object v0, Lfc/a;->k:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_25
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_35
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lfc/a$a;
invoke-interface {v1}, Lfc/a$a;->onConnected()V
goto :goto_25
:cond_35
sget-object v0, Ltc/a;->c:Ltc/a;
invoke-virtual {v0}, Ltc/a;->b()V
sget-object v0, Ltc/a;->c:Ltc/a;
invoke-virtual {v0}, Ltc/a;->d()V
sget-object v1, Lkotlinx/coroutines/GlobalScope;->INSTANCE:Lkotlinx/coroutines/GlobalScope;
invoke-static {}, Lmd/e;->c()Lkotlinx/coroutines/android/HandlerDispatcher;
move-result-object v2
const/4 v3, 0x0
new-instance v4, Lfc/a$g;
const/4 v0, 0x0
invoke-direct {v4, v0}, Lfc/a$g;-><init>(Lkotlin/coroutines/Continuation;)V
const/4 v5, 0x2
const/4 v6, 0x0
invoke-static/range {v1 .. v6}, Lkotlinx/coroutines/BuildersKt;->launch$default(Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coroutines/CoroutineStart;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lkotlinx/coroutines/Job;
:try_end_51
.catchall {:try_start_1 .. :try_end_51} :catchall_53
monitor-exit p0
return-void
:catchall_53
move-exception v0
monitor-exit p0
goto :goto_57
:goto_56
throw v0
:goto_57
goto :goto_56
.end method