.class public Lcom/dwx/okserver/upload/UploadTask;
.super Ljava/lang/Object;
.source "UploadTask.java"

# interfaces
.implements Ljava/lang/Runnable;


# annotations
.annotation system Ldalvik/annotation/Signature;
    value = {
        "<T:",
        "Ljava/lang/Object;",
        ">",
        "Ljava/lang/Object;",
        "Ljava/lang/Runnable;"
    }
.end annotation


# instance fields
.field private executor:Ljava/util/concurrent/ThreadPoolExecutor;

.field public listeners:Ljava/util/Map;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/Map<",
            "Ljava/lang/Object;",
            "Lcom/dwx/okserver/upload/UploadListener<",
            "TT;>;>;"
        }
    .end annotation
.end field

.field private priorityRunnable:Lcom/dwx/okserver/task/PriorityRunnable;

.field public progress:Lcom/dwx/okgo/model/Progress;


# direct methods
.method public constructor <init>(Lcom/dwx/okgo/model/Progress;)V
    .locals 1

    .line 42
    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    const-string v0, "progress == null"

    .line 43
    invoke-static {p1, v0}, Lcom/dwx/okgo/utils/HttpUtils;->checkNotNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 44
    iput-object p1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    .line 45
    invoke-static {}, Lcom/dwx/okserver/OkUpload;->getInstance()Lcom/dwx/okserver/OkUpload;

    move-result-object p1

    invoke-virtual {p1}, Lcom/dwx/okserver/OkUpload;->getThreadPool()Lcom/dwx/okserver/upload/UploadThreadPool;

    move-result-object p1

    invoke-virtual {p1}, Lcom/dwx/okserver/upload/UploadThreadPool;->getExecutor()Lcom/dwx/okserver/task/XExecutor;

    move-result-object p1

    iput-object p1, p0, Lcom/dwx/okserver/upload/UploadTask;->executor:Ljava/util/concurrent/ThreadPoolExecutor;

    .line 46
    new-instance p1, Ljava/util/HashMap;

    invoke-direct {p1}, Ljava/util/HashMap;-><init>()V

    iput-object p1, p0, Lcom/dwx/okserver/upload/UploadTask;->listeners:Ljava/util/Map;

    return-void
.end method

.method public constructor <init>(Ljava/lang/String;Lcom/dwx/okgo/request/base/Request;)V
    .locals 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            "Lcom/dwx/okgo/request/base/Request<",
            "TT;+",
            "Lcom/dwx/okgo/request/base/Request;",
            ">;)V"
        }
    .end annotation

    .line 29
    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    const-string v0, "tag == null"

    .line 30
    invoke-static {p1, v0}, Lcom/dwx/okgo/utils/HttpUtils;->checkNotNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 31
    new-instance v0, Lcom/dwx/okgo/model/Progress;

    invoke-direct {v0}, Lcom/dwx/okgo/model/Progress;-><init>()V

    iput-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    .line 32
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iput-object p1, v0, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

    .line 33
    invoke-virtual {p2}, Lcom/dwx/okgo/request/base/Request;->getBaseUrl()Ljava/lang/String;

    move-result-object p1

    iput-object p1, v0, Lcom/dwx/okgo/model/Progress;->url:Ljava/lang/String;

    .line 34
    iget-object p1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    const/4 v0, 0x0

    iput v0, p1, Lcom/dwx/okgo/model/Progress;->status:I

    const-wide/16 v0, -0x1

    .line 35
    iput-wide v0, p1, Lcom/dwx/okgo/model/Progress;->totalSize:J

    .line 36
    iput-object p2, p1, Lcom/dwx/okgo/model/Progress;->request:Lcom/dwx/okgo/request/base/Request;

    .line 38
    invoke-static {}, Lcom/dwx/okserver/OkUpload;->getInstance()Lcom/dwx/okserver/OkUpload;

    move-result-object p1

    invoke-virtual {p1}, Lcom/dwx/okserver/OkUpload;->getThreadPool()Lcom/dwx/okserver/upload/UploadThreadPool;

    move-result-object p1

    invoke-virtual {p1}, Lcom/dwx/okserver/upload/UploadThreadPool;->getExecutor()Lcom/dwx/okserver/task/XExecutor;

    move-result-object p1

    iput-object p1, p0, Lcom/dwx/okserver/upload/UploadTask;->executor:Ljava/util/concurrent/ThreadPoolExecutor;

    .line 39
    new-instance p1, Ljava/util/HashMap;

    invoke-direct {p1}, Ljava/util/HashMap;-><init>()V

    iput-object p1, p0, Lcom/dwx/okserver/upload/UploadTask;->listeners:Ljava/util/Map;

    return-void
