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