c.smali
.class public final Lxd/c;
.super Ljava/lang/Object;
.source "OkHttpRequestAdapter.kt"
# interfaces
.implements Lae/b;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lxd/c$a;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/lang/Object;",
"Lae/b<",
"Lxd/b;",
"Lokhttp3/Response;",
">;"
}
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000L\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0006\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\u0002\n\u0002\u0008\u0005\u0018\u0000 #2\u000e\u0012\u0004\u0012\u00020\u0002\u0012\u0004\u0012\u00020\u00030\u0001:\u0001#B\u0005\u00a2\u0006\u0002\u0010\u0004J\u0010\u0010\r\u001a\u00020\u000e2\u0006\u0010\u000f\u001a\u00020\u0010H\u0002J\u0010\u0010\u0011\u001a\u00020\u00102\u0006\u0010\u0012\u001a\u00020\u0002H\u0016J\u0010\u0010\u0013\u001a\u00020\u00022\u0006\u0010\u000f\u001a\u00020\u0010H\u0016J\u0019\u0010\u0014\u001a\u00020\u00032\u0006\u0010\u000f\u001a\u00020\u0010H\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0015J\u0008\u0010\u0016\u001a\u00020\u0017H\u0016J\u000e\u0010\u0018\u001a\u0008\u0012\u0004\u0012\u00020\u00020\u0019H\u0016J\u0010\u0010\u001a\u001a\u00020\u00172\u0006\u0010\u001b\u001a\u00020\u0002H\u0016J\u0010\u0010\u001c\u001a\u00020\u001d2\u0006\u0010\u001b\u001a\u00020\u0002H\u0016J\u0010\u0010\u001e\u001a\u00020\u001f2\u0006\u0010\u001b\u001a\u00020\u0002H\u0016J\u0019\u0010 \u001a\u00020\u001f2\u0006\u0010\u000f\u001a\u00020\u0010H\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0015J\u0019\u0010!\u001a\u00020\u001f2\u0006\u0010\u000f\u001a\u00020\u0010H\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0015J\u0019\u0010\"\u001a\u00020\u001f2\u0006\u0010\u000f\u001a\u00020\u0010H\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0015R\u001d\u0010\u0005\u001a\u0004\u0018\u00010\u00068BX\u0082\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008\t\u0010\n\u001a\u0004\u0008\u0007\u0010\u0008R\u0014\u0010\u000b\u001a\u0008\u0012\u0004\u0012\u00020\u00020\u000cX\u0082\u0004\u00a2\u0006\u0002\n\u0000\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u0006$"
}
d2 = {
"Lcom/shopee/foody/driver/conditiontask/custom/OkHttpRequestAdapter;",
"Lcom/shopee/foody/driver/conditiontask/internal/adapters/ITaskAdapter;",
"Lcom/shopee/foody/driver/conditiontask/custom/OkHttpRequest;",
"Lokhttp3/Response;",
"()V",
"mNetworkService",
"Lcom/shopee/android/network/service/INetworkService;",
"getMNetworkService",
"()Lcom/shopee/android/network/service/INetworkService;",
"mNetworkService$delegate",
"Lkotlin/Lazy;",
"mProceedingRequests",
"Ljava/util/concurrent/ConcurrentLinkedQueue;",
"buildRequest",
"Lokhttp3/Request;",
"taskInfo",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"buildTaskInfo",
"rawRequest",
"convertTaskInfoToRawRequest",
"doRequest",
"(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"getBizID",
"",
"getRawRequestType",
"Ljava/lang/Class;",
"getRequestId",
"req",
"isReqInProceeding",
"",
"recordReq",
"",
"taskCanceled",
"taskExecutedFailed",
"taskExecutedSucceed",
"Companion",
"driver_indonesiaRelease"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# instance fields
.field public final a:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Lxd/b;",
">;"
}
.end annotation
.end field
.field public final b:Lkotlin/Lazy;
# direct methods
.method public static constructor <clinit>()V
.registers 2
new-instance v0, Lxd/c$a;
const/4 v1, 0x0
invoke-direct {v0, v1}, Lxd/c$a;-><init>(Lkotlin/jvm/internal/DefaultConstructorMarker;)V
return-void
.end method
.method public constructor <init>()V
.registers 2
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
iput-object v0, p0, Lxd/c;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
sget-object v0, Lxd/c$b;->a:Lxd/c$b;
invoke-static {v0}, Lfa/a;->a(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
iput-object v0, p0, Lxd/c;->b:Lkotlin/Lazy;
return-void
.end method
# virtual methods
.method public bridge synthetic a(Ljava/lang/Object;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
.registers 2
check-cast p1, Lxd/b;
invoke-virtual {p0, p1}, Lxd/c;->a(Lxd/b;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
move-result-object p1
return-object p1
.end method
.method public a(Lxd/b;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
.registers 21
new-instance v18, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
sget-object v0, Lwd/b;->c:Lwd/b;
invoke-virtual {v0}, Lwd/b;->a()Ljava/lang/String;
move-result-object v2
invoke-virtual/range {p1 .. p1}, Lxd/b;->g()Ljava/lang/String;
move-result-object v7
invoke-virtual/range {p1 .. p1}, Lxd/b;->c()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;
move-result-object v9
invoke-virtual/range {p1 .. p1}, Lxd/b;->d()Ljava/util/HashMap;
move-result-object v8
invoke-virtual/range {p1 .. p1}, Lxd/b;->b()I
move-result v5
invoke-virtual/range {p1 .. p1}, Lxd/b;->f()Ljava/lang/String;
move-result-object v6
invoke-virtual/range {p1 .. p1}, Lxd/b;->e()Z
move-result v0
if-eqz v0, :cond_25
sget-object v0, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;->PERSIST:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;
goto :goto_27
:cond_25
sget-object v0, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;->RUNTIME:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;
:goto_27
move-object v10, v0
sget-object v11, Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;->NETWORK:Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;
const/4 v13, 0x0
invoke-virtual/range {p1 .. p1}, Lxd/b;->a()J
move-result-wide v14
const/16 v16, 0x100d
const/16 v17, 0x0
const/4 v1, 0x0
const/4 v3, 0x0
const/4 v4, 0x0
const-string v12, "OkHttpRequest"
move-object/from16 v0, v18
invoke-direct/range {v0 .. v17}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;-><init>(Ljava/lang/String;Ljava/lang/String;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;IILjava/lang/String;Ljava/lang/String;Ljava/util/HashMap;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;Ljava/lang/String;Ljava/lang/String;JILkotlin/jvm/internal/DefaultConstructorMarker;)V
return-object v18
.end method
.method public bridge synthetic a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Ljava/lang/Object;
.registers 2
invoke-virtual {p0, p1}, Lxd/c;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lxd/b;
move-result-object p1
return-object p1
.end method
.method public a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Lxd/c$e;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Lxd/c$e;
iget v1, v0, Lxd/c$e;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Lxd/c$e;->b:I
goto :goto_18
:cond_13
new-instance v0, Lxd/c$e;
invoke-direct {v0, p0, p2}, Lxd/c$e;-><init>(Lxd/c;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Lxd/c$e;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Lxd/c$e;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Lxd/c$e;->e:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v0, v0, Lxd/c$e;->d:Ljava/lang/Object;
check-cast v0, Lxd/c;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_58
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
sget-object p2, Lke/a;->e:Lke/a;
invoke-virtual {p2}, Lke/a;->a()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;
move-result-object p2
if-eqz p2, :cond_57
invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;->b()Lde/a;
move-result-object p2
if-eqz p2, :cond_57
iput-object p0, v0, Lxd/c$e;->d:Ljava/lang/Object;
iput-object p1, v0, Lxd/c$e;->e:Ljava/lang/Object;
iput v3, v0, Lxd/c$e;->b:I
invoke-interface {p2, p1, v0}, Lde/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_57
return-object v1
:cond_57
move-object v0, p0
:goto_58
iget-object p2, v0, Lxd/c;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Lxd/c;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lxd/b;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public a()Ljava/lang/String;
.registers 2
const-string v0, "OkHttpRequest"
return-object v0
.end method
.method public a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lxd/b;
.registers 12
new-instance v9, Lxd/b;
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestUrl()Ljava/lang/String;
move-result-object v1
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestType()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;
move-result-object v2
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestParams()Ljava/util/HashMap;
move-result-object v3
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskType()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;
move-result-object v0
sget-object v4, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;->PERSIST:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;
if-ne v0, v4, :cond_19
const/4 v0, 0x1
const/4 v4, 0x1
goto :goto_1b
:cond_19
const/4 v0, 0x0
const/4 v4, 0x0
:goto_1b
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getQueryID()Ljava/lang/String;
move-result-object v5
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskMaxRetryCount()I
move-result v6
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getExpireTime()J
move-result-wide v7
move-object v0, v9
invoke-direct/range {v0 .. v8}, Lxd/b;-><init>(Ljava/lang/String;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;Ljava/util/HashMap;ZLjava/lang/String;IJ)V
return-object v9
.end method
.method public final b()Lcom/shopee/android/network/service/INetworkService;
.registers 2
iget-object v0, p0, Lxd/c;->b:Lkotlin/Lazy;
invoke-interface {v0}, Lkotlin/Lazy;->getValue()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcom/shopee/android/network/service/INetworkService;
return-object v0
.end method
.method public b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Lxd/c$d;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Lxd/c$d;
iget v1, v0, Lxd/c$d;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Lxd/c$d;->b:I
goto :goto_18
:cond_13
new-instance v0, Lxd/c$d;
invoke-direct {v0, p0, p2}, Lxd/c$d;-><init>(Lxd/c;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Lxd/c$d;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Lxd/c$d;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Lxd/c$d;->e:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v0, v0, Lxd/c$d;->d:Ljava/lang/Object;
check-cast v0, Lxd/c;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_58
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
sget-object p2, Lke/a;->e:Lke/a;
invoke-virtual {p2}, Lke/a;->a()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;
move-result-object p2
if-eqz p2, :cond_57
invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;->b()Lde/a;
move-result-object p2
if-eqz p2, :cond_57
iput-object p0, v0, Lxd/c$d;->d:Ljava/lang/Object;
iput-object p1, v0, Lxd/c$d;->e:Ljava/lang/Object;
iput v3, v0, Lxd/c$d;->b:I
invoke-interface {p2, p1, v0}, Lde/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_57
return-object v1
:cond_57
move-object v0, p0
:goto_58
iget-object p2, v0, Lxd/c;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Lxd/c;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lxd/b;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public b(Lxd/b;)Ljava/lang/String;
.registers 2
invoke-virtual {p1}, Lxd/b;->f()Ljava/lang/String;
move-result-object p1
return-object p1
.end method
.method public final b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lokhttp3/Request;
.registers 7
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestType()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;
move-result-object v0
sget-object v1, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;->GET:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;
const-string v2, "Request.Builder()\n \u2026\n .build()"
if-ne v0, v1, :cond_1f
new-instance v0, Lokhttp3/Request$Builder;
invoke-direct {v0}, Lokhttp3/Request$Builder;-><init>()V
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestUrl()Ljava/lang/String;
move-result-object p1
invoke-virtual {v0, p1}, Lokhttp3/Request$Builder;->url(Ljava/lang/String;)Lokhttp3/Request$Builder;
move-result-object p1
invoke-virtual {p1}, Lokhttp3/Request$Builder;->build()Lokhttp3/Request;
move-result-object p1
invoke-static {p1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
goto :goto_6c
:cond_1f
new-instance v0, Lokhttp3/FormBody$Builder;
invoke-direct {v0}, Lokhttp3/FormBody$Builder;-><init>()V
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestParams()Ljava/util/HashMap;
move-result-object v1
if-eqz v1, :cond_50
invoke-virtual {v1}, Ljava/util/HashMap;->entrySet()Ljava/util/Set;
move-result-object v1
if-eqz v1, :cond_50
invoke-interface {v1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v1
:goto_34
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v3
if-eqz v3, :cond_50
invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v3
check-cast v3, Ljava/util/Map$Entry;
invoke-interface {v3}, Ljava/util/Map$Entry;->getKey()Ljava/lang/Object;
move-result-object v4
check-cast v4, Ljava/lang/String;
invoke-interface {v3}, Ljava/util/Map$Entry;->getValue()Ljava/lang/Object;
move-result-object v3
check-cast v3, Ljava/lang/String;
invoke-virtual {v0, v4, v3}, Lokhttp3/FormBody$Builder;->add(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/FormBody$Builder;
goto :goto_34
:cond_50
invoke-virtual {v0}, Lokhttp3/FormBody$Builder;->build()Lokhttp3/FormBody;
move-result-object v0
new-instance v1, Lokhttp3/Request$Builder;
invoke-direct {v1}, Lokhttp3/Request$Builder;-><init>()V
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getRequestUrl()Ljava/lang/String;
move-result-object p1
invoke-virtual {v1, p1}, Lokhttp3/Request$Builder;->url(Ljava/lang/String;)Lokhttp3/Request$Builder;
move-result-object p1
invoke-virtual {p1, v0}, Lokhttp3/Request$Builder;->post(Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
move-result-object p1
invoke-virtual {p1}, Lokhttp3/Request$Builder;->build()Lokhttp3/Request;
move-result-object p1
invoke-static {p1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
:goto_6c
return-object p1
.end method
.method public bridge synthetic b(Ljava/lang/Object;)V
.registers 2
check-cast p1, Lxd/b;
invoke-virtual {p0, p1}, Lxd/c;->d(Lxd/b;)V
return-void
.end method
.method public c(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lokhttp3/Response;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
invoke-virtual {p0, p1}, Lxd/c;->b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lokhttp3/Request;
move-result-object p1
invoke-virtual {p0}, Lxd/c;->b()Lcom/shopee/android/network/service/INetworkService;
move-result-object p2
if-eqz p2, :cond_11
invoke-interface {p2, p1}, Lcom/shopee/android/network/service/INetworkService;->executeOrException(Lokhttp3/Request;)Lokhttp3/Response;
move-result-object p1
if-eqz p1, :cond_11
return-object p1
:cond_11
new-instance p1, Ljava/lang/NullPointerException;
const-string p2, "NetworkService is null"
invoke-direct {p1, p2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public bridge synthetic c(Ljava/lang/Object;)Z
.registers 2
check-cast p1, Lxd/b;
invoke-virtual {p0, p1}, Lxd/c;->c(Lxd/b;)Z
move-result p1
return p1
.end method
.method public c(Lxd/b;)Z
.registers 3
iget-object v0, p0, Lxd/c;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->contains(Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method public d(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Lxd/c$c;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Lxd/c$c;
iget v1, v0, Lxd/c$c;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Lxd/c$c;->b:I
goto :goto_18
:cond_13
new-instance v0, Lxd/c$c;
invoke-direct {v0, p0, p2}, Lxd/c$c;-><init>(Lxd/c;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Lxd/c$c;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Lxd/c$c;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Lxd/c$c;->e:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v0, v0, Lxd/c$c;->d:Ljava/lang/Object;
check-cast v0, Lxd/c;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_58
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
sget-object p2, Lke/a;->e:Lke/a;
invoke-virtual {p2}, Lke/a;->a()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;
move-result-object p2
if-eqz p2, :cond_57
invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;->b()Lde/a;
move-result-object p2
if-eqz p2, :cond_57
iput-object p0, v0, Lxd/c$c;->d:Ljava/lang/Object;
iput-object p1, v0, Lxd/c$c;->e:Ljava/lang/Object;
iput v3, v0, Lxd/c$c;->b:I
invoke-interface {p2, p1, v0}, Lde/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_57
return-object v1
:cond_57
move-object v0, p0
:goto_58
iget-object p2, v0, Lxd/c;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Lxd/c;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lxd/b;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public bridge synthetic d(Ljava/lang/Object;)Ljava/lang/String;
.registers 2
check-cast p1, Lxd/b;
invoke-virtual {p0, p1}, Lxd/c;->b(Lxd/b;)Ljava/lang/String;
move-result-object p1
return-object p1
.end method
.method public d(Lxd/b;)V
.registers 3
iget-object v0, p0, Lxd/c;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
return-void
.end method