.class public final Lokhttp3/internal/ws/WebSocketReader; .super Ljava/lang/Object; .source "WebSocketReader.kt" # interfaces .implements Ljava/io/Closeable; # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lokhttp3/internal/ws/WebSocketReader$FrameCallback; } .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nWebSocketReader.kt\nKotlin\n*S Kotlin\n*F\n+ 1 WebSocketReader.kt\nokhttp3/internal/ws/WebSocketReader\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n*L\n1#1,298:1\n1#2:299\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = {} d1 = { "\u0000H\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0007\n\u0002\u0010\u000b\n\u0002\u0008\u0002\n\u0002\u0010\u0008\n\u0002\u0008\u0002\n\u0002\u0010\t\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\u0012\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0008\u0018\u00002\u00020\u0001:\u0001)B/\u0012\u0006\u0010\u001c\u001a\u00020\n\u0012\u0006\u0010#\u001a\u00020\"\u0012\u0006\u0010\u001e\u001a\u00020\u001d\u0012\u0006\u0010 \u001a\u00020\n\u0012\u0006\u0010!\u001a\u00020\n\u00a2\u0006\u0004\u0008\'\u0010(J\u0008\u0010\u0003\u001a\u00020\u0002H\u0002J\u0008\u0010\u0004\u001a\u00020\u0002H\u0002J\u0008\u0010\u0005\u001a\u00020\u0002H\u0002J\u0008\u0010\u0006\u001a\u00020\u0002H\u0002J\u0008\u0010\u0007\u001a\u00020\u0002H\u0002J\u0006\u0010\u0008\u001a\u00020\u0002J\u0008\u0010\t\u001a\u00020\u0002H\u0016R\u0016\u0010\u000b\u001a\u00020\n8\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u000b\u0010\u000cR\u0016\u0010\u000e\u001a\u00020\r8\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u000e\u0010\u000fR\u0016\u0010\u0011\u001a\u00020\u00108\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u0011\u0010\u0012R\u0016\u0010\u0013\u001a\u00020\n8\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u0013\u0010\u000cR\u0016\u0010\u0014\u001a\u00020\n8\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u0014\u0010\u000cR\u0016\u0010\u0015\u001a\u00020\n8\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u0015\u0010\u000cR\u0018\u0010\u0017\u001a\u0004\u0018\u00010\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008\u0017\u0010\u0018R\u0016\u0010\u001a\u001a\u0004\u0018\u00010\u00198\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u001a\u0010\u001bR\u0014\u0010\u001c\u001a\u00020\n8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u001c\u0010\u000cR\u0014\u0010\u001e\u001a\u00020\u001d8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u001e\u0010\u001fR\u0014\u0010 \u001a\u00020\n8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008 \u0010\u000cR\u0014\u0010!\u001a\u00020\n8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008!\u0010\u000cR\u0017\u0010#\u001a\u00020\"8\u0006\u00a2\u0006\u000c\n\u0004\u0008#\u0010$\u001a\u0004\u0008%\u0010&\u00a8\u0006*" } d2 = { "Lokhttp3/internal/ws/WebSocketReader;", "Ljava/io/Closeable;", "Lkotlin/d1;", "readHeader", "readControlFrame", "readMessageFrame", "readUntilNonControlFrame", "readMessage", "processNextFrame", "close", "", "closed", "Z", "", "opcode", "I", "", "frameLength", "J", "isFinalFrame", "isControlFrame", "readingCompressedMessage", "Lokhttp3/internal/ws/MessageInflater;", "messageInflater", "Lokhttp3/internal/ws/MessageInflater;", "", "maskKey", "[B", "isClient", "Lokhttp3/internal/ws/WebSocketReader$FrameCallback;", "frameCallback", "Lokhttp3/internal/ws/WebSocketReader$FrameCallback;", "perMessageDeflate", "noContextTakeover", "Lzj/o;", "source", "Lzj/o;", "getSource", "()Lzj/o;", "", "(ZLzj/o;Lokhttp3/internal/ws/WebSocketReader$FrameCallback;ZZ)V", "FrameCallback", "okhttp" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # instance fields .field private closed:Z .field private final controlFrameBuffer:Lzj/m; .field private final frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; .field private frameLength:J .field private final isClient:Z .field private isControlFrame:Z .field private isFinalFrame:Z .field private final maskCursor:Lzj/m$a; .field private final maskKey:[B .field private final messageFrameBuffer:Lzj/m; .field private messageInflater:Lokhttp3/internal/ws/MessageInflater; .field private final noContextTakeover:Z .field private opcode:I .field private final perMessageDeflate:Z .field private readingCompressedMessage:Z .field private final source:Lzj/o; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field # direct methods .method public constructor (ZLzj/o;Lokhttp3/internal/ws/WebSocketReader$FrameCallback;ZZ)V .locals 1 .param p2 # Lzj/o; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p3 # Lokhttp3/internal/ws/WebSocketReader$FrameCallback; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "source" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "frameCallback" invoke-static {p3, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V iput-boolean p1, p0, Lokhttp3/internal/ws/WebSocketReader;->isClient:Z iput-object p2, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; iput-object p3, p0, Lokhttp3/internal/ws/WebSocketReader;->frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; iput-boolean p4, p0, Lokhttp3/internal/ws/WebSocketReader;->perMessageDeflate:Z iput-boolean p5, p0, Lokhttp3/internal/ws/WebSocketReader;->noContextTakeover:Z .line 2 new-instance p2, Lzj/m; invoke-direct {p2}, Lzj/m;->()V iput-object p2, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; .line 3 new-instance p2, Lzj/m; invoke-direct {p2}, Lzj/m;->()V iput-object p2, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; const/4 p2, 0x0 if-eqz p1, :cond_0 move-object p3, p2 goto :goto_0 :cond_0 const/4 p3, 0x4 new-array p3, p3, [B .line 4 :goto_0 iput-object p3, p0, Lokhttp3/internal/ws/WebSocketReader;->maskKey:[B if-eqz p1, :cond_1 goto :goto_1 .line 5 :cond_1 new-instance p2, Lzj/m$a; invoke-direct {p2}, Lzj/m$a;->()V :goto_1 iput-object p2, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; return-void .end method .method private final readControlFrame()V .locals 8 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 iget-wide v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J const-wide/16 v2, 0x0 cmp-long v4, v0, v2 if-lez v4, :cond_0 .line 2 iget-object v4, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; iget-object v5, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; invoke-interface {v4, v5, v0, v1}, Lzj/o;->i1(Lzj/m;J)V .line 3 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->isClient:Z if-nez v0, :cond_0 .line 4 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; invoke-static {v1}, Lkotlin/jvm/internal/f0;->m(Ljava/lang/Object;)V invoke-virtual {v0, v1}, Lzj/m;->B1(Lzj/m$a;)Lzj/m$a; .line 5 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; invoke-virtual {v0, v2, v3}, Lzj/m$a;->d(J)I .line 6 sget-object v0, Lokhttp3/internal/ws/WebSocketProtocol;->INSTANCE:Lokhttp3/internal/ws/WebSocketProtocol; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; iget-object v4, p0, Lokhttp3/internal/ws/WebSocketReader;->maskKey:[B invoke-static {v4}, Lkotlin/jvm/internal/f0;->m(Ljava/lang/Object;)V invoke-virtual {v0, v1, v4}, Lokhttp3/internal/ws/WebSocketProtocol;->toggleMask(Lzj/m$a;[B)V .line 7 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; invoke-virtual {v0}, Lzj/m$a;->close()V .line 8 :cond_0 iget v0, p0, Lokhttp3/internal/ws/WebSocketReader;->opcode:I packed-switch v0, :pswitch_data_0 .line 9 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Unknown control opcode: " invoke-static {v1}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v1 iget v2, p0, Lokhttp3/internal/ws/WebSocketReader;->opcode:I invoke-static {v2}, Lokhttp3/internal/Util;->toHexString(I)Ljava/lang/String; move-result-object v2 invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 .line 10 :pswitch_0 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->d1()Lokio/ByteString; move-result-object v1 invoke-interface {v0, v1}, Lokhttp3/internal/ws/WebSocketReader$FrameCallback;->onReadPong(Lokio/ByteString;)V goto :goto_1 .line 11 :pswitch_1 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->d1()Lokio/ByteString; move-result-object v1 invoke-interface {v0, v1}, Lokhttp3/internal/ws/WebSocketReader$FrameCallback;->onReadPing(Lokio/ByteString;)V goto :goto_1 :pswitch_2 const/16 v0, 0x3ed .line 12 iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->size()J move-result-wide v4 const-wide/16 v6, 0x1 cmp-long v1, v4, v6 if-eqz v1, :cond_3 cmp-long v1, v4, v2 if-eqz v1, :cond_2 .line 13 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; invoke-virtual {v0}, Lzj/m;->readShort()S move-result v0 .line 14 iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->controlFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->q1()Ljava/lang/String; move-result-object v1 .line 15 sget-object v2, Lokhttp3/internal/ws/WebSocketProtocol;->INSTANCE:Lokhttp3/internal/ws/WebSocketProtocol; invoke-virtual {v2, v0}, Lokhttp3/internal/ws/WebSocketProtocol;->closeCodeExceptionMessage(I)Ljava/lang/String; move-result-object v2 if-nez v2, :cond_1 goto :goto_0 .line 16 :cond_1 new-instance v0, Ljava/net/ProtocolException; invoke-direct {v0, v2}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :cond_2 const-string v1, "" .line 17 :goto_0 iget-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; invoke-interface {v2, v0, v1}, Lokhttp3/internal/ws/WebSocketReader$FrameCallback;->onReadClose(ILjava/lang/String;)V const/4 v0, 0x1 .line 18 iput-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->closed:Z :goto_1 return-void .line 19 :cond_3 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Malformed close payload length of 1." invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 nop :pswitch_data_0 .packed-switch 0x8 :pswitch_2 :pswitch_1 :pswitch_0 .end packed-switch .end method .method private final readHeader()V .locals 8 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException;, Ljava/net/ProtocolException; } .end annotation .line 1 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->closed:Z if-nez v0, :cond_16 .line 2 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v0}, Lzj/m0;->timeout()Lzj/o0; move-result-object v0 invoke-virtual {v0}, Lzj/o0;->timeoutNanos()J move-result-wide v0 .line 3 iget-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v2}, Lzj/m0;->timeout()Lzj/o0; move-result-object v2 invoke-virtual {v2}, Lzj/o0;->clearTimeout()Lzj/o0; .line 4 :try_start_0 iget-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v2}, Lzj/o;->readByte()B move-result v2 const/16 v3, 0xff invoke-static {v2, v3}, Lokhttp3/internal/Util;->and(BI)I move-result v2 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 5 iget-object v4, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v4}, Lzj/m0;->timeout()Lzj/o0; move-result-object v4 sget-object v5, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit; invoke-virtual {v4, v0, v1, v5}, Lzj/o0;->timeout(JLjava/util/concurrent/TimeUnit;)Lzj/o0; and-int/lit8 v0, v2, 0xf .line 6 iput v0, p0, Lokhttp3/internal/ws/WebSocketReader;->opcode:I and-int/lit16 v1, v2, 0x80 const/4 v4, 0x0 const/4 v5, 0x1 if-eqz v1, :cond_0 move v1, v5 goto :goto_0 :cond_0 move v1, v4 .line 7 :goto_0 iput-boolean v1, p0, Lokhttp3/internal/ws/WebSocketReader;->isFinalFrame:Z and-int/lit8 v6, v2, 0x8 if-eqz v6, :cond_1 move v6, v5 goto :goto_1 :cond_1 move v6, v4 .line 8 :goto_1 iput-boolean v6, p0, Lokhttp3/internal/ws/WebSocketReader;->isControlFrame:Z if-eqz v6, :cond_3 if-eqz v1, :cond_2 goto :goto_2 .line 9 :cond_2 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Control frames must be final." invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :cond_3 :goto_2 and-int/lit8 v1, v2, 0x40 if-eqz v1, :cond_4 move v1, v5 goto :goto_3 :cond_4 move v1, v4 :goto_3 const-string v6, "Unexpected rsv1 flag" if-eq v0, v5, :cond_6 const/4 v7, 0x2 if-eq v0, v7, :cond_6 if-nez v1, :cond_5 goto :goto_5 .line 10 :cond_5 new-instance v0, Ljava/net/ProtocolException; invoke-direct {v0, v6}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :cond_6 if-eqz v1, :cond_8 .line 11 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->perMessageDeflate:Z if-eqz v0, :cond_7 move v0, v5 goto :goto_4 :cond_7 new-instance v0, Ljava/net/ProtocolException; invoke-direct {v0, v6}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :cond_8 move v0, v4 .line 12 :goto_4 iput-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->readingCompressedMessage:Z :goto_5 and-int/lit8 v0, v2, 0x20 if-eqz v0, :cond_9 move v0, v5 goto :goto_6 :cond_9 move v0, v4 :goto_6 if-nez v0, :cond_15 and-int/lit8 v0, v2, 0x10 if-eqz v0, :cond_a move v0, v5 goto :goto_7 :cond_a move v0, v4 :goto_7 if-nez v0, :cond_14 .line 13 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v0}, Lzj/o;->readByte()B move-result v0 invoke-static {v0, v3}, Lokhttp3/internal/Util;->and(BI)I move-result v0 and-int/lit16 v1, v0, 0x80 if-eqz v1, :cond_b move v4, v5 .line 14 :cond_b iget-boolean v1, p0, Lokhttp3/internal/ws/WebSocketReader;->isClient:Z if-ne v4, v1, :cond_d .line 15 new-instance v0, Ljava/net/ProtocolException; iget-boolean v1, p0, Lokhttp3/internal/ws/WebSocketReader;->isClient:Z if-eqz v1, :cond_c const-string v1, "Server-sent frames must not be masked." goto :goto_8 :cond_c const-string v1, "Client-sent frames must be masked." :goto_8 invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :cond_d const/16 v1, 0x7f and-int/2addr v0, v1 int-to-long v2, v0 .line 16 iput-wide v2, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J const/16 v0, 0x7e int-to-long v5, v0 cmp-long v0, v2, v5 if-nez v0, :cond_e .line 17 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v0}, Lzj/o;->readShort()S move-result v0 const v1, 0xffff invoke-static {v0, v1}, Lokhttp3/internal/Util;->and(SI)I move-result v0 int-to-long v0, v0 iput-wide v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J goto :goto_9 :cond_e int-to-long v0, v1 cmp-long v0, v2, v0 if-nez v0, :cond_10 .line 18 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v0}, Lzj/o;->readLong()J move-result-wide v0 iput-wide v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J const-wide/16 v2, 0x0 cmp-long v0, v0, v2 if-ltz v0, :cond_f goto :goto_9 .line 19 :cond_f new-instance v0, Ljava/net/ProtocolException; const-string v1, "Frame length 0x" .line 20 invoke-static {v1}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v1 iget-wide v2, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J invoke-static {v2, v3}, Lokhttp3/internal/Util;->toHexString(J)Ljava/lang/String; move-result-object v2 invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const-string v2, " > 0x7FFFFFFFFFFFFFFF" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 .line 21 invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 .line 22 :cond_10 :goto_9 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->isControlFrame:Z if-eqz v0, :cond_12 iget-wide v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J const-wide/16 v2, 0x7d cmp-long v0, v0, v2 if-gtz v0, :cond_11 goto :goto_a .line 23 :cond_11 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Control frame must be less than 125B." invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :cond_12 :goto_a if-eqz v4, :cond_13 .line 24 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->maskKey:[B invoke-static {v1}, Lkotlin/jvm/internal/f0;->m(Ljava/lang/Object;)V invoke-interface {v0, v1}, Lzj/o;->readFully([B)V :cond_13 return-void .line 25 :cond_14 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Unexpected rsv3 flag" invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 .line 26 :cond_15 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Unexpected rsv2 flag" invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 :catchall_0 move-exception v2 .line 27 iget-object v3, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; invoke-interface {v3}, Lzj/m0;->timeout()Lzj/o0; move-result-object v3 sget-object v4, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit; invoke-virtual {v3, v0, v1, v4}, Lzj/o0;->timeout(JLjava/util/concurrent/TimeUnit;)Lzj/o0; throw v2 .line 28 :cond_16 new-instance v0, Ljava/io/IOException; const-string v1, "closed" invoke-direct {v0, v1}, Ljava/io/IOException;->(Ljava/lang/String;)V throw v0 .end method .method private final readMessage()V .locals 5 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 :goto_0 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->closed:Z if-nez v0, :cond_3 .line 2 iget-wide v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J const-wide/16 v2, 0x0 cmp-long v2, v0, v2 if-lez v2, :cond_0 .line 3 iget-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; iget-object v3, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; invoke-interface {v2, v3, v0, v1}, Lzj/o;->i1(Lzj/m;J)V .line 4 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->isClient:Z if-nez v0, :cond_0 .line 5 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; invoke-static {v1}, Lkotlin/jvm/internal/f0;->m(Ljava/lang/Object;)V invoke-virtual {v0, v1}, Lzj/m;->B1(Lzj/m$a;)Lzj/m$a; .line 6 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->size()J move-result-wide v1 iget-wide v3, p0, Lokhttp3/internal/ws/WebSocketReader;->frameLength:J sub-long/2addr v1, v3 invoke-virtual {v0, v1, v2}, Lzj/m$a;->d(J)I .line 7 sget-object v0, Lokhttp3/internal/ws/WebSocketProtocol;->INSTANCE:Lokhttp3/internal/ws/WebSocketProtocol; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; iget-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->maskKey:[B invoke-static {v2}, Lkotlin/jvm/internal/f0;->m(Ljava/lang/Object;)V invoke-virtual {v0, v1, v2}, Lokhttp3/internal/ws/WebSocketProtocol;->toggleMask(Lzj/m$a;[B)V .line 8 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->maskCursor:Lzj/m$a; invoke-virtual {v0}, Lzj/m$a;->close()V .line 9 :cond_0 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->isFinalFrame:Z if-eqz v0, :cond_1 return-void .line 10 :cond_1 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readUntilNonControlFrame()V .line 11 iget v0, p0, Lokhttp3/internal/ws/WebSocketReader;->opcode:I if-nez v0, :cond_2 goto :goto_0 .line 12 :cond_2 new-instance v0, Ljava/net/ProtocolException; const-string v1, "Expected continuation opcode. Got: " invoke-static {v1}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v1 iget v2, p0, Lokhttp3/internal/ws/WebSocketReader;->opcode:I invoke-static {v2}, Lokhttp3/internal/Util;->toHexString(I)Ljava/lang/String; move-result-object v2 invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 invoke-direct {v0, v1}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v0 .line 13 :cond_3 new-instance v0, Ljava/io/IOException; const-string v1, "closed" invoke-direct {v0, v1}, Ljava/io/IOException;->(Ljava/lang/String;)V throw v0 .end method .method private final readMessageFrame()V .locals 4 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 iget v0, p0, Lokhttp3/internal/ws/WebSocketReader;->opcode:I const/4 v1, 0x1 if-eq v0, v1, :cond_1 const/4 v2, 0x2 if-ne v0, v2, :cond_0 goto :goto_0 .line 2 :cond_0 new-instance v1, Ljava/net/ProtocolException; const-string v2, "Unknown opcode: " invoke-static {v2}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v2 invoke-static {v0}, Lokhttp3/internal/Util;->toHexString(I)Ljava/lang/String; move-result-object v0 invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {v1, v0}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V throw v1 .line 3 :cond_1 :goto_0 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readMessage()V .line 4 iget-boolean v2, p0, Lokhttp3/internal/ws/WebSocketReader;->readingCompressedMessage:Z if-eqz v2, :cond_3 .line 5 iget-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->messageInflater:Lokhttp3/internal/ws/MessageInflater; if-eqz v2, :cond_2 goto :goto_1 .line 6 :cond_2 new-instance v2, Lokhttp3/internal/ws/MessageInflater; iget-boolean v3, p0, Lokhttp3/internal/ws/WebSocketReader;->noContextTakeover:Z invoke-direct {v2, v3}, Lokhttp3/internal/ws/MessageInflater;->(Z)V iput-object v2, p0, Lokhttp3/internal/ws/WebSocketReader;->messageInflater:Lokhttp3/internal/ws/MessageInflater; .line 7 :goto_1 iget-object v3, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; invoke-virtual {v2, v3}, Lokhttp3/internal/ws/MessageInflater;->inflate(Lzj/m;)V :cond_3 if-ne v0, v1, :cond_4 .line 8 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->q1()Ljava/lang/String; move-result-object v1 invoke-interface {v0, v1}, Lokhttp3/internal/ws/WebSocketReader$FrameCallback;->onReadMessage(Ljava/lang/String;)V goto :goto_2 .line 9 :cond_4 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->frameCallback:Lokhttp3/internal/ws/WebSocketReader$FrameCallback; iget-object v1, p0, Lokhttp3/internal/ws/WebSocketReader;->messageFrameBuffer:Lzj/m; invoke-virtual {v1}, Lzj/m;->d1()Lokio/ByteString; move-result-object v1 invoke-interface {v0, v1}, Lokhttp3/internal/ws/WebSocketReader$FrameCallback;->onReadMessage(Lokio/ByteString;)V :goto_2 return-void .end method .method private final readUntilNonControlFrame()V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 :goto_0 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->closed:Z if-nez v0, :cond_1 .line 2 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readHeader()V .line 3 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->isControlFrame:Z if-nez v0, :cond_0 goto :goto_1 .line 4 :cond_0 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readControlFrame()V goto :goto_0 :cond_1 :goto_1 return-void .end method # virtual methods .method public close()V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->messageInflater:Lokhttp3/internal/ws/MessageInflater; if-eqz v0, :cond_0 invoke-virtual {v0}, Lokhttp3/internal/ws/MessageInflater;->close()V :cond_0 return-void .end method .method public final getSource()Lzj/o; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/ws/WebSocketReader;->source:Lzj/o; return-object v0 .end method .method public final processNextFrame()V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readHeader()V .line 2 iget-boolean v0, p0, Lokhttp3/internal/ws/WebSocketReader;->isControlFrame:Z if-eqz v0, :cond_0 .line 3 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readControlFrame()V goto :goto_0 .line 4 :cond_0 invoke-direct {p0}, Lokhttp3/internal/ws/WebSocketReader;->readMessageFrame()V :goto_0 return-void .end method