package a0;

import android.util.Log;
import androidx.media3.session.legacy.PlaybackStateCompat;

/* JADX INFO: loaded from: classes.dex */
public class v {

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private static int f2032h = 10485760;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private int f2033a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private int f2034b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private int f2035c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private byte[] f2036d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private int f2037e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private long f2038f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private int f2039g;

    public v(int i2) {
        this.f2036d = new byte[i2];
        this.f2037e = i2;
        f2032h = Math.max(i2 / 2, f2032h);
        Log.i("RollingDataBuffer", "capacity=" + i2 + ", kBufferThreshold:" + f2032h);
        e(0L);
    }

    private int b(int i2, int i3, int i4) {
        int i5 = i2 + i3;
        return i5 >= i4 ? i5 - i4 : i5;
    }

    private void e(long j2) {
        Log.d("RollingDataBuffer", "reset() position=" + j2);
        a();
        this.f2033a = 0;
        this.f2034b = 0;
        this.f2035c = 0;
        this.f2038f = j2;
        this.f2039g = 0;
    }

    public void a() {
        int i2 = this.f2035c;
        int i3 = this.f2034b;
        if (i2 < i3) {
            i2 += this.f2037e;
        }
        int i4 = i2 - i3;
        b0.o.c("RollingDataBuffer", 64, "mRpBase=", Integer.valueOf(this.f2033a));
        b0.o.c("RollingDataBuffer", 64, "mRp=", Integer.valueOf(this.f2034b));
        b0.o.c("RollingDataBuffer", 64, "mWp=", Integer.valueOf(this.f2035c));
        b0.o.c("RollingDataBuffer", 64, "capacity=", Integer.valueOf(this.f2037e));
        b0.o.c("RollingDataBuffer", 64, "dataPosition=", Long.valueOf(this.f2038f));
        b0.o.c("RollingDataBuffer", 64, "dataSize=", Integer.valueOf(this.f2039g));
        b0.o.c("RollingDataBuffer", 64, "bufferSize=", Integer.valueOf(i4));
    }

    public synchronized boolean c() {
        boolean z2;
        int i2 = this.f2035c;
        int i3 = this.f2034b;
        if (i2 < i3) {
            i2 += this.f2037e;
        }
        int i4 = i2 - i3;
        z2 = i4 >= f2032h;
        if (z2) {
            Log.i("RollingDataBuffer", "buffer full, bufferSize=" + i4);
        }
        return z2;
    }

