.class public final Lokhttp3/internal/http2/Http2Connection; .super Ljava/lang/Object; .source "Http2Connection.java" # interfaces .implements Ljava/io/Closeable; # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lokhttp3/internal/http2/Http2Connection$Listener;, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;, Lokhttp3/internal/http2/Http2Connection$Builder; } .end annotation # static fields .field static final synthetic $assertionsDisabled:Z = false .field private static final OKHTTP_CLIENT_WINDOW_SIZE:I = 0x1000000 .field static final executor:Ljava/util/concurrent/ExecutorService; # instance fields .field bytesLeftInWriteWindow:J .field final client:Z .field final currentPushRequests:Ljava/util/Set; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Set<", "Ljava/lang/Integer;", ">;" } .end annotation .end field .field final hostname:Ljava/lang/String; .field lastGoodStreamId:I .field final listener:Lokhttp3/internal/http2/Http2Connection$Listener; .field private nextPingId:I .field nextStreamId:I .field okHttpSettings:Lokhttp3/internal/http2/Settings; .field final peerSettings:Lokhttp3/internal/http2/Settings; .field private pings:Ljava/util/Map; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Map<", "Ljava/lang/Integer;", "Lokhttp3/internal/http2/Ping;", ">;" } .end annotation .end field .field private final pushExecutor:Ljava/util/concurrent/ExecutorService; .field final pushObserver:Lokhttp3/internal/http2/PushObserver; .field final readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; .field receivedInitialPeerSettings:Z .field shutdown:Z .field final socket:Ljava/net/Socket; .field final streams:Ljava/util/Map; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Map<", "Ljava/lang/Integer;", "Lokhttp3/internal/http2/Http2Stream;", ">;" } .end annotation .end field .field unacknowledgedBytesRead:J .field final writer:Lokhttp3/internal/http2/Http2Writer; # direct methods .method static constructor ()V .locals 9 .line 69 new-instance v8, Ljava/util/concurrent/ThreadPoolExecutor; const/4 v1, 0x0 const v2, 0x7fffffff const-wide/16 v3, 0x3c sget-object v5, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit; new-instance v6, Ljava/util/concurrent/SynchronousQueue; invoke-direct {v6}, Ljava/util/concurrent/SynchronousQueue;->()V const/4 v0, 0x1 const-string v7, "OkHttp Http2Connection" .line 71 invoke-static {v7, v0}, Lokhttp3/internal/Util;->threadFactory(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory; move-result-object v7 move-object v0, v8 invoke-direct/range {v0 .. v7}, Ljava/util/concurrent/ThreadPoolExecutor;->(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V sput-object v8, Lokhttp3/internal/http2/Http2Connection;->executor:Ljava/util/concurrent/ExecutorService; return-void .end method .method constructor (Lokhttp3/internal/http2/Http2Connection$Builder;)V .locals 16 move-object/from16 v0, p0 move-object/from16 v1, p1 .line 125 invoke-direct/range {p0 .. p0}, Ljava/lang/Object;->()V .line 81 new-instance v2, Ljava/util/LinkedHashMap; invoke-direct {v2}, Ljava/util/LinkedHashMap;->()V iput-object v2, v0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; const-wide/16 v2, 0x0 .line 101 iput-wide v2, v0, Lokhttp3/internal/http2/Http2Connection;->unacknowledgedBytesRead:J .line 110 new-instance v2, Lokhttp3/internal/http2/Settings; invoke-direct {v2}, Lokhttp3/internal/http2/Settings;->()V iput-object v2, v0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; .line 116 new-instance v2, Lokhttp3/internal/http2/Settings; invoke-direct {v2}, Lokhttp3/internal/http2/Settings;->()V iput-object v2, v0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings; const/4 v3, 0x0 .line 118 iput-boolean v3, v0, Lokhttp3/internal/http2/Http2Connection;->receivedInitialPeerSettings:Z .line 777 new-instance v4, Ljava/util/LinkedHashSet; invoke-direct {v4}, Ljava/util/LinkedHashSet;->()V iput-object v4, v0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set; .line 126 iget-object v4, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->pushObserver:Lokhttp3/internal/http2/PushObserver; iput-object v4, v0, Lokhttp3/internal/http2/Http2Connection;->pushObserver:Lokhttp3/internal/http2/PushObserver; .line 127 iget-boolean v4, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->client:Z iput-boolean v4, v0, Lokhttp3/internal/http2/Http2Connection;->client:Z .line 128 iget-object v5, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->listener:Lokhttp3/internal/http2/Http2Connection$Listener; iput-object v5, v0, Lokhttp3/internal/http2/Http2Connection;->listener:Lokhttp3/internal/http2/Http2Connection$Listener; .line 130 iget-boolean v5, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->client:Z const/4 v6, 0x2 const/4 v7, 0x1 if-eqz v5, :cond_0 move v5, v7 goto :goto_0 :cond_0 move v5, v6 :goto_0 iput v5, v0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I .line 131 iget-boolean v5, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->client:Z if-eqz v5, :cond_1 .line 132 iget v5, v0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I add-int/2addr v5, v6 iput v5, v0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I .line 135 :cond_1 iget-boolean v5, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->client:Z if-eqz v5, :cond_2 move v6, v7 :cond_2 iput v6, v0, Lokhttp3/internal/http2/Http2Connection;->nextPingId:I .line 141 iget-boolean v5, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->client:Z const/4 v6, 0x7 if-eqz v5, :cond_3 .line 142 iget-object v5, v0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; const/high16 v8, 0x1000000 invoke-virtual {v5, v6, v8}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings; .line 145 :cond_3 iget-object v5, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->hostname:Ljava/lang/String; iput-object v5, v0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; .line 148 new-instance v15, Ljava/util/concurrent/ThreadPoolExecutor; const/4 v9, 0x0 const/4 v10, 0x1 const-wide/16 v11, 0x3c sget-object v13, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit; new-instance v14, Ljava/util/concurrent/LinkedBlockingQueue; invoke-direct {v14}, Ljava/util/concurrent/LinkedBlockingQueue;->()V new-array v8, v7, [Ljava/lang/Object; aput-object v5, v8, v3 const-string v3, "OkHttp %s Push Observer" .line 150 invoke-static {v3, v8}, Lokhttp3/internal/Util;->format(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; move-result-object v3 invoke-static {v3, v7}, Lokhttp3/internal/Util;->threadFactory(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory; move-result-object v3 move-object v8, v15 move-object v5, v15 move-object v15, v3 invoke-direct/range {v8 .. v15}, Ljava/util/concurrent/ThreadPoolExecutor;->(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V iput-object v5, v0, Lokhttp3/internal/http2/Http2Connection;->pushExecutor:Ljava/util/concurrent/ExecutorService; const v3, 0xffff .line 151 invoke-virtual {v2, v6, v3}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings; const/4 v3, 0x5 const/16 v5, 0x4000 .line 152 invoke-virtual {v2, v3, v5}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings; .line 153 invoke-virtual {v2}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I move-result v2 int-to-long v2, v2 iput-wide v2, v0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J .line 154 iget-object v2, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->socket:Ljava/net/Socket; iput-object v2, v0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket; .line 155 new-instance v2, Lokhttp3/internal/http2/Http2Writer; iget-object v3, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->sink:Lokio/BufferedSink; invoke-direct {v2, v3, v4}, Lokhttp3/internal/http2/Http2Writer;->(Lokio/BufferedSink;Z)V iput-object v2, v0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; .line 157 new-instance v2, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; new-instance v3, Lokhttp3/internal/http2/Http2Reader; iget-object v1, v1, Lokhttp3/internal/http2/Http2Connection$Builder;->source:Lokio/BufferedSource; invoke-direct {v3, v1, v4}, Lokhttp3/internal/http2/Http2Reader;->(Lokio/BufferedSource;Z)V invoke-direct {v2, v0, v3}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Http2Reader;)V iput-object v2, v0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; return-void .end method .method private newStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; .locals 10 .annotation system Ldalvik/annotation/Signature; value = { "(I", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;Z)", "Lokhttp3/internal/http2/Http2Stream;" } .end annotation .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation xor-int/lit8 v6, p3, 0x1 const/4 v4, 0x0 .line 216 iget-object v7, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v7 .line 217 :try_start_0 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_1 .line 218 :try_start_1 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->shutdown:Z if-nez v0, :cond_6 .line 221 iget v8, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I add-int/lit8 v0, v8, 0x2 .line 222 iput v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I .line 223 new-instance v9, Lokhttp3/internal/http2/Http2Stream; move-object v0, v9 move v1, v8 move-object v2, p0 move v3, v6 move-object v5, p2 invoke-direct/range {v0 .. v5}, Lokhttp3/internal/http2/Http2Stream;->(ILokhttp3/internal/http2/Http2Connection;ZZLjava/util/List;)V if-eqz p3, :cond_1 .line 224 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J const-wide/16 v2, 0x0 cmp-long p3, v0, v2 if-eqz p3, :cond_1 iget-wide v0, v9, Lokhttp3/internal/http2/Http2Stream;->bytesLeftInWriteWindow:J cmp-long p3, v0, v2 if-nez p3, :cond_0 goto :goto_0 :cond_0 const/4 p3, 0x0 goto :goto_1 :cond_1 :goto_0 const/4 p3, 0x1 .line 225 :goto_1 invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->isOpen()Z move-result v0 if-eqz v0, :cond_2 .line 226 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-static {v8}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 invoke-interface {v0, v1, v9}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; .line 228 :cond_2 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 if-nez p1, :cond_3 .line 230 :try_start_2 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0, v6, v8, p1, p2}, Lokhttp3/internal/http2/Http2Writer;->synStream(ZIILjava/util/List;)V goto :goto_2 .line 231 :cond_3 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z if-nez v0, :cond_5 .line 234 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0, p1, v8, p2}, Lokhttp3/internal/http2/Http2Writer;->pushPromise(IILjava/util/List;)V .line 236 :goto_2 monitor-exit v7 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 if-eqz p3, :cond_4 .line 239 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->flush()V :cond_4 return-object v9 .line 232 :cond_5 :try_start_3 new-instance p1, Ljava/lang/IllegalArgumentException; const-string p2, "client streams shouldn\'t have associated stream IDs" invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p1 :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_1 .line 219 :cond_6 :try_start_4 new-instance p1, Lokhttp3/internal/http2/ConnectionShutdownException; invoke-direct {p1}, Lokhttp3/internal/http2/ConnectionShutdownException;->()V throw p1 :catchall_0 move-exception p1 .line 228 monitor-exit p0 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_0 :try_start_5 throw p1 :catchall_1 move-exception p1 .line 236 monitor-exit v7 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_1 throw p1 .end method # virtual methods .method addBytesToWriteWindow(J)V .locals 2 .line 299 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J add-long/2addr v0, p1 iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J const-wide/16 v0, 0x0 cmp-long p1, p1, v0 if-lez p1, :cond_0 .line 300 invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V :cond_0 return-void .end method .method public close()V .locals 2 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 404 sget-object v0, Lokhttp3/internal/http2/ErrorCode;->NO_ERROR:Lokhttp3/internal/http2/ErrorCode; sget-object v1, Lokhttp3/internal/http2/ErrorCode;->CANCEL:Lokhttp3/internal/http2/ErrorCode; invoke-virtual {p0, v0, v1}, Lokhttp3/internal/http2/Http2Connection;->close(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;)V return-void .end method .method close(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;)V .locals 6 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const/4 v0, 0x0 .line 411 :try_start_0 invoke-virtual {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->shutdown(Lokhttp3/internal/http2/ErrorCode;)V :try_end_0 .catch Ljava/io/IOException; {:try_start_0 .. :try_end_0} :catch_0 move-object p1, v0 goto :goto_0 :catch_0 move-exception p1 .line 418 :goto_0 monitor-enter p0 .line 419 :try_start_1 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v1}, Ljava/util/Map;->isEmpty()Z move-result v1 if-nez v1, :cond_0 .line 420 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v1}, Ljava/util/Map;->values()Ljava/util/Collection; move-result-object v1 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v2}, Ljava/util/Map;->size()I move-result v2 new-array v2, v2, [Lokhttp3/internal/http2/Http2Stream; invoke-interface {v1, v2}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object; move-result-object v1 check-cast v1, [Lokhttp3/internal/http2/Http2Stream; .line 421 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v2}, Ljava/util/Map;->clear()V goto :goto_1 :cond_0 move-object v1, v0 .line 423 :goto_1 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; if-eqz v2, :cond_1 .line 424 invoke-interface {v2}, Ljava/util/Map;->values()Ljava/util/Collection; move-result-object v2 iget-object v3, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; invoke-interface {v3}, Ljava/util/Map;->size()I move-result v3 new-array v3, v3, [Lokhttp3/internal/http2/Ping; invoke-interface {v2, v3}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object; move-result-object v2 check-cast v2, [Lokhttp3/internal/http2/Ping; .line 425 iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; move-object v0, v2 .line 427 :cond_1 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 const/4 v2, 0x0 if-eqz v1, :cond_3 .line 430 array-length v3, v1 move v4, v2 :goto_2 if-ge v4, v3, :cond_3 aget-object v5, v1, v4 .line 432 :try_start_2 invoke-virtual {v5, p2}, Lokhttp3/internal/http2/Http2Stream;->close(Lokhttp3/internal/http2/ErrorCode;)V :try_end_2 .catch Ljava/io/IOException; {:try_start_2 .. :try_end_2} :catch_1 goto :goto_3 :catch_1 move-exception v5 if-eqz p1, :cond_2 move-object p1, v5 :cond_2 :goto_3 add-int/lit8 v4, v4, 0x1 goto :goto_2 :cond_3 if-eqz v0, :cond_4 .line 440 array-length p2, v0 :goto_4 if-ge v2, p2, :cond_4 aget-object v1, v0, v2 .line 441 invoke-virtual {v1}, Lokhttp3/internal/http2/Ping;->cancel()V add-int/lit8 v2, v2, 0x1 goto :goto_4 .line 447 :cond_4 :try_start_3 iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p2}, Lokhttp3/internal/http2/Http2Writer;->close()V :try_end_3 .catch Ljava/io/IOException; {:try_start_3 .. :try_end_3} :catch_2 goto :goto_5 :catch_2 move-exception p2 if-nez p1, :cond_5 move-object p1, p2 .line 454 :cond_5 :goto_5 :try_start_4 iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket; invoke-virtual {p2}, Ljava/net/Socket;->close()V :try_end_4 .catch Ljava/io/IOException; {:try_start_4 .. :try_end_4} :catch_3 goto :goto_6 :catch_3 move-exception p1 :goto_6 if-nez p1, :cond_6 return-void .line 459 :cond_6 throw p1 :catchall_0 move-exception p1 .line 427 :try_start_5 monitor-exit p0 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_0 throw p1 .end method .method public flush()V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 375 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Writer;->flush()V return-void .end method .method public getProtocol()Lokhttp3/Protocol; .locals 1 .line 162 sget-object v0, Lokhttp3/Protocol;->HTTP_2:Lokhttp3/Protocol; return-object v0 .end method .method declared-synchronized getStream(I)Lokhttp3/internal/http2/Http2Stream; .locals 1 monitor-enter p0 .line 173 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p1 invoke-interface {v0, p1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lokhttp3/internal/http2/Http2Stream; :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 monitor-exit p0 return-object p1 :catchall_0 move-exception p1 monitor-exit p0 throw p1 .end method .method public declared-synchronized isShutdown()Z .locals 1 monitor-enter p0 .line 500 :try_start_0 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->shutdown:Z :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 monitor-exit p0 return v0 :catchall_0 move-exception v0 monitor-exit p0 throw v0 .end method .method public declared-synchronized maxConcurrentStreams()I .locals 2 monitor-enter p0 .line 183 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings; const v1, 0x7fffffff invoke-virtual {v0, v1}, Lokhttp3/internal/http2/Settings;->getMaxConcurrentStreams(I)I move-result v0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 monitor-exit p0 return v0 :catchall_0 move-exception v0 monitor-exit p0 throw v0 .end method .method public newStream(Ljava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;Z)", "Lokhttp3/internal/http2/Http2Stream;" } .end annotation .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const/4 v0, 0x0 .line 205 invoke-direct {p0, v0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->newStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; move-result-object p1 return-object p1 .end method .method public declared-synchronized openStreamCount()I .locals 1 monitor-enter p0 .line 169 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v0}, Ljava/util/Map;->size()I move-result v0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 monitor-exit p0 return v0 :catchall_0 move-exception v0 monitor-exit p0 throw v0 .end method .method public ping()Lokhttp3/internal/http2/Ping; .locals 4 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 334 new-instance v0, Lokhttp3/internal/http2/Ping; invoke-direct {v0}, Lokhttp3/internal/http2/Ping;->()V .line 336 monitor-enter p0 .line 337 :try_start_0 iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->shutdown:Z if-nez v1, :cond_1 .line 340 iget v1, p0, Lokhttp3/internal/http2/Http2Connection;->nextPingId:I add-int/lit8 v2, v1, 0x2 .line 341 iput v2, p0, Lokhttp3/internal/http2/Http2Connection;->nextPingId:I .line 342 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; if-nez v2, :cond_0 new-instance v2, Ljava/util/LinkedHashMap; invoke-direct {v2}, Ljava/util/LinkedHashMap;->()V iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; .line 343 :cond_0 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; invoke-static {v1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v3 invoke-interface {v2, v3, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; .line 344 monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 const/4 v2, 0x0 const v3, 0x4f4b6f6b .line 345 invoke-virtual {p0, v2, v1, v3, v0}, Lokhttp3/internal/http2/Http2Connection;->writePing(ZIILokhttp3/internal/http2/Ping;)V return-object v0 .line 338 :cond_1 :try_start_1 new-instance v0, Lokhttp3/internal/http2/ConnectionShutdownException; invoke-direct {v0}, Lokhttp3/internal/http2/ConnectionShutdownException;->()V throw v0 :catchall_0 move-exception v0 .line 344 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 throw v0 .end method .method pushDataLater(ILokio/BufferedSource;IZ)V .locals 9 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 827 new-instance v5, Lokio/Buffer; invoke-direct {v5}, Lokio/Buffer;->()V int-to-long v0, p3 .line 828 invoke-interface {p2, v0, v1}, Lokio/BufferedSource;->require(J)V .line 829 invoke-interface {p2, v5, v0, v1}, Lokio/BufferedSource;->read(Lokio/Buffer;J)J .line 830 invoke-virtual {v5}, Lokio/Buffer;->size()J move-result-wide v2 cmp-long p2, v2, v0 if-nez p2, :cond_0 .line 831 iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection;->pushExecutor:Ljava/util/concurrent/ExecutorService; new-instance v8, Lokhttp3/internal/http2/Http2Connection$6; const/4 v0, 0x2 new-array v3, v0, [Ljava/lang/Object; const/4 v0, 0x0 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; aput-object v1, v3, v0 const/4 v0, 0x1 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 aput-object v1, v3, v0 const-string v2, "OkHttp %s Push Data[%s]" move-object v0, v8 move-object v1, p0 move v4, p1 move v6, p3 move v7, p4 invoke-direct/range {v0 .. v7}, Lokhttp3/internal/http2/Http2Connection$6;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;ILokio/Buffer;IZ)V invoke-interface {p2, v8}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void .line 830 :cond_0 new-instance p1, Ljava/io/IOException; new-instance p2, Ljava/lang/StringBuilder; invoke-direct {p2}, Ljava/lang/StringBuilder;->()V invoke-virtual {v5}, Lokio/Buffer;->size()J move-result-wide v0 invoke-virtual {p2, v0, v1}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder; move-result-object p2 const-string p4, " != " invoke-virtual {p2, p4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object p2 invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; move-result-object p2 invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p2 invoke-direct {p1, p2}, Ljava/io/IOException;->(Ljava/lang/String;)V throw p1 .end method .method pushHeadersLater(ILjava/util/List;Z)V .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(I", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;Z)V" } .end annotation .line 805 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushExecutor:Ljava/util/concurrent/ExecutorService; new-instance v8, Lokhttp3/internal/http2/Http2Connection$5; const/4 v1, 0x2 new-array v4, v1, [Ljava/lang/Object; iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; const/4 v2, 0x0 aput-object v1, v4, v2 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 const/4 v2, 0x1 aput-object v1, v4, v2 const-string v3, "OkHttp %s Push Headers[%s]" move-object v1, v8 move-object v2, p0 move v5, p1 move-object v6, p2 move v7, p3 invoke-direct/range {v1 .. v7}, Lokhttp3/internal/http2/Http2Connection$5;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;ILjava/util/List;Z)V invoke-interface {v0, v8}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void .end method .method pushRequestLater(ILjava/util/List;)V .locals 8 .annotation system Ldalvik/annotation/Signature; value = { "(I", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;)V" } .end annotation .line 780 monitor-enter p0 .line 781 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set; invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 invoke-interface {v0, v1}, Ljava/util/Set;->contains(Ljava/lang/Object;)Z move-result v0 if-eqz v0, :cond_0 .line 782 sget-object p2, Lokhttp3/internal/http2/ErrorCode;->PROTOCOL_ERROR:Lokhttp3/internal/http2/ErrorCode; invoke-virtual {p0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->writeSynResetLater(ILokhttp3/internal/http2/ErrorCode;)V .line 783 monitor-exit p0 return-void .line 785 :cond_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set; invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 invoke-interface {v0, v1}, Ljava/util/Set;->add(Ljava/lang/Object;)Z .line 786 monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 787 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushExecutor:Ljava/util/concurrent/ExecutorService; new-instance v7, Lokhttp3/internal/http2/Http2Connection$4; const-string v3, "OkHttp %s Push Request[%s]" const/4 v1, 0x2 new-array v4, v1, [Ljava/lang/Object; const/4 v1, 0x0 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; aput-object v2, v4, v1 const/4 v1, 0x1 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 aput-object v2, v4, v1 move-object v1, v7 move-object v2, p0 move v5, p1 move-object v6, p2 invoke-direct/range {v1 .. v6}, Lokhttp3/internal/http2/Http2Connection$4;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;ILjava/util/List;)V invoke-interface {v0, v7}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void :catchall_0 move-exception p1 .line 786 :try_start_1 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 throw p1 .end method .method pushResetLater(ILokhttp3/internal/http2/ErrorCode;)V .locals 8 .line 848 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushExecutor:Ljava/util/concurrent/ExecutorService; new-instance v7, Lokhttp3/internal/http2/Http2Connection$7; const/4 v1, 0x2 new-array v4, v1, [Ljava/lang/Object; iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; const/4 v2, 0x0 aput-object v1, v4, v2 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 const/4 v2, 0x1 aput-object v1, v4, v2 const-string v3, "OkHttp %s Push Reset[%s]" move-object v1, v7 move-object v2, p0 move v5, p1 move-object v6, p2 invoke-direct/range {v1 .. v6}, Lokhttp3/internal/http2/Http2Connection$7;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;ILokhttp3/internal/http2/ErrorCode;)V invoke-interface {v0, v7}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void .end method .method public pushStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(I", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;Z)", "Lokhttp3/internal/http2/Http2Stream;" } .end annotation .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 195 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z if-nez v0, :cond_0 .line 196 invoke-direct {p0, p1, p2, p3}, Lokhttp3/internal/http2/Http2Connection;->newStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; move-result-object p1 return-object p1 .line 195 :cond_0 new-instance p1, Ljava/lang/IllegalStateException; const-string p2, "Client cannot push requests." invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V throw p1 .end method .method pushedStream(I)Z .locals 1 const/4 v0, 0x1 if-eqz p1, :cond_0 and-int/2addr p1, v0 if-nez p1, :cond_0 goto :goto_0 :cond_0 const/4 v0, 0x0 :goto_0 return v0 .end method .method declared-synchronized removePing(I)Lokhttp3/internal/http2/Ping; .locals 1 monitor-enter p0 .line 371 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pings:Ljava/util/Map; if-eqz v0, :cond_0 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p1 invoke-interface {v0, p1}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lokhttp3/internal/http2/Ping; :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 goto :goto_0 :cond_0 const/4 p1, 0x0 :goto_0 monitor-exit p0 return-object p1 :catchall_0 move-exception p1 monitor-exit p0 throw p1 .end method .method declared-synchronized removeStream(I)Lokhttp3/internal/http2/Http2Stream; .locals 1 monitor-enter p0 .line 177 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p1 invoke-interface {v0, p1}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lokhttp3/internal/http2/Http2Stream; .line 178 invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 179 monitor-exit p0 return-object p1 :catchall_0 move-exception p1 monitor-exit p0 throw p1 .end method .method public setSettings(Lokhttp3/internal/http2/Settings;)V .locals 2 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 488 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v0 .line 489 :try_start_0 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_1 .line 490 :try_start_1 iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->shutdown:Z if-nez v1, :cond_0 .line 493 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; invoke-virtual {v1, p1}, Lokhttp3/internal/http2/Settings;->merge(Lokhttp3/internal/http2/Settings;)V .line 494 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v1, p1}, Lokhttp3/internal/http2/Http2Writer;->settings(Lokhttp3/internal/http2/Settings;)V .line 495 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 496 :try_start_2 monitor-exit v0 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 return-void .line 491 :cond_0 :try_start_3 new-instance p1, Lokhttp3/internal/http2/ConnectionShutdownException; invoke-direct {p1}, Lokhttp3/internal/http2/ConnectionShutdownException;->()V throw p1 :catchall_0 move-exception p1 .line 495 monitor-exit p0 :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_0 :try_start_4 throw p1 :catchall_1 move-exception p1 .line 496 monitor-exit v0 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_1 throw p1 .end method .method public shutdown(Lokhttp3/internal/http2/ErrorCode;)V .locals 4 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 384 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v0 .line 386 :try_start_0 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_1 .line 387 :try_start_1 iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->shutdown:Z if-eqz v1, :cond_0 .line 388 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 :try_start_2 monitor-exit v0 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 return-void :cond_0 const/4 v1, 0x1 .line 390 :try_start_3 iput-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->shutdown:Z .line 391 iget v1, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I .line 392 monitor-exit p0 :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_0 .line 395 :try_start_4 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; sget-object v3, Lokhttp3/internal/Util;->EMPTY_BYTE_ARRAY:[B invoke-virtual {v2, v1, p1, v3}, Lokhttp3/internal/http2/Http2Writer;->goAway(ILokhttp3/internal/http2/ErrorCode;[B)V .line 396 monitor-exit v0 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_1 return-void :catchall_0 move-exception p1 .line 392 :try_start_5 monitor-exit p0 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_0 :try_start_6 throw p1 :catchall_1 move-exception p1 .line 396 monitor-exit v0 :try_end_6 .catchall {:try_start_6 .. :try_end_6} :catchall_1 throw p1 .end method .method public start()V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const/4 v0, 0x1 .line 467 invoke-virtual {p0, v0}, Lokhttp3/internal/http2/Http2Connection;->start(Z)V return-void .end method .method start(Z)V .locals 5 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation if-eqz p1, :cond_0 .line 476 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->connectionPreface()V .line 477 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; invoke-virtual {p1, v0}, Lokhttp3/internal/http2/Http2Writer;->settings(Lokhttp3/internal/http2/Settings;)V .line 478 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; invoke-virtual {p1}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I move-result p1 const v0, 0xffff if-eq p1, v0, :cond_0 .line 480 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; const/4 v2, 0x0 sub-int/2addr p1, v0 int-to-long v3, p1 invoke-virtual {v1, v2, v3, v4}, Lokhttp3/internal/http2/Http2Writer;->windowUpdate(IJ)V .line 483 :cond_0 new-instance p1, Ljava/lang/Thread; iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; invoke-direct {p1, v0}, Ljava/lang/Thread;->(Ljava/lang/Runnable;)V invoke-virtual {p1}, Ljava/lang/Thread;->start()V return-void .end method .method public writeData(IZLokio/Buffer;J)V .locals 8 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const-wide/16 v0, 0x0 cmp-long v2, p4, v0 const/4 v3, 0x0 if-nez v2, :cond_0 .line 265 iget-object p4, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p4, p2, p1, p3, v3}, Lokhttp3/internal/http2/Http2Writer;->data(ZILokio/Buffer;I)V return-void :cond_0 :goto_0 cmp-long v2, p4, v0 if-lez v2, :cond_4 .line 271 monitor-enter p0 .line 273 :goto_1 :try_start_0 iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J cmp-long v2, v4, v0 if-gtz v2, :cond_2 .line 276 iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v4 invoke-interface {v2, v4}, Ljava/util/Map;->containsKey(Ljava/lang/Object;)Z move-result v2 if-eqz v2, :cond_1 .line 279 invoke-virtual {p0}, Ljava/lang/Object;->wait()V goto :goto_1 .line 277 :cond_1 new-instance p1, Ljava/io/IOException; const-string p2, "stream closed" invoke-direct {p1, p2}, Ljava/io/IOException;->(Ljava/lang/String;)V throw p1 :try_end_0 .catch Ljava/lang/InterruptedException; {:try_start_0 .. :try_end_0} :catch_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 285 :cond_2 :try_start_1 invoke-static {p4, p5, v4, v5}, Ljava/lang/Math;->min(JJ)J move-result-wide v4 long-to-int v2, v4 .line 286 iget-object v4, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v4}, Lokhttp3/internal/http2/Http2Writer;->maxDataLength()I move-result v4 invoke-static {v2, v4}, Ljava/lang/Math;->min(II)I move-result v2 .line 287 iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J int-to-long v6, v2 sub-long/2addr v4, v6 iput-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J .line 288 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 sub-long/2addr p4, v6 .line 291 iget-object v4, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; if-eqz p2, :cond_3 cmp-long v5, p4, v0 if-nez v5, :cond_3 const/4 v5, 0x1 goto :goto_2 :cond_3 move v5, v3 :goto_2 invoke-virtual {v4, v5, p1, p3, v2}, Lokhttp3/internal/http2/Http2Writer;->data(ZILokio/Buffer;I)V goto :goto_0 :catchall_0 move-exception p1 goto :goto_3 .line 282 :catch_0 :try_start_2 new-instance p1, Ljava/io/InterruptedIOException; invoke-direct {p1}, Ljava/io/InterruptedIOException;->()V throw p1 .line 288 :goto_3 monitor-exit p0 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_0 throw p1 :cond_4 return-void .end method .method writePing(ZIILokhttp3/internal/http2/Ping;)V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 363 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v0 if-eqz p4, :cond_0 .line 365 :try_start_0 invoke-virtual {p4}, Lokhttp3/internal/http2/Ping;->send()V .line 366 :cond_0 iget-object p4, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p4, p1, p2, p3}, Lokhttp3/internal/http2/Http2Writer;->ping(ZII)V .line 367 monitor-exit v0 return-void :catchall_0 move-exception p1 monitor-exit v0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 throw p1 .end method .method writePingLater(ZIILokhttp3/internal/http2/Ping;)V .locals 10 .line 351 sget-object v0, Lokhttp3/internal/http2/Http2Connection;->executor:Ljava/util/concurrent/ExecutorService; new-instance v9, Lokhttp3/internal/http2/Http2Connection$3; const/4 v1, 0x3 new-array v4, v1, [Ljava/lang/Object; iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; const/4 v2, 0x0 aput-object v1, v4, v2 .line 352 invoke-static {p2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 const/4 v2, 0x1 aput-object v1, v4, v2 invoke-static {p3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 const/4 v2, 0x2 aput-object v1, v4, v2 const-string v3, "OkHttp %s ping %08x%08x" move-object v1, v9 move-object v2, p0 move v5, p1 move v6, p2 move v7, p3 move-object v8, p4 invoke-direct/range {v1 .. v8}, Lokhttp3/internal/http2/Http2Connection$3;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;ZIILokhttp3/internal/http2/Ping;)V .line 351 invoke-interface {v0, v9}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void .end method .method writeSynReply(IZLjava/util/List;)V .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(IZ", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;)V" } .end annotation .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 247 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0, p2, p1, p3}, Lokhttp3/internal/http2/Http2Writer;->synReply(ZILjava/util/List;)V return-void .end method .method writeSynReset(ILokhttp3/internal/http2/ErrorCode;)V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 315 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0, p1, p2}, Lokhttp3/internal/http2/Http2Writer;->rstStream(ILokhttp3/internal/http2/ErrorCode;)V return-void .end method .method writeSynResetLater(ILokhttp3/internal/http2/ErrorCode;)V .locals 8 .line 304 sget-object v0, Lokhttp3/internal/http2/Http2Connection;->executor:Ljava/util/concurrent/ExecutorService; new-instance v7, Lokhttp3/internal/http2/Http2Connection$1; const/4 v1, 0x2 new-array v4, v1, [Ljava/lang/Object; iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; const/4 v2, 0x0 aput-object v1, v4, v2 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 const/4 v2, 0x1 aput-object v1, v4, v2 const-string v3, "OkHttp %s stream %d" move-object v1, v7 move-object v2, p0 move v5, p1 move-object v6, p2 invoke-direct/range {v1 .. v6}, Lokhttp3/internal/http2/Http2Connection$1;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;ILokhttp3/internal/http2/ErrorCode;)V invoke-interface {v0, v7}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void .end method .method writeWindowUpdateLater(IJ)V .locals 9 .line 319 sget-object v0, Lokhttp3/internal/http2/Http2Connection;->executor:Ljava/util/concurrent/ExecutorService; new-instance v8, Lokhttp3/internal/http2/Http2Connection$2; const/4 v1, 0x2 new-array v4, v1, [Ljava/lang/Object; iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->hostname:Ljava/lang/String; const/4 v2, 0x0 aput-object v1, v4, v2 invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v1 const/4 v2, 0x1 aput-object v1, v4, v2 const-string v3, "OkHttp Window Update %s stream %d" move-object v1, v8 move-object v2, p0 move v5, p1 move-wide v6, p2 invoke-direct/range {v1 .. v7}, Lokhttp3/internal/http2/Http2Connection$2;->(Lokhttp3/internal/http2/Http2Connection;Ljava/lang/String;[Ljava/lang/Object;IJ)V invoke-interface {v0, v8}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V return-void .end method