package okio; import com.google.android.gms.measurement.internal.u1; import defpackage.e; import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.nio.ByteBuffer; import java.nio.charset.Charset; import kotlin.Metadata; import kotlin.jvm.JvmField; import kotlin.jvm.internal.SourceDebugExtension; import nb.g; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import tv.danmaku.ijk.media.player.IjkMediaMeta; import tv.danmaku.ijk.media.player.IjkMediaPlayer; import ua.b; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000~\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0005\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u0012\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\n\n\u0002\b\u0013\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\r\b\u0000\u0018\u00002\u00020\u0001B\u000f\u0012\u0006\u0010A\u001a\u00020@¢\u0006\u0004\bK\u0010LJ\b\u0010\u0003\u001a\u00020\u0002H\u0016J\u0018\u0010\u0007\u001a\u00020\u00052\u0006\u0010\u0004\u001a\u00020\u00022\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\b\u0010\t\u001a\u00020\bH\u0016J\u0010\u0010\u000b\u001a\u00020\n2\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\u0010\u0010\f\u001a\u00020\b2\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\b\u0010\u000e\u001a\u00020\rH\u0016J\b\u0010\u0010\u001a\u00020\u000fH\u0016J\u0010\u0010\u0010\u001a\u00020\u000f2\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\u0010\u0010\u0014\u001a\u00020\u00132\u0006\u0010\u0012\u001a\u00020\u0011H\u0016J\b\u0010\u0016\u001a\u00020\u0015H\u0016J\u0010\u0010\u0016\u001a\u00020\u00152\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\u0010\u0010\u0007\u001a\u00020\u00132\u0006\u0010\u0004\u001a\u00020\u0015H\u0016J\u0010\u0010\u0017\u001a\u00020\n2\u0006\u0010\u0004\u001a\u00020\u0015H\u0016J \u0010\u0007\u001a\u00020\u00132\u0006\u0010\u0004\u001a\u00020\u00152\u0006\u0010\u0018\u001a\u00020\u00132\u0006\u0010\u0006\u001a\u00020\u0013H\u0016J\u0010\u0010\u0007\u001a\u00020\u00132\u0006\u0010\u0004\u001a\u00020\u0019H\u0016J\u0018\u0010\u0017\u001a\u00020\n2\u0006\u0010\u0004\u001a\u00020\u00022\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\u0010\u0010\u001b\u001a\u00020\u00052\u0006\u0010\u0004\u001a\u00020\u001aH\u0016J\b\u0010\u001d\u001a\u00020\u001cH\u0016J\u0010\u0010\u001d\u001a\u00020\u001c2\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\u0010\u0010 \u001a\u00020\u001c2\u0006\u0010\u001f\u001a\u00020\u001eH\u0016J\u0018\u0010 \u001a\u00020\u001c2\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\u001f\u001a\u00020\u001eH\u0016J\n\u0010!\u001a\u0004\u0018\u00010\u001cH\u0016J\b\u0010\"\u001a\u00020\u001cH\u0016J\u0010\u0010\"\u001a\u00020\u001c2\u0006\u0010#\u001a\u00020\u0005H\u0016J\b\u0010$\u001a\u00020\u0013H\u0016J\b\u0010&\u001a\u00020%H\u0016J\b\u0010'\u001a\u00020%H\u0016J\b\u0010(\u001a\u00020\u0013H\u0016J\b\u0010)\u001a\u00020\u0013H\u0016J\b\u0010*\u001a\u00020\u0005H\u0016J\b\u0010+\u001a\u00020\u0005H\u0016J\b\u0010,\u001a\u00020\u0005H\u0016J\b\u0010-\u001a\u00020\u0005H\u0016J\u0010\u0010.\u001a\u00020\n2\u0006\u0010\u0006\u001a\u00020\u0005H\u0016J\u0010\u00100\u001a\u00020\u00052\u0006\u0010/\u001a\u00020\rH\u0016J\u0018\u00100\u001a\u00020\u00052\u0006\u0010/\u001a\u00020\r2\u0006\u00101\u001a\u00020\u0005H\u0016J \u00100\u001a\u00020\u00052\u0006\u0010/\u001a\u00020\r2\u0006\u00101\u001a\u00020\u00052\u0006\u00102\u001a\u00020\u0005H\u0016J\u0010\u00100\u001a\u00020\u00052\u0006\u00103\u001a\u00020\u000fH\u0016J\u0018\u00100\u001a\u00020\u00052\u0006\u00103\u001a\u00020\u000f2\u0006\u00101\u001a\u00020\u0005H\u0016J\u0010\u00105\u001a\u00020\u00052\u0006\u00104\u001a\u00020\u000fH\u0016J\u0018\u00105\u001a\u00020\u00052\u0006\u00104\u001a\u00020\u000f2\u0006\u00101\u001a\u00020\u0005H\u0016J\u0018\u00106\u001a\u00020\b2\u0006\u0010\u0018\u001a\u00020\u00052\u0006\u00103\u001a\u00020\u000fH\u0016J(\u00106\u001a\u00020\b2\u0006\u0010\u0018\u001a\u00020\u00052\u0006\u00103\u001a\u00020\u000f2\u0006\u00107\u001a\u00020\u00132\u0006\u0010\u0006\u001a\u00020\u0013H\u0016J\b\u00108\u001a\u00020\u0001H\u0016J\b\u0010:\u001a\u000209H\u0016J\b\u0010;\u001a\u00020\bH\u0016J\b\u0010<\u001a\u00020\nH\u0016J\b\u0010>\u001a\u00020=H\u0016J\b\u0010?\u001a\u00020\u001cH\u0016R\u0014\u0010A\u001a\u00020@8\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\bA\u0010BR\u0014\u0010C\u001a\u00020\u00028\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\bC\u0010DR\u0016\u0010E\u001a\u00020\b8\u0006@\u0006X\u0087\u000e¢\u0006\u0006\n\u0004\bE\u0010FR\u001b\u0010\u0003\u001a\u00020\u00028Ö\u0002X\u0096\u0004¢\u0006\f\u0012\u0004\bI\u0010J\u001a\u0004\bG\u0010H¨\u0006M"}, d2 = {"Lokio/RealBufferedSource;", "Lokio/BufferedSource;", "Lokio/Buffer;", "buffer", "sink", "", "byteCount", "read", "", "exhausted", "Lkd/e;", "require", "request", "", "readByte", "Lokio/ByteString;", "readByteString", "Lokio/Options;", "options", "", "select", "", "readByteArray", "readFully", IjkMediaPlayer.OnNativeInvokeListener.ARG_OFFSET, "Ljava/nio/ByteBuffer;", "Lokio/Sink;", "readAll", "", "readUtf8", "Ljava/nio/charset/Charset;", "charset", "readString", "readUtf8Line", "readUtf8LineStrict", "limit", "readUtf8CodePoint", "", "readShort", "readShortLe", "readInt", "readIntLe", "readLong", "readLongLe", "readDecimalLong", "readHexadecimalUnsignedLong", "skip", "b", "indexOf", "fromIndex", "toIndex", "bytes", "targetBytes", "indexOfElement", "rangeEquals", "bytesOffset", "peek", "Ljava/io/InputStream;", "inputStream", "isOpen", "close", "Lokio/Timeout;", "timeout", "toString", "Lokio/Source;", "source", "Lokio/Source;", "bufferField", "Lokio/Buffer;", "closed", "Z", "getBuffer", "()Lokio/Buffer;", "getBuffer$annotations", "()V", "", "(Lokio/Source;)V", "okio"}, k = 1, mv = {1, 9, 0}) @SourceDebugExtension({"SMAP\nRealBufferedSource.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealBufferedSource.kt\nokio/RealBufferedSource\n+ 2 RealBufferedSource.kt\nokio/internal/-RealBufferedSource\n+ 3 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 4 Util.kt\nokio/-SegmentedByteString\n*L\n1#1,185:1\n62#1:191\n62#1:201\n62#1:208\n62#1:214\n62#1:216\n62#1:220\n62#1:225\n62#1:240\n62#1:244\n62#1:251\n62#1:264\n62#1:272\n62#1:273\n62#1:274\n62#1:280\n62#1:288\n62#1:301\n62#1:305\n62#1:306\n62#1:307\n62#1:308\n62#1:313\n62#1:325\n62#1:341\n62#1:351\n62#1:354\n62#1:357\n62#1:360\n62#1:363\n62#1:366\n62#1:372\n62#1:389\n62#1:409\n62#1:424\n62#1:441\n62#1:454\n62#1:475\n62#1:482\n38#2:186\n39#2,3:188\n42#2,6:192\n51#2:198\n52#2:200\n56#2,2:202\n60#2:204\n61#2,2:206\n63#2,3:209\n69#2,2:212\n74#2:215\n75#2:217\n79#2,2:218\n84#2:221\n86#2,2:223\n88#2,13:226\n107#2:239\n108#2:241\n112#2,2:242\n117#2,6:245\n123#2,9:252\n134#2,3:261\n137#2,5:265\n142#2:271\n146#2,5:275\n151#2,5:281\n158#2,2:286\n160#2,11:289\n174#2:300\n175#2:302\n179#2,2:303\n184#2,4:309\n188#2,6:314\n198#2:320\n199#2,3:322\n202#2,8:326\n210#2,3:335\n217#2,3:338\n220#2,7:342\n230#2,2:349\n235#2,2:352\n240#2,2:355\n245#2,2:358\n250#2,2:361\n255#2,2:364\n260#2,5:367\n265#2,11:373\n279#2,5:384\n284#2,14:390\n301#2,2:404\n303#2,2:407\n305#2,7:410\n314#2,2:417\n316#2,4:420\n320#2,11:425\n334#2,2:436\n337#2,2:439\n339#2,7:442\n350#2,2:449\n353#2,2:452\n355#2,7:455\n371#2:462\n373#2,11:464\n385#2:476\n389#2:477\n393#2,4:478\n397#2:483\n399#2:484\n401#2:485\n1#3:187\n1#3:199\n1#3:205\n1#3:222\n1#3:321\n1#3:406\n1#3:419\n1#3:438\n1#3:451\n1#3:463\n89#4:270\n89#4:334\n*S KotlinDebug\n*F\n+ 1 RealBufferedSource.kt\nokio/RealBufferedSource\n*L\n66#1:191\n67#1:201\n69#1:208\n70#1:214\n71#1:216\n72#1:220\n73#1:225\n74#1:240\n75#1:244\n77#1:251\n79#1:264\n82#1:272\n83#1:273\n87#1:274\n90#1:280\n91#1:288\n92#1:301\n93#1:305\n96#1:306\n97#1:307\n102#1:308\n105#1:313\n107#1:325\n108#1:341\n109#1:351\n110#1:354\n111#1:357\n112#1:360\n113#1:363\n114#1:366\n115#1:372\n116#1:389\n117#1:409\n121#1:424\n124#1:441\n127#1:454\n141#1:475\n181#1:482\n66#1:186\n66#1:188,3\n66#1:192,6\n67#1:198\n67#1:200\n68#1:202,2\n69#1:204\n69#1:206,2\n69#1:209,3\n70#1:212,2\n71#1:215\n71#1:217\n72#1:218,2\n73#1:221\n73#1:223,2\n73#1:226,13\n74#1:239\n74#1:241\n75#1:242,2\n77#1:245,6\n77#1:252,9\n79#1:261,3\n79#1:265,5\n79#1:271\n90#1:275,5\n90#1:281,5\n91#1:286,2\n91#1:289,11\n92#1:300\n92#1:302\n93#1:303,2\n105#1:309,4\n105#1:314,6\n107#1:320\n107#1:322,3\n107#1:326,8\n107#1:335,3\n108#1:338,3\n108#1:342,7\n109#1:349,2\n110#1:352,2\n111#1:355,2\n112#1:358,2\n113#1:361,2\n114#1:364,2\n115#1:367,5\n115#1:373,11\n116#1:384,5\n116#1:390,14\n117#1:404,2\n117#1:407,2\n117#1:410,7\n121#1:417,2\n121#1:420,4\n121#1:425,11\n124#1:436,2\n124#1:439,2\n124#1:442,7\n127#1:449,2\n127#1:452,2\n127#1:455,7\n141#1:462\n141#1:464,11\n141#1:476\n143#1:477\n181#1:478,4\n181#1:483\n182#1:484\n183#1:485\n66#1:187\n67#1:199\n69#1:205\n73#1:222\n107#1:321\n117#1:406\n121#1:419\n124#1:438\n127#1:451\n141#1:463\n79#1:270\n107#1:334\n*E\n"}) public final class RealBufferedSource implements BufferedSource { @JvmField @NotNull public final Buffer bufferField; @JvmField public boolean closed; @JvmField @NotNull public final Source source; public RealBufferedSource(@NotNull Source source) { g.i(source, "source"); this.source = source; this.bufferField = new Buffer(); } public static /* synthetic */ void getBuffer$annotations() { } @Override // okio.BufferedSource, okio.BufferedSink @NotNull /* JADX INFO: renamed from: buffer, reason: from getter */ public Buffer getBufferField() { return this.bufferField; } @Override // okio.Source, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { if (this.closed) { return; } this.closed = true; this.source.close(); this.bufferField.clear(); } @Override // okio.BufferedSource public boolean exhausted() { if (!this.closed) { return this.bufferField.exhausted() && this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1; } throw new IllegalStateException("closed".toString()); } @Override // okio.BufferedSource, okio.BufferedSink @NotNull public Buffer getBuffer() { return this.bufferField; } @Override // okio.BufferedSource public long indexOf(byte b10) { return indexOf(b10, 0L, Long.MAX_VALUE); } @Override // okio.BufferedSource public long indexOfElement(@NotNull ByteString targetBytes) { g.i(targetBytes, "targetBytes"); return indexOfElement(targetBytes, 0L); } @Override // okio.BufferedSource @NotNull public InputStream inputStream() { return new InputStream() { // from class: okio.RealBufferedSource.inputStream.1 @Override // java.io.InputStream public int available() throws IOException { RealBufferedSource realBufferedSource = RealBufferedSource.this; if (realBufferedSource.closed) { throw new IOException("closed"); } return (int) Math.min(realBufferedSource.bufferField.size(), Integer.MAX_VALUE); } @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { RealBufferedSource.this.close(); } @Override // java.io.InputStream public int read() throws IOException { RealBufferedSource realBufferedSource = RealBufferedSource.this; if (realBufferedSource.closed) { throw new IOException("closed"); } if (realBufferedSource.bufferField.size() == 0) { RealBufferedSource realBufferedSource2 = RealBufferedSource.this; if (realBufferedSource2.source.read(realBufferedSource2.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1; } } return RealBufferedSource.this.bufferField.readByte() & 255; } @NotNull public String toString() { return RealBufferedSource.this + ".inputStream()"; } @Override // java.io.InputStream public int read(@NotNull byte[] data, int offset, int byteCount) throws IOException { g.i(data, "data"); if (!RealBufferedSource.this.closed) { SegmentedByteString.checkOffsetAndCount(data.length, offset, byteCount); if (RealBufferedSource.this.bufferField.size() == 0) { RealBufferedSource realBufferedSource = RealBufferedSource.this; if (realBufferedSource.source.read(realBufferedSource.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1; } } return RealBufferedSource.this.bufferField.read(data, offset, byteCount); } throw new IOException("closed"); } }; } @Override // java.nio.channels.Channel public boolean isOpen() { return !this.closed; } @Override // okio.BufferedSource @NotNull public BufferedSource peek() { return Okio.buffer(new PeekSource(this)); } @Override // okio.BufferedSource public boolean rangeEquals(long offset, @NotNull ByteString bytes) { g.i(bytes, "bytes"); return rangeEquals(offset, bytes, 0, bytes.size()); } @Override // okio.BufferedSource public int read(@NotNull byte[] sink) { g.i(sink, "sink"); return read(sink, 0, sink.length); } @Override // okio.BufferedSource public long readAll(@NotNull Sink sink) throws IOException { g.i(sink, "sink"); long j10 = 0; while (this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) != -1) { long jCompleteSegmentByteCount = this.bufferField.completeSegmentByteCount(); if (jCompleteSegmentByteCount > 0) { j10 += jCompleteSegmentByteCount; sink.write(this.bufferField, jCompleteSegmentByteCount); } } if (this.bufferField.size() <= 0) { return j10; } long size = j10 + this.bufferField.size(); Buffer buffer = this.bufferField; sink.write(buffer, buffer.size()); return size; } @Override // okio.BufferedSource public byte readByte() throws EOFException { require(1L); return this.bufferField.readByte(); } @Override // okio.BufferedSource @NotNull public byte[] readByteArray() throws IOException { this.bufferField.writeAll(this.source); return this.bufferField.readByteArray(); } @Override // okio.BufferedSource @NotNull public ByteString readByteString() throws IOException { this.bufferField.writeAll(this.source); return this.bufferField.readByteString(); } @Override // okio.BufferedSource public long readDecimalLong() throws EOFException { byte b10; require(1L); long j10 = 0; while (true) { long j11 = j10 + 1; if (!request(j11)) { break; } b10 = this.bufferField.getByte(j10); if ((b10 < 48 || b10 > 57) && !(j10 == 0 && b10 == 45)) { break; } j10 = j11; } if (j10 == 0) { b.e(16); b.e(16); String string = Integer.toString(b10, 16); g.h(string, "toString(this, checkRadix(radix))"); throw new NumberFormatException("Expected a digit or '-' but was 0x".concat(string)); } return this.bufferField.readDecimalLong(); } @Override // okio.BufferedSource public void readFully(@NotNull byte[] bArr) throws EOFException { g.i(bArr, "sink"); try { require(bArr.length); this.bufferField.readFully(bArr); } catch (EOFException e10) { int i10 = 0; while (this.bufferField.size() > 0) { Buffer buffer = this.bufferField; int i11 = buffer.read(bArr, i10, (int) buffer.size()); if (i11 == -1) { throw new AssertionError(); } i10 += i11; } throw e10; } } @Override // okio.BufferedSource public long readHexadecimalUnsignedLong() throws EOFException { byte b10; require(1L); int i10 = 0; while (true) { int i11 = i10 + 1; if (!request(i11)) { break; } b10 = this.bufferField.getByte(i10); if ((b10 < 48 || b10 > 57) && ((b10 < 97 || b10 > 102) && (b10 < 65 || b10 > 70))) { break; } i10 = i11; } if (i10 == 0) { b.e(16); b.e(16); String string = Integer.toString(b10, 16); g.h(string, "toString(this, checkRadix(radix))"); throw new NumberFormatException("Expected leading [0-9a-fA-F] character but was 0x".concat(string)); } return this.bufferField.readHexadecimalUnsignedLong(); } @Override // okio.BufferedSource public int readInt() throws EOFException { require(4L); return this.bufferField.readInt(); } @Override // okio.BufferedSource public int readIntLe() throws EOFException { require(4L); return this.bufferField.readIntLe(); } @Override // okio.BufferedSource public long readLong() throws EOFException { require(8L); return this.bufferField.readLong(); } @Override // okio.BufferedSource public long readLongLe() throws EOFException { require(8L); return this.bufferField.readLongLe(); } @Override // okio.BufferedSource public short readShort() throws EOFException { require(2L); return this.bufferField.readShort(); } @Override // okio.BufferedSource public short readShortLe() throws EOFException { require(2L); return this.bufferField.readShortLe(); } @Override // okio.BufferedSource @NotNull public String readString(@NotNull Charset charset) throws IOException { g.i(charset, "charset"); this.bufferField.writeAll(this.source); return this.bufferField.readString(charset); } @Override // okio.BufferedSource @NotNull public String readUtf8() throws IOException { this.bufferField.writeAll(this.source); return this.bufferField.readUtf8(); } @Override // okio.BufferedSource public int readUtf8CodePoint() throws EOFException { require(1L); byte b10 = this.bufferField.getByte(0L); if ((b10 & 224) == 192) { require(2L); } else if ((b10 & 240) == 224) { require(3L); } else if ((b10 & 248) == 240) { require(4L); } return this.bufferField.readUtf8CodePoint(); } @Override // okio.BufferedSource @Nullable public String readUtf8Line() { long jIndexOf = indexOf((byte) 10); if (jIndexOf != -1) { return okio.internal.Buffer.readUtf8Line(this.bufferField, jIndexOf); } if (this.bufferField.size() != 0) { return readUtf8(this.bufferField.size()); } return null; } @Override // okio.BufferedSource @NotNull public String readUtf8LineStrict() { return readUtf8LineStrict(Long.MAX_VALUE); } @Override // okio.BufferedSource public boolean request(long byteCount) { if (byteCount < 0) { throw new IllegalArgumentException(u1.i("byteCount < 0: ", byteCount).toString()); } if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } while (this.bufferField.size() < byteCount) { if (this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return false; } } return true; } @Override // okio.BufferedSource public void require(long j10) throws EOFException { if (!request(j10)) { throw new EOFException(); } } @Override // okio.BufferedSource public int select(@NotNull Options options) throws EOFException { g.i(options, "options"); if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } while (true) { int iSelectPrefix = okio.internal.Buffer.selectPrefix(this.bufferField, options, true); if (iSelectPrefix != -2) { if (iSelectPrefix != -1) { this.bufferField.skip(options.getByteStrings()[iSelectPrefix].size()); return iSelectPrefix; } } else if (this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { break; } } return -1; } @Override // okio.BufferedSource public void skip(long j10) throws EOFException { if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } while (j10 > 0) { if (this.bufferField.size() == 0 && this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { throw new EOFException(); } long jMin = Math.min(j10, this.bufferField.size()); this.bufferField.skip(jMin); j10 -= jMin; } } @Override // okio.Source @NotNull /* JADX INFO: renamed from: timeout */ public Timeout getTimeout() { return this.source.getTimeout(); } @NotNull public String toString() { return "buffer(" + this.source + ')'; } @Override // okio.BufferedSource public long indexOf(byte b10, long fromIndex) { return indexOf(b10, fromIndex, Long.MAX_VALUE); } @Override // okio.BufferedSource public long indexOfElement(@NotNull ByteString targetBytes, long fromIndex) { g.i(targetBytes, "targetBytes"); if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } while (true) { long jIndexOfElement = this.bufferField.indexOfElement(targetBytes, fromIndex); if (jIndexOfElement != -1) { return jIndexOfElement; } long size = this.bufferField.size(); if (this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1L; } fromIndex = Math.max(fromIndex, size); } } @Override // java.nio.channels.ReadableByteChannel public int read(@NotNull ByteBuffer sink) { g.i(sink, "sink"); if (this.bufferField.size() == 0 && this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1; } return this.bufferField.read(sink); } @Override // okio.BufferedSource @NotNull public String readUtf8LineStrict(long limit) throws EOFException { if (limit < 0) { throw new IllegalArgumentException(u1.i("limit < 0: ", limit).toString()); } long j10 = limit == Long.MAX_VALUE ? Long.MAX_VALUE : limit + 1; long jIndexOf = indexOf((byte) 10, 0L, j10); if (jIndexOf != -1) { return okio.internal.Buffer.readUtf8Line(this.bufferField, jIndexOf); } if (j10 < Long.MAX_VALUE && request(j10) && this.bufferField.getByte(j10 - 1) == 13 && request(1 + j10) && this.bufferField.getByte(j10) == 10) { return okio.internal.Buffer.readUtf8Line(this.bufferField, j10); } Buffer buffer = new Buffer(); Buffer buffer2 = this.bufferField; buffer2.copyTo(buffer, 0L, Math.min(32, buffer2.size())); throw new EOFException("\\n not found: limit=" + Math.min(this.bufferField.size(), limit) + " content=" + buffer.readByteString().hex() + (char) 8230); } @Override // okio.BufferedSource public long indexOf(@NotNull ByteString bytes) { g.i(bytes, "bytes"); return indexOf(bytes, 0L); } @Override // okio.BufferedSource public boolean rangeEquals(long offset, @NotNull ByteString bytes, int bytesOffset, int byteCount) { g.i(bytes, "bytes"); if (!this.closed) { if (offset >= 0 && bytesOffset >= 0 && byteCount >= 0 && bytes.size() - bytesOffset >= byteCount) { for (int i10 = 0; i10 < byteCount; i10++) { long j10 = ((long) i10) + offset; if (request(1 + j10) && this.bufferField.getByte(j10) == bytes.getByte(bytesOffset + i10)) { } } return true; } return false; } throw new IllegalStateException("closed".toString()); } @Override // okio.BufferedSource @NotNull public byte[] readByteArray(long byteCount) throws EOFException { require(byteCount); return this.bufferField.readByteArray(byteCount); } @Override // okio.BufferedSource @NotNull public ByteString readByteString(long byteCount) throws EOFException { require(byteCount); return this.bufferField.readByteString(byteCount); } @Override // okio.BufferedSource @NotNull public String readString(long byteCount, @NotNull Charset charset) throws EOFException { g.i(charset, "charset"); require(byteCount); return this.bufferField.readString(byteCount, charset); } @Override // okio.BufferedSource @NotNull public String readUtf8(long byteCount) throws EOFException { require(byteCount); return this.bufferField.readUtf8(byteCount); } @Override // okio.BufferedSource public long indexOf(byte b10, long fromIndex, long toIndex) { if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } if (0 > fromIndex || fromIndex > toIndex) { StringBuilder sbS = e.s("fromIndex=", fromIndex, " toIndex="); sbS.append(toIndex); throw new IllegalArgumentException(sbS.toString().toString()); } while (fromIndex < toIndex) { long jIndexOf = this.bufferField.indexOf(b10, fromIndex, toIndex); if (jIndexOf != -1) { return jIndexOf; } long size = this.bufferField.size(); if (size >= toIndex || this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1L; } fromIndex = Math.max(fromIndex, size); } return -1L; } @Override // okio.Source public long read(@NotNull Buffer sink, long byteCount) { g.i(sink, "sink"); if (byteCount < 0) { throw new IllegalArgumentException(u1.i("byteCount < 0: ", byteCount).toString()); } if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } if (this.bufferField.size() == 0 && this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1L; } return this.bufferField.read(sink, Math.min(byteCount, this.bufferField.size())); } @Override // okio.BufferedSource public void readFully(@NotNull Buffer buffer, long j10) throws IOException { g.i(buffer, "sink"); try { require(j10); this.bufferField.readFully(buffer, j10); } catch (EOFException e10) { buffer.writeAll(this.bufferField); throw e10; } } @Override // okio.BufferedSource public long indexOf(@NotNull ByteString bytes, long fromIndex) throws IOException { g.i(bytes, "bytes"); if (!(!this.closed)) { throw new IllegalStateException("closed".toString()); } while (true) { long jIndexOf = this.bufferField.indexOf(bytes, fromIndex); if (jIndexOf != -1) { return jIndexOf; } long size = this.bufferField.size(); if (this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1L; } fromIndex = Math.max(fromIndex, (size - ((long) bytes.size())) + 1); } } @Override // okio.BufferedSource public int read(@NotNull byte[] sink, int offset, int byteCount) { g.i(sink, "sink"); long j10 = byteCount; SegmentedByteString.checkOffsetAndCount(sink.length, offset, j10); if (this.bufferField.size() == 0 && this.source.read(this.bufferField, IjkMediaMeta.AV_CH_TOP_FRONT_CENTER) == -1) { return -1; } return this.bufferField.read(sink, offset, (int) Math.min(j10, this.bufferField.size())); } }