.class public final Lokhttp3/internal/http2/Http2Reader$ContinuationSource; .super Ljava/lang/Object; .source "Http2Reader.kt" # interfaces .implements Lokio/Source; # annotations .annotation system Ldalvik/annotation/EnclosingClass; value = Lokhttp3/internal/http2/Http2Reader; .end annotation .annotation system Ldalvik/annotation/InnerClass; accessFlags = 0x19 name = "ContinuationSource" .end annotation .annotation runtime Lkotlin/Metadata; bv = { 0x1, 0x0, 0x3 } d1 = { "\u00004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\u0008\n\u0002\u0008\u0011\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0000\u0008\u0000\u0018\u00002\u00020\u0001B\r\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u00a2\u0006\u0002\u0010\u0004J\u0008\u0010\u0017\u001a\u00020\u0018H\u0016J\u0018\u0010\u0019\u001a\u00020\u001a2\u0006\u0010\u001b\u001a\u00020\u001c2\u0006\u0010\u001d\u001a\u00020\u001aH\u0016J\u0008\u0010\u001e\u001a\u00020\u0018H\u0002J\u0008\u0010\u001f\u001a\u00020 H\u0016R\u001a\u0010\u0005\u001a\u00020\u0006X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u0007\u0010\u0008\"\u0004\u0008\t\u0010\nR\u001a\u0010\u000b\u001a\u00020\u0006X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u000c\u0010\u0008\"\u0004\u0008\r\u0010\nR\u001a\u0010\u000e\u001a\u00020\u0006X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u000f\u0010\u0008\"\u0004\u0008\u0010\u0010\nR\u001a\u0010\u0011\u001a\u00020\u0006X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u0012\u0010\u0008\"\u0004\u0008\u0013\u0010\nR\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001a\u0010\u0014\u001a\u00020\u0006X\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u0015\u0010\u0008\"\u0004\u0008\u0016\u0010\n\u00a8\u0006!" } d2 = { "Lokhttp3/internal/http2/Http2Reader$ContinuationSource;", "Lokio/Source;", "source", "Lokio/BufferedSource;", "(Lokio/BufferedSource;)V", "flags", "", "getFlags", "()I", "setFlags", "(I)V", "left", "getLeft", "setLeft", "length", "getLength", "setLength", "padding", "getPadding", "setPadding", "streamId", "getStreamId", "setStreamId", "close", "", "read", "", "sink", "Lokio/Buffer;", "byteCount", "readContinuationHeader", "timeout", "Lokio/Timeout;", "okhttp" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # instance fields .field private flags:I .field private left:I .field private length:I .field private padding:I .field private final source:Lokio/BufferedSource; .field private streamId:I # direct methods .method public constructor (Lokio/BufferedSource;)V .locals 1 const-string v0, "source" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V .line 323 invoke-direct {p0}, Ljava/lang/Object;->()V iput-object p1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; return-void .end method .method private final readContinuationHeader()V .locals 9 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation iget v0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->streamId:I iget-object v1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; .line 360 invoke-static {v1}, Lokhttp3/internal/Util;->readMedium(Lokio/BufferedSource;)I move-result v1 iput v1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->left:I iput v1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->length:I iget-object v1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; .line 362 invoke-interface {v1}, Lokio/BufferedSource;->readByte()B move-result v1 const/16 v2, 0xff invoke-static {v1, v2}, Lokhttp3/internal/Util;->and(BI)I move-result v1 iget-object v3, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; .line 363 invoke-interface {v3}, Lokio/BufferedSource;->readByte()B move-result v3 invoke-static {v3, v2}, Lokhttp3/internal/Util;->and(BI)I move-result v2 iput v2, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->flags:I .line 364 sget-object v2, Lokhttp3/internal/http2/Http2Reader;->Companion:Lokhttp3/internal/http2/Http2Reader$Companion; invoke-virtual {v2}, Lokhttp3/internal/http2/Http2Reader$Companion;->getLogger()Ljava/util/logging/Logger; move-result-object v2 sget-object v3, Ljava/util/logging/Level;->FINE:Ljava/util/logging/Level; invoke-virtual {v2, v3}, Ljava/util/logging/Logger;->isLoggable(Ljava/util/logging/Level;)Z move-result v2 if-eqz v2, :cond_0 sget-object v2, Lokhttp3/internal/http2/Http2Reader;->Companion:Lokhttp3/internal/http2/Http2Reader$Companion; invoke-virtual {v2}, Lokhttp3/internal/http2/Http2Reader$Companion;->getLogger()Ljava/util/logging/Logger; move-result-object v2 sget-object v3, Lokhttp3/internal/http2/Http2;->INSTANCE:Lokhttp3/internal/http2/Http2; const/4 v4, 0x1 iget v5, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->streamId:I iget v6, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->length:I iget v8, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->flags:I move v7, v1 invoke-virtual/range {v3 .. v8}, Lokhttp3/internal/http2/Http2;->frameLog(ZIIII)Ljava/lang/String; move-result-object v3 invoke-virtual {v2, v3}, Ljava/util/logging/Logger;->fine(Ljava/lang/String;)V :cond_0 iget-object v2, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; .line 365 invoke-interface {v2}, Lokio/BufferedSource;->readInt()I move-result v2 const v3, 0x7fffffff and-int/2addr v2, v3 iput v2, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->streamId:I const/16 p0, 0x9 if-ne v1, p0, :cond_2 if-ne v2, v0, :cond_1 return-void .line 367 :cond_1 new-instance p0, Ljava/io/IOException; const-string v0, "TYPE_CONTINUATION streamId changed" invoke-direct {p0, v0}, Ljava/io/IOException;->(Ljava/lang/String;)V check-cast p0, Ljava/lang/Throwable; throw p0 .line 366 :cond_2 new-instance p0, Ljava/io/IOException; new-instance v0, Ljava/lang/StringBuilder; invoke-direct {v0}, Ljava/lang/StringBuilder;->()V invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object v0 const-string v1, " != TYPE_CONTINUATION" invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {p0, v0}, Ljava/io/IOException;->(Ljava/lang/String;)V check-cast p0, Ljava/lang/Throwable; throw p0 .end method # virtual methods .method public close()V .locals 0 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation return-void .end method .method public final getFlags()I .locals 0 iget p0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->flags:I return p0 .end method .method public final getLeft()I .locals 0 iget p0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->left:I return p0 .end method .method public final getLength()I .locals 0 iget p0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->length:I return p0 .end method .method public final getPadding()I .locals 0 iget p0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->padding:I return p0 .end method .method public final getStreamId()I .locals 0 iget p0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->streamId:I return p0 .end method .method public read(Lokio/Buffer;J)J .locals 6 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const-string v0, "sink" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V :goto_0 iget v0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->left:I const-wide/16 v1, -0x1 if-nez v0, :cond_1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; iget v3, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->padding:I int-to-long v3, v3 .line 337 invoke-interface {v0, v3, v4}, Lokio/BufferedSource;->skip(J)V const/4 v0, 0x0 iput v0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->padding:I iget v0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->flags:I and-int/lit8 v0, v0, 0x4 if-eqz v0, :cond_0 return-wide v1 .line 340 :cond_0 invoke-direct {p0}, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->readContinuationHeader()V goto :goto_0 :cond_1 iget-object v3, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; int-to-long v4, v0 .line 344 invoke-static {p2, p3, v4, v5}, Ljava/lang/Math;->min(JJ)J move-result-wide p2 invoke-interface {v3, p1, p2, p3}, Lokio/BufferedSource;->read(Lokio/Buffer;J)J move-result-wide p1 cmp-long p3, p1, v1 if-nez p3, :cond_2 return-wide v1 :cond_2 iget p3, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->left:I long-to-int v0, p1 sub-int/2addr p3, v0 iput p3, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->left:I return-wide p1 .end method .method public final setFlags(I)V .locals 0 iput p1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->flags:I return-void .end method .method public final setLeft(I)V .locals 0 iput p1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->left:I return-void .end method .method public final setLength(I)V .locals 0 iput p1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->length:I return-void .end method .method public final setPadding(I)V .locals 0 iput p1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->padding:I return-void .end method .method public final setStreamId(I)V .locals 0 iput p1, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->streamId:I return-void .end method .method public timeout()Lokio/Timeout; .locals 0 iget-object p0, p0, Lokhttp3/internal/http2/Http2Reader$ContinuationSource;->source:Lokio/BufferedSource; .line 350 invoke-interface {p0}, Lokio/BufferedSource;->timeout()Lokio/Timeout; move-result-object p0 return-object p0 .end method