package androidx.media3.datasource;

import android.content.Context;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.net.Uri;
import androidx.annotation.Nullable;
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 com.google.common.base.h;
import com.google.common.base.l;
import com.google.common.util.concurrent.b0;
import com.google.common.util.concurrent.w;
import com.google.common.util.concurrent.x;
import com.google.common.util.concurrent.y;
import java.io.IOException;
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 l DEFAULT_EXECUTOR_SERVICE = h.n(new d());
    private final DataSource.Factory dataSourceFactory;
    private final x listeningExecutorService;
    private final int maximumOutputDimension;

    @Nullable
    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) throws Exception {
        return BitmapUtil.decode(bArr, bArr.length, this.options, this.maximumOutputDimension);
    }

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

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

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

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

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

    @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, @Nullable BitmapFactory.Options options) {
        this(xVar, factory, options, -1);
    }

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