rr3-apk/decompiled-community/sources/com/applovin/impl/r5.java

package com.applovin.impl;

import java.util.Arrays;

/* loaded from: classes.dex */
public final class r5 implements n0 {
    private final boolean a;
    private final int b;
    private final byte[] c;
    private final m0[] d;
    private int e;
    private int f;
    private int g;
    private m0[] h;

    @Override // com.applovin.impl.n0
    public int c() {
        return this.b;
    }

    public r5(boolean z, int i) {
        this(z, i, 0);
    }

    public synchronized void e() {
        if (this.a) {
            a(0);
        }
    }

    @Override // com.applovin.impl.n0
    public synchronized m0 b() {
        m0 m0Var;
        try {
            this.f++;
            int i = this.g;
            if (i > 0) {
                m0[] m0VarArr = this.h;
                int i2 = i - 1;
                this.g = i2;
                m0Var = (m0) b1.a(m0VarArr[i2]);
                this.h[this.g] = null;
            } else {
                m0Var = new m0(new byte[this.b], 0);
            }
        } catch (Throwable th) {
            throw th;
        }
        return m0Var;
    }

    @Override // com.applovin.impl.n0
    public synchronized void a(m0 m0Var) {
        m0[] m0VarArr = this.d;
        m0VarArr[0] = m0Var;
        a(m0VarArr);
    }

    public r5(boolean z, int i, int i2) {
        b1.a(i > 0);
        b1.a(i2 >= 0);
        this.a = z;
        this.b = i;
        this.g = i2;
        this.h = new m0[i2 + 100];
        if (i2 > 0) {
            this.c = new byte[i2 * i];
            for (int i3 = 0; i3 < i2; i3++) {
                this.h[i3] = new m0(this.c, i3 * i);
            }
        } else {
            this.c = null;
        }
        this.d = new m0[1];
    }

    public synchronized int d() {
        return this.f * this.b;
    }

    @Override // com.applovin.impl.n0
    public synchronized void a(m0[] m0VarArr) {
        try {
            int i = this.g;
            int length = m0VarArr.length + i;
            m0[] m0VarArr2 = this.h;
            if (length >= m0VarArr2.length) {
                this.h = (m0[]) Arrays.copyOf(m0VarArr2, Math.max(m0VarArr2.length * 2, i + m0VarArr.length));
            }
            for (m0 m0Var : m0VarArr) {
                m0[] m0VarArr3 = this.h;
                int i2 = this.g;
                this.g = i2 + 1;
                m0VarArr3[i2] = m0Var;
            }
            this.f -= m0VarArr.length;
            notifyAll();
        } catch (Throwable th) {
            throw th;
        }
    }

    public synchronized void a(int i) {
        boolean z = i < this.e;
        this.e = i;
        if (z) {
            a();
        }
    }

    @Override // com.applovin.impl.n0
    public synchronized void a() {
        try {
            int i = 0;
            int max = Math.max(0, xp.a(this.e, this.b) - this.f);
            int i2 = this.g;
            if (max >= i2) {
                return;
            }
            if (this.c != null) {
                int i3 = i2 - 1;
                while (i <= i3) {
                    m0 m0Var = (m0) b1.a(this.h[i]);
                    if (m0Var.a == this.c) {
                        i++;
                    } else {
                        m0 m0Var2 = (m0) b1.a(this.h[i3]);
                        if (m0Var2.a != this.c) {
                            i3--;
                        } else {
                            m0[] m0VarArr = this.h;
                            m0VarArr[i] = m0Var2;
                            m0VarArr[i3] = m0Var;
                            i3--;
                            i++;
                        }
                    }
                }
                max = Math.max(max, i);
                if (max >= this.g) {
                    return;
                }
            }
            Arrays.fill(this.h, max, this.g, (Object) null);
            this.g = max;
        } catch (Throwable th) {
            throw th;
        }
    }
}