.end method

.method static synthetic access$000(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V
    .locals 0

    .line 22
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->postLoading(Lcom/dwx/okgo/model/Progress;)V

    return-void
.end method

.method private postLoading(Lcom/dwx/okgo/model/Progress;)V
    .locals 1

    .line 216
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 217
    new-instance v0, Lcom/dwx/okserver/upload/UploadTask$5;

    invoke-direct {v0, p0, p1}, Lcom/dwx/okserver/upload/UploadTask$5;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V

    invoke-static {v0}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private postOnError(Lcom/dwx/okgo/model/Progress;Ljava/lang/Throwable;)V
    .locals 2

    const-wide/16 v0, 0x0

    .line 228
    iput-wide v0, p1, Lcom/dwx/okgo/model/Progress;->speed:J

    const/4 v0, 0x4

    .line 229
    iput v0, p1, Lcom/dwx/okgo/model/Progress;->status:I

    .line 230
    iput-object p2, p1, Lcom/dwx/okgo/model/Progress;->exception:Ljava/lang/Throwable;

    .line 231
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 232
    new-instance p2, Lcom/dwx/okserver/upload/UploadTask$6;

    invoke-direct {p2, p0, p1}, Lcom/dwx/okserver/upload/UploadTask$6;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V

    invoke-static {p2}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private postOnFinish(Lcom/dwx/okgo/model/Progress;Ljava/lang/Object;)V
    .locals 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/dwx/okgo/model/Progress;",
            "TT;)V"
        }
    .end annotation

    const-wide/16 v0, 0x0

    .line 244
    iput-wide v0, p1, Lcom/dwx/okgo/model/Progress;->speed:J

    const/high16 v0, 0x3f800000    # 1.0f

    .line 245
    iput v0, p1, Lcom/dwx/okgo/model/Progress;->fraction:F

    const/4 v0, 0x5

    .line 246
    iput v0, p1, Lcom/dwx/okgo/model/Progress;->status:I

    .line 247
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 248
    new-instance v0, Lcom/dwx/okserver/upload/UploadTask$7;

    invoke-direct {v0, p0, p1, p2}, Lcom/dwx/okserver/upload/UploadTask$7;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;Ljava/lang/Object;)V

    invoke-static {v0}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private postOnRemove(Lcom/dwx/okgo/model/Progress;)V
    .locals 1

    .line 260
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 261
    new-instance v0, Lcom/dwx/okserver/upload/UploadTask$8;

    invoke-direct {v0, p0, p1}, Lcom/dwx/okserver/upload/UploadTask$8;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V

    invoke-static {v0}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private postOnStart(Lcom/dwx/okgo/model/Progress;)V
    .locals 2

    const-wide/16 v0, 0x0

    .line 174
    iput-wide v0, p1, Lcom/dwx/okgo/model/Progress;->speed:J

    const/4 v0, 0x0

    .line 175
    iput v0, p1, Lcom/dwx/okgo/model/Progress;->status:I

    .line 176
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 177
    new-instance v0, Lcom/dwx/okserver/upload/UploadTask$2;

    invoke-direct {v0, p0, p1}, Lcom/dwx/okserver/upload/UploadTask$2;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V

    invoke-static {v0}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private postPause(Lcom/dwx/okgo/model/Progress;)V
    .locals 2

    const-wide/16 v0, 0x0

    .line 202
    iput-wide v0, p1, Lcom/dwx/okgo/model/Progress;->speed:J

    const/4 v0, 0x3

    .line 203
    iput v0, p1, Lcom/dwx/okgo/model/Progress;->status:I

    .line 204
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 205
    new-instance v0, Lcom/dwx/okserver/upload/UploadTask$4;

    invoke-direct {v0, p0, p1}, Lcom/dwx/okserver/upload/UploadTask$4;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V

    invoke-static {v0}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private postWaiting(Lcom/dwx/okgo/model/Progress;)V
    .locals 2

    const-wide/16 v0, 0x0

    .line 188
    iput-wide v0, p1, Lcom/dwx/okgo/model/Progress;->speed:J

    const/4 v0, 0x1

    .line 189
    iput v0, p1, Lcom/dwx/okgo/model/Progress;->status:I

    .line 190
    invoke-direct {p0, p1}, Lcom/dwx/okserver/upload/UploadTask;->updateDatabase(Lcom/dwx/okgo/model/Progress;)V

    .line 191
    new-instance v0, Lcom/dwx/okserver/upload/UploadTask$3;

    invoke-direct {v0, p0, p1}, Lcom/dwx/okserver/upload/UploadTask$3;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okgo/model/Progress;)V

    invoke-static {v0}, Lcom/dwx/okgo/utils/HttpUtils;->runOnUiThread(Ljava/lang/Runnable;)V

    return-void
