SQLiteEventStore.smali
.class public Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;
.super Ljava/lang/Object;
.source "com.google.android.datatransport:transport-runtime@@2.2.0"
# 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 = 0xa
.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
.line 59
const-string v0, "proto"
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
.param p1, "wallClock" # Lcom/google/android/datatransport/runtime/time/Clock;
.param p2, "clock" # Lcom/google/android/datatransport/runtime/time/Clock;
.param p3, "config" # Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
.param p4, "schemaManager" # Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
.annotation runtime Ljavax/inject/Inject;
.end annotation
.line 71
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 73
iput-object p4, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->schemaManager:Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
.line 74
iput-object p1, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->wallClock:Lcom/google/android/datatransport/runtime/time/Clock;
.line 75
iput-object p2, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->monotonicClock:Lcom/google/android/datatransport/runtime/time/Clock;
.line 76
iput-object p3, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
.line 77
return-void
.end method
.method private ensureBeginTransaction(Landroid/database/sqlite/SQLiteDatabase;)V
.registers 4
.param p1, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 476
invoke-static {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$17;->lambdaFactory$(Landroid/database/sqlite/SQLiteDatabase;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;
move-result-object v0
invoke-static {}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$18;->lambdaFactory$()Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v1
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;
.line 484
return-void
.end method
.method private ensureTransportContext(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)J
.registers 8
.param p1, "db" # Landroid/database/sqlite/SQLiteDatabase;
.param p2, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.line 136
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
.line 137
.local v0, "existingId":Ljava/lang/Long;
if-eqz v0, :cond_b
.line 138
invoke-virtual {v0}, Ljava/lang/Long;->longValue()J
move-result-wide v1
return-wide v1
.line 141
:cond_b
new-instance v1, Landroid/content/ContentValues;
invoke-direct {v1}, Landroid/content/ContentValues;-><init>()V
.line 142
.local v1, "record":Landroid/content/ContentValues;
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v2
const-string v3, "backend_name"
invoke-virtual {v1, v3, v2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 143
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object v2
invoke-static {v2}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result v2
invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v2
const-string v3, "priority"
invoke-virtual {v1, v3, v2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 144
const/4 v2, 0x0
invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v3
const-string v4, "next_request_ms"
invoke-virtual {v1, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 145
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object v3
if-eqz v3, :cond_47
.line 146
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object v3
invoke-static {v3, v2}, Landroid/util/Base64;->encodeToString([BI)Ljava/lang/String;
move-result-object v2
const-string v3, "extras"
invoke-virtual {v1, v3, v2}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 149
:cond_47
const/4 v2, 0x0
const-string/jumbo v3, "transport_contexts"
invoke-virtual {p1, v3, v2, v1}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
move-result-wide v2
return-wide v2
.end method
.method private getDb()Landroid/database/sqlite/SQLiteDatabase;
.registers 3
.line 80
iget-object v0, p0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->schemaManager:Lcom/google/android/datatransport/runtime/scheduling/persistence/SchemaManager;
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
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 private getPageCount()J
.registers 3
.line 542
invoke-direct {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 534
invoke-direct {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
.param p1, "db" # Landroid/database/sqlite/SQLiteDatabase;
.param p2, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.line 154
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 155
.local v0, "selection":Ljava/lang/StringBuilder;
new-instance v1, Ljava/util/ArrayList;
const/4 v2, 0x2
new-array v2, v2, [Ljava/lang/String;
.line 158
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 159
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 157
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 161
.local v1, "selectionArgs":Ljava/util/ArrayList;, "Ljava/util/ArrayList<Ljava/lang/String;>;"
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object v2
if-eqz v2, :cond_3f
.line 162
const-string v2, " and extras = ?"
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
.line 163
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getExtras()[B
move-result-object v2
invoke-static {v2, v4}, Landroid/util/Base64;->encodeToString([BI)Ljava/lang/String;
move-result-object v2
invoke-virtual {v1, v2}, Ljava/util/ArrayList;->add(Ljava/lang/Object;)Z
.line 166
:cond_3f
const-string v2, "_id"
filled-new-array {v2}, [Ljava/lang/String;
move-result-object v7
.line 170
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v8
new-array v2, v4, [Ljava/lang/String;
.line 171
invoke-virtual {v1, v2}, Ljava/util/ArrayList;->toArray([Ljava/lang/Object;)[Ljava/lang/Object;
move-result-object v2
move-object v9, v2
check-cast v9, [Ljava/lang/String;
const/4 v10, 0x0
const/4 v11, 0x0
const/4 v12, 0x0
.line 167
const-string/jumbo v6, "transport_contexts"
move-object v5, p1
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 v2
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 v3
.line 166
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;
move-result-object v2
check-cast v2, Ljava/lang/Long;
return-object v2
.end method
.method private inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.registers 4
.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 500
.local p1, "function":Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;, "Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function<Landroid/database/sqlite/SQLiteDatabase;TT;>;"
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
.line 501
.local v0, "db":Landroid/database/sqlite/SQLiteDatabase;
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->beginTransaction()V
.line 503
: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 v1
.line 504
.local v1, "result":Ljava/lang/Object;, "TT;"
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->setTransactionSuccessful()V
:try_end_e
.catchall {:try_start_7 .. :try_end_e} :catchall_13
.line 505
nop
.line 507
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 505
return-object v1
.line 507
.end local v1 # "result":Ljava/lang/Object;, "TT;"
:catchall_13
move-exception v1
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
throw v1
.end method
.method private isStorageAtLimit()Z
.registers 6
.line 522
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 524
.local v0, "byteSize":J
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 v2, 0x1
goto :goto_17
:cond_16
const/4 v2, 0x0
:goto_17
return v2
.end method
.method private join(Ljava/util/List;Ljava/util/Map;)Ljava/util/List;
.registers 10
.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 435
.local p1, "events":Ljava/util/List;, "Ljava/util/List<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
.local p2, "metadataIndex":Ljava/util/Map;, "Ljava/util/Map<Ljava/lang/Long;Ljava/util/Set<Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;>;>;"
invoke-interface {p1}, Ljava/util/List;->listIterator()Ljava/util/ListIterator;
move-result-object v0
.line 436
.local v0, "iterator":Ljava/util/ListIterator;, "Ljava/util/ListIterator<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
:goto_4
invoke-interface {v0}, Ljava/util/ListIterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_62
.line 437
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 438
.local v1, "current":Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
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
.line 439
goto :goto_4
.line 441
: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 443
.local v2, "newEvent":Lcom/google/android/datatransport/runtime/EventInternal$Builder;
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 444
.local v4, "metadata":Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;
iget-object v5, v4, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;->key:Ljava/lang/String;
iget-object v6, v4, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;->value:Ljava/lang/String;
invoke-virtual {v2, v5, v6}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->addMetadata(Ljava/lang/String;Ljava/lang/String;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
.line 445
.end local v4 # "metadata":Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;
goto :goto_39
.line 446
:cond_4d
nop
.line 447
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 v5
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->build()Lcom/google/android/datatransport/runtime/EventInternal;
move-result-object v6
invoke-static {v3, v4, v5, v6}, 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 v3
.line 446
invoke-interface {v0, v3}, Ljava/util/ListIterator;->set(Ljava/lang/Object;)V
.line 448
.end local v1 # "current":Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
.end local v2 # "newEvent":Lcom/google/android/datatransport/runtime/EventInternal$Builder;
goto :goto_4
.line 449
:cond_62
return-object p1
.end method
.method static synthetic lambda$cleanUp$10(JLandroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Integer;
.registers 6
.param p0, "oneWeekAgo" # J
.param p2, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 318
const/4 v0, 0x1
new-array v0, v0, [Ljava/lang/String;
invoke-static {p0, p1}, Ljava/lang/String;->valueOf(J)Ljava/lang/String;
move-result-object v1
const/4 v2, 0x0
aput-object v1, v0, v2
const-string v1, "events"
const-string/jumbo v2, "timestamp_ms < ?"
invoke-virtual {p2, v1, v2, v0}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
move-result v0
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
return-object v0
.end method
.method static synthetic lambda$clearDb$11(Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 5
.param p0, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 330
const/4 v0, 0x0
new-array v1, v0, [Ljava/lang/String;
const/4 v2, 0x0
const-string v3, "events"
invoke-virtual {p0, v3, v2, v1}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
.line 331
new-array v0, v0, [Ljava/lang/String;
const-string/jumbo v1, "transport_contexts"
invoke-virtual {p0, v1, v2, v0}, Landroid/database/sqlite/SQLiteDatabase;->delete(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)I
.line 332
return-object v2
.end method
.method static synthetic lambda$ensureBeginTransaction$14(Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 2
.param p0, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 478
invoke-virtual {p0}, Landroid/database/sqlite/SQLiteDatabase;->beginTransaction()V
.line 479
const/4 v0, 0x0
return-object v0
.end method
.method static synthetic lambda$ensureBeginTransaction$15(Ljava/lang/Throwable;)Ljava/lang/Object;
.registers 3
.param p0, "ex" # Ljava/lang/Throwable;
.line 482
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
.param p0, "ex" # Ljava/lang/Throwable;
.line 83
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
.param p0, "cursor" # Landroid/database/Cursor;
.line 233
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
if-eqz v0, :cond_10
.line 234
const/4 v0, 0x0
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 v0
return-object v0
.line 236
:cond_10
const-wide/16 v0, 0x0
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v0
return-object v0
.end method
.method static synthetic lambda$getTransportContextId$2(Landroid/database/Cursor;)Ljava/lang/Long;
.registers 3
.param p0, "cursor" # Landroid/database/Cursor;
.line 176
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
if-nez v0, :cond_8
.line 177
const/4 v0, 0x0
return-object v0
.line 179
:cond_8
const/4 v0, 0x0
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 v0
return-object v0
.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 8
.param p0, "this" # Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p2, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 244
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 v0
.line 245
.local v0, "contextId":Ljava/lang/Long;
const/4 v1, 0x0
if-nez v0, :cond_c
.line 246
invoke-static {v1}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v1
return-object v1
.line 248
:cond_c
nop
.line 249
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v2
const/4 v3, 0x1
new-array v3, v3, [Ljava/lang/String;
.line 252
invoke-virtual {v0}, Ljava/lang/Long;->toString()Ljava/lang/String;
move-result-object v4
aput-object v4, v3, v1
.line 250
const-string v1, "SELECT 1 FROM events WHERE context_id = ? LIMIT 1"
invoke-virtual {v2, v1, v3}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object v1
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 v2
.line 248
invoke-static {v1, v2}, 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 v1
check-cast v1, Ljava/lang/Boolean;
return-object v1
.end method
.method static synthetic lambda$loadActiveContexts$8(Landroid/database/Cursor;)Ljava/util/List;
.registers 4
.param p0, "cursor" # Landroid/database/Cursor;
.line 301
new-instance v0, Ljava/util/ArrayList;
invoke-direct {v0}, Ljava/util/ArrayList;-><init>()V
.line 302
.local v0, "results":Ljava/util/List;, "Ljava/util/List<Lcom/google/android/datatransport/runtime/TransportContext;>;"
:goto_5
invoke-interface {p0}, Landroid/database/Cursor;->moveToNext()Z
move-result v1
if-eqz v1, :cond_3b
.line 303
nop
.line 304
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 305
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 306
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 307
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 308
invoke-virtual {v1}, Lcom/google/android/datatransport/runtime/TransportContext$Builder;->build()Lcom/google/android/datatransport/runtime/TransportContext;
move-result-object v1
.line 303
invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z
goto :goto_5
.line 310
:cond_3b
return-object v0
.end method
.method static synthetic lambda$loadActiveContexts$9(Landroid/database/sqlite/SQLiteDatabase;)Ljava/util/List;
.registers 3
.param p0, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 295
const/4 v0, 0x0
new-array v0, v0, [Ljava/lang/String;
.line 296
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"
invoke-virtual {p0, v1, v0}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object v0
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 v1
.line 295
invoke-static {v0, v1}, 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 v0
check-cast v0, Ljava/util/List;
return-object v0
.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 5
.param p0, "this" # Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p2, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 286
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 v0
.line 287
.local v0, "events":Ljava/util/List;, "Ljava/util/List<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
invoke-direct {p0, p2, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->loadMetadata(Landroid/database/sqlite/SQLiteDatabase;Ljava/util/List;)Ljava/util/Map;
move-result-object v1
invoke-direct {p0, v0, v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->join(Ljava/util/List;Ljava/util/Map;)Ljava/util/List;
move-result-object v1
return-object v1
.end method
.method static synthetic lambda$loadEvents$12(Ljava/util/List;Lcom/google/android/datatransport/runtime/TransportContext;Landroid/database/Cursor;)Ljava/lang/Object;
.registers 9
.param p0, "events" # Ljava/util/List;
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p2, "cursor" # Landroid/database/Cursor;
.line 370
:goto_0
invoke-interface {p2}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
if-eqz v0, :cond_5f
.line 371
const/4 v0, 0x0
invoke-interface {p2, v0}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v0
.line 373
.local v0, "id":J
invoke-static {}, Lcom/google/android/datatransport/runtime/EventInternal;->builder()Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v2
const/4 v3, 0x1
.line 374
invoke-interface {p2, v3}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v3
invoke-virtual {v2, v3}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setTransportName(Ljava/lang/String;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v2
const/4 v3, 0x2
.line 375
invoke-interface {p2, v3}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v3
invoke-virtual {v2, v3, v4}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setEventMillis(J)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v2
const/4 v3, 0x3
.line 376
invoke-interface {p2, v3}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v3
invoke-virtual {v2, v3, v4}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setUptimeMillis(J)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v2
new-instance v3, Lcom/google/android/datatransport/runtime/EncodedPayload;
const/4 v4, 0x4
.line 378
invoke-interface {p2, 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 {p2, v5}, Landroid/database/Cursor;->getBlob(I)[B
move-result-object v5
invoke-direct {v3, v4, v5}, Lcom/google/android/datatransport/runtime/EncodedPayload;-><init>(Lcom/google/android/datatransport/Encoding;[B)V
.line 377
invoke-virtual {v2, v3}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setEncodedPayload(Lcom/google/android/datatransport/runtime/EncodedPayload;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
move-result-object v2
.line 379
.local v2, "event":Lcom/google/android/datatransport/runtime/EventInternal$Builder;
const/4 v3, 0x6
invoke-interface {p2, v3}, Landroid/database/Cursor;->isNull(I)Z
move-result v4
if-nez v4, :cond_53
.line 380
invoke-interface {p2, v3}, Landroid/database/Cursor;->getInt(I)I
move-result v3
invoke-static {v3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v3
invoke-virtual {v2, v3}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->setCode(Ljava/lang/Integer;)Lcom/google/android/datatransport/runtime/EventInternal$Builder;
.line 382
:cond_53
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/EventInternal$Builder;->build()Lcom/google/android/datatransport/runtime/EventInternal;
move-result-object v3
invoke-static {v0, v1, p1, v3}, 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 v3
invoke-interface {p0, v3}, Ljava/util/List;->add(Ljava/lang/Object;)Z
.line 383
.end local v0 # "id":J
.end local v2 # "event":Lcom/google/android/datatransport/runtime/EventInternal$Builder;
goto :goto_0
.line 384
:cond_5f
const/4 v0, 0x0
return-object v0
.end method
.method static synthetic lambda$loadMetadata$13(Ljava/util/Map;Landroid/database/Cursor;)Ljava/lang/Object;
.registers 9
.param p0, "metadataIndex" # Ljava/util/Map;
.param p1, "cursor" # Landroid/database/Cursor;
.line 418
:goto_0
invoke-interface {p1}, Landroid/database/Cursor;->moveToNext()Z
move-result v0
const/4 v1, 0x0
if-eqz v0, :cond_38
.line 419
const/4 v0, 0x0
invoke-interface {p1, v0}, Landroid/database/Cursor;->getLong(I)J
move-result-wide v2
.line 420
.local v2, "eventId":J
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;
.line 421
.local v0, "currentSet":Ljava/util/Set;, "Ljava/util/Set<Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;>;"
if-nez v0, :cond_25
.line 422
new-instance v4, Ljava/util/HashSet;
invoke-direct {v4}, Ljava/util/HashSet;-><init>()V
move-object v0, v4
.line 423
invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v4
invoke-interface {p0, v4, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 425
:cond_25
new-instance v4, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;
const/4 v5, 0x1
invoke-interface {p1, v5}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v5
const/4 v6, 0x2
invoke-interface {p1, v6}, Landroid/database/Cursor;->getString(I)Ljava/lang/String;
move-result-object v6
invoke-direct {v4, v5, v6, 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, v4}, Ljava/util/Set;->add(Ljava/lang/Object;)Z
.line 426
.end local v0 # "currentSet":Ljava/util/Set;, "Ljava/util/Set<Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;>;"
.end local v2 # "eventId":J
goto :goto_0
.line 427
:cond_38
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 15
.param p0, "this" # Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p2, "event" # Lcom/google/android/datatransport/runtime/EventInternal;
.param p3, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 102
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->isStorageAtLimit()Z
move-result v0
if-eqz v0, :cond_d
.line 103
const-wide/16 v0, -0x1
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v0
return-object v0
.line 106
: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 107
.local v0, "contextId":J
new-instance v2, Landroid/content/ContentValues;
invoke-direct {v2}, Landroid/content/ContentValues;-><init>()V
.line 108
.local v2, "values":Landroid/content/ContentValues;
invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v3
const-string v4, "context_id"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 109
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getTransportName()Ljava/lang/String;
move-result-object v3
const-string/jumbo v4, "transport_name"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 110
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getEventMillis()J
move-result-wide v3
invoke-static {v3, v4}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v3
const-string/jumbo v4, "timestamp_ms"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 111
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getUptimeMillis()J
move-result-wide v3
invoke-static {v3, v4}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v3
const-string/jumbo v4, "uptime_ms"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 112
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getEncodedPayload()Lcom/google/android/datatransport/runtime/EncodedPayload;
move-result-object v3
invoke-virtual {v3}, Lcom/google/android/datatransport/runtime/EncodedPayload;->getEncoding()Lcom/google/android/datatransport/Encoding;
move-result-object v3
invoke-virtual {v3}, Lcom/google/android/datatransport/Encoding;->getName()Ljava/lang/String;
move-result-object v3
const-string v4, "payload_encoding"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 113
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getEncodedPayload()Lcom/google/android/datatransport/runtime/EncodedPayload;
move-result-object v3
invoke-virtual {v3}, Lcom/google/android/datatransport/runtime/EncodedPayload;->getBytes()[B
move-result-object v3
const-string v4, "payload"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;[B)V
.line 114
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getCode()Ljava/lang/Integer;
move-result-object v3
const-string v4, "code"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 115
const/4 v3, 0x0
invoke-static {v3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v3
const-string v4, "num_attempts"
invoke-virtual {v2, v4, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 116
const/4 v3, 0x0
const-string v4, "events"
invoke-virtual {p3, v4, v3, v2}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
move-result-wide v4
.line 119
.local v4, "newEventId":J
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/EventInternal;->getMetadata()Ljava/util/Map;
move-result-object v6
invoke-interface {v6}, Ljava/util/Map;->entrySet()Ljava/util/Set;
move-result-object v6
invoke-interface {v6}, Ljava/util/Set;->iterator()Ljava/util/Iterator;
move-result-object v6
:goto_89
invoke-interface {v6}, Ljava/util/Iterator;->hasNext()Z
move-result v7
if-eqz v7, :cond_c0
invoke-interface {v6}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v7
check-cast v7, Ljava/util/Map$Entry;
.line 120
.local v7, "entry":Ljava/util/Map$Entry;, "Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;"
new-instance v8, Landroid/content/ContentValues;
invoke-direct {v8}, Landroid/content/ContentValues;-><init>()V
.line 121
.local v8, "metadata":Landroid/content/ContentValues;
invoke-static {v4, v5}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v9
const-string v10, "event_id"
invoke-virtual {v8, v10, v9}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 122
invoke-interface {v7}, Ljava/util/Map$Entry;->getKey()Ljava/lang/Object;
move-result-object v9
check-cast v9, Ljava/lang/String;
const-string v10, "name"
invoke-virtual {v8, v10, v9}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 123
invoke-interface {v7}, Ljava/util/Map$Entry;->getValue()Ljava/lang/Object;
move-result-object v9
check-cast v9, Ljava/lang/String;
const-string/jumbo v10, "value"
invoke-virtual {v8, v10, v9}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 124
const-string v9, "event_metadata"
invoke-virtual {p3, v9, v3, v8}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
.line 125
.end local v7 # "entry":Ljava/util/Map$Entry;, "Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;"
.end local v8 # "metadata":Landroid/content/ContentValues;
goto :goto_89
.line 126
:cond_c0
invoke-static {v4, v5}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v3
return-object v3
.end method
.method static synthetic lambda$recordFailure$3(Ljava/lang/String;Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 3
.param p0, "query" # Ljava/lang/String;
.param p1, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 193
invoke-virtual {p1, p0}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object v0
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteStatement;->execute()V
.line 194
const-string v0, "DELETE FROM events WHERE num_attempts >= 10"
invoke-virtual {p1, v0}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object v0
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteStatement;->execute()V
.line 195
const/4 v0, 0x0
return-object v0
.end method
.method static synthetic lambda$recordNextCallTime$6(JLcom/google/android/datatransport/runtime/TransportContext;Landroid/database/sqlite/SQLiteDatabase;)Ljava/lang/Object;
.registers 10
.param p0, "timestampMs" # J
.param p2, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p3, "db" # Landroid/database/sqlite/SQLiteDatabase;
.line 261
new-instance v0, Landroid/content/ContentValues;
invoke-direct {v0}, Landroid/content/ContentValues;-><init>()V
.line 262
.local v0, "values":Landroid/content/ContentValues;
invoke-static {p0, p1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v1
const-string v2, "next_request_ms"
invoke-virtual {v0, v2, v1}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Long;)V
.line 263
const/4 v1, 0x2
new-array v1, v1, [Ljava/lang/String;
.line 269
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v2
const/4 v3, 0x0
aput-object v2, v1, v3
.line 270
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object v2
invoke-static {v2}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result v2
invoke-static {v2}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v2
const/4 v3, 0x1
aput-object v2, v1, v3
.line 264
const-string/jumbo v2, "transport_contexts"
const-string v4, "backend_name = ? and priority = ?"
invoke-virtual {p3, v2, v0, v4, v1}, Landroid/database/sqlite/SQLiteDatabase;->update(Ljava/lang/String;Landroid/content/ContentValues;Ljava/lang/String;[Ljava/lang/String;)I
move-result v1
.line 273
.local v1, "rowsUpdated":I
const/4 v4, 0x0
if-ge v1, v3, :cond_50
.line 274
invoke-virtual {p2}, Lcom/google/android/datatransport/runtime/TransportContext;->getBackendName()Ljava/lang/String;
move-result-object v3
const-string v5, "backend_name"
invoke-virtual {v0, v5, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/String;)V
.line 275
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/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v3
const-string v5, "priority"
invoke-virtual {v0, v5, v3}, Landroid/content/ContentValues;->put(Ljava/lang/String;Ljava/lang/Integer;)V
.line 276
invoke-virtual {p3, v2, v4, v0}, Landroid/database/sqlite/SQLiteDatabase;->insert(Ljava/lang/String;Ljava/lang/String;Landroid/content/ContentValues;)J
.line 278
:cond_50
return-object v4
.end method
.method private loadEvents(Landroid/database/sqlite/SQLiteDatabase;Lcom/google/android/datatransport/runtime/TransportContext;)Ljava/util/List;
.registers 21
.param p1, "db" # Landroid/database/sqlite/SQLiteDatabase;
.param p2, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.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
.line 345
new-instance v0, Ljava/util/ArrayList;
invoke-direct {v0}, Ljava/util/ArrayList;-><init>()V
.line 346
.local v0, "events":Ljava/util/List;, "Ljava/util/List<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
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 v1
.line 347
.local v1, "contextId":Ljava/lang/Long;
if-nez v1, :cond_c
.line 348
return-object v0
.line 351
:cond_c
const-string v2, "_id"
const-string/jumbo v3, "transport_name"
const-string/jumbo v4, "timestamp_ms"
const-string/jumbo v5, "uptime_ms"
const-string v6, "payload_encoding"
const-string v7, "payload"
const-string v8, "code"
filled-new-array/range {v2 .. v8}, [Ljava/lang/String;
move-result-object v11
const/4 v2, 0x1
new-array v13, v2, [Ljava/lang/String;
const/4 v2, 0x0
.line 364
invoke-virtual {v1}, Ljava/lang/Long;->toString()Ljava/lang/String;
move-result-object v3
aput-object v3, v13, v2
const/4 v14, 0x0
const/4 v15, 0x0
const/16 v16, 0x0
move-object/from16 v2, p0
iget-object v3, v2, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->config:Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;
.line 368
invoke-virtual {v3}, Lcom/google/android/datatransport/runtime/scheduling/persistence/EventStoreConfig;->getLoadBatchSize()I
move-result v3
invoke-static {v3}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v17
.line 352
const-string v10, "events"
const-string v12, "context_id = ?"
move-object/from16 v9, p1
invoke-virtual/range {v9 .. v17}, 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 v3
move-object/from16 v4, p2
invoke-static {v0, v4}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$15;->lambdaFactory$(Ljava/util/List;Lcom/google/android/datatransport/runtime/TransportContext;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v5
.line 351
invoke-static {v3, v5}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.line 386
return-object v0
.end method
.method private loadMetadata(Landroid/database/sqlite/SQLiteDatabase;Ljava/util/List;)Ljava/util/Map;
.registers 16
.param p1, "db" # Landroid/database/sqlite/SQLiteDatabase;
.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 398
.local p2, "events":Ljava/util/List;, "Ljava/util/List<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
new-instance v0, Ljava/util/HashMap;
invoke-direct {v0}, Ljava/util/HashMap;-><init>()V
.line 399
.local v0, "metadataIndex":Ljava/util/Map;, "Ljava/util/Map<Ljava/lang/Long;Ljava/util/Set<Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Metadata;>;>;"
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "event_id IN ("
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
.line 400
.local v1, "whereClause":Ljava/lang/StringBuilder;
const/4 v2, 0x0
.local v2, "i":I
:goto_d
invoke-interface {p2}, Ljava/util/List;->size()I
move-result v3
if-ge v2, v3, :cond_30
.line 401
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 402
invoke-interface {p2}, Ljava/util/List;->size()I
move-result v3
add-int/lit8 v3, v3, -0x1
if-ge v2, v3, :cond_2d
.line 403
const/16 v3, 0x2c
invoke-virtual {v1, v3}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
.line 400
:cond_2d
add-int/lit8 v2, v2, 0x1
goto :goto_d
.line 406
.end local v2 # "i":I
:cond_30
const/16 v2, 0x29
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
.line 408
const-string v2, "event_id"
const-string v3, "name"
const-string/jumbo v4, "value"
filled-new-array {v2, v3, v4}, [Ljava/lang/String;
move-result-object v7
.line 412
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v8
const/4 v9, 0x0
const/4 v10, 0x0
const/4 v11, 0x0
const/4 v12, 0x0
.line 409
const-string v6, "event_metadata"
move-object v5, p1
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 v2
invoke-static {v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$$Lambda$16;->lambdaFactory$(Ljava/util/Map;)Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;
move-result-object v3
.line 408
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;
.line 429
return-object v0
.end method
.method private static maybeBase64Decode(Ljava/lang/String;)[B
.registers 2
.param p0, "value" # Ljava/lang/String;
.line 337
if-nez p0, :cond_4
.line 338
const/4 v0, 0x0
return-object v0
.line 340
:cond_4
const/4 v0, 0x0
invoke-static {p0, v0}, Landroid/util/Base64;->decode(Ljava/lang/String;I)[B
move-result-object v0
return-object v0
.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 453
.local p1, "retriable":Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;, "Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer<TT;>;"
.local p2, "failureHandler":Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;, "Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function<Ljava/lang/Throwable;TT;>;"
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 456
.local v0, "startTime":J
:goto_6
:try_start_6
invoke-interface {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Producer;->produce()Ljava/lang/Object;
move-result-object v2
:try_end_a
.catch Landroid/database/sqlite/SQLiteDatabaseLockedException; {:try_start_6 .. :try_end_a} :catch_b
return-object v2
.line 457
:catch_b
move-exception v2
.line 458
.local v2, "ex":Landroid/database/sqlite/SQLiteDatabaseLockedException;
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 459
invoke-interface {p2, v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v3
return-object v3
.line 461
:cond_23
const-wide/16 v3, 0x32
invoke-static {v3, v4}, Landroid/os/SystemClock;->sleep(J)V
.line 463
.end local v2 # "ex":Landroid/database/sqlite/SQLiteDatabaseLockedException;
goto :goto_6
.end method
.method private static toEncoding(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
.registers 2
.param p0, "value" # Ljava/lang/String;
.line 390
if-nez p0, :cond_5
.line 391
sget-object v0, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->PROTOBUF_ENCODING:Lcom/google/android/datatransport/Encoding;
return-object v0
.line 393
:cond_5
invoke-static {p0}, Lcom/google/android/datatransport/Encoding;->of(Ljava/lang/String;)Lcom/google/android/datatransport/Encoding;
move-result-object v0
return-object v0
.end method
.method private static toIdList(Ljava/lang/Iterable;)Ljava/lang/String;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/Iterable<",
"Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;",
">;)",
"Ljava/lang/String;"
}
.end annotation
.line 210
.local p0, "events":Ljava/lang/Iterable;, "Ljava/lang/Iterable<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
new-instance v0, Ljava/lang/StringBuilder;
const-string v1, "("
invoke-direct {v0, v1}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
.line 211
.local v0, "idList":Ljava/lang/StringBuilder;
invoke-interface {p0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v1
.line 212
.local v1, "iterator":Ljava/util/Iterator;, "Ljava/util/Iterator<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
:cond_b
:goto_b
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v2
if-eqz v2, :cond_2a
.line 213
invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v2
check-cast v2, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
invoke-virtual {v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;->getId()J
move-result-wide v2
invoke-virtual {v0, v2, v3}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
.line 214
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v2
if-eqz v2, :cond_b
.line 215
const/16 v2, 0x2c
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
goto :goto_b
.line 218
:cond_2a
const/16 v2, 0x29
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder;
.line 219
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
return-object v2
.end method
.method private static tryWithCursor(Landroid/database/Cursor;Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.registers 3
.param p0, "c" # Landroid/database/Cursor;
.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 547
.local p1, "function":Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;, "Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function<Landroid/database/Cursor;TT;>;"
: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 v0
:try_end_4
.catchall {:try_start_0 .. :try_end_4} :catchall_8
.line 549
invoke-interface {p0}, Landroid/database/Cursor;->close()V
.line 547
return-object v0
.line 549
:catchall_8
move-exception v0
invoke-interface {p0}, Landroid/database/Cursor;->close()V
throw v0
.end method
# virtual methods
.method public cleanUp()I
.registers 5
.line 316
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 317
.local v0, "oneWeekAgo":J
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 v2
invoke-direct {p0, v2}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
move-result-object v2
check-cast v2, Ljava/lang/Integer;
invoke-virtual {v2}, Ljava/lang/Integer;->intValue()I
move-result v2
return v2
.end method
.method public clearDb()V
.registers 2
.line 328
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;
.line 334
return-void
.end method
.method public close()V
.registers 2
.line 323
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
.line 324
return-void
.end method
.method getByteSize()J
.registers 5
.line 529
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 public getNextCallTime(Lcom/google/android/datatransport/runtime/TransportContext;)J
.registers 6
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.line 224
nop
.line 225
invoke-direct {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 229
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 230
invoke-virtual {p1}, Lcom/google/android/datatransport/runtime/TransportContext;->getPriority()Lcom/google/android/datatransport/Priority;
move-result-object v2
invoke-static {v2}, Lcom/google/android/datatransport/runtime/util/PriorityMapping;->toInt(Lcom/google/android/datatransport/Priority;)I
move-result v2
invoke-static {v2}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v2
const/4 v3, 0x1
aput-object v2, v1, v3
.line 226
const-string v2, "SELECT next_request_ms FROM transport_contexts WHERE backend_name = ? and priority = ?"
invoke-virtual {v0, v2, v1}, Landroid/database/sqlite/SQLiteDatabase;->rawQuery(Ljava/lang/String;[Ljava/lang/String;)Landroid/database/Cursor;
move-result-object v0
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 v1
.line 224
invoke-static {v0, v1}, 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 v0
check-cast v0, Ljava/lang/Long;
invoke-virtual {v0}, 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 3
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.line 242
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 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/Boolean;
invoke-virtual {v0}, Ljava/lang/Boolean;->booleanValue()Z
move-result v0
return v0
.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 293
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 3
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.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 284
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 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 persist(Lcom/google/android/datatransport/runtime/TransportContext;Lcom/google/android/datatransport/runtime/EventInternal;)Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;
.registers 8
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p2, "event" # Lcom/google/android/datatransport/runtime/EventInternal;
.line 90
const/4 v0, 0x3
new-array v0, v0, [Ljava/lang/Object;
.line 93
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 94
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 95
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
.line 90
const-string v1, "SQLiteEventStore"
const-string v2, "Storing event with priority=%s, name=%s for destination %s"
invoke-static {v1, v2, v0}, Lcom/google/android/datatransport/runtime/logging/Logging;->d(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/Object;)V
.line 96
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 97
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
.line 129
.local v0, "newRowId":J
const-wide/16 v2, 0x1
cmp-long v4, v0, v2
if-gez v4, :cond_35
.line 130
const/4 v2, 0x0
return-object v2
.line 132
: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 v2
return-object v2
.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 185
.local p1, "events":Ljava/lang/Iterable;, "Ljava/lang/Iterable<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
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
.line 186
return-void
.line 188
: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 189
invoke-static {p1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->toIdList(Ljava/lang/Iterable;)Ljava/lang/String;
move-result-object v1
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
.line 191
.local v0, "query":Ljava/lang/String;
invoke-static {v0}, 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 v1
invoke-direct {p0, v1}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->inTransaction(Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore$Function;)Ljava/lang/Object;
.line 197
return-void
.end method
.method public recordNextCallTime(Lcom/google/android/datatransport/runtime/TransportContext;J)V
.registers 5
.param p1, "transportContext" # Lcom/google/android/datatransport/runtime/TransportContext;
.param p2, "timestampMs" # J
.line 259
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 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;
.line 280
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 201
.local p1, "events":Ljava/lang/Iterable;, "Ljava/lang/Iterable<Lcom/google/android/datatransport/runtime/scheduling/persistence/PersistedEvent;>;"
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
.line 202
return-void
.line 205
: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 v1
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
.line 206
.local v0, "query":Ljava/lang/String;
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v1
invoke-virtual {v1, v0}, Landroid/database/sqlite/SQLiteDatabase;->compileStatement(Ljava/lang/String;)Landroid/database/sqlite/SQLiteStatement;
move-result-object v1
invoke-virtual {v1}, Landroid/database/sqlite/SQLiteStatement;->execute()V
.line 207
return-void
.end method
.method public runCriticalSection(Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection;)Ljava/lang/Object;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection<",
"TT;>;)TT;"
}
.end annotation
.line 488
.local p1, "criticalSection":Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection;, "Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection<TT;>;"
invoke-direct {p0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->getDb()Landroid/database/sqlite/SQLiteDatabase;
move-result-object v0
.line 489
.local v0, "db":Landroid/database/sqlite/SQLiteDatabase;
invoke-direct {p0, v0}, Lcom/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore;->ensureBeginTransaction(Landroid/database/sqlite/SQLiteDatabase;)V
.line 491
:try_start_7
invoke-interface {p1}, Lcom/google/android/datatransport/runtime/synchronization/SynchronizationGuard$CriticalSection;->execute()Ljava/lang/Object;
move-result-object v1
.line 492
.local v1, "result":Ljava/lang/Object;, "TT;"
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->setTransactionSuccessful()V
:try_end_e
.catchall {:try_start_7 .. :try_end_e} :catchall_13
.line 493
nop
.line 495
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
.line 493
return-object v1
.line 495
.end local v1 # "result":Ljava/lang/Object;, "TT;"
:catchall_13
move-exception v1
invoke-virtual {v0}, Landroid/database/sqlite/SQLiteDatabase;->endTransaction()V
throw v1
.end method