package okhttp3.internal.http2; import h.i; import h.r; import h.x.d.h; import h.x.d.k; import i.b0; import i.d; import i.d0; import i.e0; import i.f; 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 okhttp3.Headers; import okhttp3.internal.Util; /* JADX INFO: compiled from: Http2Stream.kt */ /* JADX INFO: loaded from: classes.dex */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u008a\u0001\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000b\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\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\f\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0018\u0002\n\u0002\b\u0012\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0011\u0018\u0000 t:\u0004tuvwB3\b\u0000\u0012\u0006\u0010N\u001a\u00020&\u0012\u0006\u0010<\u001a\u00020;\u0012\u0006\u00106\u001a\u00020\u0012\u0012\u0006\u0010+\u001a\u00020\u0012\u0012\b\u0010*\u001a\u0004\u0018\u00010\u0017¢\u0006\u0004\br\u0010sJ\u0015\u0010\u0004\u001a\u00020\u00032\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0004\u0010\u0005J\u000f\u0010\b\u001a\u00020\u0003H\u0000¢\u0006\u0004\b\u0006\u0010\u0007J\u000f\u0010\n\u001a\u00020\u0003H\u0000¢\u0006\u0004\b\t\u0010\u0007J\u001f\u0010\u000f\u001a\u00020\u00032\u0006\u0010\f\u001a\u00020\u000b2\b\u0010\u000e\u001a\u0004\u0018\u00010\r¢\u0006\u0004\b\u000f\u0010\u0010J!\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0011\u001a\u00020\u000b2\b\u0010\u000e\u001a\u0004\u0018\u00010\rH\u0002¢\u0006\u0004\b\u0013\u0010\u0014J\u0015\u0010\u0015\u001a\u00020\u00032\u0006\u0010\u0011\u001a\u00020\u000b¢\u0006\u0004\b\u0015\u0010\u0016J\u0015\u0010\u0019\u001a\u00020\u00032\u0006\u0010\u0018\u001a\u00020\u0017¢\u0006\u0004\b\u0019\u0010\u001aJ\r\u0010\u001c\u001a\u00020\u001b¢\u0006\u0004\b\u001c\u0010\u001dJ\r\u0010\u001f\u001a\u00020\u001e¢\u0006\u0004\b\u001f\u0010 J\r\u0010\"\u001a\u00020!¢\u0006\u0004\b\"\u0010#J\u001d\u0010(\u001a\u00020\u00032\u0006\u0010%\u001a\u00020$2\u0006\u0010'\u001a\u00020&¢\u0006\u0004\b(\u0010)J\u001d\u0010,\u001a\u00020\u00032\u0006\u0010*\u001a\u00020\u00172\u0006\u0010+\u001a\u00020\u0012¢\u0006\u0004\b,\u0010-J\u0015\u0010.\u001a\u00020\u00032\u0006\u0010\u0011\u001a\u00020\u000b¢\u0006\u0004\b.\u0010\u0016J\r\u0010/\u001a\u00020\u0017¢\u0006\u0004\b/\u00100J\r\u0010\u0018\u001a\u00020\u0017¢\u0006\u0004\b\u0018\u00100J\u000f\u00102\u001a\u00020\u0003H\u0000¢\u0006\u0004\b1\u0010\u0007J+\u00108\u001a\u00020\u00032\f\u00105\u001a\b\u0012\u0004\u0012\u000204032\u0006\u00106\u001a\u00020\u00122\u0006\u00107\u001a\u00020\u0012¢\u0006\u0004\b8\u00109J\r\u0010:\u001a\u00020!¢\u0006\u0004\b:\u0010#R\u0019\u0010<\u001a\u00020;8\u0006@\u0006¢\u0006\f\n\u0004\b<\u0010=\u001a\u0004\b>\u0010?R$\u0010\u0011\u001a\u0004\u0018\u00010\u000b8@@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0011\u0010@\u001a\u0004\bA\u0010B\"\u0004\bC\u0010\u0016R$\u0010\u000e\u001a\u0004\u0018\u00010\r8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u000e\u0010D\u001a\u0004\bE\u0010F\"\u0004\bG\u0010HR\u0016\u0010I\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bI\u0010JR\u001c\u0010L\u001a\b\u0012\u0004\u0012\u00020\u00170K8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bL\u0010MR\u0019\u0010N\u001a\u00020&8\u0006@\u0006¢\u0006\f\n\u0004\bN\u0010O\u001a\u0004\bP\u0010QR\u0013\u0010R\u001a\u00020\u00128F@\u0006¢\u0006\u0006\u001a\u0004\bR\u0010SR\u0013\u0010T\u001a\u00020\u00128F@\u0006¢\u0006\u0006\u001a\u0004\bT\u0010SR*\u0010V\u001a\u00020\u00012\u0006\u0010U\u001a\u00020\u00018\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bV\u0010W\u001a\u0004\bX\u0010Y\"\u0004\bZ\u0010\u0005R*\u0010[\u001a\u00020\u00012\u0006\u0010U\u001a\u00020\u00018\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\b[\u0010W\u001a\u0004\b\\\u0010Y\"\u0004\b]\u0010\u0005R \u0010\"\u001a\u00060^R\u00020\u00008\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\"\u0010_\u001a\u0004\b`\u0010aR \u0010c\u001a\u00060bR\u00020\u00008\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bc\u0010d\u001a\u0004\be\u0010fR \u0010%\u001a\u00060gR\u00020\u00008\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b%\u0010h\u001a\u0004\bi\u0010jR*\u0010k\u001a\u00020\u00012\u0006\u0010U\u001a\u00020\u00018\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bk\u0010W\u001a\u0004\bl\u0010Y\"\u0004\bm\u0010\u0005R*\u0010n\u001a\u00020\u00012\u0006\u0010U\u001a\u00020\u00018\u0006@@X\u0086\u000e¢\u0006\u0012\n\u0004\bn\u0010W\u001a\u0004\bo\u0010Y\"\u0004\bp\u0010\u0005R \u0010:\u001a\u00060^R\u00020\u00008\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b:\u0010_\u001a\u0004\bq\u0010a¨\u0006x"}, d2 = {"Lokhttp3/internal/http2/Http2Stream;", "", "delta", "", "addBytesToWriteWindow", "(J)V", "cancelStreamIfNecessary$okhttp", "()V", "cancelStreamIfNecessary", "checkOutNotClosed$okhttp", "checkOutNotClosed", "Lokhttp3/internal/http2/ErrorCode;", "rstStatusCode", "Ljava/io/IOException;", "errorException", "close", "(Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V", "errorCode", "", "closeInternal", "(Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)Z", "closeLater", "(Lokhttp3/internal/http2/ErrorCode;)V", "Lokhttp3/Headers;", "trailers", "enqueueTrailers", "(Lokhttp3/Headers;)V", "Lokio/Sink;", "getSink", "()Lokio/Sink;", "Lokio/Source;", "getSource", "()Lokio/Source;", "Lokio/Timeout;", "readTimeout", "()Lokio/Timeout;", "Lokio/BufferedSource;", "source", "", "length", "receiveData", "(Lokio/BufferedSource;I)V", "headers", "inFinished", "receiveHeaders", "(Lokhttp3/Headers;Z)V", "receiveRstStream", "takeHeaders", "()Lokhttp3/Headers;", "waitForIo$okhttp", "waitForIo", "", "Lokhttp3/internal/http2/Header;", "responseHeaders", "outFinished", "flushHeaders", "writeHeaders", "(Ljava/util/List;ZZ)V", "writeTimeout", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Http2Connection;", "getConnection", "()Lokhttp3/internal/http2/Http2Connection;", "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", "hasResponseHeaders", "Z", "Ljava/util/ArrayDeque;", "headersQueue", "Ljava/util/ArrayDeque;", "id", "I", "getId", "()I", "isLocallyInitiated", "()Z", "isOpen", "", "readBytesAcknowledged", "J", "getReadBytesAcknowledged", "()J", "setReadBytesAcknowledged$okhttp", "readBytesTotal", "getReadBytesTotal", "setReadBytesTotal$okhttp", "Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "getReadTimeout$okhttp", "()Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "Lokhttp3/internal/http2/Http2Stream$FramingSink;", "sink", "Lokhttp3/internal/http2/Http2Stream$FramingSink;", "getSink$okhttp", "()Lokhttp3/internal/http2/Http2Stream$FramingSink;", "Lokhttp3/internal/http2/Http2Stream$FramingSource;", "Lokhttp3/internal/http2/Http2Stream$FramingSource;", "getSource$okhttp", "()Lokhttp3/internal/http2/Http2Stream$FramingSource;", "writeBytesMaximum", "getWriteBytesMaximum", "setWriteBytesMaximum$okhttp", "writeBytesTotal", "getWriteBytesTotal", "setWriteBytesTotal$okhttp", "getWriteTimeout$okhttp", "", "(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V", "Companion", "FramingSink", "FramingSource", "StreamTimeout", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class Http2Stream { public static final Companion Companion = new Companion(null); public static final long EMIT_BUFFER_SIZE = 16384; private final Http2Connection connection; private ErrorCode errorCode; private IOException errorException; private boolean hasResponseHeaders; private final ArrayDeque headersQueue; private final int id; private long readBytesAcknowledged; private long readBytesTotal; private final StreamTimeout readTimeout; private final FramingSink sink; private final FramingSource source; private long writeBytesMaximum; private long writeBytesTotal; private final StreamTimeout writeTimeout; /* JADX INFO: compiled from: Http2Stream.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0002\b\u0005\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\u0004\u0010\u0005R\u0016\u0010\u0002\u001a\u00020\u00018\u0000@\u0000X\u0080T¢\u0006\u0006\n\u0004\b\u0002\u0010\u0003¨\u0006\u0006"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$Companion;", "", "EMIT_BUFFER_SIZE", "J", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Companion { private Companion() { } public /* synthetic */ Companion(h hVar) { this(); } } /* JADX INFO: compiled from: Http2Stream.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000>\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\t\b\u0086\u0004\u0018\u00002\u00020\u0001B\u0019\b\u0000\u0012\u0006\u0010\u001f\u001a\u00020\u0007\u0012\u0006\u0010\u001c\u001a\u00020\u0015¢\u0006\u0004\b.\u0010/J\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004J\u001f\u0010\t\u001a\u00020\u00072\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\t\u0010\nJ\u001f\u0010\u000f\u001a\u00020\u00022\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\b\u001a\u00020\u0007H\u0000¢\u0006\u0004\b\r\u0010\u000eJ\u000f\u0010\u0011\u001a\u00020\u0010H\u0016¢\u0006\u0004\b\u0011\u0010\u0012J\u0017\u0010\u0013\u001a\u00020\u00022\u0006\u0010\t\u001a\u00020\u0007H\u0002¢\u0006\u0004\b\u0013\u0010\u0014R\"\u0010\u0016\u001a\u00020\u00158\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u0016\u0010\u0017\u001a\u0004\b\u0018\u0010\u0019\"\u0004\b\u001a\u0010\u001bR\"\u0010\u001c\u001a\u00020\u00158\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b\u001c\u0010\u0017\u001a\u0004\b\u001d\u0010\u0019\"\u0004\b\u001e\u0010\u001bR\u0016\u0010\u001f\u001a\u00020\u00078\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001f\u0010 R\u0019\u0010!\u001a\u00020\u00058\u0006@\u0006¢\u0006\f\n\u0004\b!\u0010\"\u001a\u0004\b#\u0010$R\u0019\u0010%\u001a\u00020\u00058\u0006@\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-¨\u00060"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$FramingSource;", "Li/d0;", "", "close", "()V", "Lokio/Buffer;", "sink", "", "byteCount", "read", "(Lokio/Buffer;J)J", "Lokio/BufferedSource;", "source", "receive$okhttp", "(Lokio/BufferedSource;J)V", "receive", "Lokio/Timeout;", "timeout", "()Lokio/Timeout;", "updateConnectionFlowControl", "(J)V", "", "closed", "Z", "getClosed$okhttp", "()Z", "setClosed$okhttp", "(Z)V", "finished", "getFinished$okhttp", "setFinished$okhttp", "maxByteCount", "J", "readBuffer", "Lokio/Buffer;", "getReadBuffer", "()Lokio/Buffer;", "receiveBuffer", "getReceiveBuffer", "Lokhttp3/Headers;", "trailers", "Lokhttp3/Headers;", "getTrailers", "()Lokhttp3/Headers;", "setTrailers", "(Lokhttp3/Headers;)V", "", "(Lokhttp3/internal/http2/Http2Stream;JZ)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class FramingSource implements d0 { private boolean closed; private boolean finished; private final long maxByteCount; private Headers trailers; private final f receiveBuffer = new f(); private final f readBuffer = new f(); public FramingSource(long j2, boolean z) { this.maxByteCount = j2; this.finished = z; } private final void updateConnectionFlowControl(long j2) { Http2Stream http2Stream = Http2Stream.this; if (!Util.assertionsEnabled || !Thread.holdsLock(http2Stream)) { Http2Stream.this.getConnection().updateConnectionFlowControl$okhttp(j2); return; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(http2Stream); throw new AssertionError(sb.toString()); } @Override // i.d0, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { long J; synchronized (Http2Stream.this) { this.closed = true; J = this.readBuffer.J(); this.readBuffer.a(); Http2Stream http2Stream = Http2Stream.this; if (http2Stream == null) { throw new NullPointerException("null cannot be cast to non-null type java.lang.Object"); } http2Stream.notifyAll(); r rVar = r.a; } if (J > 0) { updateConnectionFlowControl(J); } Http2Stream.this.cancelStreamIfNecessary$okhttp(); } public final boolean getClosed$okhttp() { return this.closed; } public final boolean getFinished$okhttp() { return this.finished; } public final f getReadBuffer() { return this.readBuffer; } public final f getReceiveBuffer() { return this.receiveBuffer; } public final Headers getTrailers() { return this.trailers; } @Override // i.d0 public long read(f fVar, long j2) throws IOException { IOException errorException$okhttp; long j3; boolean z; k.d(fVar, "sink"); if (!(j2 >= 0)) { throw new IllegalArgumentException(("byteCount < 0: " + j2).toString()); } do { errorException$okhttp = null; synchronized (Http2Stream.this) { Http2Stream.this.getReadTimeout$okhttp().enter(); try { if (Http2Stream.this.getErrorCode$okhttp() != null && (errorException$okhttp = Http2Stream.this.getErrorException$okhttp()) == null) { ErrorCode errorCode$okhttp = Http2Stream.this.getErrorCode$okhttp(); k.b(errorCode$okhttp); errorException$okhttp = new StreamResetException(errorCode$okhttp); } if (this.closed) { throw new IOException("stream closed"); } if (this.readBuffer.J() > 0) { j3 = this.readBuffer.read(fVar, Math.min(j2, this.readBuffer.J())); Http2Stream http2Stream = Http2Stream.this; http2Stream.setReadBytesTotal$okhttp(http2Stream.getReadBytesTotal() + j3); long readBytesTotal = Http2Stream.this.getReadBytesTotal() - Http2Stream.this.getReadBytesAcknowledged(); if (errorException$okhttp == null && readBytesTotal >= Http2Stream.this.getConnection().getOkHttpSettings().getInitialWindowSize() / 2) { Http2Stream.this.getConnection().writeWindowUpdateLater$okhttp(Http2Stream.this.getId(), readBytesTotal); Http2Stream.this.setReadBytesAcknowledged$okhttp(Http2Stream.this.getReadBytesTotal()); } } else if (this.finished || errorException$okhttp != null) { j3 = -1; } else { Http2Stream.this.waitForIo$okhttp(); j3 = -1; z = true; Http2Stream.this.getReadTimeout$okhttp().exitAndThrowIfTimedOut(); r rVar = r.a; } z = false; Http2Stream.this.getReadTimeout$okhttp().exitAndThrowIfTimedOut(); r rVar2 = r.a; } finally { } } } while (z); if (j3 != -1) { updateConnectionFlowControl(j3); return j3; } if (errorException$okhttp == null) { return -1L; } k.b(errorException$okhttp); throw errorException$okhttp; } public final void receive$okhttp(i.h hVar, long j2) throws IOException { boolean z; boolean z2; boolean z3; long J; k.d(hVar, "source"); Http2Stream http2Stream = Http2Stream.this; if (Util.assertionsEnabled && Thread.holdsLock(http2Stream)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(http2Stream); throw new AssertionError(sb.toString()); } while (j2 > 0) { synchronized (Http2Stream.this) { z = this.finished; z2 = true; z3 = this.readBuffer.J() + j2 > this.maxByteCount; r rVar = r.a; } if (z3) { hVar.skip(j2); Http2Stream.this.closeLater(ErrorCode.FLOW_CONTROL_ERROR); return; } if (z) { hVar.skip(j2); return; } long j3 = hVar.read(this.receiveBuffer, j2); if (j3 == -1) { throw new EOFException(); } j2 -= j3; synchronized (Http2Stream.this) { if (this.closed) { J = this.receiveBuffer.J(); this.receiveBuffer.a(); } else { if (this.readBuffer.J() != 0) { z2 = false; } this.readBuffer.e(this.receiveBuffer); if (z2) { Http2Stream http2Stream2 = Http2Stream.this; if (http2Stream2 == null) { throw new NullPointerException("null cannot be cast to non-null type java.lang.Object"); } http2Stream2.notifyAll(); } J = 0; } r rVar2 = r.a; } if (J > 0) { updateConnectionFlowControl(J); } } } public final void setClosed$okhttp(boolean z) { this.closed = z; } public final void setFinished$okhttp(boolean z) { this.finished = z; } public final void setTrailers(Headers headers) { this.trailers = headers; } @Override // i.d0 public e0 timeout() { return Http2Stream.this.getReadTimeout$okhttp(); } } /* JADX INFO: compiled from: Http2Stream.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\n\u0010\u000bJ\r\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0003\u0010\u0004J\u0019\u0010\u0007\u001a\u00020\u00052\b\u0010\u0006\u001a\u0004\u0018\u00010\u0005H\u0014¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\t\u001a\u00020\u0002H\u0014¢\u0006\u0004\b\t\u0010\u0004¨\u0006\f"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$StreamTimeout;", "Li/d;", "", "exitAndThrowIfTimedOut", "()V", "Ljava/io/IOException;", "cause", "newTimeoutException", "(Ljava/io/IOException;)Ljava/io/IOException;", "timedOut", "", "(Lokhttp3/internal/http2/Http2Stream;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class StreamTimeout extends d { public StreamTimeout() { } public final void exitAndThrowIfTimedOut() throws IOException { if (exit()) { throw newTimeoutException(null); } } @Override // i.d protected IOException newTimeoutException(IOException iOException) { SocketTimeoutException socketTimeoutException = new SocketTimeoutException("timeout"); if (iOException != null) { socketTimeoutException.initCause(iOException); } return socketTimeoutException; } @Override // i.d protected void timedOut() { Http2Stream.this.closeLater(ErrorCode.CANCEL); Http2Stream.this.getConnection().sendDegradedPingLater$okhttp(); } } public Http2Stream(int i2, Http2Connection http2Connection, boolean z, boolean z2, Headers headers) { k.d(http2Connection, "connection"); this.id = i2; this.connection = http2Connection; this.writeBytesMaximum = http2Connection.getPeerSettings().getInitialWindowSize(); this.headersQueue = new ArrayDeque<>(); this.source = new FramingSource(this.connection.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".toString()); } } else { if (!(!isLocallyInitiated())) { throw new IllegalStateException("locally-initiated streams shouldn't have headers yet".toString()); } this.headersQueue.add(headers); } } private final boolean closeInternal(ErrorCode errorCode, IOException iOException) { if (Util.assertionsEnabled && Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } synchronized (this) { if (this.errorCode != null) { return false; } if (this.source.getFinished$okhttp() && this.sink.getFinished()) { return false; } this.errorCode = errorCode; this.errorException = iOException; notifyAll(); r rVar = r.a; this.connection.removeStream$okhttp(this.id); return true; } } public final void addBytesToWriteWindow(long j2) { this.writeBytesMaximum += j2; if (j2 > 0) { notifyAll(); } } public final void cancelStreamIfNecessary$okhttp() throws IOException { boolean z; boolean zIsOpen; if (Util.assertionsEnabled && Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } synchronized (this) { z = !this.source.getFinished$okhttp() && this.source.getClosed$okhttp() && (this.sink.getFinished() || this.sink.getClosed()); zIsOpen = isOpen(); r rVar = r.a; } 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; k.b(errorCode); throw new StreamResetException(errorCode); } } public final void close(ErrorCode errorCode, IOException iOException) throws IOException { k.d(errorCode, "rstStatusCode"); if (closeInternal(errorCode, iOException)) { this.connection.writeSynReset$okhttp(this.id, errorCode); } } public final void closeLater(ErrorCode errorCode) { k.d(errorCode, "errorCode"); if (closeInternal(errorCode, null)) { this.connection.writeSynResetLater$okhttp(this.id, errorCode); } } public final void enqueueTrailers(Headers headers) { k.d(headers, "trailers"); synchronized (this) { boolean z = true; if (!(!this.sink.getFinished())) { throw new IllegalStateException("already finished".toString()); } if (headers.size() == 0) { z = false; } if (!z) { throw new IllegalArgumentException("trailers.size() == 0".toString()); } this.sink.setTrailers(headers); r rVar = r.a; } } public final Http2Connection getConnection() { return this.connection; } public final synchronized ErrorCode getErrorCode$okhttp() { return this.errorCode; } public final IOException getErrorException$okhttp() { return this.errorException; } public final int getId() { return this.id; } public final long getReadBytesAcknowledged() { return this.readBytesAcknowledged; } public final long getReadBytesTotal() { return this.readBytesTotal; } public final StreamTimeout getReadTimeout$okhttp() { return this.readTimeout; } public final b0 getSink() { synchronized (this) { if (!(this.hasResponseHeaders || isLocallyInitiated())) { throw new IllegalStateException("reply before requesting the sink".toString()); } r rVar = r.a; } return this.sink; } public final FramingSink getSink$okhttp() { return this.sink; } public final d0 getSource() { return this.source; } public final FramingSource getSource$okhttp() { return this.source; } public final long getWriteBytesMaximum() { return this.writeBytesMaximum; } public final long getWriteBytesTotal() { return this.writeBytesTotal; } public final StreamTimeout getWriteTimeout$okhttp() { return this.writeTimeout; } public final boolean isLocallyInitiated() { return this.connection.getClient$okhttp() == ((this.id & 1) == 1); } public final synchronized boolean isOpen() { if (this.errorCode != null) { return false; } if ((this.source.getFinished$okhttp() || this.source.getClosed$okhttp()) && (this.sink.getFinished() || this.sink.getClosed())) { if (this.hasResponseHeaders) { return false; } } return true; } public final e0 readTimeout() { return this.readTimeout; } public final void receiveData(i.h hVar, int i2) throws IOException { k.d(hVar, "source"); if (!Util.assertionsEnabled || !Thread.holdsLock(this)) { this.source.receive$okhttp(hVar, i2); return; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } public final void receiveHeaders(Headers headers, boolean z) { boolean zIsOpen; k.d(headers, "headers"); if (Util.assertionsEnabled && Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } synchronized (this) { if (this.hasResponseHeaders && z) { this.source.setTrailers(headers); } else { this.hasResponseHeaders = true; this.headersQueue.add(headers); } if (z) { this.source.setFinished$okhttp(true); } zIsOpen = isOpen(); notifyAll(); r rVar = r.a; } if (zIsOpen) { return; } this.connection.removeStream$okhttp(this.id); } public final synchronized void receiveRstStream(ErrorCode errorCode) { k.d(errorCode, "errorCode"); if (this.errorCode == null) { this.errorCode = errorCode; notifyAll(); } } public final void setErrorCode$okhttp(ErrorCode errorCode) { this.errorCode = errorCode; } public final void setErrorException$okhttp(IOException iOException) { this.errorException = iOException; } public final void setReadBytesAcknowledged$okhttp(long j2) { this.readBytesAcknowledged = j2; } public final void setReadBytesTotal$okhttp(long j2) { this.readBytesTotal = j2; } public final void setWriteBytesMaximum$okhttp(long j2) { this.writeBytesMaximum = j2; } public final void setWriteBytesTotal$okhttp(long j2) { this.writeBytesTotal = j2; } 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; k.b(errorCode); throw new StreamResetException(errorCode); } headersRemoveFirst = this.headersQueue.removeFirst(); k.c(headersRemoveFirst, "headersQueue.removeFirst()"); return headersRemoveFirst; } public final synchronized Headers trailers() throws IOException { Headers trailers; if (this.errorCode != null) { IOException iOException = this.errorException; if (iOException != null) { throw iOException; } ErrorCode errorCode = this.errorCode; k.b(errorCode); throw new StreamResetException(errorCode); } if (!(this.source.getFinished$okhttp() && this.source.getReceiveBuffer().B() && this.source.getReadBuffer().B())) { throw new IllegalStateException("too early; can't read the trailers yet".toString()); } 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(List
list, boolean z, boolean z2) throws IOException { boolean z3; k.d(list, "responseHeaders"); if (Util.assertionsEnabled && Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } synchronized (this) { z3 = true; this.hasResponseHeaders = true; if (z) { this.sink.setFinished(true); } r rVar = r.a; } if (!z2) { synchronized (this.connection) { if (this.connection.getWriteBytesTotal() < this.connection.getWriteBytesMaximum()) { z3 = false; } r rVar2 = r.a; } z2 = z3; } this.connection.writeHeaders$okhttp(this.id, z, list); if (z2) { this.connection.flush(); } } public final e0 writeTimeout() { return this.writeTimeout; } /* JADX INFO: compiled from: Http2Stream.kt */ @i(bv = {1, 0, 3}, d1 = {"\u00006\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\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\r\n\u0002\u0018\u0002\n\u0002\b\t\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0011\u0012\b\b\u0002\u0010\u0018\u001a\u00020\u0005¢\u0006\u0004\b$\u0010%J\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004J\u0017\u0010\u0007\u001a\u00020\u00022\u0006\u0010\u0006\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\t\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\t\u0010\u0004J\u000f\u0010\u000b\u001a\u00020\nH\u0016¢\u0006\u0004\b\u000b\u0010\fJ\u001f\u0010\u0011\u001a\u00020\u00022\u0006\u0010\u000e\u001a\u00020\r2\u0006\u0010\u0010\u001a\u00020\u000fH\u0016¢\u0006\u0004\b\u0011\u0010\u0012R\"\u0010\u0013\u001a\u00020\u00058\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0013\u0010\u0014\u001a\u0004\b\u0015\u0010\u0016\"\u0004\b\u0017\u0010\bR\"\u0010\u0018\u001a\u00020\u00058\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0018\u0010\u0014\u001a\u0004\b\u0019\u0010\u0016\"\u0004\b\u001a\u0010\bR\u0016\u0010\u001b\u001a\u00020\r8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001b\u0010\u001cR$\u0010\u001e\u001a\u0004\u0018\u00010\u001d8\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u001e\u0010\u001f\u001a\u0004\b \u0010!\"\u0004\b\"\u0010#¨\u0006&"}, d2 = {"Lokhttp3/internal/http2/Http2Stream$FramingSink;", "Li/b0;", "", "close", "()V", "", "outFinishedOnLastFrame", "emitFrame", "(Z)V", "flush", "Lokio/Timeout;", "timeout", "()Lokio/Timeout;", "Lokio/Buffer;", "source", "", "byteCount", "write", "(Lokio/Buffer;J)V", "closed", "Z", "getClosed", "()Z", "setClosed", "finished", "getFinished", "setFinished", "sendBuffer", "Lokio/Buffer;", "Lokhttp3/Headers;", "trailers", "Lokhttp3/Headers;", "getTrailers", "()Lokhttp3/Headers;", "setTrailers", "(Lokhttp3/Headers;)V", "", "(Lokhttp3/internal/http2/Http2Stream;Z)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class FramingSink implements b0 { private boolean closed; private boolean finished; private final f sendBuffer; private Headers trailers; public FramingSink(boolean z) { this.finished = z; this.sendBuffer = new f(); } private final void emitFrame(boolean z) throws IOException { long jMin; boolean z2; synchronized (Http2Stream.this) { Http2Stream.this.getWriteTimeout$okhttp().enter(); while (Http2Stream.this.getWriteBytesTotal() >= Http2Stream.this.getWriteBytesMaximum() && !this.finished && !this.closed && Http2Stream.this.getErrorCode$okhttp() == null) { try { Http2Stream.this.waitForIo$okhttp(); } finally { } } Http2Stream.this.getWriteTimeout$okhttp().exitAndThrowIfTimedOut(); Http2Stream.this.checkOutNotClosed$okhttp(); jMin = Math.min(Http2Stream.this.getWriteBytesMaximum() - Http2Stream.this.getWriteBytesTotal(), this.sendBuffer.J()); Http2Stream http2Stream = Http2Stream.this; http2Stream.setWriteBytesTotal$okhttp(http2Stream.getWriteBytesTotal() + jMin); z2 = z && jMin == this.sendBuffer.J() && Http2Stream.this.getErrorCode$okhttp() == null; r rVar = r.a; } Http2Stream.this.getWriteTimeout$okhttp().enter(); try { Http2Stream.this.getConnection().writeData(Http2Stream.this.getId(), z2, this.sendBuffer, jMin); } finally { } } @Override // i.b0, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel public void close() throws IOException { Http2Stream http2Stream = Http2Stream.this; if (Util.assertionsEnabled && Thread.holdsLock(http2Stream)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(http2Stream); throw new AssertionError(sb.toString()); } synchronized (Http2Stream.this) { if (this.closed) { return; } boolean z = Http2Stream.this.getErrorCode$okhttp() == null; r rVar = r.a; if (!Http2Stream.this.getSink$okhttp().finished) { boolean z2 = this.sendBuffer.J() > 0; if (this.trailers != null) { while (this.sendBuffer.J() > 0) { emitFrame(false); } Http2Connection connection = Http2Stream.this.getConnection(); int id = Http2Stream.this.getId(); Headers headers = this.trailers; k.b(headers); connection.writeHeaders$okhttp(id, z, Util.toHeaderList(headers)); } else if (z2) { while (this.sendBuffer.J() > 0) { emitFrame(true); } } else if (z) { Http2Stream.this.getConnection().writeData(Http2Stream.this.getId(), true, null, 0L); } } synchronized (Http2Stream.this) { this.closed = true; r rVar2 = r.a; } Http2Stream.this.getConnection().flush(); Http2Stream.this.cancelStreamIfNecessary$okhttp(); } } @Override // i.b0, java.io.Flushable public void flush() throws IOException { Http2Stream http2Stream = Http2Stream.this; if (Util.assertionsEnabled && Thread.holdsLock(http2Stream)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(http2Stream); throw new AssertionError(sb.toString()); } synchronized (Http2Stream.this) { Http2Stream.this.checkOutNotClosed$okhttp(); r rVar = r.a; } while (this.sendBuffer.J() > 0) { emitFrame(false); Http2Stream.this.getConnection().flush(); } } public final boolean getClosed() { return this.closed; } public final boolean getFinished() { return this.finished; } 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(Headers headers) { this.trailers = headers; } @Override // i.b0 public e0 timeout() { return Http2Stream.this.getWriteTimeout$okhttp(); } @Override // i.b0 public void write(f fVar, long j2) throws IOException { k.d(fVar, "source"); Http2Stream http2Stream = Http2Stream.this; if (!Util.assertionsEnabled || !Thread.holdsLock(http2Stream)) { this.sendBuffer.write(fVar, j2); while (this.sendBuffer.J() >= Http2Stream.EMIT_BUFFER_SIZE) { emitFrame(false); } return; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(http2Stream); throw new AssertionError(sb.toString()); } public /* synthetic */ FramingSink(Http2Stream http2Stream, boolean z, int i2, h hVar) { this((i2 & 1) != 0 ? false : z); } } }