package defpackage;

import android.util.Log;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import androidx.media3.exoplayer.video.VideoRendererEventListener;
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: classes.dex */
public final /* synthetic */ class fia implements Runnable {
    public final /* synthetic */ int a;
    public final /* synthetic */ Object b;
    public final /* synthetic */ long c;
    public final /* synthetic */ int d;

    public /* synthetic */ fia(int i, long j, VideoRendererEventListener.EventDispatcher eventDispatcher) {
        this.a = 1;
        this.b = eventDispatcher;
        this.c = j;
        this.d = i;
    }

    @Override // java.lang.Runnable
    public final void run() {
        switch (this.a) {
            case 0:
                ((VideoRendererEventListener.EventDispatcher) this.b).lambda$droppedFrames$3(this.d, this.c);
                return;
            case 1:
                ((VideoRendererEventListener.EventDispatcher) this.b).lambda$reportVideoFrameProcessingOffset$4(this.c, this.d);
                return;
            default:
                g17 g17Var = (g17) this.b;
                long j = this.c;
                AtomicBoolean atomicBoolean = g17Var.h;
                AtomicInteger atomicInteger = g17Var.m;
                if (atomicBoolean.get()) {
                    return;
                }
                int i = atomicInteger.get();
                int i2 = this.d;
                if (i != i2) {
                    return;
                }
                try {
                    Response responseExecute = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    try {
                        if (atomicInteger.get() != i2) {
                            f21.a(responseExecute, null);
                            return;
                        }
                        if (responseExecute.isSuccessful()) {
                            ResponseBody responseBodyBody = responseExecute.body();
                            g17Var.j(responseBodyBody != null ? responseBodyBody.byteStream() : null, 0L, j, i2);
                            f21.a(responseExecute, null);
                            return;
                        }
                        Log.e("StreamSession", "Single GET HTTP " + responseExecute.code() + ", marking FAILED [gen=" + i2 + "]");
                        if (atomicInteger.get() == i2) {
                            g17Var.f();
                        }
                        f21.a(responseExecute, null);
                        return;
                    } finally {
                    }
                } catch (Exception e) {
                    if (g17Var.h.get() || atomicInteger.get() != i2) {
                        return;
                    }
                    Log.e("StreamSession", "Single GET failed: " + e.getMessage() + " [gen=" + i2 + "]");
                    g17Var.f();
                    return;
                }
        }
    }

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