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;

/* renamed from: ᵟᵾ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C3089 implements Closeable {

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public static final C1928 f11776 = new C1928("proto");

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final InterfaceC0313 f11777;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final InterfaceC2765 f11778;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final C1408 f11779;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final C5121 f11780;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final InterfaceC0313 f11781;

    public C3089(InterfaceC0313 interfaceC0313, InterfaceC0313 interfaceC03132, C5121 c5121, C1408 c1408, InterfaceC2765 interfaceC2765) {
        this.f11779 = c1408;
        this.f11777 = interfaceC0313;
        this.f11781 = interfaceC03132;
        this.f11780 = c5121;
        this.f11778 = interfaceC2765;
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public static Long m7414(SQLiteDatabase sQLiteDatabase, C5456 c5456) {
        StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?");
        ArrayList arrayList = new ArrayList(Arrays.asList(c5456.f20490, String.valueOf(AbstractC3999.m8840(c5456.f20489))));
        byte[] bArr = c5456.f20491;
        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();
        }
    }

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public static Object m7415(Cursor cursor, InterfaceC5372 interfaceC5372) {
        try {
            return interfaceC5372.apply(cursor);
        } finally {
            cursor.close();
        }
    }

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public static String m7416(Iterable iterable) {
        StringBuilder sb = new StringBuilder("(");
        Iterator it = iterable.iterator();
        while (it.hasNext()) {
            sb.append(((C1921) it.next()).f7729);
            if (it.hasNext()) {
                sb.append(',');
            }
        }
        sb.append(')');
        return sb.toString();
    }

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

    /* renamed from: ˌʾˀ, reason: contains not printable characters */
    public final Object m7417(InterfaceC5372 interfaceC5372) {
        SQLiteDatabase sQLiteDatabaseM7421 = m7421();
        sQLiteDatabaseM7421.beginTransaction();
        try {
            Object objApply = interfaceC5372.apply(sQLiteDatabaseM7421);
            sQLiteDatabaseM7421.setTransactionSuccessful();
            return objApply;
        } finally {
            sQLiteDatabaseM7421.endTransaction();
        }
    }

    /* renamed from: ᵞʡ, reason: contains not printable characters */
    public final ArrayList m7418(SQLiteDatabase sQLiteDatabase, C5456 c5456, int i) {
        ArrayList arrayList = new ArrayList();
        Long lM7414 = m7414(sQLiteDatabase, c5456);
        if (lM7414 == null) {
            return arrayList;
        }
        m7415(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[]{lM7414.toString()}, null, null, null, String.valueOf(i)), new C0817(this, arrayList, c5456, 9));
        return arrayList;
    }

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public final Object m7419(InterfaceC1777 interfaceC1777) {
        SQLiteDatabase sQLiteDatabaseM7421 = m7421();
        InterfaceC0313 interfaceC0313 = this.f11781;
        long jM1696 = interfaceC0313.m1696();
        while (true) {
            try {
                sQLiteDatabaseM7421.beginTransaction();
                try {
                    Object objMo1598 = interfaceC1777.mo1598();
                    sQLiteDatabaseM7421.setTransactionSuccessful();
                    return objMo1598;
                } finally {
                    sQLiteDatabaseM7421.endTransaction();
                }
            } catch (SQLiteDatabaseLockedException e) {
                if (interfaceC0313.m1696() >= this.f11780.f19080 + jM1696) {
                    throw new SynchronizationException("Timed out while trying to acquire the lock.", e);
                }
                SystemClock.sleep(50L);
            }
        }
    }

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final void m7420(long j, EnumC2677 enumC2677, String str) {
        m7417(new C4830(str, enumC2677, j));
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final SQLiteDatabase m7421() {
        C1408 c1408 = this.f11779;
        Objects.requireNonNull(c1408);
        InterfaceC0313 interfaceC0313 = this.f11781;
        long jM1696 = interfaceC0313.m1696();
        while (true) {
            try {
                return c1408.getWritableDatabase();
            } catch (SQLiteDatabaseLockedException e) {
                if (interfaceC0313.m1696() >= this.f11780.f19080 + jM1696) {
                    throw new SynchronizationException("Timed out while trying to open db.", e);
                }
                SystemClock.sleep(50L);
            }
        }
    }
}