package k1;

import java.io.IOException;
import l1.C0622e;

/* JADX INFO: loaded from: classes.dex */
class x0 extends Y {

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

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

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

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

    /* JADX INFO: renamed from: a0, reason: collision with root package name */
    private boolean f5047a0;

    /* JADX INFO: renamed from: b0, reason: collision with root package name */
    Object f5048b0;

    x0(b0 b0Var) {
        super(b0Var, (b0Var.f4773s0 & (-65281)) | 32);
        this.f5043L = new byte[4096];
        this.f5047a0 = (b0Var.f4773s0 & 1536) != 1536;
        this.f5048b0 = new Object();
    }

    @Override // k1.Y, java.io.InputStream
    public int available() {
        C0586d c0586d = W.f4726p0;
        if (C0622e.f5384g < 3) {
            return 0;
        }
        W.f4723m0.println("Named Pipe available() does not apply to TRANSACT Named Pipes");
        return 0;
    }

    int d(byte[] bArr, int i2, int i3) {
        byte[] bArr2 = this.f5043L;
        int length = bArr2.length;
        int i4 = this.f5046Z;
        if (i3 > length - i4) {
            int length2 = bArr2.length * 2;
            if (i3 > length2 - i4) {
                length2 = i3 + i4;
            }
            byte[] bArr3 = new byte[length2];
            this.f5043L = bArr3;
            int length3 = bArr2.length;
            int i5 = this.f5044M;
            int i6 = length3 - i5;
            if (i4 > i6) {
                System.arraycopy(bArr2, i5, bArr3, 0, i6);
                System.arraycopy(bArr2, 0, this.f5043L, i6, this.f5046Z - i6);
            } else {
                System.arraycopy(bArr2, i5, bArr3, 0, i4);
            }
            this.f5044M = 0;
            this.f5045Q = this.f5046Z;
        }
        byte[] bArr4 = this.f5043L;
        int length4 = bArr4.length;
        int i7 = this.f5045Q;
        int i8 = length4 - i7;
        if (i3 > i8) {
            System.arraycopy(bArr, i2, bArr4, i7, i8);
            System.arraycopy(bArr, i2 + i8, this.f5043L, 0, i3 - i8);
        } else {
            System.arraycopy(bArr, i2, bArr4, i7, i3);
        }
        this.f5045Q = (this.f5045Q + i3) % this.f5043L.length;
        this.f5046Z += i3;
        return i3;
    }

    @Override // k1.Y, java.io.InputStream
    public int read() {
        int i2;
        synchronized (this.f5048b0) {
            while (this.f5046Z == 0) {
                try {
                    this.f5048b0.wait();
                } catch (InterruptedException e2) {
                    throw new IOException(e2.getMessage());
                }
            }
            byte[] bArr = this.f5043L;
            int i3 = this.f5044M;
            i2 = bArr[i3] & 255;
            this.f5044M = (i3 + 1) % bArr.length;
        }
        return i2;
    }

    @Override // k1.Y, java.io.InputStream
    public int read(byte[] bArr) {
        return read(bArr, 0, bArr.length);
    }

    @Override // k1.Y, java.io.InputStream
    public int read(byte[] bArr, int i2, int i3) {
        int i4;
        if (i3 <= 0) {
            return 0;
        }
        synchronized (this.f5048b0) {
            while (true) {
                try {
                    i4 = this.f5046Z;
                    if (i4 != 0) {
                        break;
                    }
                    this.f5048b0.wait();
                } catch (InterruptedException e2) {
                    throw new IOException(e2.getMessage());
                }
            }
            byte[] bArr2 = this.f5043L;
            int length = bArr2.length;
            int i5 = this.f5044M;
            int i6 = length - i5;
            if (i3 > i4) {
                i3 = i4;
            }
            if (i4 > i6 && i3 > i6) {
                System.arraycopy(bArr2, i5, bArr, i2, i6);
                System.arraycopy(this.f5043L, 0, bArr, i2 + i6, i3 - i6);
            } else {
                System.arraycopy(bArr2, i5, bArr, i2, i3);
            }
            this.f5046Z -= i3;
            this.f5044M = (this.f5044M + i3) % this.f5043L.length;
        }
        return i3;
    }
}