BLiveStatisHttpSender.smali

.class public final Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;
.super Ljava/lang/Object;
.source "SourceFile"

# interfaces
.implements Lsg/bigo/sdk/blivestat/IHttpSenderConfig;
.implements Lsg/bigo/sdk/blivestat/sender/IInfoSender;


# annotations
.annotation system Ldalvik/annotation/MemberClasses;
    value = {
        Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;,
        Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;
    }
.end annotation


# static fields
.field private static final G_TAG:Ljava/lang/String; = "BLiveStatisSDK"

.field private static final INTERVALTIME_1st:J

.field private static final INTERVALTIME_2nd:J

.field private static final MAX_CONTINUE_FAILURE_TIMES:I = 0x14

.field private static final MAX_THRESHOLD_SIZE:I = 0x5dc

.field private static final MEDIA_TYPE_TEXT:Lokhttp3/v;

.field private static final QUERY_SIZE:I = 0xc8

.field private static final SINGLE_RECORD_RETRY_TIMES:I = 0x2

.field private static final TAG:Ljava/lang/String; = "BLiveStatisSDK"

.field private static final encryKey:Ljava/lang/String; = "Z+W_wHN2ja4_#@HC"

.field private static sUserAgent:Ljava/lang/String;


# instance fields
.field private curContinueFailureCount:I

.field private isNetworkAvailable:Z

.field private final mAesCipher:Lsg/bigo/sdk/blivestat/utils/AesCipher;

.field private mCanSendInBackground:Z

.field private mCommonSendFuture:Ljava/util/concurrent/Future;

.field private final mCommonSendTask:Ljava/lang/Runnable;

.field private final mConfig:Lsg/bigo/sdk/blivestat/config/StatisConfig;

.field private final mContext:Landroid/content/Context;

.field private final mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

.field private final mDebug:Z

.field private volatile mDelaySendTask:Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;

.field private mDivideTime:J

.field private final mEventRecTimeMap:Ljava/util/HashMap;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/HashMap<",
            "Ljava/lang/String;",
            "Ljava/util/List<",
            "Landroid/util/Pair<",
            "Ljava/lang/String;",
            "Ljava/lang/Long;",
            ">;>;>;"
        }
    .end annotation
.end field

.field private final mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

.field private mInBackground:Z

.field private final mNetStatusListener:Landroid/content/BroadcastReceiver;

.field private mOnlyCheckDauCache:Z

.field private final mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/PriorityBlockingQueue<",
            "Lsg/bigo/sdk/blivestat/database/StatCacheDao;",
            ">;"
        }
    .end annotation
.end field

.field private final mReportUrlConfig:Landroid/util/SparseArray;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Landroid/util/SparseArray<",
            "[",
            "Ljava/lang/String;",
            ">;"
        }
    .end annotation
.end field

.field private mSenderCallback:Lsg/bigo/sdk/blivestat/IStatisSenderCallback;

.field private mSenderResultCallback:Lsg/bigo/sdk/blivestat/sender/ISenderResultCallback;

.field private final mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/ConcurrentLinkedQueue<",
            "Lsg/bigo/sdk/blivestat/database/StatCacheDao;",
            ">;"
        }
    .end annotation
.end field

.field private final mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

.field private maxCall:I

.field private final sendLock:Ljava/util/concurrent/Semaphore;


# direct methods
.method static constructor <clinit>()V
    .registers 3

    const-string v0, "text/plain"

    .line 66
    invoke-static {v0}, Lokhttp3/v;->b(Ljava/lang/String;)Lokhttp3/v;

    move-result-object v0

    sput-object v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->MEDIA_TYPE_TEXT:Lokhttp3/v;

    const-string v0, "BigoLive-Android"

    .line 99
    sput-object v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sUserAgent:Ljava/lang/String;

    .line 600
    sget-object v0, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;

    const-wide/16 v1, 0x3

    invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/TimeUnit;->toMillis(J)J

    move-result-wide v0

    sput-wide v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->INTERVALTIME_1st:J

    .line 601
    sget-object v0, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;

    const-wide/16 v1, 0x5

    invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/TimeUnit;->toMillis(J)J

    move-result-wide v0

    sput-wide v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->INTERVALTIME_2nd:J

    return-void
.end method