.end method

.method private updateDatabase(Lcom/dwx/okgo/model/Progress;)V
    .locals 2

    .line 273
    invoke-static {p1}, Lcom/dwx/okgo/model/Progress;->buildUpdateContentValues(Lcom/dwx/okgo/model/Progress;)Landroid/content/ContentValues;

    move-result-object v0

    .line 274
    invoke-static {}, Lcom/dwx/okgo/db/UploadManager;->getInstance()Lcom/dwx/okgo/db/UploadManager;

    move-result-object v1

    iget-object p1, p1, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

    invoke-virtual {v1, v0, p1}, Lcom/dwx/okgo/db/UploadManager;->update(Landroid/content/ContentValues;Ljava/lang/String;)Z

    return-void
.end method


# virtual methods
.method public extra1(Ljava/io/Serializable;)Lcom/dwx/okserver/upload/UploadTask;
    .locals 1
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/io/Serializable;",
            ")",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 55
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iput-object p1, v0, Lcom/dwx/okgo/model/Progress;->extra1:Ljava/io/Serializable;

    return-object p0
.end method

.method public extra2(Ljava/io/Serializable;)Lcom/dwx/okserver/upload/UploadTask;
    .locals 1
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/io/Serializable;",
            ")",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 60
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iput-object p1, v0, Lcom/dwx/okgo/model/Progress;->extra2:Ljava/io/Serializable;

    return-object p0
.end method

.method public extra3(Ljava/io/Serializable;)Lcom/dwx/okserver/upload/UploadTask;
    .locals 1
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/io/Serializable;",
            ")",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 65
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iput-object p1, v0, Lcom/dwx/okgo/model/Progress;->extra3:Ljava/io/Serializable;

    return-object p0
.end method

