package defpackage;

import android.util.Log;
import androidx.media3.exoplayer.audio.AudioRendererEventListener;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: loaded from: classes3.dex */
public final /* synthetic */ class f17 implements Runnable {
    public final /* synthetic */ int a;
    public final /* synthetic */ Object b;
    public final /* synthetic */ int c;
    public final /* synthetic */ long d;
    public final /* synthetic */ long e;

    public /* synthetic */ f17(Object obj, int i, long j, long j2, int i2) {
        this.a = i2;
        this.b = obj;
        this.c = i;
        this.d = j;
        this.e = j2;
    }

    @Override // java.lang.Runnable
    public final void run() {
        switch (this.a) {
            case 0:
                g17 g17Var = (g17) this.b;
                AtomicBoolean atomicBoolean = g17Var.h;
                AtomicInteger atomicInteger = g17Var.m;
                if (atomicBoolean.get()) {
                    return;
                }
                int i = atomicInteger.get();
                int i2 = this.c;
                if (i != i2) {
                    return;
                }
                vz0 vz0Var = new vz0(g17Var.b, g17Var.a);
                long j = this.d;
                long j2 = this.e;
                byte[] bArrA = vz0Var.a(j, j2);
                if (g17Var.h.get() || atomicInteger.get() != i2) {
                    return;
                }
                if (bArrA == null) {
                    g17Var.g(i2, j, j2);
                    return;
                }
                g17Var.j.incrementAndGet();
                q59 q59Var = g17Var.i;
                if (q59Var != null) {
                    q59Var.b(j, bArrA);
                    return;
                }
                return;
            case 1:
                g17 g17Var2 = (g17) this.b;
                AtomicBoolean atomicBoolean2 = g17Var2.h;
                AtomicInteger atomicInteger2 = g17Var2.m;
                if (atomicBoolean2.get()) {
                    return;
                }
                int i3 = atomicInteger2.get();
                int i4 = this.c;
                if (i3 != i4) {
                    return;
                }
                try {
                    Thread.sleep(1000L);
                    vz0 vz0Var2 = new vz0(g17Var2.b, g17Var2.a);
                    long j3 = this.d;
                    long j4 = this.e;
                    byte[] bArrA2 = vz0Var2.a(j3, j4);
                    if (g17Var2.h.get() || atomicInteger2.get() != i4) {
                        return;
                    }
                    if (bArrA2 == null) {
                        g17Var2.g(i4, j3, j4);
                        return;
                    }
                    g17Var2.j.incrementAndGet();
                    q59 q59Var2 = g17Var2.i;
                    if (q59Var2 != null) {
                        q59Var2.b(j3, bArrA2);
                        return;
                    }
                    return;
                } catch (InterruptedException unused) {
                    Thread.currentThread().interrupt();
                    return;
                }
            case 2:
                g17 g17Var3 = (g17) this.b;
                long j5 = this.d;
                long j6 = this.e;
                AtomicBoolean atomicBoolean3 = g17Var3.h;
                AtomicInteger atomicInteger3 = g17Var3.m;
                if (atomicBoolean3.get()) {
                    return;
                }
                int i5 = atomicInteger3.get();
                int i6 = this.c;
                if (i5 != i6) {
                    return;
                }
                try {
                    Response responseExecute = g17Var3.b.newCall(new Request.Builder().url(g17Var3.a).header(RtspHeaders.RANGE, "bytes=" + j5 + "-" + j6).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    try {
                        if (atomicInteger3.get() != i6) {
                            f21.a(responseExecute, null);
                            return;
                        }
                        if (responseExecute.code() == 206) {
                            ResponseBody responseBodyBody = responseExecute.body();
                            g17Var3.j(responseBodyBody != null ? responseBodyBody.byteStream() : null, j5, -1L, i6);
                        } else if (responseExecute.isSuccessful()) {
                            ResponseBody responseBodyBody2 = responseExecute.body();
                            g17Var3.j(responseBodyBody2 != null ? responseBodyBody2.byteStream() : null, 0L, j5, i6);
                        } else {
                            Log.w("StreamSession", "Single Range HTTP " + responseExecute.code() + ", degrading to SINGLE_GET [gen=" + i6 + "]");
                            g17Var3.c(i6);
                        }
                        f21.a(responseExecute, null);
                        return;
                    } finally {
                    }
                } catch (Exception e) {
                    if (g17Var3.h.get() || atomicInteger3.get() != i6) {
                        return;
                    }
                    Log.w("StreamSession", "Single Range failed: " + e.getMessage() + ", degrading to SINGLE_GET [gen=" + i6 + "]");
                    g17Var3.c(i6);
                    return;
                }
            default:
                ((AudioRendererEventListener.EventDispatcher) this.b).lambda$underrun$4(this.c, this.d, this.e);
                return;
        }
    }
}