package androidx.media3.session;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.database.Cursor;
import android.net.Uri;
import android.os.Build;
import androidx.media3.common.util.BackgroundExecutor;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: loaded from: classes.dex */
final class AndroidAutoConnectionStateObserver {
    private static final String BROADCAST_INTENT = "androidx.car.app.connection.action.CAR_CONNECTION_UPDATED";
    private static final String QUERY_COLUMN = "CarConnectionState";
    private static final Uri QUERY_URI = Uri.parse("content://androidx.car.app.connection");
    private final Executor backgroundExecutor;
    private final AndroidAutoChangeReceiver changeReceiver;
    private final Context context;
    private final AtomicBoolean isConnected;
    private final AtomicBoolean isReleased;
    private final Runnable listener;

    public final class AndroidAutoChangeReceiver extends BroadcastReceiver {
        private AndroidAutoChangeReceiver() {
        }

        @Override // android.content.BroadcastReceiver
        public void onReceive(Context context, Intent intent) {
            AndroidAutoConnectionStateObserver.this.backgroundExecutor.execute(new a(AndroidAutoConnectionStateObserver.this, 2));
        }
    }

    public AndroidAutoConnectionStateObserver(Context context, Runnable runnable) {
        this.context = context.getApplicationContext();
        this.listener = runnable;
        Executor executor = BackgroundExecutor.get();
        this.backgroundExecutor = executor;
        this.changeReceiver = new AndroidAutoChangeReceiver();
        this.isConnected = new AtomicBoolean();
        this.isReleased = new AtomicBoolean();
        executor.execute(new a(this, 1));
    }

    public static /* synthetic */ void access$200(AndroidAutoConnectionStateObserver androidAutoConnectionStateObserver) {
        androidAutoConnectionStateObserver.updateConnectionState();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$new$0() {
        IntentFilter intentFilter = new IntentFilter(BROADCAST_INTENT);
        if (Build.VERSION.SDK_INT >= 33) {
            this.context.registerReceiver(this.changeReceiver, intentFilter, 2);
        } else {
            this.context.registerReceiver(this.changeReceiver, intentFilter);
        }
        updateConnectionState();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$release$1() {
        this.context.unregisterReceiver(this.changeReceiver);
    }

    private boolean queryConnectionState() {
        Cursor cursorQuery;
        try {
            cursorQuery = this.context.getContentResolver().query(QUERY_URI, new String[]{QUERY_COLUMN}, null, null, null);
        } catch (Exception unused) {
            return false;
        }
        if (cursorQuery == null) {
            if (cursorQuery != null) {
            }
            return false;
        }
        try {
            int columnIndex = cursorQuery.getColumnIndex(QUERY_COLUMN);
            if (columnIndex != -1 && cursorQuery.moveToNext()) {
                boolean z = cursorQuery.getInt(columnIndex) != 0;
                cursorQuery.close();
                return z;
            }
        } finally {
        }
        return false;
        cursorQuery.close();
        return false;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void updateConnectionState() {
        boolean z = this.isConnected.get();
        boolean zQueryConnectionState = queryConnectionState();
        this.isConnected.set(zQueryConnectionState);
        if (z == zQueryConnectionState || this.isReleased.get()) {
            return;
        }
        this.listener.run();
    }

    public boolean isConnected() {
        return this.isConnected.get();
    }

    public void release() {
        if (this.isReleased.getAndSet(true)) {
            return;
        }
        this.backgroundExecutor.execute(new a(this, 0));
    }
}