package M1;

import java.io.IOException;
import java.io.InputStream;
import java.io.PushbackInputStream;
import java.nio.charset.StandardCharsets;

/* JADX INFO: loaded from: classes2.dex */
public final class b extends PushbackInputStream {

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    static final boolean f1442g;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    static final String f1443r;

    /* JADX INFO: renamed from: x, reason: collision with root package name */
    static final byte[] f1444x;

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

    static {
        String strLineSeparator = System.lineSeparator();
        f1443r = strLineSeparator;
        f1442g = strLineSeparator.equals("\r\n");
        f1444x = strLineSeparator.getBytes(StandardCharsets.US_ASCII);
    }

    public b(InputStream inputStream) {
        super(inputStream, f1444x.length + 1);
    }

    private int readInt() throws IOException {
        int i2 = super.read();
        if (i2 != 13) {
            return i2;
        }
        int i3 = super.read();
        if (i3 != 10) {
            if (i3 != -1) {
                unread(i3);
            }
            return 13;
        }
        unread(f1444x);
        this.f1445b--;
        return super.read();
    }

    @Override // java.io.PushbackInputStream, java.io.FilterInputStream, java.io.InputStream
    public int available() throws IOException {
        if (((PushbackInputStream) this).in != null) {
            return (((PushbackInputStream) this).buf.length - ((PushbackInputStream) this).pos) + ((PushbackInputStream) this).in.available();
        }
        throw new IOException("Stream closed");
    }

    @Override // java.io.PushbackInputStream, java.io.FilterInputStream, java.io.InputStream
    public int read() {
        return f1442g ? super.read() : readInt();
    }

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

    @Override // java.io.PushbackInputStream, java.io.FilterInputStream, java.io.InputStream
    public int read(byte[] bArr, int i2, int i3) throws IOException {
        int i4;
        if (f1442g) {
            return super.read(bArr, i2, i3);
        }
        if (i3 < 1) {
            return 0;
        }
        int iMin = Math.min(i3, available());
        this.f1445b = iMin;
        if (iMin < 1) {
            this.f1445b = 1;
        }
        int i5 = readInt();
        if (i5 == -1) {
            return -1;
        }
        int i6 = i2;
        while (true) {
            i4 = i6 + 1;
            bArr[i6] = (byte) i5;
            int i7 = this.f1445b - 1;
            this.f1445b = i7;
            if (i7 <= 0 || (i5 = readInt()) == -1) {
                break;
            }
            i6 = i4;
        }
        return i4 - i2;
    }
}