package com.strmr.ps.ui.player;

import android.media.MediaExtractor;
import android.media.MediaFormat;
import defpackage.ak1;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.ik2;
import defpackage.kq;
import defpackage.n89;
import defpackage.s38;
import defpackage.vx8;
import defpackage.y41;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.ExecutorService;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
@DebugMetadata(c = "com.strmr.ps.ui.player.VideoPlayerActivity$startFrameRatePreflight$1$1", f = "VideoPlayerActivity.kt", i = {}, l = {}, m = "invokeSuspend", n = {}, s = {})
@vx8
final class ao extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
    public final /* synthetic */ String a;
    public final /* synthetic */ VideoPlayerActivity b;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public ao(VideoPlayerActivity videoPlayerActivity, String str, Continuation continuation) {
        super(2, continuation);
        this.a = str;
        this.b = videoPlayerActivity;
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Continuation create(Object obj, Continuation continuation) {
        return new ao(this.b, this.a, continuation);
    }

    @Override // defpackage.gr3
    public final Object invoke(Object obj, Object obj2) {
        ao aoVar = (ao) create((ak1) obj, (Continuation) obj2);
        e6a e6aVar = e6a.a;
        aoVar.invokeSuspend(e6aVar);
        return e6aVar;
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Object invokeSuspend(Object obj) {
        e6a e6aVar;
        Iterable iterable;
        ck1 ck1Var = ck1.a;
        s38.b(obj);
        MediaExtractor mediaExtractor = new MediaExtractor();
        try {
            mediaExtractor.setDataSource(this.a);
            int trackCount = mediaExtractor.getTrackCount();
            int i = 0;
            while (true) {
                e6aVar = e6a.a;
                if (i >= trackCount) {
                    break;
                }
                MediaFormat trackFormat = mediaExtractor.getTrackFormat(i);
                cr4.f(trackFormat, "getTrackFormat(...)");
                String string = trackFormat.getString("mime");
                if (string != null && n89.ar(string, "video/", false)) {
                    mediaExtractor.selectTrack(i);
                    ArrayList arrayList = new ArrayList();
                    while (arrayList.size() < 33) {
                        long sampleTime = mediaExtractor.getSampleTime();
                        if (sampleTime < 0) {
                            break;
                        }
                        arrayList.add(Boxing.boxLong(sampleTime));
                        if (!mediaExtractor.advance()) {
                            break;
                        }
                    }
                    int size = arrayList.size();
                    VideoPlayerActivity videoPlayerActivity = this.b;
                    if (size > 13) {
                        Iterator it = y41.u(arrayList, 3).iterator();
                        if (it.hasNext()) {
                            ArrayList arrayList2 = new ArrayList();
                            Object next = it.next();
                            while (it.hasNext()) {
                                Object next2 = it.next();
                                arrayList2.add(Boxing.boxLong(((Number) next2).longValue() - ((Number) next).longValue()));
                                next = next2;
                            }
                            iterable = arrayList2;
                        } else {
                            iterable = ik2.a;
                        }
                        ArrayList arrayList3 = new ArrayList();
                        for (Object obj2 : iterable) {
                            if (((Number) obj2).longValue() > 0) {
                                arrayList3.add(obj2);
                            }
                        }
                        if (arrayList3.size() >= 10) {
                            List listBi = y41.bi(arrayList3);
                            long jLongValue = ((Number) listBi.get(listBi.size() / 2)).longValue();
                            float f = (float) (1000000.0d / jLongValue);
                            if (f >= 10.0f) {
                                float fBp = VideoPlayerActivity.bp(f);
                                videoPlayerActivity.cx = fBp;
                                ExecutorService executorService = kq.a;
                                kq.h("FrameRate", "Preflight frame-duration: raw=" + f + "fps, snapped=" + fBp + "fps (median=" + jLongValue + "us, " + arrayList3.size() + " samples)");
                                mediaExtractor.release();
                                return e6aVar;
                            }
                        }
                    }
                    if (trackFormat.containsKey("frame-rate")) {
                        float integer = trackFormat.getInteger("frame-rate");
                        if (integer >= 10.0f) {
                            videoPlayerActivity.cx = integer;
                            ExecutorService executorService2 = kq.a;
                            kq.h("FrameRate", "Preflight container metadata: " + integer + "fps (integer, no sub-frame precision)");
                        }
                    }
                }
                i++;
            }
            mediaExtractor.release();
            return e6aVar;
        } catch (Throwable th) {
            mediaExtractor.release();
            throw th;
        }
    }
}