SQLiteEventStore.smali
.class public Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;
.super Ljava/lang/Object;
.source "SQLiteEventStore.java"
# interfaces
.implements Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStore;
.implements Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;,
Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;,
Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;
}
.end annotation
.annotation runtime Ljavax/inject/Singleton;
.end annotation
# static fields
.field private static final LOCK_RETRY_BACK_OFF_MILLIS:I = 0x32
.field private static final LOG_TAG:Ljava/lang/String; = "SQLiteEventStore"
.field static final MAX_RETRIES:I = 0x10
.field private static final PROTOBUF_ENCODING:Lcom/google/android/datatransport/Encoding;
# instance fields
.field private final config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
.field private final monotonicClock:Lcom/google/android/datatransport/runtime/time/Clock;
.field private final schemaManager:Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
.field private final wallClock:Lcom/google/android/datatransport/runtime/time/Clock;
# direct methods
.method static constructor <clinit>()V
.registers 1
const-string v0, "proto"
.line 60
invoke-static {v0}, Lcom/google/android/datatransport/Encoding;->of(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
move-result-object v0
sput-object v0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->PROTOBUF_ENCODING:Lcom/google/android/datatransport/Encoding;
return-void
.end method
.method constructor <init>(Lcom/google/android/datatransport/runtime/time/Clock;Lcom/google/android/datatransport/runtime/time/Clock;Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;)V
.registers 5
.annotation runtime Ljavax/inject/Inject;
.end annotation
.line 72
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 74
iput-object p4, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->schemaManager:Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
.line 75
iput-object p1, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->wallClock:Lcom/google/android/datatransport/runtime/time/Clock;
.line 76
iput-object p2, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->monotonicClock:Lcom/google/android/datatransport/runtime/time/Clock;
.line 77
iput-object p3, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
return-void
.end method
.method private ensureBeginTransaction(Landroid/database/sqlite/SQLiteDatabase;)V
.registers 3
.line 537
invoke-static {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$18;->lambdaFactory$(Landroid/database/sqlite/SQLiteDatabase;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;
move-result-object p1
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$19;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
invoke-direct {p0, p1, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->retryIfDbLocked(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
return-void
.end method
.method private ensureTransportContext(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)J
.registers 7
.line 159
invoke-direct {p0, p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getTransportContextId(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/lang/Long;
move-result-object v0
if-eqz v0, :cond_b
.line 161
invoke-virtual {v0}, Ljava/lang/Long;->longValue()J
move-result-wide p1
return-wide p1
.line 164
:cond_b
new-instance v0, Landroid/content/ContentValues;
invoke-direct {v0}, Landroid/content/ContentValues;-><init>()V
.line 165
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v1
const-string v2, "backend_name"
invoke-virtual {v0, v2, v1}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 166
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object v1
invoke-static {v1}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result v1
invoke-static {v1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v1
const-string v2, "priority"
invoke-virtual {v0, v2, v1}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
const/4 v1, 0x0
.line 167
invoke-static {v1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
const-string v3, "next_request_ms"
invoke-virtual {v0, v3, v2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 168
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object v2
if-eqz v2, :cond_47
.line 169
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object p2
invoke-static {p2, v1}, Landroid/util/Base64;->encodeToString([BI)Ljava/lang/String;
move-result-object p2
const-string v1, "extras"
invoke-virtual {v0, v1, p2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
:cond_47
const/4 p2, 0x0
const-string/jumbo v1, "transport_contexts"
.line 172
invoke-virtual {p1, v1, p2, v0}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
move-result-wide p1
return-wide p1
.end method
.method private getPageCount()J
.registers 3
.line 603
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
const-string v1, "PRAGMA page_count"
invoke-virtual {v0, v1}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object v0
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteStatement;->simpleQueryForLong()J
move-result-wide v0
return-wide v0
.end method
.method private getPageSize()J
.registers 3
.line 595
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
const-string v1, "PRAGMA page_size"
invoke-virtual {v0, v1}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object v0
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteStatement;->simpleQueryForLong()J
move-result-wide v0
return-wide v0
.end method
.method private getTransportContextId(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/lang/Long;
.registers 16
.line 177
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "backend_name = ? and priority = ?"
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
.line 178
new-instance v1, Ljava/util/ArrayList;
const/4 v2, 0x2
new-array v2, v2, [Ljava/lang/String;
.line 181
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v3
const/4 v4, 0x0
aput-object v3, v2, v4
.line 182
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object v3
invoke-static {v3}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result v3
invoke-static {v3}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v3
const/4 v5, 0x1
aput-object v3, v2, v5
.line 180
invoke-static {v2}, Ljava/util/Arrays;->asList([Ljava/lang/Object;)Ljava/util/List;
move-result-object v2
invoke-direct {v1, v2}, Ljava/util/ArrayList;-><init>(Ljava/util/Collection;)V
.line 184
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object v2
if-eqz v2, :cond_3f
const-string v2, " and extras = ?"
.line 185
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
.line 186
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object p2
invoke-static {p2, v4}, Landroid/util/Base64;->encodeToString([BI)Ljava/lang/String;
move-result-object p2
invoke-virtual {v1, p2}, Ljava/util/ArrayList;->add(Ljava/lang/Object;)Z
:cond_3f
const-string p2, "_id"
.line 189
filled-new-array {p2}, [Ljava/lang/String;
move-result-object v7
.line 193
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v8
new-array p2, v4, [Ljava/lang/String;
.line 194
invoke-virtual {v1, p2}, Ljava/util/ArrayList;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;
move-result-object p2
move-object v9, p2
check-cast v9, [Ljava/lang/String;
const/4 v10, 0x0
const/4 v11, 0x0
const/4 v12, 0x0
const-string/jumbo v6, "transport_contexts"
move-object v5, p1
.line 190
invoke-virtual/range {v5 .. v12}, Landroid/database/sqlite/SQLiteDatabase;->query(Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p1
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$6;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p2
.line 189
invoke-static {p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/Long;
return-object p1
.end method
.method private inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function<",
"Landroid/database/sqlite/SQLiteDatabase;",
"TT;>;)TT;"
}
.end annotation
.line 561
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
.line 562
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->beginTransaction()V
.line 564
:try_start_7
invoke-interface {p1, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
.line 565
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->setTransactionSuccessful()V
:try_end_e
.catchall {:try_start_7 .. :try_end_e} :catchall_12
.line 568
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
return-object p1
:catchall_12
move-exception p1
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 569
throw p1
.end method
.method private isStorageAtLimit()Z
.registers 6
.line 583
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getPageCount()J
move-result-wide v0
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getPageSize()J
move-result-wide v2
mul-long v0, v0, v2
.line 585
iget-object v2, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;->getMaxStorageSizeInBytes()J
move-result-wide v2
cmp-long v4, v0, v2
if-ltz v4, :cond_16
const/4 v0, 0x1
goto :goto_17
:cond_16
const/4 v0, 0x0
:goto_17
return v0
.end method
.method private join(Ljava/util/List;Ljava/util/Map;)Ljava/util/List;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;",
"Ljava/util/Map<",
"Ljava/lang/Long;",
"Ljava/util/Set<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;",
">;>;)",
"Ljava/util/List<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;"
}
.end annotation
.line 496
invoke-interface {p1}, Ljava/util/List;->listIterator()Ljava/util/ListIterator;
move-result-object v0
.line 497
:goto_4
invoke-interface {v0}, Ljava/util/ListIterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_61
.line 498
invoke-interface {v0}, Ljava/util/ListIterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
.line 499
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getId()J
move-result-wide v2
invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v2
invoke-interface {p2, v2}, Ljava/util/Map;->containsKey(Ljava/lang/Object;)Z
move-result v2
if-nez v2, :cond_1f
goto :goto_4
.line 502
:cond_1f
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getEvent()Lcom/google/android/datatransport/runtime/EventInternal;
move-result-object v2
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/EventInternal;->toBuilder()Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v2
.line 504
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getId()J
move-result-wide v3
invoke-static {v3, v4}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v3
invoke-interface {p2, v3}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v3
check-cast v3, Ljava/util/Set;
invoke-interface {v3}, Ljava/util/Set;->iterator()Ljava/util/Iterator;
move-result-object v3
:goto_39
invoke-interface {v3}, Ljava/util/Iterator;->hasNext()Z
move-result v4
if-eqz v4, :cond_4d
invoke-interface {v3}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v4
check-cast v4, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;
.line 505
iget-object v5, v4, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;->key:Ljava/lang/String;
iget-object v4, v4, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;->value:Ljava/lang/String;
invoke-virtual {v2, v5, v4}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->addMetadata(Ljava/lang/String;Ljava/lang/String;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
goto :goto_39
.line 508
:cond_4d
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getId()J
move-result-wide v3
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getTransportContext()Lcom/google/android/datatransport/runtime/TransportContext;
move-result-object v1
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->build()Lcom/google/android/datatransport/runtime/EventInternal;
move-result-object v2
invoke-static {v3, v4, v1, v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->create(JLcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;)Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
move-result-object v1
.line 507
invoke-interface {v0, v1}, Ljava/util/ListIterator;->set(Ljava/lang/Object;)V
goto :goto_4
:cond_61
return-object p1
.end method
.method static synthetic lambda$cleanUp$10(JLandroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Integer;
.registers 4
const/4 v0, 0x1
new-array v0, v0, [Ljava/lang/String;
.line 341
invoke-static {p0, p1}, Ljava/lang/String;->valueOf(J)Ljava/lang/String;
move-result-object p0
const/4 p1, 0x0
aput-object p0, v0, p1
const-string p0, "events"
const-string p1, "timestamp_ms < ?"
invoke-virtual {p2, p0, p1, v0}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
move-result p0
invoke-static {p0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object p0
return-object p0
.end method
.method static synthetic lambda$clearDb$11(Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 5
const/4 v0, 0x0
new-array v1, v0, [Ljava/lang/String;
const-string v2, "events"
const/4 v3, 0x0
.line 353
invoke-virtual {p0, v2, v3, v1}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
new-array v0, v0, [Ljava/lang/String;
const-string/jumbo v1, "transport_contexts"
.line 354
invoke-virtual {p0, v1, v3, v0}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
return-object v3
.end method
.method static synthetic lambda$ensureBeginTransaction$15(Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 1
.line 539
invoke-virtual {p0}, Landroid/database/sqlite/SQLiteDatabase;->beginTransaction()V
const/4 p0, 0x0
return-object p0
.end method
.method static synthetic lambda$ensureBeginTransaction$16(Ljava/lang/Throwable;)Ljava/lang/Object;
.registers 3
.line 543
new-instance v0, Lcom/google/android/datatransport/runtime/synchronization/SynchronizationException;
const-string v1, "Timed out while trying to acquire the lock."
invoke-direct {v0, v1, p0}, Lcom/google/android/datatransport/runtime/synchronization/SynchronizationException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v0
.end method
.method static synthetic lambda$getDb$0(Ljava/lang/Throwable;)Landroid/database/sqlite/SQLiteDatabase;
.registers 3
.line 85
new-instance v0, Lcom/google/android/datatransport/runtime/synchronization/SynchronizationException;
const-string v1, "Timed out while trying to open db."
invoke-direct {v0, v1, p0}, Lcom/google/android/datatransport/runtime/synchronization/SynchronizationException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v0
.end method
.method static synthetic lambda$getNextCallTime$4(Landroid/database/Cursor;)Ljava/lang/Long;
.registers 3
.line 256
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
if-eqz v0, :cond_10
const/4 v0, 0x0
.line 257
invoke-interface {p0, v0}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v0
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object p0
return-object p0
:cond_10
const-wide/16 v0, 0x0
.line 259
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object p0
return-object p0
.end method
.method static synthetic lambda$getTransportContextId$2(Landroid/database/Cursor;)Ljava/lang/Long;
.registers 3
.line 199
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
if-nez v0, :cond_8
const/4 p0, 0x0
return-object p0
:cond_8
const/4 v0, 0x0
.line 202
invoke-interface {p0, v0}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v0
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object p0
return-object p0
.end method
.method static synthetic lambda$hasPendingEventsFor$5(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Lcom/google/android/datatransport/runtime/TransportContext;Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Boolean;
.registers 4
.line 267
invoke-direct {p0, p2, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getTransportContextId(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/lang/Long;
move-result-object p1
const/4 p2, 0x0
if-nez p1, :cond_c
.line 269
invoke-static {p2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object p0
return-object p0
.line 272
:cond_c
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object p0
const/4 v0, 0x1
new-array v0, v0, [Ljava/lang/String;
.line 275
invoke-virtual {p1}, Ljava/lang/Long;->toString()Ljava/lang/String;
move-result-object p1
aput-object p1, v0, p2
const-string p1, "SELECT 1 FROM events WHERE context_id = ? LIMIT 1"
.line 273
invoke-virtual {p0, p1, v0}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p0
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$21;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p1
.line 271
invoke-static {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p0
check-cast p0, Ljava/lang/Boolean;
return-object p0
.end method
.method static synthetic lambda$loadActiveContexts$8(Landroid/database/Cursor;)Ljava/util/List;
.registers 4
.line 324
new-instance v0, Ljava/util/ArrayList;
invoke-direct {v0}, Ljava/util/ArrayList;-><init>()V
.line 325
:goto_5
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v1
if-eqz v1, :cond_3a
.line 327
invoke-static {}, Lcom/google/android/datatransport/runtime/TransportContext;->builder()Lcom/google/android/datatransport/runtime/TransportContext$Builder;
move-result-object v1
const/4 v2, 0x1
.line 328
invoke-interface {p0, v2}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v2
invoke-virtual {v1, v2}, Lcom/google/android/datatransport/runtime/TransportContext$Builder;->setBackendName(Ljava/lang/String;)Lcom/google/android/datatransport/runtime/TransportContext$Builder;
move-result-object v1
const/4 v2, 0x2
.line 329
invoke-interface {p0, v2}, Landroid/database/Cursor;->getInt(I)I
move-result v2
invoke-static {v2}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->valueOf(I)Lcom/google/android/datatransport/Priority;
move-result-object v2
invoke-virtual {v1, v2}, Lcom/google/android/datatransport/runtime/TransportContext$Builder;->setPriority(Lcom/google/android/datatransport/Priority;)Lcom/google/android/datatransport/runtime/TransportContext$Builder;
move-result-object v1
const/4 v2, 0x3
.line 330
invoke-interface {p0, v2}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v2
invoke-static {v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->maybeBase64Decode(Ljava/lang/String;)[B
move-result-object v2
invoke-virtual {v1, v2}, Lcom/google/android/datatransport/runtime/TransportContext$Builder;->setExtras([B)Lcom/google/android/datatransport/runtime/TransportContext$Builder;
move-result-object v1
.line 331
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/TransportContext$Builder;->build()Lcom/google/android/datatransport/runtime/TransportContext;
move-result-object v1
.line 326
invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z
goto :goto_5
:cond_3a
return-object v0
.end method
.method static synthetic lambda$loadActiveContexts$9(Landroid/database/sqlite/SQLiteDatabase;)Ljava/util/List;
.registers 3
const/4 v0, 0x0
new-array v0, v0, [Ljava/lang/String;
const-string v1, "SELECT distinct t._id, t.backend_name, t.priority, t.extras FROM transport_contexts AS t, events AS e WHERE e.context_id = t._id"
.line 319
invoke-virtual {p0, v1, v0}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p0
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$20;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
.line 318
invoke-static {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p0
check-cast p0, Ljava/util/List;
return-object p0
.end method
.method static synthetic lambda$loadBatch$7(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Lcom/google/android/datatransport/runtime/TransportContext;Landroid/database/sqlite/SQLiteDatabase;)Ljava/util/List;
.registers 3
.line 309
invoke-direct {p0, p2, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->loadEvents(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/util/List;
move-result-object p1
.line 310
invoke-direct {p0, p2, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->loadMetadata(Landroid/database/sqlite/SQLiteDatabase;Ljava/util/List;)Ljava/util/Map;
move-result-object p2
invoke-direct {p0, p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->join(Ljava/util/List;Ljava/util/Map;)Ljava/util/List;
move-result-object p0
return-object p0
.end method
.method static synthetic lambda$loadEvents$12(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Ljava/util/List;Lcom/google/android/datatransport/runtime/TransportContext;Landroid/database/Cursor;)Ljava/lang/Object;
.registers 10
.line 394
:goto_0
invoke-interface {p3}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
if-eqz v0, :cond_7d
const/4 v0, 0x0
.line 395
invoke-interface {p3, v0}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v1
const/4 v3, 0x7
.line 396
invoke-interface {p3, v3}, Landroid/database/Cursor;->getInt(I)I
move-result v3
const/4 v4, 0x1
if-eqz v3, :cond_14
const/4 v0, 0x1
.line 398
:cond_14
invoke-static {}, Lcom/google/android/datatransport/runtime/EventInternal;->builder()Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v3
.line 399
invoke-interface {p3, v4}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v4
invoke-virtual {v3, v4}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setTransportName(Ljava/lang/String;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v3
const/4 v4, 0x2
.line 400
invoke-interface {p3, v4}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v4
invoke-virtual {v3, v4, v5}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setEventMillis(J)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v3
const/4 v4, 0x3
.line 401
invoke-interface {p3, v4}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v4
invoke-virtual {v3, v4, v5}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setUptimeMillis(J)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v3
const/4 v4, 0x4
if-eqz v0, :cond_4b
.line 403
new-instance v0, Lcom/google/android/datatransport/runtime/EncodedPayload;
.line 404
invoke-interface {p3, v4}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v4
invoke-static {v4}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->toEncoding(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
move-result-object v4
const/4 v5, 0x5
invoke-interface {p3, v5}, Landroid/database/Cursor;->getBlob(I)[B
move-result-object v5
invoke-direct {v0, v4, v5}, Lcom/google/android/datatransport/runtime/EncodedPayload;-><init>(Lcom/google/android/datatransport/Encoding;[B)V
.line 403
invoke-virtual {v3, v0}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setEncodedPayload(Lcom/google/android/datatransport/runtime/EncodedPayload;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
goto :goto_5f
.line 406
:cond_4b
new-instance v0, Lcom/google/android/datatransport/runtime/EncodedPayload;
.line 407
invoke-interface {p3, v4}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v4
invoke-static {v4}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->toEncoding(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
move-result-object v4
invoke-direct {p0, v1, v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->readPayload(J)[B
move-result-object v5
invoke-direct {v0, v4, v5}, Lcom/google/android/datatransport/runtime/EncodedPayload;-><init>(Lcom/google/android/datatransport/Encoding;[B)V
.line 406
invoke-virtual {v3, v0}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setEncodedPayload(Lcom/google/android/datatransport/runtime/EncodedPayload;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
:goto_5f
const/4 v0, 0x6
.line 409
invoke-interface {p3, v0}, Landroid/database/Cursor;->isNull(I)Z
move-result v4
if-nez v4, :cond_71
.line 410
invoke-interface {p3, v0}, Landroid/database/Cursor;->getInt(I)I
move-result v0
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
invoke-virtual {v3, v0}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setCode(Ljava/lang/Integer;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
.line 412
:cond_71
invoke-virtual {v3}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->build()Lcom/google/android/datatransport/runtime/EventInternal;
move-result-object v0
invoke-static {v1, v2, p2, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->create(JLcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;)Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
move-result-object v0
invoke-interface {p1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z
goto :goto_0
:cond_7d
const/4 p0, 0x0
return-object p0
.end method
.method static synthetic lambda$loadMetadata$14(Ljava/util/Map;Landroid/database/Cursor;)Ljava/lang/Object;
.registers 7
.line 479
:goto_0
invoke-interface {p1}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
const/4 v1, 0x0
if-eqz v0, :cond_37
const/4 v0, 0x0
.line 480
invoke-interface {p1, v0}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v2
.line 481
invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v0
invoke-interface {p0, v0}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/util/Set;
if-nez v0, :cond_24
.line 483
new-instance v0, Ljava/util/HashSet;
invoke-direct {v0}, Ljava/util/HashSet;-><init>()V
.line 484
invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v2
invoke-interface {p0, v2, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 486
:cond_24
new-instance v2, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;
const/4 v3, 0x1
invoke-interface {p1, v3}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v3
const/4 v4, 0x2
invoke-interface {p1, v4}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v4
invoke-direct {v2, v3, v4, v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;-><init>(Ljava/lang/String;Ljava/lang/String;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$1;)V
invoke-interface {v0, v2}, Ljava/util/Set;->add(Ljava/lang/Object;)Z
goto :goto_0
:cond_37
return-object v1
.end method
.method static synthetic lambda$persist$1(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Lcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Long;
.registers 14
.line 104
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->isStorageAtLimit()Z
move-result v0
if-eqz v0, :cond_d
const-wide/16 p0, -0x1
.line 105
invoke-static {p0, p1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object p0
return-object p0
.line 108
:cond_d
invoke-direct {p0, p3, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->ensureTransportContext(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)J
move-result-wide v0
.line 109
iget-object p0, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;->getMaxBlobByteSizePerRow()I
move-result p0
.line 111
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getEncodedPayload()Lcom/google/android/datatransport/runtime/EncodedPayload;
move-result-object p1
invoke-virtual {p1}, Lcom/google/android/datatransport/runtime/EncodedPayload;->getBytes()[B
move-result-object p1
.line 112
array-length v2, p1
const/4 v3, 0x0
const/4 v4, 0x1
if-gt v2, p0, :cond_26
const/4 v2, 0x1
goto :goto_27
:cond_26
const/4 v2, 0x0
.line 113
:goto_27
new-instance v5, Landroid/content/ContentValues;
invoke-direct {v5}, Landroid/content/ContentValues;-><init>()V
.line 114
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v0
const-string v1, "context_id"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 115
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getTransportName()Ljava/lang/String;
move-result-object v0
const-string/jumbo v1, "transport_name"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 116
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getEventMillis()J
move-result-wide v0
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v0
const-string v1, "timestamp_ms"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 117
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getUptimeMillis()J
move-result-wide v0
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v0
const-string/jumbo v1, "uptime_ms"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 118
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getEncodedPayload()Lcom/google/android/datatransport/runtime/EncodedPayload;
move-result-object v0
invoke-virtual {v0}, Lcom/google/android/datatransport/runtime/EncodedPayload;->getEncoding()Lcom/google/android/datatransport/Encoding;
move-result-object v0
invoke-virtual {v0}, Lcom/google/android/datatransport/Encoding;->getName()Ljava/lang/String;
move-result-object v0
const-string v1, "payload_encoding"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 119
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getCode()Ljava/lang/Integer;
move-result-object v0
const-string v1, "code"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 120
invoke-static {v3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
const-string v1, "num_attempts"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 121
invoke-static {v2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v0
const-string v1, "inline"
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Boolean;)V
if-eqz v2, :cond_8a
move-object v0, p1
goto :goto_8c
:cond_8a
new-array v0, v3, [B
:goto_8c
const-string v1, "payload"
.line 122
invoke-virtual {v5, v1, v0}, Landroid/content/ContentValues;->put(Ljava/lang/String;[B)V
const-string v0, "events"
const/4 v1, 0x0
.line 123
invoke-virtual {p3, v0, v1, v5}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
move-result-wide v5
const-string v0, "event_id"
if-nez v2, :cond_d8
.line 125
array-length v2, p1
int-to-double v2, v2
int-to-double v7, p0
div-double/2addr v2, v7
invoke-static {v2, v3}, Ljava/lang/Math;->ceil(D)D
move-result-wide v2
double-to-int v2, v2
:goto_a5
if-gt v4, v2, :cond_d8
add-int/lit8 v3, v4, -0x1
mul-int v3, v3, p0
mul-int v7, v4, p0
.line 128
array-length v8, p1
.line 132
invoke-static {v7, v8}, Ljava/lang/Math;->min(II)I
move-result v7
.line 129
invoke-static {p1, v3, v7}, Ljava/util/Arrays;->copyOfRange([BII)[B
move-result-object v3
.line 133
new-instance v7, Landroid/content/ContentValues;
invoke-direct {v7}, Landroid/content/ContentValues;-><init>()V
.line 134
invoke-static {v5, v6}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v8
invoke-virtual {v7, v0, v8}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 135
invoke-static {v4}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v8
const-string v9, "sequence_num"
invoke-virtual {v7, v9, v8}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
const-string v8, "bytes"
.line 136
invoke-virtual {v7, v8, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;[B)V
const-string v3, "event_payloads"
.line 137
invoke-virtual {p3, v3, v1, v7}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
add-int/lit8 v4, v4, 0x1
goto :goto_a5
.line 142
:cond_d8
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getMetadata()Ljava/util/Map;
move-result-object p0
invoke-interface {p0}, Ljava/util/Map;->entrySet()Ljava/util/Set;
move-result-object p0
invoke-interface {p0}, Ljava/util/Set;->iterator()Ljava/util/Iterator;
move-result-object p0
:goto_e4
invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z
move-result p1
if-eqz p1, :cond_119
invoke-interface {p0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/util/Map$Entry;
.line 143
new-instance p2, Landroid/content/ContentValues;
invoke-direct {p2}, Landroid/content/ContentValues;-><init>()V
.line 144
invoke-static {v5, v6}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v2
invoke-virtual {p2, v0, v2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 145
invoke-interface {p1}, Ljava/util/Map$Entry;->getKey()Ljava/lang/Object;
move-result-object v2
check-cast v2, Ljava/lang/String;
const-string v3, "name"
invoke-virtual {p2, v3, v2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 146
invoke-interface {p1}, Ljava/util/Map$Entry;->getValue()Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/String;
const-string/jumbo v2, "value"
invoke-virtual {p2, v2, p1}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
const-string p1, "event_metadata"
.line 147
invoke-virtual {p3, p1, v1, p2}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
goto :goto_e4
.line 149
:cond_119
invoke-static {v5, v6}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object p0
return-object p0
.end method
.method static synthetic lambda$readPayload$13(Landroid/database/Cursor;)[B
.registers 7
.line 431
new-instance v0, Ljava/util/ArrayList;
invoke-direct {v0}, Ljava/util/ArrayList;-><init>()V
const/4 v1, 0x0
const/4 v2, 0x0
.line 433
:goto_7
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v3
if-eqz v3, :cond_17
.line 434
invoke-interface {p0, v1}, Landroid/database/Cursor;->getBlob(I)[B
move-result-object v3
.line 435
invoke-interface {v0, v3}, Ljava/util/List;->add(Ljava/lang/Object;)Z
.line 436
array-length v3, v3
add-int/2addr v2, v3
goto :goto_7
.line 439
:cond_17
new-array p0, v2, [B
const/4 v2, 0x0
const/4 v3, 0x0
.line 441
:goto_1b
invoke-interface {v0}, Ljava/util/List;->size()I
move-result v4
if-ge v2, v4, :cond_30
.line 442
invoke-interface {v0, v2}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v4
check-cast v4, [B
.line 443
array-length v5, v4
invoke-static {v4, v1, p0, v3, v5}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 444
array-length v4, v4
add-int/2addr v3, v4
add-int/lit8 v2, v2, 0x1
goto :goto_1b
:cond_30
return-object p0
.end method
.method static synthetic lambda$recordFailure$3(Ljava/lang/String;Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 2
.line 216
invoke-virtual {p1, p0}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object p0
invoke-virtual {p0}, Landroid/database/sqlite/SQLiteStatement;->execute()V
const-string p0, "DELETE FROM events WHERE num_attempts >= 16"
.line 217
invoke-virtual {p1, p0}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object p0
invoke-virtual {p0}, Landroid/database/sqlite/SQLiteStatement;->execute()V
const/4 p0, 0x0
return-object p0
.end method
.method static synthetic lambda$recordNextCallTime$6(JLcom/google/android/datatransport/runtime/TransportContext;Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 7
.line 284
new-instance v0, Landroid/content/ContentValues;
invoke-direct {v0}, Landroid/content/ContentValues;-><init>()V
.line 285
invoke-static {p0, p1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object p0
const-string p1, "next_request_ms"
invoke-virtual {v0, p1, p0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
const/4 p0, 0x2
new-array p0, p0, [Ljava/lang/String;
.line 292
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object p1
const/4 v1, 0x0
aput-object p1, p0, v1
.line 293
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object p1
invoke-static {p1}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result p1
invoke-static {p1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object p1
const/4 v1, 0x1
aput-object p1, p0, v1
const-string/jumbo p1, "transport_contexts"
const-string v2, "backend_name = ? and priority = ?"
.line 287
invoke-virtual {p3, p1, v0, v2, p0}, Landroid/database/sqlite/SQLiteDatabase;->update(Ljava/lang/String;Landroid/content/ContentValues;Ljava/lang/String;[Ljava/lang/String;)I
move-result p0
const/4 v2, 0x0
if-ge p0, v1, :cond_50
.line 297
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object p0
const-string v1, "backend_name"
invoke-virtual {v0, v1, p0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 298
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object p0
invoke-static {p0}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result p0
invoke-static {p0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object p0
const-string p2, "priority"
invoke-virtual {v0, p2, p0}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 299
invoke-virtual {p3, p1, v2, v0}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
:cond_50
return-object v2
.end method
.method private loadEvents(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/util/List;
.registers 23
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroid/database/sqlite/SQLiteDatabase;",
"Lcom/google/android/datatransport/runtime/TransportContext;",
")",
"Ljava/util/List<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;"
}
.end annotation
move-object/from16 v0, p0
.line 368
new-instance v1, Ljava/util/ArrayList;
invoke-direct {v1}, Ljava/util/ArrayList;-><init>()V
.line 369
invoke-direct/range {p0 .. p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getTransportContextId(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/lang/Long;
move-result-object v2
if-nez v2, :cond_e
return-object v1
:cond_e
const-string v3, "_id"
const-string/jumbo v4, "transport_name"
const-string v5, "timestamp_ms"
const-string/jumbo v6, "uptime_ms"
const-string v7, "payload_encoding"
const-string v8, "payload"
const-string v9, "code"
const-string v10, "inline"
.line 374
filled-new-array/range {v3 .. v10}, [Ljava/lang/String;
move-result-object v13
const/4 v3, 0x1
new-array v15, v3, [Ljava/lang/String;
const/4 v3, 0x0
.line 388
invoke-virtual {v2}, Ljava/lang/Long;->toString()Ljava/lang/String;
move-result-object v2
aput-object v2, v15, v3
const/16 v16, 0x0
const/16 v17, 0x0
const/16 v18, 0x0
iget-object v2, v0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
.line 392
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;->getLoadBatchSize()I
move-result v2
invoke-static {v2}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v19
const-string v12, "events"
const-string v14, "context_id = ?"
move-object/from16 v11, p1
.line 375
invoke-virtual/range {v11 .. v19}, Landroid/database/sqlite/SQLiteDatabase;->query(Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Landroid/database/Cursor;
move-result-object v2
move-object/from16 v3, p2
invoke-static {v0, v1, v3}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$15;->lambdaFactory$(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Ljava/util/List;Lcom/google/android/datatransport/runtime/TransportContext;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v3
.line 374
invoke-static {v2, v3}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
return-object v1
.end method
.method private loadMetadata(Landroid/database/sqlite/SQLiteDatabase;Ljava/util/List;)Ljava/util/Map;
.registers 15
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroid/database/sqlite/SQLiteDatabase;",
"Ljava/util/List<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;)",
"Ljava/util/Map<",
"Ljava/lang/Long;",
"Ljava/util/Set<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;",
">;>;"
}
.end annotation
.line 459
new-instance v0, Ljava/util/HashMap;
invoke-direct {v0}, Ljava/util/HashMap;-><init>()V
.line 460
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "event_id IN ("
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
const/4 v2, 0x0
.line 461
:goto_d
invoke-interface {p2}, Ljava/util/List;->size()I
move-result v3
if-ge v2, v3, :cond_30
.line 462
invoke-interface {p2, v2}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v3
check-cast v3, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
invoke-virtual {v3}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getId()J
move-result-wide v3
invoke-virtual {v1, v3, v4}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
.line 463
invoke-interface {p2}, Ljava/util/List;->size()I
move-result v3
add-int/lit8 v3, v3, -0x1
if-ge v2, v3, :cond_2d
const/16 v3, 0x2c
.line 464
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
:cond_2d
add-int/lit8 v2, v2, 0x1
goto :goto_d
:cond_30
const/16 p2, 0x29
.line 467
invoke-virtual {v1, p2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
const-string p2, "event_id"
const-string v2, "name"
const-string/jumbo v3, "value"
.line 469
filled-new-array {p2, v2, v3}, [Ljava/lang/String;
move-result-object v6
.line 473
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v7
const/4 v8, 0x0
const/4 v9, 0x0
const/4 v10, 0x0
const/4 v11, 0x0
const-string v5, "event_metadata"
move-object v4, p1
.line 470
invoke-virtual/range {v4 .. v11}, Landroid/database/sqlite/SQLiteDatabase;->query(Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p1
invoke-static {v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$17;->lambdaFactory$(Ljava/util/Map;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p2
.line 469
invoke-static {p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
return-object v0
.end method
.method private static maybeBase64Decode(Ljava/lang/String;)[B
.registers 2
if-nez p0, :cond_4
const/4 p0, 0x0
return-object p0
:cond_4
const/4 v0, 0x0
.line 363
invoke-static {p0, v0}, Landroid/util/Base64;->decode(Ljava/lang/String;I)[B
move-result-object p0
return-object p0
.end method
.method private readPayload(J)[B
.registers 11
.line 421
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
const-string v1, "bytes"
filled-new-array {v1}, [Ljava/lang/String;
move-result-object v2
const/4 v1, 0x1
new-array v4, v1, [Ljava/lang/String;
.line 426
invoke-static {p1, p2}, Ljava/lang/String;->valueOf(J)Ljava/lang/String;
move-result-object p1
const/4 p2, 0x0
aput-object p1, v4, p2
const-string v1, "event_payloads"
const-string v3, "event_id = ?"
const/4 v5, 0x0
const/4 v6, 0x0
const-string v7, "sequence_num"
.line 422
invoke-virtual/range {v0 .. v7}, Landroid/database/sqlite/SQLiteDatabase;->query(Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p1
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$16;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p2
.line 420
invoke-static {p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p1
check-cast p1, [B
return-object p1
.end method
.method private retryIfDbLocked(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer<",
"TT;>;",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function<",
"Ljava/lang/Throwable;",
"TT;>;)TT;"
}
.end annotation
.line 514
iget-object v0, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->monotonicClock:Lcom/google/android/datatransport/runtime/time/Clock;
invoke-interface {v0}, Lcom/google/android/datatransport/runtime/time/Clock;->getTime()J
move-result-wide v0
.line 517
:goto_6
:try_start_6
invoke-interface {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;->produce()Ljava/lang/Object;
move-result-object p1
:try_end_a
.catch Landroid/database/sqlite/SQLiteDatabaseLockedException; {:try_start_6 .. :try_end_a} :catch_b
return-object p1
:catch_b
move-exception v2
.line 519
iget-object v3, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->monotonicClock:Lcom/google/android/datatransport/runtime/time/Clock;
invoke-interface {v3}, Lcom/google/android/datatransport/runtime/time/Clock;->getTime()J
move-result-wide v3
iget-object v5, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
invoke-virtual {v5}, Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;->getCriticalSectionEnterTimeoutMs()I
move-result v5
int-to-long v5, v5
add-long/2addr v5, v0
cmp-long v7, v3, v5
if-ltz v7, :cond_23
.line 520
invoke-interface {p2, v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
return-object p1
:cond_23
const-wide/16 v2, 0x32
.line 522
invoke-static {v2, v3}, Landroid/os/SystemClock;->sleep(J)V
goto :goto_6
.end method
.method private static toEncoding(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
.registers 1
if-nez p0, :cond_5
.line 452
sget-object p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->PROTOBUF_ENCODING:Lcom/google/android/datatransport/Encoding;
return-object p0
.line 454
:cond_5
invoke-static {p0}, Lcom/google/android/datatransport/Encoding;->of(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
move-result-object p0
return-object p0
.end method
.method private static toIdList(Ljava/lang/Iterable;)Ljava/lang/String;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/Iterable<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;)",
"Ljava/lang/String;"
}
.end annotation
.line 233
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "("
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
.line 234
invoke-interface {p0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object p0
.line 235
:cond_b
:goto_b
invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_2a
.line 236
invoke-interface {p0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getId()J
move-result-wide v1
invoke-virtual {v0, v1, v2}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
.line 237
invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_b
const/16 v1, 0x2c
.line 238
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
goto :goto_b
:cond_2a
const/16 p0, 0x29
.line 241
invoke-virtual {v0, p0}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
.line 242
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p0
return-object p0
.end method
.method private static tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Landroid/database/Cursor;",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function<",
"Landroid/database/Cursor;",
"TT;>;)TT;"
}
.end annotation
.line 608
:try_start_0
invoke-interface {p1, p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
:try_end_4
.catchall {:try_start_0 .. :try_end_4} :catchall_8
.line 610
invoke-interface {p0}, Landroid/database/Cursor;->close()V
return-object p1
:catchall_8
move-exception p1
invoke-interface {p0}, Landroid/database/Cursor;->close()V
.line 611
throw p1
.end method
# virtual methods
.method public cleanUp()I
.registers 5
.line 339
iget-object v0, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->wallClock:Lcom/google/android/datatransport/runtime/time/Clock;
invoke-interface {v0}, Lcom/google/android/datatransport/runtime/time/Clock;->getTime()J
move-result-wide v0
iget-object v2, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;->getEventCleanUpAge()J
move-result-wide v2
sub-long/2addr v0, v2
.line 340
invoke-static {v0, v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$13;->lambdaFactory$(J)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
invoke-direct {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Integer;
invoke-virtual {v0}, Ljava/lang/Integer;->intValue()I
move-result v0
return v0
.end method
.method public clearDb()V
.registers 2
.line 351
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$14;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
invoke-direct {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
return-void
.end method
.method public close()V
.registers 2
.line 346
iget-object v0, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->schemaManager:Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
invoke-virtual {v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;->close()V
return-void
.end method
.method getByteSize()J
.registers 5
.line 590
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getPageCount()J
move-result-wide v0
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getPageSize()J
move-result-wide v2
mul-long v0, v0, v2
return-wide v0
.end method
.method getDb()Landroid/database/sqlite/SQLiteDatabase;
.registers 3
.line 82
iget-object v0, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->schemaManager:Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
.line 83
invoke-virtual {v0}, Ljava/lang/Object;->getClass()Ljava/lang/Class;
invoke-static {v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$1;->lambdaFactory$(Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;
move-result-object v0
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$4;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v1
.line 82
invoke-direct {p0, v0, v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->retryIfDbLocked(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Landroid/database/sqlite/SQLiteDatabase;
return-object v0
.end method
.method public getNextCallTime(Lcom/google/android/datatransport/runtime/TransportContext;)J
.registers 6
.line 248
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
const/4 v1, 0x2
new-array v1, v1, [Ljava/lang/String;
.line 252
invoke-virtual {p1}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v2
const/4 v3, 0x0
aput-object v2, v1, v3
.line 253
invoke-virtual {p1}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object p1
invoke-static {p1}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result p1
invoke-static {p1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object p1
const/4 v2, 0x1
aput-object p1, v1, v2
const-string p1, "SELECT next_request_ms FROM transport_contexts WHERE backend_name = ? and priority = ?"
.line 249
invoke-virtual {v0, p1, v1}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object p1
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$8;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
.line 247
invoke-static {p1, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/Long;
invoke-virtual {p1}, Ljava/lang/Long;->longValue()J
move-result-wide v0
return-wide v0
.end method
.method public hasPendingEventsFor(Lcom/google/android/datatransport/runtime/TransportContext;)Z
.registers 2
.line 265
invoke-static {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$9;->lambdaFactory$(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Lcom/google/android/datatransport/runtime/TransportContext;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p1
invoke-direct {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/Boolean;
invoke-virtual {p1}, Ljava/lang/Boolean;->booleanValue()Z
move-result p1
return p1
.end method
.method public loadActiveContexts()Ljava/lang/Iterable;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/lang/Iterable<",
"Lcom/google/android/datatransport/runtime/TransportContext;",
">;"
}
.end annotation
.line 316
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$12;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
invoke-direct {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Iterable;
return-object v0
.end method
.method public loadBatch(Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/lang/Iterable;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/google/android/datatransport/runtime/TransportContext;",
")",
"Ljava/lang/Iterable<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;"
}
.end annotation
.line 307
invoke-static {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$11;->lambdaFactory$(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Lcom/google/android/datatransport/runtime/TransportContext;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p1
invoke-direct {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/Iterable;
return-object p1
.end method
.method public persist(Lcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;)Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
.registers 8
const/4 v0, 0x3
new-array v0, v0, [Ljava/lang/Object;
.line 95
invoke-virtual {p1}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object v1
const/4 v2, 0x0
aput-object v1, v0, v2
.line 96
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getTransportName()Ljava/lang/String;
move-result-object v1
const/4 v2, 0x1
aput-object v1, v0, v2
.line 97
invoke-virtual {p1}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v1
const/4 v2, 0x2
aput-object v1, v0, v2
const-string v1, "SQLiteEventStore"
const-string v2, "Storing event with priority=%s, name=%s for destination %s"
.line 92
invoke-static {v1, v2, v0}, Lcom/google/android/datatransport/runtime/logging/Logging;->d(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/Object;)V
.line 98
invoke-static {p0, p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$5;->lambdaFactory$(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;Lcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v0
.line 99
invoke-direct {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Long;
invoke-virtual {v0}, Ljava/lang/Long;->longValue()J
move-result-wide v0
const-wide/16 v2, 0x1
cmp-long v4, v0, v2
if-gez v4, :cond_35
const/4 p1, 0x0
return-object p1
.line 155
:cond_35
invoke-static {v0, v1, p1, p2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->create(JLcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;)Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
move-result-object p1
return-object p1
.end method
.method public recordFailure(Ljava/lang/Iterable;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/Iterable<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;)V"
}
.end annotation
.line 208
invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v0
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-nez v0, :cond_b
return-void
.line 211
:cond_b
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "UPDATE events SET num_attempts = num_attempts + 1 WHERE _id in "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
.line 212
invoke-static {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->toIdList(Ljava/lang/Iterable;)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
.line 214
invoke-static {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$7;->lambdaFactory$(Ljava/lang/String;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p1
invoke-direct {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
return-void
.end method
.method public recordNextCallTime(Lcom/google/android/datatransport/runtime/TransportContext;J)V
.registers 4
.line 282
invoke-static {p2, p3, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$10;->lambdaFactory$(JLcom/google/android/datatransport/runtime/TransportContext;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object p1
invoke-direct {p0, p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
return-void
.end method
.method public recordSuccess(Ljava/lang/Iterable;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/Iterable<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;)V"
}
.end annotation
.line 224
invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v0
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-nez v0, :cond_b
return-void
.line 228
:cond_b
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "DELETE FROM events WHERE _id in "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->toIdList(Ljava/lang/Iterable;)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
.line 229
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
invoke-virtual {v0, p1}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object p1
invoke-virtual {p1}, Landroid/database/sqlite/SQLiteStatement;->execute()V
return-void
.end method
.method public runCriticalSection(Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection;)Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection<",
"TT;>;)TT;"
}
.end annotation
.line 549
invoke-virtual {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
.line 550
invoke-direct {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->ensureBeginTransaction(Landroid/database/sqlite/SQLiteDatabase;)V
.line 552
:try_start_7
invoke-interface {p1}, Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection;->execute()Ljava/lang/Object;
move-result-object p1
.line 553
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->setTransactionSuccessful()V
:try_end_e
.catchall {:try_start_7 .. :try_end_e} :catchall_12
.line 556
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
return-object p1
:catchall_12
move-exception p1
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 557
throw p1
.end method