.class public final Lokhttp3/internal/http2/Http2Connection; .super Ljava/lang/Object; .source "Http2Connection.kt" # interfaces .implements Ljava/io/Closeable; # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lokhttp3/internal/http2/Http2Connection$Builder;, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;, Lokhttp3/internal/http2/Http2Connection$Listener;, Lokhttp3/internal/http2/Http2Connection$Companion; } .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nHttp2Connection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection\n+ 2 Util.kt\nokhttp3/internal/Util\n+ 3 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 4 TaskQueue.kt\nokhttp3/internal/concurrent/TaskQueue\n+ 5 ArraysJVM.kt\nkotlin/collections/ArraysKt__ArraysJVMKt\n+ 6 _Arrays.kt\nkotlin/collections/ArraysKt___ArraysKt\n*L\n1#1,1006:1\n563#2:1007\n557#2:1009\n557#2:1032\n615#2,4:1033\n402#2,5:1037\n402#2,5:1045\n402#2,5:1051\n402#2,5:1056\n1#3:1008\n92#4,11:1010\n92#4,11:1021\n92#4,11:1061\n92#4,11:1072\n92#4,11:1083\n92#4,11:1094\n92#4,11:1105\n92#4,11:1116\n84#4,4:1127\n37#5,2:1042\n13416#6:1044\n13417#6:1050\n*E\n*S KotlinDebug\n*F\n+ 1 Http2Connection.kt\nokhttp3/internal/http2/Http2Connection\n*L\n183#1:1007\n319#1:1009\n402#1:1032\n446#1,4:1033\n448#1,5:1037\n461#1,5:1045\n467#1,5:1051\n472#1,5:1056\n340#1,11:1010\n361#1,11:1021\n506#1,11:1061\n554#1,11:1072\n893#1,11:1083\n911#1,11:1094\n938#1,11:1105\n952#1,11:1116\n152#1,4:1127\n455#1,2:1042\n460#1:1044\n460#1:1050\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = {} d1 = { "\u0000\u00b2\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0008\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0008\n\u0002\u0010\t\n\u0002\u0008\n\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u001a\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0011\n\u0002\u0018\u0002\n\u0002\u0008\n\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010%\n\u0002\u0008\u0004\n\u0002\u0010\u000e\n\u0002\u0008\u000f\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u001c\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010#\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0008\u0018\u0000 \u00b2\u00012\u00020\u0001:\u0008\u00b3\u0001\u00b2\u0001\u00b4\u0001\u00b5\u0001B\u0015\u0008\u0000\u0012\u0008\u0010\u00af\u0001\u001a\u00030\u00ae\u0001\u00a2\u0006\u0006\u0008\u00b0\u0001\u0010\u00b1\u0001J&\u0010\n\u001a\u00020\t2\u0006\u0010\u0003\u001a\u00020\u00022\u000c\u0010\u0006\u001a\u0008\u0012\u0004\u0012\u00020\u00050\u00042\u0006\u0010\u0008\u001a\u00020\u0007H\u0002J\u0012\u0010\u000e\u001a\u00020\r2\u0008\u0010\u000c\u001a\u0004\u0018\u00010\u000bH\u0002J\u0006\u0010\u000f\u001a\u00020\u0002J\u0010\u0010\u0011\u001a\u0004\u0018\u00010\t2\u0006\u0010\u0010\u001a\u00020\u0002J\u0019\u0010\u0015\u001a\u0004\u0018\u00010\t2\u0006\u0010\u0012\u001a\u00020\u0002H\u0000\u00a2\u0006\u0004\u0008\u0013\u0010\u0014J\u0017\u0010\u001a\u001a\u00020\r2\u0006\u0010\u0017\u001a\u00020\u0016H\u0000\u00a2\u0006\u0004\u0008\u0018\u0010\u0019J$\u0010\u001b\u001a\u00020\t2\u0006\u0010\u0003\u001a\u00020\u00022\u000c\u0010\u0006\u001a\u0008\u0012\u0004\u0012\u00020\u00050\u00042\u0006\u0010\u0008\u001a\u00020\u0007J\u001c\u0010\n\u001a\u00020\t2\u000c\u0010\u0006\u001a\u0008\u0012\u0004\u0012\u00020\u00050\u00042\u0006\u0010\u0008\u001a\u00020\u0007J-\u0010 \u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010\u001c\u001a\u00020\u00072\u000c\u0010\u001d\u001a\u0008\u0012\u0004\u0012\u00020\u00050\u0004H\u0000\u00a2\u0006\u0004\u0008\u001e\u0010\u001fJ(\u0010$\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010\u001c\u001a\u00020\u00072\u0008\u0010\"\u001a\u0004\u0018\u00010!2\u0006\u0010#\u001a\u00020\u0016J\u001f\u0010)\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010&\u001a\u00020%H\u0000\u00a2\u0006\u0004\u0008\'\u0010(J\u001f\u0010,\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010*\u001a\u00020%H\u0000\u00a2\u0006\u0004\u0008+\u0010(J\u001f\u00100\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010-\u001a\u00020\u0016H\u0000\u00a2\u0006\u0004\u0008.\u0010/J\u001e\u00104\u001a\u00020\r2\u0006\u00101\u001a\u00020\u00072\u0006\u00102\u001a\u00020\u00022\u0006\u00103\u001a\u00020\u0002J\u0006\u00105\u001a\u00020\rJ\u0006\u00104\u001a\u00020\rJ\u0006\u00106\u001a\u00020\rJ\u0006\u00107\u001a\u00020\rJ\u000e\u00108\u001a\u00020\r2\u0006\u0010*\u001a\u00020%J\u0008\u00109\u001a\u00020\rH\u0016J)\u00109\u001a\u00020\r2\u0006\u0010:\u001a\u00020%2\u0006\u0010;\u001a\u00020%2\u0008\u0010<\u001a\u0004\u0018\u00010\u000bH\u0000\u00a2\u0006\u0004\u0008=\u0010>J\u001c\u0010B\u001a\u00020\r2\u0008\u0008\u0002\u0010?\u001a\u00020\u00072\u0008\u0008\u0002\u0010A\u001a\u00020@H\u0007J\u000e\u0010E\u001a\u00020\r2\u0006\u0010D\u001a\u00020CJ\u000e\u0010G\u001a\u00020\u00072\u0006\u0010F\u001a\u00020\u0016J\u000f\u0010J\u001a\u00020\rH\u0000\u00a2\u0006\u0004\u0008H\u0010IJ\u0017\u0010M\u001a\u00020\u00072\u0006\u0010\u0012\u001a\u00020\u0002H\u0000\u00a2\u0006\u0004\u0008K\u0010LJ%\u0010P\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u000c\u0010\u0006\u001a\u0008\u0012\u0004\u0012\u00020\u00050\u0004H\u0000\u00a2\u0006\u0004\u0008N\u0010OJ-\u0010T\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u000c\u0010\u0006\u001a\u0008\u0012\u0004\u0012\u00020\u00050\u00042\u0006\u0010Q\u001a\u00020\u0007H\u0000\u00a2\u0006\u0004\u0008R\u0010SJ/\u0010Y\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010V\u001a\u00020U2\u0006\u0010#\u001a\u00020\u00022\u0006\u0010Q\u001a\u00020\u0007H\u0000\u00a2\u0006\u0004\u0008W\u0010XJ\u001f\u0010[\u001a\u00020\r2\u0006\u0010\u0012\u001a\u00020\u00022\u0006\u0010&\u001a\u00020%H\u0000\u00a2\u0006\u0004\u0008Z\u0010(R\u001a\u0010\\\u001a\u00020\u00078\u0000X\u0080\u0004\u00a2\u0006\u000c\n\u0004\u0008\\\u0010]\u001a\u0004\u0008^\u0010_R\u001a\u0010a\u001a\u00020`8\u0000X\u0080\u0004\u00a2\u0006\u000c\n\u0004\u0008a\u0010b\u001a\u0004\u0008c\u0010dR&\u0010f\u001a\u000e\u0012\u0004\u0012\u00020\u0002\u0012\u0004\u0012\u00020\t0e8\u0000X\u0080\u0004\u00a2\u0006\u000c\n\u0004\u0008f\u0010g\u001a\u0004\u0008h\u0010iR\u001a\u0010k\u001a\u00020j8\u0000X\u0080\u0004\u00a2\u0006\u000c\n\u0004\u0008k\u0010l\u001a\u0004\u0008m\u0010nR\"\u0010o\u001a\u00020\u00028\u0000@\u0000X\u0080\u000e\u00a2\u0006\u0012\n\u0004\u0008o\u0010p\u001a\u0004\u0008q\u0010r\"\u0004\u0008s\u0010tR\"\u0010u\u001a\u00020\u00028\u0000@\u0000X\u0080\u000e\u00a2\u0006\u0012\n\u0004\u0008u\u0010p\u001a\u0004\u0008v\u0010r\"\u0004\u0008w\u0010tR\u0016\u0010x\u001a\u00020\u00078\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0006\n\u0004\u0008x\u0010]R\u0014\u0010A\u001a\u00020@8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008A\u0010yR\u0014\u0010{\u001a\u00020z8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008{\u0010|R\u0014\u0010}\u001a\u00020z8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008}\u0010|R\u0014\u0010~\u001a\u00020z8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008~\u0010|R\u0017\u0010\u0080\u0001\u001a\u00020\u007f8\u0002X\u0082\u0004\u00a2\u0006\u0008\n\u0006\u0008\u0080\u0001\u0010\u0081\u0001R\u0019\u0010\u0082\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0082\u0001\u0010\u0083\u0001R\u0019\u0010\u0084\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0084\u0001\u0010\u0083\u0001R\u0019\u0010\u0085\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0085\u0001\u0010\u0083\u0001R\u0019\u0010\u0086\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0086\u0001\u0010\u0083\u0001R\u0019\u0010\u0087\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0087\u0001\u0010\u0083\u0001R\u0019\u0010\u0088\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0088\u0001\u0010\u0083\u0001R\u0019\u0010\u0089\u0001\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e\u00a2\u0006\u0008\n\u0006\u0008\u0089\u0001\u0010\u0083\u0001R\u001c\u0010\u008a\u0001\u001a\u00020C8\u0006\u00a2\u0006\u0010\n\u0006\u0008\u008a\u0001\u0010\u008b\u0001\u001a\u0006\u0008\u008c\u0001\u0010\u008d\u0001R)\u0010\u008e\u0001\u001a\u00020C8\u0006@\u0006X\u0086\u000e\u00a2\u0006\u0018\n\u0006\u0008\u008e\u0001\u0010\u008b\u0001\u001a\u0006\u0008\u008f\u0001\u0010\u008d\u0001\"\u0006\u0008\u0090\u0001\u0010\u0091\u0001R*\u0010\u0093\u0001\u001a\u00020\u00162\u0007\u0010\u0092\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e\u00a2\u0006\u0010\n\u0006\u0008\u0093\u0001\u0010\u0083\u0001\u001a\u0006\u0008\u0094\u0001\u0010\u0095\u0001R*\u0010\u0096\u0001\u001a\u00020\u00162\u0007\u0010\u0092\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e\u00a2\u0006\u0010\n\u0006\u0008\u0096\u0001\u0010\u0083\u0001\u001a\u0006\u0008\u0097\u0001\u0010\u0095\u0001R*\u0010\u0098\u0001\u001a\u00020\u00162\u0007\u0010\u0092\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e\u00a2\u0006\u0010\n\u0006\u0008\u0098\u0001\u0010\u0083\u0001\u001a\u0006\u0008\u0099\u0001\u0010\u0095\u0001R*\u0010\u009a\u0001\u001a\u00020\u00162\u0007\u0010\u0092\u0001\u001a\u00020\u00168\u0006@BX\u0086\u000e\u00a2\u0006\u0010\n\u0006\u0008\u009a\u0001\u0010\u0083\u0001\u001a\u0006\u0008\u009b\u0001\u0010\u0095\u0001R \u0010\u009d\u0001\u001a\u00030\u009c\u00018\u0000X\u0080\u0004\u00a2\u0006\u0010\n\u0006\u0008\u009d\u0001\u0010\u009e\u0001\u001a\u0006\u0008\u009f\u0001\u0010\u00a0\u0001R\u001d\u0010\u00a2\u0001\u001a\u00030\u00a1\u00018\u0006\u00a2\u0006\u0010\n\u0006\u0008\u00a2\u0001\u0010\u00a3\u0001\u001a\u0006\u0008\u00a4\u0001\u0010\u00a5\u0001R!\u0010\u00a7\u0001\u001a\u00070\u00a6\u0001R\u00020\u00008\u0006\u00a2\u0006\u0010\n\u0006\u0008\u00a7\u0001\u0010\u00a8\u0001\u001a\u0006\u0008\u00a9\u0001\u0010\u00aa\u0001R\u001e\u0010\u00ac\u0001\u001a\t\u0012\u0004\u0012\u00020\u00020\u00ab\u00018\u0002X\u0082\u0004\u00a2\u0006\u0008\n\u0006\u0008\u00ac\u0001\u0010\u00ad\u0001\u00a8\u0006\u00b6\u0001" } d2 = { "Lokhttp3/internal/http2/Http2Connection;", "Ljava/io/Closeable;", "", "associatedStreamId", "", "Lokhttp3/internal/http2/Header;", "requestHeaders", "", "out", "Lokhttp3/internal/http2/Http2Stream;", "newStream", "Ljava/io/IOException;", "e", "Lkotlin/d1;", "failConnection", "openStreamCount", "id", "getStream", "streamId", "removeStream$okhttp", "(I)Lokhttp3/internal/http2/Http2Stream;", "removeStream", "", "read", "updateConnectionFlowControl$okhttp", "(J)V", "updateConnectionFlowControl", "pushStream", "outFinished", "alternating", "writeHeaders$okhttp", "(IZLjava/util/List;)V", "writeHeaders", "Lzj/m;", "buffer", "byteCount", "writeData", "Lokhttp3/internal/http2/ErrorCode;", "errorCode", "writeSynResetLater$okhttp", "(ILokhttp3/internal/http2/ErrorCode;)V", "writeSynResetLater", "statusCode", "writeSynReset$okhttp", "writeSynReset", "unacknowledgedBytesRead", "writeWindowUpdateLater$okhttp", "(IJ)V", "writeWindowUpdateLater", "reply", "payload1", "payload2", "writePing", "writePingAndAwaitPong", "awaitPong", "flush", "shutdown", "close", "connectionCode", "streamCode", "cause", "close$okhttp", "(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V", "sendConnectionPreface", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "start", "Lokhttp3/internal/http2/Settings;", "settings", "setSettings", "nowNs", "isHealthy", "sendDegradedPingLater$okhttp", "()V", "sendDegradedPingLater", "pushedStream$okhttp", "(I)Z", "pushedStream", "pushRequestLater$okhttp", "(ILjava/util/List;)V", "pushRequestLater", "inFinished", "pushHeadersLater$okhttp", "(ILjava/util/List;Z)V", "pushHeadersLater", "Lzj/o;", "source", "pushDataLater$okhttp", "(ILzj/o;IZ)V", "pushDataLater", "pushResetLater$okhttp", "pushResetLater", "client", "Z", "getClient$okhttp", "()Z", "Lokhttp3/internal/http2/Http2Connection$Listener;", "listener", "Lokhttp3/internal/http2/Http2Connection$Listener;", "getListener$okhttp", "()Lokhttp3/internal/http2/Http2Connection$Listener;", "", "streams", "Ljava/util/Map;", "getStreams$okhttp", "()Ljava/util/Map;", "", "connectionName", "Ljava/lang/String;", "getConnectionName$okhttp", "()Ljava/lang/String;", "lastGoodStreamId", "I", "getLastGoodStreamId$okhttp", "()I", "setLastGoodStreamId$okhttp", "(I)V", "nextStreamId", "getNextStreamId$okhttp", "setNextStreamId$okhttp", "isShutdown", "Lokhttp3/internal/concurrent/TaskRunner;", "Lokhttp3/internal/concurrent/TaskQueue;", "writerQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "pushQueue", "settingsListenerQueue", "Lokhttp3/internal/http2/PushObserver;", "pushObserver", "Lokhttp3/internal/http2/PushObserver;", "intervalPingsSent", "J", "intervalPongsReceived", "degradedPingsSent", "degradedPongsReceived", "awaitPingsSent", "awaitPongsReceived", "degradedPongDeadlineNs", "okHttpSettings", "Lokhttp3/internal/http2/Settings;", "getOkHttpSettings", "()Lokhttp3/internal/http2/Settings;", "peerSettings", "getPeerSettings", "setPeerSettings", "(Lokhttp3/internal/http2/Settings;)V", "", "readBytesTotal", "getReadBytesTotal", "()J", "readBytesAcknowledged", "getReadBytesAcknowledged", "writeBytesTotal", "getWriteBytesTotal", "writeBytesMaximum", "getWriteBytesMaximum", "Ljava/net/Socket;", "socket", "Ljava/net/Socket;", "getSocket$okhttp", "()Ljava/net/Socket;", "Lokhttp3/internal/http2/Http2Writer;", "writer", "Lokhttp3/internal/http2/Http2Writer;", "getWriter", "()Lokhttp3/internal/http2/Http2Writer;", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "readerRunnable", "Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "getReaderRunnable", "()Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;", "", "currentPushRequests", "Ljava/util/Set;", "Lokhttp3/internal/http2/Http2Connection$Builder;", "builder", "", "(Lokhttp3/internal/http2/Http2Connection$Builder;)V", "Companion", "Builder", "Listener", "ReaderRunnable", "okhttp" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # static fields .field public static final AWAIT_PING:I = 0x3 .field public static final Companion:Lokhttp3/internal/http2/Http2Connection$Companion; .field private static final DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field public static final DEGRADED_PING:I = 0x2 .field public static final DEGRADED_PONG_TIMEOUT_NS:I = 0x3b9aca00 .field public static final INTERVAL_PING:I = 0x1 .field public static final OKHTTP_CLIENT_WINDOW_SIZE:I = 0x1000000 # instance fields .field private awaitPingsSent:J .field private awaitPongsReceived:J .field private final client:Z .field private final connectionName:Ljava/lang/String; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private final currentPushRequests:Ljava/util/Set; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Set<", "Ljava/lang/Integer;", ">;" } .end annotation .end field .field private degradedPingsSent:J .field private degradedPongDeadlineNs:J .field private degradedPongsReceived:J .field private intervalPingsSent:J .field private intervalPongsReceived:J .field private isShutdown:Z .field private lastGoodStreamId:I .field private final listener:Lokhttp3/internal/http2/Http2Connection$Listener; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private nextStreamId:I .field private final okHttpSettings:Lokhttp3/internal/http2/Settings; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private peerSettings:Lokhttp3/internal/http2/Settings; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private final pushObserver:Lokhttp3/internal/http2/PushObserver; .field private final pushQueue:Lokhttp3/internal/concurrent/TaskQueue; .field private readBytesAcknowledged:J .field private readBytesTotal:J .field private final readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private final settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue; .field private final socket:Ljava/net/Socket; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private final streams:Ljava/util/Map; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Map<", "Ljava/lang/Integer;", "Lokhttp3/internal/http2/Http2Stream;", ">;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private final taskRunner:Lokhttp3/internal/concurrent/TaskRunner; .field private writeBytesMaximum:J .field private writeBytesTotal:J .field private final writer:Lokhttp3/internal/http2/Http2Writer; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field private final writerQueue:Lokhttp3/internal/concurrent/TaskQueue; # direct methods .method public static constructor ()V .locals 3 new-instance v0, Lokhttp3/internal/http2/Http2Connection$Companion; const/4 v1, 0x0 invoke-direct {v0, v1}, Lokhttp3/internal/http2/Http2Connection$Companion;->(Lkotlin/jvm/internal/u;)V sput-object v0, Lokhttp3/internal/http2/Http2Connection;->Companion:Lokhttp3/internal/http2/Http2Connection$Companion; .line 1 new-instance v0, Lokhttp3/internal/http2/Settings; invoke-direct {v0}, Lokhttp3/internal/http2/Settings;->()V const/4 v1, 0x7 const v2, 0xffff .line 2 invoke-virtual {v0, v1, v2}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings; const/4 v1, 0x5 const/16 v2, 0x4000 .line 3 invoke-virtual {v0, v1, v2}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings; .line 4 sput-object v0, Lokhttp3/internal/http2/Http2Connection;->DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings; return-void .end method .method public constructor (Lokhttp3/internal/http2/Http2Connection$Builder;)V .locals 12 .param p1 # Lokhttp3/internal/http2/Http2Connection$Builder; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "builder" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V .line 2 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getClient$okhttp()Z move-result v0 iput-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z .line 3 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getListener$okhttp()Lokhttp3/internal/http2/Http2Connection$Listener; move-result-object v1 iput-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->listener:Lokhttp3/internal/http2/Http2Connection$Listener; .line 4 new-instance v1, Ljava/util/LinkedHashMap; invoke-direct {v1}, Ljava/util/LinkedHashMap;->()V iput-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; .line 5 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getConnectionName$okhttp()Ljava/lang/String; move-result-object v1 iput-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; .line 6 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getClient$okhttp()Z move-result v2 if-eqz v2, :cond_0 const/4 v2, 0x3 goto :goto_0 :cond_0 const/4 v2, 0x2 :goto_0 iput v2, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I .line 7 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getTaskRunner$okhttp()Lokhttp3/internal/concurrent/TaskRunner; move-result-object v2 iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->taskRunner:Lokhttp3/internal/concurrent/TaskRunner; .line 8 invoke-virtual {v2}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue; move-result-object v3 iput-object v3, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue; .line 9 invoke-virtual {v2}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue; move-result-object v4 iput-object v4, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue; .line 10 invoke-virtual {v2}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue; move-result-object v2 iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue; .line 11 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getPushObserver$okhttp()Lokhttp3/internal/http2/PushObserver; move-result-object v2 iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->pushObserver:Lokhttp3/internal/http2/PushObserver; .line 12 new-instance v2, Lokhttp3/internal/http2/Settings; invoke-direct {v2}, Lokhttp3/internal/http2/Settings;->()V .line 13 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getClient$okhttp()Z move-result v4 if-eqz v4, :cond_1 const/4 v4, 0x7 const/high16 v5, 0x1000000 .line 14 invoke-virtual {v2, v4, v5}, Lokhttp3/internal/http2/Settings;->set(II)Lokhttp3/internal/http2/Settings; .line 15 :cond_1 sget-object v4, Lkotlin/d1;->a:Lkotlin/d1; .line 16 iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; .line 17 sget-object v2, Lokhttp3/internal/http2/Http2Connection;->DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings; iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings; .line 18 invoke-virtual {v2}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I move-result v2 int-to-long v4, v2 iput-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J .line 19 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getSocket$okhttp()Ljava/net/Socket; move-result-object v2 iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket; .line 20 new-instance v2, Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getSink$okhttp()Lzj/n; move-result-object v4 invoke-direct {v2, v4, v0}, Lokhttp3/internal/http2/Http2Writer;->(Lzj/n;Z)V iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; .line 21 new-instance v2, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; new-instance v4, Lokhttp3/internal/http2/Http2Reader; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getSource$okhttp()Lzj/o; move-result-object v5 invoke-direct {v4, v5, v0}, Lokhttp3/internal/http2/Http2Reader;->(Lzj/o;Z)V invoke-direct {v2, p0, v4}, Lokhttp3/internal/http2/Http2Connection$ReaderRunnable;->(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Http2Reader;)V iput-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; .line 22 new-instance v0, Ljava/util/LinkedHashSet; invoke-direct {v0}, Ljava/util/LinkedHashSet;->()V iput-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set; .line 23 invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getPingIntervalMillis$okhttp()I move-result v0 if-eqz v0, :cond_2 .line 24 sget-object v0, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection$Builder;->getPingIntervalMillis$okhttp()I move-result p1 int-to-long v4, p1 invoke-virtual {v0, v4, v5}, Ljava/util/concurrent/TimeUnit;->toNanos(J)J move-result-wide v4 const-string p1, " ping" .line 25 invoke-static {v1, p1}, Lc/g;->a(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; move-result-object v8 .line 26 new-instance p1, Lokhttp3/internal/http2/Http2Connection$$special$$inlined$schedule$1; move-object v6, p1 move-object v7, v8 move-object v9, p0 move-wide v10, v4 invoke-direct/range {v6 .. v11}, Lokhttp3/internal/http2/Http2Connection$$special$$inlined$schedule$1;->(Ljava/lang/String;Ljava/lang/String;Lokhttp3/internal/http2/Http2Connection;J)V invoke-virtual {v3, p1, v4, v5}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V :cond_2 return-void .end method .method public static final synthetic access$failConnection(Lokhttp3/internal/http2/Http2Connection;Ljava/io/IOException;)V .locals 0 .line 1 invoke-direct {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->failConnection(Ljava/io/IOException;)V return-void .end method .method public static final synthetic access$getAwaitPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;)J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPongsReceived:J return-wide v0 .end method .method public static final synthetic access$getCurrentPushRequests$p(Lokhttp3/internal/http2/Http2Connection;)Ljava/util/Set; .locals 0 .line 1 iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->currentPushRequests:Ljava/util/Set; return-object p0 .end method .method public static final synthetic access$getDEFAULT_SETTINGS$cp()Lokhttp3/internal/http2/Settings; .locals 1 .line 1 sget-object v0, Lokhttp3/internal/http2/Http2Connection;->DEFAULT_SETTINGS:Lokhttp3/internal/http2/Settings; return-object v0 .end method .method public static final synthetic access$getDegradedPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;)J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J return-wide v0 .end method .method public static final synthetic access$getIntervalPingsSent$p(Lokhttp3/internal/http2/Http2Connection;)J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPingsSent:J return-wide v0 .end method .method public static final synthetic access$getIntervalPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;)J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPongsReceived:J return-wide v0 .end method .method public static final synthetic access$getPushObserver$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/http2/PushObserver; .locals 0 .line 1 iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->pushObserver:Lokhttp3/internal/http2/PushObserver; return-object p0 .end method .method public static final synthetic access$getSettingsListenerQueue$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue; .locals 0 .line 1 iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue; return-object p0 .end method .method public static final synthetic access$getTaskRunner$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskRunner; .locals 0 .line 1 iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->taskRunner:Lokhttp3/internal/concurrent/TaskRunner; return-object p0 .end method .method public static final synthetic access$getWriteBytesMaximum$p(Lokhttp3/internal/http2/Http2Connection;)J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J return-wide v0 .end method .method public static final synthetic access$getWriterQueue$p(Lokhttp3/internal/http2/Http2Connection;)Lokhttp3/internal/concurrent/TaskQueue; .locals 0 .line 1 iget-object p0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue; return-object p0 .end method .method public static final synthetic access$isShutdown$p(Lokhttp3/internal/http2/Http2Connection;)Z .locals 0 .line 1 iget-boolean p0, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z return p0 .end method .method public static final synthetic access$setAwaitPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;J)V .locals 0 .line 1 iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPongsReceived:J return-void .end method .method public static final synthetic access$setDegradedPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;J)V .locals 0 .line 1 iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J return-void .end method .method public static final synthetic access$setIntervalPingsSent$p(Lokhttp3/internal/http2/Http2Connection;J)V .locals 0 .line 1 iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPingsSent:J return-void .end method .method public static final synthetic access$setIntervalPongsReceived$p(Lokhttp3/internal/http2/Http2Connection;J)V .locals 0 .line 1 iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->intervalPongsReceived:J return-void .end method .method public static final synthetic access$setShutdown$p(Lokhttp3/internal/http2/Http2Connection;Z)V .locals 0 .line 1 iput-boolean p1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z return-void .end method .method public static final synthetic access$setWriteBytesMaximum$p(Lokhttp3/internal/http2/Http2Connection;J)V .locals 0 .line 1 iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J return-void .end method .method private final failConnection(Ljava/io/IOException;)V .locals 1 .line 1 sget-object v0, Lokhttp3/internal/http2/ErrorCode;->PROTOCOL_ERROR:Lokhttp3/internal/http2/ErrorCode; invoke-virtual {p0, v0, v0, p1}, Lokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V return-void .end method .method private final 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 2 iget-object v7, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v7 .line 3 :try_start_0 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_1 .line 4 :try_start_1 iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I const v1, 0x3fffffff # 1.9999999f if-le v0, v1, :cond_0 .line 5 sget-object v0, Lokhttp3/internal/http2/ErrorCode;->REFUSED_STREAM:Lokhttp3/internal/http2/ErrorCode; invoke-virtual {p0, v0}, Lokhttp3/internal/http2/Http2Connection;->shutdown(Lokhttp3/internal/http2/ErrorCode;)V .line 6 :cond_0 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z if-nez v0, :cond_7 .line 7 iget v8, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I add-int/lit8 v0, v8, 0x2 .line 8 iput v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I .line 9 new-instance v9, Lokhttp3/internal/http2/Http2Stream; const/4 v5, 0x0 move-object v0, v9 move v1, v8 move-object v2, p0 move v3, v6 invoke-direct/range {v0 .. v5}, Lokhttp3/internal/http2/Http2Stream;->(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V const/4 v0, 0x1 if-eqz p3, :cond_2 .line 10 iget-wide v1, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J iget-wide v3, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J cmp-long p3, v1, v3 if-gez p3, :cond_2 invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->getWriteBytesTotal()J move-result-wide v1 invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->getWriteBytesMaximum()J move-result-wide v3 cmp-long p3, v1, v3 if-ltz p3, :cond_1 goto :goto_0 :cond_1 const/4 p3, 0x0 goto :goto_1 :cond_2 :goto_0 move p3, v0 .line 11 :goto_1 invoke-virtual {v9}, Lokhttp3/internal/http2/Http2Stream;->isOpen()Z move-result v1 if-eqz v1, :cond_3 .line 12 iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-static {v8}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 invoke-interface {v1, v2, v9}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; .line 13 :cond_3 sget-object v1, Lkotlin/d1;->a:Lkotlin/d1; :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 14 :try_start_2 monitor-exit p0 if-nez p1, :cond_4 .line 15 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1, v6, v8, p2}, Lokhttp3/internal/http2/Http2Writer;->headers(ZILjava/util/List;)V goto :goto_2 .line 16 :cond_4 iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z xor-int/2addr v0, v1 if-eqz v0, :cond_6 .line 17 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 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 .line 18 :goto_2 monitor-exit v7 if-eqz p3, :cond_5 .line 19 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->flush()V :cond_5 return-object v9 :cond_6 :try_start_3 const-string p1, "client streams shouldn\'t have associated stream IDs" .line 20 new-instance p2, Ljava/lang/IllegalArgumentException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p2, p1}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p2 :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_1 .line 21 :cond_7 :try_start_4 new-instance p1, Lokhttp3/internal/http2/ConnectionShutdownException; invoke-direct {p1}, Lokhttp3/internal/http2/ConnectionShutdownException;->()V throw p1 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_0 :catchall_0 move-exception p1 .line 22 :try_start_5 monitor-exit p0 throw p1 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_1 :catchall_1 move-exception p1 .line 23 monitor-exit v7 throw p1 .end method .method public static synthetic start$default(Lokhttp3/internal/http2/Http2Connection;ZLokhttp3/internal/concurrent/TaskRunner;ILjava/lang/Object;)V .locals 0 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation and-int/lit8 p4, p3, 0x1 if-eqz p4, :cond_0 const/4 p1, 0x1 :cond_0 and-int/lit8 p3, p3, 0x2 if-eqz p3, :cond_1 .line 1 sget-object p2, Lokhttp3/internal/concurrent/TaskRunner;->INSTANCE:Lokhttp3/internal/concurrent/TaskRunner; :cond_1 invoke-virtual {p0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->start(ZLokhttp3/internal/concurrent/TaskRunner;)V return-void .end method # virtual methods .method public final declared-synchronized awaitPong()V .locals 4 .annotation system Ldalvik/annotation/Throws; value = { Ljava/lang/InterruptedException; } .end annotation monitor-enter p0 .line 1 :goto_0 :try_start_0 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPongsReceived:J iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPingsSent:J cmp-long v0, v0, v2 if-gez v0, :cond_0 .line 2 invoke-virtual {p0}, Ljava/lang/Object;->wait()V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 goto :goto_0 .line 3 :cond_0 monitor-exit p0 return-void :catchall_0 move-exception v0 monitor-exit p0 throw v0 .end method .method public close()V .locals 3 .line 1 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; const/4 v2, 0x0 invoke-virtual {p0, v0, v1, v2}, Lokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V return-void .end method .method public final close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V .locals 3 .param p1 # Lokhttp3/internal/http2/ErrorCode; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p2 # Lokhttp3/internal/http2/ErrorCode; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p3 # Ljava/io/IOException; .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .end param const-string v0, "connectionCode" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "streamCode" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 sget-boolean v0, Lokhttp3/internal/Util;->assertionsEnabled:Z if-eqz v0, :cond_1 invoke-static {p0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z move-result v0 if-nez v0, :cond_0 goto :goto_0 .line 2 :cond_0 new-instance p1, Ljava/lang/AssertionError; const-string p2, "Thread " invoke-static {p2}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object p2 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object p3 const-string v0, "Thread.currentThread()" invoke-static {p3, v0}, Lkotlin/jvm/internal/f0;->o(Ljava/lang/Object;Ljava/lang/String;)V invoke-virtual {p3}, Ljava/lang/Thread;->getName()Ljava/lang/String; move-result-object p3 invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const-string p3, " MUST NOT hold lock on " invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {p2, p0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p2 invoke-direct {p1, p2}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V throw p1 .line 3 :cond_1 :goto_0 :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 :catch_0 const/4 p1, 0x0 .line 4 monitor-enter p0 .line 5 :try_start_1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v0}, Ljava/util/Map;->isEmpty()Z move-result v0 xor-int/lit8 v0, v0, 0x1 const/4 v1, 0x0 if-eqz v0, :cond_3 .line 6 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {p1}, Ljava/util/Map;->values()Ljava/util/Collection; move-result-object p1 new-array v0, v1, [Lokhttp3/internal/http2/Http2Stream; .line 7 invoke-interface {p1, v0}, Ljava/util/Collection;->toArray([Ljava/lang/Object;)[Ljava/lang/Object; move-result-object p1 if-eqz p1, :cond_2 check-cast p1, [Lokhttp3/internal/http2/Http2Stream; .line 8 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; invoke-interface {v0}, Ljava/util/Map;->clear()V goto :goto_1 .line 9 :cond_2 new-instance p1, Ljava/lang/NullPointerException; const-string p2, "null cannot be cast to non-null type kotlin.Array" invoke-direct {p1, p2}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V throw p1 .line 10 :cond_3 :goto_1 sget-object v0, Lkotlin/d1;->a:Lkotlin/d1; :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 11 monitor-exit p0 if-eqz p1, :cond_4 .line 12 array-length v0, p1 :goto_2 if-ge v1, v0, :cond_4 aget-object v2, p1, v1 .line 13 :try_start_2 invoke-virtual {v2, p2, p3}, Lokhttp3/internal/http2/Http2Stream;->close(Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V :try_end_2 .catch Ljava/io/IOException; {:try_start_2 .. :try_end_2} :catch_1 :catch_1 add-int/lit8 v1, v1, 0x1 goto :goto_2 .line 14 :cond_4 :try_start_3 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->close()V :try_end_3 .catch Ljava/io/IOException; {:try_start_3 .. :try_end_3} :catch_2 .line 15 :catch_2 :try_start_4 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket; invoke-virtual {p1}, Ljava/net/Socket;->close()V :try_end_4 .catch Ljava/io/IOException; {:try_start_4 .. :try_end_4} :catch_3 .line 16 :catch_3 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue; invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->shutdown()V .line 17 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue; invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->shutdown()V .line 18 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->settingsListenerQueue:Lokhttp3/internal/concurrent/TaskQueue; invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->shutdown()V return-void :catchall_0 move-exception p1 .line 19 monitor-exit p0 throw p1 .end method .method public final flush()V .locals 1 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .line 1 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 final getClient$okhttp()Z .locals 1 .line 1 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z return v0 .end method .method public final getConnectionName$okhttp()Ljava/lang/String; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; return-object v0 .end method .method public final getLastGoodStreamId$okhttp()I .locals 1 .line 1 iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I return v0 .end method .method public final getListener$okhttp()Lokhttp3/internal/http2/Http2Connection$Listener; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->listener:Lokhttp3/internal/http2/Http2Connection$Listener; return-object v0 .end method .method public final getNextStreamId$okhttp()I .locals 1 .line 1 iget v0, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I return v0 .end method .method public final getOkHttpSettings()Lokhttp3/internal/http2/Settings; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings; return-object v0 .end method .method public final getPeerSettings()Lokhttp3/internal/http2/Settings; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings; return-object v0 .end method .method public final getReadBytesAcknowledged()J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J return-wide v0 .end method .method public final getReadBytesTotal()J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesTotal:J return-wide v0 .end method .method public final getReaderRunnable()Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; return-object v0 .end method .method public final getSocket$okhttp()Ljava/net/Socket; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->socket:Ljava/net/Socket; return-object v0 .end method .method public final declared-synchronized getStream(I)Lokhttp3/internal/http2/Http2Stream; .locals 1 .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation monitor-enter p0 .line 1 :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 final getStreams$okhttp()Ljava/util/Map; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/Map<", "Ljava/lang/Integer;", "Lokhttp3/internal/http2/Http2Stream;", ">;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->streams:Ljava/util/Map; return-object v0 .end method .method public final getWriteBytesMaximum()J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J return-wide v0 .end method .method public final getWriteBytesTotal()J .locals 2 .line 1 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J return-wide v0 .end method .method public final getWriter()Lokhttp3/internal/http2/Http2Writer; .locals 1 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; return-object v0 .end method .method public final declared-synchronized isHealthy(J)Z .locals 6 monitor-enter p0 .line 1 :try_start_0 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 const/4 v1, 0x0 if-eqz v0, :cond_0 monitor-exit p0 return v1 .line 2 :cond_0 :try_start_1 iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J cmp-long v0, v2, v4 if-gez v0, :cond_1 iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongDeadlineNs:J :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 cmp-long p1, p1, v2 if-ltz p1, :cond_1 monitor-exit p0 return v1 :cond_1 const/4 p1, 0x1 .line 3 monitor-exit p0 return p1 :catchall_0 move-exception p1 monitor-exit p0 throw p1 .end method .method public final newStream(Ljava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; .locals 1 .param p1 # Ljava/util/List; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .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 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation const-string v0, "requestHeaders" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V const/4 v0, 0x0 .line 1 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 final declared-synchronized openStreamCount()I .locals 1 monitor-enter p0 .line 1 :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 final pushDataLater$okhttp(ILzj/o;IZ)V .locals 11 .param p2 # Lzj/o; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const-string v0, "source" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 new-instance v8, Lzj/m; invoke-direct {v8}, Lzj/m;->()V int-to-long v0, p3 .line 2 invoke-interface {p2, v0, v1}, Lzj/o;->l0(J)V .line 3 invoke-interface {p2, v8, v0, v1}, Lzj/m0;->read(Lzj/m;J)J .line 4 iget-object p2, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v0, Ljava/lang/StringBuilder; invoke-direct {v0}, Ljava/lang/StringBuilder;->()V iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v1, 0x5b invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v1, "] onData" invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v4 .line 5 new-instance v0, Lokhttp3/internal/http2/Http2Connection$pushDataLater$$inlined$execute$1; const/4 v5, 0x1 move-object v1, v0 move-object v2, v4 move v3, v5 move-object v6, p0 move v7, p1 move v9, p3 move v10, p4 invoke-direct/range {v1 .. v10}, Lokhttp3/internal/http2/Http2Connection$pushDataLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILzj/m;IZ)V const-wide/16 p3, 0x0 invoke-virtual {p2, v0, p3, p4}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void .end method .method public final pushHeadersLater$okhttp(ILjava/util/List;Z)V .locals 12 .param p2 # Ljava/util/List; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(I", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;Z)V" } .end annotation const-string v0, "requestHeaders" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v2, 0x5b invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v2, "] onHeaders" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v6 .line 2 new-instance v1, Lokhttp3/internal/http2/Http2Connection$pushHeadersLater$$inlined$execute$1; const/4 v7, 0x1 move-object v3, v1 move-object v4, v6 move v5, v7 move-object v8, p0 move v9, p1 move-object v10, p2 move v11, p3 invoke-direct/range {v3 .. v11}, Lokhttp3/internal/http2/Http2Connection$pushHeadersLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILjava/util/List;Z)V const-wide/16 p1, 0x0 invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void .end method .method public final pushRequestLater$okhttp(ILjava/util/List;)V .locals 12 .param p2 # Ljava/util/List; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(I", "Ljava/util/List<", "Lokhttp3/internal/http2/Header;", ">;)V" } .end annotation const-string v0, "requestHeaders" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 monitor-enter p0 .line 2 :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 3 sget-object p2, Lokhttp3/internal/http2/ErrorCode;->PROTOCOL_ERROR:Lokhttp3/internal/http2/ErrorCode; invoke-virtual {p0, p1, p2}, Lokhttp3/internal/http2/Http2Connection;->writeSynResetLater$okhttp(ILokhttp3/internal/http2/ErrorCode;)V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 4 monitor-exit p0 return-void .line 5 :cond_0 :try_start_1 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 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 6 monitor-exit p0 .line 7 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v2, 0x5b invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v2, "] onRequest" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v6 const-wide/16 v1, 0x0 const/4 v7, 0x1 .line 8 new-instance v11, Lokhttp3/internal/http2/Http2Connection$pushRequestLater$$inlined$execute$1; move-object v3, v11 move-object v4, v6 move v5, v7 move-object v8, p0 move v9, p1 move-object v10, p2 invoke-direct/range {v3 .. v10}, Lokhttp3/internal/http2/Http2Connection$pushRequestLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILjava/util/List;)V invoke-virtual {v0, v11, v1, v2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void :catchall_0 move-exception p1 .line 9 monitor-exit p0 throw p1 .end method .method public final pushResetLater$okhttp(ILokhttp3/internal/http2/ErrorCode;)V .locals 11 .param p2 # Lokhttp3/internal/http2/ErrorCode; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "errorCode" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->pushQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v2, 0x5b invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v2, "] onReset" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v6 .line 2 new-instance v1, Lokhttp3/internal/http2/Http2Connection$pushResetLater$$inlined$execute$1; const/4 v7, 0x1 move-object v3, v1 move-object v4, v6 move v5, v7 move-object v8, p0 move v9, p1 move-object v10, p2 invoke-direct/range {v3 .. v10}, Lokhttp3/internal/http2/Http2Connection$pushResetLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILokhttp3/internal/http2/ErrorCode;)V const-wide/16 p1, 0x0 invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void .end method .method public final pushStream(ILjava/util/List;Z)Lokhttp3/internal/http2/Http2Stream; .locals 1 .param p2 # Ljava/util/List; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .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 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation const-string v0, "requestHeaders" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Connection;->client:Z xor-int/lit8 v0, v0, 0x1 if-eqz v0, :cond_0 .line 2 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 3 :cond_0 new-instance p1, Ljava/lang/IllegalStateException; const-string p2, "Client cannot push requests." invoke-virtual {p2}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p2 invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V throw p1 .end method .method public final pushedStream$okhttp(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 public final declared-synchronized removeStream$okhttp(I)Lokhttp3/internal/http2/Http2Stream; .locals 1 .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation monitor-enter p0 .line 1 :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 2 invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 3 monitor-exit p0 return-object p1 :catchall_0 move-exception p1 monitor-exit p0 throw p1 .end method .method public final sendDegradedPingLater$okhttp()V .locals 10 .line 1 monitor-enter p0 .line 2 :try_start_0 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongsReceived:J iget-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 cmp-long v0, v0, v2 if-gez v0, :cond_0 monitor-exit p0 return-void :cond_0 const-wide/16 v0, 0x1 add-long/2addr v2, v0 .line 3 :try_start_1 iput-wide v2, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPingsSent:J .line 4 invoke-static {}, Ljava/lang/System;->nanoTime()J move-result-wide v0 const v2, 0x3b9aca00 int-to-long v2, v2 add-long/2addr v0, v2 iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->degradedPongDeadlineNs:J .line 5 sget-object v0, Lkotlin/d1;->a:Lkotlin/d1; :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 6 monitor-exit p0 .line 7 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; const-string v3, " ping" invoke-static {v1, v2, v3}, Landroidx/camera/camera2/internal/b;->a(Ljava/lang/StringBuilder;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; move-result-object v7 const-wide/16 v1, 0x0 const/4 v8, 0x1 .line 8 new-instance v3, Lokhttp3/internal/http2/Http2Connection$sendDegradedPingLater$$inlined$execute$1; move-object v4, v3 move-object v5, v7 move v6, v8 move-object v9, p0 invoke-direct/range {v4 .. v9}, Lokhttp3/internal/http2/Http2Connection$sendDegradedPingLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;)V invoke-virtual {v0, v3, v1, v2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void :catchall_0 move-exception v0 .line 9 monitor-exit p0 throw v0 .end method .method public final setLastGoodStreamId$okhttp(I)V .locals 0 .line 1 iput p1, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I return-void .end method .method public final setNextStreamId$okhttp(I)V .locals 0 .line 1 iput p1, p0, Lokhttp3/internal/http2/Http2Connection;->nextStreamId:I return-void .end method .method public final setPeerSettings(Lokhttp3/internal/http2/Settings;)V .locals 1 .param p1 # Lokhttp3/internal/http2/Settings; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iput-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings; return-void .end method .method public final setSettings(Lokhttp3/internal/http2/Settings;)V .locals 2 .param p1 # Lokhttp3/internal/http2/Settings; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const-string v0, "settings" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v0 .line 2 :try_start_0 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_1 .line 3 :try_start_1 iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z if-nez v1, :cond_0 .line 4 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 5 sget-object v1, Lkotlin/d1;->a:Lkotlin/d1; :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 6 :try_start_2 monitor-exit p0 .line 7 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 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 .line 8 monitor-exit v0 return-void .line 9 :cond_0 :try_start_3 new-instance p1, Lokhttp3/internal/http2/ConnectionShutdownException; invoke-direct {p1}, Lokhttp3/internal/http2/ConnectionShutdownException;->()V throw p1 :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_0 :catchall_0 move-exception p1 .line 10 :try_start_4 monitor-exit p0 throw p1 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_1 :catchall_1 move-exception p1 .line 11 monitor-exit v0 throw p1 .end method .method public final shutdown(Lokhttp3/internal/http2/ErrorCode;)V .locals 4 .param p1 # Lokhttp3/internal/http2/ErrorCode; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const-string v0, "statusCode" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; monitor-enter v0 .line 2 :try_start_0 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_1 .line 3 :try_start_1 iget-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 if-eqz v1, :cond_0 .line 4 :try_start_2 monitor-exit p0 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 monitor-exit v0 return-void :cond_0 const/4 v1, 0x1 .line 5 :try_start_3 iput-boolean v1, p0, Lokhttp3/internal/http2/Http2Connection;->isShutdown:Z .line 6 iget v1, p0, Lokhttp3/internal/http2/Http2Connection;->lastGoodStreamId:I .line 7 sget-object v2, Lkotlin/d1;->a:Lkotlin/d1; :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_0 .line 8 :try_start_4 monitor-exit p0 .line 9 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 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_1 .line 10 monitor-exit v0 return-void :catchall_0 move-exception p1 .line 11 :try_start_5 monitor-exit p0 throw p1 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_1 :catchall_1 move-exception p1 .line 12 monitor-exit v0 throw p1 .end method .method public final start()V .locals 3 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .annotation build Lkotlin/jvm/JvmOverloads; .end annotation const/4 v0, 0x0 const/4 v1, 0x0 const/4 v2, 0x3 invoke-static {p0, v0, v1, v2, v1}, Lokhttp3/internal/http2/Http2Connection;->start$default(Lokhttp3/internal/http2/Http2Connection;ZLokhttp3/internal/concurrent/TaskRunner;ILjava/lang/Object;)V return-void .end method .method public final start(Z)V .locals 2 .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .annotation build Lkotlin/jvm/JvmOverloads; .end annotation const/4 v0, 0x0 const/4 v1, 0x2 invoke-static {p0, p1, v0, v1, v0}, Lokhttp3/internal/http2/Http2Connection;->start$default(Lokhttp3/internal/http2/Http2Connection;ZLokhttp3/internal/concurrent/TaskRunner;ILjava/lang/Object;)V return-void .end method .method public final start(ZLokhttp3/internal/concurrent/TaskRunner;)V .locals 8 .param p2 # Lokhttp3/internal/concurrent/TaskRunner; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation .annotation build Lkotlin/jvm/JvmOverloads; .end annotation const-string v0, "taskRunner" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V if-eqz p1, :cond_0 .line 1 iget-object p1, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Writer;->connectionPreface()V .line 2 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 3 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 4 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 5 :cond_0 invoke-virtual {p2}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue; move-result-object p1 iget-object v4, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; iget-object v1, p0, Lokhttp3/internal/http2/Http2Connection;->readerRunnable:Lokhttp3/internal/http2/Http2Connection$ReaderRunnable; const-wide/16 v6, 0x0 const/4 v5, 0x1 .line 6 new-instance p2, Lokhttp3/internal/concurrent/TaskQueue$execute$1; move-object v0, p2 move-object v2, v4 move v3, v5 invoke-direct/range {v0 .. v5}, Lokhttp3/internal/concurrent/TaskQueue$execute$1;->(Lej/a;Ljava/lang/String;ZLjava/lang/String;Z)V invoke-virtual {p1, p2, v6, v7}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void .end method .method public final declared-synchronized updateConnectionFlowControl$okhttp(J)V .locals 2 monitor-enter p0 .line 1 :try_start_0 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesTotal:J add-long/2addr v0, p1 iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesTotal:J .line 2 iget-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J sub-long/2addr v0, p1 .line 3 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 div-int/lit8 p1, p1, 0x2 int-to-long p1, p1 cmp-long p1, v0, p1 if-ltz p1, :cond_0 const/4 p1, 0x0 .line 4 invoke-virtual {p0, p1, v0, v1}, Lokhttp3/internal/http2/Http2Connection;->writeWindowUpdateLater$okhttp(IJ)V .line 5 iget-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J add-long/2addr p1, v0 iput-wide p1, p0, Lokhttp3/internal/http2/Http2Connection;->readBytesAcknowledged:J :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 6 :cond_0 monitor-exit p0 return-void :catchall_0 move-exception p1 monitor-exit p0 throw p1 .end method .method public final writeData(IZLzj/m;J)V .locals 8 .param p3 # Lzj/m; .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .end param .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 1 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(ZILzj/m;I)V return-void :cond_0 :goto_0 cmp-long v2, p4, v0 if-lez v2, :cond_4 .line 2 monitor-enter p0 .line 3 :goto_1 :try_start_0 iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J iget-wide v6, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesMaximum:J cmp-long v2, v4, v6 if-ltz v2, :cond_2 .line 4 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 5 invoke-virtual {p0}, Ljava/lang/Object;->wait()V goto :goto_1 .line 6 :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 :cond_2 sub-long/2addr v6, v4 .line 7 :try_start_1 invoke-static {p4, p5, v6, v7}, Ljava/lang/Math;->min(JJ)J move-result-wide v4 long-to-int v2, v4 .line 8 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 9 iget-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J int-to-long v6, v2 add-long/2addr v4, v6 iput-wide v4, p0, Lokhttp3/internal/http2/Http2Connection;->writeBytesTotal:J .line 10 sget-object v4, Lkotlin/d1;->a:Lkotlin/d1; :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 .line 11 monitor-exit p0 sub-long/2addr p4, v6 .line 12 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(ZILzj/m;I)V goto :goto_0 :catchall_0 move-exception p1 goto :goto_3 .line 13 :catch_0 :try_start_2 invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object p1 invoke-virtual {p1}, Ljava/lang/Thread;->interrupt()V .line 14 new-instance p1, Ljava/io/InterruptedIOException; invoke-direct {p1}, Ljava/io/InterruptedIOException;->()V throw p1 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_0 .line 15 :goto_3 monitor-exit p0 throw p1 :cond_4 return-void .end method .method public final writeHeaders$okhttp(IZLjava/util/List;)V .locals 1 .param p3 # Ljava/util/List; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .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 const-string v0, "alternating" invoke-static {p3, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0, p2, p1, p3}, Lokhttp3/internal/http2/Http2Writer;->headers(ZILjava/util/List;)V return-void .end method .method public final writePing()V .locals 4 .annotation system Ldalvik/annotation/Throws; value = { Ljava/lang/InterruptedException; } .end annotation .line 3 monitor-enter p0 .line 4 :try_start_0 iget-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPingsSent:J const-wide/16 v2, 0x1 add-long/2addr v0, v2 iput-wide v0, p0, Lokhttp3/internal/http2/Http2Connection;->awaitPingsSent:J :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 .line 5 monitor-exit p0 const/4 v0, 0x0 const/4 v1, 0x3 const v2, 0x4f4b6f6b .line 6 invoke-virtual {p0, v0, v1, v2}, Lokhttp3/internal/http2/Http2Connection;->writePing(ZII)V return-void :catchall_0 move-exception v0 .line 7 monitor-exit p0 throw v0 .end method .method public final writePing(ZII)V .locals 1 .line 1 :try_start_0 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writer:Lokhttp3/internal/http2/Http2Writer; invoke-virtual {v0, p1, p2, p3}, Lokhttp3/internal/http2/Http2Writer;->ping(ZII)V :try_end_0 .catch Ljava/io/IOException; {:try_start_0 .. :try_end_0} :catch_0 goto :goto_0 :catch_0 move-exception p1 .line 2 invoke-direct {p0, p1}, Lokhttp3/internal/http2/Http2Connection;->failConnection(Ljava/io/IOException;)V :goto_0 return-void .end method .method public final writePingAndAwaitPong()V .locals 0 .annotation system Ldalvik/annotation/Throws; value = { Ljava/lang/InterruptedException; } .end annotation .line 1 invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Connection;->writePing()V .line 2 invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Connection;->awaitPong()V return-void .end method .method public final writeSynReset$okhttp(ILokhttp3/internal/http2/ErrorCode;)V .locals 1 .param p2 # Lokhttp3/internal/http2/ErrorCode; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Throws; value = { Ljava/io/IOException; } .end annotation const-string v0, "statusCode" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 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 public final writeSynResetLater$okhttp(ILokhttp3/internal/http2/ErrorCode;)V .locals 11 .param p2 # Lokhttp3/internal/http2/ErrorCode; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "errorCode" invoke-static {p2, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v2, 0x5b invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v2, "] writeSynReset" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v6 .line 2 new-instance v1, Lokhttp3/internal/http2/Http2Connection$writeSynResetLater$$inlined$execute$1; const/4 v7, 0x1 move-object v3, v1 move-object v4, v6 move v5, v7 move-object v8, p0 move v9, p1 move-object v10, p2 invoke-direct/range {v3 .. v10}, Lokhttp3/internal/http2/Http2Connection$writeSynResetLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;ILokhttp3/internal/http2/ErrorCode;)V const-wide/16 p1, 0x0 invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void .end method .method public final writeWindowUpdateLater$okhttp(IJ)V .locals 12 .line 1 iget-object v0, p0, Lokhttp3/internal/http2/Http2Connection;->writerQueue:Lokhttp3/internal/concurrent/TaskQueue; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V iget-object v2, p0, Lokhttp3/internal/http2/Http2Connection;->connectionName:Ljava/lang/String; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v2, 0x5b invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string v2, "] windowUpdate" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v6 .line 2 new-instance v1, Lokhttp3/internal/http2/Http2Connection$writeWindowUpdateLater$$inlined$execute$1; const/4 v7, 0x1 move-object v3, v1 move-object v4, v6 move v5, v7 move-object v8, p0 move v9, p1 move-wide v10, p2 invoke-direct/range {v3 .. v11}, Lokhttp3/internal/http2/Http2Connection$writeWindowUpdateLater$$inlined$execute$1;->(Ljava/lang/String;ZLjava/lang/String;ZLokhttp3/internal/http2/Http2Connection;IJ)V const-wide/16 p1, 0x0 invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V return-void .end method