package okio;

import io.netty.handler.codec.dns.DnsRecord;
import io.netty.handler.codec.http2.Http2CodecUtil;
import io.netty.handler.codec.rtsp.RtspHeaders;
import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.util.Objects;
import kotlin.Metadata;
import kotlin.jvm.internal.o;
import kotlin.reflect.w.internal.y0.n.c2.c;

/* JADX INFO: renamed from: z.r, reason: from Kotlin metadata */
/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u0000\u0086\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u0005\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0010\u0012\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010\n\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0000\u0018\u00002\u00020\u0001B\r\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0002\u0010\u0004J\b\u0010\u0005\u001a\u00020\u0006H\u0016J\b\u0010\u000e\u001a\u00020\u000fH\u0016J\b\u0010\u0010\u001a\u00020\rH\u0016J\u0010\u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0013\u001a\u00020\u0014H\u0016J\u0018\u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u0012H\u0016J \u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00122\u0006\u0010\u0016\u001a\u00020\u0012H\u0016J\u0010\u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0017\u001a\u00020\u0018H\u0016J\u0018\u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0017\u001a\u00020\u00182\u0006\u0010\u0015\u001a\u00020\u0012H\u0016J\u0010\u0010\u0019\u001a\u00020\u00122\u0006\u0010\u001a\u001a\u00020\u0018H\u0016J\u0018\u0010\u0019\u001a\u00020\u00122\u0006\u0010\u001a\u001a\u00020\u00182\u0006\u0010\u0015\u001a\u00020\u0012H\u0016J\b\u0010\u001b\u001a\u00020\u001cH\u0016J\b\u0010\u001d\u001a\u00020\rH\u0016J\b\u0010\u001e\u001a\u00020\u0001H\u0016J\u0018\u0010\u001f\u001a\u00020\r2\u0006\u0010 \u001a\u00020\u00122\u0006\u0010\u0017\u001a\u00020\u0018H\u0016J(\u0010\u001f\u001a\u00020\r2\u0006\u0010 \u001a\u00020\u00122\u0006\u0010\u0017\u001a\u00020\u00182\u0006\u0010!\u001a\u00020\"2\u0006\u0010#\u001a\u00020\"H\u0016J\u0010\u0010$\u001a\u00020\"2\u0006\u0010%\u001a\u00020&H\u0016J\u0010\u0010$\u001a\u00020\"2\u0006\u0010%\u001a\u00020'H\u0016J \u0010$\u001a\u00020\"2\u0006\u0010%\u001a\u00020'2\u0006\u0010 \u001a\u00020\"2\u0006\u0010#\u001a\u00020\"H\u0016J\u0018\u0010$\u001a\u00020\u00122\u0006\u0010%\u001a\u00020\u00062\u0006\u0010#\u001a\u00020\u0012H\u0016J\u0010\u0010(\u001a\u00020\u00122\u0006\u0010%\u001a\u00020)H\u0016J\b\u0010*\u001a\u00020\u0014H\u0016J\b\u0010+\u001a\u00020'H\u0016J\u0010\u0010+\u001a\u00020'2\u0006\u0010#\u001a\u00020\u0012H\u0016J\b\u0010,\u001a\u00020\u0018H\u0016J\u0010\u0010,\u001a\u00020\u00182\u0006\u0010#\u001a\u00020\u0012H\u0016J\b\u0010-\u001a\u00020\u0012H\u0016J\u0010\u0010.\u001a\u00020\u000f2\u0006\u0010%\u001a\u00020'H\u0016J\u0018\u0010.\u001a\u00020\u000f2\u0006\u0010%\u001a\u00020\u00062\u0006\u0010#\u001a\u00020\u0012H\u0016J\b\u0010/\u001a\u00020\u0012H\u0016J\b\u00100\u001a\u00020\"H\u0016J\b\u00101\u001a\u00020\"H\u0016J\b\u00102\u001a\u00020\u0012H\u0016J\b\u00103\u001a\u00020\u0012H\u0016J\b\u00104\u001a\u000205H\u0016J\b\u00106\u001a\u000205H\u0016J\u0010\u00107\u001a\u0002082\u0006\u00109\u001a\u00020:H\u0016J\u0018\u00107\u001a\u0002082\u0006\u0010#\u001a\u00020\u00122\u0006\u00109\u001a\u00020:H\u0016J\b\u0010;\u001a\u000208H\u0016J\u0010\u0010;\u001a\u0002082\u0006\u0010#\u001a\u00020\u0012H\u0016J\b\u0010<\u001a\u00020\"H\u0016J\n\u0010=\u001a\u0004\u0018\u000108H\u0016J\b\u0010>\u001a\u000208H\u0016J\u0010\u0010>\u001a\u0002082\u0006\u0010?\u001a\u00020\u0012H\u0016J\u0010\u0010@\u001a\u00020\r2\u0006\u0010#\u001a\u00020\u0012H\u0016J\u0010\u0010A\u001a\u00020\u000f2\u0006\u0010#\u001a\u00020\u0012H\u0016J\u0010\u0010B\u001a\u00020\"2\u0006\u0010C\u001a\u00020DH\u0016J\u0010\u0010E\u001a\u00020\u000f2\u0006\u0010#\u001a\u00020\u0012H\u0016J\b\u0010F\u001a\u00020GH\u0016J\b\u0010H\u001a\u000208H\u0016R\u001b\u0010\u0005\u001a\u00020\u00068Ö\u0002X\u0096\u0004¢\u0006\f\u0012\u0004\b\u0007\u0010\b\u001a\u0004\b\t\u0010\nR\u0010\u0010\u000b\u001a\u00020\u00068\u0006X\u0087\u0004¢\u0006\u0002\n\u0000R\u0012\u0010\f\u001a\u00020\r8\u0006@\u0006X\u0087\u000e¢\u0006\u0002\n\u0000R\u0010\u0010\u0002\u001a\u00020\u00038\u0006X\u0087\u0004¢\u0006\u0002\n\u0000¨\u0006I"}, d2 = {"Lokio/RealBufferedSource;", "Lokio/BufferedSource;", "source", "Lokio/Source;", "(Lokio/Source;)V", "buffer", "Lokio/Buffer;", "getBuffer$annotations", "()V", "getBuffer", "()Lokio/Buffer;", "bufferField", "closed", "", "close", "", "exhausted", "indexOf", "", "b", "", "fromIndex", "toIndex", "bytes", "Lokio/ByteString;", "indexOfElement", "targetBytes", "inputStream", "Ljava/io/InputStream;", "isOpen", "peek", "rangeEquals", "offset", "bytesOffset", "", "byteCount", "read", "sink", "Ljava/nio/ByteBuffer;", "", "readAll", "Lokio/Sink;", "readByte", "readByteArray", "readByteString", "readDecimalLong", "readFully", "readHexadecimalUnsignedLong", "readInt", "readIntLe", "readLong", "readLongLe", "readShort", "", "readShortLe", "readString", "", "charset", "Ljava/nio/charset/Charset;", "readUtf8", "readUtf8CodePoint", "readUtf8Line", "readUtf8LineStrict", "limit", "request", "require", "select", "options", "Lokio/Options;", "skip", RtspHeaders.Values.TIMEOUT, "Lokio/Timeout;", "toString", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48)
public final class RealBufferedSource implements BufferedSource {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final Source f10147f;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final Buffer f10148m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public boolean f10149n;