    /* JADX WARN: Removed duplicated region for block: B:15:0x0077  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public synchronized int d(long r17, byte[] r19, int r20, int r21) {
        /*
            r16 = this;
            r1 = r16
            r0 = r19
            r2 = r20
            monitor-enter(r16)
            long r3 = r1.f2038f     // Catch: java.lang.Throwable -> L5f
            long r3 = r17 - r3
            int r3 = (int) r3     // Catch: java.lang.Throwable -> L5f
            int r4 = r1.f2033a     // Catch: java.lang.Throwable -> L5f
            int r5 = r1.f2037e     // Catch: java.lang.Throwable -> L5f
            int r4 = r1.b(r4, r3, r5)     // Catch: java.lang.Throwable -> L5f
            java.lang.String r5 = "RollingDataBuffer"
            java.lang.String r6 = "+read position="
            java.lang.Long r7 = java.lang.Long.valueOf(r17)     // Catch: java.lang.Throwable -> L5f
            java.lang.String r8 = " size="
            java.lang.Integer r9 = java.lang.Integer.valueOf(r21)     // Catch: java.lang.Throwable -> L5f
            java.lang.String r10 = " startOffset="
            java.lang.Integer r11 = java.lang.Integer.valueOf(r3)     // Catch: java.lang.Throwable -> L5f
            java.lang.Object[] r6 = new java.lang.Object[]{r6, r7, r8, r9, r10, r11}     // Catch: java.lang.Throwable -> L5f
            r7 = 64
            b0.o.c(r5, r7, r6)     // Catch: java.lang.Throwable -> L5f
            r16.a()     // Catch: java.lang.Throwable -> L5f
            long r5 = r1.f2038f     // Catch: java.lang.Throwable -> L5f
            int r8 = (r17 > r5 ? 1 : (r17 == r5 ? 0 : -1))
            r9 = 0
            if (r8 < 0) goto L77
            int r8 = r1.f2039g     // Catch: java.lang.Throwable -> L5f
            long r10 = (long) r8     // Catch: java.lang.Throwable -> L5f
            long r5 = r5 + r10
            int r5 = (r17 > r5 ? 1 : (r17 == r5 ? 0 : -1))
            if (r5 >= 0) goto L77
            int r8 = r8 - r3
            r3 = r21
            int r5 = java.lang.Math.min(r3, r8)     // Catch: java.lang.Throwable -> L5f
            int r6 = r4 + r5
            int r8 = r1.f2037e     // Catch: java.lang.Throwable -> L5f
            if (r6 >= r8) goto L61
            byte[] r6 = r1.f2036d     // Catch: java.lang.Throwable -> L5f
            java.lang.System.arraycopy(r6, r4, r0, r2, r5)     // Catch: java.lang.Throwable -> L5f
            int r0 = r1.f2037e     // Catch: java.lang.Throwable -> L5f
            int r0 = r1.b(r4, r5, r0)     // Catch: java.lang.Throwable -> L5f
            r1.f2034b = r0     // Catch: java.lang.Throwable -> L5f
            r9 = r5
            goto L79
        L5f:
            r0 = move-exception
            goto L96
        L61:
            if (r9 >= r5) goto L79
            int r6 = r9 + r2
            byte[] r8 = r1.f2036d     // Catch: java.lang.Throwable -> L5f
            r8 = r8[r4]     // Catch: java.lang.Throwable -> L5f
            r0[r6] = r8     // Catch: java.lang.Throwable -> L5f
            int r6 = r1.f2037e     // Catch: java.lang.Throwable -> L5f
            r8 = 1
            int r4 = r1.b(r4, r8, r6)     // Catch: java.lang.Throwable -> L5f
            r1.f2034b = r4     // Catch: java.lang.Throwable -> L5f
            int r9 = r9 + 1
            goto L61
        L77:
            r3 = r21
        L79:
            java.lang.String r0 = "RollingDataBuffer"
            java.lang.String r10 = "-read position="
            java.lang.Long r11 = java.lang.Long.valueOf(r17)     // Catch: java.lang.Throwable -> L5f
            java.lang.String r12 = " size="
            java.lang.Integer r13 = java.lang.Integer.valueOf(r21)     // Catch: java.lang.Throwable -> L5f
            java.lang.String r14 = " i="
            java.lang.Integer r15 = java.lang.Integer.valueOf(r9)     // Catch: java.lang.Throwable -> L5f
            java.lang.Object[] r2 = new java.lang.Object[]{r10, r11, r12, r13, r14, r15}     // Catch: java.lang.Throwable -> L5f
            b0.o.c(r0, r7, r2)     // Catch: java.lang.Throwable -> L5f
            monitor-exit(r16)
            return r9
        L96:
            monitor-exit(r16)     // Catch: java.lang.Throwable -> L5f
            throw r0
        */
        throw new UnsupportedOperationException("Method not decompiled: a0.v.d(long, byte[], int, int):int");
    }

    public synchronized boolean f(long j2, int i2) {
        Log.d("RollingDataBuffer", "tryReset() position=" + j2);
        long j3 = this.f2038f;
        if (j2 >= j3 && j2 <= j3 + ((long) this.f2039g) + PlaybackStateCompat.ACTION_SET_SHUFFLE_MODE) {
            return false;
        }
        e(j2);
        return true;
    }

    public synchronized int g(byte[] bArr, int i2) {
        try {
            b0.o.c("RollingDataBuffer", 64, "write size=", Integer.valueOf(i2));
            a();
            int i3 = this.f2037e;
            if (i2 >= i3 - this.f2039g) {
                this.f2033a = b(this.f2033a, i2, i3);
                this.f2038f += (long) i2;
                this.f2039g -= i2;
            }
            int i4 = this.f2035c;
            if (i4 + i2 < this.f2037e) {
                System.arraycopy(bArr, 0, this.f2036d, i4, i2);
                this.f2035c = b(this.f2035c, i2, this.f2037e);
                this.f2039g += i2;
            } else {
                b0.o.c("RollingDataBuffer", 64, "rolling write happening ");
                for (int i5 = 0; i5 < i2; i5++) {
                    byte[] bArr2 = this.f2036d;
                    int i6 = this.f2035c;
                    bArr2[i6] = bArr[i5];
                    this.f2035c = b(i6, 1, this.f2037e);
                    this.f2039g++;
                }
            }
        } catch (Throwable th) {
            throw th;
        }
        return i2;
    }
}