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.InputStream; import java.nio.ByteBuffer; import java.nio.channels.ByteChannel; import java.nio.charset.Charset; import kotlin.Metadata; import kotlin.collections.j; import kotlin.jvm.internal.o; import kotlin.text.Charsets; import okio.b0.b; /* JADX INFO: renamed from: z.d, reason: from Kotlin metadata */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000ª\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u001a\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\u0005\n\u0002\u0010\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\u0000\n\u0002\b\u0003\n\u0002\u0010\u0005\n\u0002\b\u0005\n\u0002\u0010\b\n\u0002\b\r\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\u0010\u0012\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0010\n\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0017\u0018\u00002\u00020\u00012\u00020\u00022\u00020\u00032\u00020\u0004:\u0002\u0090\u0001B\u0005¢\u0006\u0002\u0010\u0005J\b\u0010\u0006\u001a\u00020\u0000H\u0016J\u0006\u0010\u0011\u001a\u00020\u0012J\b\u0010\u0013\u001a\u00020\u0000H\u0016J\b\u0010\u0014\u001a\u00020\u0012H\u0016J\u0006\u0010\u0015\u001a\u00020\fJ\u0006\u0010\u0016\u001a\u00020\u0000J$\u0010\u0017\u001a\u00020\u00002\u0006\u0010\u0018\u001a\u00020\u00192\b\b\u0002\u0010\u001a\u001a\u00020\f2\b\b\u0002\u0010\u001b\u001a\u00020\fH\u0007J\u0018\u0010\u0017\u001a\u00020\u00002\u0006\u0010\u0018\u001a\u00020\u00002\b\b\u0002\u0010\u001a\u001a\u00020\fJ \u0010\u0017\u001a\u00020\u00002\u0006\u0010\u0018\u001a\u00020\u00002\b\b\u0002\u0010\u001a\u001a\u00020\f2\u0006\u0010\u001b\u001a\u00020\fJ\u0010\u0010\u001c\u001a\u00020\u001d2\u0006\u0010\u001e\u001a\u00020\u001fH\u0002J\b\u0010 \u001a\u00020\u0000H\u0016J\b\u0010!\u001a\u00020\u0000H\u0016J\u0013\u0010\"\u001a\u00020#2\b\u0010$\u001a\u0004\u0018\u00010%H\u0096\u0002J\b\u0010&\u001a\u00020#H\u0016J\b\u0010'\u001a\u00020\u0012H\u0016J\u0016\u0010(\u001a\u00020)2\u0006\u0010*\u001a\u00020\fH\u0087\u0002¢\u0006\u0002\b+J\u0015\u0010+\u001a\u00020)2\u0006\u0010,\u001a\u00020\fH\u0007¢\u0006\u0002\b-J\b\u0010.\u001a\u00020/H\u0016J\u0018\u00100\u001a\u00020\u001d2\u0006\u0010\u001e\u001a\u00020\u001f2\u0006\u00101\u001a\u00020\u001dH\u0002J\u000e\u00102\u001a\u00020\u001d2\u0006\u00101\u001a\u00020\u001dJ\u000e\u00103\u001a\u00020\u001d2\u0006\u00101\u001a\u00020\u001dJ\u000e\u00104\u001a\u00020\u001d2\u0006\u00101\u001a\u00020\u001dJ\u0010\u00105\u001a\u00020\f2\u0006\u00106\u001a\u00020)H\u0016J\u0018\u00105\u001a\u00020\f2\u0006\u00106\u001a\u00020)2\u0006\u00107\u001a\u00020\fH\u0016J \u00105\u001a\u00020\f2\u0006\u00106\u001a\u00020)2\u0006\u00107\u001a\u00020\f2\u0006\u00108\u001a\u00020\fH\u0016J\u0010\u00105\u001a\u00020\f2\u0006\u00109\u001a\u00020\u001dH\u0016J\u0018\u00105\u001a\u00020\f2\u0006\u00109\u001a\u00020\u001d2\u0006\u00107\u001a\u00020\fH\u0016J\u0010\u0010:\u001a\u00020\f2\u0006\u0010;\u001a\u00020\u001dH\u0016J\u0018\u0010:\u001a\u00020\f2\u0006\u0010;\u001a\u00020\u001d2\u0006\u00107\u001a\u00020\fH\u0016J\b\u0010<\u001a\u00020=H\u0016J\b\u0010>\u001a\u00020#H\u0016J\u0006\u0010?\u001a\u00020\u001dJ\b\u0010@\u001a\u00020\u0019H\u0016J\b\u0010A\u001a\u00020\u0001H\u0016J\u0018\u0010B\u001a\u00020#2\u0006\u0010\u001a\u001a\u00020\f2\u0006\u00109\u001a\u00020\u001dH\u0016J(\u0010B\u001a\u00020#2\u0006\u0010\u001a\u001a\u00020\f2\u0006\u00109\u001a\u00020\u001d2\u0006\u0010C\u001a\u00020/2\u0006\u0010\u001b\u001a\u00020/H\u0016J\u0010\u0010D\u001a\u00020/2\u0006\u0010E\u001a\u00020FH\u0016J\u0010\u0010D\u001a\u00020/2\u0006\u0010E\u001a\u00020GH\u0016J \u0010D\u001a\u00020/2\u0006\u0010E\u001a\u00020G2\u0006\u0010\u001a\u001a\u00020/2\u0006\u0010\u001b\u001a\u00020/H\u0016J\u0018\u0010D\u001a\u00020\f2\u0006\u0010E\u001a\u00020\u00002\u0006\u0010\u001b\u001a\u00020\fH\u0016J\u0010\u0010H\u001a\u00020\f2\u0006\u0010E\u001a\u00020IH\u0016J\u0012\u0010J\u001a\u00020K2\b\b\u0002\u0010L\u001a\u00020KH\u0007J\b\u0010M\u001a\u00020)H\u0016J\b\u0010N\u001a\u00020GH\u0016J\u0010\u0010N\u001a\u00020G2\u0006\u0010\u001b\u001a\u00020\fH\u0016J\b\u0010O\u001a\u00020\u001dH\u0016J\u0010\u0010O\u001a\u00020\u001d2\u0006\u0010\u001b\u001a\u00020\fH\u0016J\b\u0010P\u001a\u00020\fH\u0016J\u000e\u0010Q\u001a\u00020\u00002\u0006\u0010R\u001a\u00020=J\u0016\u0010Q\u001a\u00020\u00002\u0006\u0010R\u001a\u00020=2\u0006\u0010\u001b\u001a\u00020\fJ \u0010Q\u001a\u00020\u00122\u0006\u0010R\u001a\u00020=2\u0006\u0010\u001b\u001a\u00020\f2\u0006\u0010S\u001a\u00020#H\u0002J\u0010\u0010T\u001a\u00020\u00122\u0006\u0010E\u001a\u00020GH\u0016J\u0018\u0010T\u001a\u00020\u00122\u0006\u0010E\u001a\u00020\u00002\u0006\u0010\u001b\u001a\u00020\fH\u0016J\b\u0010U\u001a\u00020\fH\u0016J\b\u0010V\u001a\u00020/H\u0016J\b\u0010W\u001a\u00020/H\u0016J\b\u0010X\u001a\u00020\fH\u0016J\b\u0010Y\u001a\u00020\fH\u0016J\b\u0010Z\u001a\u00020[H\u0016J\b\u0010\\\u001a\u00020[H\u0016J\u0010\u0010]\u001a\u00020\u001f2\u0006\u0010^\u001a\u00020_H\u0016J\u0018\u0010]\u001a\u00020\u001f2\u0006\u0010\u001b\u001a\u00020\f2\u0006\u0010^\u001a\u00020_H\u0016J\u0012\u0010`\u001a\u00020K2\b\b\u0002\u0010L\u001a\u00020KH\u0007J\b\u0010a\u001a\u00020\u001fH\u0016J\u0010\u0010a\u001a\u00020\u001f2\u0006\u0010\u001b\u001a\u00020\fH\u0016J\b\u0010b\u001a\u00020/H\u0016J\n\u0010c\u001a\u0004\u0018\u00010\u001fH\u0016J\b\u0010d\u001a\u00020\u001fH\u0016J\u0010\u0010d\u001a\u00020\u001f2\u0006\u0010e\u001a\u00020\fH\u0016J\u0010\u0010f\u001a\u00020#2\u0006\u0010\u001b\u001a\u00020\fH\u0016J\u0010\u0010g\u001a\u00020\u00122\u0006\u0010\u001b\u001a\u00020\fH\u0016J\u0010\u0010h\u001a\u00020/2\u0006\u0010i\u001a\u00020jH\u0016J\u0006\u0010k\u001a\u00020\u001dJ\u0006\u0010l\u001a\u00020\u001dJ\u0006\u0010m\u001a\u00020\u001dJ\r\u0010\r\u001a\u00020\fH\u0007¢\u0006\u0002\bnJ\u0010\u0010o\u001a\u00020\u00122\u0006\u0010\u001b\u001a\u00020\fH\u0016J\u0006\u0010p\u001a\u00020\u001dJ\u000e\u0010p\u001a\u00020\u001d2\u0006\u0010\u001b\u001a\u00020/J\b\u0010q\u001a\u00020rH\u0016J\b\u0010s\u001a\u00020\u001fH\u0016J\u0015\u0010t\u001a\u00020\n2\u0006\u0010u\u001a\u00020/H\u0000¢\u0006\u0002\bvJ\u0010\u0010w\u001a\u00020/2\u0006\u0010x\u001a\u00020FH\u0016J\u0010\u0010w\u001a\u00020\u00002\u0006\u0010x\u001a\u00020GH\u0016J \u0010w\u001a\u00020\u00002\u0006\u0010x\u001a\u00020G2\u0006\u0010\u001a\u001a\u00020/2\u0006\u0010\u001b\u001a\u00020/H\u0016J\u0018\u0010w\u001a\u00020\u00122\u0006\u0010x\u001a\u00020\u00002\u0006\u0010\u001b\u001a\u00020\fH\u0016J\u0010\u0010w\u001a\u00020\u00002\u0006\u0010y\u001a\u00020\u001dH\u0016J \u0010w\u001a\u00020\u00002\u0006\u0010y\u001a\u00020\u001d2\u0006\u0010\u001a\u001a\u00020/2\u0006\u0010\u001b\u001a\u00020/H\u0016J\u0018\u0010w\u001a\u00020\u00002\u0006\u0010x\u001a\u00020z2\u0006\u0010\u001b\u001a\u00020\fH\u0016J\u0010\u0010{\u001a\u00020\f2\u0006\u0010x\u001a\u00020zH\u0016J\u0010\u0010|\u001a\u00020\u00002\u0006\u00106\u001a\u00020/H\u0016J\u0010\u0010}\u001a\u00020\u00002\u0006\u0010~\u001a\u00020\fH\u0016J\u0010\u0010\u007f\u001a\u00020\u00002\u0006\u0010~\u001a\u00020\fH\u0016J\u0012\u0010\u0080\u0001\u001a\u00020\u00002\u0007\u0010\u0081\u0001\u001a\u00020/H\u0016J\u0012\u0010\u0082\u0001\u001a\u00020\u00002\u0007\u0010\u0081\u0001\u001a\u00020/H\u0016J\u0011\u0010\u0083\u0001\u001a\u00020\u00002\u0006\u0010~\u001a\u00020\fH\u0016J\u0011\u0010\u0084\u0001\u001a\u00020\u00002\u0006\u0010~\u001a\u00020\fH\u0016J\u0012\u0010\u0085\u0001\u001a\u00020\u00002\u0007\u0010\u0086\u0001\u001a\u00020/H\u0016J\u0012\u0010\u0087\u0001\u001a\u00020\u00002\u0007\u0010\u0086\u0001\u001a\u00020/H\u0016J\u001a\u0010\u0088\u0001\u001a\u00020\u00002\u0007\u0010\u0089\u0001\u001a\u00020\u001f2\u0006\u0010^\u001a\u00020_H\u0016J,\u0010\u0088\u0001\u001a\u00020\u00002\u0007\u0010\u0089\u0001\u001a\u00020\u001f2\u0007\u0010\u008a\u0001\u001a\u00020/2\u0007\u0010\u008b\u0001\u001a\u00020/2\u0006\u0010^\u001a\u00020_H\u0016J\u001b\u0010\u008c\u0001\u001a\u00020\u00002\u0006\u0010\u0018\u001a\u00020\u00192\b\b\u0002\u0010\u001b\u001a\u00020\fH\u0007J\u0012\u0010\u008d\u0001\u001a\u00020\u00002\u0007\u0010\u0089\u0001\u001a\u00020\u001fH\u0016J$\u0010\u008d\u0001\u001a\u00020\u00002\u0007\u0010\u0089\u0001\u001a\u00020\u001f2\u0007\u0010\u008a\u0001\u001a\u00020/2\u0007\u0010\u008b\u0001\u001a\u00020/H\u0016J\u0012\u0010\u008e\u0001\u001a\u00020\u00002\u0007\u0010\u008f\u0001\u001a\u00020/H\u0016R\u0014\u0010\u0006\u001a\u00020\u00008VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b\u0007\u0010\bR\u0014\u0010\t\u001a\u0004\u0018\u00010\n8\u0000@\u0000X\u0081\u000e¢\u0006\u0002\n\u0000R&\u0010\r\u001a\u00020\f2\u0006\u0010\u000b\u001a\u00020\f8G@@X\u0086\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\r\u0010\u000e\"\u0004\b\u000f\u0010\u0010¨\u0006\u0091\u0001"}, d2 = {"Lokio/Buffer;", "Lokio/BufferedSource;", "Lokio/BufferedSink;", "", "Ljava/nio/channels/ByteChannel;", "()V", "buffer", "getBuffer", "()Lokio/Buffer;", "head", "Lokio/Segment;", "", "", "size", "()J", "setSize$okio", "(J)V", "clear", "", "clone", "close", "completeSegmentByteCount", "copy", "copyTo", "out", "Ljava/io/OutputStream;", "offset", "byteCount", "digest", "Lokio/ByteString;", "algorithm", "", "emit", "emitCompleteSegments", "equals", "", "other", "", "exhausted", "flush", "get", "", "pos", "getByte", "index", "-deprecated_getByte", "hashCode", "", "hmac", "key", "hmacSha1", "hmacSha256", "hmacSha512", "indexOf", "b", "fromIndex", "toIndex", "bytes", "indexOfElement", "targetBytes", "inputStream", "Ljava/io/InputStream;", "isOpen", "md5", "outputStream", "peek", "rangeEquals", "bytesOffset", "read", "sink", "Ljava/nio/ByteBuffer;", "", "readAll", "Lokio/Sink;", "readAndWriteUnsafe", "Lokio/Buffer$UnsafeCursor;", "unsafeCursor", "readByte", "readByteArray", "readByteString", "readDecimalLong", "readFrom", "input", "forever", "readFully", "readHexadecimalUnsignedLong", "readInt", "readIntLe", "readLong", "readLongLe", "readShort", "", "readShortLe", "readString", "charset", "Ljava/nio/charset/Charset;", "readUnsafe", "readUtf8", "readUtf8CodePoint", "readUtf8Line", "readUtf8LineStrict", "limit", "request", "require", "select", "options", "Lokio/Options;", "sha1", "sha256", "sha512", "-deprecated_size", "skip", "snapshot", RtspHeaders.Values.TIMEOUT, "Lokio/Timeout;", "toString", "writableSegment", "minimumCapacity", "writableSegment$okio", "write", "source", "byteString", "Lokio/Source;", "writeAll", "writeByte", "writeDecimalLong", "v", "writeHexadecimalUnsignedLong", "writeInt", "i", "writeIntLe", "writeLong", "writeLongLe", "writeShort", "s", "writeShortLe", "writeString", "string", "beginIndex", "endIndex", "writeTo", "writeUtf8", "writeUtf8CodePoint", "codePoint", "UnsafeCursor", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48) public final class Buffer implements BufferedSource, BufferedSink, Cloneable, ByteChannel { /* JADX INFO: renamed from: f, reason: collision with root package name */ public Segment f10117f; /* JADX INFO: renamed from: m, reason: collision with root package name */ public long f10118m; /* JADX INFO: renamed from: z.d$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/Buffer$inputStream$1", "Ljava/io/InputStream;", "available", "", "close", "", "read", "sink", "", "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() { return (int) Math.min(Buffer.this.f10118m, Integer.MAX_VALUE); } @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable public void close() { } @Override // java.io.InputStream public int read() { Buffer buffer = Buffer.this; if (buffer.f10118m > 0) { return buffer.readByte() & 255; } return -1; } @Override // java.io.InputStream public int read(byte[] sink, int offset, int byteCount) { o.f(sink, "sink"); return Buffer.this.read(sink, offset, byteCount); } public String toString() { return Buffer.this + ".inputStream()"; } } public Buffer A(byte[] bArr) { o.f(bArr, "source"); B(bArr, 0, bArr.length); return this; } public Buffer B(byte[] bArr, int i2, int i3) { o.f(bArr, "source"); long j2 = i3; a0.b(bArr.length, i2, j2); int i4 = i3 + i2; while (i2 < i4) { Segment segmentX = x(1); int iMin = Math.min(i4 - i2, 8192 - segmentX.f10152c); int i5 = i2 + iMin; j.g(bArr, segmentX.a, segmentX.f10152c, i2, i5); segmentX.f10152c += iMin; i2 = i5; } this.f10118m += j2; return this; } public Buffer C(int i2) { Segment segmentX = x(1); byte[] bArr = segmentX.a; int i3 = segmentX.f10152c; segmentX.f10152c = i3 + 1; bArr[i3] = (byte) i2; this.f10118m++; return this; } /* JADX WARN: Removed duplicated region for block: B:13:0x0027 */ /* JADX WARN: Removed duplicated region for block: B:35:0x006c */ /* JADX WARN: Removed duplicated region for block: B:67:0x00e5 */ /* JADX WARN: Removed duplicated region for block: B:71:0x00f4 A[LOOP:0: B:69:0x00f0->B:71:0x00f4, LOOP_END] */ /* JADX WARN: Removed duplicated region for block: B:73:0x0104 */ @Override // okio.BufferedSink /* JADX INFO: renamed from: D, reason: merged with bridge method [inline-methods] */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public okio.Buffer writeDecimalLong(long r13) { /* Method dump skipped, instruction units count: 279 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okio.Buffer.writeDecimalLong(long):z.d"); } @Override // okio.BufferedSink /* JADX INFO: renamed from: E, reason: merged with bridge method [inline-methods] */ public Buffer writeHexadecimalUnsignedLong(long j2) { if (j2 == 0) { C(48); } else { long j3 = (j2 >>> 1) | j2; long j4 = j3 | (j3 >>> 2); long j5 = j4 | (j4 >>> 4); long j6 = j5 | (j5 >>> 8); long j7 = j6 | (j6 >>> 16); long j8 = j7 | (j7 >>> 32); long j9 = j8 - ((j8 >>> 1) & 6148914691236517205L); long j10 = ((j9 >>> 2) & 3689348814741910323L) + (j9 & 3689348814741910323L); long j11 = ((j10 >>> 4) + j10) & 1085102592571150095L; long j12 = j11 + (j11 >>> 8); long j13 = j12 + (j12 >>> 16); int i2 = (int) ((((j13 & 63) + ((j13 >>> 32) & 63)) + ((long) 3)) / ((long) 4)); Segment segmentX = x(i2); byte[] bArr = segmentX.a; int i3 = segmentX.f10152c; for (int i4 = (i3 + i2) - 1; i4 >= i3; i4--) { bArr[i4] = okio.b0.a.a[(int) (15 & j2)]; j2 >>>= 4; } segmentX.f10152c += i2; this.f10118m += (long) i2; } return this; } public Buffer F(int i2) { Segment segmentX = x(4); byte[] bArr = segmentX.a; int i3 = segmentX.f10152c; int i4 = i3 + 1; bArr[i3] = (byte) ((i2 >>> 24) & DnsRecord.CLASS_ANY); int i5 = i4 + 1; bArr[i4] = (byte) ((i2 >>> 16) & DnsRecord.CLASS_ANY); int i6 = i5 + 1; bArr[i5] = (byte) ((i2 >>> 8) & DnsRecord.CLASS_ANY); bArr[i6] = (byte) (i2 & DnsRecord.CLASS_ANY); segmentX.f10152c = i6 + 1; this.f10118m += 4; return this; } public Buffer G(int i2) { Segment segmentX = x(2); byte[] bArr = segmentX.a; int i3 = segmentX.f10152c; int i4 = i3 + 1; bArr[i3] = (byte) ((i2 >>> 8) & DnsRecord.CLASS_ANY); bArr[i4] = (byte) (i2 & DnsRecord.CLASS_ANY); segmentX.f10152c = i4 + 1; this.f10118m += 2; return this; } public Buffer H(String str) { o.f(str, "string"); I(str, 0, str.length()); return this; } public Buffer I(String str, int i2, int i3) { char cCharAt; long j2; long j3; o.f(str, "string"); if (!(i2 >= 0)) { throw new IllegalArgumentException(g.a.a.a.a.l("beginIndex < 0: ", i2).toString()); } if (!(i3 >= i2)) { throw new IllegalArgumentException(g.a.a.a.a.o("endIndex < beginIndex: ", i3, " < ", i2).toString()); } if (!(i3 <= str.length())) { StringBuilder sbG = g.a.a.a.a.G("endIndex > string.length: ", i3, " > "); sbG.append(str.length()); throw new IllegalArgumentException(sbG.toString().toString()); } while (i2 < i3) { char cCharAt2 = str.charAt(i2); if (cCharAt2 < 128) { Segment segmentX = x(1); byte[] bArr = segmentX.a; int i4 = segmentX.f10152c - i2; int iMin = Math.min(i3, 8192 - i4); int i5 = i2 + 1; bArr[i2 + i4] = (byte) cCharAt2; while (true) { i2 = i5; if (i2 >= iMin || (cCharAt = str.charAt(i2)) >= 128) { break; } i5 = i2 + 1; bArr[i2 + i4] = (byte) cCharAt; } int i6 = segmentX.f10152c; int i7 = (i4 + i2) - i6; segmentX.f10152c = i6 + i7; this.f10118m += (long) i7; } else { if (cCharAt2 < 2048) { Segment segmentX2 = x(2); byte[] bArr2 = segmentX2.a; int i8 = segmentX2.f10152c; bArr2[i8] = (byte) ((cCharAt2 >> 6) | 192); bArr2[i8 + 1] = (byte) ((cCharAt2 & '?') | 128); segmentX2.f10152c = i8 + 2; j2 = this.f10118m; j3 = 2; } else if (cCharAt2 < 55296 || cCharAt2 > 57343) { Segment segmentX3 = x(3); byte[] bArr3 = segmentX3.a; int i9 = segmentX3.f10152c; bArr3[i9] = (byte) ((cCharAt2 >> '\f') | 224); bArr3[i9 + 1] = (byte) ((63 & (cCharAt2 >> 6)) | 128); bArr3[i9 + 2] = (byte) ((cCharAt2 & '?') | 128); segmentX3.f10152c = i9 + 3; j2 = this.f10118m; j3 = 3; } else { int i10 = i2 + 1; char cCharAt3 = i10 < i3 ? str.charAt(i10) : (char) 0; if (cCharAt2 <= 56319) { if (56320 <= cCharAt3 && cCharAt3 < 57344) { int i11 = (((cCharAt2 & 1023) << 10) | (cCharAt3 & 1023)) + 65536; Segment segmentX4 = x(4); byte[] bArr4 = segmentX4.a; int i12 = segmentX4.f10152c; bArr4[i12] = (byte) ((i11 >> 18) | 240); bArr4[i12 + 1] = (byte) (((i11 >> 12) & 63) | 128); bArr4[i12 + 2] = (byte) (((i11 >> 6) & 63) | 128); bArr4[i12 + 3] = (byte) ((i11 & 63) | 128); segmentX4.f10152c = i12 + 4; this.f10118m += 4; i2 += 2; } } C(63); i2 = i10; } this.f10118m = j2 + j3; i2++; } } return this; } public Buffer J(int i2) { String strA; long j2; long j3; if (i2 < 128) { C(i2); } else { if (i2 < 2048) { Segment segmentX = x(2); byte[] bArr = segmentX.a; int i3 = segmentX.f10152c; bArr[i3] = (byte) ((i2 >> 6) | 192); bArr[i3 + 1] = (byte) ((i2 & 63) | 128); segmentX.f10152c = i3 + 2; j2 = this.f10118m; j3 = 2; } else { int i4 = 0; if (55296 <= i2 && i2 < 57344) { C(63); } else if (i2 < 65536) { Segment segmentX2 = x(3); byte[] bArr2 = segmentX2.a; int i5 = segmentX2.f10152c; bArr2[i5] = (byte) ((i2 >> 12) | 224); bArr2[i5 + 1] = (byte) (((i2 >> 6) & 63) | 128); bArr2[i5 + 2] = (byte) ((i2 & 63) | 128); segmentX2.f10152c = i5 + 3; j2 = this.f10118m; j3 = 3; } else { if (i2 > 1114111) { StringBuilder sbF = g.a.a.a.a.F("Unexpected code point: 0x"); if (i2 != 0) { char[] cArr = b.a; char[] cArr2 = {cArr[(i2 >> 28) & 15], cArr[(i2 >> 24) & 15], cArr[(i2 >> 20) & 15], cArr[(i2 >> 16) & 15], cArr[(i2 >> 12) & 15], cArr[(i2 >> 8) & 15], cArr[(i2 >> 4) & 15], cArr[i2 & 15]}; while (i4 < 8 && cArr2[i4] == '0') { i4++; } strA = kotlin.text.j.a(cArr2, i4, 8); } else { strA = "0"; } sbF.append(strA); throw new IllegalArgumentException(sbF.toString()); } Segment segmentX3 = x(4); byte[] bArr3 = segmentX3.a; int i6 = segmentX3.f10152c; bArr3[i6] = (byte) ((i2 >> 18) | 240); bArr3[i6 + 1] = (byte) (((i2 >> 12) & 63) | 128); bArr3[i6 + 2] = (byte) (((i2 >> 6) & 63) | 128); bArr3[i6 + 3] = (byte) ((i2 & 63) | 128); segmentX3.f10152c = i6 + 4; j2 = this.f10118m; j3 = 4; } } this.f10118m = j2 + j3; } return this; } @Override // okio.BufferedSource public ByteString b(long j2) throws EOFException { if (!(j2 >= 0 && j2 <= 2147483647L)) { throw new IllegalArgumentException(g.a.a.a.a.q("byteCount: ", j2).toString()); } if (this.f10118m < j2) { throw new EOFException(); } if (j2 < 4096) { return new ByteString(p(j2)); } ByteString byteStringU = u((int) j2); skip(j2); return byteStringU; } @Override // okio.BufferedSink public Buffer buffer() { return this; } public final Buffer c(Buffer buffer, long j2, long j3) { o.f(buffer, "out"); a0.b(this.f10118m, j2, j3); if (j3 != 0) { buffer.f10118m += j3; Segment segment = this.f10117f; while (true) { o.c(segment); int i2 = segment.f10152c; int i3 = segment.f10151b; if (j2 < i2 - i3) { break; } j2 -= (long) (i2 - i3); segment = segment.f10155f; } while (j3 > 0) { o.c(segment); Segment segmentC = segment.c(); int i4 = segmentC.f10151b + ((int) j2); segmentC.f10151b = i4; segmentC.f10152c = Math.min(i4 + ((int) j3), segmentC.f10152c); Segment segment2 = buffer.f10117f; if (segment2 == null) { segmentC.f10156g = segmentC; segmentC.f10155f = segmentC; buffer.f10117f = segmentC; } else { o.c(segment2); Segment segment3 = segment2.f10156g; o.c(segment3); segment3.b(segmentC); } j3 -= (long) (segmentC.f10152c - segmentC.f10151b); segment = segment.f10155f; j2 = 0; } } return this; } public Object clone() { Buffer buffer = new Buffer(); if (this.f10118m != 0) { Segment segment = this.f10117f; o.c(segment); Segment segmentC = segment.c(); buffer.f10117f = segmentC; segmentC.f10156g = segmentC; segmentC.f10155f = segmentC; for (Segment segment2 = segment.f10155f; segment2 != segment; segment2 = segment2.f10155f) { Segment segment3 = segmentC.f10156g; o.c(segment3); o.c(segment2); segment3.b(segment2.c()); } buffer.f10118m = this.f10118m; } return buffer; } @Override // okio.Source, java.io.Closeable, java.lang.AutoCloseable public void close() { } public final byte d(long j2) { a0.b(this.f10118m, j2, 1L); Segment segment = this.f10117f; if (segment == null) { Segment segment2 = null; o.c(null); return segment2.a[(int) ((((long) segment2.f10151b) + j2) - (-1))]; } long j3 = this.f10118m; if (j3 - j2 < j2) { while (j3 > j2) { segment = segment.f10156g; o.c(segment); j3 -= (long) (segment.f10152c - segment.f10151b); } o.c(segment); return segment.a[(int) ((((long) segment.f10151b) + j2) - j3)]; } long j4 = 0; while (true) { long j5 = ((long) (segment.f10152c - segment.f10151b)) + j4; if (j5 > j2) { o.c(segment); return segment.a[(int) ((((long) segment.f10151b) + j2) - j4)]; } segment = segment.f10155f; o.c(segment); j4 = j5; } } public boolean equals(Object other) { if (this != other) { if (!(other instanceof Buffer)) { return false; } long j2 = this.f10118m; Buffer buffer = (Buffer) other; if (j2 != buffer.f10118m) { return false; } if (j2 != 0) { Segment segment = this.f10117f; o.c(segment); Segment segment2 = buffer.f10117f; o.c(segment2); int i2 = segment.f10151b; int i3 = segment2.f10151b; long j3 = 0; while (j3 < this.f10118m) { long jMin = Math.min(segment.f10152c - i2, segment2.f10152c - i3); long j4 = 0; while (j4 < jMin) { int i4 = i2 + 1; int i5 = i3 + 1; if (segment.a[i2] != segment2.a[i3]) { return false; } j4++; i2 = i4; i3 = i5; } if (i2 == segment.f10152c) { segment = segment.f10155f; o.c(segment); i2 = segment.f10151b; } if (i3 == segment2.f10152c) { segment2 = segment2.f10155f; o.c(segment2); i3 = segment2.f10151b; } j3 += jMin; } } } return true; } @Override // okio.BufferedSource public boolean f() { return this.f10118m == 0; } @Override // okio.BufferedSink, okio.Sink, java.io.Flushable public void flush() { } public long g(byte b2, long j2, long j3) { Segment segment; long j4 = 0; boolean z2 = false; if (0 <= j2 && j2 <= j3) { z2 = true; } if (!z2) { StringBuilder sbF = g.a.a.a.a.F("size="); sbF.append(this.f10118m); sbF.append(" fromIndex="); sbF.append(j2); sbF.append(" toIndex="); sbF.append(j3); throw new IllegalArgumentException(sbF.toString().toString()); } long j5 = this.f10118m; if (j3 > j5) { j3 = j5; } if (j2 != j3 && (segment = this.f10117f) != null) { if (j5 - j2 < j2) { while (j5 > j2) { segment = segment.f10156g; o.c(segment); j5 -= (long) (segment.f10152c - segment.f10151b); } while (j5 < j3) { byte[] bArr = segment.a; int iMin = (int) Math.min(segment.f10152c, (((long) segment.f10151b) + j3) - j5); for (int i2 = (int) ((((long) segment.f10151b) + j2) - j5); i2 < iMin; i2++) { if (bArr[i2] == b2) { return ((long) (i2 - segment.f10151b)) + j5; } } j5 += (long) (segment.f10152c - segment.f10151b); segment = segment.f10155f; o.c(segment); j2 = j5; } } else { while (true) { long j6 = ((long) (segment.f10152c - segment.f10151b)) + j4; if (j6 > j2) { break; } segment = segment.f10155f; o.c(segment); j4 = j6; } while (j4 < j3) { byte[] bArr2 = segment.a; int iMin2 = (int) Math.min(segment.f10152c, (((long) segment.f10151b) + j3) - j4); for (int i3 = (int) ((((long) segment.f10151b) + j2) - j4); i3 < iMin2; i3++) { if (bArr2[i3] == b2) { return ((long) (i3 - segment.f10151b)) + j4; } } j4 += (long) (segment.f10152c - segment.f10151b); segment = segment.f10155f; o.c(segment); j2 = j4; } } } return -1L; } @Override // okio.BufferedSource, okio.BufferedSink public Buffer getBuffer() { return this; } public int hashCode() { Segment segment = this.f10117f; if (segment == null) { return 0; } int i2 = 1; do { int i3 = segment.f10152c; for (int i4 = segment.f10151b; i4 < i3; i4++) { i2 = (i2 * 31) + segment.a[i4]; } segment = segment.f10155f; o.c(segment); } while (segment != this.f10117f); return i2; } @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 ? j2 + 1 : Long.MAX_VALUE; byte b2 = (byte) 10; long jG = g(b2, 0L, j3); if (jG != -1) { return okio.b0.a.a(this, jG); } if (j3 < this.f10118m && d(j3 - 1) == ((byte) 13) && d(j3) == b2) { return okio.b0.a.a(this, j3); } Buffer buffer = new Buffer(); c(buffer, 0L, Math.min(32, this.f10118m)); StringBuilder sbF = g.a.a.a.a.F("\\n not found: limit="); sbF.append(Math.min(this.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 true; } public long j(ByteString byteString) { int i2; o.f(byteString, "targetBytes"); o.f(byteString, "targetBytes"); Segment segment = this.f10117f; if (segment == null) { return -1L; } long j2 = this.f10118m; long j3 = 0; if (j2 - 0 < 0) { while (j2 > 0) { segment = segment.f10156g; o.c(segment); j2 -= (long) (segment.f10152c - segment.f10151b); } if (byteString.g() == 2) { byte bJ = byteString.j(0); byte bJ2 = byteString.j(1); while (j2 < this.f10118m) { byte[] bArr = segment.a; i2 = (int) ((((long) segment.f10151b) + j3) - j2); int i3 = segment.f10152c; while (i2 < i3) { byte b2 = bArr[i2]; if (b2 != bJ && b2 != bJ2) { i2++; } } j3 = ((long) (segment.f10152c - segment.f10151b)) + j2; segment = segment.f10155f; o.c(segment); j2 = j3; } return -1L; } byte[] bArrI = byteString.getF10122n(); while (j2 < this.f10118m) { byte[] bArr2 = segment.a; i2 = (int) ((((long) segment.f10151b) + j3) - j2); int i4 = segment.f10152c; while (i2 < i4) { byte b3 = bArr2[i2]; for (byte b4 : bArrI) { if (b3 != b4) { } } i2++; } j3 = ((long) (segment.f10152c - segment.f10151b)) + j2; segment = segment.f10155f; o.c(segment); j2 = j3; } return -1L; } j2 = 0; while (true) { long j4 = ((long) (segment.f10152c - segment.f10151b)) + j2; if (j4 > 0) { break; } segment = segment.f10155f; o.c(segment); j2 = j4; } if (byteString.g() == 2) { byte bJ3 = byteString.j(0); byte bJ4 = byteString.j(1); while (j2 < this.f10118m) { byte[] bArr3 = segment.a; i2 = (int) ((((long) segment.f10151b) + j3) - j2); int i5 = segment.f10152c; while (i2 < i5) { byte b5 = bArr3[i2]; if (b5 != bJ3 && b5 != bJ4) { i2++; } } j3 = ((long) (segment.f10152c - segment.f10151b)) + j2; segment = segment.f10155f; o.c(segment); j2 = j3; } return -1L; } byte[] bArrI2 = byteString.getF10122n(); while (j2 < this.f10118m) { byte[] bArr4 = segment.a; i2 = (int) ((((long) segment.f10151b) + j3) - j2); int i6 = segment.f10152c; while (i2 < i6) { byte b6 = bArr4[i2]; for (byte b7 : bArrI2) { if (b6 != b7) { } } i2++; } j3 = ((long) (segment.f10152c - segment.f10151b)) + j2; segment = segment.f10155f; o.c(segment); j2 = j3; } return -1L; return ((long) (i2 - segment.f10151b)) + j2; } @Override // okio.BufferedSource public String k(Charset charset) { o.f(charset, "charset"); return o(this.f10118m, charset); } public ByteString l() { return b(this.f10118m); } public short m() { int i2 = readShort() & 65535; return (short) (((i2 & DnsRecord.CLASS_ANY) << 8) | ((65280 & i2) >>> 8)); } @Override // okio.BufferedSource public String n() { return i(Long.MAX_VALUE); } public String o(long j2, Charset charset) throws EOFException { o.f(charset, "charset"); if (!(j2 >= 0 && j2 <= 2147483647L)) { throw new IllegalArgumentException(g.a.a.a.a.q("byteCount: ", j2).toString()); } if (this.f10118m < j2) { throw new EOFException(); } if (j2 == 0) { return ""; } Segment segment = this.f10117f; o.c(segment); if (((long) segment.f10151b) + j2 > segment.f10152c) { return new String(p(j2), charset); } int i2 = (int) j2; String str = new String(segment.a, segment.f10151b, i2, charset); int i3 = segment.f10151b + i2; segment.f10151b = i3; this.f10118m -= j2; if (i3 == segment.f10152c) { this.f10117f = segment.a(); SegmentPool.a(segment); } return str; } @Override // okio.BufferedSource public byte[] p(long j2) throws EOFException { int i2 = 0; if (!(j2 >= 0 && j2 <= 2147483647L)) { throw new IllegalArgumentException(g.a.a.a.a.q("byteCount: ", j2).toString()); } if (this.f10118m < j2) { throw new EOFException(); } int i3 = (int) j2; byte[] bArr = new byte[i3]; o.f(bArr, "sink"); while (i2 < i3) { int i4 = read(bArr, i2, i3 - i2); if (i4 == -1) { throw new EOFException(); } i2 += i4; } return bArr; } public String q() { return o(this.f10118m, Charsets.f9181b); } @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()); } long j3 = this.f10118m; if (j3 == 0) { return -1L; } if (j2 > j3) { j2 = j3; } buffer.write(this, j2); return j2; } @Override // java.nio.channels.ReadableByteChannel public int read(ByteBuffer sink) { o.f(sink, "sink"); Segment segment = this.f10117f; if (segment == null) { return -1; } int iMin = Math.min(sink.remaining(), segment.f10152c - segment.f10151b); sink.put(segment.a, segment.f10151b, iMin); int i2 = segment.f10151b + iMin; segment.f10151b = i2; this.f10118m -= (long) iMin; if (i2 == segment.f10152c) { this.f10117f = segment.a(); SegmentPool.a(segment); } return iMin; } public int read(byte[] sink, int offset, int byteCount) { o.f(sink, "sink"); a0.b(sink.length, offset, byteCount); Segment segment = this.f10117f; if (segment == null) { return -1; } int iMin = Math.min(byteCount, segment.f10152c - segment.f10151b); byte[] bArr = segment.a; int i2 = segment.f10151b; j.g(bArr, sink, offset, i2, i2 + iMin); int i3 = segment.f10151b + iMin; segment.f10151b = i3; this.f10118m -= (long) iMin; if (i3 == segment.f10152c) { this.f10117f = segment.a(); SegmentPool.a(segment); } return iMin; } @Override // okio.BufferedSource public byte readByte() throws EOFException { if (this.f10118m == 0) { throw new EOFException(); } Segment segment = this.f10117f; o.c(segment); int i2 = segment.f10151b; int i3 = segment.f10152c; int i4 = i2 + 1; byte b2 = segment.a[i2]; this.f10118m--; if (i4 == i3) { this.f10117f = segment.a(); SegmentPool.a(segment); } else { segment.f10151b = i4; } return b2; } @Override // okio.BufferedSource public int readInt() throws EOFException { if (this.f10118m < 4) { throw new EOFException(); } Segment segment = this.f10117f; o.c(segment); int i2 = segment.f10151b; int i3 = segment.f10152c; if (i3 - i2 < 4) { return ((readByte() & 255) << 24) | ((readByte() & 255) << 16) | ((readByte() & 255) << 8) | (readByte() & 255); } byte[] bArr = segment.a; int i4 = i2 + 1; int i5 = i4 + 1; int i6 = ((bArr[i2] & 255) << 24) | ((bArr[i4] & 255) << 16); int i7 = i5 + 1; int i8 = i6 | ((bArr[i5] & 255) << 8); int i9 = i7 + 1; int i10 = i8 | (bArr[i7] & 255); this.f10118m -= 4; if (i9 == i3) { this.f10117f = segment.a(); SegmentPool.a(segment); } else { segment.f10151b = i9; } return i10; } @Override // okio.BufferedSource public short readShort() throws EOFException { if (this.f10118m < 2) { throw new EOFException(); } Segment segment = this.f10117f; o.c(segment); int i2 = segment.f10151b; int i3 = segment.f10152c; if (i3 - i2 < 2) { return (short) (((readByte() & 255) << 8) | (readByte() & 255)); } byte[] bArr = segment.a; int i4 = i2 + 1; int i5 = i4 + 1; int i6 = ((bArr[i2] & 255) << 8) | (bArr[i4] & 255); this.f10118m -= 2; if (i5 == i3) { this.f10117f = segment.a(); SegmentPool.a(segment); } else { segment.f10151b = i5; } return (short) i6; } public String s(long j2) { return o(j2, Charsets.f9181b); } @Override // okio.BufferedSource public void skip(long byteCount) throws EOFException { while (byteCount > 0) { Segment segment = this.f10117f; if (segment == null) { throw new EOFException(); } int iMin = (int) Math.min(byteCount, segment.f10152c - segment.f10151b); long j2 = iMin; this.f10118m -= j2; byteCount -= j2; int i2 = segment.f10151b + iMin; segment.f10151b = i2; if (i2 == segment.f10152c) { this.f10117f = segment.a(); SegmentPool.a(segment); } } } @Override // okio.BufferedSource public void t(long j2) throws EOFException { if (this.f10118m < j2) { throw new EOFException(); } } @Override // okio.Source public Timeout timeout() { return Timeout.a; } public String toString() { long j2 = this.f10118m; if (j2 <= 2147483647L) { return u((int) j2).toString(); } StringBuilder sbF = g.a.a.a.a.F("size > Int.MAX_VALUE: "); sbF.append(this.f10118m); throw new IllegalStateException(sbF.toString().toString()); } public final ByteString u(int i2) { if (i2 == 0) { return ByteString.f10121m; } a0.b(this.f10118m, 0L, i2); Segment segment = this.f10117f; int i3 = 0; int i4 = 0; int i5 = 0; while (i4 < i2) { o.c(segment); int i6 = segment.f10152c; int i7 = segment.f10151b; if (i6 == i7) { throw new AssertionError("s.limit == s.pos"); } i4 += i6 - i7; i5++; segment = segment.f10155f; } byte[][] bArr = new byte[i5][]; int[] iArr = new int[i5 * 2]; Segment segment2 = this.f10117f; int i8 = 0; while (i3 < i2) { o.c(segment2); bArr[i8] = segment2.a; i3 += segment2.f10152c - segment2.f10151b; iArr[i8] = Math.min(i3, i2); iArr[i8 + i5] = segment2.f10151b; segment2.f10153d = true; i8++; segment2 = segment2.f10155f; } return new SegmentedByteString(bArr, iArr); } /* JADX WARN: Removed duplicated region for block: B:33:0x00aa */ /* JADX WARN: Removed duplicated region for block: B:34:0x00b4 */ /* JADX WARN: Removed duplicated region for block: B:36:0x00b8 */ /* JADX WARN: Removed duplicated region for block: B:44:0x00bc A[EDGE_INSN: B:44:0x00bc->B:38:0x00bc BREAK A[LOOP:0: B:5:0x000c->B:46:?], SYNTHETIC] */ @Override // okio.BufferedSource /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public long v() throws java.io.EOFException { /* Method dump skipped, instruction units count: 201 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okio.Buffer.v():long"); } @Override // okio.BufferedSource public InputStream w() { return new a(); } @Override // java.nio.channels.WritableByteChannel public int write(ByteBuffer source) { o.f(source, "source"); int iRemaining = source.remaining(); int i2 = iRemaining; while (i2 > 0) { Segment segmentX = x(1); int iMin = Math.min(i2, 8192 - segmentX.f10152c); source.get(segmentX.a, segmentX.f10152c, iMin); i2 -= iMin; segmentX.f10152c += iMin; } this.f10118m += (long) iRemaining; return iRemaining; } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink write(ByteString byteString) { z(byteString); return this; } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink write(byte[] bArr) { A(bArr); return this; } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink write(byte[] bArr, int i2, int i3) { B(bArr, i2, i3); return this; } @Override // okio.Sink public void write(Buffer buffer, long j2) { int i2; Segment segment; Segment segmentB; o.f(buffer, "source"); if (!(buffer != this)) { throw new IllegalArgumentException("source == this".toString()); } a0.b(buffer.f10118m, 0L, j2); while (j2 > 0) { Segment segment2 = buffer.f10117f; o.c(segment2); int i3 = segment2.f10152c; o.c(buffer.f10117f); if (j2 < i3 - r3.f10151b) { Segment segment3 = this.f10117f; if (segment3 != null) { o.c(segment3); segment = segment3.f10156g; } else { segment = null; } if (segment != null && segment.f10154e) { if ((((long) segment.f10152c) + j2) - ((long) (segment.f10153d ? 0 : segment.f10151b)) <= Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE) { Segment segment4 = buffer.f10117f; o.c(segment4); segment4.d(segment, (int) j2); buffer.f10118m -= j2; this.f10118m += j2; return; } } Segment segment5 = buffer.f10117f; o.c(segment5); int i4 = (int) j2; if (!(i4 > 0 && i4 <= segment5.f10152c - segment5.f10151b)) { throw new IllegalArgumentException("byteCount out of range".toString()); } if (i4 >= 1024) { segmentB = segment5.c(); } else { segmentB = SegmentPool.b(); byte[] bArr = segment5.a; byte[] bArr2 = segmentB.a; int i5 = segment5.f10151b; j.i(bArr, bArr2, 0, i5, i5 + i4, 2); } segmentB.f10152c = segmentB.f10151b + i4; segment5.f10151b += i4; Segment segment6 = segment5.f10156g; o.c(segment6); segment6.b(segmentB); buffer.f10117f = segmentB; } Segment segment7 = buffer.f10117f; o.c(segment7); long j3 = segment7.f10152c - segment7.f10151b; buffer.f10117f = segment7.a(); Segment segment8 = this.f10117f; if (segment8 == null) { this.f10117f = segment7; segment7.f10156g = segment7; segment7.f10155f = segment7; } else { o.c(segment8); Segment segment9 = segment8.f10156g; o.c(segment9); segment9.b(segment7); Segment segment10 = segment7.f10156g; if (!(segment10 != segment7)) { throw new IllegalStateException("cannot compact".toString()); } o.c(segment10); if (segment10.f10154e) { int i6 = segment7.f10152c - segment7.f10151b; Segment segment11 = segment7.f10156g; o.c(segment11); int i7 = 8192 - segment11.f10152c; Segment segment12 = segment7.f10156g; o.c(segment12); if (segment12.f10153d) { i2 = 0; } else { Segment segment13 = segment7.f10156g; o.c(segment13); i2 = segment13.f10151b; } if (i6 <= i7 + i2) { Segment segment14 = segment7.f10156g; o.c(segment14); segment7.d(segment14, i6); segment7.a(); SegmentPool.a(segment7); } } } buffer.f10118m -= j3; this.f10118m += j3; j2 -= j3; } } @Override // okio.BufferedSink public long writeAll(Source source) { o.f(source, "source"); long j2 = 0; while (true) { long jR = source.r(this, Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE); if (jR == -1) { return j2; } j2 += jR; } } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink writeByte(int i2) { C(i2); return this; } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink writeInt(int i2) { F(i2); return this; } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink writeShort(int i2) { G(i2); return this; } @Override // okio.BufferedSink public /* bridge */ /* synthetic */ BufferedSink writeUtf8(String str) { H(str); return this; } public final Segment x(int i2) { if (!(i2 >= 1 && i2 <= 8192)) { throw new IllegalArgumentException("unexpected capacity".toString()); } Segment segment = this.f10117f; if (segment == null) { Segment segmentB = SegmentPool.b(); this.f10117f = segmentB; segmentB.f10156g = segmentB; segmentB.f10155f = segmentB; return segmentB; } o.c(segment); Segment segment2 = segment.f10156g; o.c(segment2); if (segment2.f10152c + i2 <= 8192 && segment2.f10154e) { return segment2; } Segment segmentB2 = SegmentPool.b(); segment2.b(segmentB2); return segmentB2; } @Override // okio.BufferedSource public int y(Options options) throws EOFException { o.f(options, "options"); int iB = okio.b0.a.b(this, options, false); if (iB == -1) { return -1; } skip(options.f10140m[iB].g()); return iB; } public Buffer z(ByteString byteString) { o.f(byteString, "byteString"); byteString.r(this, 0, byteString.g()); return this; } }