package com.google.android.gms.internal.ads;

import androidx.annotation.Nullable;
import java.util.ArrayDeque;
import java.util.ArrayList;
import java.util.PriorityQueue;

/* JADX INFO: loaded from: classes2.dex */
public final class dq1 {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final vp1 f10477a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final ArrayDeque f10478b = new ArrayDeque();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final ArrayDeque f10479c = new ArrayDeque();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final PriorityQueue f10480d = new PriorityQueue();

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public int f10481e = -1;

    @Nullable
    private gp1 zzf;

    public dq1(ru ruVar) {
        this.f10477a = ruVar;
    }

    public final void a(int i10) {
        ih1.b1(i10 >= 0);
        this.f10481e = i10;
        c(i10);
    }

    /* JADX WARN: Code restructure failed: missing block: B:11:0x0026, code lost:
    
        if (r8 < r0.f11830b) goto L33;
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void b(long j10, p01 p01Var) {
        if (j10 != -9223372036854775807L) {
            int i10 = this.f10481e;
            if (i10 != 0) {
                PriorityQueue priorityQueue = this.f10480d;
                if (i10 != -1 && priorityQueue.size() >= this.f10481e) {
                    gp1 gp1Var = (gp1) priorityQueue.peek();
                    String str = bb1.f9474a;
                }
                ArrayDeque arrayDeque = this.f10478b;
                p01 p01Var2 = arrayDeque.isEmpty() ? new p01() : (p01) arrayDeque.pop();
                p01Var2.v(p01Var.y());
                System.arraycopy(p01Var.f15225a, p01Var.f15226b, p01Var2.f15225a, 0, p01Var2.y());
                gp1 gp1Var2 = this.zzf;
                if (gp1Var2 != null && j10 == gp1Var2.f11830b) {
                    gp1Var2.f11829a.add(p01Var2);
                    return;
                }
                ArrayDeque arrayDeque2 = this.f10479c;
                gp1 gp1Var3 = arrayDeque2.isEmpty() ? new gp1() : (gp1) arrayDeque2.pop();
                ArrayList arrayList = gp1Var3.f11829a;
                ih1.b1(arrayList.isEmpty());
                gp1Var3.f11830b = j10;
                arrayList.add(p01Var2);
                priorityQueue.add(gp1Var3);
                this.zzf = gp1Var3;
                int i11 = this.f10481e;
                if (i11 != -1) {
                    c(i11);
                    return;
                }
                return;
            }
        } else {
            j10 = -9223372036854775807L;
        }
        ((ru) this.f10477a).e(j10, p01Var);
    }

    public final void c(int i10) {
        ArrayList arrayList;
        while (true) {
            PriorityQueue priorityQueue = this.f10480d;
            if (priorityQueue.size() <= i10) {
                return;
            }
            gp1 gp1Var = (gp1) priorityQueue.poll();
            String str = bb1.f9474a;
            int i11 = 0;
            while (true) {
                arrayList = gp1Var.f11829a;
                if (i11 >= arrayList.size()) {
                    break;
                }
                ((ru) this.f10477a).e(gp1Var.f11830b, (p01) arrayList.get(i11));
                this.f10478b.push((p01) arrayList.get(i11));
                i11++;
            }
            arrayList.clear();
            gp1 gp1Var2 = this.zzf;
            if (gp1Var2 != null && gp1Var2.f11830b == gp1Var.f11830b) {
                this.zzf = null;
            }
            this.f10479c.push(gp1Var);
        }
    }
}