123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814 |
- .class public final Lokhttp3/internal/http2/Http2Codec;
- .super Ljava/lang/Object;
- .source ""
- # interfaces
- .implements Lokhttp3/internal/http/HttpCodec;
- # annotations
- .annotation system Ldalvik/annotation/MemberClasses;
- value = {
- Lokhttp3/internal/http2/Http2Codec$StreamFinishingSource;
- }
- .end annotation
- # static fields
- .field private static final CONNECTION:Lokio/ByteString;
- .field private static final ENCODING:Lokio/ByteString;
- .field private static final HOST:Lokio/ByteString;
- .field private static final HTTP_2_SKIPPED_REQUEST_HEADERS:Ljava/util/List;
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "Ljava/util/List<",
- "Lokio/ByteString;",
- ">;"
- }
- .end annotation
- .end field
- .field private static final HTTP_2_SKIPPED_RESPONSE_HEADERS:Ljava/util/List;
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "Ljava/util/List<",
- "Lokio/ByteString;",
- ">;"
- }
- .end annotation
- .end field
- .field private static final KEEP_ALIVE:Lokio/ByteString;
- .field private static final PROXY_CONNECTION:Lokio/ByteString;
- .field private static final TE:Lokio/ByteString;
- .field private static final TRANSFER_ENCODING:Lokio/ByteString;
- .field private static final UPGRADE:Lokio/ByteString;
- # instance fields
- .field private final chain:Lokhttp3/Interceptor$Chain;
- .field private final client:Lokhttp3/OkHttpClient;
- .field private final connection:Lokhttp3/internal/http2/Http2Connection;
- .field private stream:Lokhttp3/internal/http2/Http2Stream;
- .field final streamAllocation:Lokhttp3/internal/connection/StreamAllocation;
- # direct methods
- .method static constructor <clinit>()V
- .locals 12
- const-string v0, "connection"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->CONNECTION:Lokio/ByteString;
- const-string v0, "host"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->HOST:Lokio/ByteString;
- const-string v0, "keep-alive"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->KEEP_ALIVE:Lokio/ByteString;
- const-string v0, "proxy-connection"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->PROXY_CONNECTION:Lokio/ByteString;
- const-string v0, "transfer-encoding"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->TRANSFER_ENCODING:Lokio/ByteString;
- const-string v0, "te"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->TE:Lokio/ByteString;
- const-string v0, "encoding"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->ENCODING:Lokio/ByteString;
- const-string v0, "upgrade"
- invoke-static {v0}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->UPGRADE:Lokio/ByteString;
- const/16 v0, 0xc
- new-array v0, v0, [Lokio/ByteString;
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->CONNECTION:Lokio/ByteString;
- const/4 v2, 0x0
- aput-object v1, v0, v2
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->HOST:Lokio/ByteString;
- const/4 v3, 0x1
- aput-object v1, v0, v3
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->KEEP_ALIVE:Lokio/ByteString;
- const/4 v4, 0x2
- aput-object v1, v0, v4
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->PROXY_CONNECTION:Lokio/ByteString;
- const/4 v5, 0x3
- aput-object v1, v0, v5
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->TE:Lokio/ByteString;
- const/4 v6, 0x4
- aput-object v1, v0, v6
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->TRANSFER_ENCODING:Lokio/ByteString;
- const/4 v7, 0x5
- aput-object v1, v0, v7
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->ENCODING:Lokio/ByteString;
- const/4 v8, 0x6
- aput-object v1, v0, v8
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->UPGRADE:Lokio/ByteString;
- const/4 v9, 0x7
- aput-object v1, v0, v9
- sget-object v1, Lokhttp3/internal/http2/Header;->TARGET_METHOD:Lokio/ByteString;
- const/16 v10, 0x8
- aput-object v1, v0, v10
- sget-object v1, Lokhttp3/internal/http2/Header;->TARGET_PATH:Lokio/ByteString;
- const/16 v11, 0x9
- aput-object v1, v0, v11
- sget-object v1, Lokhttp3/internal/http2/Header;->TARGET_SCHEME:Lokio/ByteString;
- const/16 v11, 0xa
- aput-object v1, v0, v11
- sget-object v1, Lokhttp3/internal/http2/Header;->TARGET_AUTHORITY:Lokio/ByteString;
- const/16 v11, 0xb
- aput-object v1, v0, v11
- invoke-static {v0}, Lokhttp3/internal/Util;->immutableList([Ljava/lang/Object;)Ljava/util/List;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->HTTP_2_SKIPPED_REQUEST_HEADERS:Ljava/util/List;
- new-array v0, v10, [Lokio/ByteString;
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->CONNECTION:Lokio/ByteString;
- aput-object v1, v0, v2
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->HOST:Lokio/ByteString;
- aput-object v1, v0, v3
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->KEEP_ALIVE:Lokio/ByteString;
- aput-object v1, v0, v4
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->PROXY_CONNECTION:Lokio/ByteString;
- aput-object v1, v0, v5
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->TE:Lokio/ByteString;
- aput-object v1, v0, v6
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->TRANSFER_ENCODING:Lokio/ByteString;
- aput-object v1, v0, v7
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->ENCODING:Lokio/ByteString;
- aput-object v1, v0, v8
- sget-object v1, Lokhttp3/internal/http2/Http2Codec;->UPGRADE:Lokio/ByteString;
- aput-object v1, v0, v9
- invoke-static {v0}, Lokhttp3/internal/Util;->immutableList([Ljava/lang/Object;)Ljava/util/List;
- move-result-object v0
- sput-object v0, Lokhttp3/internal/http2/Http2Codec;->HTTP_2_SKIPPED_RESPONSE_HEADERS:Ljava/util/List;
- return-void
- .end method
- .method public constructor <init>(Lokhttp3/OkHttpClient;Lokhttp3/Interceptor$Chain;Lokhttp3/internal/connection/StreamAllocation;Lokhttp3/internal/http2/Http2Connection;)V
- .locals 0
- invoke-direct {p0}, Ljava/lang/Object;-><init>()V
- iput-object p1, p0, Lokhttp3/internal/http2/Http2Codec;->client:Lokhttp3/OkHttpClient;
- iput-object p2, p0, Lokhttp3/internal/http2/Http2Codec;->chain:Lokhttp3/Interceptor$Chain;
- iput-object p3, p0, Lokhttp3/internal/http2/Http2Codec;->streamAllocation:Lokhttp3/internal/connection/StreamAllocation;
- iput-object p4, p0, Lokhttp3/internal/http2/Http2Codec;->connection:Lokhttp3/internal/http2/Http2Connection;
- return-void
- .end method
- .method public static http2HeadersList(Lokhttp3/Request;)Ljava/util/List;
- .locals 6
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "(",
- "Lokhttp3/Request;",
- ")",
- "Ljava/util/List<",
- "Lokhttp3/internal/http2/Header;",
- ">;"
- }
- .end annotation
- invoke-virtual {p0}, Lokhttp3/Request;->headers()Lokhttp3/Headers;
- move-result-object v0
- new-instance v1, Ljava/util/ArrayList;
- invoke-virtual {v0}, Lokhttp3/Headers;->size()I
- move-result v2
- add-int/lit8 v2, v2, 0x4
- invoke-direct {v1, v2}, Ljava/util/ArrayList;-><init>(I)V
- new-instance v2, Lokhttp3/internal/http2/Header;
- sget-object v3, Lokhttp3/internal/http2/Header;->TARGET_METHOD:Lokio/ByteString;
- invoke-virtual {p0}, Lokhttp3/Request;->method()Ljava/lang/String;
- move-result-object v4
- invoke-direct {v2, v3, v4}, Lokhttp3/internal/http2/Header;-><init>(Lokio/ByteString;Ljava/lang/String;)V
- invoke-interface {v1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z
- new-instance v2, Lokhttp3/internal/http2/Header;
- sget-object v3, Lokhttp3/internal/http2/Header;->TARGET_PATH:Lokio/ByteString;
- invoke-virtual {p0}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl;
- move-result-object v4
- invoke-static {v4}, Lokhttp3/internal/http/RequestLine;->requestPath(Lokhttp3/HttpUrl;)Ljava/lang/String;
- move-result-object v4
- invoke-direct {v2, v3, v4}, Lokhttp3/internal/http2/Header;-><init>(Lokio/ByteString;Ljava/lang/String;)V
- invoke-interface {v1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z
- const-string v2, "Host"
- invoke-virtual {p0, v2}, Lokhttp3/Request;->header(Ljava/lang/String;)Ljava/lang/String;
- move-result-object v2
- if-eqz v2, :cond_0
- new-instance v3, Lokhttp3/internal/http2/Header;
- sget-object v4, Lokhttp3/internal/http2/Header;->TARGET_AUTHORITY:Lokio/ByteString;
- invoke-direct {v3, v4, v2}, Lokhttp3/internal/http2/Header;-><init>(Lokio/ByteString;Ljava/lang/String;)V
- invoke-interface {v1, v3}, Ljava/util/List;->add(Ljava/lang/Object;)Z
- :cond_0
- new-instance v2, Lokhttp3/internal/http2/Header;
- sget-object v3, Lokhttp3/internal/http2/Header;->TARGET_SCHEME:Lokio/ByteString;
- invoke-virtual {p0}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl;
- move-result-object p0
- invoke-virtual {p0}, Lokhttp3/HttpUrl;->scheme()Ljava/lang/String;
- move-result-object p0
- invoke-direct {v2, v3, p0}, Lokhttp3/internal/http2/Header;-><init>(Lokio/ByteString;Ljava/lang/String;)V
- invoke-interface {v1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z
- const/4 p0, 0x0
- invoke-virtual {v0}, Lokhttp3/Headers;->size()I
- move-result v2
- :goto_0
- if-ge p0, v2, :cond_2
- invoke-virtual {v0, p0}, Lokhttp3/Headers;->name(I)Ljava/lang/String;
- move-result-object v3
- sget-object v4, Ljava/util/Locale;->US:Ljava/util/Locale;
- invoke-virtual {v3, v4}, Ljava/lang/String;->toLowerCase(Ljava/util/Locale;)Ljava/lang/String;
- move-result-object v3
- invoke-static {v3}, Lokio/ByteString;->encodeUtf8(Ljava/lang/String;)Lokio/ByteString;
- move-result-object v3
- sget-object v4, Lokhttp3/internal/http2/Http2Codec;->HTTP_2_SKIPPED_REQUEST_HEADERS:Ljava/util/List;
- invoke-interface {v4, v3}, Ljava/util/List;->contains(Ljava/lang/Object;)Z
- move-result v4
- if-nez v4, :cond_1
- new-instance v4, Lokhttp3/internal/http2/Header;
- invoke-virtual {v0, p0}, Lokhttp3/Headers;->value(I)Ljava/lang/String;
- move-result-object v5
- invoke-direct {v4, v3, v5}, Lokhttp3/internal/http2/Header;-><init>(Lokio/ByteString;Ljava/lang/String;)V
- invoke-interface {v1, v4}, Ljava/util/List;->add(Ljava/lang/Object;)Z
- :cond_1
- add-int/lit8 p0, p0, 0x1
- goto :goto_0
- :cond_2
- return-object v1
- .end method
- .method public static readHttp2HeadersList(Ljava/util/List;)Lokhttp3/Response$Builder;
- .locals 8
- .annotation system Ldalvik/annotation/Signature;
- value = {
- "(",
- "Ljava/util/List<",
- "Lokhttp3/internal/http2/Header;",
- ">;)",
- "Lokhttp3/Response$Builder;"
- }
- .end annotation
- .annotation system Ldalvik/annotation/Throws;
- value = {
- Ljava/io/IOException;
- }
- .end annotation
- new-instance v0, Lokhttp3/Headers$Builder;
- invoke-direct {v0}, Lokhttp3/Headers$Builder;-><init>()V
- invoke-interface {p0}, Ljava/util/List;->size()I
- move-result v1
- const/4 v2, 0x0
- const/4 v3, 0x0
- move-object v4, v0
- move-object v0, v2
- :goto_0
- if-ge v3, v1, :cond_3
- invoke-interface {p0, v3}, Ljava/util/List;->get(I)Ljava/lang/Object;
- move-result-object v5
- check-cast v5, Lokhttp3/internal/http2/Header;
- if-nez v5, :cond_0
- if-eqz v0, :cond_2
- iget v5, v0, Lokhttp3/internal/http/StatusLine;->code:I
- const/16 v6, 0x64
- if-ne v5, v6, :cond_2
- new-instance v0, Lokhttp3/Headers$Builder;
- invoke-direct {v0}, Lokhttp3/Headers$Builder;-><init>()V
- move-object v4, v0
- move-object v0, v2
- goto :goto_1
- :cond_0
- iget-object v6, v5, Lokhttp3/internal/http2/Header;->name:Lokio/ByteString;
- iget-object v5, v5, Lokhttp3/internal/http2/Header;->value:Lokio/ByteString;
- invoke-virtual {v5}, Lokio/ByteString;->utf8()Ljava/lang/String;
- move-result-object v5
- sget-object v7, Lokhttp3/internal/http2/Header;->RESPONSE_STATUS:Lokio/ByteString;
- invoke-virtual {v6, v7}, Lokio/ByteString;->equals(Ljava/lang/Object;)Z
- move-result v7
- if-eqz v7, :cond_1
- new-instance v0, Ljava/lang/StringBuilder;
- invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
- const-string v6, "HTTP/1.1 "
- invoke-virtual {v0, v6}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
- invoke-virtual {v0, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
- invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
- move-result-object v0
- invoke-static {v0}, Lokhttp3/internal/http/StatusLine;->parse(Ljava/lang/String;)Lokhttp3/internal/http/StatusLine;
- move-result-object v0
- goto :goto_1
- :cond_1
- sget-object v7, Lokhttp3/internal/http2/Http2Codec;->HTTP_2_SKIPPED_RESPONSE_HEADERS:Ljava/util/List;
- invoke-interface {v7, v6}, Ljava/util/List;->contains(Ljava/lang/Object;)Z
- move-result v7
- if-nez v7, :cond_2
- sget-object v7, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
- invoke-virtual {v6}, Lokio/ByteString;->utf8()Ljava/lang/String;
- move-result-object v6
- invoke-virtual {v7, v4, v6, v5}, Lokhttp3/internal/Internal;->addLenient(Lokhttp3/Headers$Builder;Ljava/lang/String;Ljava/lang/String;)V
- :cond_2
- :goto_1
- add-int/lit8 v3, v3, 0x1
- goto :goto_0
- :cond_3
- if-eqz v0, :cond_4
- new-instance p0, Lokhttp3/Response$Builder;
- invoke-direct {p0}, Lokhttp3/Response$Builder;-><init>()V
- sget-object v1, Lokhttp3/Protocol;->HTTP_2:Lokhttp3/Protocol;
- invoke-virtual {p0, v1}, Lokhttp3/Response$Builder;->protocol(Lokhttp3/Protocol;)Lokhttp3/Response$Builder;
- move-result-object p0
- iget v1, v0, Lokhttp3/internal/http/StatusLine;->code:I
- invoke-virtual {p0, v1}, Lokhttp3/Response$Builder;->code(I)Lokhttp3/Response$Builder;
- move-result-object p0
- iget-object v0, v0, Lokhttp3/internal/http/StatusLine;->message:Ljava/lang/String;
- invoke-virtual {p0, v0}, Lokhttp3/Response$Builder;->message(Ljava/lang/String;)Lokhttp3/Response$Builder;
- move-result-object p0
- invoke-virtual {v4}, Lokhttp3/Headers$Builder;->build()Lokhttp3/Headers;
- move-result-object v0
- invoke-virtual {p0, v0}, Lokhttp3/Response$Builder;->headers(Lokhttp3/Headers;)Lokhttp3/Response$Builder;
- move-result-object p0
- return-object p0
- :cond_4
- new-instance p0, Ljava/net/ProtocolException;
- const-string v0, "Expected \':status\' header not present"
- invoke-direct {p0, v0}, Ljava/net/ProtocolException;-><init>(Ljava/lang/String;)V
- goto :goto_3
- :goto_2
- throw p0
- :goto_3
- goto :goto_2
- .end method
- # virtual methods
- .method public cancel()V
- .locals 2
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- if-eqz v0, :cond_0
- sget-object v1, Lokhttp3/internal/http2/ErrorCode;->CANCEL:Lokhttp3/internal/http2/ErrorCode;
- invoke-virtual {v0, v1}, Lokhttp3/internal/http2/Http2Stream;->closeLater(Lokhttp3/internal/http2/ErrorCode;)V
- :cond_0
- return-void
- .end method
- .method public createRequestBody(Lokhttp3/Request;J)Lokio/Sink;
- .locals 0
- iget-object p1, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Stream;->getSink()Lokio/Sink;
- move-result-object p1
- return-object p1
- .end method
- .method public finishRequest()V
- .locals 1
- .annotation system Ldalvik/annotation/Throws;
- value = {
- Ljava/io/IOException;
- }
- .end annotation
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Stream;->getSink()Lokio/Sink;
- move-result-object v0
- invoke-interface {v0}, Lokio/Sink;->close()V
- return-void
- .end method
- .method public flushRequest()V
- .locals 1
- .annotation system Ldalvik/annotation/Throws;
- value = {
- Ljava/io/IOException;
- }
- .end annotation
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->connection:Lokhttp3/internal/http2/Http2Connection;
- invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Connection;->flush()V
- return-void
- .end method
- .method public openResponseBody(Lokhttp3/Response;)Lokhttp3/ResponseBody;
- .locals 4
- .annotation system Ldalvik/annotation/Throws;
- value = {
- Ljava/io/IOException;
- }
- .end annotation
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->streamAllocation:Lokhttp3/internal/connection/StreamAllocation;
- iget-object v1, v0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
- iget-object v0, v0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
- invoke-virtual {v1, v0}, Lokhttp3/EventListener;->responseBodyStart(Lokhttp3/Call;)V
- const-string v0, "Content-Type"
- invoke-virtual {p1, v0}, Lokhttp3/Response;->header(Ljava/lang/String;)Ljava/lang/String;
- move-result-object v0
- invoke-static {p1}, Lokhttp3/internal/http/HttpHeaders;->contentLength(Lokhttp3/Response;)J
- move-result-wide v1
- new-instance p1, Lokhttp3/internal/http2/Http2Codec$StreamFinishingSource;
- iget-object v3, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- invoke-virtual {v3}, Lokhttp3/internal/http2/Http2Stream;->getSource()Lokio/Source;
- move-result-object v3
- invoke-direct {p1, p0, v3}, Lokhttp3/internal/http2/Http2Codec$StreamFinishingSource;-><init>(Lokhttp3/internal/http2/Http2Codec;Lokio/Source;)V
- new-instance v3, Lokhttp3/internal/http/RealResponseBody;
- invoke-static {p1}, Lokio/Okio;->buffer(Lokio/Source;)Lokio/BufferedSource;
- move-result-object p1
- invoke-direct {v3, v0, v1, v2, p1}, Lokhttp3/internal/http/RealResponseBody;-><init>(Ljava/lang/String;JLokio/BufferedSource;)V
- return-object v3
- .end method
- .method public readResponseHeaders(Z)Lokhttp3/Response$Builder;
- .locals 2
- .annotation system Ldalvik/annotation/Throws;
- value = {
- Ljava/io/IOException;
- }
- .end annotation
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Stream;->takeResponseHeaders()Ljava/util/List;
- move-result-object v0
- invoke-static {v0}, Lokhttp3/internal/http2/Http2Codec;->readHttp2HeadersList(Ljava/util/List;)Lokhttp3/Response$Builder;
- move-result-object v0
- if-eqz p1, :cond_0
- sget-object p1, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
- invoke-virtual {p1, v0}, Lokhttp3/internal/Internal;->code(Lokhttp3/Response$Builder;)I
- move-result p1
- const/16 v1, 0x64
- if-ne p1, v1, :cond_0
- const/4 p1, 0x0
- return-object p1
- :cond_0
- return-object v0
- .end method
- .method public writeRequestHeaders(Lokhttp3/Request;)V
- .locals 3
- .annotation system Ldalvik/annotation/Throws;
- value = {
- Ljava/io/IOException;
- }
- .end annotation
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- if-eqz v0, :cond_0
- return-void
- :cond_0
- invoke-virtual {p1}, Lokhttp3/Request;->body()Lokhttp3/RequestBody;
- move-result-object v0
- if-eqz v0, :cond_1
- const/4 v0, 0x1
- goto :goto_0
- :cond_1
- const/4 v0, 0x0
- :goto_0
- invoke-static {p1}, Lokhttp3/internal/http2/Http2Codec;->http2HeadersList(Lokhttp3/Request;)Ljava/util/List;
- move-result-object p1
- iget-object v1, p0, Lokhttp3/internal/http2/Http2Codec;->connection:Lokhttp3/internal/http2/Http2Connection;
- invoke-virtual {v1, p1, v0}, Lokhttp3/internal/http2/Http2Connection;->newStream(Ljava/util/List;Z)Lokhttp3/internal/http2/Http2Stream;
- move-result-object p1
- iput-object p1, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- iget-object p1, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Stream;->readTimeout()Lokio/Timeout;
- move-result-object p1
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->chain:Lokhttp3/Interceptor$Chain;
- invoke-interface {v0}, Lokhttp3/Interceptor$Chain;->readTimeoutMillis()I
- move-result v0
- int-to-long v0, v0
- sget-object v2, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit;
- invoke-virtual {p1, v0, v1, v2}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
- iget-object p1, p0, Lokhttp3/internal/http2/Http2Codec;->stream:Lokhttp3/internal/http2/Http2Stream;
- invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Stream;->writeTimeout()Lokio/Timeout;
- move-result-object p1
- iget-object v0, p0, Lokhttp3/internal/http2/Http2Codec;->chain:Lokhttp3/Interceptor$Chain;
- invoke-interface {v0}, Lokhttp3/Interceptor$Chain;->writeTimeoutMillis()I
- move-result v0
- int-to-long v0, v0
- sget-object v2, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit;
- invoke-virtual {p1, v0, v1, v2}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
- return-void
- .end method
|