.method public pause()V
    .locals 3

    .line 118
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->executor:Ljava/util/concurrent/ThreadPoolExecutor;

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->priorityRunnable:Lcom/dwx/okserver/task/PriorityRunnable;

    invoke-virtual {v0, v1}, Ljava/util/concurrent/ThreadPoolExecutor;->remove(Ljava/lang/Runnable;)Z

    .line 119
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v0, v0, Lcom/dwx/okgo/model/Progress;->status:I

    const/4 v1, 0x1

    if-ne v0, v1, :cond_0

    .line 120
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-direct {p0, v0}, Lcom/dwx/okserver/upload/UploadTask;->postPause(Lcom/dwx/okgo/model/Progress;)V

    goto :goto_0

    .line 121
    :cond_0
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v0, v0, Lcom/dwx/okgo/model/Progress;->status:I

    const/4 v1, 0x2

    if-ne v0, v1, :cond_1

    .line 122
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    const-wide/16 v1, 0x0

    iput-wide v1, v0, Lcom/dwx/okgo/model/Progress;->speed:J

    const/4 v1, 0x3

    .line 123
    iput v1, v0, Lcom/dwx/okgo/model/Progress;->status:I

    goto :goto_0

    .line 125
    :cond_1
    new-instance v0, Ljava/lang/StringBuilder;

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

    const-string v1, "only the task with status WAITING(1) or LOADING(2) can pause, current status is "

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

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v1, v1, Lcom/dwx/okgo/model/Progress;->status: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 {v0}, Lcom/dwx/okgo/utils/OkLogger;->w(Ljava/lang/String;)V

    :goto_0
    return-void
.end method

.method public priority(I)Lcom/dwx/okserver/upload/UploadTask;
    .locals 1
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(I)",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 50
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iput p1, v0, Lcom/dwx/okgo/model/Progress;->priority:I

    return-object p0
.end method

.method public register(Lcom/dwx/okserver/upload/UploadListener;)Lcom/dwx/okserver/upload/UploadTask;
    .locals 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/dwx/okserver/upload/UploadListener<",
            "TT;>;)",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    if-eqz p1, :cond_0

    .line 76
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->listeners:Ljava/util/Map;

    iget-object v1, p1, Lcom/dwx/okserver/upload/UploadListener;->tag:Ljava/lang/Object;

    invoke-interface {v0, v1, p1}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

    :cond_0
    return-object p0
.end method

.method public remove()Lcom/dwx/okserver/upload/UploadTask;
    .locals 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 131
    invoke-virtual {p0}, Lcom/dwx/okserver/upload/UploadTask;->pause()V

    .line 132
    invoke-static {}, Lcom/dwx/okgo/db/UploadManager;->getInstance()Lcom/dwx/okgo/db/UploadManager;

    move-result-object v0

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget-object v1, v1, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

    invoke-virtual {v0, v1}, Lcom/dwx/okgo/db/UploadManager;->delete(Ljava/lang/String;)V

    .line 134
    invoke-static {}, Lcom/dwx/okserver/OkUpload;->getInstance()Lcom/dwx/okserver/OkUpload;

    move-result-object v0

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget-object v1, v1, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

    invoke-virtual {v0, v1}, Lcom/dwx/okserver/OkUpload;->removeTask(Ljava/lang/String;)Lcom/dwx/okserver/upload/UploadTask;

    move-result-object v0

    .line 135
    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-direct {p0, v1}, Lcom/dwx/okserver/upload/UploadTask;->postOnRemove(Lcom/dwx/okgo/model/Progress;)V

    return-object v0
.end method

.method public restart()V
    .locals 4

    .line 107
    invoke-virtual {p0}, Lcom/dwx/okserver/upload/UploadTask;->pause()V

    .line 108
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    const/4 v1, 0x0

    iput v1, v0, Lcom/dwx/okgo/model/Progress;->status:I

    const-wide/16 v1, 0x0

    .line 109
    iput-wide v1, v0, Lcom/dwx/okgo/model/Progress;->currentSize:J

    const/4 v3, 0x0

    .line 110
    iput v3, v0, Lcom/dwx/okgo/model/Progress;->fraction:F

    .line 111
    iput-wide v1, v0, Lcom/dwx/okgo/model/Progress;->speed:J

    .line 112
    invoke-static {}, Lcom/dwx/okgo/db/UploadManager;->getInstance()Lcom/dwx/okgo/db/UploadManager;

    move-result-object v0

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-virtual {v0, v1}, Lcom/dwx/okgo/db/UploadManager;->replace(Ljava/lang/Object;)Z

    .line 113
    invoke-virtual {p0}, Lcom/dwx/okserver/upload/UploadTask;->start()Lcom/dwx/okserver/upload/UploadTask;

    return-void
