package okhttp3.internal.ws; import com.ifpdos.sdk.httpd.binder.aidl.RequestLine; import h.c0.p; import h.i; import h.r; import h.s.l; import h.x.d.h; import h.x.d.k; import i.g; import i.i; import java.io.Closeable; import java.io.IOException; import java.net.ProtocolException; import java.net.SocketTimeoutException; import java.util.ArrayDeque; import java.util.List; import java.util.Random; import java.util.concurrent.TimeUnit; import okhttp3.Call; import okhttp3.Callback; import okhttp3.EventListener; import okhttp3.OkHttpClient; import okhttp3.Protocol; import okhttp3.Request; import okhttp3.Response; import okhttp3.WebSocket; import okhttp3.WebSocketListener; import okhttp3.internal.Util; import okhttp3.internal.concurrent.Task; import okhttp3.internal.concurrent.TaskQueue; import okhttp3.internal.concurrent.TaskRunner; import okhttp3.internal.connection.Exchange; import okhttp3.internal.connection.RealCall; import okhttp3.internal.ws.WebSocketReader; import org.snmp4j.util.SnmpConfigurator; /* JADX INFO: compiled from: RealWebSocket.kt */ /* JADX INFO: loaded from: classes.dex */ @i(bv = {1, 0, 3}, d1 = {"\u0000À\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\t\u0018\u0000 \u0082\u00012\u00020\u00012\u00020\u0002:\n\u0083\u0001\u0082\u0001\u0084\u0001\u0085\u0001\u0086\u0001BC\u0012\u0006\u0010\u007f\u001a\u00020~\u0012\u0006\u0010g\u001a\u00020?\u0012\u0006\u0010]\u001a\u00020\\\u0012\u0006\u0010l\u001a\u00020k\u0012\u0006\u0010i\u001a\u00020\u0003\u0012\b\u0010W\u001a\u0004\u0018\u00010N\u0012\u0006\u0010e\u001a\u00020\u0003¢\u0006\u0006\b\u0080\u0001\u0010\u0081\u0001J\u001d\u0010\b\u001a\u00020\u00072\u0006\u0010\u0004\u001a\u00020\u00032\u0006\u0010\u0006\u001a\u00020\u0005¢\u0006\u0004\b\b\u0010\tJ\u000f\u0010\n\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\n\u0010\u000bJ!\u0010\u0012\u001a\u00020\u00072\u0006\u0010\r\u001a\u00020\f2\b\u0010\u000f\u001a\u0004\u0018\u00010\u000eH\u0000¢\u0006\u0004\b\u0010\u0010\u0011J!\u0010\u0018\u001a\u00020\u00172\u0006\u0010\u0014\u001a\u00020\u00132\b\u0010\u0016\u001a\u0004\u0018\u00010\u0015H\u0016¢\u0006\u0004\b\u0018\u0010\u0019J'\u0010\u0018\u001a\u00020\u00172\u0006\u0010\u0014\u001a\u00020\u00132\b\u0010\u0016\u001a\u0004\u0018\u00010\u00152\u0006\u0010\u001a\u001a\u00020\u0003¢\u0006\u0004\b\u0018\u0010\u001bJ\u0015\u0010\u001e\u001a\u00020\u00072\u0006\u0010\u001d\u001a\u00020\u001c¢\u0006\u0004\b\u001e\u0010\u001fJ#\u0010#\u001a\u00020\u00072\n\u0010\"\u001a\u00060 j\u0002`!2\b\u0010\r\u001a\u0004\u0018\u00010\f¢\u0006\u0004\b#\u0010$J\u001d\u0010(\u001a\u00020\u00072\u0006\u0010%\u001a\u00020\u00152\u0006\u0010'\u001a\u00020&¢\u0006\u0004\b(\u0010)J\r\u0010*\u001a\u00020\u0007¢\u0006\u0004\b*\u0010\u000bJ\u001f\u0010+\u001a\u00020\u00072\u0006\u0010\u0014\u001a\u00020\u00132\u0006\u0010\u0016\u001a\u00020\u0015H\u0016¢\u0006\u0004\b+\u0010,J\u0017\u0010.\u001a\u00020\u00072\u0006\u0010-\u001a\u00020\u0015H\u0016¢\u0006\u0004\b.\u0010/J\u0017\u0010.\u001a\u00020\u00072\u0006\u00101\u001a\u000200H\u0016¢\u0006\u0004\b.\u00102J\u0017\u00104\u001a\u00020\u00072\u0006\u00103\u001a\u000200H\u0016¢\u0006\u0004\b4\u00102J\u0017\u00105\u001a\u00020\u00072\u0006\u00103\u001a\u000200H\u0016¢\u0006\u0004\b5\u00102J\u0015\u00106\u001a\u00020\u00172\u0006\u00103\u001a\u000200¢\u0006\u0004\b6\u00107J\r\u00108\u001a\u00020\u0017¢\u0006\u0004\b8\u00109J\u000f\u0010:\u001a\u00020\u0003H\u0016¢\u0006\u0004\b:\u0010;J\r\u0010<\u001a\u00020\u0013¢\u0006\u0004\b<\u0010=J\r\u0010>\u001a\u00020\u0013¢\u0006\u0004\b>\u0010=J\u000f\u0010@\u001a\u00020?H\u0016¢\u0006\u0004\b@\u0010AJ\u000f\u0010B\u001a\u00020\u0007H\u0002¢\u0006\u0004\bB\u0010\u000bJ\u0017\u0010C\u001a\u00020\u00172\u0006\u0010-\u001a\u00020\u0015H\u0016¢\u0006\u0004\bC\u0010DJ\u0017\u0010C\u001a\u00020\u00172\u0006\u00101\u001a\u000200H\u0016¢\u0006\u0004\bC\u00107J\u001f\u0010C\u001a\u00020\u00172\u0006\u0010E\u001a\u0002002\u0006\u0010F\u001a\u00020\u0013H\u0002¢\u0006\u0004\bC\u0010GJ\r\u0010H\u001a\u00020\u0013¢\u0006\u0004\bH\u0010=J\r\u0010I\u001a\u00020\u0007¢\u0006\u0004\bI\u0010\u000bJ\u000f\u0010K\u001a\u00020\u0017H\u0000¢\u0006\u0004\bJ\u00109J\u000f\u0010M\u001a\u00020\u0007H\u0000¢\u0006\u0004\bL\u0010\u000bJ\u0013\u0010O\u001a\u00020\u0017*\u00020NH\u0002¢\u0006\u0004\bO\u0010PR\u0016\u0010Q\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bQ\u0010RR\u0018\u0010T\u001a\u0004\u0018\u00010S8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bT\u0010UR\u0016\u0010V\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bV\u0010RR\u0018\u0010W\u001a\u0004\u0018\u00010N8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bW\u0010XR\u0016\u0010Y\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bY\u0010RR\u0016\u0010Z\u001a\u00020\u00158\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bZ\u0010[R\u001c\u0010]\u001a\u00020\\8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b]\u0010^\u001a\u0004\b_\u0010`R\u001c\u0010c\u001a\b\u0012\u0004\u0012\u00020b0a8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bc\u0010dR\u0016\u0010e\u001a\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\be\u0010fR\u0018\u0010%\u001a\u0004\u0018\u00010\u00158\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b%\u0010[R\u0016\u0010g\u001a\u00020?8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bg\u0010hR\u0016\u0010i\u001a\u00020\u00038\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bi\u0010fR\u001c\u0010j\u001a\b\u0012\u0004\u0012\u0002000a8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bj\u0010dR\u0016\u0010:\u001a\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b:\u0010fR\u0016\u0010l\u001a\u00020k8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bl\u0010mR\u0018\u0010o\u001a\u0004\u0018\u00010n8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bo\u0010pR\u0016\u0010q\u001a\u00020\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bq\u0010rR\u0018\u0010s\u001a\u0004\u0018\u00010\u00158\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bs\u0010[R\u0016\u0010<\u001a\u00020\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b<\u0010rR\u0016\u0010>\u001a\u00020\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b>\u0010rR\u0016\u0010H\u001a\u00020\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bH\u0010rR\u0018\u0010'\u001a\u0004\u0018\u00010&8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b'\u0010tR\u0016\u0010v\u001a\u00020u8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bv\u0010wR\u0018\u0010y\u001a\u0004\u0018\u00010x8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\by\u0010zR\u0018\u0010|\u001a\u0004\u0018\u00010{8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b|\u0010}¨\u0006\u0087\u0001"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket;", "Lokhttp3/WebSocket;", "okhttp3/internal/ws/WebSocketReader$FrameCallback", "", "timeout", "Ljava/util/concurrent/TimeUnit;", "timeUnit", "", "awaitTermination", "(JLjava/util/concurrent/TimeUnit;)V", "cancel", "()V", "Lokhttp3/Response;", "response", "Lokhttp3/internal/connection/Exchange;", "exchange", "checkUpgradeSuccess$okhttp", "(Lokhttp3/Response;Lokhttp3/internal/connection/Exchange;)V", "checkUpgradeSuccess", "", "code", "", "reason", "", "close", "(ILjava/lang/String;)Z", "cancelAfterCloseMillis", "(ILjava/lang/String;J)Z", "Lokhttp3/OkHttpClient;", "client", "connect", "(Lokhttp3/OkHttpClient;)V", "Ljava/lang/Exception;", "Lkotlin/Exception;", SnmpConfigurator.O_AUTHORITATIVE_ENGINE_ID, "failWebSocket", "(Ljava/lang/Exception;Lokhttp3/Response;)V", "name", "Lokhttp3/internal/ws/RealWebSocket$Streams;", "streams", "initReaderAndWriter", "(Ljava/lang/String;Lokhttp3/internal/ws/RealWebSocket$Streams;)V", "loopReader", "onReadClose", "(ILjava/lang/String;)V", "text", "onReadMessage", "(Ljava/lang/String;)V", "Lokio/ByteString;", "bytes", "(Lokio/ByteString;)V", "payload", "onReadPing", "onReadPong", "pong", "(Lokio/ByteString;)Z", "processNextFrame", "()Z", "queueSize", "()J", "receivedPingCount", "()I", "receivedPongCount", "Lokhttp3/Request;", "request", "()Lokhttp3/Request;", "runWriter", "send", "(Ljava/lang/String;)Z", "data", "formatOpcode", "(Lokio/ByteString;I)Z", "sentPingCount", "tearDown", "writeOneFrame$okhttp", "writeOneFrame", "writePingFrame$okhttp", "writePingFrame", "Lokhttp3/internal/ws/WebSocketExtensions;", "isValid", "(Lokhttp3/internal/ws/WebSocketExtensions;)Z", "awaitingPong", "Z", "Lokhttp3/Call;", "call", "Lokhttp3/Call;", "enqueuedClose", "extensions", "Lokhttp3/internal/ws/WebSocketExtensions;", "failed", "key", "Ljava/lang/String;", "Lokhttp3/WebSocketListener;", "listener", "Lokhttp3/WebSocketListener;", "getListener$okhttp", "()Lokhttp3/WebSocketListener;", "Ljava/util/ArrayDeque;", "", "messageAndCloseQueue", "Ljava/util/ArrayDeque;", "minimumDeflateSize", "J", "originalRequest", "Lokhttp3/Request;", "pingIntervalMillis", "pongQueue", "Ljava/util/Random;", "random", "Ljava/util/Random;", "Lokhttp3/internal/ws/WebSocketReader;", "reader", "Lokhttp3/internal/ws/WebSocketReader;", "receivedCloseCode", "I", "receivedCloseReason", "Lokhttp3/internal/ws/RealWebSocket$Streams;", "Lokhttp3/internal/concurrent/TaskQueue;", "taskQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "Lokhttp3/internal/ws/WebSocketWriter;", "writer", "Lokhttp3/internal/ws/WebSocketWriter;", "Lokhttp3/internal/concurrent/Task;", "writerTask", "Lokhttp3/internal/concurrent/Task;", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "", "(Lokhttp3/internal/concurrent/TaskRunner;Lokhttp3/Request;Lokhttp3/WebSocketListener;Ljava/util/Random;JLokhttp3/internal/ws/WebSocketExtensions;J)V", "Companion", "Close", "Message", "Streams", "WriterTask", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class RealWebSocket implements WebSocket, WebSocketReader.FrameCallback { private static final long CANCEL_AFTER_CLOSE_MILLIS = 60000; public static final long DEFAULT_MINIMUM_DEFLATE_SIZE = 1024; private static final long MAX_QUEUE_SIZE = 16777216; private boolean awaitingPong; private Call call; private boolean enqueuedClose; private WebSocketExtensions extensions; private boolean failed; private final String key; private final WebSocketListener listener; private final ArrayDeque messageAndCloseQueue; private long minimumDeflateSize; private String name; private final Request originalRequest; private final long pingIntervalMillis; private final ArrayDeque pongQueue; private long queueSize; private final Random random; private WebSocketReader reader; private int receivedCloseCode; private String receivedCloseReason; private int receivedPingCount; private int receivedPongCount; private int sentPingCount; private Streams streams; private TaskQueue taskQueue; private WebSocketWriter writer; private Task writerTask; public static final Companion Companion = new Companion(null); private static final List ONLY_HTTP1 = l.b(Protocol.HTTP_1_1); /* JADX INFO: compiled from: RealWebSocket.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u001c\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0000\u0018\u0000B!\u0012\u0006\u0010\u0007\u001a\u00020\u0006\u0012\b\u0010\f\u001a\u0004\u0018\u00010\u000b\u0012\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0010\u0010\u0011R\u0019\u0010\u0002\u001a\u00020\u00018\u0006@\u0006¢\u0006\f\n\u0004\b\u0002\u0010\u0003\u001a\u0004\b\u0004\u0010\u0005R\u0019\u0010\u0007\u001a\u00020\u00068\u0006@\u0006¢\u0006\f\n\u0004\b\u0007\u0010\b\u001a\u0004\b\t\u0010\nR\u001b\u0010\f\u001a\u0004\u0018\u00010\u000b8\u0006@\u0006¢\u0006\f\n\u0004\b\f\u0010\r\u001a\u0004\b\u000e\u0010\u000f¨\u0006\u0012"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Close;", "", "cancelAfterCloseMillis", "J", "getCancelAfterCloseMillis", "()J", "", "code", "I", "getCode", "()I", "Lokio/ByteString;", "reason", "Lokio/ByteString;", "getReason", "()Lokio/ByteString;", "", "(ILokio/ByteString;J)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Close { private final long cancelAfterCloseMillis; private final int code; private final i.i reason; public Close(int i2, i.i iVar, long j2) { this.code = i2; this.reason = iVar; this.cancelAfterCloseMillis = j2; } public final long getCancelAfterCloseMillis() { return this.cancelAfterCloseMillis; } public final int getCode() { return this.code; } public final i.i getReason() { return this.reason; } } /* JADX INFO: compiled from: RealWebSocket.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\n\u0010\u000bR\u0016\u0010\u0002\u001a\u00020\u00018\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0002\u0010\u0003R\u0016\u0010\u0004\u001a\u00020\u00018\u0006@\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u0004\u0010\u0003R\u0016\u0010\u0005\u001a\u00020\u00018\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0005\u0010\u0003R\u001c\u0010\b\u001a\b\u0012\u0004\u0012\u00020\u00070\u00068\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\b\u0010\t¨\u0006\f"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Companion;", "", "CANCEL_AFTER_CLOSE_MILLIS", "J", "DEFAULT_MINIMUM_DEFLATE_SIZE", "MAX_QUEUE_SIZE", "", "Lokhttp3/Protocol;", "ONLY_HTTP1", "Ljava/util/List;", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Companion { private Companion() { } public /* synthetic */ Companion(h hVar) { this(); } } /* JADX INFO: compiled from: RealWebSocket.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u0014\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0007\b\u0000\u0018\u0000B\u0017\u0012\u0006\u0010\u0007\u001a\u00020\u0006\u0012\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u000b\u0010\fR\u0019\u0010\u0002\u001a\u00020\u00018\u0006@\u0006¢\u0006\f\n\u0004\b\u0002\u0010\u0003\u001a\u0004\b\u0004\u0010\u0005R\u0019\u0010\u0007\u001a\u00020\u00068\u0006@\u0006¢\u0006\f\n\u0004\b\u0007\u0010\b\u001a\u0004\b\t\u0010\n¨\u0006\r"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Message;", "Lokio/ByteString;", "data", "Lokio/ByteString;", "getData", "()Lokio/ByteString;", "", "formatOpcode", "I", "getFormatOpcode", "()I", "", "(ILokio/ByteString;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Message { private final i.i data; private final int formatOpcode; public Message(int i2, i.i iVar) { k.d(iVar, "data"); this.formatOpcode = i2; this.data = iVar; } public final i.i getData() { return this.data; } public final int getFormatOpcode() { return this.formatOpcode; } } /* JADX INFO: compiled from: RealWebSocket.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0007\b&\u0018\u00002\u00020\u0001B\u001f\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\r\u001a\u00020\f\u0012\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b\u0011\u0010\u0012R\u0019\u0010\u0003\u001a\u00020\u00028\u0006@\u0006¢\u0006\f\n\u0004\b\u0003\u0010\u0004\u001a\u0004\b\u0005\u0010\u0006R\u0019\u0010\b\u001a\u00020\u00078\u0006@\u0006¢\u0006\f\n\u0004\b\b\u0010\t\u001a\u0004\b\n\u0010\u000bR\u0019\u0010\r\u001a\u00020\f8\u0006@\u0006¢\u0006\f\n\u0004\b\r\u0010\u000e\u001a\u0004\b\u000f\u0010\u0010¨\u0006\u0013"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Streams;", "Ljava/io/Closeable;", "", "client", "Z", "getClient", "()Z", "Lokio/BufferedSink;", "sink", "Lokio/BufferedSink;", "getSink", "()Lokio/BufferedSink;", "Lokio/BufferedSource;", "source", "Lokio/BufferedSource;", "getSource", "()Lokio/BufferedSource;", "", "(ZLokio/BufferedSource;Lokio/BufferedSink;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static abstract class Streams implements Closeable { private final boolean client; private final g sink; private final i.h source; public Streams(boolean z, i.h hVar, g gVar) { k.d(hVar, "source"); k.d(gVar, "sink"); this.client = z; this.source = hVar; this.sink = gVar; } public final boolean getClient() { return this.client; } public final g getSink() { return this.sink; } public final i.h getSource() { return this.source; } } /* JADX INFO: compiled from: RealWebSocket.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0002\b\u0005\b\u0082\u0004\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\u0005\u0010\u0006J\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004¨\u0006\u0007"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$WriterTask;", "Lokhttp3/internal/concurrent/Task;", "", "runOnce", "()J", "", "(Lokhttp3/internal/ws/RealWebSocket;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") private final class WriterTask extends Task { public WriterTask() { super(RealWebSocket.this.name + " writer", false, 2, null); } @Override // okhttp3.internal.concurrent.Task public long runOnce() { try { return RealWebSocket.this.writeOneFrame$okhttp() ? 0L : -1L; } catch (IOException e2) { RealWebSocket.this.failWebSocket(e2, null); return -1L; } } } public RealWebSocket(TaskRunner taskRunner, Request request, WebSocketListener webSocketListener, Random random, long j2, WebSocketExtensions webSocketExtensions, long j3) { k.d(taskRunner, "taskRunner"); k.d(request, "originalRequest"); k.d(webSocketListener, "listener"); k.d(random, "random"); this.originalRequest = request; this.listener = webSocketListener; this.random = random; this.pingIntervalMillis = j2; this.extensions = webSocketExtensions; this.minimumDeflateSize = j3; this.taskQueue = taskRunner.newQueue(); this.pongQueue = new ArrayDeque<>(); this.messageAndCloseQueue = new ArrayDeque<>(); this.receivedCloseCode = -1; if (!k.a(RequestLine.METHOD_GET, this.originalRequest.method())) { throw new IllegalArgumentException(("Request must be GET: " + this.originalRequest.method()).toString()); } i.a aVar = i.i.f1027h; byte[] bArr = new byte[16]; this.random.nextBytes(bArr); r rVar = r.a; this.key = i.a.f(aVar, bArr, 0, 0, 3, null).a(); } /* JADX INFO: Access modifiers changed from: private */ public final boolean isValid(WebSocketExtensions webSocketExtensions) { if (webSocketExtensions.unknownValues || webSocketExtensions.clientMaxWindowBits != null) { return false; } Integer num = webSocketExtensions.serverMaxWindowBits; if (num == null) { return true; } int iIntValue = num.intValue(); return 8 <= iIntValue && 15 >= iIntValue; } private final void runWriter() { if (!Util.assertionsEnabled || Thread.holdsLock(this)) { Task task = this.writerTask; if (task != null) { TaskQueue.schedule$default(this.taskQueue, task, 0L, 2, null); return; } return; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } public final void awaitTermination(long j2, TimeUnit timeUnit) throws InterruptedException { k.d(timeUnit, "timeUnit"); this.taskQueue.idleLatch().await(j2, timeUnit); } @Override // okhttp3.WebSocket public void cancel() { Call call = this.call; k.b(call); call.cancel(); } public final void checkUpgradeSuccess$okhttp(Response response, Exchange exchange) throws IOException { k.d(response, "response"); if (response.code() != 101) { throw new ProtocolException("Expected HTTP 101 response but was '" + response.code() + ' ' + response.message() + '\''); } String strHeader$default = Response.header$default(response, "Connection", null, 2, null); if (!p.m("Upgrade", strHeader$default, true)) { throw new ProtocolException("Expected 'Connection' header value 'Upgrade' but was '" + strHeader$default + '\''); } String strHeader$default2 = Response.header$default(response, "Upgrade", null, 2, null); if (!p.m("websocket", strHeader$default2, true)) { throw new ProtocolException("Expected 'Upgrade' header value 'websocket' but was '" + strHeader$default2 + '\''); } String strHeader$default3 = Response.header$default(response, "Sec-WebSocket-Accept", null, 2, null); String strA = i.i.f1027h.d(this.key + WebSocketProtocol.ACCEPT_MAGIC).q().a(); if (!(!k.a(strA, strHeader$default3))) { if (exchange == null) { throw new ProtocolException("Web Socket exchange missing: bad interceptor?"); } return; } throw new ProtocolException("Expected 'Sec-WebSocket-Accept' header value '" + strA + "' but was '" + strHeader$default3 + '\''); } @Override // okhttp3.WebSocket public boolean close(int i2, String str) { return close(i2, str, CANCEL_AFTER_CLOSE_MILLIS); } public final void connect(OkHttpClient okHttpClient) { k.d(okHttpClient, "client"); if (this.originalRequest.header("Sec-WebSocket-Extensions") != null) { failWebSocket(new ProtocolException("Request header not permitted: 'Sec-WebSocket-Extensions'"), null); return; } OkHttpClient okHttpClientBuild = okHttpClient.newBuilder().eventListener(EventListener.NONE).protocols(ONLY_HTTP1).build(); final Request requestBuild = this.originalRequest.newBuilder().header("Upgrade", "websocket").header("Connection", "Upgrade").header("Sec-WebSocket-Key", this.key).header("Sec-WebSocket-Version", "13").header("Sec-WebSocket-Extensions", "permessage-deflate").build(); RealCall realCall = new RealCall(okHttpClientBuild, requestBuild, true); this.call = realCall; k.b(realCall); realCall.enqueue(new Callback() { // from class: okhttp3.internal.ws.RealWebSocket.connect.1 @Override // okhttp3.Callback public void onFailure(Call call, IOException iOException) { k.d(call, "call"); k.d(iOException, SnmpConfigurator.O_AUTHORITATIVE_ENGINE_ID); RealWebSocket.this.failWebSocket(iOException, null); } @Override // okhttp3.Callback public void onResponse(Call call, Response response) throws IOException { k.d(call, "call"); k.d(response, "response"); Exchange exchange = response.exchange(); try { RealWebSocket.this.checkUpgradeSuccess$okhttp(response, exchange); k.b(exchange); Streams streamsNewWebSocketStreams = exchange.newWebSocketStreams(); WebSocketExtensions webSocketExtensions = WebSocketExtensions.Companion.parse(response.headers()); RealWebSocket.this.extensions = webSocketExtensions; if (!RealWebSocket.this.isValid(webSocketExtensions)) { synchronized (RealWebSocket.this) { RealWebSocket.this.messageAndCloseQueue.clear(); RealWebSocket.this.close(1010, "unexpected Sec-WebSocket-Extensions in response header"); } } try { RealWebSocket.this.initReaderAndWriter(Util.okHttpName + " WebSocket " + requestBuild.url().redact(), streamsNewWebSocketStreams); RealWebSocket.this.getListener$okhttp().onOpen(RealWebSocket.this, response); RealWebSocket.this.loopReader(); } catch (Exception e2) { RealWebSocket.this.failWebSocket(e2, null); } } catch (IOException e3) { if (exchange != null) { exchange.webSocketUpgradeFailed(); } RealWebSocket.this.failWebSocket(e3, response); Util.closeQuietly(response); } } }); } public final void failWebSocket(Exception exc, Response response) { k.d(exc, SnmpConfigurator.O_AUTHORITATIVE_ENGINE_ID); synchronized (this) { if (this.failed) { return; } this.failed = true; Streams streams = this.streams; this.streams = null; WebSocketReader webSocketReader = this.reader; this.reader = null; WebSocketWriter webSocketWriter = this.writer; this.writer = null; this.taskQueue.shutdown(); r rVar = r.a; try { this.listener.onFailure(this, exc, response); } finally { if (streams != null) { Util.closeQuietly(streams); } if (webSocketReader != null) { Util.closeQuietly(webSocketReader); } if (webSocketWriter != null) { Util.closeQuietly(webSocketWriter); } } } } public final WebSocketListener getListener$okhttp() { return this.listener; } public final void initReaderAndWriter(final String str, final Streams streams) throws IOException { k.d(str, "name"); k.d(streams, "streams"); final WebSocketExtensions webSocketExtensions = this.extensions; k.b(webSocketExtensions); synchronized (this) { this.name = str; this.streams = streams; this.writer = new WebSocketWriter(streams.getClient(), streams.getSink(), this.random, webSocketExtensions.perMessageDeflate, webSocketExtensions.noContextTakeover(streams.getClient()), this.minimumDeflateSize); this.writerTask = new WriterTask(); if (this.pingIntervalMillis != 0) { final long nanos = TimeUnit.MILLISECONDS.toNanos(this.pingIntervalMillis); final String str2 = str + " ping"; this.taskQueue.schedule(new Task(str2) { // from class: okhttp3.internal.ws.RealWebSocket$initReaderAndWriter$$inlined$synchronized$lambda$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.writePingFrame$okhttp(); return nanos; } }, nanos); } if (!this.messageAndCloseQueue.isEmpty()) { runWriter(); } r rVar = r.a; } this.reader = new WebSocketReader(streams.getClient(), streams.getSource(), this, webSocketExtensions.perMessageDeflate, webSocketExtensions.noContextTakeover(!streams.getClient())); } public final void loopReader() throws IOException { while (this.receivedCloseCode == -1) { WebSocketReader webSocketReader = this.reader; k.b(webSocketReader); webSocketReader.processNextFrame(); } } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public void onReadClose(int i2, String str) { Streams streams; WebSocketReader webSocketReader; WebSocketWriter webSocketWriter; k.d(str, "reason"); boolean z = true; if (!(i2 != -1)) { throw new IllegalArgumentException("Failed requirement.".toString()); } synchronized (this) { if (this.receivedCloseCode != -1) { z = false; } if (!z) { throw new IllegalStateException("already closed".toString()); } this.receivedCloseCode = i2; this.receivedCloseReason = str; streams = null; if (this.enqueuedClose && this.messageAndCloseQueue.isEmpty()) { Streams streams2 = this.streams; this.streams = null; webSocketReader = this.reader; this.reader = null; webSocketWriter = this.writer; this.writer = null; this.taskQueue.shutdown(); streams = streams2; } else { webSocketReader = null; webSocketWriter = null; } r rVar = r.a; } try { this.listener.onClosing(this, i2, str); if (streams != null) { this.listener.onClosed(this, i2, str); } } finally { if (streams != null) { Util.closeQuietly(streams); } if (webSocketReader != null) { Util.closeQuietly(webSocketReader); } if (webSocketWriter != null) { Util.closeQuietly(webSocketWriter); } } } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public void onReadMessage(String str) throws IOException { k.d(str, "text"); this.listener.onMessage(this, str); } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public synchronized void onReadPing(i.i iVar) { k.d(iVar, "payload"); if (!this.failed && (!this.enqueuedClose || !this.messageAndCloseQueue.isEmpty())) { this.pongQueue.add(iVar); runWriter(); this.receivedPingCount++; } } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public synchronized void onReadPong(i.i iVar) { k.d(iVar, "payload"); this.receivedPongCount++; this.awaitingPong = false; } public final synchronized boolean pong(i.i iVar) { k.d(iVar, "payload"); if (!this.failed && (!this.enqueuedClose || !this.messageAndCloseQueue.isEmpty())) { this.pongQueue.add(iVar); runWriter(); return true; } return false; } public final boolean processNextFrame() throws IOException { try { WebSocketReader webSocketReader = this.reader; k.b(webSocketReader); webSocketReader.processNextFrame(); return this.receivedCloseCode == -1; } catch (Exception e2) { failWebSocket(e2, null); return false; } } @Override // okhttp3.WebSocket public synchronized long queueSize() { return this.queueSize; } public final synchronized int receivedPingCount() { return this.receivedPingCount; } public final synchronized int receivedPongCount() { return this.receivedPongCount; } @Override // okhttp3.WebSocket public Request request() { return this.originalRequest; } @Override // okhttp3.WebSocket public boolean send(String str) { k.d(str, "text"); return send(i.i.f1027h.d(str), 1); } public final synchronized int sentPingCount() { return this.sentPingCount; } public final void tearDown() throws InterruptedException { this.taskQueue.shutdown(); this.taskQueue.idleLatch().await(10L, TimeUnit.SECONDS); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:57:0x017b */ /* JADX WARN: Removed duplicated region for block: B:60:0x0186 */ /* JADX WARN: Removed duplicated region for block: B:63:0x0191 */ /* JADX WARN: Removed duplicated region for block: B:78:0x01c4 */ /* JADX WARN: Removed duplicated region for block: B:81:0x01cd */ /* JADX WARN: Removed duplicated region for block: B:84:0x01d6 */ /* JADX WARN: Type inference failed for: r1v10, types: [java.lang.Object, okhttp3.internal.ws.WebSocketWriter] */ /* JADX WARN: Type inference failed for: r1v13, types: [h.x.d.u] */ /* JADX WARN: Type inference failed for: r1v2 */ /* JADX WARN: Type inference failed for: r2v1 */ /* JADX WARN: Type inference failed for: r2v10 */ /* JADX WARN: Type inference failed for: r2v17, types: [T, okhttp3.internal.ws.RealWebSocket$Streams] */ /* JADX WARN: Type inference failed for: r2v18, types: [T, okhttp3.internal.ws.WebSocketReader] */ /* JADX WARN: Type inference failed for: r2v19, types: [T, okhttp3.internal.ws.WebSocketWriter] */ /* JADX WARN: Type inference failed for: r2v6, types: [boolean] */ /* JADX WARN: Type inference failed for: r3v16, types: [T, java.lang.Object] */ /* JADX WARN: Type inference failed for: r3v3, types: [i.i] */ /* JADX WARN: Type inference failed for: r3v4 */ /* JADX WARN: Type inference failed for: r3v8 */ /* JADX WARN: Type inference failed for: r4v2, types: [T, java.lang.String] */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final boolean writeOneFrame$okhttp() throws java.lang.Throwable { /* Method dump skipped, instruction units count: 479 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.ws.RealWebSocket.writeOneFrame$okhttp():boolean"); } public final void writePingFrame$okhttp() { synchronized (this) { if (this.failed) { return; } WebSocketWriter webSocketWriter = this.writer; if (webSocketWriter != null) { int i2 = this.awaitingPong ? this.sentPingCount : -1; this.sentPingCount++; this.awaitingPong = true; r rVar = r.a; if (i2 == -1) { try { webSocketWriter.writePing(i.i.f1026g); return; } catch (IOException e2) { failWebSocket(e2, null); return; } } failWebSocket(new SocketTimeoutException("sent ping but didn't receive pong within " + this.pingIntervalMillis + "ms (after " + (i2 - 1) + " successful ping/pongs)"), null); } } } public final synchronized boolean close(int i2, String str, long j2) { WebSocketProtocol.INSTANCE.validateCloseCode(i2); i.i iVarD = null; if (str != null) { iVarD = i.i.f1027h.d(str); if (!(((long) iVarD.s()) <= 123)) { throw new IllegalArgumentException(("reason.size() > 123: " + str).toString()); } } if (!this.failed && !this.enqueuedClose) { this.enqueuedClose = true; this.messageAndCloseQueue.add(new Close(i2, iVarD, j2)); runWriter(); return true; } return false; } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public void onReadMessage(i.i iVar) throws IOException { k.d(iVar, "bytes"); this.listener.onMessage(this, iVar); } @Override // okhttp3.WebSocket public boolean send(i.i iVar) { k.d(iVar, "bytes"); return send(iVar, 2); } private final synchronized boolean send(i.i iVar, int i2) { if (!this.failed && !this.enqueuedClose) { if (this.queueSize + ((long) iVar.s()) > MAX_QUEUE_SIZE) { close(1001, null); return false; } this.queueSize += (long) iVar.s(); this.messageAndCloseQueue.add(new Message(i2, iVar)); runWriter(); return true; } return false; } }