mirror of
https://github.com/Pinball3D/Rabbit-R1.git
synced 2024-12-24 08:02:37 -06:00
278 lines
15 KiB
Java
278 lines
15 KiB
Java
package okio.internal;
|
|
|
|
import androidx.media3.exoplayer.upstream.CmcdHeadersFactory;
|
|
import io.flutter.plugin.editing.SpellCheckPlugin;
|
|
import io.sentry.protocol.TransactionInfo;
|
|
import java.io.EOFException;
|
|
import kotlin.Metadata;
|
|
import kotlin.jvm.internal.Intrinsics;
|
|
import okio.Buffer;
|
|
import okio.BufferedSink;
|
|
import okio.ByteString;
|
|
import okio.RealBufferedSink;
|
|
import okio.Source;
|
|
import okio.Timeout;
|
|
|
|
/* compiled from: RealBufferedSink.kt */
|
|
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000D\n\u0000\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\u0012\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0015\u001a\r\u0010\u0000\u001a\u00020\u0001*\u00020\u0002H\u0080\b\u001a\r\u0010\u0003\u001a\u00020\u0004*\u00020\u0002H\u0080\b\u001a\r\u0010\u0005\u001a\u00020\u0004*\u00020\u0002H\u0080\b\u001a\r\u0010\u0006\u001a\u00020\u0001*\u00020\u0002H\u0080\b\u001a\r\u0010\u0007\u001a\u00020\b*\u00020\u0002H\u0080\b\u001a\r\u0010\t\u001a\u00020\n*\u00020\u0002H\u0080\b\u001a\u0015\u0010\u000b\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\f\u001a\u00020\rH\u0080\b\u001a%\u0010\u000b\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\f\u001a\u00020\r2\u0006\u0010\u000e\u001a\u00020\u000f2\u0006\u0010\u0010\u001a\u00020\u000fH\u0080\b\u001a\u001d\u0010\u000b\u001a\u00020\u0001*\u00020\u00022\u0006\u0010\f\u001a\u00020\u00112\u0006\u0010\u0010\u001a\u00020\u0012H\u0080\b\u001a\u0015\u0010\u000b\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u0013\u001a\u00020\u0014H\u0080\b\u001a%\u0010\u000b\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u000e\u001a\u00020\u000f2\u0006\u0010\u0010\u001a\u00020\u000fH\u0080\b\u001a\u001d\u0010\u000b\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\f\u001a\u00020\u00152\u0006\u0010\u0010\u001a\u00020\u0012H\u0080\b\u001a\u0015\u0010\u0016\u001a\u00020\u0012*\u00020\u00022\u0006\u0010\f\u001a\u00020\u0015H\u0080\b\u001a\u0015\u0010\u0017\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u0018\u001a\u00020\u000fH\u0080\b\u001a\u0015\u0010\u0019\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u001a\u001a\u00020\u0012H\u0080\b\u001a\u0015\u0010\u001b\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u001a\u001a\u00020\u0012H\u0080\b\u001a\u0015\u0010\u001c\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u001d\u001a\u00020\u000fH\u0080\b\u001a\u0015\u0010\u001e\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u001d\u001a\u00020\u000fH\u0080\b\u001a\u0015\u0010\u001f\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u001a\u001a\u00020\u0012H\u0080\b\u001a\u0015\u0010 \u001a\u00020\u0004*\u00020\u00022\u0006\u0010\u001a\u001a\u00020\u0012H\u0080\b\u001a\u0015\u0010!\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\"\u001a\u00020\u000fH\u0080\b\u001a\u0015\u0010#\u001a\u00020\u0004*\u00020\u00022\u0006\u0010\"\u001a\u00020\u000fH\u0080\b\u001a\u0015\u0010$\u001a\u00020\u0004*\u00020\u00022\u0006\u0010%\u001a\u00020\nH\u0080\b\u001a%\u0010$\u001a\u00020\u0004*\u00020\u00022\u0006\u0010%\u001a\u00020\n2\u0006\u0010&\u001a\u00020\u000f2\u0006\u0010'\u001a\u00020\u000fH\u0080\b\u001a\u0015\u0010(\u001a\u00020\u0004*\u00020\u00022\u0006\u0010)\u001a\u00020\u000fH\u0080\b¨\u0006*"}, d2 = {"commonClose", "", "Lokio/RealBufferedSink;", "commonEmit", "Lokio/BufferedSink;", "commonEmitCompleteSegments", "commonFlush", "commonTimeout", "Lokio/Timeout;", "commonToString", "", "commonWrite", TransactionInfo.JsonKeys.SOURCE, "", "offset", "", "byteCount", "Lokio/Buffer;", "", "byteString", "Lokio/ByteString;", "Lokio/Source;", "commonWriteAll", "commonWriteByte", "b", "commonWriteDecimalLong", "v", "commonWriteHexadecimalUnsignedLong", "commonWriteInt", CmcdHeadersFactory.OBJECT_TYPE_INIT_SEGMENT, "commonWriteIntLe", "commonWriteLong", "commonWriteLongLe", "commonWriteShort", CmcdHeadersFactory.STREAMING_FORMAT_SS, "commonWriteShortLe", "commonWriteUtf8", "string", "beginIndex", SpellCheckPlugin.END_INDEX_KEY, "commonWriteUtf8CodePoint", "codePoint", "okio"}, k = 2, mv = {1, 4, 0})
|
|
/* loaded from: classes3.dex */
|
|
public final class RealBufferedSinkKt {
|
|
public static final void commonWrite(RealBufferedSink commonWrite, Buffer source, long j) {
|
|
Intrinsics.checkNotNullParameter(commonWrite, "$this$commonWrite");
|
|
Intrinsics.checkNotNullParameter(source, "source");
|
|
if (!(!commonWrite.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWrite.bufferField.write(source, j);
|
|
commonWrite.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWrite(RealBufferedSink commonWrite, ByteString byteString) {
|
|
Intrinsics.checkNotNullParameter(commonWrite, "$this$commonWrite");
|
|
Intrinsics.checkNotNullParameter(byteString, "byteString");
|
|
if (!(!commonWrite.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWrite.bufferField.write(byteString);
|
|
return commonWrite.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWrite(RealBufferedSink commonWrite, ByteString byteString, int i, int i2) {
|
|
Intrinsics.checkNotNullParameter(commonWrite, "$this$commonWrite");
|
|
Intrinsics.checkNotNullParameter(byteString, "byteString");
|
|
if (!(!commonWrite.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWrite.bufferField.write(byteString, i, i2);
|
|
return commonWrite.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteUtf8(RealBufferedSink commonWriteUtf8, String string) {
|
|
Intrinsics.checkNotNullParameter(commonWriteUtf8, "$this$commonWriteUtf8");
|
|
Intrinsics.checkNotNullParameter(string, "string");
|
|
if (!(!commonWriteUtf8.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteUtf8.bufferField.writeUtf8(string);
|
|
return commonWriteUtf8.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteUtf8(RealBufferedSink commonWriteUtf8, String string, int i, int i2) {
|
|
Intrinsics.checkNotNullParameter(commonWriteUtf8, "$this$commonWriteUtf8");
|
|
Intrinsics.checkNotNullParameter(string, "string");
|
|
if (!(!commonWriteUtf8.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteUtf8.bufferField.writeUtf8(string, i, i2);
|
|
return commonWriteUtf8.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteUtf8CodePoint(RealBufferedSink commonWriteUtf8CodePoint, int i) {
|
|
Intrinsics.checkNotNullParameter(commonWriteUtf8CodePoint, "$this$commonWriteUtf8CodePoint");
|
|
if (!(!commonWriteUtf8CodePoint.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteUtf8CodePoint.bufferField.writeUtf8CodePoint(i);
|
|
return commonWriteUtf8CodePoint.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWrite(RealBufferedSink commonWrite, byte[] source) {
|
|
Intrinsics.checkNotNullParameter(commonWrite, "$this$commonWrite");
|
|
Intrinsics.checkNotNullParameter(source, "source");
|
|
if (!(!commonWrite.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWrite.bufferField.write(source);
|
|
return commonWrite.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWrite(RealBufferedSink commonWrite, byte[] source, int i, int i2) {
|
|
Intrinsics.checkNotNullParameter(commonWrite, "$this$commonWrite");
|
|
Intrinsics.checkNotNullParameter(source, "source");
|
|
if (!(!commonWrite.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWrite.bufferField.write(source, i, i2);
|
|
return commonWrite.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteByte(RealBufferedSink commonWriteByte, int i) {
|
|
Intrinsics.checkNotNullParameter(commonWriteByte, "$this$commonWriteByte");
|
|
if (!(!commonWriteByte.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteByte.bufferField.writeByte(i);
|
|
return commonWriteByte.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteShort(RealBufferedSink commonWriteShort, int i) {
|
|
Intrinsics.checkNotNullParameter(commonWriteShort, "$this$commonWriteShort");
|
|
if (!(!commonWriteShort.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteShort.bufferField.writeShort(i);
|
|
return commonWriteShort.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteShortLe(RealBufferedSink commonWriteShortLe, int i) {
|
|
Intrinsics.checkNotNullParameter(commonWriteShortLe, "$this$commonWriteShortLe");
|
|
if (!(!commonWriteShortLe.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteShortLe.bufferField.writeShortLe(i);
|
|
return commonWriteShortLe.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteInt(RealBufferedSink commonWriteInt, int i) {
|
|
Intrinsics.checkNotNullParameter(commonWriteInt, "$this$commonWriteInt");
|
|
if (!(!commonWriteInt.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteInt.bufferField.writeInt(i);
|
|
return commonWriteInt.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteIntLe(RealBufferedSink commonWriteIntLe, int i) {
|
|
Intrinsics.checkNotNullParameter(commonWriteIntLe, "$this$commonWriteIntLe");
|
|
if (!(!commonWriteIntLe.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteIntLe.bufferField.writeIntLe(i);
|
|
return commonWriteIntLe.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteLong(RealBufferedSink commonWriteLong, long j) {
|
|
Intrinsics.checkNotNullParameter(commonWriteLong, "$this$commonWriteLong");
|
|
if (!(!commonWriteLong.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteLong.bufferField.writeLong(j);
|
|
return commonWriteLong.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteLongLe(RealBufferedSink commonWriteLongLe, long j) {
|
|
Intrinsics.checkNotNullParameter(commonWriteLongLe, "$this$commonWriteLongLe");
|
|
if (!(!commonWriteLongLe.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteLongLe.bufferField.writeLongLe(j);
|
|
return commonWriteLongLe.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteDecimalLong(RealBufferedSink commonWriteDecimalLong, long j) {
|
|
Intrinsics.checkNotNullParameter(commonWriteDecimalLong, "$this$commonWriteDecimalLong");
|
|
if (!(!commonWriteDecimalLong.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteDecimalLong.bufferField.writeDecimalLong(j);
|
|
return commonWriteDecimalLong.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonWriteHexadecimalUnsignedLong(RealBufferedSink commonWriteHexadecimalUnsignedLong, long j) {
|
|
Intrinsics.checkNotNullParameter(commonWriteHexadecimalUnsignedLong, "$this$commonWriteHexadecimalUnsignedLong");
|
|
if (!(!commonWriteHexadecimalUnsignedLong.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
commonWriteHexadecimalUnsignedLong.bufferField.writeHexadecimalUnsignedLong(j);
|
|
return commonWriteHexadecimalUnsignedLong.emitCompleteSegments();
|
|
}
|
|
|
|
public static final BufferedSink commonEmitCompleteSegments(RealBufferedSink commonEmitCompleteSegments) {
|
|
Intrinsics.checkNotNullParameter(commonEmitCompleteSegments, "$this$commonEmitCompleteSegments");
|
|
if (!(!commonEmitCompleteSegments.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
long completeSegmentByteCount = commonEmitCompleteSegments.bufferField.completeSegmentByteCount();
|
|
if (completeSegmentByteCount > 0) {
|
|
commonEmitCompleteSegments.sink.write(commonEmitCompleteSegments.bufferField, completeSegmentByteCount);
|
|
}
|
|
return commonEmitCompleteSegments;
|
|
}
|
|
|
|
public static final BufferedSink commonEmit(RealBufferedSink commonEmit) {
|
|
Intrinsics.checkNotNullParameter(commonEmit, "$this$commonEmit");
|
|
if (!(!commonEmit.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
long size = commonEmit.bufferField.size();
|
|
if (size > 0) {
|
|
commonEmit.sink.write(commonEmit.bufferField, size);
|
|
}
|
|
return commonEmit;
|
|
}
|
|
|
|
public static final void commonFlush(RealBufferedSink commonFlush) {
|
|
Intrinsics.checkNotNullParameter(commonFlush, "$this$commonFlush");
|
|
if (!(!commonFlush.closed)) {
|
|
throw new IllegalStateException("closed".toString());
|
|
}
|
|
if (commonFlush.bufferField.size() > 0) {
|
|
commonFlush.sink.write(commonFlush.bufferField, commonFlush.bufferField.size());
|
|
}
|
|
commonFlush.sink.flush();
|
|
}
|
|
|
|
public static final void commonClose(RealBufferedSink commonClose) {
|
|
Intrinsics.checkNotNullParameter(commonClose, "$this$commonClose");
|
|
if (commonClose.closed) {
|
|
return;
|
|
}
|
|
Throwable th = null;
|
|
try {
|
|
if (commonClose.bufferField.size() > 0) {
|
|
commonClose.sink.write(commonClose.bufferField, commonClose.bufferField.size());
|
|
}
|
|
} catch (Throwable th2) {
|
|
th = th2;
|
|
}
|
|
try {
|
|
commonClose.sink.close();
|
|
} catch (Throwable th3) {
|
|
if (th == null) {
|
|
th = th3;
|
|
}
|
|
}
|
|
commonClose.closed = true;
|
|
if (th != null) {
|
|
throw th;
|
|
}
|
|
}
|
|
|
|
public static final Timeout commonTimeout(RealBufferedSink commonTimeout) {
|
|
Intrinsics.checkNotNullParameter(commonTimeout, "$this$commonTimeout");
|
|
return commonTimeout.sink.getTimeout();
|
|
}
|
|
|
|
public static final String commonToString(RealBufferedSink commonToString) {
|
|
Intrinsics.checkNotNullParameter(commonToString, "$this$commonToString");
|
|
return "buffer(" + commonToString.sink + ')';
|
|
}
|
|
|
|
public static final long commonWriteAll(RealBufferedSink commonWriteAll, Source source) {
|
|
Intrinsics.checkNotNullParameter(commonWriteAll, "$this$commonWriteAll");
|
|
Intrinsics.checkNotNullParameter(source, "source");
|
|
long j = 0;
|
|
while (true) {
|
|
long read = source.read(commonWriteAll.bufferField, 8192);
|
|
if (read == -1) {
|
|
return j;
|
|
}
|
|
j += read;
|
|
commonWriteAll.emitCompleteSegments();
|
|
}
|
|
}
|
|
|
|
public static final BufferedSink commonWrite(RealBufferedSink commonWrite, Source source, long j) {
|
|
Intrinsics.checkNotNullParameter(commonWrite, "$this$commonWrite");
|
|
Intrinsics.checkNotNullParameter(source, "source");
|
|
while (j > 0) {
|
|
long read = source.read(commonWrite.bufferField, j);
|
|
if (read == -1) {
|
|
throw new EOFException();
|
|
}
|
|
j -= read;
|
|
commonWrite.emitCompleteSegments();
|
|
}
|
|
return commonWrite;
|
|
}
|
|
}
|