package okhttp3.internal.http2; import androidx.media3.exoplayer.rtsp.SessionDescription; import com.google.android.gms.measurement.internal.u1; import java.io.EOFException; import java.io.IOException; import java.io.InterruptedIOException; import java.net.SocketTimeoutException; import java.util.ArrayDeque; import java.util.List; import kotlin.Metadata; import kotlin.jvm.internal.SourceDebugExtension; import kotlin.jvm.internal.d; import nb.g; import okhttp3.Headers; import okhttp3.internal.Util; import okio.AsyncTimeout; import okio.Buffer; import okio.BufferedSource; import okio.Sink; import okio.Source; import okio.Timeout; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import xyz.stream.download.config.InnerConstant; /* JADX INFO: loaded from: classes.dex */ @Metadata(d1 = {"\u0000\u008a\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\t\n\u0002\u0010\t\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\u0014\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0018\u0018\u0000 k2\u00020\u0001:\u0004klmnB3\b\u0000\u0012\u0006\u00100\u001a\u00020\u001e\u0012\u0006\u00105\u001a\u000204\u0012\u0006\u0010\t\u001a\u00020\b\u0012\u0006\u0010\"\u001a\u00020\b\u0012\b\u0010!\u001a\u0004\u0018\u00010\u0002¢\u0006\u0004\bi\u0010jJ\u0006\u0010\u0003\u001a\u00020\u0002J\u0006\u0010\u0004\u001a\u00020\u0002J$\u0010\f\u001a\u00020\u000b2\f\u0010\u0007\u001a\b\u0012\u0004\u0012\u00020\u00060\u00052\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\n\u001a\u00020\bJ\u000e\u0010\r\u001a\u00020\u000b2\u0006\u0010\u0004\u001a\u00020\u0002J\u0006\u0010\u000f\u001a\u00020\u000eJ\u0006\u0010\u0010\u001a\u00020\u000eJ\u0006\u0010\u0012\u001a\u00020\u0011J\u0006\u0010\u0014\u001a\u00020\u0013J\u0018\u0010\u0019\u001a\u00020\u000b2\u0006\u0010\u0016\u001a\u00020\u00152\b\u0010\u0018\u001a\u0004\u0018\u00010\u0017J\u000e\u0010\u001b\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\u0015J\u0016\u0010 \u001a\u00020\u000b2\u0006\u0010\u001d\u001a\u00020\u001c2\u0006\u0010\u001f\u001a\u00020\u001eJ\u0016\u0010#\u001a\u00020\u000b2\u0006\u0010!\u001a\u00020\u00022\u0006\u0010\"\u001a\u00020\bJ\u000e\u0010$\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\u0015J\u000f\u0010'\u001a\u00020\u000bH\u0000¢\u0006\u0004\b%\u0010&J\u000e\u0010*\u001a\u00020\u000b2\u0006\u0010)\u001a\u00020(J\u000f\u0010,\u001a\u00020\u000bH\u0000¢\u0006\u0004\b+\u0010&J\u000f\u0010.\u001a\u00020\u000bH\u0000¢\u0006\u0004\b-\u0010&J\u001a\u0010/\u001a\u00020\b2\u0006\u0010\u001a\u001a\u00020\u00152\b\u0010\u0018\u001a\u0004\u0018\u00010\u0017H\u0002R\u0017\u00100\u001a\u00020\u001e8\u0006¢\u0006\f\n\u0004\b0\u00101\u001a\u0004\b2\u00103R\u0017\u00105\u001a\u0002048\u0006¢\u0006\f\n\u0004\b5\u00106\u001a\u0004\b7\u00108R*\u0010:\u001a\u00020(2\u0006\u00109\u001a\u00020(8\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\b:\u0010;\u001a\u0004\b<\u0010=\"\u0004\b>\u0010?R*\u0010@\u001a\u00020(2\u0006\u00109\u001a\u00020(8\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\b@\u0010;\u001a\u0004\bA\u0010=\"\u0004\bB\u0010?R*\u0010C\u001a\u00020(2\u0006\u00109\u001a\u00020(8\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bC\u0010;\u001a\u0004\bD\u0010=\"\u0004\bE\u0010?R*\u0010F\u001a\u00020(2\u0006\u00109\u001a\u00020(8\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bF\u0010;\u001a\u0004\bG\u0010=\"\u0004\bH\u0010?R\u001a\u0010J\u001a\b\u0012\u0004\u0012\u00020\u00020I8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bJ\u0010KR\u0016\u0010L\u001a\u00020\b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bL\u0010MR\u001e\u0010\u001d\u001a\u00060NR\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u001d\u0010O\u001a\u0004\bP\u0010QR\u001e\u0010S\u001a\u00060RR\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\bS\u0010T\u001a\u0004\bU\u0010VR\u001e\u0010\u000f\u001a\u00060WR\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u000f\u0010X\u001a\u0004\bY\u0010ZR\u001e\u0010\u0010\u001a\u00060WR\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0010\u0010X\u001a\u0004\b[\u0010ZR$\u0010\u001a\u001a\u0004\u0018\u00010\u00158@@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u001a\u0010\\\u001a\u0004\b]\u0010^\"\u0004\b_\u0010`R$\u0010\u0018\u001a\u0004\u0018\u00010\u00178\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0018\u0010a\u001a\u0004\bb\u0010c\"\u0004\bd\u0010eR\u0011\u0010f\u001a\u00020\b8F¢\u0006\u0006\u001a\u0004\bf\u0010gR\u0011\u0010h\u001a\u00020\b8F¢\u0006\u0006\u001a\u0004\bh\u0010g¨\u0006o"}, d2 = {"Lokhttp3/internal/http2/Http2Stream;", "", "Lokhttp3/Headers;", "takeHeaders", "trailers", "", "Lokhttp3/internal/http2/Header;", "responseHeaders", "", "outFinished", "flushHeaders", "Lkd/e;", "writeHeaders", "enqueueTrailers", "Lokio/Timeout;", "readTimeout", "writeTimeout", "Lokio/Source;", "getSource", "Lokio/Sink;", "getSink", "Lokhttp3/internal/http2/ErrorCode;", "rstStatusCode", "Ljava/io/IOException;", "errorException", "close", "errorCode", "closeLater", "Lokio/BufferedSource;", "source", "", SessionDescription.ATTR_LENGTH, "receiveData", "headers", "inFinished", "receiveHeaders", "receiveRstStream", "cancelStreamIfNecessary$okhttp", "()V", "cancelStreamIfNecessary", "", "delta", "addBytesToWriteWindow", "checkOutNotClosed$okhttp", "checkOutNotClosed", "waitForIo$okhttp", "waitForIo", "closeInternal", InnerConstant.Db.f36069id, "I", "getId", "()I", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Http2Connection;", "getConnection", "()Lokhttp3/internal/http2/Http2Connection;", "", "readBytesTotal", "J", "getReadBytesTotal", "()J", "setReadBytesTotal$okhttp", "(J)V", "readBytesAcknowledged", "getReadBytesAcknowledged", "setReadBytesAcknowledged$okhttp", "writeBytesTotal", "getWriteBytesTotal", "setWriteBytesTotal$okhttp", "writeBytesMaximum", "getWriteBytesMaximum", "setWriteBytesMaximum$okhttp", "Ljava/util/ArrayDeque;", "headersQueue", "Ljava/util/ArrayDeque;", "hasResponseHeaders", "Z", "Lokhttp3/internal/http2/Http2Stream$FramingSource;", "Lokhttp3/internal/http2/Http2Stream$FramingSource;", "getSource$okhttp", "()Lokhttp3/internal/http2/Http2Stream$FramingSource;", "Lokhttp3/internal/http2/Http2Stream$FramingSink;", "sink", "Lokhttp3/internal/http2/Http2Stream$FramingSink;", "getSink$okhttp", "()Lokhttp3/internal/http2/Http2Stream$FramingSink;", "Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "getReadTimeout$okhttp", "()Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "getWriteTimeout$okhttp", "Lokhttp3/internal/http2/ErrorCode;", "getErrorCode$okhttp", "()Lokhttp3/internal/http2/ErrorCode;", "setErrorCode$okhttp", "(Lokhttp3/internal/http2/ErrorCode;)V", "Ljava/io/IOException;", "getErrorException$okhttp", "()Ljava/io/IOException;", "setErrorException$okhttp", "(Ljava/io/IOException;)V", "isOpen", "()Z", "isLocallyInitiated", "", "(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V", "Companion", "FramingSink", "FramingSource", "StreamTimeout", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nHttp2Stream.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Stream.kt\nokhttp3/internal/http2/Http2Stream\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 Util.kt\nokhttp3/internal/Util\n*L\n1#1,688:1\n1#2:689\n615#3,4:690\n615#3,4:694\n563#3:698\n615#3,4:699\n615#3,4:703\n563#3:707\n563#3:708\n615#3,4:709\n563#3:713\n557#3:714\n*S KotlinDebug\n*F\n+ 1 Http2Stream.kt\nokhttp3/internal/http2/Http2Stream\n*L\n176#1:690,4\n255#1:694,4\n263#1:698\n274#1:699,4\n281#1:703,4\n295#1:707\n305#1:708\n491#1:709,4\n637#1:713\n657#1:714\n*E\n"}) public final class Http2Stream { public static final long EMIT_BUFFER_SIZE = 16384; @NotNull private final Http2Connection connection; @Nullable private ErrorCode errorCode; @Nullable private IOException errorException; private boolean hasResponseHeaders; @NotNull private final ArrayDeque headersQueue; private final int id; private long readBytesAcknowledged; private long readBytesTotal; @NotNull private final StreamTimeout readTimeout; @NotNull private final FramingSink sink; @NotNull private final FramingSource source; private long writeBytesMaximum; private long writeBytesTotal; @NotNull private final StreamTimeout writeTimeout; @Metadata(d1 = {"\u0000<\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\f\b\u0086\u0004\u0018\u00002\u00020\u0001B\u0019\b\u0000\u0012\u0006\u0010\u0011\u001a\u00020\u0002\u0012\u0006\u0010\u0014\u001a\u00020\u0013¢\u0006\u0004\b*\u0010+J\u0010\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H\u0002J\u0018\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\b\u001a\u00020\u0002H\u0016J\u001f\u0010\r\u001a\u00020\u00042\u0006\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0002H\u0000¢\u0006\u0004\b\u000b\u0010\fJ\b\u0010\u000f\u001a\u00020\u000eH\u0016J\b\u0010\u0010\u001a\u00020\u0004H\u0016R\u0014\u0010\u0011\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0011\u0010\u0012R\"\u0010\u0014\u001a\u00020\u00138\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0014\u0010\u0015\u001a\u0004\b\u0016\u0010\u0017\"\u0004\b\u0018\u0010\u0019R\u0017\u0010\u001a\u001a\u00020\u00068\u0006¢\u0006\f\n\u0004\b\u001a\u0010\u001b\u001a\u0004\b\u001c\u0010\u001dR\u0017\u0010\u001e\u001a\u00020\u00068\u0006¢\u0006\f\n\u0004\b\u001e\u0010\u001b\u001a\u0004\b\u001f\u0010\u001dR$\u0010!\u001a\u0004\u0018\u00010 8\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b!\u0010\"\u001a\u0004\b#\u0010$\"\u0004\b%\u0010&R\"\u0010'\u001a\u00020\u00138\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b'\u0010\u0015\u001a\u0004\b(\u0010\u0017\"\u0004\b)\u0010\u0019¨\u0006,"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$FramingSource;", "Lokio/Source;", "", "read", "Lkd/e;", "updateConnectionFlowControl", "Lokio/Buffer;", "sink", "byteCount", "Lokio/BufferedSource;", "source", "receive$okhttp", "(Lokio/BufferedSource;J)V", "receive", "Lokio/Timeout;", "timeout", "close", "maxByteCount", "J", "", "finished", "Z", "getFinished$okhttp", "()Z", "setFinished$okhttp", "(Z)V", "receiveBuffer", "Lokio/Buffer;", "getReceiveBuffer", "()Lokio/Buffer;", "readBuffer", "getReadBuffer", "Lokhttp3/Headers;", "trailers", "Lokhttp3/Headers;", "getTrailers", "()Lokhttp3/Headers;", "setTrailers", "(Lokhttp3/Headers;)V", "closed", "getClosed$okhttp", "setClosed$okhttp", "", "(Lokhttp3/internal/http2/Http2Stream;JZ)V", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nHttp2Stream.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Stream.kt\nokhttp3/internal/http2/Http2Stream$FramingSource\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 Util.kt\nokhttp3/internal/Util\n*L\n1#1,688:1\n1#2:689\n615#3,4:690\n615#3,4:694\n563#3:698\n563#3:699\n*S KotlinDebug\n*F\n+ 1 Http2Stream.kt\nokhttp3/internal/http2/Http2Stream$FramingSource\n*L\n407#1:690,4\n418#1:694,4\n458#1:698\n480#1:699\n*E\n"}) public final class FramingSource implements Source { private boolean closed; private boolean finished; private final long maxByteCount; @Nullable private Headers trailers; @NotNull private final Buffer receiveBuffer = new Buffer(); @NotNull private final Buffer readBuffer = new Buffer(); public FramingSource(long j10, boolean z10) { this.maxByteCount = j10; this.finished = z10; } private final void updateConnectionFlowControl(long j10) { Http2Stream http2Stream = Http2Stream.this; if (!Util.assertionsEnabled || !Thread.holdsLock(http2Stream)) { Http2Stream.this.getConnection().updateConnectionFlowControl$okhttp(j10); return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } @Override // okio.Source, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { long size; Http2Stream http2Stream = Http2Stream.this; synchronized (http2Stream) { this.closed = true; size = this.readBuffer.size(); this.readBuffer.clear(); g.g(http2Stream, "null cannot be cast to non-null type java.lang.Object"); http2Stream.notifyAll(); } if (size > 0) { updateConnectionFlowControl(size); } Http2Stream.this.cancelStreamIfNecessary$okhttp(); } /* JADX INFO: renamed from: getClosed$okhttp, reason: from getter */ public final boolean getClosed() { return this.closed; } /* JADX INFO: renamed from: getFinished$okhttp, reason: from getter */ public final boolean getFinished() { return this.finished; } @NotNull public final Buffer getReadBuffer() { return this.readBuffer; } @NotNull public final Buffer getReceiveBuffer() { return this.receiveBuffer; } @Nullable public final Headers getTrailers() { return this.trailers; } @Override // okio.Source public long read(@NotNull Buffer sink, long byteCount) throws IOException { IOException errorException; boolean z10; long j10; g.i(sink, "sink"); long j11 = 0; if (byteCount < 0) { throw new IllegalArgumentException(u1.i("byteCount < 0: ", byteCount).toString()); } while (true) { Http2Stream http2Stream = Http2Stream.this; synchronized (http2Stream) { http2Stream.getReadTimeout().enter(); try { if (http2Stream.getErrorCode$okhttp() == null || this.finished) { errorException = null; } else { errorException = http2Stream.getErrorException(); if (errorException == null) { ErrorCode errorCode$okhttp = http2Stream.getErrorCode$okhttp(); g.f(errorCode$okhttp); errorException = new StreamResetException(errorCode$okhttp); } } if (this.closed) { throw new IOException("stream closed"); } z10 = false; if (this.readBuffer.size() > j11) { Buffer buffer = this.readBuffer; j10 = buffer.read(sink, Math.min(byteCount, buffer.size())); http2Stream.setReadBytesTotal$okhttp(http2Stream.getReadBytesTotal() + j10); long readBytesTotal = http2Stream.getReadBytesTotal() - http2Stream.getReadBytesAcknowledged(); if (errorException == null && readBytesTotal >= http2Stream.getConnection().getOkHttpSettings().getInitialWindowSize() / 2) { http2Stream.getConnection().writeWindowUpdateLater$okhttp(http2Stream.getId(), readBytesTotal); http2Stream.setReadBytesAcknowledged$okhttp(http2Stream.getReadBytesTotal()); } } else { if (!this.finished && errorException == null) { http2Stream.waitForIo$okhttp(); z10 = true; } j10 = -1; } http2Stream.getReadTimeout().exitAndThrowIfTimedOut(); } catch (Throwable th) { http2Stream.getReadTimeout().exitAndThrowIfTimedOut(); throw th; } } if (!z10) { if (j10 != -1) { return j10; } if (errorException == null) { return -1L; } throw errorException; } j11 = 0; } } public final void receive$okhttp(@NotNull BufferedSource source, long byteCount) throws IOException { boolean z10; boolean z11; g.i(source, "source"); Http2Stream http2Stream = Http2Stream.this; if (Util.assertionsEnabled && Thread.holdsLock(http2Stream)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } long j10 = byteCount; while (j10 > 0) { synchronized (Http2Stream.this) { z10 = this.finished; z11 = this.readBuffer.size() + j10 > this.maxByteCount; } if (z11) { source.skip(j10); Http2Stream.this.closeLater(ErrorCode.FLOW_CONTROL_ERROR); return; } if (z10) { source.skip(j10); return; } long j11 = source.read(this.receiveBuffer, j10); if (j11 == -1) { throw new EOFException(); } j10 -= j11; Http2Stream http2Stream2 = Http2Stream.this; synchronized (http2Stream2) { try { if (this.closed) { this.receiveBuffer.clear(); } else { boolean z12 = this.readBuffer.size() == 0; this.readBuffer.writeAll(this.receiveBuffer); if (z12) { g.g(http2Stream2, "null cannot be cast to non-null type java.lang.Object"); http2Stream2.notifyAll(); } } } catch (Throwable th) { throw th; } } } updateConnectionFlowControl(byteCount); } public final void setClosed$okhttp(boolean z10) { this.closed = z10; } public final void setFinished$okhttp(boolean z10) { this.finished = z10; } public final void setTrailers(@Nullable Headers headers) { this.trailers = headers; } @Override // okio.Source @NotNull /* JADX INFO: renamed from: timeout */ public Timeout getTimeout() { return Http2Stream.this.getReadTimeout(); } } @Metadata(d1 = {"\u0000\u0016\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\b\u0010\tJ\b\u0010\u0003\u001a\u00020\u0002H\u0014J\u0012\u0010\u0006\u001a\u00020\u00042\b\u0010\u0005\u001a\u0004\u0018\u00010\u0004H\u0014J\u0006\u0010\u0007\u001a\u00020\u0002¨\u0006\n"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "Lokio/AsyncTimeout;", "Lkd/e;", "timedOut", "Ljava/io/IOException;", "cause", "newTimeoutException", "exitAndThrowIfTimedOut", "", "(Lokhttp3/internal/http2/Http2Stream;)V", "okhttp"}, k = 1, mv = {1, 8, 0}) public final class StreamTimeout extends AsyncTimeout { public StreamTimeout() { } public final void exitAndThrowIfTimedOut() throws IOException { if (exit()) { throw newTimeoutException(null); } } @Override // okio.AsyncTimeout @NotNull public IOException newTimeoutException(@Nullable IOException cause) { SocketTimeoutException socketTimeoutException = new SocketTimeoutException("timeout"); if (cause != null) { socketTimeoutException.initCause(cause); } return socketTimeoutException; } @Override // okio.AsyncTimeout public void timedOut() { Http2Stream.this.closeLater(ErrorCode.CANCEL); Http2Stream.this.getConnection().sendDegradedPingLater$okhttp(); } } public Http2Stream(int i10, @NotNull Http2Connection http2Connection, boolean z10, boolean z11, @Nullable Headers headers) { g.i(http2Connection, "connection"); this.id = i10; this.connection = http2Connection; this.writeBytesMaximum = http2Connection.getPeerSettings().getInitialWindowSize(); ArrayDeque arrayDeque = new ArrayDeque<>(); this.headersQueue = arrayDeque; this.source = new FramingSource(http2Connection.getOkHttpSettings().getInitialWindowSize(), z11); this.sink = new FramingSink(z10); this.readTimeout = new StreamTimeout(); this.writeTimeout = new StreamTimeout(); if (headers == null) { if (!isLocallyInitiated()) { throw new IllegalStateException("remotely-initiated streams should have headers".toString()); } } else { if (!(!isLocallyInitiated())) { throw new IllegalStateException("locally-initiated streams shouldn't have headers yet".toString()); } arrayDeque.add(headers); } } private final boolean closeInternal(ErrorCode errorCode, IOException errorException) { if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } synchronized (this) { if (this.errorCode != null) { return false; } this.errorCode = errorCode; this.errorException = errorException; notifyAll(); if (this.source.getFinished()) { if (this.sink.getFinished()) { return false; } } this.connection.removeStream$okhttp(this.id); return true; } } public final void addBytesToWriteWindow(long j10) { this.writeBytesMaximum += j10; if (j10 > 0) { notifyAll(); } } public final void cancelStreamIfNecessary$okhttp() throws IOException { boolean z10; boolean zIsOpen; if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } synchronized (this) { try { z10 = !this.source.getFinished() && this.source.getClosed() && (this.sink.getFinished() || this.sink.getClosed()); zIsOpen = isOpen(); } catch (Throwable th) { throw th; } } if (z10) { close(ErrorCode.CANCEL, null); } else { if (zIsOpen) { return; } this.connection.removeStream$okhttp(this.id); } } public final void checkOutNotClosed$okhttp() throws IOException { if (this.sink.getClosed()) { throw new IOException("stream closed"); } if (this.sink.getFinished()) { throw new IOException("stream finished"); } if (this.errorCode != null) { IOException iOException = this.errorException; if (iOException != null) { throw iOException; } ErrorCode errorCode = this.errorCode; g.f(errorCode); throw new StreamResetException(errorCode); } } public final void close(@NotNull ErrorCode errorCode, @Nullable IOException iOException) throws IOException { g.i(errorCode, "rstStatusCode"); if (closeInternal(errorCode, iOException)) { this.connection.writeSynReset$okhttp(this.id, errorCode); } } public final void closeLater(@NotNull ErrorCode errorCode) { g.i(errorCode, "errorCode"); if (closeInternal(errorCode, null)) { this.connection.writeSynResetLater$okhttp(this.id, errorCode); } } public final void enqueueTrailers(@NotNull Headers headers) { g.i(headers, "trailers"); synchronized (this) { if (!(!this.sink.getFinished())) { throw new IllegalStateException("already finished".toString()); } if (headers.size() == 0) { throw new IllegalArgumentException("trailers.size() == 0".toString()); } this.sink.setTrailers(headers); } } @NotNull public final Http2Connection getConnection() { return this.connection; } @Nullable public final synchronized ErrorCode getErrorCode$okhttp() { return this.errorCode; } @Nullable /* JADX INFO: renamed from: getErrorException$okhttp, reason: from getter */ public final IOException getErrorException() { return this.errorException; } public final int getId() { return this.id; } public final long getReadBytesAcknowledged() { return this.readBytesAcknowledged; } public final long getReadBytesTotal() { return this.readBytesTotal; } @NotNull /* JADX INFO: renamed from: getReadTimeout$okhttp, reason: from getter */ public final StreamTimeout getReadTimeout() { return this.readTimeout; } @NotNull public final Sink getSink() { synchronized (this) { if (!this.hasResponseHeaders && !isLocallyInitiated()) { throw new IllegalStateException("reply before requesting the sink".toString()); } } return this.sink; } @NotNull /* JADX INFO: renamed from: getSink$okhttp, reason: from getter */ public final FramingSink getSink() { return this.sink; } @NotNull public final Source getSource() { return this.source; } @NotNull /* JADX INFO: renamed from: getSource$okhttp, reason: from getter */ public final FramingSource getSource() { return this.source; } public final long getWriteBytesMaximum() { return this.writeBytesMaximum; } public final long getWriteBytesTotal() { return this.writeBytesTotal; } @NotNull /* JADX INFO: renamed from: getWriteTimeout$okhttp, reason: from getter */ public final StreamTimeout getWriteTimeout() { return this.writeTimeout; } public final boolean isLocallyInitiated() { return this.connection.getClient() == ((this.id & 1) == 1); } public final synchronized boolean isOpen() { try { if (this.errorCode != null) { return false; } if (this.source.getFinished() || this.source.getClosed()) { if (this.sink.getFinished() || this.sink.getClosed()) { if (this.hasResponseHeaders) { return false; } } } return true; } catch (Throwable th) { throw th; } } @NotNull public final Timeout readTimeout() { return this.readTimeout; } public final void receiveData(@NotNull BufferedSource bufferedSource, int i10) throws IOException { g.i(bufferedSource, "source"); if (!Util.assertionsEnabled || !Thread.holdsLock(this)) { this.source.receive$okhttp(bufferedSource, i10); return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } public final void receiveHeaders(@NotNull Headers headers, boolean z10) { boolean zIsOpen; g.i(headers, "headers"); if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } synchronized (this) { try { if (this.hasResponseHeaders && z10) { this.source.setTrailers(headers); } else { this.hasResponseHeaders = true; this.headersQueue.add(headers); } if (z10) { this.source.setFinished$okhttp(true); } zIsOpen = isOpen(); notifyAll(); } catch (Throwable th) { throw th; } } if (zIsOpen) { return; } this.connection.removeStream$okhttp(this.id); } public final synchronized void receiveRstStream(@NotNull ErrorCode errorCode) { g.i(errorCode, "errorCode"); if (this.errorCode == null) { this.errorCode = errorCode; notifyAll(); } } public final void setErrorCode$okhttp(@Nullable ErrorCode errorCode) { this.errorCode = errorCode; } public final void setErrorException$okhttp(@Nullable IOException iOException) { this.errorException = iOException; } public final void setReadBytesAcknowledged$okhttp(long j10) { this.readBytesAcknowledged = j10; } public final void setReadBytesTotal$okhttp(long j10) { this.readBytesTotal = j10; } public final void setWriteBytesMaximum$okhttp(long j10) { this.writeBytesMaximum = j10; } public final void setWriteBytesTotal$okhttp(long j10) { this.writeBytesTotal = j10; } @NotNull public final synchronized Headers takeHeaders() throws IOException { Headers headersRemoveFirst; this.readTimeout.enter(); while (this.headersQueue.isEmpty() && this.errorCode == null) { try { waitForIo$okhttp(); } catch (Throwable th) { this.readTimeout.exitAndThrowIfTimedOut(); throw th; } } this.readTimeout.exitAndThrowIfTimedOut(); if (!(!this.headersQueue.isEmpty())) { IOException iOException = this.errorException; if (iOException != null) { throw iOException; } ErrorCode errorCode = this.errorCode; g.f(errorCode); throw new StreamResetException(errorCode); } headersRemoveFirst = this.headersQueue.removeFirst(); g.h(headersRemoveFirst, "headersQueue.removeFirst()"); return headersRemoveFirst; } @NotNull public final synchronized Headers trailers() throws IOException { Headers trailers; if (!this.source.getFinished() || !this.source.getReceiveBuffer().exhausted() || !this.source.getReadBuffer().exhausted()) { if (this.errorCode == null) { throw new IllegalStateException("too early; can't read the trailers yet"); } IOException iOException = this.errorException; if (iOException != null) { throw iOException; } ErrorCode errorCode = this.errorCode; g.f(errorCode); throw new StreamResetException(errorCode); } trailers = this.source.getTrailers(); if (trailers == null) { trailers = Util.EMPTY_HEADERS; } return trailers; } public final void waitForIo$okhttp() throws InterruptedIOException { try { wait(); } catch (InterruptedException unused) { Thread.currentThread().interrupt(); throw new InterruptedIOException(); } } public final void writeHeaders(@NotNull List
list, boolean z10, boolean z11) throws IOException { boolean z12; g.i(list, "responseHeaders"); if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } synchronized (this) { this.hasResponseHeaders = true; if (z10) { this.sink.setFinished(true); } } if (!z11) { synchronized (this.connection) { z12 = this.connection.getWriteBytesTotal() >= this.connection.getWriteBytesMaximum(); } z11 = z12; } this.connection.writeHeaders$okhttp(this.id, z10, list); if (z11) { this.connection.flush(); } } @NotNull public final Timeout writeTimeout() { return this.writeTimeout; } @Metadata(d1 = {"\u00002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0018\u0002\n\u0002\b\f\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0011\u0012\b\b\u0002\u0010\u000f\u001a\u00020\u0002¢\u0006\u0004\b!\u0010\"J\u0010\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H\u0002J\u0018\u0010\n\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\bH\u0016J\b\u0010\u000b\u001a\u00020\u0004H\u0016J\b\u0010\r\u001a\u00020\fH\u0016J\b\u0010\u000e\u001a\u00020\u0004H\u0016R\"\u0010\u000f\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u000f\u0010\u0010\u001a\u0004\b\u0011\u0010\u0012\"\u0004\b\u0013\u0010\u0014R\u0014\u0010\u0015\u001a\u00020\u00068\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0015\u0010\u0016R$\u0010\u0018\u001a\u0004\u0018\u00010\u00178\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0018\u0010\u0019\u001a\u0004\b\u001a\u0010\u001b\"\u0004\b\u001c\u0010\u001dR\"\u0010\u001e\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u001e\u0010\u0010\u001a\u0004\b\u001f\u0010\u0012\"\u0004\b \u0010\u0014¨\u0006#"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$FramingSink;", "Lokio/Sink;", "", "outFinishedOnLastFrame", "Lkd/e;", "emitFrame", "Lokio/Buffer;", "source", "", "byteCount", "write", "flush", "Lokio/Timeout;", "timeout", "close", "finished", "Z", "getFinished", "()Z", "setFinished", "(Z)V", "sendBuffer", "Lokio/Buffer;", "Lokhttp3/Headers;", "trailers", "Lokhttp3/Headers;", "getTrailers", "()Lokhttp3/Headers;", "setTrailers", "(Lokhttp3/Headers;)V", "closed", "getClosed", "setClosed", "", "(Lokhttp3/internal/http2/Http2Stream;Z)V", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nHttp2Stream.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Stream.kt\nokhttp3/internal/http2/Http2Stream$FramingSink\n+ 2 Util.kt\nokhttp3/internal/Util\n*L\n1#1,688:1\n615#2,4:689\n615#2,4:693\n615#2,4:697\n*S KotlinDebug\n*F\n+ 1 Http2Stream.kt\nokhttp3/internal/http2/Http2Stream$FramingSink\n*L\n528#1:689,4\n573#1:693,4\n589#1:697,4\n*E\n"}) public final class FramingSink implements Sink { private boolean closed; private boolean finished; @NotNull private final Buffer sendBuffer; @Nullable private Headers trailers; public FramingSink(boolean z10) { this.finished = z10; this.sendBuffer = new Buffer(); } private final void emitFrame(boolean z10) throws IOException { long jMin; boolean z11; Http2Stream http2Stream = Http2Stream.this; synchronized (http2Stream) { http2Stream.getWriteTimeout().enter(); while (http2Stream.getWriteBytesTotal() >= http2Stream.getWriteBytesMaximum() && !this.finished && !this.closed && http2Stream.getErrorCode$okhttp() == null) { try { http2Stream.waitForIo$okhttp(); } finally { http2Stream.getWriteTimeout().exitAndThrowIfTimedOut(); } } http2Stream.getWriteTimeout().exitAndThrowIfTimedOut(); http2Stream.checkOutNotClosed$okhttp(); jMin = Math.min(http2Stream.getWriteBytesMaximum() - http2Stream.getWriteBytesTotal(), this.sendBuffer.size()); http2Stream.setWriteBytesTotal$okhttp(http2Stream.getWriteBytesTotal() + jMin); z11 = z10 && jMin == this.sendBuffer.size(); } Http2Stream.this.getWriteTimeout().enter(); try { Http2Stream.this.getConnection().writeData(Http2Stream.this.getId(), z11, this.sendBuffer, jMin); } finally { http2Stream = Http2Stream.this; } } @Override // okio.Sink, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { Http2Stream http2Stream = Http2Stream.this; if (Util.assertionsEnabled && Thread.holdsLock(http2Stream)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } Http2Stream http2Stream2 = Http2Stream.this; synchronized (http2Stream2) { if (this.closed) { return; } boolean z10 = http2Stream2.getErrorCode$okhttp() == null; if (!Http2Stream.this.getSink().finished) { boolean z11 = this.sendBuffer.size() > 0; if (this.trailers != null) { while (this.sendBuffer.size() > 0) { emitFrame(false); } Http2Connection connection = Http2Stream.this.getConnection(); int id2 = Http2Stream.this.getId(); Headers headers = this.trailers; g.f(headers); connection.writeHeaders$okhttp(id2, z10, Util.toHeaderList(headers)); } else if (z11) { while (this.sendBuffer.size() > 0) { emitFrame(true); } } else if (z10) { Http2Stream.this.getConnection().writeData(Http2Stream.this.getId(), true, null, 0L); } } synchronized (Http2Stream.this) { this.closed = true; } Http2Stream.this.getConnection().flush(); Http2Stream.this.cancelStreamIfNecessary$okhttp(); } } @Override // okio.Sink, java.io.Flushable public void flush() throws IOException { Http2Stream http2Stream = Http2Stream.this; if (Util.assertionsEnabled && Thread.holdsLock(http2Stream)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } Http2Stream http2Stream2 = Http2Stream.this; synchronized (http2Stream2) { http2Stream2.checkOutNotClosed$okhttp(); } while (this.sendBuffer.size() > 0) { emitFrame(false); Http2Stream.this.getConnection().flush(); } } public final boolean getClosed() { return this.closed; } public final boolean getFinished() { return this.finished; } @Nullable public final Headers getTrailers() { return this.trailers; } public final void setClosed(boolean z10) { this.closed = z10; } public final void setFinished(boolean z10) { this.finished = z10; } public final void setTrailers(@Nullable Headers headers) { this.trailers = headers; } @Override // okio.Sink @NotNull /* JADX INFO: renamed from: timeout */ public Timeout getTimeout() { return Http2Stream.this.getWriteTimeout(); } @Override // okio.Sink public void write(@NotNull Buffer buffer, long j10) throws IOException { g.i(buffer, "source"); Http2Stream http2Stream = Http2Stream.this; if (!Util.assertionsEnabled || !Thread.holdsLock(http2Stream)) { this.sendBuffer.write(buffer, j10); while (this.sendBuffer.size() >= 16384) { emitFrame(false); } } else { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } } public /* synthetic */ FramingSink(Http2Stream http2Stream, boolean z10, int i10, d dVar) { this((i10 & 1) != 0 ? false : z10); } } }