package defpackage;

import android.net.Uri;
import android.util.Log;
import androidx.media3.common.C;
import androidx.media3.common.util.UnstableApi;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.datasource.DataSpec;
import androidx.media3.datasource.HttpDataSource;
import androidx.media3.datasource.TransferListener;
import androidx.media3.exoplayer.ExoPlayer;
import androidx.media3.exoplayer.upstream.CmcdData;
import com.google.android.gms.measurement.api.AppMeasurementSdk;
import java.io.EOFException;
import java.io.IOException;
import java.net.ProtocolException;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.List;
import java.util.Map;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0007\u0018\u00002\u00020\u0001:\u0001\u0002¨\u0006\u0003"}, d2 = {"Lg48;", "Landroidx/media3/datasource/HttpDataSource;", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@UnstableApi
public final class g48 implements HttpDataSource {
    public static final long[] d = {250, 1000, C.DEFAULT_MAX_SEEK_TO_PREVIOUS_POSITION_MS};
    public static final long[] e = {0, 500, ExoPlayer.DEFAULT_DETACH_SURFACE_TIMEOUT_MS};
    public final HttpDataSource a;
    public DataSpec b;
    public long c;

    @Metadata(d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0010\u0016\n\u0002\b\u0004\b\u0086\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0006\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0006\u0010\u0007R\u0014\u0010\t\u001a\u00020\b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\t\u0010\nR\u0014\u0010\u000b\u001a\u00020\b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000b\u0010\n¨\u0006\f"}, d2 = {"Lg48$a;", "", "", "TAG", "Ljava/lang/String;", "", "MAX_READ_RETRIES", "I", "", "RETRY_DELAYS_MS", "[J", "CONNECTION_CLOSE_DELAYS_MS", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class a {
    }

    public g48(HttpDataSource httpDataSource) {
        this.a = httpDataSource;
    }

    @Override // androidx.media3.datasource.DataSource
    public final void addTransferListener(TransferListener transferListener) {
        cr4.g(transferListener, "transferListener");
        this.a.addTransferListener(transferListener);
    }

    @Override // androidx.media3.datasource.HttpDataSource
    public final void clearAllRequestProperties() {
        this.a.clearAllRequestProperties();
    }

    @Override // androidx.media3.datasource.HttpDataSource
    public final void clearRequestProperty(String str) {
        cr4.g(str, AppMeasurementSdk.ConditionalUserProperty.NAME);
        this.a.clearRequestProperty(str);
    }

    @Override // androidx.media3.datasource.HttpDataSource, androidx.media3.datasource.DataSource
    public final void close() throws HttpDataSource.HttpDataSourceException {
        this.b = null;
        this.c = 0L;
        this.a.close();
    }

    @Override // androidx.media3.datasource.HttpDataSource
    public final int getResponseCode() {
        return this.a.getResponseCode();
    }

    @Override // androidx.media3.datasource.HttpDataSource, androidx.media3.datasource.DataSource
    public final Map getResponseHeaders() {
        Map<String, List<String>> responseHeaders = this.a.getResponseHeaders();
        cr4.f(responseHeaders, "getResponseHeaders(...)");
        return responseHeaders;
    }

    @Override // androidx.media3.datasource.DataSource
    public final Uri getUri() {
        return this.a.getUri();
    }

    @Override // androidx.media3.datasource.HttpDataSource, androidx.media3.datasource.DataSource
    public final long open(DataSpec dataSpec) {
        cr4.g(dataSpec, "dataSpec");
        this.b = dataSpec;
        this.c = 0L;
        return this.a.open(dataSpec);
    }

    /* JADX WARN: Code restructure failed: missing block: B:47:0x007d, code lost:
    
        r7 = defpackage.g48.e;
     */
    @Override // androidx.media3.datasource.HttpDataSource, androidx.media3.common.DataReader
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final int read(byte[] bArr, int i, int i2) throws IOException {
        int i3;
        long[] jArr;
        int i4;
        HttpDataSource httpDataSource = this.a;
        cr4.g(bArr, "buffer");
        try {
            int i5 = httpDataSource.read(bArr, i, i2);
            if (i5 <= 0) {
                return i5;
            }
            this.c += (long) i5;
            return i5;
        } catch (IOException e2) {
            e = e2;
            DataSpec dataSpec = this.b;
            if (dataSpec == null) {
                throw e;
            }
            if (!(e instanceof HttpDataSource.InvalidResponseCodeException) ? !((e.getCause() instanceof UnknownHostException) || (e instanceof UnknownHostException)) : !(400 <= (i4 = ((HttpDataSource.InvalidResponseCodeException) e).responseCode) && i4 < 500 && i4 != 408 && i4 != 429)) {
                n41.ab("Non-recoverable error, skipping retry: ", e.getMessage(), "RetryDataSource");
                throw e;
            }
            Throwable cause = e;
            while (true) {
                i3 = 1;
                if (cause == null) {
                    jArr = d;
                    break;
                }
                if ((cause instanceof EOFException) || (cause instanceof SocketException)) {
                    break;
                }
                if (cause instanceof ProtocolException) {
                    String message = ((ProtocolException) cause).getMessage();
                    if (message == null) {
                        message = "";
                    }
                    if (n89.l(message, "unexpected end of stream", true) || n89.l(message, "closed", true)) {
                        break;
                    }
                }
                cause = cause.getCause();
            }
            while (i3 < 4) {
                long j = jArr[i3 - 1];
                IOException iOException = e;
                Log.w("RetryDataSource", "Read failed at +" + this.c + "B, retry #" + i3 + " in " + j + "ms: " + e.getMessage());
                if (j > 0) {
                    try {
                        Thread.sleep(j);
                    } catch (InterruptedException unused) {
                        Thread.currentThread().interrupt();
                        throw iOException;
                    }
                }
                try {
                    httpDataSource.close();
                } catch (IOException unused2) {
                }
                try {
                    long j2 = dataSpec.position;
                    long j3 = this.c;
                    long j4 = j2 + j3;
                    long j5 = dataSpec.length;
                    long j6 = -1;
                    if (j5 != -1) {
                        j6 = j5 - j3;
                        if (j6 <= 0) {
                            throw iOException;
                        }
                    }
                    DataSpec dataSpecBuild = dataSpec.buildUpon().setPosition(j4).setLength(j6).build();
                    cr4.f(dataSpecBuild, "build(...)");
                    httpDataSource.open(dataSpecBuild);
                    this.b = dataSpecBuild;
                    this.c = 0L;
                    int i6 = httpDataSource.read(bArr, i, i2);
                    if (i6 > 0) {
                        this.c += (long) i6;
                    }
                    Log.w("RetryDataSource", "Retry #" + i3 + " succeeded, resumed at position " + j4);
                    return i6;
                } catch (IOException unused3) {
                    if (i3 == 3) {
                        Log.e("RetryDataSource", "All 3 retries exhausted, propagating error");
                        throw iOException;
                    }
                    i3++;
                    e = iOException;
                }
            }
            throw e;
        }
    }

    @Override // androidx.media3.datasource.HttpDataSource
    public final void setRequestProperty(String str, String str2) {
        cr4.g(str, AppMeasurementSdk.ConditionalUserProperty.NAME);
        cr4.g(str2, AppMeasurementSdk.ConditionalUserProperty.VALUE);
        this.a.setRequestProperty(str, str2);
    }
}