.class public final Lokhttp3/internal/http1/Http1ExchangeCodec; .super Ljava/lang/Object; .source "Http1ExchangeCodec.kt" # interfaces .implements Lokhttp3/internal/http/ExchangeCodec; # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lokhttp3/internal/http1/Http1ExchangeCodec$KnownLengthSink;, Lokhttp3/internal/http1/Http1ExchangeCodec$ChunkedSink;, Lokhttp3/internal/http1/Http1ExchangeCodec$AbstractSource;, Lokhttp3/internal/http1/Http1ExchangeCodec$FixedLengthSource;, Lokhttp3/internal/http1/Http1ExchangeCodec$ChunkedSource;, Lokhttp3/internal/http1/Http1ExchangeCodec$UnknownLengthSource;, Lokhttp3/internal/http1/Http1ExchangeCodec$Companion; } .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nHttp1ExchangeCodec.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http1ExchangeCodec.kt\nokhttp3/internal/http1/Http1ExchangeCodec\n*L\n1#1,516:1\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = { 0x1, 0x0, 0x3 } d1 = { "\u0000\u0080\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u000b\n\u0002\u0008\u0002\n\u0002\u0010\u0008\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0007\n\u0002\u0010\u000e\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u000f\u0018\u0000 @2\u00020\u0001:\u0007=>?@ABCB\'\u0012\u0008\u0010\u0002\u001a\u0004\u0018\u00010\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\u0006\u0010\u0006\u001a\u00020\u0007\u0012\u0006\u0010\u0008\u001a\u00020\t\u00a2\u0006\u0002\u0010\nJ\u0008\u0010\u001b\u001a\u00020\u001cH\u0016J\u0018\u0010\u001d\u001a\u00020\u001e2\u0006\u0010\u001f\u001a\u00020\u00172\u0006\u0010 \u001a\u00020\u000eH\u0016J\u0010\u0010!\u001a\u00020\u001c2\u0006\u0010\"\u001a\u00020#H\u0002J\u0008\u0010$\u001a\u00020\u001cH\u0016J\u0008\u0010%\u001a\u00020\u001cH\u0016J\u0008\u0010&\u001a\u00020\u001eH\u0002J\u0010\u0010\'\u001a\u00020(2\u0006\u0010)\u001a\u00020*H\u0002J\u0010\u0010+\u001a\u00020(2\u0006\u0010,\u001a\u00020\u000eH\u0002J\u0008\u0010-\u001a\u00020\u001eH\u0002J\u0008\u0010.\u001a\u00020(H\u0002J\u0010\u0010/\u001a\u00020(2\u0006\u00100\u001a\u00020\u0019H\u0016J\u0008\u00101\u001a\u000202H\u0002J\u0008\u00103\u001a\u00020\u0015H\u0002J\u0012\u00104\u001a\u0004\u0018\u0001052\u0006\u00106\u001a\u00020\u0010H\u0016J\u0010\u00107\u001a\u00020\u000e2\u0006\u00100\u001a\u00020\u0019H\u0016J\u000e\u00108\u001a\u00020\u001c2\u0006\u00100\u001a\u00020\u0019J\u0008\u0010\u0014\u001a\u00020\u0015H\u0016J\u0016\u00109\u001a\u00020\u001c2\u0006\u0010:\u001a\u00020\u00152\u0006\u0010;\u001a\u000202J\u0010\u0010<\u001a\u00020\u001c2\u0006\u0010\u001f\u001a\u00020\u0017H\u0016R\u0010\u0010\u0002\u001a\u0004\u0018\u00010\u0003X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0014\u0010\u0004\u001a\u00020\u0005X\u0096\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008\u000b\u0010\u000cR\u000e\u0010\r\u001a\u00020\u000eX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0011\u0010\u000f\u001a\u00020\u00108F\u00a2\u0006\u0006\u001a\u0004\u0008\u000f\u0010\u0011R\u000e\u0010\u0008\u001a\u00020\tX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0006\u001a\u00020\u0007X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0012\u001a\u00020\u0013X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u0014\u001a\u0004\u0018\u00010\u0015X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0018\u0010\u0016\u001a\u00020\u0010*\u00020\u00178BX\u0082\u0004\u00a2\u0006\u0006\u001a\u0004\u0008\u0016\u0010\u0018R\u0018\u0010\u0016\u001a\u00020\u0010*\u00020\u00198BX\u0082\u0004\u00a2\u0006\u0006\u001a\u0004\u0008\u0016\u0010\u001a\u00a8\u0006D" } d2 = { "Lokhttp3/internal/http1/Http1ExchangeCodec;", "Lokhttp3/internal/http/ExchangeCodec;", "client", "Lokhttp3/OkHttpClient;", "connection", "Lokhttp3/internal/connection/RealConnection;", "source", "Lokio/BufferedSource;", "sink", "Lokio/BufferedSink;", "(Lokhttp3/OkHttpClient;Lokhttp3/internal/connection/RealConnection;Lokio/BufferedSource;Lokio/BufferedSink;)V", "getConnection", "()Lokhttp3/internal/connection/RealConnection;", "headerLimit", "", "isClosed", "", "()Z", "state", "", "trailers", "Lokhttp3/Headers;", "isChunked", "Lokhttp3/Request;", "(Lokhttp3/Request;)Z", "Lokhttp3/Response;", "(Lokhttp3/Response;)Z", "cancel", "", "createRequestBody", "Lokio/Sink;", "request", "contentLength", "detachTimeout", "timeout", "Lokio/ForwardingTimeout;", "finishRequest", "flushRequest", "newChunkedSink", "newChunkedSource", "Lokio/Source;", "url", "Lokhttp3/HttpUrl;", "newFixedLengthSource", "length", "newKnownLengthSink", "newUnknownLengthSource", "openResponseBodySource", "response", "readHeaderLine", "", "readHeaders", "readResponseHeaders", "Lokhttp3/Response$Builder;", "expectContinue", "reportedContentLength", "skipConnectBody", "writeRequest", "headers", "requestLine", "writeRequestHeaders", "AbstractSource", "ChunkedSink", "ChunkedSource", "Companion", "FixedLengthSource", "KnownLengthSink", "UnknownLengthSource", "okhttp" } k = 0x1 mv = { 0x1, 0x1, 0x10 } .end annotation # static fields .field public static final Companion:Lokhttp3/internal/http1/Http1ExchangeCodec$Companion; .field private static final HEADER_LIMIT:I = 0x40000 .field private static final NO_CHUNK_YET:J = -0x1L .field private static final STATE_CLOSED:I = 0x6 .field private static final STATE_IDLE:I = 0x0 .field private static final STATE_OPEN_REQUEST_BODY:I = 0x1 .field private static final STATE_OPEN_RESPONSE_BODY:I = 0x4 .field private static final STATE_READING_RESPONSE_BODY:I = 0x5 .field private static final STATE_READ_RESPONSE_HEADERS:I = 0x3 .field private static final STATE_WRITING_REQUEST_BODY:I = 0x2 # instance fields .field private final client:Lokhttp3/OkHttpClient; .field private final connection:Lokhttp3/internal/connection/RealConnection; .field private headerLimit:J .field private final sink:Lokio/BufferedSink; .field private final source:Lokio/BufferedSource; .field private state:I .field private trailers:Lokhttp3/Headers; # direct methods .method static constructor ()V .registers 2 new-instance v0, Lokhttp3/internal/http1/Http1ExchangeCodec$Companion; const/4 v1, 0x0 invoke-direct {v0, v1}, Lokhttp3/internal/http1/Http1ExchangeCodec$Companion;->(Lkotlin/jvm/internal/DefaultConstructorMarker;)V sput-object v0, Lokhttp3/internal/http1/Http1ExchangeCodec;->Companion:Lokhttp3/internal/http1/Http1ExchangeCodec$Companion; return-void .end method .method public constructor (Lokhttp3/OkHttpClient;Lokhttp3/internal/connection/RealConnection;Lokio/BufferedSource;Lokio/BufferedSink;)V .registers 6 const-string v0, "connection" invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "source" invoke-static {p3, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "sink" invoke-static {p4, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 64 invoke-direct {p0}, Ljava/lang/Object;->()V iput-object p1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->client:Lokhttp3/OkHttpClient; iput-object p2, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->connection:Lokhttp3/internal/connection/RealConnection; iput-object p3, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->source:Lokio/BufferedSource; iput-object p4, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; const/high16 p1, 0x40000 int-to-long p1, p1 .line 73 iput-wide p1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->headerLimit:J return-void .end method .method public static final synthetic access$detachTimeout(Lokhttp3/internal/http1/Http1ExchangeCodec;Lokio/ForwardingTimeout;)V .registers 2 .line 64 invoke-direct {p0, p1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->detachTimeout(Lokio/ForwardingTimeout;)V return-void .end method .method public static final synthetic access$getClient$p(Lokhttp3/internal/http1/Http1ExchangeCodec;)Lokhttp3/OkHttpClient; .registers 1 .line 64 iget-object p0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->client:Lokhttp3/OkHttpClient; return-object p0 .end method .method public static final synthetic access$getSink$p(Lokhttp3/internal/http1/Http1ExchangeCodec;)Lokio/BufferedSink; .registers 1 .line 64 iget-object p0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; return-object p0 .end method .method public static final synthetic access$getSource$p(Lokhttp3/internal/http1/Http1ExchangeCodec;)Lokio/BufferedSource; .registers 1 .line 64 iget-object p0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->source:Lokio/BufferedSource; return-object p0 .end method .method public static final synthetic access$getState$p(Lokhttp3/internal/http1/Http1ExchangeCodec;)I .registers 1 .line 64 iget p0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I return p0 .end method .method public static final synthetic access$getTrailers$p(Lokhttp3/internal/http1/Http1ExchangeCodec;)Lokhttp3/Headers; .registers 1 .line 64 iget-object p0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->trailers:Lokhttp3/Headers; return-object p0 .end method .method public static final synthetic access$readHeaders(Lokhttp3/internal/http1/Http1ExchangeCodec;)Lokhttp3/Headers; .registers 1 .line 64 invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->readHeaders()Lokhttp3/Headers; move-result-object p0 return-object p0 .end method .method public static final synthetic access$setState$p(Lokhttp3/internal/http1/Http1ExchangeCodec;I)V .registers 2 .line 64 iput p1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I return-void .end method .method public static final synthetic access$setTrailers$p(Lokhttp3/internal/http1/Http1ExchangeCodec;Lokhttp3/Headers;)V .registers 2 .line 64 iput-object p1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->trailers:Lokhttp3/Headers; return-void .end method .method private final detachTimeout(Lokio/ForwardingTimeout;)V .registers 4 .line 261 invoke-virtual {p1}, Lokio/ForwardingTimeout;->delegate()Lokio/Timeout; move-result-object v0 .line 262 sget-object v1, Lokio/Timeout;->NONE:Lokio/Timeout; invoke-virtual {p1, v1}, Lokio/ForwardingTimeout;->setDelegate(Lokio/Timeout;)Lokio/ForwardingTimeout; .line 263 invoke-virtual {v0}, Lokio/Timeout;->clearDeadline()Lokio/Timeout; .line 264 invoke-virtual {v0}, Lokio/Timeout;->clearTimeout()Lokio/Timeout; return-void .end method .method private final isChunked(Lokhttp3/Request;)Z .registers 4 .line 79 const-string v0, "Transfer-Encoding" invoke-virtual {p1, v0}, Lokhttp3/Request;->header(Ljava/lang/String;)Ljava/lang/String; move-result-object p1 const/4 v0, 0x1 const-string v1, "chunked" invoke-static {v1, p1, v0}, Lkotlin/text/StringsKt;->equals(Ljava/lang/String;Ljava/lang/String;Z)Z move-result p1 return p1 .end method .method private final isChunked(Lokhttp3/Response;)Z .registers 5 const/4 v0, 0x0 const/4 v1, 0x2 .line 76 const-string v2, "Transfer-Encoding" invoke-static {p1, v2, v0, v1, v0}, Lokhttp3/Response;->header$default(Lokhttp3/Response;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)Ljava/lang/String; move-result-object p1 const/4 v0, 0x1 const-string v1, "chunked" invoke-static {v1, p1, v0}, Lkotlin/text/StringsKt;->equals(Ljava/lang/String;Ljava/lang/String;Z)Z move-result p1 return p1 .end method .method private final newChunkedSink()Lokio/Sink; .registers 3 .line 225 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x1 if-ne v0, v1, :cond_6 goto :goto_7 :cond_6 const/4 v1, 0x0 :goto_7 if-eqz v1, :cond_14 const/4 v0, 0x2 .line 226 iput v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I .line 227 new-instance v0, Lokhttp3/internal/http1/Http1ExchangeCodec$ChunkedSink; invoke-direct {v0, p0}, Lokhttp3/internal/http1/Http1ExchangeCodec$ChunkedSink;->(Lokhttp3/internal/http1/Http1ExchangeCodec;)V check-cast v0, Lokio/Sink; return-object v0 .line 225 :cond_14 new-instance v0, Ljava/lang/StringBuilder; const-string v1, "state: " invoke-direct {v0, v1}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 new-instance v1, Ljava/lang/IllegalStateException; invoke-virtual {v0}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {v1, v0}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast v1, Ljava/lang/Throwable; throw v1 .end method .method private final newChunkedSource(Lokhttp3/HttpUrl;)Lokio/Source; .registers 4 .line 243 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x4 if-ne v0, v1, :cond_7 const/4 v0, 0x1 goto :goto_8 :cond_7 const/4 v0, 0x0 :goto_8 if-eqz v0, :cond_15 const/4 v0, 0x5 .line 244 iput v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I .line 245 new-instance v0, Lokhttp3/internal/http1/Http1ExchangeCodec$ChunkedSource; invoke-direct {v0, p0, p1}, Lokhttp3/internal/http1/Http1ExchangeCodec$ChunkedSource;->(Lokhttp3/internal/http1/Http1ExchangeCodec;Lokhttp3/HttpUrl;)V check-cast v0, Lokio/Source; return-object v0 .line 243 :cond_15 new-instance p1, Ljava/lang/StringBuilder; const-string v0, "state: " invoke-direct {p1, v0}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object p1 invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 new-instance v0, Ljava/lang/IllegalStateException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {v0, p1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast v0, Ljava/lang/Throwable; throw v0 .end method .method private final newFixedLengthSource(J)Lokio/Source; .registers 5 .line 237 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x4 if-ne v0, v1, :cond_7 const/4 v0, 0x1 goto :goto_8 :cond_7 const/4 v0, 0x0 :goto_8 if-eqz v0, :cond_15 const/4 v0, 0x5 .line 238 iput v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I .line 239 new-instance v0, Lokhttp3/internal/http1/Http1ExchangeCodec$FixedLengthSource; invoke-direct {v0, p0, p1, p2}, Lokhttp3/internal/http1/Http1ExchangeCodec$FixedLengthSource;->(Lokhttp3/internal/http1/Http1ExchangeCodec;J)V check-cast v0, Lokio/Source; return-object v0 .line 237 :cond_15 new-instance p1, Ljava/lang/StringBuilder; const-string p2, "state: " invoke-direct {p1, p2}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget p2, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {p1, p2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object p1 invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 new-instance p2, Ljava/lang/IllegalStateException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p2, p1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast p2, Ljava/lang/Throwable; throw p2 .end method .method private final newKnownLengthSink()Lokio/Sink; .registers 3 .line 231 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x1 if-ne v0, v1, :cond_6 goto :goto_7 :cond_6 const/4 v1, 0x0 :goto_7 if-eqz v1, :cond_14 const/4 v0, 0x2 .line 232 iput v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I .line 233 new-instance v0, Lokhttp3/internal/http1/Http1ExchangeCodec$KnownLengthSink; invoke-direct {v0, p0}, Lokhttp3/internal/http1/Http1ExchangeCodec$KnownLengthSink;->(Lokhttp3/internal/http1/Http1ExchangeCodec;)V check-cast v0, Lokio/Sink; return-object v0 .line 231 :cond_14 new-instance v0, Ljava/lang/StringBuilder; const-string v1, "state: " invoke-direct {v0, v1}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 new-instance v1, Ljava/lang/IllegalStateException; invoke-virtual {v0}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {v1, v0}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast v1, Ljava/lang/Throwable; throw v1 .end method .method private final newUnknownLengthSource()Lokio/Source; .registers 3 .line 249 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x4 if-ne v0, v1, :cond_7 const/4 v0, 0x1 goto :goto_8 :cond_7 const/4 v0, 0x0 :goto_8 if-eqz v0, :cond_1c const/4 v0, 0x5 .line 250 iput v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I .line 251 invoke-virtual {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->getConnection()Lokhttp3/internal/connection/RealConnection; move-result-object v0 invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->noNewExchanges()V .line 252 new-instance v0, Lokhttp3/internal/http1/Http1ExchangeCodec$UnknownLengthSource; invoke-direct {v0, p0}, Lokhttp3/internal/http1/Http1ExchangeCodec$UnknownLengthSource;->(Lokhttp3/internal/http1/Http1ExchangeCodec;)V check-cast v0, Lokio/Source; return-object v0 .line 249 :cond_1c new-instance v0, Ljava/lang/StringBuilder; const-string v1, "state: " invoke-direct {v0, v1}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 new-instance v1, Ljava/lang/IllegalStateException; invoke-virtual {v0}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {v1, v0}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast v1, Ljava/lang/Throwable; throw v1 .end method .method private final readHeaderLine()Ljava/lang/String; .registers 6 .line 207 iget-object v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->source:Lokio/BufferedSource; iget-wide v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->headerLimit:J invoke-interface {v0, v1, v2}, Lokio/BufferedSource;->readUtf8LineStrict(J)Ljava/lang/String; move-result-object v0 .line 208 iget-wide v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->headerLimit:J invoke-virtual {v0}, Ljava/lang/String;->length()I move-result v3 int-to-long v3, v3 sub-long/2addr v1, v3 iput-wide v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->headerLimit:J return-object v0 .end method .method private final readHeaders()Lokhttp3/Headers; .registers 4 .line 214 new-instance v0, Lokhttp3/Headers$Builder; invoke-direct {v0}, Lokhttp3/Headers$Builder;->()V .line 216 invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->readHeaderLine()Ljava/lang/String; move-result-object v1 .line 217 :goto_9 move-object v2, v1 check-cast v2, Ljava/lang/CharSequence; invoke-interface {v2}, Ljava/lang/CharSequence;->length()I move-result v2 if-lez v2, :cond_1a .line 218 invoke-virtual {v0, v1}, Lokhttp3/Headers$Builder;->addLenient$okhttp(Ljava/lang/String;)Lokhttp3/Headers$Builder; .line 219 invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->readHeaderLine()Ljava/lang/String; move-result-object v1 goto :goto_9 .line 221 :cond_1a invoke-virtual {v0}, Lokhttp3/Headers$Builder;->build()Lokhttp3/Headers; move-result-object v0 return-object v0 .end method # virtual methods .method public cancel()V .registers 2 .line 104 invoke-virtual {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->getConnection()Lokhttp3/internal/connection/RealConnection; move-result-object v0 invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->cancel()V return-void .end method .method public createRequestBody(Lokhttp3/Request;J)Lokio/Sink; .registers 6 const-string v0, "request" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 93 invoke-virtual {p1}, Lokhttp3/Request;->body()Lokhttp3/RequestBody; move-result-object v0 if-eqz v0, :cond_20 invoke-virtual {p1}, Lokhttp3/Request;->body()Lokhttp3/RequestBody; move-result-object v0 invoke-virtual {v0}, Lokhttp3/RequestBody;->isDuplex()Z move-result v0 if-nez v0, :cond_16 goto :goto_20 :cond_16 new-instance p1, Ljava/net/ProtocolException; .line 94 const-string p2, "Duplex connections are not supported for HTTP/1" .line 93 invoke-direct {p1, p2}, Ljava/net/ProtocolException;->(Ljava/lang/String;)V check-cast p1, Ljava/lang/Throwable; throw p1 .line 95 :cond_20 :goto_20 invoke-direct {p0, p1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->isChunked(Lokhttp3/Request;)Z move-result p1 if-eqz p1, :cond_2b invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newChunkedSink()Lokio/Sink; move-result-object p1 goto :goto_35 :cond_2b const-wide/16 v0, -0x1 cmp-long p1, p2, v0 if-eqz p1, :cond_36 .line 96 invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newKnownLengthSink()Lokio/Sink; move-result-object p1 :goto_35 return-object p1 .line 98 :cond_36 new-instance p1, Ljava/lang/IllegalStateException; .line 99 const-string p2, "Cannot stream a request body without chunked encoding or a known content length!" .line 98 invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast p1, Ljava/lang/Throwable; throw p1 .end method .method public finishRequest()V .registers 2 .line 155 iget-object v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; invoke-interface {v0}, Lokio/BufferedSink;->flush()V return-void .end method .method public flushRequest()V .registers 2 .line 151 iget-object v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; invoke-interface {v0}, Lokio/BufferedSink;->flush()V return-void .end method .method public getConnection()Lokhttp3/internal/connection/RealConnection; .registers 2 .line 68 iget-object v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->connection:Lokhttp3/internal/connection/RealConnection; return-object v0 .end method .method public final isClosed()Z .registers 3 .line 89 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x6 if-ne v0, v1, :cond_7 const/4 v0, 0x1 goto :goto_8 :cond_7 const/4 v0, 0x0 :goto_8 return v0 .end method .method public openResponseBodySource(Lokhttp3/Response;)Lokio/Source; .registers 6 const-string v0, "response" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 132 invoke-static {p1}, Lokhttp3/internal/http/HttpHeaders;->promisesBody(Lokhttp3/Response;)Z move-result v0 if-nez v0, :cond_12 const-wide/16 v0, 0x0 invoke-direct {p0, v0, v1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newFixedLengthSource(J)Lokio/Source; move-result-object p1 goto :goto_38 .line 133 :cond_12 invoke-direct {p0, p1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->isChunked(Lokhttp3/Response;)Z move-result v0 if-eqz v0, :cond_25 invoke-virtual {p1}, Lokhttp3/Response;->request()Lokhttp3/Request; move-result-object p1 invoke-virtual {p1}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl; move-result-object p1 invoke-direct {p0, p1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newChunkedSource(Lokhttp3/HttpUrl;)Lokio/Source; move-result-object p1 goto :goto_38 .line 135 :cond_25 invoke-static {p1}, Lokhttp3/internal/Util;->headersContentLength(Lokhttp3/Response;)J move-result-wide v0 const-wide/16 v2, -0x1 cmp-long p1, v0, v2 if-eqz p1, :cond_34 .line 137 invoke-direct {p0, v0, v1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newFixedLengthSource(J)Lokio/Source; move-result-object p1 goto :goto_38 .line 139 :cond_34 invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newUnknownLengthSource()Lokio/Source; move-result-object p1 :goto_38 return-object p1 .end method .method public readResponseHeaders(Z)Lokhttp3/Response$Builder; .registers 6 .line 173 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x3 const/4 v2, 0x1 if-eq v0, v2, :cond_a if-ne v0, v1, :cond_9 goto :goto_a :cond_9 const/4 v2, 0x0 :cond_a :goto_a if-eqz v2, :cond_78 .line 178 :try_start_c sget-object v0, Lokhttp3/internal/http/StatusLine;->Companion:Lokhttp3/internal/http/StatusLine$Companion; invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->readHeaderLine()Ljava/lang/String; move-result-object v2 invoke-virtual {v0, v2}, Lokhttp3/internal/http/StatusLine$Companion;->parse(Ljava/lang/String;)Lokhttp3/internal/http/StatusLine; move-result-object v0 .line 180 new-instance v2, Lokhttp3/Response$Builder; invoke-direct {v2}, Lokhttp3/Response$Builder;->()V .line 181 iget-object v3, v0, Lokhttp3/internal/http/StatusLine;->protocol:Lokhttp3/Protocol; invoke-virtual {v2, v3}, Lokhttp3/Response$Builder;->protocol(Lokhttp3/Protocol;)Lokhttp3/Response$Builder; move-result-object v2 .line 182 iget v3, v0, Lokhttp3/internal/http/StatusLine;->code:I invoke-virtual {v2, v3}, Lokhttp3/Response$Builder;->code(I)Lokhttp3/Response$Builder; move-result-object v2 .line 183 iget-object v3, v0, Lokhttp3/internal/http/StatusLine;->message:Ljava/lang/String; invoke-virtual {v2, v3}, Lokhttp3/Response$Builder;->message(Ljava/lang/String;)Lokhttp3/Response$Builder; move-result-object v2 .line 184 invoke-direct {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->readHeaders()Lokhttp3/Headers; move-result-object v3 invoke-virtual {v2, v3}, Lokhttp3/Response$Builder;->headers(Lokhttp3/Headers;)Lokhttp3/Response$Builder; move-result-object v2 const/16 v3, 0x64 if-eqz p1, :cond_3f .line 187 iget p1, v0, Lokhttp3/internal/http/StatusLine;->code:I if-ne p1, v3, :cond_3f const/4 v2, 0x0 goto :goto_49 .line 190 :cond_3f iget p1, v0, Lokhttp3/internal/http/StatusLine;->code:I if-ne p1, v3, :cond_46 .line 191 iput v1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I goto :goto_49 :cond_46 const/4 p1, 0x4 .line 195 iput p1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I :try_end_49 .catch Ljava/io/EOFException; {:try_start_c .. :try_end_49} :catch_4a :goto_49 return-object v2 :catch_4a move-exception p1 .line 201 invoke-virtual {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->getConnection()Lokhttp3/internal/connection/RealConnection; move-result-object v0 invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route; move-result-object v0 invoke-virtual {v0}, Lokhttp3/Route;->address()Lokhttp3/Address; move-result-object v0 invoke-virtual {v0}, Lokhttp3/Address;->url()Lokhttp3/HttpUrl; move-result-object v0 invoke-virtual {v0}, Lokhttp3/HttpUrl;->redact()Ljava/lang/String; move-result-object v0 .line 202 new-instance v1, Ljava/io/IOException; new-instance v2, Ljava/lang/StringBuilder; const-string v3, "unexpected end of stream on " invoke-direct {v2, v3}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V invoke-virtual {v2, v0}, 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 check-cast p1, Ljava/lang/Throwable; invoke-direct {v1, v0, p1}, Ljava/io/IOException;->(Ljava/lang/String;Ljava/lang/Throwable;)V check-cast v1, Ljava/lang/Throwable; throw v1 .line 174 :cond_78 new-instance p1, Ljava/lang/StringBuilder; const-string v0, "state: " invoke-direct {p1, v0}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object p1 invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 .line 173 new-instance v0, Ljava/lang/IllegalStateException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {v0, p1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast v0, Ljava/lang/Throwable; throw v0 .end method .method public reportedContentLength(Lokhttp3/Response;)J .registers 4 const-string v0, "response" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 124 invoke-static {p1}, Lokhttp3/internal/http/HttpHeaders;->promisesBody(Lokhttp3/Response;)Z move-result v0 if-nez v0, :cond_e const-wide/16 v0, 0x0 goto :goto_1b .line 125 :cond_e invoke-direct {p0, p1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->isChunked(Lokhttp3/Response;)Z move-result v0 if-eqz v0, :cond_17 const-wide/16 v0, -0x1 goto :goto_1b .line 126 :cond_17 invoke-static {p1}, Lokhttp3/internal/Util;->headersContentLength(Lokhttp3/Response;)J move-result-wide v0 :goto_1b return-wide v0 .end method .method public final skipConnectBody(Lokhttp3/Response;)V .registers 6 const-string v0, "response" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 272 invoke-static {p1}, Lokhttp3/internal/Util;->headersContentLength(Lokhttp3/Response;)J move-result-wide v0 const-wide/16 v2, -0x1 cmp-long p1, v0, v2 if-nez p1, :cond_10 return-void .line 274 :cond_10 invoke-direct {p0, v0, v1}, Lokhttp3/internal/http1/Http1ExchangeCodec;->newFixedLengthSource(J)Lokio/Source; move-result-object p1 const v0, 0x7fffffff .line 275 sget-object v1, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; invoke-static {p1, v0, v1}, Lokhttp3/internal/Util;->skipAll(Lokio/Source;ILjava/util/concurrent/TimeUnit;)Z .line 276 invoke-interface {p1}, Lokio/Source;->close()V return-void .end method .method public trailers()Lokhttp3/Headers; .registers 3 .line 146 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x6 if-ne v0, v1, :cond_7 const/4 v0, 0x1 goto :goto_8 :cond_7 const/4 v0, 0x0 :goto_8 if-eqz v0, :cond_12 .line 147 iget-object v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->trailers:Lokhttp3/Headers; if-eqz v0, :cond_f goto :goto_11 :cond_f sget-object v0, Lokhttp3/internal/Util;->EMPTY_HEADERS:Lokhttp3/Headers; :goto_11 return-object v0 .line 146 :cond_12 new-instance v0, Ljava/lang/IllegalStateException; const-string v1, "too early; can\'t read the trailers yet" invoke-virtual {v1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object v1 invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast v0, Ljava/lang/Throwable; throw v0 .end method .method public final writeRequest(Lokhttp3/Headers;Ljava/lang/String;)V .registers 8 const-string v0, "headers" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "requestLine" invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 160 iget v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I const/4 v1, 0x0 const/4 v2, 0x1 if-nez v0, :cond_12 move v0, v2 goto :goto_13 :cond_12 move v0, v1 :goto_13 if-eqz v0, :cond_4c .line 161 iget-object v0, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; invoke-interface {v0, p2}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; move-result-object p2 const-string v0, "\r\n" invoke-interface {p2, v0}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; .line 162 invoke-virtual {p1}, Lokhttp3/Headers;->size()I move-result p2 :goto_24 if-ge v1, p2, :cond_44 .line 163 iget-object v3, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; invoke-virtual {p1, v1}, Lokhttp3/Headers;->name(I)Ljava/lang/String; move-result-object v4 invoke-interface {v3, v4}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; move-result-object v3 .line 164 const-string v4, ": " invoke-interface {v3, v4}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; move-result-object v3 .line 165 invoke-virtual {p1, v1}, Lokhttp3/Headers;->value(I)Ljava/lang/String; move-result-object v4 invoke-interface {v3, v4}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; move-result-object v3 .line 166 invoke-interface {v3, v0}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; add-int/lit8 v1, v1, 0x1 goto :goto_24 .line 168 :cond_44 iget-object p1, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->sink:Lokio/BufferedSink; invoke-interface {p1, v0}, Lokio/BufferedSink;->writeUtf8(Ljava/lang/String;)Lokio/BufferedSink; .line 169 iput v2, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I return-void .line 160 :cond_4c new-instance p1, Ljava/lang/StringBuilder; const-string p2, "state: " invoke-direct {p1, p2}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V iget p2, p0, Lokhttp3/internal/http1/Http1ExchangeCodec;->state:I invoke-virtual {p1, p2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object p1 invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 new-instance p2, Ljava/lang/IllegalStateException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p2, p1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V check-cast p2, Ljava/lang/Throwable; throw p2 .end method .method public writeRequestHeaders(Lokhttp3/Request;)V .registers 5 const-string v0, "request" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 118 sget-object v0, Lokhttp3/internal/http/RequestLine;->INSTANCE:Lokhttp3/internal/http/RequestLine; invoke-virtual {p0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->getConnection()Lokhttp3/internal/connection/RealConnection; move-result-object v1 invoke-virtual {v1}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route; move-result-object v1 invoke-virtual {v1}, Lokhttp3/Route;->proxy()Ljava/net/Proxy; move-result-object v1 invoke-virtual {v1}, Ljava/net/Proxy;->type()Ljava/net/Proxy$Type; move-result-object v1 const-string v2, "connection.route().proxy.type()" invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-virtual {v0, p1, v1}, Lokhttp3/internal/http/RequestLine;->get(Lokhttp3/Request;Ljava/net/Proxy$Type;)Ljava/lang/String; move-result-object v0 .line 119 invoke-virtual {p1}, Lokhttp3/Request;->headers()Lokhttp3/Headers; move-result-object p1 invoke-virtual {p0, p1, v0}, Lokhttp3/internal/http1/Http1ExchangeCodec;->writeRequest(Lokhttp3/Headers;Ljava/lang/String;)V return-void .end method