.end method

.method public run()V
    .locals 3

    .line 141
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    const/4 v1, 0x2

    iput v1, v0, Lcom/dwx/okgo/model/Progress;->status:I

    .line 142
    invoke-direct {p0, v0}, Lcom/dwx/okserver/upload/UploadTask;->postLoading(Lcom/dwx/okgo/model/Progress;)V

    .line 146
    :try_start_0
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget-object v0, v0, Lcom/dwx/okgo/model/Progress;->request:Lcom/dwx/okgo/request/base/Request;

    .line 147
    invoke-virtual {v0}, Lcom/dwx/okgo/request/base/Request;->getRawCall()Lcom/dwx/okhttp3/Call;

    move-result-object v1

    .line 148
    new-instance v2, Lcom/dwx/okserver/upload/UploadTask$1;

    invoke-direct {v2, p0, v1}, Lcom/dwx/okserver/upload/UploadTask$1;-><init>(Lcom/dwx/okserver/upload/UploadTask;Lcom/dwx/okhttp3/Call;)V

    invoke-virtual {v0, v2}, Lcom/dwx/okgo/request/base/Request;->uploadInterceptor(Lcom/dwx/okgo/request/base/ProgressRequestBody$UploadInterceptor;)Lcom/dwx/okgo/request/base/Request;

    .line 160
    invoke-virtual {v0}, Lcom/dwx/okgo/request/base/Request;->adapt()Lcom/dwx/okgo/adapter/Call;

    move-result-object v0

    invoke-interface {v0}, Lcom/dwx/okgo/adapter/Call;->execute()Lcom/dwx/okgo/model/Response;

    move-result-object v0
    :try_end_0
    .catch Ljava/lang/Exception; {:try_start_0 .. :try_end_0} :catch_0

    .line 166
    invoke-virtual {v0}, Lcom/dwx/okgo/model/Response;->isSuccessful()Z

    move-result v1

    if-eqz v1, :cond_0

    .line 167
    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-virtual {v0}, Lcom/dwx/okgo/model/Response;->body()Ljava/lang/Object;

    move-result-object v0

    invoke-direct {p0, v1, v0}, Lcom/dwx/okserver/upload/UploadTask;->postOnFinish(Lcom/dwx/okgo/model/Progress;Ljava/lang/Object;)V

    goto :goto_0

    .line 169
    :cond_0
    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-virtual {v0}, Lcom/dwx/okgo/model/Response;->getException()Ljava/lang/Throwable;

    move-result-object v0

    invoke-direct {p0, v1, v0}, Lcom/dwx/okserver/upload/UploadTask;->postOnError(Lcom/dwx/okgo/model/Progress;Ljava/lang/Throwable;)V

    :goto_0
    return-void

    :catch_0
    move-exception v0

    .line 162
    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-direct {p0, v1, v0}, Lcom/dwx/okserver/upload/UploadTask;->postOnError(Lcom/dwx/okgo/model/Progress;Ljava/lang/Throwable;)V

    return-void
.end method

.method public save()Lcom/dwx/okserver/upload/UploadTask;
    .locals 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 70
    invoke-static {}, Lcom/dwx/okgo/db/UploadManager;->getInstance()Lcom/dwx/okgo/db/UploadManager;

    move-result-object v0

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-virtual {v0, v1}, Lcom/dwx/okgo/db/UploadManager;->replace(Ljava/lang/Object;)Z

    return-object p0
.end method

