package defpackage;

import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabaseLockedException;
import android.os.SystemClock;
import android.util.Base64;
import com.google.android.datatransport.runtime.synchronization.SynchronizationException;
import j$.util.Objects;
import java.io.Closeable;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;

/* JADX INFO: renamed from: ˀʽᵮˏ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C0520 implements Closeable {

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public static final C0160 f2690 = new C0160("proto");

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final C2278 f2691;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final InterfaceC4630 f2692;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final InterfaceC4630 f2693;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public final C4104 f2694;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public final InterfaceC2142 f2695;

    public C0520(InterfaceC4630 interfaceC4630, InterfaceC4630 interfaceC46302, C4104 c4104, C2278 c2278, InterfaceC2142 interfaceC2142) {
        this.f2691 = c2278;
        this.f2693 = interfaceC4630;
        this.f2692 = interfaceC46302;
        this.f2694 = c4104;
        this.f2695 = interfaceC2142;
    }

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public static String m2008(Iterable iterable) {
        StringBuilder sb = new StringBuilder("(");
        Iterator it = iterable.iterator();
        while (it.hasNext()) {
            sb.append(((C0279) it.next()).f1901);
            if (it.hasNext()) {
                sb.append(',');
            }
        }
        sb.append(')');
        return sb.toString();
    }

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public static Long m2009(SQLiteDatabase sQLiteDatabase, C3147 c3147) {
        StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?");
        ArrayList arrayList = new ArrayList(Arrays.asList(c3147.f11994, String.valueOf(AbstractC4151.m9068(c3147.f11993))));
        byte[] bArr = c3147.f11992;
        if (bArr != null) {
            sb.append(" and extras = ?");
            arrayList.add(Base64.encodeToString(bArr, 0));
        } else {
            sb.append(" and extras is null");
        }
        Cursor cursorQuery = sQLiteDatabase.query("transport_contexts", new String[]{"_id"}, sb.toString(), (String[]) arrayList.toArray(new String[0]), null, null, null);
        try {
            return !cursorQuery.moveToNext() ? null : Long.valueOf(cursorQuery.getLong(0));
        } finally {
            cursorQuery.close();
        }
    }

    /* JADX INFO: renamed from: ᵸˆˁ, reason: contains not printable characters */
    public static Object m2010(Cursor cursor, InterfaceC4590 interfaceC4590) {
        try {
            return interfaceC4590.apply(cursor);
        } finally {
            cursor.close();
        }
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        this.f2691.close();
    }

    /* JADX INFO: renamed from: ˏːˆ, reason: contains not printable characters */
    public final void m2011(long j, EnumC1197 enumC1197, String str) {
        m2013(new C3413(str, enumC1197, j));
    }

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final Object m2012(InterfaceC1633 interfaceC1633) {
        SQLiteDatabase sQLiteDatabaseM2015 = m2015();
        InterfaceC4630 interfaceC4630 = this.f2692;
        long jM9768 = interfaceC4630.m9768();
        while (true) {
            try {
                sQLiteDatabaseM2015.beginTransaction();
                try {
                    Object objMo2135 = interfaceC1633.mo2135();
                    sQLiteDatabaseM2015.setTransactionSuccessful();
                    return objMo2135;
                } finally {
                    sQLiteDatabaseM2015.endTransaction();
                }
            } catch (SQLiteDatabaseLockedException e) {
                if (interfaceC4630.m9768() >= ((long) this.f2694.f15720) + jM9768) {
                    throw new SynchronizationException("Timed out while trying to acquire the lock.", e);
                }
                SystemClock.sleep(50L);
            }
        }
    }

    /* JADX INFO: renamed from: ᵟᵹᵙ, reason: contains not printable characters */
    public final Object m2013(InterfaceC4590 interfaceC4590) {
        SQLiteDatabase sQLiteDatabaseM2015 = m2015();
        sQLiteDatabaseM2015.beginTransaction();
        try {
            Object objApply = interfaceC4590.apply(sQLiteDatabaseM2015);
            sQLiteDatabaseM2015.setTransactionSuccessful();
            return objApply;
        } finally {
            sQLiteDatabaseM2015.endTransaction();
        }
    }

    /* JADX INFO: renamed from: ᵱʡˏ, reason: contains not printable characters */
    public final ArrayList m2014(SQLiteDatabase sQLiteDatabase, C3147 c3147, int i) {
        ArrayList arrayList = new ArrayList();
        Long lM2009 = m2009(sQLiteDatabase, c3147);
        if (lM2009 == null) {
            return arrayList;
        }
        m2010(sQLiteDatabase.query("events", new String[]{"_id", "transport_name", "timestamp_ms", "uptime_ms", "payload_encoding", "payload", "code", "inline", "product_id", "pseudonymous_id", "experiment_ids_clear_blob", "experiment_ids_encrypted_blob"}, "context_id = ?", new String[]{lM2009.toString()}, null, null, null, String.valueOf(i)), new C4021(this, arrayList, c3147, 9));
        return arrayList;
    }

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final SQLiteDatabase m2015() {
        C2278 c2278 = this.f2691;
        Objects.requireNonNull(c2278);
        InterfaceC4630 interfaceC4630 = this.f2692;
        long jM9768 = interfaceC4630.m9768();
        while (true) {
            try {
                return c2278.getWritableDatabase();
            } catch (SQLiteDatabaseLockedException e) {
                if (interfaceC4630.m9768() >= ((long) this.f2694.f15720) + jM9768) {
                    throw new SynchronizationException("Timed out while trying to open db.", e);
                }
                SystemClock.sleep(50L);
            }
        }
    }
}