StatCacheTable.smali
.class Lsg/bigo/sdk/blivestat/database/StatCacheTable;
.super Ljava/lang/Object;
.source "SourceFile"
# static fields
.field private static final ACTION_INTERVAL:J = 0x3e8L
.field private static final COLUMN_CREATE_TIME:Ljava/lang/String; = "create_time"
.field private static final COLUMN_DATA_TYPE:Ljava/lang/String; = "data_type"
.field private static final COLUMN_KEY:Ljava/lang/String; = "value_key"
.field private static final COLUMN_LENGTH:Ljava/lang/String; = "value_length"
.field private static final COLUMN_PRIORITY:Ljava/lang/String; = "priority"
.field private static final COLUMN_VALUE:Ljava/lang/String; = "value"
.field static final CURRENT_DB_VERSION:I = 0x4
.field private static final G_TAG:Ljava/lang/String; = "BLiveStatisSDK"
.field private static final MAX_ACTION_SIZE:I = 0x14
.field private static volatile sExpireTime:J = 0x48190800L
.field private static volatile sMaxCacheCount:J = 0x186a0L
# instance fields
.field private final CACHE_TABLE_NAME:Ljava/lang/String;
.field private final STAT_DIR:Ljava/lang/String;
.field private final mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
.field private final mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
.field private final sCacheDeleteData: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 sCacheInsertData: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 sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.field private final sDeleteRunnable:Ljava/lang/Runnable;
.field private sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.field private final sInsertRunnable:Ljava/lang/Runnable;
.field private final sWriteLock:Ljava/util/concurrent/Semaphore;
# direct methods
.method static constructor <clinit>()V
.registers 0
return-void
.end method
.method public constructor <init>(ILsg/bigo/sdk/blivestat/database/StatCacheDbHelper;Lsg/bigo/sdk/blivestat/utils/StatThread;)V
.registers 7
.line 47
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
const-string v0, "/stat/"
.line 39
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->STAT_DIR:Ljava/lang/String;
.line 141
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
const/4 v0, 0x0
.line 142
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.line 143
new-instance v1, Lsg/bigo/sdk/blivestat/database/StatCacheTable$1;
invoke-direct {v1, p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable$1;-><init>(Lsg/bigo/sdk/blivestat/database/StatCacheTable;)V
iput-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertRunnable:Ljava/lang/Runnable;
.line 150
new-instance v1, Ljava/util/concurrent/Semaphore;
const/4 v2, 0x1
invoke-direct {v1, v2}, Ljava/util/concurrent/Semaphore;-><init>(I)V
iput-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
.line 217
new-instance v1, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
iput-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
.line 218
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.line 219
new-instance v0, Lsg/bigo/sdk/blivestat/database/StatCacheTable$2;
invoke-direct {v0, p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable$2;-><init>(Lsg/bigo/sdk/blivestat/database/StatCacheTable;)V
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteRunnable:Ljava/lang/Runnable;
.line 48
invoke-static {p1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object p1
const-string v0, "stat_cache_"
invoke-virtual {v0, p1}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object p1
iput-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
.line 49
new-instance p1, Ljava/lang/StringBuilder;
const-string v0, "Create stat cache table: "
invoke-direct {p1, v0}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
const-string v0, "BLiveStatisSDK"
invoke-static {v0, p1}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 50
iput-object p2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
.line 51
iput-object p3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
return-void
.end method
.method static synthetic access$000(Lsg/bigo/sdk/blivestat/database/StatCacheTable;)V
.registers 1
.line 23
invoke-direct {p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->insertAllCache()V
return-void
.end method
.method static synthetic access$100(Lsg/bigo/sdk/blivestat/database/StatCacheTable;)V
.registers 1
.line 23
invoke-direct {p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->deleteAllCache()V
return-void
.end method
.method private databaseAlertForV4()Ljava/lang/String;
.registers 3
.line 55
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "ALTER TABLE "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, " ADD COLUMN data_type INTEGER DEFAULT 0;"
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
return-object v0
.end method
.method private deleteAllCache()V
.registers 11
const-string v0, "BLiveStatisSDK"
.line 227
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->isEmpty()Z
move-result v1
if-eqz v1, :cond_e
const/4 v0, 0x0
.line 228
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
return-void
.line 231
:cond_e
new-instance v1, Ljava/util/concurrent/ConcurrentLinkedQueue;
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v1, v2}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>(Ljava/util/Collection;)V
.line 232
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v2}, Ljava/util/concurrent/ConcurrentLinkedQueue;->clear()V
.line 233
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v2}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getWritableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v2
.line 234
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v3
.line 236
:try_start_24
iget-object v5, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
invoke-virtual {v5}, Ljava/util/concurrent/Semaphore;->acquire()V
.line 237
invoke-virtual {v2}, Landroid/database/sqlite/SQLiteDatabase;->beginTransaction()V
.line 238
invoke-virtual {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->iterator()Ljava/util/Iterator;
move-result-object v5
:goto_30
invoke-interface {v5}, Ljava/util/Iterator;->hasNext()Z
move-result v6
if-eqz v6, :cond_4e
invoke-interface {v5}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v6
check-cast v6, Lsg/bigo/sdk/blivestat/database/StatCacheDao;
const-string v7, "value_key = ?"
const/4 v8, 0x1
new-array v8, v8, [Ljava/lang/String;
const/4 v9, 0x0
.line 240
invoke-virtual {v6}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;
move-result-object v6
aput-object v6, v8, v9
.line 241
iget-object v6, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v2, v6, v7, v8}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
goto :goto_30
.line 243
:cond_4e
invoke-virtual {v2}, Landroid/database/sqlite/SQLiteDatabase;->setTransactionSuccessful()V
:try_end_51
.catch Ljava/lang/Exception; {:try_start_24 .. :try_end_51} :catch_5c
.catchall {:try_start_24 .. :try_end_51} :catchall_5a
.line 247
:goto_51
invoke-virtual {v2}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 248
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
invoke-virtual {v2}, Ljava/util/concurrent/Semaphore;->release()V
goto :goto_73
:catchall_5a
move-exception v0
goto :goto_a2
:catch_5c
move-exception v5
.line 245
:try_start_5d
new-instance v6, Ljava/lang/StringBuilder;
const-string v7, "deleteAllCache error:"
invoke-direct {v6, v7}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v5}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v5
invoke-virtual {v6, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v6}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v5
invoke-static {v0, v5}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
:try_end_72
.catchall {:try_start_5d .. :try_end_72} :catchall_5a
goto :goto_51
.line 250
:goto_73
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v5, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteRunnable:Ljava/lang/Runnable;
const-wide/16 v6, 0x3e8
invoke-virtual {v2, v5, v6, v7}, Lsg/bigo/sdk/blivestat/utils/StatThread;->postDelay(Ljava/lang/Runnable;J)Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
move-result-object v2
iput-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.line 251
new-instance v2, Ljava/lang/StringBuilder;
const-string v5, "deleteAllCache size:"
invoke-direct {v2, v5}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->size()I
move-result v1
invoke-virtual {v2, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v1, " ,cost:"
invoke-virtual {v2, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v5
sub-long/2addr v5, v3
invoke-virtual {v2, v5, v6}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v0, v1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return-void
.line 247
:goto_a2
invoke-virtual {v2}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 248
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
invoke-virtual {v1}, Ljava/util/concurrent/Semaphore;->release()V
goto :goto_ac
:goto_ab
throw v0
:goto_ac
goto :goto_ab
.end method
.method private deleteExceedCacheData()V
.registers 8
.line 391
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getWritableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
.line 392
invoke-virtual {p0, v0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->dataSizeInDb(Landroid/database/sqlite/SQLiteDatabase;)I
move-result v1
int-to-long v2, v1
.line 393
sget-wide v4, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sMaxCacheCount:J
cmp-long v6, v2, v4
if-gez v6, :cond_12
return-void
.line 396
:cond_12
invoke-static {v1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v1
const-string v2, "will deleteExceedCacheData dataSize="
invoke-virtual {v2, v1}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object v1
const-string v2, "BLiveStatisSDK"
invoke-static {v2, v1}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 397
new-instance v1, Ljava/lang/StringBuilder;
const-string v3, "DELETE FROM "
invoke-direct {v1, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " WHERE value_key NOT IN ( SELECT value_key FROM "
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " ORDER BY create_time DESC LIMIT "
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
sget-wide v3, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sMaxCacheCount:J
invoke-virtual {v1, v3, v4}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
const-string v3, " )"
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
.line 403
:try_start_4a
invoke-virtual {v0, v1}, Landroid/database/sqlite/SQLiteDatabase;->execSQL(Ljava/lang/String;)V
const-string v0, "deleteExceedCacheData finish"
.line 404
invoke-static {v2, v0}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V
:try_end_52
.catch Ljava/lang/Exception; {:try_start_4a .. :try_end_52} :catch_53
return-void
:catch_53
move-exception v0
.line 406
new-instance v1, Ljava/lang/StringBuilder;
const-string v3, "deleteExceedCacheData error:"
invoke-direct {v1, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v0}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v0
invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v0, ",table:"
invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-static {v2, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
return-void
.end method
.method private deleteExpireData()V
.registers 7
const-string v0, "BLiveStatisSDK"
.line 375
invoke-static {}, Ljava/lang/System;->currentTimeMillis()J
move-result-wide v1
.line 376
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v3}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getWritableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v3
.line 377
new-instance v4, Ljava/lang/StringBuilder;
const-string v5, "DELETE FROM "
invoke-direct {v4, v5}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v5, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v5, " WHERE ("
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v1, v2}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
const-string v1, "-create_time) > "
invoke-virtual {v4, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
sget-wide v1, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sExpireTime:J
invoke-virtual {v4, v1, v2}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
.line 380
:try_start_2e
invoke-virtual {v3, v1}, Landroid/database/sqlite/SQLiteDatabase;->execSQL(Ljava/lang/String;)V
const-string v1, "deleteExpireData"
.line 381
invoke-static {v0, v1}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V
:try_end_36
.catch Ljava/lang/Exception; {:try_start_2e .. :try_end_36} :catch_37
return-void
:catch_37
move-exception v1
.line 383
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "deleteExpireData error:"
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v1
invoke-virtual {v2, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, ",table:"
invoke-virtual {v2, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v2, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v0, v1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
return-void
.end method
.method private deleteTableExistsId()V
.registers 4
.line 115
invoke-static {}, Lsg/bigo/common/a;->d()Landroid/content/Context;
move-result-object v0
.line 116
new-instance v1, Ljava/io/File;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
invoke-virtual {v0}, Landroid/content/Context;->getFilesDir()Ljava/io/File;
move-result-object v0
invoke-virtual {v0}, Ljava/io/File;->getAbsolutePath()Ljava/lang/String;
move-result-object v0
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v0, "/stat/"
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {v1, v0}, Ljava/io/File;-><init>(Ljava/lang/String;)V
.line 117
invoke-virtual {v1}, Ljava/io/File;->exists()Z
move-result v0
if-eqz v0, :cond_30
.line 118
invoke-virtual {v1}, Ljava/io/File;->delete()Z
:cond_30
return-void
.end method
.method private getStatCacheData(Ljava/lang/String;)Ljava/util/concurrent/PriorityBlockingQueue;
.registers 10
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
")",
"Ljava/util/concurrent/PriorityBlockingQueue<",
"Lsg/bigo/sdk/blivestat/database/StatCacheDao;",
">;"
}
.end annotation
.line 302
new-instance v0, Ljava/util/concurrent/PriorityBlockingQueue;
const/16 v1, 0x8
invoke-direct {v0, v1}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>(I)V
.line 303
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->isEmpty()Z
move-result v1
const/4 v2, 0x0
if-nez v1, :cond_1e
.line 304
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
invoke-virtual {v1, v3}, Lsg/bigo/sdk/blivestat/utils/StatThread;->cancelTask(Lsg/bigo/sdk/blivestat/utils/StatThread$Task;)V
.line 305
iput-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.line 306
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteRunnable:Ljava/lang/Runnable;
invoke-interface {v1}, Ljava/lang/Runnable;->run()V
.line 308
:cond_1e
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v1}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getReadableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v1
.line 309
invoke-virtual {v1, p1, v2}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p1
.line 311
:goto_28
invoke-interface {p1}, Landroid/database/Cursor;->moveToNext()Z
move-result v1
const-string v2, "BLiveStatisSDK"
if-eqz v1, :cond_91
.line 313
:try_start_30
new-instance v1, Lsg/bigo/sdk/blivestat/database/StatCacheDao;
invoke-direct {v1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;-><init>()V
const-string v3, "value_key"
.line 314
invoke-interface {p1, v3}, Landroid/database/Cursor;->getColumnIndexOrThrow(Ljava/lang/String;)I
move-result v3
const-string v4, "create_time"
.line 315
invoke-interface {p1, v4}, Landroid/database/Cursor;->getColumnIndexOrThrow(Ljava/lang/String;)I
move-result v4
const-string v5, "priority"
.line 316
invoke-interface {p1, v5}, Landroid/database/Cursor;->getColumnIndexOrThrow(Ljava/lang/String;)I
move-result v5
const-string v6, "value"
.line 317
invoke-interface {p1, v6}, Landroid/database/Cursor;->getColumnIndexOrThrow(Ljava/lang/String;)I
move-result v6
const-string v7, "data_type"
.line 318
invoke-interface {p1, v7}, Landroid/database/Cursor;->getColumnIndexOrThrow(Ljava/lang/String;)I
move-result v7
.line 320
invoke-interface {p1, v3}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v3
invoke-virtual {v1, v3}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setKey(Ljava/lang/String;)V
.line 321
invoke-interface {p1, v4}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v3
invoke-virtual {v1, v3, v4}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setCreateTime(J)V
.line 322
invoke-interface {p1, v5}, Landroid/database/Cursor;->getInt(I)I
move-result v3
invoke-virtual {v1, v3}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setPriority(I)V
.line 323
invoke-interface {p1, v6}, Landroid/database/Cursor;->getBlob(I)[B
move-result-object v3
invoke-virtual {v1, v3}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setValue([B)V
.line 324
invoke-interface {p1, v7}, Landroid/database/Cursor;->getInt(I)I
move-result v3
invoke-virtual {v1, v3}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->setDataType(I)V
.line 325
invoke-virtual {v0, v1}, Ljava/util/concurrent/PriorityBlockingQueue;->add(Ljava/lang/Object;)Z
:try_end_79
.catch Ljava/lang/Exception; {:try_start_30 .. :try_end_79} :catch_7a
goto :goto_28
:catch_7a
move-exception v1
.line 327
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, "getStatCacheData error:"
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v1
invoke-virtual {v3, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
goto :goto_28
.line 330
:cond_91
invoke-interface {p1}, Landroid/database/Cursor;->close()V
.line 331
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->isEmpty()Z
move-result p1
if-nez p1, :cond_a1
.line 332
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/PriorityBlockingQueue;->addAll(Ljava/util/Collection;)Z
.line 334
:cond_a1
new-instance p1, Ljava/lang/StringBuilder;
const-string v1, "getStatCacheData dataSize is:"
invoke-direct {p1, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v0}, Ljava/util/concurrent/PriorityBlockingQueue;->size()I
move-result v1
invoke-virtual {p1, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
invoke-static {v2, p1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return-object v0
.end method
.method private insertAllCache()V
.registers 13
.line 153
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->isEmpty()Z
move-result v0
const/4 v1, 0x0
if-eqz v0, :cond_c
.line 154
iput-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
return-void
.line 157
:cond_c
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
const-string v2, "BLiveStatisSDK"
if-eqz v0, :cond_2f
.line 158
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "insert data from "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, " error "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-static {v2, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
return-void
.line 162
:cond_2f
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getWritableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
.line 163
new-instance v3, Ljava/util/concurrent/ConcurrentLinkedQueue;
iget-object v4, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v3, v4}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>(Ljava/util/Collection;)V
.line 164
iget-object v4, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v4}, Ljava/util/concurrent/ConcurrentLinkedQueue;->clear()V
.line 165
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v4
.line 167
:try_start_45
iget-object v6, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
invoke-virtual {v6}, Ljava/util/concurrent/Semaphore;->acquire()V
.line 168
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->beginTransaction()V
.line 169
invoke-virtual {v3}, Ljava/util/concurrent/ConcurrentLinkedQueue;->iterator()Ljava/util/Iterator;
move-result-object v6
:goto_51
invoke-interface {v6}, Ljava/util/Iterator;->hasNext()Z
move-result v7
if-eqz v7, :cond_af
invoke-interface {v6}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v7
check-cast v7, Lsg/bigo/sdk/blivestat/database/StatCacheDao;
.line 170
invoke-virtual {v7}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getValue()[B
move-result-object v8
array-length v8, v8
.line 171
new-instance v9, Landroid/content/ContentValues;
invoke-direct {v9}, Landroid/content/ContentValues;-><init>()V
const-string v10, "value_key"
.line 172
invoke-virtual {v7}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getKey()Ljava/lang/String;
move-result-object v11
invoke-virtual {v9, v10, v11}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
const-string v10, "value_length"
.line 173
invoke-static {v8}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v8
invoke-virtual {v9, v10, v8}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
const-string v8, "value"
.line 174
invoke-virtual {v7}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getValue()[B
move-result-object v10
invoke-virtual {v9, v8, v10}, Landroid/content/ContentValues;->put(Ljava/lang/String;[B)V
const-string v8, "priority"
.line 175
invoke-virtual {v7}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getPriority()I
move-result v10
invoke-static {v10}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v10
invoke-virtual {v9, v8, v10}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
const-string v8, "create_time"
.line 176
invoke-virtual {v7}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getCreateTime()J
move-result-wide v10
invoke-static {v10, v11}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v10
invoke-virtual {v9, v8, v10}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
const-string v8, "data_type"
.line 177
invoke-virtual {v7}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getDataType()I
move-result v7
invoke-static {v7}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v7
invoke-virtual {v9, v8, v7}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 178
iget-object v7, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v7, v1, v9}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
goto :goto_51
.line 180
:cond_af
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->setTransactionSuccessful()V
:try_end_b2
.catch Ljava/lang/Exception; {:try_start_45 .. :try_end_b2} :catch_bd
.catchall {:try_start_45 .. :try_end_b2} :catchall_bb
.line 184
:goto_b2
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 185
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
invoke-virtual {v0}, Ljava/util/concurrent/Semaphore;->release()V
goto :goto_d4
:catchall_bb
move-exception v1
goto :goto_103
:catch_bd
move-exception v1
.line 182
:try_start_be
new-instance v6, Ljava/lang/StringBuilder;
const-string v7, "insert error:"
invoke-direct {v6, v7}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v1
invoke-virtual {v6, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v6}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v2, v1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
:try_end_d3
.catchall {:try_start_be .. :try_end_d3} :catchall_bb
goto :goto_b2
.line 187
:goto_d4
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertRunnable:Ljava/lang/Runnable;
const-wide/16 v6, 0x3e8
invoke-virtual {v0, v1, v6, v7}, Lsg/bigo/sdk/blivestat/utils/StatThread;->postDelay(Ljava/lang/Runnable;J)Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
move-result-object v0
iput-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
.line 188
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "insert data size:"
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v3}, Ljava/util/concurrent/ConcurrentLinkedQueue;->size()I
move-result v1
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v1, ", cost:"
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J
move-result-wide v6
sub-long/2addr v6, v4
invoke-virtual {v0, v6, v7}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-static {v2, v0}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return-void
.line 184
:goto_103
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 185
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sWriteLock:Ljava/util/concurrent/Semaphore;
invoke-virtual {v0}, Ljava/util/concurrent/Semaphore;->release()V
goto :goto_10d
:goto_10c
throw v1
:goto_10d
goto :goto_10c
.end method
# virtual methods
.method dataSizeInDb(Landroid/database/sqlite/SQLiteDatabase;)I
.registers 7
.line 420
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
const/4 v1, 0x0
if-eqz v0, :cond_a
return v1
:cond_a
const-string v0, "sizeCount"
.line 426
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "SELECT count(*) as "
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " FROM "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
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/4 v3, 0x0
.line 428
invoke-virtual {p1, v2, v3}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p1
const-string v2, "BLiveStatisSDK"
if-nez p1, :cond_41
.line 431
new-instance p1, Ljava/lang/StringBuilder;
const-string v0, "dataSizeInDb cursor is null, table:"
invoke-direct {p1, v0}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
invoke-static {v2, p1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return v1
.line 437
:cond_41
:goto_41
:try_start_41
invoke-interface {p1}, Landroid/database/Cursor;->moveToNext()Z
move-result v3
if-eqz v3, :cond_50
.line 438
invoke-interface {p1, v0}, Landroid/database/Cursor;->getColumnIndex(Ljava/lang/String;)I
move-result v3
.line 439
invoke-interface {p1, v3}, Landroid/database/Cursor;->getInt(I)I
move-result v1
:try_end_4f
.catch Ljava/lang/Exception; {:try_start_41 .. :try_end_4f} :catch_56
.catchall {:try_start_41 .. :try_end_4f} :catchall_54
goto :goto_41
.line 444
:cond_50
:goto_50
invoke-interface {p1}, Landroid/database/Cursor;->close()V
goto :goto_77
:catchall_54
move-exception v0
goto :goto_85
:catch_56
move-exception v0
.line 442
:try_start_57
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, "get db size error:"
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v0}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v0
invoke-virtual {v3, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v0, ",table:"
invoke-virtual {v3, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v3, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-static {v2, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
:try_end_76
.catchall {:try_start_57 .. :try_end_76} :catchall_54
goto :goto_50
.line 446
:goto_77
invoke-static {v1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object p1
const-string v0, "cacheDB size:"
invoke-virtual {v0, p1}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object p1
invoke-static {v2, p1}, Lsg/bigo/sdk/blivestat/log/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V
return v1
.line 444
:goto_85
invoke-interface {p1}, Landroid/database/Cursor;->close()V
goto :goto_8a
:goto_89
throw v0
:goto_8a
goto :goto_89
.end method
.method delete(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)Z
.registers 7
.line 193
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
const-string v1, "BLiveStatisSDK"
if-nez v0, :cond_59
if-nez p1, :cond_d
goto :goto_59
.line 198
:cond_d
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
move-result v0
const/4 v2, 0x1
if-eqz v0, :cond_2c
.line 200
new-instance v0, Ljava/lang/StringBuilder;
const-string v3, "delete data key from memory:"
invoke-direct {v0, 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 {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/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return v2
.line 204
:cond_2c
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
.line 205
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheDeleteData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->size()I
move-result p1
const/16 v0, 0x14
if-le p1, v0, :cond_48
.line 206
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
invoke-virtual {p1, v0}, Lsg/bigo/sdk/blivestat/utils/StatThread;->cancelTask(Lsg/bigo/sdk/blivestat/utils/StatThread$Task;)V
.line 207
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteRunnable:Ljava/lang/Runnable;
invoke-interface {p1}, Ljava/lang/Runnable;->run()V
return v2
.line 210
:cond_48
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
if-nez p1, :cond_58
.line 211
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteRunnable:Ljava/lang/Runnable;
const-wide/16 v3, 0x3e8
invoke-virtual {p1, v0, v3, v4}, Lsg/bigo/sdk/blivestat/utils/StatThread;->postDelay(Ljava/lang/Runnable;J)Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
move-result-object p1
iput-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sDeleteFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
:cond_58
return v2
.line 194
:cond_59
:goto_59
new-instance p1, Ljava/lang/StringBuilder;
const-string v0, "delete data from "
invoke-direct {p1, v0}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v0, " error "
invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)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/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
const/4 p1, 0x0
return p1
.end method
.method deleteUselessData()V
.registers 1
.line 455
invoke-direct {p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->deleteExpireData()V
.line 456
invoke-direct {p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->deleteExceedCacheData()V
return-void
.end method
.method dropTable(Landroid/database/sqlite/SQLiteDatabase;)Z
.registers 4
.line 90
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, " DROP TABLE "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
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
.line 92
:try_start_10
invoke-virtual {p1, v0}, Landroid/database/sqlite/SQLiteDatabase;->execSQL(Ljava/lang/String;)V
:try_end_13
.catch Ljava/lang/Exception; {:try_start_10 .. :try_end_13} :catch_18
.line 97
invoke-direct {p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->deleteTableExistsId()V
const/4 p1, 0x1
return p1
:catch_18
move-exception p1
.line 94
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "dropTable statCacheTable error:"
invoke-direct {v0, v1}, 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
const-string v0, "BLiveStatisSDK"
invoke-static {v0, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
const/4 p1, 0x0
return p1
.end method
.method getDivideTime(I)J
.registers 8
const-wide/16 v0, -0x1
const-string v2, "BLiveStatisSDK"
if-gtz p1, :cond_14
.line 345
invoke-static {p1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object p1
const-string v3, "getDivideTime but limit="
invoke-virtual {v3, p1}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object p1
invoke-static {v2, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
return-wide v0
.line 348
:cond_14
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, " SELECT value_key ,create_time, priority, value FROM "
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v4, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v4, " ORDER BY create_time DESC LIMIT "
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v3
.line 352
iget-object v4, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v4}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getReadableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v4
const/4 v5, 0x0
.line 353
invoke-virtual {v4, v3, v5}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object v3
.line 356
:try_start_37
invoke-interface {v3}, Landroid/database/Cursor;->getCount()I
move-result v4
if-lt v4, p1, :cond_4a
.line 357
invoke-interface {v3}, Landroid/database/Cursor;->moveToLast()Z
const-string p1, "create_time"
.line 358
invoke-interface {v3, p1}, Landroid/database/Cursor;->getColumnIndexOrThrow(Ljava/lang/String;)I
move-result p1
.line 359
invoke-interface {v3, p1}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v0
:try_end_4a
.catch Ljava/lang/Exception; {:try_start_37 .. :try_end_4a} :catch_50
.catchall {:try_start_37 .. :try_end_4a} :catchall_4e
.line 364
:cond_4a
:goto_4a
invoke-interface {v3}, Landroid/database/Cursor;->close()V
goto :goto_67
:catchall_4e
move-exception p1
goto :goto_75
:catch_50
move-exception p1
.line 362
:try_start_51
new-instance v4, Ljava/lang/StringBuilder;
const-string v5, "getDivideTime error:"
invoke-direct {v4, v5}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {p1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object p1
invoke-virtual {v4, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
invoke-static {v2, p1}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
:try_end_66
.catchall {:try_start_51 .. :try_end_66} :catchall_4e
goto :goto_4a
.line 367
:goto_67
invoke-static {v0, v1}, Ljava/lang/String;->valueOf(J)Ljava/lang/String;
move-result-object p1
const-string v3, "getDivideTime divideTime is:"
invoke-virtual {v3, p1}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object p1
invoke-static {v2, p1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return-wide v0
.line 364
:goto_75
invoke-interface {v3}, Landroid/database/Cursor;->close()V
goto :goto_7a
:goto_79
throw p1
:goto_7a
goto :goto_79
.end method
.method getHighPriorityDataSizeInDb()I
.registers 7
.line 463
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
const/4 v1, 0x0
if-eqz v0, :cond_a
return v1
:cond_a
const-string v0, "sizeCount"
.line 468
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "SELECT count(1) as "
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " FROM "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " WHERE priority >= 99"
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
.line 469
iget-object v3, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v3}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getReadableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v3
const/4 v4, 0x0
.line 470
invoke-virtual {v3, v2, v4}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object v2
const-string v3, "BLiveStatisSDK"
if-nez v2, :cond_4c
.line 473
new-instance v0, Ljava/lang/StringBuilder;
const-string v2, "highPriorityDataSizeInDb cursor is null, table:"
invoke-direct {v0, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-static {v3, v0}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
return v1
.line 479
:cond_4c
:goto_4c
:try_start_4c
invoke-interface {v2}, Landroid/database/Cursor;->moveToNext()Z
move-result v4
if-eqz v4, :cond_5b
.line 480
invoke-interface {v2, v0}, Landroid/database/Cursor;->getColumnIndex(Ljava/lang/String;)I
move-result v4
.line 481
invoke-interface {v2, v4}, Landroid/database/Cursor;->getInt(I)I
move-result v1
:try_end_5a
.catch Ljava/lang/Exception; {:try_start_4c .. :try_end_5a} :catch_61
.catchall {:try_start_4c .. :try_end_5a} :catchall_5f
goto :goto_4c
.line 486
:cond_5b
:goto_5b
invoke-interface {v2}, Landroid/database/Cursor;->close()V
goto :goto_82
:catchall_5f
move-exception v0
goto :goto_83
:catch_61
move-exception v0
.line 484
:try_start_62
new-instance v4, Ljava/lang/StringBuilder;
const-string v5, "get db size error:"
invoke-direct {v4, v5}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v0}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object v0
invoke-virtual {v4, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v0, ",table:"
invoke-virtual {v4, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v4, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-static {v3, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
:try_end_81
.catchall {:try_start_62 .. :try_end_81} :catchall_5f
goto :goto_5b
:goto_82
return v1
.line 486
:goto_83
invoke-interface {v2}, Landroid/database/Cursor;->close()V
goto :goto_88
:goto_87
throw v0
:goto_88
goto :goto_87
.end method
.method getHighestStatCacheData()Ljava/util/concurrent/PriorityBlockingQueue;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/concurrent/PriorityBlockingQueue<",
"Lsg/bigo/sdk/blivestat/database/StatCacheDao;",
">;"
}
.end annotation
.line 495
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
if-eqz v0, :cond_25
.line 496
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "getHighestData TableName:"
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
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/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 497
new-instance v0, Ljava/util/concurrent/PriorityBlockingQueue;
const/16 v1, 0x8
invoke-direct {v0, v1}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>(I)V
return-object v0
.line 500
:cond_25
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, " SELECT value_key ,create_time, priority, value, data_type FROM "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, " WHERE priority>=99 ORDER BY create_time"
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
.line 503
invoke-direct {p0, v0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->getStatCacheData(Ljava/lang/String;)Ljava/util/concurrent/PriorityBlockingQueue;
move-result-object v0
return-object v0
.end method
.method getStatCacheData(I)Ljava/util/concurrent/PriorityBlockingQueue;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(I)",
"Ljava/util/concurrent/PriorityBlockingQueue<",
"Lsg/bigo/sdk/blivestat/database/StatCacheDao;",
">;"
}
.end annotation
.line 257
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
if-nez v0, :cond_28
if-gtz p1, :cond_b
goto :goto_28
.line 263
:cond_b
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, " SELECT value_key ,create_time, priority, value, data_type FROM "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, " ORDER BY create_time DESC LIMIT "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
.line 267
invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->getStatCacheData(Ljava/lang/String;)Ljava/util/concurrent/PriorityBlockingQueue;
move-result-object p1
return-object p1
.line 258
:cond_28
:goto_28
new-instance p1, Ljava/lang/StringBuilder;
const-string v0, "getStatCacheData TableName:"
invoke-direct {p1, v0}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
const-string v0, "BLiveStatisSDK"
invoke-static {v0, p1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 259
new-instance p1, Ljava/util/concurrent/PriorityBlockingQueue;
const/16 v0, 0x8
invoke-direct {p1, v0}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>(I)V
return-object p1
.end method
.method getStatCacheDataByTime(JZI)Ljava/util/concurrent/PriorityBlockingQueue;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(JZI)",
"Ljava/util/concurrent/PriorityBlockingQueue<",
"Lsg/bigo/sdk/blivestat/database/StatCacheDao;",
">;"
}
.end annotation
.line 278
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-static {v0}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z
move-result v0
if-nez v0, :cond_3a
if-gtz p4, :cond_b
goto :goto_3a
:cond_b
if-eqz p3, :cond_10
const-string p3, " >= "
goto :goto_12
:cond_10
const-string p3, " < "
.line 292
:goto_12
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, " SELECT value_key ,create_time, priority, value, data_type FROM "
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, " WHERE create_time"
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0, p1, p2}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
const-string p1, " ORDER BY priority DESC, create_time DESC LIMIT "
invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0, p4}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
.line 297
invoke-direct {p0, p1}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->getStatCacheData(Ljava/lang/String;)Ljava/util/concurrent/PriorityBlockingQueue;
move-result-object p1
return-object p1
.line 279
:cond_3a
:goto_3a
new-instance p1, Ljava/lang/StringBuilder;
const-string p2, "getDataBeforeTime TableName:"
invoke-direct {p1, p2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object p2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {p1, p2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)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/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 280
new-instance p1, Ljava/util/concurrent/PriorityBlockingQueue;
const/16 p2, 0x8
invoke-direct {p1, p2}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>(I)V
return-object p1
.end method
.method insert(Lsg/bigo/sdk/blivestat/database/StatCacheDao;)Z
.registers 6
if-eqz p1, :cond_37
.line 125
invoke-virtual {p1}, Lsg/bigo/sdk/blivestat/database/StatCacheDao;->getValue()[B
move-result-object v0
if-nez v0, :cond_9
goto :goto_37
.line 129
:cond_9
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
.line 130
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sCacheInsertData:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->size()I
move-result p1
const/16 v0, 0x14
const/4 v1, 0x1
if-le p1, v0, :cond_26
.line 131
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
invoke-virtual {p1, v0}, Lsg/bigo/sdk/blivestat/utils/StatThread;->cancelTask(Lsg/bigo/sdk/blivestat/utils/StatThread$Task;)V
.line 132
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertRunnable:Ljava/lang/Runnable;
invoke-interface {p1}, Ljava/lang/Runnable;->run()V
return v1
.line 135
:cond_26
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
if-nez p1, :cond_36
.line 136
iget-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mWorker:Lsg/bigo/sdk/blivestat/utils/StatThread;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertRunnable:Ljava/lang/Runnable;
const-wide/16 v2, 0x3e8
invoke-virtual {p1, v0, v2, v3}, Lsg/bigo/sdk/blivestat/utils/StatThread;->postDelay(Ljava/lang/Runnable;J)Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
move-result-object p1
iput-object p1, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sInsertFuture:Lsg/bigo/sdk/blivestat/utils/StatThread$Task;
:cond_36
return v1
:cond_37
:goto_37
const-string p1, "BLiveStatisSDK"
const-string v0, "insert value is null "
.line 126
invoke-static {p1, v0}, Lsg/bigo/sdk/blivestat/log/StatLog;->e(Ljava/lang/String;Ljava/lang/String;)V
const/4 p1, 0x0
return p1
.end method
.method onCheck()Z
.registers 4
.line 59
invoke-static {}, Lsg/bigo/common/a;->d()Landroid/content/Context;
move-result-object v0
.line 60
new-instance v1, Ljava/io/File;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
invoke-virtual {v0}, Landroid/content/Context;->getFilesDir()Ljava/io/File;
move-result-object v0
invoke-virtual {v0}, Ljava/io/File;->getAbsolutePath()Ljava/lang/String;
move-result-object v0
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v0, "/stat/"
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {v1, v0}, Ljava/io/File;-><init>(Ljava/lang/String;)V
.line 61
invoke-virtual {v1}, Ljava/io/File;->exists()Z
move-result v0
if-eqz v0, :cond_2f
const/4 v0, 0x1
return v0
.line 64
:cond_2f
iget-object v0, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->mCacheDbHelper:Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;
invoke-virtual {v0}, Lsg/bigo/sdk/blivestat/database/StatCacheDbHelper;->getWritableDatabase()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
invoke-virtual {p0, v0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->onCreate(Landroid/database/sqlite/SQLiteDatabase;)Z
move-result v0
return v0
.end method
.method onCreate(Landroid/database/sqlite/SQLiteDatabase;)Z
.registers 6
const-string v0, "BLiveStatisSDK"
.line 76
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "CREATE TABLE IF NOT EXISTS "
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v2, p0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->CACHE_TABLE_NAME:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v2, " (value_key VARCHAR(32) PRIMARY KEY NOT NULL, value_length INTEGER DEFAULT 0, value BLOB, priority INTEGER DEFAULT 0, create_time BIGINT(64), data_type INTEGER DEFAULT 0 )"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
.line 78
:try_start_17
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "onCreate path:"
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {p1}, Landroid/database/sqlite/SQLiteDatabase;->getPath()Ljava/lang/String;
move-result-object v3
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, ",version="
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Landroid/database/sqlite/SQLiteDatabase;->getVersion()I
move-result v3
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
invoke-static {v0, v2}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 79
invoke-virtual {p1, v1}, Landroid/database/sqlite/SQLiteDatabase;->execSQL(Ljava/lang/String;)V
:try_end_3b
.catch Ljava/lang/Exception; {:try_start_17 .. :try_end_3b} :catch_4a
.line 84
invoke-static {v1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;
move-result-object p1
const-string v1, "onCreate Table sql:"
invoke-virtual {v1, p1}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object p1
invoke-static {v0, p1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
const/4 p1, 0x1
return p1
:catch_4a
move-exception p1
.line 81
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "create statCacheTable error:"
invoke-direct {v1, 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 {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 p1
.end method
.method onUpgrade(Landroid/database/sqlite/SQLiteDatabase;I)Z
.registers 6
const-string v0, "BLiveStatisSDK"
.line 103
:try_start_2
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "onUpgrade from "
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v1, p2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, " to 4"
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-static {v0, v1}, Lsg/bigo/sdk/blivestat/log/InternalLog;->d(Ljava/lang/String;Ljava/lang/String;)V
const/4 v1, 0x4
if-ge p2, v1, :cond_22
.line 105
invoke-direct {p0}, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->databaseAlertForV4()Ljava/lang/String;
move-result-object p2
invoke-virtual {p1, p2}, Landroid/database/sqlite/SQLiteDatabase;->execSQL(Ljava/lang/String;)V
:try_end_22
.catch Ljava/lang/Exception; {:try_start_2 .. :try_end_22} :catch_24
:cond_22
const/4 p1, 0x1
return p1
:catch_24
move-exception p1
.line 108
new-instance p2, Ljava/lang/StringBuilder;
const-string v1, "onUpgrade error:"
invoke-direct {p2, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {p1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p2}, 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 p1
.end method
.method declared-synchronized setExpireTimeAndMaxCount(II)V
.registers 6
monitor-enter p0
mul-int/lit8 v0, p1, 0x18
mul-int/lit16 v0, v0, 0xe10
mul-int/lit16 v0, v0, 0x3e8
int-to-long v0, v0
.line 414
:try_start_8
sput-wide v0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sExpireTime:J
int-to-long v0, p2
.line 415
sput-wide v0, Lsg/bigo/sdk/blivestat/database/StatCacheTable;->sMaxCacheCount:J
const-string v0, "BLiveStatisSDK"
.line 416
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "setExpireTimeAndMaxCount dayNum=:"
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, " , maxCount="
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1, p2}, Ljava/lang/StringBuilder;->append(I)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/CoreStatLog;->i(Ljava/lang/String;Ljava/lang/String;)V
:try_end_28
.catchall {:try_start_8 .. :try_end_28} :catchall_2a
.line 417
monitor-exit p0
return-void
:catchall_2a
move-exception p1
monitor-exit p0
throw p1
.end method