package okhttp3.internal.http2; import androidx.media3.container.NalUnitUtil; import androidx.media3.exoplayer.rtsp.SessionDescription; import androidx.media3.extractor.text.ttml.TtmlNode; import defpackage.cr4; import defpackage.ko9; import defpackage.kp6; import defpackage.lg0; import defpackage.mv8; import defpackage.n41; import defpackage.pq6; import defpackage.px8; import defpackage.sh0; import defpackage.tv; import defpackage.uz1; import defpackage.vx8; 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 okhttp3.Headers; import okhttp3.internal.Util; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000\u008e\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\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\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0010\t\n\u0002\b\u001e\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\u0015\u0018\u0000 u2\u00020\u0001:\u0004uvwxB3\b\u0000\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\u0006\u0010\u0007\u001a\u00020\u0006\u0012\u0006\u0010\b\u001a\u00020\u0006\u0012\b\u0010\n\u001a\u0004\u0018\u00010\t¢\u0006\u0004\b\u000b\u0010\fJ\r\u0010\r\u001a\u00020\t¢\u0006\u0004\b\r\u0010\u000eJ\r\u0010\u000f\u001a\u00020\t¢\u0006\u0004\b\u000f\u0010\u000eJ+\u0010\u0015\u001a\u00020\u00142\f\u0010\u0012\u001a\b\u0012\u0004\u0012\u00020\u00110\u00102\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u0013\u001a\u00020\u0006¢\u0006\u0004\b\u0015\u0010\u0016J\u0015\u0010\u0017\u001a\u00020\u00142\u0006\u0010\u000f\u001a\u00020\t¢\u0006\u0004\b\u0017\u0010\u0018J\r\u0010\u001a\u001a\u00020\u0019¢\u0006\u0004\b\u001a\u0010\u001bJ\r\u0010\u001c\u001a\u00020\u0019¢\u0006\u0004\b\u001c\u0010\u001bJ\r\u0010\u001e\u001a\u00020\u001d¢\u0006\u0004\b\u001e\u0010\u001fJ\r\u0010!\u001a\u00020 ¢\u0006\u0004\b!\u0010\"J\u001f\u0010'\u001a\u00020\u00142\u0006\u0010$\u001a\u00020#2\b\u0010&\u001a\u0004\u0018\u00010%¢\u0006\u0004\b'\u0010(J\u0015\u0010*\u001a\u00020\u00142\u0006\u0010)\u001a\u00020#¢\u0006\u0004\b*\u0010+J\u001d\u0010/\u001a\u00020\u00142\u0006\u0010-\u001a\u00020,2\u0006\u0010.\u001a\u00020\u0002¢\u0006\u0004\b/\u00100J\u001d\u00101\u001a\u00020\u00142\u0006\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0006¢\u0006\u0004\b1\u00102J\u0015\u00103\u001a\u00020\u00142\u0006\u0010)\u001a\u00020#¢\u0006\u0004\b3\u0010+J\u000f\u00106\u001a\u00020\u0014H\u0000¢\u0006\u0004\b4\u00105J\u0015\u00109\u001a\u00020\u00142\u0006\u00108\u001a\u000207¢\u0006\u0004\b9\u0010:J\u000f\u0010<\u001a\u00020\u0014H\u0000¢\u0006\u0004\b;\u00105J\u000f\u0010>\u001a\u00020\u0014H\u0000¢\u0006\u0004\b=\u00105J!\u0010?\u001a\u00020\u00062\u0006\u0010)\u001a\u00020#2\b\u0010&\u001a\u0004\u0018\u00010%H\u0002¢\u0006\u0004\b?\u0010@R\u0017\u0010\u0003\u001a\u00020\u00028\u0006¢\u0006\f\n\u0004\b\u0003\u0010A\u001a\u0004\bB\u0010CR\u0017\u0010\u0005\u001a\u00020\u00048\u0006¢\u0006\f\n\u0004\b\u0005\u0010D\u001a\u0004\bE\u0010FR*\u0010H\u001a\u0002072\u0006\u0010G\u001a\u0002078\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bH\u0010I\u001a\u0004\bJ\u0010K\"\u0004\bL\u0010:R*\u0010M\u001a\u0002072\u0006\u0010G\u001a\u0002078\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bM\u0010I\u001a\u0004\bN\u0010K\"\u0004\bO\u0010:R*\u0010P\u001a\u0002072\u0006\u0010G\u001a\u0002078\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bP\u0010I\u001a\u0004\bQ\u0010K\"\u0004\bR\u0010:R*\u0010S\u001a\u0002072\u0006\u0010G\u001a\u0002078\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bS\u0010I\u001a\u0004\bT\u0010K\"\u0004\bU\u0010:R\u001a\u0010W\u001a\b\u0012\u0004\u0012\u00020\t0V8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bW\u0010XR\u0016\u0010Y\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bY\u0010ZR\u001e\u0010-\u001a\u00060[R\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b-\u0010\\\u001a\u0004\b]\u0010^R\u001e\u0010`\u001a\u00060_R\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b`\u0010a\u001a\u0004\bb\u0010cR\u001e\u0010\u001a\u001a\u00060dR\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u001a\u0010e\u001a\u0004\bf\u0010gR\u001e\u0010\u001c\u001a\u00060dR\u00020\u00008\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u001c\u0010e\u001a\u0004\bh\u0010gR$\u0010)\u001a\u0004\u0018\u00010#8@@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b)\u0010i\u001a\u0004\bj\u0010k\"\u0004\bl\u0010+R$\u0010&\u001a\u0004\u0018\u00010%8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b&\u0010m\u001a\u0004\bn\u0010o\"\u0004\bp\u0010qR\u0011\u0010r\u001a\u00020\u00068F¢\u0006\u0006\u001a\u0004\br\u0010sR\u0011\u0010t\u001a\u00020\u00068F¢\u0006\u0006\u001a\u0004\bt\u0010s¨\u0006y"}, d2 = {"Lokhttp3/internal/http2/Http2Stream;", "", "", TtmlNode.ATTR_ID, "Lokhttp3/internal/http2/Http2Connection;", "connection", "", "outFinished", "inFinished", "Lokhttp3/Headers;", "headers", "", "(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V", "takeHeaders", "()Lokhttp3/Headers;", "trailers", "", "Lokhttp3/internal/http2/Header;", "responseHeaders", "flushHeaders", "Le6a;", "writeHeaders", "(Ljava/util/List;ZZ)V", "enqueueTrailers", "(Lokhttp3/Headers;)V", "Lko9;", "readTimeout", "()Lko9;", "writeTimeout", "Lpx8;", "getSource", "()Lpx8;", "Lmv8;", "getSink", "()Lmv8;", "Lokhttp3/internal/http2/ErrorCode;", "rstStatusCode", "Ljava/io/IOException;", "errorException", "close", "(Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V", "errorCode", "closeLater", "(Lokhttp3/internal/http2/ErrorCode;)V", "Lsh0;", "source", SessionDescription.ATTR_LENGTH, "receiveData", "(Lsh0;I)V", "receiveHeaders", "(Lokhttp3/Headers;Z)V", "receiveRstStream", "cancelStreamIfNecessary$okhttp", "()V", "cancelStreamIfNecessary", "", "delta", "addBytesToWriteWindow", "(J)V", "checkOutNotClosed$okhttp", "checkOutNotClosed", "waitForIo$okhttp", "waitForIo", "closeInternal", "(Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)Z", "I", "getId", "()I", "Lokhttp3/internal/http2/Http2Connection;", "getConnection", "()Lokhttp3/internal/http2/Http2Connection;", "", "readBytesTotal", "J", "getReadBytesTotal", "()J", "setReadBytesTotal$okhttp", "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", "Ljava/io/IOException;", "getErrorException$okhttp", "()Ljava/io/IOException;", "setErrorException$okhttp", "(Ljava/io/IOException;)V", "isOpen", "()Z", "isLocallyInitiated", "Companion", "FramingSink", "FramingSource", "StreamTimeout", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class Http2Stream { public static final long EMIT_BUFFER_SIZE = 16384; @kp6 private final Http2Connection connection; @pq6 private ErrorCode errorCode; @pq6 private IOException errorException; private boolean hasResponseHeaders; @kp6 private final ArrayDeque headersQueue; private final int id; private long readBytesAcknowledged; private long readBytesTotal; @kp6 private final StreamTimeout readTimeout; @kp6 private final FramingSink sink; @kp6 private final FramingSource source; private long writeBytesMaximum; private long writeBytesTotal; @kp6 private final StreamTimeout writeTimeout; @Metadata(d1 = {"\u0000>\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0010\n\u0002\u0018\u0002\n\u0002\b\n\b\u0086\u0004\u0018\u00002\u00020\u0001B\u0019\b\u0000\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007J\u0017\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0002H\u0002¢\u0006\u0004\b\n\u0010\u000bJ\u001f\u0010\b\u001a\u00020\u00022\u0006\u0010\r\u001a\u00020\f2\u0006\u0010\u000e\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\b\u0010\u000fJ\u001f\u0010\u0014\u001a\u00020\t2\u0006\u0010\u0011\u001a\u00020\u00102\u0006\u0010\u000e\u001a\u00020\u0002H\u0000¢\u0006\u0004\b\u0012\u0010\u0013J\u000f\u0010\u0016\u001a\u00020\u0015H\u0016¢\u0006\u0004\b\u0016\u0010\u0017J\u000f\u0010\u0018\u001a\u00020\tH\u0016¢\u0006\u0004\b\u0018\u0010\u0019R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u001aR\"\u0010\u0005\u001a\u00020\u00048\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0005\u0010\u001b\u001a\u0004\b\u001c\u0010\u001d\"\u0004\b\u001e\u0010\u001fR\u0017\u0010 \u001a\u00020\f8\u0006¢\u0006\f\n\u0004\b \u0010!\u001a\u0004\b\"\u0010#R\u0017\u0010$\u001a\u00020\f8\u0006¢\u0006\f\n\u0004\b$\u0010!\u001a\u0004\b%\u0010#R$\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\u00048\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b-\u0010\u001b\u001a\u0004\b.\u0010\u001d\"\u0004\b/\u0010\u001f¨\u00060"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$FramingSource;", "Lpx8;", "", "maxByteCount", "", "finished", "", "(Lokhttp3/internal/http2/Http2Stream;JZ)V", "read", "Le6a;", "updateConnectionFlowControl", "(J)V", "Llg0;", "sink", "byteCount", "(Llg0;J)J", "Lsh0;", "source", "receive$okhttp", "(Lsh0;J)V", "receive", "Lko9;", "timeout", "()Lko9;", "close", "()V", "J", "Z", "getFinished$okhttp", "()Z", "setFinished$okhttp", "(Z)V", "receiveBuffer", "Llg0;", "getReceiveBuffer", "()Llg0;", "readBuffer", "getReadBuffer", "Lokhttp3/Headers;", "trailers", "Lokhttp3/Headers;", "getTrailers", "()Lokhttp3/Headers;", "setTrailers", "(Lokhttp3/Headers;)V", "closed", "getClosed$okhttp", "setClosed$okhttp", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class FramingSource implements px8 { private boolean closed; private boolean finished; private final long maxByteCount; @pq6 private Headers trailers; @kp6 private final lg0 receiveBuffer = new lg0(); @kp6 private final lg0 readBuffer = new lg0(); public FramingSource(long j, boolean z) { this.maxByteCount = j; this.finished = z; } private final void updateConnectionFlowControl(long read) { Http2Stream http2Stream = Http2Stream.this; if (!Util.assertionsEnabled || !Thread.holdsLock(http2Stream)) { Http2Stream.this.getConnection().updateConnectionFlowControl$okhttp(read); return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { long j; Http2Stream http2Stream = Http2Stream.this; synchronized (http2Stream) { this.closed = true; lg0 lg0Var = this.readBuffer; j = lg0Var.b; lg0Var.a(); cr4.e(http2Stream, "null cannot be cast to non-null type java.lang.Object"); http2Stream.notifyAll(); } if (j > 0) { updateConnectionFlowControl(j); } 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; } @kp6 public final lg0 getReadBuffer() { return this.readBuffer; } @kp6 public final lg0 getReceiveBuffer() { return this.receiveBuffer; } @pq6 public final Headers getTrailers() { return this.trailers; } @Override // defpackage.px8 public long read(@kp6 lg0 sink, long byteCount) throws IOException { IOException errorException; boolean z; long j; cr4.g(sink, "sink"); long j2 = 0; if (byteCount < 0) { throw new IllegalArgumentException(n41.j(byteCount, "byteCount < 0: ").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(); cr4.d(errorCode$okhttp); errorException = new StreamResetException(errorCode$okhttp); } } if (this.closed) { throw new IOException("stream closed"); } lg0 lg0Var = this.readBuffer; long j3 = lg0Var.b; z = false; if (j3 > j2) { j = lg0Var.read(sink, Math.min(byteCount, j3)); http2Stream.setReadBytesTotal$okhttp(http2Stream.getReadBytesTotal() + j); 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(); z = true; } j = -1; } http2Stream.getReadTimeout().exitAndThrowIfTimedOut(); } finally { } } if (!z) { if (j != -1) { return j; } if (errorException == null) { return -1L; } throw errorException; } j2 = 0; } } public final void receive$okhttp(@kp6 sh0 source, long byteCount) throws IOException { boolean z; boolean z2; cr4.g(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 j = byteCount; while (j > 0) { synchronized (Http2Stream.this) { z = this.finished; z2 = this.readBuffer.b + j > this.maxByteCount; } if (z2) { source.skip(j); Http2Stream.this.closeLater(ErrorCode.FLOW_CONTROL_ERROR); return; } if (z) { source.skip(j); return; } long j2 = source.read(this.receiveBuffer, j); if (j2 == -1) { throw new EOFException(); } j -= j2; Http2Stream http2Stream2 = Http2Stream.this; synchronized (http2Stream2) { try { if (this.closed) { this.receiveBuffer.a(); } else { lg0 lg0Var = this.readBuffer; boolean z3 = lg0Var.b == 0; lg0Var.r(this.receiveBuffer); if (z3) { http2Stream2.notifyAll(); } } } catch (Throwable th) { throw th; } } } updateConnectionFlowControl(byteCount); } public final void setClosed$okhttp(boolean z) { this.closed = z; } public final void setFinished$okhttp(boolean z) { this.finished = z; } public final void setTrailers(@pq6 Headers headers) { this.trailers = headers; } @Override // defpackage.px8 @kp6 /* JADX INFO: renamed from: timeout */ public ko9 getTimeout() { return Http2Stream.this.getReadTimeout(); } } @Metadata(d1 = {"\u0000\u001c\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\u0002\u0010\u0003J\u000f\u0010\u0005\u001a\u00020\u0004H\u0014¢\u0006\u0004\b\u0005\u0010\u0006J\u0019\u0010\t\u001a\u00020\u00072\b\u0010\b\u001a\u0004\u0018\u00010\u0007H\u0014¢\u0006\u0004\b\t\u0010\nJ\r\u0010\u000b\u001a\u00020\u0004¢\u0006\u0004\b\u000b\u0010\u0006¨\u0006\f"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "Ltv;", "", "(Lokhttp3/internal/http2/Http2Stream;)V", "Le6a;", "timedOut", "()V", "Ljava/io/IOException;", "cause", "newTimeoutException", "(Ljava/io/IOException;)Ljava/io/IOException;", "exitAndThrowIfTimedOut", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class StreamTimeout extends tv { public StreamTimeout() { } public final void exitAndThrowIfTimedOut() throws IOException { if (exit()) { throw newTimeoutException(null); } } @Override // defpackage.tv @kp6 public IOException newTimeoutException(@pq6 IOException cause) { SocketTimeoutException socketTimeoutException = new SocketTimeoutException("timeout"); if (cause != null) { socketTimeoutException.initCause(cause); } return socketTimeoutException; } @Override // defpackage.tv public void timedOut() { Http2Stream.this.closeLater(ErrorCode.CANCEL); Http2Stream.this.getConnection().sendDegradedPingLater$okhttp(); } } public Http2Stream(int i, @kp6 Http2Connection http2Connection, boolean z, boolean z2, @pq6 Headers headers) { cr4.g(http2Connection, "connection"); this.id = i; this.connection = http2Connection; this.writeBytesMaximum = http2Connection.getPeerSettings().getInitialWindowSize(); ArrayDeque arrayDeque = new ArrayDeque<>(); this.headersQueue = arrayDeque; this.source = new FramingSource(http2Connection.getOkHttpSettings().getInitialWindowSize(), z2); this.sink = new FramingSink(z); this.readTimeout = new StreamTimeout(); this.writeTimeout = new StreamTimeout(); if (headers == null) { if (!isLocallyInitiated()) { throw new IllegalStateException("remotely-initiated streams should have headers"); } } else { if (isLocallyInitiated()) { throw new IllegalStateException("locally-initiated streams shouldn't have headers yet"); } 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 delta) { this.writeBytesMaximum += delta; if (delta > 0) { notifyAll(); } } public final void cancelStreamIfNecessary$okhttp() throws IOException { boolean z; boolean zIsOpen; if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } synchronized (this) { try { z = !this.source.getFinished() && this.source.getClosed() && (this.sink.getFinished() || this.sink.getClosed()); zIsOpen = isOpen(); } catch (Throwable th) { throw th; } } if (z) { 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; cr4.d(errorCode); throw new StreamResetException(errorCode); } } public final void close(@kp6 ErrorCode rstStatusCode, @pq6 IOException errorException) throws IOException { cr4.g(rstStatusCode, "rstStatusCode"); if (closeInternal(rstStatusCode, errorException)) { this.connection.writeSynReset$okhttp(this.id, rstStatusCode); } } public final void closeLater(@kp6 ErrorCode errorCode) { cr4.g(errorCode, "errorCode"); if (closeInternal(errorCode, null)) { this.connection.writeSynResetLater$okhttp(this.id, errorCode); } } public final void enqueueTrailers(@kp6 Headers trailers) { cr4.g(trailers, "trailers"); synchronized (this) { if (this.sink.getFinished()) { throw new IllegalStateException("already finished"); } if (trailers.size() == 0) { throw new IllegalArgumentException("trailers.size() == 0"); } this.sink.setTrailers(trailers); } } @kp6 public final Http2Connection getConnection() { return this.connection; } @pq6 public final synchronized ErrorCode getErrorCode$okhttp() { return this.errorCode; } @pq6 /* 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; } @kp6 /* JADX INFO: renamed from: getReadTimeout$okhttp, reason: from getter */ public final StreamTimeout getReadTimeout() { return this.readTimeout; } @kp6 public final mv8 getSink() { synchronized (this) { if (!this.hasResponseHeaders && !isLocallyInitiated()) { throw new IllegalStateException("reply before requesting the sink"); } } return this.sink; } @kp6 /* JADX INFO: renamed from: getSink$okhttp, reason: from getter */ public final FramingSink getSink() { return this.sink; } @kp6 public final px8 getSource() { return this.source; } @kp6 /* 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; } @kp6 /* 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; } } @kp6 public final ko9 readTimeout() { return this.readTimeout; } public final void receiveData(@kp6 sh0 source, int length) throws IOException { cr4.g(source, "source"); if (!Util.assertionsEnabled || !Thread.holdsLock(this)) { this.source.receive$okhttp(source, length); return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } public final void receiveHeaders(@kp6 Headers headers, boolean inFinished) { boolean zIsOpen; cr4.g(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 && inFinished) { this.source.setTrailers(headers); } else { this.hasResponseHeaders = true; this.headersQueue.add(headers); } if (inFinished) { 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(@kp6 ErrorCode errorCode) { cr4.g(errorCode, "errorCode"); if (this.errorCode == null) { this.errorCode = errorCode; notifyAll(); } } public final void setErrorCode$okhttp(@pq6 ErrorCode errorCode) { this.errorCode = errorCode; } public final void setErrorException$okhttp(@pq6 IOException iOException) { this.errorException = iOException; } public final void setReadBytesAcknowledged$okhttp(long j) { this.readBytesAcknowledged = j; } public final void setReadBytesTotal$okhttp(long j) { this.readBytesTotal = j; } public final void setWriteBytesMaximum$okhttp(long j) { this.writeBytesMaximum = j; } public final void setWriteBytesTotal$okhttp(long j) { this.writeBytesTotal = j; } @kp6 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; cr4.d(errorCode); throw new StreamResetException(errorCode); } headersRemoveFirst = this.headersQueue.removeFirst(); cr4.f(headersRemoveFirst, "headersQueue.removeFirst()"); return headersRemoveFirst; } @kp6 public final synchronized Headers trailers() throws IOException { Headers trailers; if (!this.source.getFinished() || !this.source.getReceiveBuffer().j() || !this.source.getReadBuffer().j()) { 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; cr4.d(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(@kp6 List
responseHeaders, boolean outFinished, boolean flushHeaders) throws IOException { boolean z; cr4.g(responseHeaders, "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 (outFinished) { this.sink.setFinished(true); } } if (!flushHeaders) { synchronized (this.connection) { z = this.connection.getWriteBytesTotal() >= this.connection.getWriteBytesMaximum(); } flushHeaders = z; } this.connection.writeHeaders$okhttp(this.id, outFinished, responseHeaders); if (flushHeaders) { this.connection.flush(); } } @kp6 public final ko9 writeTimeout() { return this.writeTimeout; } @Metadata(d1 = {"\u00006\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\n\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0011\u0012\b\b\u0002\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0017\u0010\b\u001a\u00020\u00072\u0006\u0010\u0006\u001a\u00020\u0002H\u0002¢\u0006\u0004\b\b\u0010\tJ\u001f\u0010\u000e\u001a\u00020\u00072\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\r\u001a\u00020\fH\u0016¢\u0006\u0004\b\u000e\u0010\u000fJ\u000f\u0010\u0010\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\u0010\u0010\u0011J\u000f\u0010\u0013\u001a\u00020\u0012H\u0016¢\u0006\u0004\b\u0013\u0010\u0014J\u000f\u0010\u0015\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\u0015\u0010\u0011R\"\u0010\u0003\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0003\u0010\u0016\u001a\u0004\b\u0017\u0010\u0018\"\u0004\b\u0019\u0010\tR\u0014\u0010\u001a\u001a\u00020\n8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001a\u0010\u001bR$\u0010\u001d\u001a\u0004\u0018\u00010\u001c8\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u001d\u0010\u001e\u001a\u0004\b\u001f\u0010 \"\u0004\b!\u0010\"R\"\u0010#\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b#\u0010\u0016\u001a\u0004\b$\u0010\u0018\"\u0004\b%\u0010\t¨\u0006&"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$FramingSink;", "Lmv8;", "", "finished", "", "(Lokhttp3/internal/http2/Http2Stream;Z)V", "outFinishedOnLastFrame", "Le6a;", "emitFrame", "(Z)V", "Llg0;", "source", "", "byteCount", "write", "(Llg0;J)V", "flush", "()V", "Lko9;", "timeout", "()Lko9;", "close", "Z", "getFinished", "()Z", "setFinished", "sendBuffer", "Llg0;", "Lokhttp3/Headers;", "trailers", "Lokhttp3/Headers;", "getTrailers", "()Lokhttp3/Headers;", "setTrailers", "(Lokhttp3/Headers;)V", "closed", "getClosed", "setClosed", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class FramingSink implements mv8 { private boolean closed; private boolean finished; @kp6 private final lg0 sendBuffer; @pq6 private Headers trailers; public FramingSink(boolean z) { this.finished = z; this.sendBuffer = new lg0(); } /* JADX WARN: Finally extract failed */ private final void emitFrame(boolean outFinishedOnLastFrame) throws IOException { long jMin; boolean z; 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(); } catch (Throwable th) { http2Stream.getWriteTimeout().exitAndThrowIfTimedOut(); throw th; } } http2Stream.getWriteTimeout().exitAndThrowIfTimedOut(); http2Stream.checkOutNotClosed$okhttp(); jMin = Math.min(http2Stream.getWriteBytesMaximum() - http2Stream.getWriteBytesTotal(), this.sendBuffer.b); http2Stream.setWriteBytesTotal$okhttp(http2Stream.getWriteBytesTotal() + jMin); z = outFinishedOnLastFrame && jMin == this.sendBuffer.b; } Http2Stream.this.getWriteTimeout().enter(); try { Http2Stream.this.getConnection().writeData(Http2Stream.this.getId(), z, this.sendBuffer, jMin); } finally { Http2Stream.this.getWriteTimeout().exitAndThrowIfTimedOut(); } } @Override // defpackage.mv8, 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 z = http2Stream2.getErrorCode$okhttp() == null; if (!Http2Stream.this.getSink().finished) { boolean z2 = this.sendBuffer.b > 0; if (this.trailers != null) { while (this.sendBuffer.b > 0) { emitFrame(false); } Http2Connection connection = Http2Stream.this.getConnection(); int id = Http2Stream.this.getId(); Headers headers = this.trailers; cr4.d(headers); connection.writeHeaders$okhttp(id, z, Util.toHeaderList(headers)); } else if (z2) { while (this.sendBuffer.b > 0) { emitFrame(true); } } else if (z) { 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 // defpackage.mv8, 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.b > 0) { emitFrame(false); Http2Stream.this.getConnection().flush(); } } public final boolean getClosed() { return this.closed; } public final boolean getFinished() { return this.finished; } @pq6 public final Headers getTrailers() { return this.trailers; } public final void setClosed(boolean z) { this.closed = z; } public final void setFinished(boolean z) { this.finished = z; } public final void setTrailers(@pq6 Headers headers) { this.trailers = headers; } @Override // defpackage.mv8 @kp6 /* JADX INFO: renamed from: timeout */ public ko9 getB() { return Http2Stream.this.getWriteTimeout(); } @Override // defpackage.mv8 public void write(@kp6 lg0 source, long byteCount) throws IOException { cr4.g(source, "source"); Http2Stream http2Stream = Http2Stream.this; if (!Util.assertionsEnabled || !Thread.holdsLock(http2Stream)) { this.sendBuffer.write(source, byteCount); while (this.sendBuffer.b >= 16384) { emitFrame(false); } } else { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + http2Stream); } } public /* synthetic */ FramingSink(Http2Stream http2Stream, boolean z, int i, uz1 uz1Var) { this((i & 1) != 0 ? false : z); } } }