package okio.internal; import androidx.exifinterface.media.ExifInterface; import java.io.EOFException; import kotlin.Metadata; import kotlin.UByte; import kotlin.collections.ArraysKt; import kotlin.jvm.functions.Function2; import kotlin.jvm.internal.ByteCompanionObject; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.LongCompanionObject; import kotlin.text.Typography; import okhttp3.internal.connection.RealConnection; import okio.Buffer; import okio.ByteString; import okio.Options; import okio.Platform; import okio.Segment; import okio.SegmentPool; import okio.SegmentedByteString; import okio.Sink; import okio.Source; import okio.Utf8; import okio.Util; /* compiled from: Buffer.kt */ @Metadata(bv = {1, 0, 3}, d1 = {"\u0000v\n\u0000\n\u0002\u0010\u0012\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u0005\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0010\n\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0015\n\u0002\u0018\u0002\n\u0002\b\u0004\u001a0\u0010\t\u001a\u00020\n2\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010\r\u001a\u00020\b2\u0006\u0010\u000e\u001a\u00020\u00012\u0006\u0010\u000f\u001a\u00020\b2\u0006\u0010\u0010\u001a\u00020\bH\u0000\u001a\r\u0010\u0011\u001a\u00020\u0012*\u00020\u0013H\u0080\b\u001a\r\u0010\u0014\u001a\u00020\u0005*\u00020\u0013H\u0080\b\u001a\r\u0010\u0015\u001a\u00020\u0013*\u00020\u0013H\u0080\b\u001a%\u0010\u0016\u001a\u00020\u0013*\u00020\u00132\u0006\u0010\u0017\u001a\u00020\u00132\u0006\u0010\u0018\u001a\u00020\u00052\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\u0017\u0010\u001a\u001a\u00020\n*\u00020\u00132\b\u0010\u001b\u001a\u0004\u0018\u00010\u001cH\u0080\b\u001a\u0015\u0010\u001d\u001a\u00020\u001e*\u00020\u00132\u0006\u0010\u001f\u001a\u00020\u0005H\u0080\b\u001a\r\u0010 \u001a\u00020\b*\u00020\u0013H\u0080\b\u001a%\u0010!\u001a\u00020\u0005*\u00020\u00132\u0006\u0010\"\u001a\u00020\u001e2\u0006\u0010#\u001a\u00020\u00052\u0006\u0010$\u001a\u00020\u0005H\u0080\b\u001a\u001d\u0010!\u001a\u00020\u0005*\u00020\u00132\u0006\u0010\u000e\u001a\u00020%2\u0006\u0010#\u001a\u00020\u0005H\u0080\b\u001a\u001d\u0010&\u001a\u00020\u0005*\u00020\u00132\u0006\u0010'\u001a\u00020%2\u0006\u0010#\u001a\u00020\u0005H\u0080\b\u001a-\u0010(\u001a\u00020\n*\u00020\u00132\u0006\u0010\u0018\u001a\u00020\u00052\u0006\u0010\u000e\u001a\u00020%2\u0006\u0010\u000f\u001a\u00020\b2\u0006\u0010\u0019\u001a\u00020\bH\u0080\b\u001a\u0015\u0010)\u001a\u00020\b*\u00020\u00132\u0006\u0010*\u001a\u00020\u0001H\u0080\b\u001a%\u0010)\u001a\u00020\b*\u00020\u00132\u0006\u0010*\u001a\u00020\u00012\u0006\u0010\u0018\u001a\u00020\b2\u0006\u0010\u0019\u001a\u00020\bH\u0080\b\u001a\u001d\u0010)\u001a\u00020\u0005*\u00020\u00132\u0006\u0010*\u001a\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\u0015\u0010+\u001a\u00020\u0005*\u00020\u00132\u0006\u0010*\u001a\u00020,H\u0080\b\u001a\r\u0010-\u001a\u00020\u001e*\u00020\u0013H\u0080\b\u001a\r\u0010.\u001a\u00020\u0001*\u00020\u0013H\u0080\b\u001a\u0015\u0010.\u001a\u00020\u0001*\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\r\u0010/\u001a\u00020%*\u00020\u0013H\u0080\b\u001a\u0015\u0010/\u001a\u00020%*\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\r\u00100\u001a\u00020\u0005*\u00020\u0013H\u0080\b\u001a\u0015\u00101\u001a\u00020\u0012*\u00020\u00132\u0006\u0010*\u001a\u00020\u0001H\u0080\b\u001a\u001d\u00101\u001a\u00020\u0012*\u00020\u00132\u0006\u0010*\u001a\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\r\u00102\u001a\u00020\u0005*\u00020\u0013H\u0080\b\u001a\r\u00103\u001a\u00020\b*\u00020\u0013H\u0080\b\u001a\r\u00104\u001a\u00020\u0005*\u00020\u0013H\u0080\b\u001a\r\u00105\u001a\u000206*\u00020\u0013H\u0080\b\u001a\u0015\u00107\u001a\u000208*\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\r\u00109\u001a\u00020\b*\u00020\u0013H\u0080\b\u001a\u000f\u0010:\u001a\u0004\u0018\u000108*\u00020\u0013H\u0080\b\u001a\u0015\u0010;\u001a\u000208*\u00020\u00132\u0006\u0010<\u001a\u00020\u0005H\u0080\b\u001a\u0015\u0010=\u001a\u00020\b*\u00020\u00132\u0006\u0010>\u001a\u00020?H\u0080\b\u001a\u0015\u0010@\u001a\u00020\u0012*\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\r\u0010A\u001a\u00020%*\u00020\u0013H\u0080\b\u001a\u0015\u0010A\u001a\u00020%*\u00020\u00132\u0006\u0010\u0019\u001a\u00020\bH\u0080\b\u001a\u0015\u0010B\u001a\u00020\f*\u00020\u00132\u0006\u0010C\u001a\u00020\bH\u0080\b\u001a\u0015\u0010D\u001a\u00020\u0013*\u00020\u00132\u0006\u0010E\u001a\u00020\u0001H\u0080\b\u001a%\u0010D\u001a\u00020\u0013*\u00020\u00132\u0006\u0010E\u001a\u00020\u00012\u0006\u0010\u0018\u001a\u00020\b2\u0006\u0010\u0019\u001a\u00020\bH\u0080\b\u001a\u001d\u0010D\u001a\u00020\u0012*\u00020\u00132\u0006\u0010E\u001a\u00020\u00132\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a)\u0010D\u001a\u00020\u0013*\u00020\u00132\u0006\u0010F\u001a\u00020%2\b\b\u0002\u0010\u0018\u001a\u00020\b2\b\b\u0002\u0010\u0019\u001a\u00020\bH\u0080\b\u001a\u001d\u0010D\u001a\u00020\u0013*\u00020\u00132\u0006\u0010E\u001a\u00020G2\u0006\u0010\u0019\u001a\u00020\u0005H\u0080\b\u001a\u0015\u0010H\u001a\u00020\u0005*\u00020\u00132\u0006\u0010E\u001a\u00020GH\u0080\b\u001a\u0015\u0010I\u001a\u00020\u0013*\u00020\u00132\u0006\u0010\"\u001a\u00020\bH\u0080\b\u001a\u0015\u0010J\u001a\u00020\u0013*\u00020\u00132\u0006\u0010K\u001a\u00020\u0005H\u0080\b\u001a\u0015\u0010L\u001a\u00020\u0013*\u00020\u00132\u0006\u0010K\u001a\u00020\u0005H\u0080\b\u001a\u0015\u0010M\u001a\u00020\u0013*\u00020\u00132\u0006\u0010N\u001a\u00020\bH\u0080\b\u001a\u0015\u0010O\u001a\u00020\u0013*\u00020\u00132\u0006\u0010K\u001a\u00020\u0005H\u0080\b\u001a\u0015\u0010P\u001a\u00020\u0013*\u00020\u00132\u0006\u0010Q\u001a\u00020\bH\u0080\b\u001a%\u0010R\u001a\u00020\u0013*\u00020\u00132\u0006\u0010S\u001a\u0002082\u0006\u0010T\u001a\u00020\b2\u0006\u0010U\u001a\u00020\bH\u0080\b\u001a\u0015\u0010V\u001a\u00020\u0013*\u00020\u00132\u0006\u0010W\u001a\u00020\bH\u0080\b\u001a\u0014\u0010X\u001a\u000208*\u00020\u00132\u0006\u0010Y\u001a\u00020\u0005H\u0000\u001a<\u0010Z\u001a\u0002H[\"\u0004\b\u0000\u0010[*\u00020\u00132\u0006\u0010#\u001a\u00020\u00052\u001a\u0010\\\u001a\u0016\u0012\u0006\u0012\u0004\u0018\u00010\f\u0012\u0004\u0012\u00020\u0005\u0012\u0004\u0012\u0002H[0]H\u0080\b¢\u0006\u0002\u0010^\u001a\u001e\u0010_\u001a\u00020\b*\u00020\u00132\u0006\u0010>\u001a\u00020?2\b\b\u0002\u0010`\u001a\u00020\nH\u0000\"\u0014\u0010\u0000\u001a\u00020\u0001X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0002\u0010\u0003\"\u000e\u0010\u0004\u001a\u00020\u0005X\u0080T¢\u0006\u0002\n\u0000\"\u000e\u0010\u0006\u001a\u00020\u0005X\u0080T¢\u0006\u0002\n\u0000\"\u000e\u0010\u0007\u001a\u00020\bX\u0080T¢\u0006\u0002\n\u0000¨\u0006a"}, d2 = {"HEX_DIGIT_BYTES", "", "getHEX_DIGIT_BYTES", "()[B", "OVERFLOW_DIGIT_START", "", "OVERFLOW_ZONE", "SEGMENTING_THRESHOLD", "", "rangeEquals", "", "segment", "Lokio/Segment;", "segmentPos", "bytes", "bytesOffset", "bytesLimit", "commonClear", "", "Lokio/Buffer;", "commonCompleteSegmentByteCount", "commonCopy", "commonCopyTo", "out", "offset", "byteCount", "commonEquals", "other", "", "commonGet", "", "pos", "commonHashCode", "commonIndexOf", "b", "fromIndex", "toIndex", "Lokio/ByteString;", "commonIndexOfElement", "targetBytes", "commonRangeEquals", "commonRead", "sink", "commonReadAll", "Lokio/Sink;", "commonReadByte", "commonReadByteArray", "commonReadByteString", "commonReadDecimalLong", "commonReadFully", "commonReadHexadecimalUnsignedLong", "commonReadInt", "commonReadLong", "commonReadShort", "", "commonReadUtf8", "", "commonReadUtf8CodePoint", "commonReadUtf8Line", "commonReadUtf8LineStrict", "limit", "commonSelect", "options", "Lokio/Options;", "commonSkip", "commonSnapshot", "commonWritableSegment", "minimumCapacity", "commonWrite", "source", "byteString", "Lokio/Source;", "commonWriteAll", "commonWriteByte", "commonWriteDecimalLong", "v", "commonWriteHexadecimalUnsignedLong", "commonWriteInt", "i", "commonWriteLong", "commonWriteShort", "s", "commonWriteUtf8", "string", "beginIndex", "endIndex", "commonWriteUtf8CodePoint", "codePoint", "readUtf8Line", "newline", "seek", ExifInterface.GPS_DIRECTION_TRUE, "lambda", "Lkotlin/Function2;", "(Lokio/Buffer;JLkotlin/jvm/functions/Function2;)Ljava/lang/Object;", "selectPrefix", "selectTruncated", "okio"}, k = 2, mv = {1, 1, 16}) /* loaded from: classes2.dex */ public final class BufferKt { private static final byte[] HEX_DIGIT_BYTES = Platform.asUtf8ToByteArray("0123456789abcdef"); public static final long OVERFLOW_DIGIT_START = -7; public static final long OVERFLOW_ZONE = -922337203685477580L; public static final int SEGMENTING_THRESHOLD = 4096; public static final byte[] getHEX_DIGIT_BYTES() { return HEX_DIGIT_BYTES; } public static final boolean rangeEquals(Segment segment, int i, byte[] bytes, int i2, int i3) { Intrinsics.checkParameterIsNotNull(segment, "segment"); Intrinsics.checkParameterIsNotNull(bytes, "bytes"); int i4 = segment.limit; byte[] bArr = segment.data; while (i2 < i3) { if (i == i4) { segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } byte[] bArr2 = segment.data; bArr = bArr2; i = segment.pos; i4 = segment.limit; } if (bArr[i] != bytes[i2]) { return false; } i++; i2++; } return true; } public static final String readUtf8Line(Buffer readUtf8Line, long j) { Intrinsics.checkParameterIsNotNull(readUtf8Line, "$this$readUtf8Line"); if (j > 0) { long j2 = j - 1; if (readUtf8Line.getByte(j2) == ((byte) 13)) { String readUtf8 = readUtf8Line.readUtf8(j2); readUtf8Line.skip(2L); return readUtf8; } } String readUtf82 = readUtf8Line.readUtf8(j); readUtf8Line.skip(1L); return readUtf82; } public static final T seek(Buffer seek, long j, Function2 lambda) { Intrinsics.checkParameterIsNotNull(seek, "$this$seek"); Intrinsics.checkParameterIsNotNull(lambda, "lambda"); Segment segment = seek.head; if (segment == null) { return lambda.invoke(null, -1L); } if (seek.size() - j < j) { long size = seek.size(); while (size > j) { segment = segment.prev; if (segment == null) { Intrinsics.throwNpe(); } size -= segment.limit - segment.pos; } return lambda.invoke(segment, Long.valueOf(size)); } long j2 = 0; while (true) { long j3 = (segment.limit - segment.pos) + j2; if (j3 <= j) { segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j2 = j3; } else { return lambda.invoke(segment, Long.valueOf(j2)); } } } public static /* synthetic */ int selectPrefix$default(Buffer buffer, Options options, boolean z, int i, Object obj) { if ((i & 2) != 0) { z = false; } return selectPrefix(buffer, options, z); } /* JADX WARN: Code restructure failed: missing block: B:35:0x0061, code lost: if (r19 == false) goto L97; */ /* JADX WARN: Code restructure failed: missing block: B:36:0x0063, code lost: return -2; */ /* JADX WARN: Code restructure failed: missing block: B:37:0x0064, code lost: return r10; */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final int selectPrefix(okio.Buffer r17, okio.Options r18, boolean r19) { /* Method dump skipped, instructions count: 190 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okio.internal.BufferKt.selectPrefix(okio.Buffer, okio.Options, boolean):int"); } public static final Buffer commonCopyTo(Buffer commonCopyTo, Buffer out, long j, long j2) { Intrinsics.checkParameterIsNotNull(commonCopyTo, "$this$commonCopyTo"); Intrinsics.checkParameterIsNotNull(out, "out"); Util.checkOffsetAndCount(commonCopyTo.size(), j, j2); if (j2 == 0) { return commonCopyTo; } out.setSize$okio(out.size() + j2); Segment segment = commonCopyTo.head; while (true) { if (segment == null) { Intrinsics.throwNpe(); } if (j < segment.limit - segment.pos) { break; } j -= segment.limit - segment.pos; segment = segment.next; } while (j2 > 0) { if (segment == null) { Intrinsics.throwNpe(); } Segment sharedCopy = segment.sharedCopy(); sharedCopy.pos += (int) j; sharedCopy.limit = Math.min(sharedCopy.pos + ((int) j2), sharedCopy.limit); if (out.head == null) { sharedCopy.prev = sharedCopy; sharedCopy.next = sharedCopy.prev; out.head = sharedCopy.next; } else { Segment segment2 = out.head; if (segment2 == null) { Intrinsics.throwNpe(); } Segment segment3 = segment2.prev; if (segment3 == null) { Intrinsics.throwNpe(); } segment3.push(sharedCopy); } j2 -= sharedCopy.limit - sharedCopy.pos; segment = segment.next; j = 0; } return commonCopyTo; } public static final long commonCompleteSegmentByteCount(Buffer commonCompleteSegmentByteCount) { Intrinsics.checkParameterIsNotNull(commonCompleteSegmentByteCount, "$this$commonCompleteSegmentByteCount"); long size = commonCompleteSegmentByteCount.size(); if (size == 0) { return 0L; } Segment segment = commonCompleteSegmentByteCount.head; if (segment == null) { Intrinsics.throwNpe(); } Segment segment2 = segment.prev; if (segment2 == null) { Intrinsics.throwNpe(); } return (segment2.limit >= 8192 || !segment2.owner) ? size : size - (segment2.limit - segment2.pos); } public static final byte commonReadByte(Buffer commonReadByte) { Intrinsics.checkParameterIsNotNull(commonReadByte, "$this$commonReadByte"); if (commonReadByte.size() == 0) { throw new EOFException(); } Segment segment = commonReadByte.head; if (segment == null) { Intrinsics.throwNpe(); } int i = segment.pos; int i2 = segment.limit; int i3 = i + 1; byte b = segment.data[i]; commonReadByte.setSize$okio(commonReadByte.size() - 1); if (i3 == i2) { commonReadByte.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } else { segment.pos = i3; } return b; } public static final short commonReadShort(Buffer commonReadShort) { Intrinsics.checkParameterIsNotNull(commonReadShort, "$this$commonReadShort"); if (commonReadShort.size() < 2) { throw new EOFException(); } Segment segment = commonReadShort.head; if (segment == null) { Intrinsics.throwNpe(); } int i = segment.pos; int i2 = segment.limit; if (i2 - i < 2) { return (short) ((commonReadShort.readByte() & UByte.MAX_VALUE) | ((commonReadShort.readByte() & UByte.MAX_VALUE) << 8)); } byte[] bArr = segment.data; int i3 = i + 1; int i4 = (bArr[i] & UByte.MAX_VALUE) << 8; int i5 = i + 2; int i6 = (bArr[i3] & UByte.MAX_VALUE) | i4; commonReadShort.setSize$okio(commonReadShort.size() - 2); if (i5 == i2) { commonReadShort.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } else { segment.pos = i5; } return (short) i6; } public static final int commonReadInt(Buffer commonReadInt) { Intrinsics.checkParameterIsNotNull(commonReadInt, "$this$commonReadInt"); if (commonReadInt.size() < 4) { throw new EOFException(); } Segment segment = commonReadInt.head; if (segment == null) { Intrinsics.throwNpe(); } int i = segment.pos; int i2 = segment.limit; if (i2 - i < 4) { return (commonReadInt.readByte() & UByte.MAX_VALUE) | ((commonReadInt.readByte() & UByte.MAX_VALUE) << 24) | ((commonReadInt.readByte() & UByte.MAX_VALUE) << 16) | ((commonReadInt.readByte() & UByte.MAX_VALUE) << 8); } byte[] bArr = segment.data; int i3 = i + 3; int i4 = ((bArr[i + 1] & UByte.MAX_VALUE) << 16) | ((bArr[i] & UByte.MAX_VALUE) << 24) | ((bArr[i + 2] & UByte.MAX_VALUE) << 8); int i5 = i + 4; int i6 = (bArr[i3] & UByte.MAX_VALUE) | i4; commonReadInt.setSize$okio(commonReadInt.size() - 4); if (i5 == i2) { commonReadInt.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } else { segment.pos = i5; } return i6; } public static final long commonReadLong(Buffer commonReadLong) { Intrinsics.checkParameterIsNotNull(commonReadLong, "$this$commonReadLong"); if (commonReadLong.size() < 8) { throw new EOFException(); } Segment segment = commonReadLong.head; if (segment == null) { Intrinsics.throwNpe(); } int i = segment.pos; int i2 = segment.limit; if (i2 - i < 8) { return ((commonReadLong.readInt() & 4294967295L) << 32) | (4294967295L & commonReadLong.readInt()); } byte[] bArr = segment.data; int i3 = i + 7; long j = ((bArr[i] & 255) << 56) | ((bArr[i + 1] & 255) << 48) | ((bArr[i + 2] & 255) << 40) | ((bArr[i + 3] & 255) << 32) | ((bArr[i + 4] & 255) << 24) | ((bArr[i + 5] & 255) << 16) | ((bArr[i + 6] & 255) << 8); int i4 = i + 8; long j2 = j | (bArr[i3] & 255); commonReadLong.setSize$okio(commonReadLong.size() - 8); if (i4 == i2) { commonReadLong.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } else { segment.pos = i4; } return j2; } public static final byte commonGet(Buffer commonGet, long j) { Intrinsics.checkParameterIsNotNull(commonGet, "$this$commonGet"); Util.checkOffsetAndCount(commonGet.size(), j, 1L); Segment segment = commonGet.head; if (segment == null) { Segment segment2 = null; Intrinsics.throwNpe(); byte[] bArr = segment2.data; throw null; } if (commonGet.size() - j < j) { long size = commonGet.size(); while (size > j) { segment = segment.prev; if (segment == null) { Intrinsics.throwNpe(); } size -= segment.limit - segment.pos; } if (segment == null) { Intrinsics.throwNpe(); } return segment.data[(int) ((segment.pos + j) - size)]; } long j2 = 0; while (true) { long j3 = (segment.limit - segment.pos) + j2; if (j3 > j) { break; } segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j2 = j3; } if (segment == null) { Intrinsics.throwNpe(); } return segment.data[(int) ((segment.pos + j) - j2)]; } public static final void commonClear(Buffer commonClear) { Intrinsics.checkParameterIsNotNull(commonClear, "$this$commonClear"); commonClear.skip(commonClear.size()); } public static final void commonSkip(Buffer commonSkip, long j) { Intrinsics.checkParameterIsNotNull(commonSkip, "$this$commonSkip"); while (j > 0) { Segment segment = commonSkip.head; if (segment == null) { throw new EOFException(); } int min = (int) Math.min(j, segment.limit - segment.pos); long j2 = min; commonSkip.setSize$okio(commonSkip.size() - j2); j -= j2; segment.pos += min; if (segment.pos == segment.limit) { commonSkip.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } } } public static /* synthetic */ Buffer commonWrite$default(Buffer commonWrite, ByteString byteString, int i, int i2, int i3, Object obj) { if ((i3 & 2) != 0) { i = 0; } if ((i3 & 4) != 0) { i2 = byteString.size(); } Intrinsics.checkParameterIsNotNull(commonWrite, "$this$commonWrite"); Intrinsics.checkParameterIsNotNull(byteString, "byteString"); byteString.write$okio(commonWrite, i, i2); return commonWrite; } public static final Buffer commonWrite(Buffer commonWrite, ByteString byteString, int i, int i2) { Intrinsics.checkParameterIsNotNull(commonWrite, "$this$commonWrite"); Intrinsics.checkParameterIsNotNull(byteString, "byteString"); byteString.write$okio(commonWrite, i, i2); return commonWrite; } public static final Buffer commonWriteDecimalLong(Buffer commonWriteDecimalLong, long j) { boolean z; Intrinsics.checkParameterIsNotNull(commonWriteDecimalLong, "$this$commonWriteDecimalLong"); if (j == 0) { return commonWriteDecimalLong.writeByte(48); } int i = 1; if (j < 0) { j = -j; if (j < 0) { return commonWriteDecimalLong.writeUtf8("-9223372036854775808"); } z = true; } else { z = false; } if (j >= 100000000) { i = j < 1000000000000L ? j < RealConnection.IDLE_CONNECTION_HEALTHY_NS ? j < 1000000000 ? 9 : 10 : j < 100000000000L ? 11 : 12 : j < 1000000000000000L ? j < 10000000000000L ? 13 : j < 100000000000000L ? 14 : 15 : j < 100000000000000000L ? j < 10000000000000000L ? 16 : 17 : j < 1000000000000000000L ? 18 : 19; } else if (j >= 10000) { i = j < 1000000 ? j < 100000 ? 5 : 6 : j < 10000000 ? 7 : 8; } else if (j >= 100) { i = j < 1000 ? 3 : 4; } else if (j >= 10) { i = 2; } if (z) { i++; } Segment writableSegment$okio = commonWriteDecimalLong.writableSegment$okio(i); byte[] bArr = writableSegment$okio.data; int i2 = writableSegment$okio.limit + i; while (j != 0) { long j2 = 10; i2--; bArr[i2] = getHEX_DIGIT_BYTES()[(int) (j % j2)]; j /= j2; } if (z) { bArr[i2 - 1] = (byte) 45; } writableSegment$okio.limit += i; commonWriteDecimalLong.setSize$okio(commonWriteDecimalLong.size() + i); return commonWriteDecimalLong; } public static final Buffer commonWriteHexadecimalUnsignedLong(Buffer commonWriteHexadecimalUnsignedLong, long j) { Intrinsics.checkParameterIsNotNull(commonWriteHexadecimalUnsignedLong, "$this$commonWriteHexadecimalUnsignedLong"); if (j == 0) { return commonWriteHexadecimalUnsignedLong.writeByte(48); } long j2 = (j >>> 1) | j; long j3 = j2 | (j2 >>> 2); long j4 = j3 | (j3 >>> 4); long j5 = j4 | (j4 >>> 8); long j6 = j5 | (j5 >>> 16); long j7 = j6 | (j6 >>> 32); long j8 = j7 - ((j7 >>> 1) & 6148914691236517205L); long j9 = ((j8 >>> 2) & 3689348814741910323L) + (j8 & 3689348814741910323L); long j10 = ((j9 >>> 4) + j9) & 1085102592571150095L; long j11 = j10 + (j10 >>> 8); long j12 = j11 + (j11 >>> 16); int i = (int) ((((j12 & 63) + ((j12 >>> 32) & 63)) + 3) / 4); Segment writableSegment$okio = commonWriteHexadecimalUnsignedLong.writableSegment$okio(i); byte[] bArr = writableSegment$okio.data; int i2 = writableSegment$okio.limit; for (int i3 = (writableSegment$okio.limit + i) - 1; i3 >= i2; i3--) { bArr[i3] = getHEX_DIGIT_BYTES()[(int) (15 & j)]; j >>>= 4; } writableSegment$okio.limit += i; commonWriteHexadecimalUnsignedLong.setSize$okio(commonWriteHexadecimalUnsignedLong.size() + i); return commonWriteHexadecimalUnsignedLong; } public static final Segment commonWritableSegment(Buffer commonWritableSegment, int i) { Intrinsics.checkParameterIsNotNull(commonWritableSegment, "$this$commonWritableSegment"); if (!(i >= 1 && i <= 8192)) { throw new IllegalArgumentException("unexpected capacity".toString()); } if (commonWritableSegment.head == null) { Segment take = SegmentPool.INSTANCE.take(); commonWritableSegment.head = take; take.prev = take; take.next = take; return take; } Segment segment = commonWritableSegment.head; if (segment == null) { Intrinsics.throwNpe(); } Segment segment2 = segment.prev; if (segment2 == null) { Intrinsics.throwNpe(); } return (segment2.limit + i > 8192 || !segment2.owner) ? segment2.push(SegmentPool.INSTANCE.take()) : segment2; } public static final Buffer commonWrite(Buffer commonWrite, byte[] source) { Intrinsics.checkParameterIsNotNull(commonWrite, "$this$commonWrite"); Intrinsics.checkParameterIsNotNull(source, "source"); return commonWrite.write(source, 0, source.length); } public static final Buffer commonWrite(Buffer commonWrite, byte[] source, int i, int i2) { Intrinsics.checkParameterIsNotNull(commonWrite, "$this$commonWrite"); Intrinsics.checkParameterIsNotNull(source, "source"); long j = i2; Util.checkOffsetAndCount(source.length, i, j); int i3 = i2 + i; while (i < i3) { Segment writableSegment$okio = commonWrite.writableSegment$okio(1); int min = Math.min(i3 - i, 8192 - writableSegment$okio.limit); int i4 = i + min; ArraysKt.copyInto(source, writableSegment$okio.data, writableSegment$okio.limit, i, i4); writableSegment$okio.limit += min; i = i4; } commonWrite.setSize$okio(commonWrite.size() + j); return commonWrite; } public static final byte[] commonReadByteArray(Buffer commonReadByteArray) { Intrinsics.checkParameterIsNotNull(commonReadByteArray, "$this$commonReadByteArray"); return commonReadByteArray.readByteArray(commonReadByteArray.size()); } public static final byte[] commonReadByteArray(Buffer commonReadByteArray, long j) { Intrinsics.checkParameterIsNotNull(commonReadByteArray, "$this$commonReadByteArray"); if (!(j >= 0 && j <= ((long) Integer.MAX_VALUE))) { throw new IllegalArgumentException(("byteCount: " + j).toString()); } if (commonReadByteArray.size() < j) { throw new EOFException(); } byte[] bArr = new byte[(int) j]; commonReadByteArray.readFully(bArr); return bArr; } public static final int commonRead(Buffer commonRead, byte[] sink) { Intrinsics.checkParameterIsNotNull(commonRead, "$this$commonRead"); Intrinsics.checkParameterIsNotNull(sink, "sink"); return commonRead.read(sink, 0, sink.length); } public static final void commonReadFully(Buffer commonReadFully, byte[] sink) { Intrinsics.checkParameterIsNotNull(commonReadFully, "$this$commonReadFully"); Intrinsics.checkParameterIsNotNull(sink, "sink"); int i = 0; while (i < sink.length) { int read = commonReadFully.read(sink, i, sink.length - i); if (read == -1) { throw new EOFException(); } i += read; } } public static final int commonRead(Buffer commonRead, byte[] sink, int i, int i2) { Intrinsics.checkParameterIsNotNull(commonRead, "$this$commonRead"); Intrinsics.checkParameterIsNotNull(sink, "sink"); Util.checkOffsetAndCount(sink.length, i, i2); Segment segment = commonRead.head; if (segment == null) { return -1; } int min = Math.min(i2, segment.limit - segment.pos); ArraysKt.copyInto(segment.data, sink, i, segment.pos, segment.pos + min); segment.pos += min; commonRead.setSize$okio(commonRead.size() - min); if (segment.pos == segment.limit) { commonRead.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } return min; } /* JADX WARN: Removed duplicated region for block: B:38:0x00a8 */ /* JADX WARN: Removed duplicated region for block: B:40:0x00b8 */ /* JADX WARN: Removed duplicated region for block: B:49:0x00bc A[EDGE_INSN: B:49:0x00bc->B:43:0x00bc BREAK A[LOOP:0: B:4:0x0016->B:48:?], SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:50:0x00b4 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final long commonReadDecimalLong(okio.Buffer r15) { /* Method dump skipped, instructions count: 210 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okio.internal.BufferKt.commonReadDecimalLong(okio.Buffer):long"); } /* JADX WARN: Removed duplicated region for block: B:34:0x00a3 */ /* JADX WARN: Removed duplicated region for block: B:36:0x00b3 */ /* JADX WARN: Removed duplicated region for block: B:42:0x00b7 A[EDGE_INSN: B:42:0x00b7->B:39:0x00b7 BREAK A[LOOP:0: B:4:0x0012->B:41:?], SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:43:0x00af */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final long commonReadHexadecimalUnsignedLong(okio.Buffer r14) { /* java.lang.String r0 = "$this$commonReadHexadecimalUnsignedLong" kotlin.jvm.internal.Intrinsics.checkParameterIsNotNull(r14, r0) long r0 = r14.size() r2 = 0 int r0 = (r0 > r2 ? 1 : (r0 == r2 ? 0 : -1)) if (r0 == 0) goto Lc1 r0 = 0 r1 = r0 r4 = r2 L12: okio.Segment r6 = r14.head if (r6 != 0) goto L19 kotlin.jvm.internal.Intrinsics.throwNpe() L19: byte[] r7 = r6.data int r8 = r6.pos int r9 = r6.limit L1f: if (r8 >= r9) goto La1 r10 = r7[r8] r11 = 48 byte r11 = (byte) r11 if (r10 < r11) goto L30 r12 = 57 byte r12 = (byte) r12 if (r10 > r12) goto L30 int r11 = r10 - r11 goto L4a L30: r11 = 97 byte r11 = (byte) r11 if (r10 < r11) goto L3f r12 = 102(0x66, float:1.43E-43) byte r12 = (byte) r12 if (r10 > r12) goto L3f L3a: int r11 = r10 - r11 int r11 = r11 + 10 goto L4a L3f: r11 = 65 byte r11 = (byte) r11 if (r10 < r11) goto L82 r12 = 70 byte r12 = (byte) r12 if (r10 > r12) goto L82 goto L3a L4a: r12 = -1152921504606846976(0xf000000000000000, double:-3.105036184601418E231) long r12 = r12 & r4 int r12 = (r12 > r2 ? 1 : (r12 == r2 ? 0 : -1)) if (r12 != 0) goto L5a r10 = 4 long r4 = r4 << r10 long r10 = (long) r11 long r4 = r4 | r10 int r8 = r8 + 1 int r0 = r0 + 1 goto L1f L5a: okio.Buffer r14 = new okio.Buffer r14.() okio.Buffer r14 = r14.writeHexadecimalUnsignedLong(r4) okio.Buffer r14 = r14.writeByte(r10) java.lang.NumberFormatException r0 = new java.lang.NumberFormatException java.lang.StringBuilder r1 = new java.lang.StringBuilder java.lang.String r2 = "Number too large: " r1.(r2) java.lang.String r14 = r14.readUtf8() java.lang.StringBuilder r14 = r1.append(r14) java.lang.String r14 = r14.toString() r0.(r14) java.lang.Throwable r0 = (java.lang.Throwable) r0 throw r0 L82: if (r0 == 0) goto L86 r1 = 1 goto La1 L86: java.lang.NumberFormatException r14 = new java.lang.NumberFormatException java.lang.StringBuilder r0 = new java.lang.StringBuilder java.lang.String r1 = "Expected leading [0-9a-fA-F] character but was 0x" r0.(r1) java.lang.String r1 = okio.Util.toHexString(r10) java.lang.StringBuilder r0 = r0.append(r1) java.lang.String r0 = r0.toString() r14.(r0) java.lang.Throwable r14 = (java.lang.Throwable) r14 throw r14 La1: if (r8 != r9) goto Laf okio.Segment r7 = r6.pop() r14.head = r7 okio.SegmentPool r7 = okio.SegmentPool.INSTANCE r7.recycle(r6) goto Lb1 Laf: r6.pos = r8 Lb1: if (r1 != 0) goto Lb7 okio.Segment r6 = r14.head if (r6 != 0) goto L12 Lb7: long r1 = r14.size() long r6 = (long) r0 long r1 = r1 - r6 r14.setSize$okio(r1) return r4 Lc1: java.io.EOFException r14 = new java.io.EOFException r14.() java.lang.Throwable r14 = (java.lang.Throwable) r14 throw r14 */ throw new UnsupportedOperationException("Method not decompiled: okio.internal.BufferKt.commonReadHexadecimalUnsignedLong(okio.Buffer):long"); } public static final ByteString commonReadByteString(Buffer commonReadByteString) { Intrinsics.checkParameterIsNotNull(commonReadByteString, "$this$commonReadByteString"); return commonReadByteString.readByteString(commonReadByteString.size()); } public static final ByteString commonReadByteString(Buffer commonReadByteString, long j) { Intrinsics.checkParameterIsNotNull(commonReadByteString, "$this$commonReadByteString"); if (!(j >= 0 && j <= ((long) Integer.MAX_VALUE))) { throw new IllegalArgumentException(("byteCount: " + j).toString()); } if (commonReadByteString.size() < j) { throw new EOFException(); } if (j >= 4096) { ByteString snapshot = commonReadByteString.snapshot((int) j); commonReadByteString.skip(j); return snapshot; } return new ByteString(commonReadByteString.readByteArray(j)); } public static final int commonSelect(Buffer commonSelect, Options options) { Intrinsics.checkParameterIsNotNull(commonSelect, "$this$commonSelect"); Intrinsics.checkParameterIsNotNull(options, "options"); int selectPrefix$default = selectPrefix$default(commonSelect, options, false, 2, null); if (selectPrefix$default == -1) { return -1; } commonSelect.skip(options.getByteStrings()[selectPrefix$default].size()); return selectPrefix$default; } public static final void commonReadFully(Buffer commonReadFully, Buffer sink, long j) { Intrinsics.checkParameterIsNotNull(commonReadFully, "$this$commonReadFully"); Intrinsics.checkParameterIsNotNull(sink, "sink"); if (commonReadFully.size() < j) { sink.write(commonReadFully, commonReadFully.size()); throw new EOFException(); } sink.write(commonReadFully, j); } public static final long commonReadAll(Buffer commonReadAll, Sink sink) { Intrinsics.checkParameterIsNotNull(commonReadAll, "$this$commonReadAll"); Intrinsics.checkParameterIsNotNull(sink, "sink"); long size = commonReadAll.size(); if (size > 0) { sink.write(commonReadAll, size); } return size; } public static final String commonReadUtf8(Buffer commonReadUtf8, long j) { Intrinsics.checkParameterIsNotNull(commonReadUtf8, "$this$commonReadUtf8"); if (!(j >= 0 && j <= ((long) Integer.MAX_VALUE))) { throw new IllegalArgumentException(("byteCount: " + j).toString()); } if (commonReadUtf8.size() < j) { throw new EOFException(); } if (j == 0) { return ""; } Segment segment = commonReadUtf8.head; if (segment == null) { Intrinsics.throwNpe(); } if (segment.pos + j > segment.limit) { return _Utf8Kt.commonToUtf8String$default(commonReadUtf8.readByteArray(j), 0, 0, 3, null); } int i = (int) j; String commonToUtf8String = _Utf8Kt.commonToUtf8String(segment.data, segment.pos, segment.pos + i); segment.pos += i; commonReadUtf8.setSize$okio(commonReadUtf8.size() - j); if (segment.pos == segment.limit) { commonReadUtf8.head = segment.pop(); SegmentPool.INSTANCE.recycle(segment); } return commonToUtf8String; } public static final String commonReadUtf8Line(Buffer commonReadUtf8Line) { Intrinsics.checkParameterIsNotNull(commonReadUtf8Line, "$this$commonReadUtf8Line"); long indexOf = commonReadUtf8Line.indexOf((byte) 10); if (indexOf != -1) { return readUtf8Line(commonReadUtf8Line, indexOf); } if (commonReadUtf8Line.size() != 0) { return commonReadUtf8Line.readUtf8(commonReadUtf8Line.size()); } return null; } public static final String commonReadUtf8LineStrict(Buffer commonReadUtf8LineStrict, long j) { Intrinsics.checkParameterIsNotNull(commonReadUtf8LineStrict, "$this$commonReadUtf8LineStrict"); if (!(j >= 0)) { throw new IllegalArgumentException(("limit < 0: " + j).toString()); } long j2 = LongCompanionObject.MAX_VALUE; if (j != LongCompanionObject.MAX_VALUE) { j2 = j + 1; } byte b = (byte) 10; long indexOf = commonReadUtf8LineStrict.indexOf(b, 0L, j2); if (indexOf != -1) { return readUtf8Line(commonReadUtf8LineStrict, indexOf); } if (j2 < commonReadUtf8LineStrict.size() && commonReadUtf8LineStrict.getByte(j2 - 1) == ((byte) 13) && commonReadUtf8LineStrict.getByte(j2) == b) { return readUtf8Line(commonReadUtf8LineStrict, j2); } Buffer buffer = new Buffer(); commonReadUtf8LineStrict.copyTo(buffer, 0L, Math.min(32, commonReadUtf8LineStrict.size())); throw new EOFException("\\n not found: limit=" + Math.min(commonReadUtf8LineStrict.size(), j) + " content=" + buffer.readByteString().hex() + Typography.ellipsis); } public static final int commonReadUtf8CodePoint(Buffer commonReadUtf8CodePoint) { int i; int i2; int i3; Intrinsics.checkParameterIsNotNull(commonReadUtf8CodePoint, "$this$commonReadUtf8CodePoint"); if (commonReadUtf8CodePoint.size() == 0) { throw new EOFException(); } byte b = commonReadUtf8CodePoint.getByte(0L); if ((b & ByteCompanionObject.MIN_VALUE) == 0) { i = b & ByteCompanionObject.MAX_VALUE; i3 = 0; i2 = 1; } else if ((b & 224) == 192) { i = b & 31; i2 = 2; i3 = 128; } else if ((b & 240) == 224) { i = b & 15; i2 = 3; i3 = 2048; } else { if ((b & 248) != 240) { commonReadUtf8CodePoint.skip(1L); return Utf8.REPLACEMENT_CODE_POINT; } i = b & 7; i2 = 4; i3 = 65536; } long j = i2; if (commonReadUtf8CodePoint.size() < j) { throw new EOFException("size < " + i2 + ": " + commonReadUtf8CodePoint.size() + " (to read code point prefixed 0x" + Util.toHexString(b) + ')'); } for (int i4 = 1; i4 < i2; i4++) { long j2 = i4; byte b2 = commonReadUtf8CodePoint.getByte(j2); if ((b2 & 192) != 128) { commonReadUtf8CodePoint.skip(j2); return Utf8.REPLACEMENT_CODE_POINT; } i = (i << 6) | (b2 & Utf8.REPLACEMENT_BYTE); } commonReadUtf8CodePoint.skip(j); return i > 1114111 ? Utf8.REPLACEMENT_CODE_POINT : ((55296 <= i && 57343 >= i) || i < i3) ? Utf8.REPLACEMENT_CODE_POINT : i; } public static final Buffer commonWriteUtf8(Buffer commonWriteUtf8, String string, int i, int i2) { int i3; Intrinsics.checkParameterIsNotNull(commonWriteUtf8, "$this$commonWriteUtf8"); Intrinsics.checkParameterIsNotNull(string, "string"); if (!(i >= 0)) { throw new IllegalArgumentException(("beginIndex < 0: " + i).toString()); } if (!(i2 >= i)) { throw new IllegalArgumentException(("endIndex < beginIndex: " + i2 + " < " + i).toString()); } if (!(i2 <= string.length())) { throw new IllegalArgumentException(("endIndex > string.length: " + i2 + " > " + string.length()).toString()); } while (i < i2) { char charAt = string.charAt(i); if (charAt < 128) { Segment writableSegment$okio = commonWriteUtf8.writableSegment$okio(1); byte[] bArr = writableSegment$okio.data; int i4 = writableSegment$okio.limit - i; int min = Math.min(i2, 8192 - i4); i3 = i + 1; bArr[i + i4] = (byte) charAt; while (i3 < min) { char charAt2 = string.charAt(i3); if (charAt2 >= 128) { break; } bArr[i3 + i4] = (byte) charAt2; i3++; } int i5 = (i4 + i3) - writableSegment$okio.limit; writableSegment$okio.limit += i5; commonWriteUtf8.setSize$okio(commonWriteUtf8.size() + i5); } else { if (charAt < 2048) { Segment writableSegment$okio2 = commonWriteUtf8.writableSegment$okio(2); writableSegment$okio2.data[writableSegment$okio2.limit] = (byte) ((charAt >> 6) | 192); writableSegment$okio2.data[writableSegment$okio2.limit + 1] = (byte) ((charAt & '?') | 128); writableSegment$okio2.limit += 2; commonWriteUtf8.setSize$okio(commonWriteUtf8.size() + 2); } else if (charAt < 55296 || charAt > 57343) { Segment writableSegment$okio3 = commonWriteUtf8.writableSegment$okio(3); writableSegment$okio3.data[writableSegment$okio3.limit] = (byte) ((charAt >> '\f') | 224); writableSegment$okio3.data[writableSegment$okio3.limit + 1] = (byte) ((63 & (charAt >> 6)) | 128); writableSegment$okio3.data[writableSegment$okio3.limit + 2] = (byte) ((charAt & '?') | 128); writableSegment$okio3.limit += 3; commonWriteUtf8.setSize$okio(commonWriteUtf8.size() + 3); } else { i3 = i + 1; char charAt3 = i3 < i2 ? string.charAt(i3) : (char) 0; if (charAt > 56319 || 56320 > charAt3 || 57343 < charAt3) { commonWriteUtf8.writeByte(63); } else { int i6 = (((charAt & 1023) << 10) | (charAt3 & 1023)) + 65536; Segment writableSegment$okio4 = commonWriteUtf8.writableSegment$okio(4); writableSegment$okio4.data[writableSegment$okio4.limit] = (byte) ((i6 >> 18) | 240); writableSegment$okio4.data[writableSegment$okio4.limit + 1] = (byte) (((i6 >> 12) & 63) | 128); writableSegment$okio4.data[writableSegment$okio4.limit + 2] = (byte) (((i6 >> 6) & 63) | 128); writableSegment$okio4.data[writableSegment$okio4.limit + 3] = (byte) ((i6 & 63) | 128); writableSegment$okio4.limit += 4; commonWriteUtf8.setSize$okio(commonWriteUtf8.size() + 4); i += 2; } } i++; } i = i3; } return commonWriteUtf8; } public static final Buffer commonWriteUtf8CodePoint(Buffer commonWriteUtf8CodePoint, int i) { Intrinsics.checkParameterIsNotNull(commonWriteUtf8CodePoint, "$this$commonWriteUtf8CodePoint"); if (i < 128) { commonWriteUtf8CodePoint.writeByte(i); } else if (i < 2048) { Segment writableSegment$okio = commonWriteUtf8CodePoint.writableSegment$okio(2); writableSegment$okio.data[writableSegment$okio.limit] = (byte) ((i >> 6) | 192); writableSegment$okio.data[writableSegment$okio.limit + 1] = (byte) ((i & 63) | 128); writableSegment$okio.limit += 2; commonWriteUtf8CodePoint.setSize$okio(commonWriteUtf8CodePoint.size() + 2); } else if (55296 <= i && 57343 >= i) { commonWriteUtf8CodePoint.writeByte(63); } else if (i < 65536) { Segment writableSegment$okio2 = commonWriteUtf8CodePoint.writableSegment$okio(3); writableSegment$okio2.data[writableSegment$okio2.limit] = (byte) ((i >> 12) | 224); writableSegment$okio2.data[writableSegment$okio2.limit + 1] = (byte) (((i >> 6) & 63) | 128); writableSegment$okio2.data[writableSegment$okio2.limit + 2] = (byte) ((i & 63) | 128); writableSegment$okio2.limit += 3; commonWriteUtf8CodePoint.setSize$okio(commonWriteUtf8CodePoint.size() + 3); } else if (i <= 1114111) { Segment writableSegment$okio3 = commonWriteUtf8CodePoint.writableSegment$okio(4); writableSegment$okio3.data[writableSegment$okio3.limit] = (byte) ((i >> 18) | 240); writableSegment$okio3.data[writableSegment$okio3.limit + 1] = (byte) (((i >> 12) & 63) | 128); writableSegment$okio3.data[writableSegment$okio3.limit + 2] = (byte) (((i >> 6) & 63) | 128); writableSegment$okio3.data[writableSegment$okio3.limit + 3] = (byte) ((i & 63) | 128); writableSegment$okio3.limit += 4; commonWriteUtf8CodePoint.setSize$okio(commonWriteUtf8CodePoint.size() + 4); } else { throw new IllegalArgumentException("Unexpected code point: 0x" + Util.toHexString(i)); } return commonWriteUtf8CodePoint; } public static final long commonWriteAll(Buffer commonWriteAll, Source source) { Intrinsics.checkParameterIsNotNull(commonWriteAll, "$this$commonWriteAll"); Intrinsics.checkParameterIsNotNull(source, "source"); long j = 0; while (true) { long read = source.read(commonWriteAll, 8192); if (read == -1) { return j; } j += read; } } public static final Buffer commonWrite(Buffer commonWrite, Source source, long j) { Intrinsics.checkParameterIsNotNull(commonWrite, "$this$commonWrite"); Intrinsics.checkParameterIsNotNull(source, "source"); while (j > 0) { long read = source.read(commonWrite, j); if (read == -1) { throw new EOFException(); } j -= read; } return commonWrite; } public static final Buffer commonWriteByte(Buffer commonWriteByte, int i) { Intrinsics.checkParameterIsNotNull(commonWriteByte, "$this$commonWriteByte"); Segment writableSegment$okio = commonWriteByte.writableSegment$okio(1); byte[] bArr = writableSegment$okio.data; int i2 = writableSegment$okio.limit; writableSegment$okio.limit = i2 + 1; bArr[i2] = (byte) i; commonWriteByte.setSize$okio(commonWriteByte.size() + 1); return commonWriteByte; } public static final Buffer commonWriteShort(Buffer commonWriteShort, int i) { Intrinsics.checkParameterIsNotNull(commonWriteShort, "$this$commonWriteShort"); Segment writableSegment$okio = commonWriteShort.writableSegment$okio(2); byte[] bArr = writableSegment$okio.data; int i2 = writableSegment$okio.limit; bArr[i2] = (byte) ((i >>> 8) & 255); bArr[i2 + 1] = (byte) (i & 255); writableSegment$okio.limit = i2 + 2; commonWriteShort.setSize$okio(commonWriteShort.size() + 2); return commonWriteShort; } public static final Buffer commonWriteInt(Buffer commonWriteInt, int i) { Intrinsics.checkParameterIsNotNull(commonWriteInt, "$this$commonWriteInt"); Segment writableSegment$okio = commonWriteInt.writableSegment$okio(4); byte[] bArr = writableSegment$okio.data; int i2 = writableSegment$okio.limit; bArr[i2] = (byte) ((i >>> 24) & 255); bArr[i2 + 1] = (byte) ((i >>> 16) & 255); bArr[i2 + 2] = (byte) ((i >>> 8) & 255); bArr[i2 + 3] = (byte) (i & 255); writableSegment$okio.limit = i2 + 4; commonWriteInt.setSize$okio(commonWriteInt.size() + 4); return commonWriteInt; } public static final Buffer commonWriteLong(Buffer commonWriteLong, long j) { Intrinsics.checkParameterIsNotNull(commonWriteLong, "$this$commonWriteLong"); Segment writableSegment$okio = commonWriteLong.writableSegment$okio(8); byte[] bArr = writableSegment$okio.data; int i = writableSegment$okio.limit; bArr[i] = (byte) ((j >>> 56) & 255); bArr[i + 1] = (byte) ((j >>> 48) & 255); bArr[i + 2] = (byte) ((j >>> 40) & 255); bArr[i + 3] = (byte) ((j >>> 32) & 255); bArr[i + 4] = (byte) ((j >>> 24) & 255); bArr[i + 5] = (byte) ((j >>> 16) & 255); bArr[i + 6] = (byte) ((j >>> 8) & 255); bArr[i + 7] = (byte) (j & 255); writableSegment$okio.limit = i + 8; commonWriteLong.setSize$okio(commonWriteLong.size() + 8); return commonWriteLong; } public static final void commonWrite(Buffer commonWrite, Buffer source, long j) { Segment segment; Intrinsics.checkParameterIsNotNull(commonWrite, "$this$commonWrite"); Intrinsics.checkParameterIsNotNull(source, "source"); if (!(source != commonWrite)) { throw new IllegalArgumentException("source == this".toString()); } Util.checkOffsetAndCount(source.size(), 0L, j); while (j > 0) { Segment segment2 = source.head; if (segment2 == null) { Intrinsics.throwNpe(); } int i = segment2.limit; if (source.head == null) { Intrinsics.throwNpe(); } if (j < i - r2.pos) { if (commonWrite.head != null) { Segment segment3 = commonWrite.head; if (segment3 == null) { Intrinsics.throwNpe(); } segment = segment3.prev; } else { segment = null; } if (segment != null && segment.owner) { if ((segment.limit + j) - (segment.shared ? 0 : segment.pos) <= 8192) { Segment segment4 = source.head; if (segment4 == null) { Intrinsics.throwNpe(); } segment4.writeTo(segment, (int) j); source.setSize$okio(source.size() - j); commonWrite.setSize$okio(commonWrite.size() + j); return; } } Segment segment5 = source.head; if (segment5 == null) { Intrinsics.throwNpe(); } source.head = segment5.split((int) j); } Segment segment6 = source.head; if (segment6 == null) { Intrinsics.throwNpe(); } long j2 = segment6.limit - segment6.pos; source.head = segment6.pop(); if (commonWrite.head == null) { commonWrite.head = segment6; segment6.prev = segment6; segment6.next = segment6.prev; } else { Segment segment7 = commonWrite.head; if (segment7 == null) { Intrinsics.throwNpe(); } Segment segment8 = segment7.prev; if (segment8 == null) { Intrinsics.throwNpe(); } segment8.push(segment6).compact(); } source.setSize$okio(source.size() - j2); commonWrite.setSize$okio(commonWrite.size() + j2); j -= j2; } } public static final long commonRead(Buffer commonRead, Buffer sink, long j) { Intrinsics.checkParameterIsNotNull(commonRead, "$this$commonRead"); Intrinsics.checkParameterIsNotNull(sink, "sink"); if (!(j >= 0)) { throw new IllegalArgumentException(("byteCount < 0: " + j).toString()); } if (commonRead.size() == 0) { return -1L; } if (j > commonRead.size()) { j = commonRead.size(); } sink.write(commonRead, j); return j; } public static final long commonIndexOf(Buffer commonIndexOf, byte b, long j, long j2) { int i; Intrinsics.checkParameterIsNotNull(commonIndexOf, "$this$commonIndexOf"); long j3 = 0; if (!(0 <= j && j2 >= j)) { throw new IllegalArgumentException(("size=" + commonIndexOf.size() + " fromIndex=" + j + " toIndex=" + j2).toString()); } if (j2 > commonIndexOf.size()) { j2 = commonIndexOf.size(); } if (j == j2) { return -1L; } Segment segment = commonIndexOf.head; if (segment != null) { if (commonIndexOf.size() - j < j) { j3 = commonIndexOf.size(); while (j3 > j) { segment = segment.prev; if (segment == null) { Intrinsics.throwNpe(); } j3 -= segment.limit - segment.pos; } if (segment != null) { while (j3 < j2) { byte[] bArr = segment.data; int min = (int) Math.min(segment.limit, (segment.pos + j2) - j3); i = (int) ((segment.pos + j) - j3); while (i < min) { if (bArr[i] != b) { i++; } } j3 += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j = j3; } } return -1L; } while (true) { long j4 = (segment.limit - segment.pos) + j3; if (j4 > j) { break; } segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j3 = j4; } if (segment != null) { while (j3 < j2) { byte[] bArr2 = segment.data; int min2 = (int) Math.min(segment.limit, (segment.pos + j2) - j3); i = (int) ((segment.pos + j) - j3); while (i < min2) { if (bArr2[i] != b) { i++; } } j3 += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j = j3; } } return -1L; return (i - segment.pos) + j3; } return -1L; } public static final long commonIndexOf(Buffer commonIndexOf, ByteString bytes, long j) { long j2 = j; Intrinsics.checkParameterIsNotNull(commonIndexOf, "$this$commonIndexOf"); Intrinsics.checkParameterIsNotNull(bytes, "bytes"); boolean z = true; if (!(bytes.size() > 0)) { throw new IllegalArgumentException("bytes is empty".toString()); } long j3 = 0; if (!(j2 >= 0)) { throw new IllegalArgumentException(("fromIndex < 0: " + j2).toString()); } Segment segment = commonIndexOf.head; if (segment == null) { return -1L; } if (commonIndexOf.size() - j2 < j2) { long size = commonIndexOf.size(); while (size > j2) { segment = segment.prev; if (segment == null) { Intrinsics.throwNpe(); } size -= segment.limit - segment.pos; } if (segment == null) { return -1L; } byte[] internalArray$okio = bytes.internalArray$okio(); byte b = internalArray$okio[0]; int size2 = bytes.size(); long size3 = (commonIndexOf.size() - size2) + 1; while (size < size3) { byte[] bArr = segment.data; int min = (int) Math.min(segment.limit, (segment.pos + size3) - size); for (int i = (int) ((segment.pos + j2) - size); i < min; i++) { if (bArr[i] == b && rangeEquals(segment, i + 1, internalArray$okio, 1, size2)) { return (i - segment.pos) + size; } } size += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j2 = size; } return -1L; } while (true) { long j4 = (segment.limit - segment.pos) + j3; if (j4 > j2) { break; } boolean z2 = z; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j3 = j4; z = z2; } if (segment == null) { return -1L; } byte[] internalArray$okio2 = bytes.internalArray$okio(); byte b2 = internalArray$okio2[0]; int size4 = bytes.size(); long size5 = (commonIndexOf.size() - size4) + 1; while (j3 < size5) { byte[] bArr2 = segment.data; long j5 = j3; int min2 = (int) Math.min(segment.limit, (segment.pos + size5) - j3); for (int i2 = (int) ((segment.pos + j2) - j5); i2 < min2; i2++) { if (bArr2[i2] == b2 && rangeEquals(segment, i2 + 1, internalArray$okio2, 1, size4)) { return (i2 - segment.pos) + j5; } } j3 = j5 + (segment.limit - segment.pos); segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j2 = j3; } return -1L; } public static final boolean commonRangeEquals(Buffer commonRangeEquals, long j, ByteString bytes, int i, int i2) { Intrinsics.checkParameterIsNotNull(commonRangeEquals, "$this$commonRangeEquals"); Intrinsics.checkParameterIsNotNull(bytes, "bytes"); if (j < 0 || i < 0 || i2 < 0 || commonRangeEquals.size() - j < i2 || bytes.size() - i < i2) { return false; } for (int i3 = 0; i3 < i2; i3++) { if (commonRangeEquals.getByte(i3 + j) != bytes.getByte(i + i3)) { return false; } } return true; } public static final boolean commonEquals(Buffer commonEquals, Object obj) { Intrinsics.checkParameterIsNotNull(commonEquals, "$this$commonEquals"); if (commonEquals == obj) { return true; } if (!(obj instanceof Buffer)) { return false; } Buffer buffer = (Buffer) obj; if (commonEquals.size() != buffer.size()) { return false; } if (commonEquals.size() == 0) { return true; } Segment segment = commonEquals.head; if (segment == null) { Intrinsics.throwNpe(); } Segment segment2 = buffer.head; if (segment2 == null) { Intrinsics.throwNpe(); } int i = segment.pos; int i2 = segment2.pos; long j = 0; while (j < commonEquals.size()) { long min = Math.min(segment.limit - i, segment2.limit - i2); long j2 = 0; while (j2 < min) { int i3 = i + 1; int i4 = i2 + 1; if (segment.data[i] != segment2.data[i2]) { return false; } j2++; i = i3; i2 = i4; } if (i == segment.limit) { segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } i = segment.pos; } if (i2 == segment2.limit) { segment2 = segment2.next; if (segment2 == null) { Intrinsics.throwNpe(); } i2 = segment2.pos; } j += min; } return true; } public static final int commonHashCode(Buffer commonHashCode) { Intrinsics.checkParameterIsNotNull(commonHashCode, "$this$commonHashCode"); Segment segment = commonHashCode.head; if (segment == null) { return 0; } int i = 1; do { int i2 = segment.limit; for (int i3 = segment.pos; i3 < i2; i3++) { i = (i * 31) + segment.data[i3]; } segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } } while (segment != commonHashCode.head); return i; } public static final Buffer commonCopy(Buffer commonCopy) { Intrinsics.checkParameterIsNotNull(commonCopy, "$this$commonCopy"); Buffer buffer = new Buffer(); if (commonCopy.size() == 0) { return buffer; } Segment segment = commonCopy.head; if (segment == null) { Intrinsics.throwNpe(); } Segment sharedCopy = segment.sharedCopy(); buffer.head = sharedCopy; sharedCopy.prev = buffer.head; sharedCopy.next = sharedCopy.prev; for (Segment segment2 = segment.next; segment2 != segment; segment2 = segment2.next) { Segment segment3 = sharedCopy.prev; if (segment3 == null) { Intrinsics.throwNpe(); } if (segment2 == null) { Intrinsics.throwNpe(); } segment3.push(segment2.sharedCopy()); } buffer.setSize$okio(commonCopy.size()); return buffer; } public static final ByteString commonSnapshot(Buffer commonSnapshot) { Intrinsics.checkParameterIsNotNull(commonSnapshot, "$this$commonSnapshot"); if (!(commonSnapshot.size() <= ((long) Integer.MAX_VALUE))) { throw new IllegalStateException(("size > Int.MAX_VALUE: " + commonSnapshot.size()).toString()); } return commonSnapshot.snapshot((int) commonSnapshot.size()); } public static final ByteString commonSnapshot(Buffer commonSnapshot, int i) { Intrinsics.checkParameterIsNotNull(commonSnapshot, "$this$commonSnapshot"); if (i == 0) { return ByteString.EMPTY; } Util.checkOffsetAndCount(commonSnapshot.size(), 0L, i); Segment segment = commonSnapshot.head; int i2 = 0; int i3 = 0; int i4 = 0; while (i3 < i) { if (segment == null) { Intrinsics.throwNpe(); } if (segment.limit == segment.pos) { throw new AssertionError("s.limit == s.pos"); } i3 += segment.limit - segment.pos; i4++; segment = segment.next; } byte[][] bArr = new byte[i4]; int[] iArr = new int[i4 * 2]; Segment segment2 = commonSnapshot.head; int i5 = 0; while (i2 < i) { if (segment2 == null) { Intrinsics.throwNpe(); } bArr[i5] = segment2.data; i2 += segment2.limit - segment2.pos; iArr[i5] = Math.min(i2, i); iArr[bArr.length + i5] = segment2.pos; segment2.shared = true; i5++; segment2 = segment2.next; } return new SegmentedByteString(bArr, iArr); } public static final long commonIndexOfElement(Buffer commonIndexOfElement, ByteString targetBytes, long j) { int i; int i2; Intrinsics.checkParameterIsNotNull(commonIndexOfElement, "$this$commonIndexOfElement"); Intrinsics.checkParameterIsNotNull(targetBytes, "targetBytes"); long j2 = 0; if (!(j >= 0)) { throw new IllegalArgumentException(("fromIndex < 0: " + j).toString()); } Segment segment = commonIndexOfElement.head; if (segment == null) { return -1L; } if (commonIndexOfElement.size() - j < j) { j2 = commonIndexOfElement.size(); while (j2 > j) { segment = segment.prev; if (segment == null) { Intrinsics.throwNpe(); } j2 -= segment.limit - segment.pos; } if (segment != null) { if (targetBytes.size() == 2) { byte b = targetBytes.getByte(0); byte b2 = targetBytes.getByte(1); while (j2 < commonIndexOfElement.size()) { byte[] bArr = segment.data; i = (int) ((segment.pos + j) - j2); int i3 = segment.limit; while (i < i3) { byte b3 = bArr[i]; if (b3 != b && b3 != b2) { i++; } i2 = segment.pos; } j2 += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j = j2; } } else { byte[] internalArray$okio = targetBytes.internalArray$okio(); while (j2 < commonIndexOfElement.size()) { byte[] bArr2 = segment.data; i = (int) ((segment.pos + j) - j2); int i4 = segment.limit; while (i < i4) { byte b4 = bArr2[i]; for (byte b5 : internalArray$okio) { if (b4 == b5) { i2 = segment.pos; } } i++; } j2 += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j = j2; } } } return -1L; } while (true) { long j3 = (segment.limit - segment.pos) + j2; if (j3 > j) { break; } segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j2 = j3; } if (segment != null) { if (targetBytes.size() == 2) { byte b6 = targetBytes.getByte(0); byte b7 = targetBytes.getByte(1); while (j2 < commonIndexOfElement.size()) { byte[] bArr3 = segment.data; i = (int) ((segment.pos + j) - j2); int i5 = segment.limit; while (i < i5) { byte b8 = bArr3[i]; if (b8 != b6 && b8 != b7) { i++; } i2 = segment.pos; } j2 += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j = j2; } } else { byte[] internalArray$okio2 = targetBytes.internalArray$okio(); while (j2 < commonIndexOfElement.size()) { byte[] bArr4 = segment.data; i = (int) ((segment.pos + j) - j2); int i6 = segment.limit; while (i < i6) { byte b9 = bArr4[i]; for (byte b10 : internalArray$okio2) { if (b9 == b10) { i2 = segment.pos; } } i++; } j2 += segment.limit - segment.pos; segment = segment.next; if (segment == null) { Intrinsics.throwNpe(); } j = j2; } } } return -1L; return (i - i2) + j2; } }