.method public constructor <init>(Landroid/content/Context;Lsg/bigo/sdk/blivestat/config/StatisConfig;ZLsg/bigo/sdk/blivestat/database/StatCacheDbFactory;Lsg/bigo/sdk/blivestat/utils/StatThread;)V
    .registers 10

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

    .line 70
    new-instance v0, Lsg/bigo/sdk/blivestat/utils/AesCipher;

    const-string v1, "Z+W_wHN2ja4_#@HC"

    invoke-virtual {v1}, Ljava/lang/String;->getBytes()[B

    move-result-object v1

    invoke-direct {v0, v1}, Lsg/bigo/sdk/blivestat/utils/AesCipher;-><init>([B)V

    iput-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mAesCipher:Lsg/bigo/sdk/blivestat/utils/AesCipher;

    .line 71
    new-instance v0, Landroid/util/SparseArray;

    const/4 v1, 0x2

    invoke-direct {v0, v1}, Landroid/util/SparseArray;-><init>(I)V

    iput-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mReportUrlConfig:Landroid/util/SparseArray;

    .line 76
    new-instance v0, Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-direct {v0}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>()V

    iput-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    .line 77
    new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V

    iput-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    const/4 v0, 0x0

    .line 79
    iput v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->curContinueFailureCount:I

    .line 85
    new-instance v2, Ljava/util/concurrent/Semaphore;

    const/4 v3, 0x1

    invoke-direct {v2, v3}, Ljava/util/concurrent/Semaphore;-><init>(I)V

    iput-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    .line 88
    new-instance v2, Ljava/util/HashMap;

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

    iput-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mEventRecTimeMap:Ljava/util/HashMap;

    const/4 v2, 0x0

    .line 90
    iput-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDelaySendTask:Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;

    .line 95
    iput-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendFuture:Ljava/util/concurrent/Future;

    .line 106
    iput-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mOnlyCheckDauCache:Z

    .line 130
    new-instance v2, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$1;

    invoke-direct {v2, p0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$1;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)V

    iput-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mNetStatusListener:Landroid/content/BroadcastReceiver;

    .line 401
    new-instance v2, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$3;

    invoke-direct {v2, p0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$3;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)V

    iput-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendTask:Ljava/lang/Runnable;

    .line 109
    iput-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mContext:Landroid/content/Context;

    .line 110
    iput-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mConfig:Lsg/bigo/sdk/blivestat/config/StatisConfig;

    .line 111
    iput-boolean p3, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDebug:Z

    .line 112
    iput-object p4, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    .line 113
    new-instance p1, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-direct {p1, p2}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;-><init>(Lsg/bigo/sdk/blivestat/config/IStatisConfig;)V

    iput-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    .line 114
    invoke-virtual {p1}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->getMaxRequest()I

    move-result p1

    iput p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->maxCall:I

    .line 115
    iput-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mInBackground:Z

    .line 116
    iput-boolean v3, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCanSendInBackground:Z

    .line 117
    invoke-static {}, Lsg/bigo/common/p;->b()Z

    move-result p1

    iput-boolean p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->isNetworkAvailable:Z

    .line 118
    iput-object p5, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

    .line 119
    invoke-virtual {p2}, Lsg/bigo/sdk/blivestat/config/StatisConfig;->getYYReportUrl()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p0, v3, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->setReportUrl(ILjava/lang/String;)V

    .line 120
    invoke-virtual {p2}, Lsg/bigo/sdk/blivestat/config/StatisConfig;->getPBReportUrl()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p0, v1, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->setReportUrl(ILjava/lang/String;)V

    .line 121
    invoke-direct {p0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->registerNetListener()V

    return-void
.end method

.method static synthetic access$000(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)Z
    .registers 1

    .line 63
    iget-boolean p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->isNetworkAvailable:Z

    return p0
.end method

.method static synthetic access$002(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Z)Z
    .registers 2

    .line 63
    iput-boolean p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->isNetworkAvailable:Z

    return p1
.end method

.method static synthetic access$100(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)Ljava/lang/Runnable;
    .registers 1

    .line 63
    iget-object p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendTask:Ljava/lang/Runnable;

    return-object p0
.end method

.method static synthetic access$1000(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)Z
    .registers 1

    .line 63
    iget-boolean p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDebug:Z

    return p0
.end method

.method static synthetic access$1100(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lokhttp3/aa;)Lokhttp3/aa;
    .registers 2

    .line 63
    invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->requestSwitchHttpsHttp(Lokhttp3/aa;)Lokhttp3/aa;

    move-result-object p0

    return-object p0
.end method

.method static synthetic access$1200(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;IILokhttp3/aa;Ljava/util/List;Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;)V
    .registers 6

    .line 63
    invoke-direct/range {p0 .. p5}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->doHttpSend(IILokhttp3/aa;Ljava/util/List;Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;)V

    return-void
.end method

.method static synthetic access$1300()J
    .registers 2

    .line 63
    sget-wide v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->INTERVALTIME_1st:J

    return-wide v0
.end method

.method static synthetic access$1400()J
    .registers 2

    .line 63
    sget-wide v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->INTERVALTIME_2nd:J

    return-wide v0
.end method

.method static synthetic access$1500(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)Lsg/bigo/sdk/blivestat/IStatisSenderCallback;
    .registers 1

    .line 63
    iget-object p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSenderCallback:Lsg/bigo/sdk/blivestat/IStatisSenderCallback;

    return-object p0
.end method

.method static synthetic access$1600(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)J
    .registers 3

    .line 63
    iget-wide v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDivideTime:J

    return-wide v0
.end method

.method static synthetic access$1700(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;JZZ)V
    .registers 5

    .line 63
    invoke-direct {p0, p1, p2, p3, p4}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->addContentFromCache(JZZ)V

    return-void
.end method

.method static synthetic access$200(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)Lsg/bigo/sdk/blivestat/utils/StatThread;
    .registers 1

    .line 63
    iget-object p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

    return-object p0
.end method

.method static synthetic access$400(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Z)V
    .registers 2

    .line 63
    invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->trySendContent(Z)V

    return-void
.end method

.method static synthetic access$500(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 2

    .line 63
    invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->handleSendContentSuc(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V

    return-void
.end method

.method static synthetic access$600(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)Lsg/bigo/sdk/blivestat/sender/ISenderResultCallback;
    .registers 1

    .line 63
    iget-object p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSenderResultCallback:Lsg/bigo/sdk/blivestat/sender/ISenderResultCallback;

    return-object p0
.end method

.method static synthetic access$700(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 2

    .line 63
    invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->handleSendFail(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V

    return-void
.end method

.method static synthetic access$800(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)I
    .registers 1

    .line 63
    iget p0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->curContinueFailureCount:I

    return p0
.end method

.method static synthetic access$802(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;I)I
    .registers 2

    .line 63
    iput p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->curContinueFailureCount:I

    return p1
.end method

.method static synthetic access$808(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)I
    .registers 3

    .line 63
    iget v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->curContinueFailureCount:I

    add-int/lit8 v1, v0, 0x1

    iput v1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->curContinueFailureCount:I

    return v0
.end method

.method static synthetic access$900(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 2

    .line 63
    invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->handleSendContent(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V

    return-void
.end method

.method private addContentFromCache(JZZ)V
    .registers 8

    .line 375
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->getHighestStatCacheData()Ljava/util/concurrent/PriorityBlockingQueue;

    move-result-object v0

    .line 376
    iget-object v1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {v1, v0}, Ljava/util/concurrent/PriorityBlockingQueue;->addAll(Ljava/util/Collection;)Z

    if-eqz p4, :cond_39

    .line 379
    iget-boolean p4, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mOnlyCheckDauCache:Z

    if-eqz p4, :cond_39

    .line 380
    new-instance p1, Ljava/lang/StringBuilder;

    const-string p2, "Only add high priority cache: "

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

    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {p2}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I

    move-result p2

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

    const-string p2, ", All Cache size: "

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

    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {p2}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->getAllCacheSize()I

    move-result p2

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

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

    move-result-object p1

    const-string p2, "BLiveStatisSDK"

    invoke-static {p2, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->w(Ljava/lang/String;Ljava/lang/String;)V

    return-void

    .line 384
    :cond_39
    invoke-virtual {v0}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I

    move-result p4

    const/16 v1, 0xc8

    if-ge p4, v1, :cond_51

    .line 385
    iget-object p4, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {v0}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I

    move-result v0

    sub-int/2addr v1, v0

    invoke-virtual {v2, p1, p2, p3, v1}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->getStatCacheDataByTime(JZI)Ljava/util/concurrent/PriorityBlockingQueue;

    move-result-object p1

    invoke-virtual {p4, p1}, Ljava/util/concurrent/PriorityBlockingQueue;->addAll(Ljava/util/Collection;)Z

    :cond_51
    return-void
.end method

.method private compress([B)[B
    .registers 5

    const/4 v0, 0x0

    .line 503
    :try_start_1
    new-instance v1, Ljava/io/ByteArrayOutputStream;

    invoke-direct {v1}, Ljava/io/ByteArrayOutputStream;-><init>()V
    :try_end_6
    .catch Ljava/io/IOException; {:try_start_1 .. :try_end_6} :catch_30
    .catchall {:try_start_1 .. :try_end_6} :catchall_23

    .line 504
    :try_start_6
    new-instance v2, Ljava/util/zip/GZIPOutputStream;

    invoke-direct {v2, v1}, Ljava/util/zip/GZIPOutputStream;-><init>(Ljava/io/OutputStream;)V
    :try_end_b
    .catch Ljava/io/IOException; {:try_start_6 .. :try_end_b} :catch_21
    .catchall {:try_start_6 .. :try_end_b} :catchall_1f

    .line 505
    :try_start_b
    invoke-virtual {v2, p1}, Ljava/util/zip/GZIPOutputStream;->write([B)V

    .line 506
    invoke-virtual {v2}, Ljava/util/zip/GZIPOutputStream;->finish()V

    .line 507
    invoke-virtual {v1}, Ljava/io/ByteArrayOutputStream;->toByteArray()[B

    move-result-object v0
    :try_end_15
    .catch Ljava/io/IOException; {:try_start_b .. :try_end_15} :catch_32
    .catchall {:try_start_b .. :try_end_15} :catchall_1c

    .line 513
    :try_start_15
    invoke-virtual {v2}, Ljava/util/zip/GZIPOutputStream;->close()V

    .line 516
    :goto_18
    invoke-virtual {v1}, Ljava/io/ByteArrayOutputStream;->close()V
    :try_end_1b
    .catch Ljava/lang/Exception; {:try_start_15 .. :try_end_1b} :catch_3a

    goto :goto_3a

    :catchall_1c
    move-exception p1

    move-object v0, v2

    goto :goto_25

    :catchall_1f
    move-exception p1

    goto :goto_25

    :catch_21
    move-object v2, v0

    goto :goto_32

    :catchall_23
    move-exception p1

    move-object v1, v0

    :goto_25
    if-eqz v0, :cond_2a

    .line 513
    :try_start_27
    invoke-virtual {v0}, Ljava/util/zip/GZIPOutputStream;->close()V

    :cond_2a
    if-eqz v1, :cond_2f

    .line 516
    invoke-virtual {v1}, Ljava/io/ByteArrayOutputStream;->close()V
    :try_end_2f
    .catch Ljava/lang/Exception; {:try_start_27 .. :try_end_2f} :catch_2f

    .line 520
    :catch_2f
    :cond_2f
    throw p1

    :catch_30
    move-object v1, v0

    move-object v2, v1

    :catch_32
    :goto_32
    if-eqz v2, :cond_37

    .line 513
    :try_start_34
    invoke-virtual {v2}, Ljava/util/zip/GZIPOutputStream;->close()V
    :try_end_37
    .catch Ljava/lang/Exception; {:try_start_34 .. :try_end_37} :catch_3a

    :cond_37
    if-eqz v1, :cond_3a

    goto :goto_18

    :catch_3a
    :cond_3a
    :goto_3a
    return-object v0
.end method

.method private doHttpSend(IILokhttp3/aa;Ljava/util/List;Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;)V
    .registers 19
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(II",
            "Lokhttp3/aa;",
            "Ljava/util/List<",
            "Landroid/util/Pair<",
            "Ljava/lang/String;",
            "Ljava/lang/Long;",
            ">;>;",
            "Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;",
            ")V"
        }
    .end annotation

    move-object v10, p0

    move-object/from16 v5, p3

    .line 4081
    const-class v0, Ljava/lang/Object;

    invoke-virtual {v5, v0}, Lokhttp3/aa;->a(Ljava/lang/Class;)Ljava/lang/Object;

    move-result-object v0

    if-nez v0, :cond_14

    .line 617
    invoke-static {}, Ljava/util/UUID;->randomUUID()Ljava/util/UUID;

    move-result-object v0

    invoke-virtual {v0}, Ljava/util/UUID;->hashCode()I

    move-result v0

    goto :goto_1e

    .line 5081
    :cond_14
    const-class v0, Ljava/lang/Object;

    invoke-virtual {v5, v0}, Lokhttp3/aa;->a(Ljava/lang/Class;)Ljava/lang/Object;

    move-result-object v0

    .line 617
    invoke-virtual {v0}, Ljava/lang/Object;->hashCode()I

    move-result v0

    :goto_1e
    move v6, v0

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

    move-result-wide v8

    .line 621
    iget-object v0, v10, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSenderCallback:Lsg/bigo/sdk/blivestat/IStatisSenderCallback;

    move-object/from16 v3, p4

    if-eqz v0, :cond_2c

    .line 622
    invoke-interface {v0, v6, v3}, Lsg/bigo/sdk/blivestat/IStatisSenderCallback;->onStartSendEvent(ILjava/util/List;)V

    .line 625
    :cond_2c
    iget-object v0, v10, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->getHttpClient()Lokhttp3/x;

    move-result-object v0

    const/4 v1, 0x0

    .line 5427
    invoke-static {v0, v5, v1}, Lokhttp3/z;->a(Lokhttp3/x;Lokhttp3/aa;Z)Lokhttp3/z;

    move-result-object v11

    .line 625
    new-instance v12, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$6;

    move-object v0, v12

    move-object v1, p0

    move v2, p2

    move-object/from16 v3, p4

    move v4, p1

    move-object/from16 v5, p3

    move-object/from16 v7, p5

    invoke-direct/range {v0 .. v9}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$6;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;ILjava/util/List;ILokhttp3/aa;ILsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;J)V

    invoke-interface {v11, v12}, Lokhttp3/e;->a(Lokhttp3/f;)V

    return-void
.end method

.method private getSendUrl(I)Ljava/lang/String;
    .registers 6

    const/4 v0, 0x1

    if-nez p1, :cond_5

    const/4 v1, 0x1

    goto :goto_6

    :cond_5
    move v1, p1

    .line 411
    :goto_6
    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mReportUrlConfig:Landroid/util/SparseArray;

    invoke-virtual {v2, v1}, Landroid/util/SparseArray;->get(I)Ljava/lang/Object;

    move-result-object v1

    check-cast v1, [Ljava/lang/String;

    if-eqz v1, :cond_33

    .line 412
    array-length v2, v1

    const/4 v3, 0x2

    if-eq v2, v3, :cond_15

    goto :goto_33

    .line 417
    :cond_15
    iget-boolean p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDebug:Z

    if-eqz p1, :cond_29

    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mConfig:Lsg/bigo/sdk/blivestat/config/StatisConfig;

    invoke-virtual {p1}, Lsg/bigo/sdk/blivestat/config/StatisConfig;->getCommonInfoProvider()Lsg/bigo/sdk/blivestat/config/ICommonInfoProvider;

    move-result-object p1

    invoke-interface {p1}, Lsg/bigo/sdk/blivestat/config/ICommonInfoProvider;->isUseOfficialUrlWhenDebug()Z

    move-result p1

    if-eqz p1, :cond_26

    goto :goto_29

    .line 420
    :cond_26
    aget-object p1, v1, v0

    return-object p1

    .line 418
    :cond_29
    :goto_29
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    const/4 v0, 0x0

    aget-object v0, v1, v0

    invoke-virtual {p1, v0}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->toBigoUrl(Ljava/lang/String;)Ljava/lang/String;

    move-result-object p1

    return-object p1

    :cond_33
    :goto_33
    const-string v0, "BLiveStatisSDK-Error"

    const-string v1, "report event error, didn\'t set report url!! error code: 1"

    .line 413
    invoke-static {v0, v1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    .line 414
    new-instance v1, Ljava/lang/StringBuilder;

    const-string v2, "report url config for type "

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

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

    const-string p1, " error!!"

    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

    invoke-static {v0, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    const/4 p1, 0x0

    return-object p1
.end method

.method private getStatCacheDao(I[BI)Lsg/bigo/sdk/blivestat/database/StatCacheDao;
    .registers 7

    .line 390
    new-instance v0, Lsg/bigo/sdk/blivestat/database/StatCacheDao;

    invoke-direct {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;-><init>()V

    .line 391
    iget-object v1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {v1}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->generateKey()Ljava/lang/String;

    move-result-object v1

    .line 392
    invoke-virtual {v0, v1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setKey(Ljava/lang/String;)V

    .line 393
    invoke-virtual {v0, p3}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setPriority(I)V

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

    move-result-wide v1

    invoke-virtual {v0, v1, v2}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setCreateTime(J)V

    .line 395
    invoke-virtual {v0, p2}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setValue([B)V

    .line 396
    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setDataType(I)V

    return-object v0
.end method

.method private handleSendContent(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 6

    .line 464
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z

    move-result v0

    const-string v1, "BLiveStatisSDK"

    if-nez v0, :cond_24

    const-string v0, "handleSendContent remove content from mSendingList error"

    .line 466
    invoke-static {v1, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    .line 467
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->poll()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lsg/bigo/sdk/blivestat/database/StatCacheDao;

    if-eqz v0, :cond_24

    .line 468
    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->equals(Ljava/lang/Object;)Z

    move-result v2

    if-nez v2, :cond_24

    .line 469
    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v2, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z

    .line 473
    :cond_24
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->delete(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)Z

    move-result v0

    .line 474
    new-instance v2, Ljava/lang/StringBuilder;

    const-string v3, "handleSendContent delete data from db key:"

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

    invoke-virtual {p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;

    move-result-object p1

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

    const-string p1, ",isOK:"

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

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

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

    move-result-object p1

    invoke-static {v1, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    const/4 p1, 0x0

    .line 475
    invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->trySendContent(Z)V

    return-void
.end method

.method private handleSendContentSuc(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 4

    .line 454
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

    new-instance v1, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$5;

    invoke-direct {v1, p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$5;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V

    invoke-virtual {v0, v1}, Lsg/bigo/sdk/blivestat/utils/StatThread;->post(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;

    return-void
.end method

.method private handleSendFail(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 4

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

    const-string v1, "handleSendFail key:"

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

    invoke-virtual {p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;

    move-result-object v1

    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

    const-string v1, "BLiveStatisSDK"

    invoke-static {v1, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 481
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z

    move-result v0

    if-nez v0, :cond_39

    const-string v0, "handleSendFail remove content from mSendingList error"

    .line 483
    invoke-static {v1, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    .line 484
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->poll()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lsg/bigo/sdk/blivestat/database/StatCacheDao;

    if-eqz v0, :cond_39

    .line 485
    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->equals(Ljava/lang/Object;)Z

    move-result p1

    if-nez p1, :cond_39

    .line 486
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {p1, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z

    :cond_39
    return-void
.end method

.method private registerNetListener()V
    .registers 6

    .line 125
    new-instance v0, Landroid/content/IntentFilter;

    const-string v1, "android.net.conn.CONNECTIVITY_CHANGE"

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

    .line 127
    iget-object v1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mContext:Landroid/content/Context;

    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mNetStatusListener:Landroid/content/BroadcastReceiver;

    iget-object v3, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

    invoke-virtual {v3}, Lsg/bigo/sdk/blivestat/utils/StatThread;->getHandler()Landroid/os/Handler;

    move-result-object v3

    const/4 v4, 0x0

    invoke-virtual {v1, v2, v0, v4, v3}, Landroid/content/Context;->registerReceiver(Landroid/content/BroadcastReceiver;Landroid/content/IntentFilter;Ljava/lang/String;Landroid/os/Handler;)Landroid/content/Intent;

    return-void
.end method

.method private requestSwitchHttpsHttp(Lokhttp3/aa;)Lokhttp3/aa;
    .registers 4

    .line 3049
    iget-object v0, p1, Lokhttp3/aa;->a:Lokhttp3/t;

    .line 604
    invoke-virtual {v0}, Lokhttp3/t;->h()Lokhttp3/t$a;

    move-result-object v0

    .line 3106
    iget-object v1, p1, Lokhttp3/aa;->a:Lokhttp3/t;

    invoke-virtual {v1}, Lokhttp3/t;->b()Z

    move-result v1

    if-eqz v1, :cond_14

    const-string v1, "http"

    .line 606
    invoke-virtual {v0, v1}, Lokhttp3/t$a;->a(Ljava/lang/String;)Lokhttp3/t$a;

    goto :goto_19

    :cond_14
    const-string v1, "https"

    .line 608
    invoke-virtual {v0, v1}, Lokhttp3/t$a;->a(Ljava/lang/String;)Lokhttp3/t$a;

    .line 610
    :goto_19
    invoke-virtual {p1}, Lokhttp3/aa;->a()Lokhttp3/aa$a;

    move-result-object p1

    invoke-virtual {v0}, Lokhttp3/t$a;->b()Lokhttp3/t;

    move-result-object v0

    invoke-virtual {p1, v0}, Lokhttp3/aa$a;->a(Lokhttp3/t;)Lokhttp3/aa$a;

    move-result-object p1

    invoke-virtual {p1}, Lokhttp3/aa$a;->a()Lokhttp3/aa;

    move-result-object p1

    return-object p1
.end method

.method private sendContent(Ljava/lang/String;Lsg/bigo/sdk/blivestat/database/StatCacheDao;Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;)V
    .registers 14

    .line 527
    invoke-static {p1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;

    move-result-object v0

    const-string v1, "sendContent url:"

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

    move-result-object v0

    const-string v1, "BLiveStatisSDK"

    invoke-static {v1, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 530
    invoke-virtual {p2}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getValue()[B

    move-result-object v0

    if-nez v0, :cond_1b

    if-eqz p3, :cond_1a

    .line 533
    invoke-interface {p3}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;->onSuc()V

    :cond_1a
    return-void

    .line 542
    :cond_1b
    new-instance v1, Lokhttp3/aa$a;

    invoke-direct {v1}, Lokhttp3/aa$a;-><init>()V

    .line 543
    new-instance v2, Ljava/lang/StringBuilder;

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

    sget-object v3, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sUserAgent:Ljava/lang/String;

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

    const-string v3, " "

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

    iget-object v3, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mConfig:Lsg/bigo/sdk/blivestat/config/StatisConfig;

    invoke-static {v3}, Lsg/bigo/sdk/blivestat/utils/StatAccountChangeHelper;->getAccountInfo(Lsg/bigo/sdk/blivestat/config/IStatisConfig;)Ljava/lang/String;

    move-result-object v3

    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

    const-string v3, "User-Agent"

    .line 544
    invoke-virtual {v1, v3, v2}, Lokhttp3/aa$a;->a(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/aa$a;

    .line 547
    invoke-direct {p0, v0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->compress([B)[B

    move-result-object v2

    if-eqz v2, :cond_4f

    const-string v0, "Content-Encoding"

    const-string v3, "gzip"

    .line 549
    invoke-virtual {v1, v0, v3}, Lokhttp3/aa$a;->a(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/aa$a;

    move-object v0, v2

    .line 554
    :cond_4f
    array-length v2, v0

    invoke-static {v2}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;

    move-result-object v2

    const-string v3, "data-len"

    invoke-virtual {v1, v3, v2}, Lokhttp3/aa$a;->a(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/aa$a;

    .line 556
    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mAesCipher:Lsg/bigo/sdk/blivestat/utils/AesCipher;

    invoke-virtual {v2, v0}, Lsg/bigo/sdk/blivestat/utils/AesCipher;->encryptByAES([B)[B

    move-result-object v2

    if-eqz v2, :cond_65

    const/4 v0, 0x1

    move-object v0, v2

    const/4 v2, 0x1

    goto :goto_66

    :cond_65
    const/4 v2, 0x0

    .line 562
    :goto_66
    sget-object v3, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->MEDIA_TYPE_TEXT:Lokhttp3/v;

    .line 2080
    array-length v4, v0

    invoke-static {v3, v0, v4}, Lokhttp3/ab;->a(Lokhttp3/v;[BI)Lokhttp3/ab;

    move-result-object v3

    .line 563
    invoke-static {p1, v2}, Lsg/bigo/sdk/blivestat/utils/Utils;->addSuffixForEncrypt(Ljava/lang/String;Z)Ljava/lang/String;

    move-result-object p1

    invoke-virtual {v1, p1}, Lokhttp3/aa$a;->a(Ljava/lang/String;)Lokhttp3/aa$a;

    const-string p1, "POST"

    .line 2232
    invoke-virtual {v1, p1, v3}, Lokhttp3/aa$a;->a(Ljava/lang/String;Lokhttp3/ab;)Lokhttp3/aa$a;

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

    move-result-wide v2

    .line 567
    new-instance v8, Ljava/util/ArrayList;

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

    .line 568
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mEventRecTimeMap:Ljava/util/HashMap;

    invoke-virtual {p2}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;

    move-result-object v4

    invoke-virtual {p1, v4}, Ljava/util/HashMap;->containsKey(Ljava/lang/Object;)Z

    move-result p1

    if-eqz p1, :cond_c9

    .line 570
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mEventRecTimeMap:Ljava/util/HashMap;

    invoke-virtual {p2}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;

    move-result-object p2

    invoke-virtual {p1, p2}, Ljava/util/HashMap;->remove(Ljava/lang/Object;)Ljava/lang/Object;

    move-result-object p1

    check-cast p1, Ljava/util/List;

    .line 571
    invoke-interface {p1}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object p1

    :cond_9e
    :goto_9e
    invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z

    move-result p2

    if-eqz p2, :cond_c9

    invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object p2

    check-cast p2, Landroid/util/Pair;

    .line 572
    iget-object v4, p2, Landroid/util/Pair;->second:Ljava/lang/Object;

    check-cast v4, Ljava/lang/Long;

    invoke-virtual {v4}, Ljava/lang/Long;->longValue()J

    move-result-wide v4

    sub-long v4, v2, v4

    const-wide/16 v6, 0x0

    cmp-long v9, v4, v6

    if-lez v9, :cond_9e

    .line 574
    new-instance v6, Landroid/util/Pair;

    iget-object p2, p2, Landroid/util/Pair;->first:Ljava/lang/Object;

    invoke-static {v4, v5}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;

    move-result-object v4

    invoke-direct {v6, p2, v4}, Landroid/util/Pair;-><init>(Ljava/lang/Object;Ljava/lang/Object;)V

    invoke-interface {v8, v6}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    goto :goto_9e

    :cond_c9
    const/4 v5, 0x2

    .line 578
    array-length v6, v0

    invoke-virtual {v1}, Lokhttp3/aa$a;->a()Lokhttp3/aa;

    move-result-object v7

    move-object v4, p0

    move-object v9, p3

    invoke-direct/range {v4 .. v9}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->doHttpSend(IILokhttp3/aa;Ljava/util/List;Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;)V

    return-void
.end method

.method private sendSyncByTrying(Ljava/lang/String;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    .registers 4

    .line 425
    new-instance v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$4;

    invoke-direct {v0, p0, p2}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$4;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V

    invoke-direct {p0, p1, p2, v0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendContent(Ljava/lang/String;Lsg/bigo/sdk/blivestat/database/StatCacheDao;Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$ISendContentListener;)V

    return-void
.end method

.method private trySendContent(Z)V
    .registers 7

    .line 314
    iget-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCanSendInBackground:Z

    const-string v1, "BLiveStatisSDK"

    if-nez v0, :cond_10

    iget-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mInBackground:Z

    if-eqz v0, :cond_10

    const-string p1, "trySendContent return, in background now, can not send stats in background"

    .line 315
    invoke-static {v1, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    return-void

    .line 320
    :cond_10
    iget-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->isNetworkAvailable:Z

    if-nez v0, :cond_2e

    invoke-static {}, Lsg/bigo/common/p;->b()Z

    move-result v0

    if-nez v0, :cond_2e

    .line 321
    new-instance p1, Ljava/lang/StringBuilder;

    const-string v0, "trySendContent return, network is unavailable, isNetworkAvailable="

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

    iget-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->isNetworkAvailable:Z

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

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

    move-result-object p1

    invoke-static {v1, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->w(Ljava/lang/String;Ljava/lang/String;)V

    return-void

    .line 325
    :cond_2e
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    invoke-virtual {v0}, Ljava/util/concurrent/Semaphore;->tryAcquire()Z

    move-result v0

    if-nez v0, :cond_37

    return-void

    .line 331
    :cond_37
    :try_start_37
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->getMaxRequest()I

    move-result v0

    iput v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->maxCall:I

    .line 332
    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v2}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->getCurRunCallCount()I

    move-result v2
    :try_end_45
    .catch Ljava/lang/Exception; {:try_start_37 .. :try_end_45} :catch_ea
    .catchall {:try_start_37 .. :try_end_45} :catchall_e8

    sub-int/2addr v0, v2

    if-gtz v0, :cond_4e

    .line 367
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    invoke-virtual {p1}, Ljava/util/concurrent/Semaphore;->release()V

    return-void

    .line 337
    :cond_4e
    :try_start_4e
    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {v2}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I

    move-result v2

    if-gtz v2, :cond_64

    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v2}, Ljava/util/concurrent/ConcurrentLinkedQueue;->size()I

    move-result v2

    if-gtz v2, :cond_64

    .line 338
    iget-wide v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDivideTime:J

    const/4 v4, 0x1

    invoke-direct {p0, v2, v3, v4, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->addContentFromCache(JZZ)V

    .line 341
    :cond_64
    new-instance p1, Ljava/lang/StringBuilder;

    const-string v2, "trySendContent pendingList:"

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

    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {v2}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I

    move-result v2

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

    const-string v2, ",sendingSize:"

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

    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v2}, Ljava/util/concurrent/ConcurrentLinkedQueue;->size()I

    move-result v2

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

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

    move-result-object p1

    invoke-static {v1, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 343
    new-instance p1, Ljava/util/ArrayList;

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

    .line 344
    :goto_8e
    iget-object v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {v2}, Ljava/util/concurrent/PriorityBlockingQueue;->isEmpty()Z

    move-result v2

    if-nez v2, :cond_a5

    add-int/lit8 v2, v0, -0x1

    if-lez v0, :cond_a5

    .line 345
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {v0}, Ljava/util/concurrent/PriorityBlockingQueue;->poll()Ljava/lang/Object;

    move-result-object v0

    invoke-interface {p1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    move v0, v2

    goto :goto_8e

    .line 348
    :cond_a5
    invoke-interface {p1}, Ljava/util/List;->isEmpty()Z

    move-result v0
    :try_end_a9
    .catch Ljava/lang/Exception; {:try_start_4e .. :try_end_a9} :catch_ea
    .catchall {:try_start_4e .. :try_end_a9} :catchall_e8

    if-eqz v0, :cond_b1

    .line 367
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    invoke-virtual {p1}, Ljava/util/concurrent/Semaphore;->release()V

    return-void

    .line 352
    :cond_b1
    :try_start_b1
    invoke-interface {p1}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object p1

    :cond_b5
    :goto_b5
    invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z

    move-result v0

    if-eqz v0, :cond_e2

    invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lsg/bigo/sdk/blivestat/database/StatCacheDao;

    if-eqz v0, :cond_b5

    .line 356
    invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getDataType()I

    move-result v2

    invoke-direct {p0, v2}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->getSendUrl(I)Ljava/lang/String;

    move-result-object v2

    .line 357
    invoke-static {v2}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z

    move-result v3

    if-nez v3, :cond_b5

    .line 358
    iget-object v3, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v3, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->contains(Ljava/lang/Object;)Z

    move-result v3

    if-nez v3, :cond_b5

    .line 359
    iget-object v3, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSendingList:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v3, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z

    .line 360
    invoke-direct {p0, v2, v0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendSyncByTrying(Ljava/lang/String;Lsg/bigo/sdk/blivestat/database/StatCacheDao;)V
    :try_end_e1
    .catch Ljava/lang/Exception; {:try_start_b1 .. :try_end_e1} :catch_ea
    .catchall {:try_start_b1 .. :try_end_e1} :catchall_e8

    goto :goto_b5

    .line 367
    :cond_e2
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    invoke-virtual {p1}, Ljava/util/concurrent/Semaphore;->release()V

    return-void

    :catchall_e8
    move-exception p1

    goto :goto_106

    :catch_ea
    move-exception p1

    .line 365
    :try_start_eb
    new-instance v0, Ljava/lang/StringBuilder;

    const-string v2, "trySendContent error:"

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

    invoke-virtual {p1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;

    move-result-object p1

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

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

    move-result-object p1

    invoke-static {v1, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
    :try_end_100
    .catchall {:try_start_eb .. :try_end_100} :catchall_e8

    .line 367
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    invoke-virtual {p1}, Ljava/util/concurrent/Semaphore;->release()V

    return-void

    :goto_106
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sendLock:Ljava/util/concurrent/Semaphore;

    invoke-virtual {v0}, Ljava/util/concurrent/Semaphore;->release()V

    goto :goto_10d

    :goto_10c
    throw p1

    :goto_10d
    goto :goto_10c
.end method


# virtual methods
.method public final checkAndDelaySend()V
    .registers 6

    .line 265
    monitor-enter p0

    .line 267
    :try_start_1
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->deleteUselessData()V

    .line 268
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    const/16 v1, 0x5dc

    invoke-virtual {v0, v1}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->getDivideTime(I)J

    move-result-wide v0

    const-string v2, "BLiveStatisSDK"

    const-string v3, "checkNeedDelaySend divideTime="

    .line 269
    invoke-static {v0, v1}, Ljava/lang/String;->valueOf(J)Ljava/lang/String;

    move-result-object v4

    invoke-virtual {v3, v4}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;

    move-result-object v3

    invoke-static {v2, v3}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V

    const-wide/16 v2, 0x0

    cmp-long v4, v0, v2

    if-lez v4, :cond_36

    .line 273
    iput-wide v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDivideTime:J

    .line 274
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDelaySendTask:Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;

    if-nez v0, :cond_30

    .line 275
    new-instance v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;

    invoke-direct {v0, p0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;)V

    iput-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDelaySendTask:Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;

    .line 277
    :cond_30
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDelaySendTask:Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;

    # invokes: Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;->startSendDataDelay()V
    invoke-static {v0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;->access$300(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$DelaySendTask;)V

    goto :goto_38

    .line 279
    :cond_36
    iput-wide v2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDivideTime:J

    .line 281
    :goto_38
    monitor-exit p0

    return-void

    :catchall_3a
    move-exception v0

    monitor-exit p0
    :try_end_3c
    .catchall {:try_start_1 .. :try_end_3c} :catchall_3a

    throw v0
.end method

.method public final debugHttp(Ljava/util/List;Lokhttp3/p;)V
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/List<",
            "Lokhttp3/u;",
            ">;",
            "Lokhttp3/p;",
            ")V"
        }
    .end annotation

    .line 748
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0, p1, p2}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->config(Ljava/util/List;Lokhttp3/p;)V

    return-void
.end method

.method public final onEnterBackground()V
    .registers 2

    const/4 v0, 0x1

    .line 249
    iput-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mInBackground:Z

    return-void
.end method

.method public final onEnterForeground()V
    .registers 2

    const/4 v0, 0x0

    .line 244
    iput-boolean v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mInBackground:Z

    return-void
.end method

.method public final onNetworkAvailableChanged(Z)V
    .registers 2

    return-void
.end method

.method public final onNetworkStateChange(I)V
    .registers 2

    return-void
.end method

.method public final reportEvent(ILjava/lang/String;Ljava/util/HashMap;ILjava/util/List;)V
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(I",
            "Ljava/lang/String;",
            "Ljava/util/HashMap<",
            "Ljava/lang/String;",
            "Ljava/lang/String;",
            ">;I",
            "Ljava/util/List<",
            "Landroid/util/Pair<",
            "Ljava/lang/String;",
            "Ljava/lang/Long;",
            ">;>;)V"
        }
    .end annotation

    .line 310
    new-instance p1, Ljava/lang/UnsupportedOperationException;

    const-string p2, "http only support send byte stream"

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

    throw p1
.end method

.method public final reportEventData(ILsg/bigo/sdk/blivestat/info/basestat/proto/IInfo;ILjava/util/List;)V
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(I",
            "Lsg/bigo/sdk/blivestat/info/basestat/proto/IInfo;",
            "I",
            "Ljava/util/List<",
            "Landroid/util/Pair<",
            "Ljava/lang/String;",
            "Ljava/lang/Long;",
            ">;>;)V"
        }
    .end annotation

    .line 304
    new-instance p1, Ljava/lang/UnsupportedOperationException;

    const-string p2, "http only support send byte stream"

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

    throw p1
.end method

.method public final reportEventData(I[BILjava/util/List;)V
    .registers 7
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(I[BI",
            "Ljava/util/List<",
            "Landroid/util/Pair<",
            "Ljava/lang/String;",
            "Ljava/lang/Long;",
            ">;>;)V"
        }
    .end annotation

    const/4 v0, 0x0

    const/16 v1, 0xa

    if-lt p3, v1, :cond_7

    const/4 v1, 0x1

    goto :goto_8

    :cond_7
    const/4 v1, 0x0

    .line 289
    :goto_8
    invoke-direct {p0, p1, p2, p3}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->getStatCacheDao(I[BI)Lsg/bigo/sdk/blivestat/database/StatCacheDao;

    move-result-object p1

    .line 290
    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mDbFactory:Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;

    invoke-virtual {p2, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDbFactory;->insert(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)Z

    if-eqz v1, :cond_22

    .line 292
    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {p2}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I

    move-result p2

    const/16 p3, 0x12c

    if-ge p2, p3, :cond_22

    .line 293
    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mPendingQueue:Ljava/util/concurrent/PriorityBlockingQueue;

    invoke-virtual {p2, p1}, Ljava/util/concurrent/PriorityBlockingQueue;->add(Ljava/lang/Object;)Z

    :cond_22
    if-eqz p4, :cond_33

    .line 296
    invoke-interface {p4}, Ljava/util/List;->isEmpty()Z

    move-result p2

    if-nez p2, :cond_33

    .line 297
    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mEventRecTimeMap:Ljava/util/HashMap;

    invoke-virtual {p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1, p4}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

    .line 299
    :cond_33
    invoke-direct {p0, v0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->trySendContent(Z)V

    return-void
.end method

.method public final setBackupAddressIP([Ljava/lang/String;)V
    .registers 3

    .line 212
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->setBackupAddressIP([Ljava/lang/String;)V

    return-void
.end method

.method public final setBackupHost(Ljava/lang/String;)V
    .registers 3

    .line 197
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->setBackupHostJson(Ljava/lang/String;)V

    return-void
.end method

.method public final setCanSendInBackground(Z)V
    .registers 2

    .line 170
    iput-boolean p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCanSendInBackground:Z

    return-void
.end method

.method public final setExternDns(Lsg/bigo/sdk/blivestat/config/IDnsConfig;)V
    .registers 3

    if-eqz p1, :cond_7

    .line 206
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0, p1}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->setExternDns(Lsg/bigo/sdk/blivestat/config/IDnsConfig;)V

    :cond_7
    return-void
.end method

.method public final setLogExtra(Ljava/util/HashMap;)V
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/HashMap<",
            "Ljava/lang/String;",
            "Ljava/lang/String;",
            ">;)V"
        }
    .end annotation

    return-void
.end method

.method public final setMaxRequests(I)V
    .registers 3

    .line 224
    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mHttpUtils:Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;

    invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/sender/http/HttpUtils;->getHttpClient()Lokhttp3/x;

    move-result-object v0

    .line 1390
    iget-object v0, v0, Lokhttp3/x;->c:Lokhttp3/n;

    .line 224
    invoke-virtual {v0, p1}, Lokhttp3/n;->a(I)V

    return-void
.end method

.method public final setReportUrl(ILjava/lang/String;)V
    .registers 4

    const-string v0, "http://45.255.127.143:9230/stats"

    .line 175
    invoke-virtual {p0, p1, p2, v0}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->setReportUrl(ILjava/lang/String;Ljava/lang/String;)V

    return-void
.end method

.method public final setReportUrl(ILjava/lang/String;Ljava/lang/String;)V
    .registers 6

    .line 187
    invoke-static {p3, p2}, Landroid/text/TextUtils;->equals(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Z

    move-result v0

    if-nez v0, :cond_18

    const/4 v0, 0x2

    new-array v0, v0, [Ljava/lang/String;

    const/4 v1, 0x0

    aput-object p2, v0, v1

    const/4 p2, 0x1

    aput-object p3, v0, p2

    .line 191
    iget-object p2, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mReportUrlConfig:Landroid/util/SparseArray;

    invoke-virtual {p2, p1, v0}, Landroid/util/SparseArray;->put(ILjava/lang/Object;)V

    .line 192
    invoke-virtual {p0, v1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->triggerSend(Z)V

    return-void

    .line 188
    :cond_18
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string p2, "debug and official url is same!!"

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

    throw p1
.end method

.method public final setSenderCallback(Lsg/bigo/sdk/blivestat/IStatisSenderCallback;)V
    .registers 2

    .line 591
    iput-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSenderCallback:Lsg/bigo/sdk/blivestat/IStatisSenderCallback;

    return-void
.end method

.method public final setSenderResultCallback(Lsg/bigo/sdk/blivestat/sender/ISenderResultCallback;)V
    .registers 3

    .line 146
    new-instance v0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$2;

    invoke-direct {v0, p0, p1}, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender$2;-><init>(Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;Lsg/bigo/sdk/blivestat/sender/ISenderResultCallback;)V

    iput-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mSenderResultCallback:Lsg/bigo/sdk/blivestat/sender/ISenderResultCallback;

    return-void
.end method

.method public final setUserAgent(Ljava/lang/String;)V
    .registers 3

    .line 217
    invoke-static {p1}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z

    move-result v0

    if-nez v0, :cond_8

    .line 218
    sput-object p1, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->sUserAgent:Ljava/lang/String;

    :cond_8
    return-void
.end method

.method public final triggerSend(Z)V
    .registers 4

    .line 235
    invoke-static {p1}, Ljava/lang/String;->valueOf(Z)Ljava/lang/String;

    move-result-object v0

    const-string v1, "triggerSend check cache, onlyCheckDauCache: "

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

    move-result-object v0

    const-string v1, "BLiveStatisSDK"

    invoke-static {v1, v0}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V

    .line 236
    iput-boolean p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mOnlyCheckDauCache:Z

    .line 237
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendFuture:Ljava/util/concurrent/Future;

    invoke-virtual {p1, v0}, Lsg/bigo/sdk/blivestat/utils/StatThread;->cancel(Ljava/util/concurrent/Future;)V

    const/4 p1, 0x0

    .line 238
    iput-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendFuture:Ljava/util/concurrent/Future;

    .line 239
    iget-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;

    iget-object v0, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendTask:Ljava/lang/Runnable;

    invoke-virtual {p1, v0}, Lsg/bigo/sdk/blivestat/utils/StatThread;->post(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;

    move-result-object p1

    iput-object p1, p0, Lsg/bigo/sdk/blivestat/sender/http/BLiveStatisHttpSender;->mCommonSendFuture:Ljava/util/concurrent/Future;

    return-void
.end method