.method public start()Lcom/dwx/okserver/upload/UploadTask;
    .locals 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lcom/dwx/okserver/upload/UploadTask<",
            "TT;>;"
        }
    .end annotation

    .line 92
    invoke-static {}, Lcom/dwx/okserver/OkUpload;->getInstance()Lcom/dwx/okserver/OkUpload;

    move-result-object v0

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget-object v1, v1, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

    invoke-virtual {v0, v1}, Lcom/dwx/okserver/OkUpload;->getTask(Ljava/lang/String;)Lcom/dwx/okserver/upload/UploadTask;

    move-result-object v0

    if-eqz v0, :cond_1

    invoke-static {}, Lcom/dwx/okgo/db/UploadManager;->getInstance()Lcom/dwx/okgo/db/UploadManager;

    move-result-object v0

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget-object v1, v1, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

    invoke-virtual {v0, v1}, Lcom/dwx/okgo/db/UploadManager;->get(Ljava/lang/String;)Lcom/dwx/okgo/model/Progress;

    move-result-object v0

    if-eqz v0, :cond_1

    .line 95
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v0, v0, Lcom/dwx/okgo/model/Progress;->status:I

    const/4 v1, 0x1

    if-eq v0, v1, :cond_0

    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v0, v0, Lcom/dwx/okgo/model/Progress;->status:I

    const/4 v1, 0x2

    if-eq v0, v1, :cond_0

    .line 96
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-direct {p0, v0}, Lcom/dwx/okserver/upload/UploadTask;->postOnStart(Lcom/dwx/okgo/model/Progress;)V

    .line 97
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    invoke-direct {p0, v0}, Lcom/dwx/okserver/upload/UploadTask;->postWaiting(Lcom/dwx/okgo/model/Progress;)V

    .line 98
    new-instance v0, Lcom/dwx/okserver/task/PriorityRunnable;

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v1, v1, Lcom/dwx/okgo/model/Progress;->priority:I

    invoke-direct {v0, v1, p0}, Lcom/dwx/okserver/task/PriorityRunnable;-><init>(ILjava/lang/Runnable;)V

    iput-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->priorityRunnable:Lcom/dwx/okserver/task/PriorityRunnable;

    .line 99
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->executor:Ljava/util/concurrent/ThreadPoolExecutor;

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->priorityRunnable:Lcom/dwx/okserver/task/PriorityRunnable;

    invoke-virtual {v0, v1}, Ljava/util/concurrent/ThreadPoolExecutor;->execute(Ljava/lang/Runnable;)V

    goto :goto_0

    .line 101
    :cond_0
    new-instance v0, Ljava/lang/StringBuilder;

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

    const-string v1, "the task with tag "

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

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget-object v1, v1, Lcom/dwx/okgo/model/Progress;->tag:Ljava/lang/String;

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

    const-string v1, " is already in the upload queue, current task status is "

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

    iget-object v1, p0, Lcom/dwx/okserver/upload/UploadTask;->progress:Lcom/dwx/okgo/model/Progress;

    iget v1, v1, Lcom/dwx/okgo/model/Progress;->status: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 {v0}, Lcom/dwx/okgo/utils/OkLogger;->w(Ljava/lang/String;)V

    :goto_0
    return-object p0

    .line 93
    :cond_1
    new-instance v0, Ljava/lang/IllegalStateException;

    const-string v1, "you must call UploadTask#save() before UploadTask#start()\uff01"

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

    throw v0
.end method

.method public unRegister(Lcom/dwx/okserver/upload/UploadListener;)V
    .locals 1
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/dwx/okserver/upload/UploadListener<",
            "TT;>;)V"
        }
    .end annotation

    const-string v0, "listener == null"

    .line 82
    invoke-static {p1, v0}, Lcom/dwx/okgo/utils/HttpUtils;->checkNotNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 83
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->listeners:Ljava/util/Map;

    iget-object p1, p1, Lcom/dwx/okserver/upload/UploadListener;->tag:Ljava/lang/Object;

    invoke-interface {v0, p1}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object;

    return-void
.end method

.method public unRegister(Ljava/lang/String;)V
    .locals 1

    const-string v0, "tag == null"

    .line 87
    invoke-static {p1, v0}, Lcom/dwx/okgo/utils/HttpUtils;->checkNotNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 88
    iget-object v0, p0, Lcom/dwx/okserver/upload/UploadTask;->listeners:Ljava/util/Map;

    invoke-interface {v0, p1}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object;

    return-void
.end method