    public RealBufferedSource(Source source) {
        o.f(source, "source");
        this.f10147f = source;
        this.f10148m = new Buffer();
    }

    public long a(byte b2, long j2, long j3) {
        if (!(!this.f10149n)) {
            throw new IllegalStateException("closed".toString());
        }
        if (!(0 <= j2 && j2 <= j3)) {
            throw new IllegalArgumentException(("fromIndex=" + j2 + " toIndex=" + j3).toString());
        }
        while (j2 < j3) {
            long jG = this.f10148m.g(b2, j2, j3);
            if (jG != -1) {
                return jG;
            }
            Buffer buffer = this.f10148m;
            long j4 = buffer.f10118m;
            if (j4 >= j3 || this.f10147f.r(buffer, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
                return -1L;
            }
            j2 = Math.max(j2, j4);
        }
        return -1L;
    }

    @Override // okio.BufferedSource
    public ByteString b(long j2) throws EOFException {
        if (d(j2)) {
            return this.f10148m.b(j2);
        }
        throw new EOFException();
    }

    public int c() throws EOFException {
        t(4L);
        int i2 = this.f10148m.readInt();
        return ((i2 & DnsRecord.CLASS_ANY) << 24) | (((-16777216) & i2) >>> 24) | ((16711680 & i2) >>> 8) | ((65280 & i2) << 8);
    }

    @Override // okio.Source, java.io.Closeable, java.lang.AutoCloseable
    public void close() throws EOFException {
        if (this.f10149n) {
            return;
        }
        this.f10149n = true;
        this.f10147f.close();
        Buffer buffer = this.f10148m;
        buffer.skip(buffer.f10118m);
    }

    public boolean d(long j2) {
        Buffer buffer;
        if (!(j2 >= 0)) {
            throw new IllegalArgumentException(g.a.a.a.a.q("byteCount < 0: ", j2).toString());
        }
        if (!(!this.f10149n)) {
            throw new IllegalStateException("closed".toString());
        }
        do {
            buffer = this.f10148m;
            if (buffer.f10118m >= j2) {
                return true;
            }
        } while (this.f10147f.r(buffer, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) != -1);
        return false;
    }

    @Override // okio.BufferedSource
    public boolean f() {
        if (!this.f10149n) {
            return this.f10148m.f() && this.f10147f.r(this.f10148m, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1;
        }
        throw new IllegalStateException("closed".toString());
    }

    @Override // okio.BufferedSource, okio.BufferedSink
    /* JADX INFO: renamed from: getBuffer, reason: from getter */
    public Buffer getF10148m() {
        return this.f10148m;
    }

    @Override // okio.BufferedSource
    public String i(long j2) throws EOFException {
        if (!(j2 >= 0)) {
            throw new IllegalArgumentException(g.a.a.a.a.q("limit < 0: ", j2).toString());
        }
        long j3 = j2 == Long.MAX_VALUE ? Long.MAX_VALUE : j2 + 1;
        byte b2 = (byte) 10;
        long jA = a(b2, 0L, j3);
        if (jA != -1) {
            return okio.b0.a.a(this.f10148m, jA);
        }
        if (j3 < Long.MAX_VALUE && d(j3) && this.f10148m.d(j3 - 1) == ((byte) 13) && d(1 + j3) && this.f10148m.d(j3) == b2) {
            return okio.b0.a.a(this.f10148m, j3);
        }
        Buffer buffer = new Buffer();
        Buffer buffer2 = this.f10148m;
        buffer2.c(buffer, 0L, Math.min(32, buffer2.f10118m));
        StringBuilder sbF = g.a.a.a.a.F("\\n not found: limit=");
        sbF.append(Math.min(this.f10148m.f10118m, j2));
        sbF.append(" content=");
        sbF.append(buffer.l().h());
        sbF.append((char) 8230);
        throw new EOFException(sbF.toString());
    }

    @Override // java.nio.channels.Channel
    public boolean isOpen() {
        return !this.f10149n;
    }

    @Override // okio.BufferedSource
    public String k(Charset charset) {
        o.f(charset, "charset");
        this.f10148m.writeAll(this.f10147f);
        Buffer buffer = this.f10148m;
        Objects.requireNonNull(buffer);
        o.f(charset, "charset");
        return buffer.o(buffer.f10118m, charset);
    }

    @Override // okio.BufferedSource
    public String n() {
        return i(Long.MAX_VALUE);
    }

    @Override // okio.BufferedSource
    public byte[] p(long j2) throws EOFException {
        if (d(j2)) {
            return this.f10148m.p(j2);
        }
        throw new EOFException();
    }

    @Override // okio.Source
    public long r(Buffer buffer, long j2) {
        o.f(buffer, "sink");
        if (!(j2 >= 0)) {
            throw new IllegalArgumentException(g.a.a.a.a.q("byteCount < 0: ", j2).toString());
        }
        if (!(!this.f10149n)) {
            throw new IllegalStateException("closed".toString());
        }
        Buffer buffer2 = this.f10148m;
        if (buffer2.f10118m == 0 && this.f10147f.r(buffer2, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
            return -1L;
        }
        return this.f10148m.r(buffer, Math.min(j2, this.f10148m.f10118m));
    }

    @Override // java.nio.channels.ReadableByteChannel
    public int read(ByteBuffer sink) {
        o.f(sink, "sink");
        Buffer buffer = this.f10148m;
        if (buffer.f10118m == 0 && this.f10147f.r(buffer, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
            return -1;
        }
        return this.f10148m.read(sink);
    }

    @Override // okio.BufferedSource
    public byte readByte() throws EOFException {
        t(1L);
        return this.f10148m.readByte();
    }

    @Override // okio.BufferedSource
    public int readInt() throws EOFException {
        t(4L);
        return this.f10148m.readInt();
    }

    @Override // okio.BufferedSource
    public short readShort() throws EOFException {
        t(2L);
        return this.f10148m.readShort();
    }

    @Override // okio.BufferedSource
    public void skip(long byteCount) throws EOFException {
        if (!(!this.f10149n)) {
            throw new IllegalStateException("closed".toString());
        }
        while (byteCount > 0) {
            Buffer buffer = this.f10148m;
            if (buffer.f10118m == 0 && this.f10147f.r(buffer, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
                throw new EOFException();
            }
            long jMin = Math.min(byteCount, this.f10148m.f10118m);
            this.f10148m.skip(jMin);
            byteCount -= jMin;
        }
    }

    @Override // okio.BufferedSource
    public void t(long j2) throws EOFException {
        if (!d(j2)) {
            throw new EOFException();
        }
    }

    @Override // okio.Source
    /* JADX INFO: renamed from: timeout */
    public Timeout getF10138m() {
        return this.f10147f.getF10138m();
    }

    public String toString() {
        StringBuilder sbF = g.a.a.a.a.F("buffer(");
        sbF.append(this.f10147f);
        sbF.append(')');
        return sbF.toString();
    }

    @Override // okio.BufferedSource
    public long v() throws EOFException {
        byte bD;
        t(1L);
        int i2 = 0;
        while (true) {
            int i3 = i2 + 1;
            if (!d(i3)) {
                break;
            }
            bD = this.f10148m.d(i2);
            if ((bD < ((byte) 48) || bD > ((byte) 57)) && ((bD < ((byte) 97) || bD > ((byte) 102)) && (bD < ((byte) 65) || bD > ((byte) 70)))) {
                break;
            }
            i2 = i3;
        }
        if (i2 == 0) {
            StringBuilder sb = new StringBuilder();
            sb.append("Expected leading [0-9a-fA-F] character but was 0x");
            c.r(16);
            c.r(16);
            String string = Integer.toString(bD, 16);
            o.e(string, "toString(this, checkRadix(radix))");
            sb.append(string);
            throw new NumberFormatException(sb.toString());
        }
        return this.f10148m.v();
    }

    @Override // okio.BufferedSource
    public InputStream w() {
        return new a();
    }

    @Override // okio.BufferedSource
    public int y(Options options) throws EOFException {
        o.f(options, "options");
        if (!(!this.f10149n)) {
            throw new IllegalStateException("closed".toString());
        }
        while (true) {
            int iB = okio.b0.a.b(this.f10148m, options, true);
            if (iB != -2) {
                if (iB != -1) {
                    this.f10148m.skip(options.f10140m[iB].g());
                    return iB;
                }
            } else if (this.f10147f.r(this.f10148m, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
                break;
            }
        }
        return -1;
    }

    /* JADX INFO: renamed from: z.r$a */
    @Metadata(d1 = {"\u0000'\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\u0012\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0000*\u0001\u0000\b\n\u0018\u00002\u00020\u0001J\b\u0010\u0002\u001a\u00020\u0003H\u0016J\b\u0010\u0004\u001a\u00020\u0005H\u0016J\b\u0010\u0006\u001a\u00020\u0003H\u0016J \u0010\u0006\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\b2\u0006\u0010\t\u001a\u00020\u00032\u0006\u0010\n\u001a\u00020\u0003H\u0016J\b\u0010\u000b\u001a\u00020\fH\u0016¨\u0006\r"}, d2 = {"okio/RealBufferedSource$inputStream$1", "Ljava/io/InputStream;", "available", "", "close", "", "read", "data", "", "offset", "byteCount", "toString", "", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48)
    public static final class a extends InputStream {
        public a() {
        }

        @Override // java.io.InputStream
        public int available() throws IOException {
            RealBufferedSource realBufferedSource = RealBufferedSource.this;
            if (realBufferedSource.f10149n) {
                throw new IOException("closed");
            }
            return (int) Math.min(realBufferedSource.f10148m.f10118m, Integer.MAX_VALUE);
        }

        @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable
        public void close() throws EOFException {
            RealBufferedSource.this.close();
        }

        @Override // java.io.InputStream
        public int read() throws IOException {
            RealBufferedSource realBufferedSource = RealBufferedSource.this;
            if (realBufferedSource.f10149n) {
                throw new IOException("closed");
            }
            Buffer buffer = realBufferedSource.f10148m;
            if (buffer.f10118m == 0 && realBufferedSource.f10147f.r(buffer, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
                return -1;
            }
            return RealBufferedSource.this.f10148m.readByte() & 255;
        }

        public String toString() {
            return RealBufferedSource.this + ".inputStream()";
        }

        @Override // java.io.InputStream
        public int read(byte[] data, int offset, int byteCount) throws IOException {
            o.f(data, "data");
            if (RealBufferedSource.this.f10149n) {
                throw new IOException("closed");
            }
            a0.b(data.length, offset, byteCount);
            RealBufferedSource realBufferedSource = RealBufferedSource.this;
            Buffer buffer = realBufferedSource.f10148m;
            if (buffer.f10118m == 0 && realBufferedSource.f10147f.r(buffer, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) == -1) {
                return -1;
            }
            return RealBufferedSource.this.f10148m.read(data, offset, byteCount);
        }
    }
}