package androidx.media3.datasource;

import E3.q;
import J3.B;
import J3.w;
import J3.x;
import J3.y;
import a.AbstractC0872a;
import android.content.Context;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.net.Uri;
import androidx.media3.common.util.Assertions;
import androidx.media3.common.util.BitmapLoader;
import androidx.media3.common.util.UnstableApi;
import androidx.media3.common.util.Util;
import androidx.media3.datasource.DataSource;
import androidx.media3.datasource.DefaultDataSource;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;

/* JADX INFO: loaded from: classes.dex */
@UnstableApi
public final class DataSourceBitmapLoader implements BitmapLoader {
    public static final q DEFAULT_EXECUTOR_SERVICE = AbstractC0872a.X(new b());
    private final DataSource.Factory dataSourceFactory;
    private final x listeningExecutorService;
    private final BitmapFactory.Options options;

    public DataSourceBitmapLoader(Context context) {
        this((x) Assertions.checkStateNotNull((x) DEFAULT_EXECUTOR_SERVICE.get()), new DefaultDataSource.Factory(context));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Bitmap lambda$decodeBitmap$1(byte[] bArr) {
        return BitmapUtil.decode(bArr, bArr.length, this.options);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Bitmap lambda$loadBitmap$2(Uri uri) {
        return load(this.dataSourceFactory.createDataSource(), uri, this.options);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static x lambda$static$0() {
        ExecutorService executorServiceNewSingleThreadExecutor = Executors.newSingleThreadExecutor();
        return executorServiceNewSingleThreadExecutor instanceof x ? (x) executorServiceNewSingleThreadExecutor : executorServiceNewSingleThreadExecutor instanceof ScheduledExecutorService ? new B((ScheduledExecutorService) executorServiceNewSingleThreadExecutor) : new y(executorServiceNewSingleThreadExecutor);
    }

    private static Bitmap load(DataSource dataSource, Uri uri, BitmapFactory.Options options) {
        try {
            dataSource.open(new DataSpec(uri));
            byte[] toEnd = DataSourceUtil.readToEnd(dataSource);
            return BitmapUtil.decode(toEnd, toEnd.length, options);
        } finally {
            dataSource.close();
        }
    }

    @Override // androidx.media3.common.util.BitmapLoader
    public w decodeBitmap(byte[] bArr) {
        return ((y) this.listeningExecutorService).a(new c(0, this, bArr));
    }

    @Override // androidx.media3.common.util.BitmapLoader
    public w loadBitmap(Uri uri) {
        return ((y) this.listeningExecutorService).a(new c(1, this, uri));
    }

    @Override // androidx.media3.common.util.BitmapLoader
    public boolean supportsMimeType(String str) {
        return Util.isBitmapFactorySupportedMimeType(str);
    }

    public DataSourceBitmapLoader(x xVar, DataSource.Factory factory) {
        this(xVar, factory, null);
    }

    public DataSourceBitmapLoader(x xVar, DataSource.Factory factory, BitmapFactory.Options options) {
        this.listeningExecutorService = xVar;
        this.dataSourceFactory = factory;
        this.options = options;
    }
}
