package okhttp3.internal.ws; import androidx.media3.common.MimeTypes; import androidx.media3.exoplayer.rtsp.RtspHeaders; import hb.a; 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 kotlin.Metadata; import kotlin.jvm.internal.SourceDebugExtension; import kotlin.text.h; import nb.g; 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 okio.BufferedSink; import okio.BufferedSource; import okio.ByteString; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import tv.danmaku.ijk.media.player.IjkMediaMeta; import xd.c; /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000Æ\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\t\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\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\t\u0018\u0000 r2\u00020\u00012\u00020\u0002:\u0005srtuvBA\u0012\u0006\u0010o\u001a\u00020n\u0012\u0006\u0010A\u001a\u00020\u0003\u0012\u0006\u0010D\u001a\u00020C\u0012\u0006\u0010I\u001a\u00020H\u0012\u0006\u0010K\u001a\u00020\u0005\u0012\b\u0010M\u001a\u0004\u0018\u00010<\u0012\u0006\u0010O\u001a\u00020\u0005¢\u0006\u0004\bp\u0010qJ\b\u0010\u0004\u001a\u00020\u0003H\u0016J\b\u0010\u0006\u001a\u00020\u0005H\u0016J\b\u0010\b\u001a\u00020\u0007H\u0016J\u000e\u0010\u000b\u001a\u00020\u00072\u0006\u0010\n\u001a\u00020\tJ!\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\u0016\u0010\u0017\u001a\u00020\u00072\u0006\u0010\u0014\u001a\u00020\u00132\u0006\u0010\u0016\u001a\u00020\u0015J\u0006\u0010\u0018\u001a\u00020\u0007J\u0006\u0010\u001a\u001a\u00020\u0019J\u0016\u0010\u001e\u001a\u00020\u00072\u0006\u0010\u001b\u001a\u00020\u00052\u0006\u0010\u001d\u001a\u00020\u001cJ\u0006\u0010\u001f\u001a\u00020\u0007J\u0006\u0010!\u001a\u00020 J\u0006\u0010\"\u001a\u00020 J\u0006\u0010#\u001a\u00020 J\u0010\u0010%\u001a\u00020\u00072\u0006\u0010$\u001a\u00020\u0013H\u0016J\u0010\u0010%\u001a\u00020\u00072\u0006\u0010'\u001a\u00020&H\u0016J\u0010\u0010)\u001a\u00020\u00072\u0006\u0010(\u001a\u00020&H\u0016J\u0010\u0010*\u001a\u00020\u00072\u0006\u0010(\u001a\u00020&H\u0016J\u0018\u0010-\u001a\u00020\u00072\u0006\u0010+\u001a\u00020 2\u0006\u0010,\u001a\u00020\u0013H\u0016J\u0010\u0010.\u001a\u00020\u00192\u0006\u0010$\u001a\u00020\u0013H\u0016J\u0010\u0010.\u001a\u00020\u00192\u0006\u0010'\u001a\u00020&H\u0016J\u000e\u0010/\u001a\u00020\u00192\u0006\u0010(\u001a\u00020&J\u001a\u00100\u001a\u00020\u00192\u0006\u0010+\u001a\u00020 2\b\u0010,\u001a\u0004\u0018\u00010\u0013H\u0016J \u00100\u001a\u00020\u00192\u0006\u0010+\u001a\u00020 2\b\u0010,\u001a\u0004\u0018\u00010\u00132\u0006\u00101\u001a\u00020\u0005J\u000f\u00104\u001a\u00020\u0019H\u0000¢\u0006\u0004\b2\u00103J\u000f\u00107\u001a\u00020\u0007H\u0000¢\u0006\u0004\b5\u00106J\u001c\u0010;\u001a\u00020\u00072\n\u0010:\u001a\u000608j\u0002`92\b\u0010\r\u001a\u0004\u0018\u00010\fJ\f\u0010=\u001a\u00020\u0019*\u00020\u001a\u00020&2\u0006\u0010?\u001a\u00020 H\u0002J\b\u0010@\u001a\u00020\u0007H\u0002R\u0014\u0010A\u001a\u00020\u00038\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bA\u0010BR\u001a\u0010D\u001a\u00020C8\u0000X\u0080\u0004¢\u0006\f\n\u0004\bD\u0010E\u001a\u0004\bF\u0010GR\u0014\u0010I\u001a\u00020H8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bI\u0010JR\u0014\u0010K\u001a\u00020\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bK\u0010LR\u0018\u0010M\u001a\u0004\u0018\u00010<8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bM\u0010NR\u0016\u0010O\u001a\u00020\u00058\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bO\u0010LR\u0014\u0010P\u001a\u00020\u00138\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bP\u0010QR\u0018\u0010S\u001a\u0004\u0018\u00010R8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bS\u0010TR\u0018\u0010V\u001a\u0004\u0018\u00010U8\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]R\u0016\u0010_\u001a\u00020^8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b_\u0010`R\u0018\u0010\u0014\u001a\u0004\u0018\u00010\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0014\u0010QR\u0018\u0010\u0016\u001a\u0004\u0018\u00010\u00158\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0016\u0010aR\u001a\u0010c\u001a\b\u0012\u0004\u0012\u00020&0b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bc\u0010dR\u001a\u0010f\u001a\b\u0012\u0004\u0012\u00020e0b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bf\u0010dR\u0016\u0010\u0006\u001a\u00020\u00058\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0006\u0010LR\u0016\u0010g\u001a\u00020\u00198\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bg\u0010hR\u0016\u0010i\u001a\u00020 8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bi\u0010jR\u0018\u0010k\u001a\u0004\u0018\u00010\u00138\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bk\u0010QR\u0016\u0010l\u001a\u00020\u00198\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bl\u0010hR\u0016\u0010!\u001a\u00020 8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b!\u0010jR\u0016\u0010\"\u001a\u00020 8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\"\u0010jR\u0016\u0010#\u001a\u00020 8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b#\u0010jR\u0016\u0010m\u001a\u00020\u00198\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bm\u0010h¨\u0006w"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket;", "Lokhttp3/WebSocket;", "Lokhttp3/internal/ws/WebSocketReader$FrameCallback;", "Lokhttp3/Request;", "request", "", "queueSize", "Lkd/e;", "cancel", "Lokhttp3/OkHttpClient;", "client", "connect", "Lokhttp3/Response;", "response", "Lokhttp3/internal/connection/Exchange;", "exchange", "checkUpgradeSuccess$okhttp", "(Lokhttp3/Response;Lokhttp3/internal/connection/Exchange;)V", "checkUpgradeSuccess", "", "name", "Lokhttp3/internal/ws/RealWebSocket$Streams;", IjkMediaMeta.IJKM_KEY_STREAMS, "initReaderAndWriter", "loopReader", "", "processNextFrame", "timeout", "Ljava/util/concurrent/TimeUnit;", "timeUnit", "awaitTermination", "tearDown", "", "sentPingCount", "receivedPingCount", "receivedPongCount", MimeTypes.BASE_TYPE_TEXT, "onReadMessage", "Lokio/ByteString;", "bytes", "payload", "onReadPing", "onReadPong", "code", "reason", "onReadClose", "send", "pong", "close", "cancelAfterCloseMillis", "writeOneFrame$okhttp", "()Z", "writeOneFrame", "writePingFrame$okhttp", "()V", "writePingFrame", "Ljava/lang/Exception;", "Lkotlin/Exception;", "e", "failWebSocket", "Lokhttp3/internal/ws/WebSocketExtensions;", "isValid", "data", "formatOpcode", "runWriter", "originalRequest", "Lokhttp3/Request;", "Lokhttp3/WebSocketListener;", "listener", "Lokhttp3/WebSocketListener;", "getListener$okhttp", "()Lokhttp3/WebSocketListener;", "Ljava/util/Random;", "random", "Ljava/util/Random;", "pingIntervalMillis", "J", "extensions", "Lokhttp3/internal/ws/WebSocketExtensions;", "minimumDeflateSize", "key", "Ljava/lang/String;", "Lokhttp3/Call;", "call", "Lokhttp3/Call;", "Lokhttp3/internal/concurrent/Task;", "writerTask", "Lokhttp3/internal/concurrent/Task;", "Lokhttp3/internal/ws/WebSocketReader;", "reader", "Lokhttp3/internal/ws/WebSocketReader;", "Lokhttp3/internal/ws/WebSocketWriter;", "writer", "Lokhttp3/internal/ws/WebSocketWriter;", "Lokhttp3/internal/concurrent/TaskQueue;", "taskQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "Lokhttp3/internal/ws/RealWebSocket$Streams;", "Ljava/util/ArrayDeque;", "pongQueue", "Ljava/util/ArrayDeque;", "", "messageAndCloseQueue", "enqueuedClose", "Z", "receivedCloseCode", "I", "receivedCloseReason", "failed", "awaitingPong", "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, 8, 0}) @SourceDebugExtension({"SMAP\nRealWebSocket.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealWebSocket.kt\nokhttp3/internal/ws/RealWebSocket\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 TaskQueue.kt\nokhttp3/internal/concurrent/TaskQueue\n+ 4 Util.kt\nokhttp3/internal/Util\n*L\n1#1,654:1\n1#2:655\n84#3,4:656\n90#3,13:664\n608#4,4:660\n*S KotlinDebug\n*F\n+ 1 RealWebSocket.kt\nokhttp3/internal/ws/RealWebSocket\n*L\n269#1:656,4\n512#1:664,13\n457#1:660,4\n*E\n"}) 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; @Nullable private Call call; private boolean enqueuedClose; @Nullable private WebSocketExtensions extensions; private boolean failed; @NotNull private final String key; @NotNull private final WebSocketListener listener; @NotNull private final ArrayDeque messageAndCloseQueue; private long minimumDeflateSize; @Nullable private String name; @NotNull private final Request originalRequest; private final long pingIntervalMillis; @NotNull private final ArrayDeque pongQueue; private long queueSize; @NotNull private final Random random; @Nullable private WebSocketReader reader; private int receivedCloseCode; @Nullable private String receivedCloseReason; private int receivedPingCount; private int receivedPongCount; private int sentPingCount; @Nullable private Streams streams; @NotNull private TaskQueue taskQueue; @Nullable private WebSocketWriter writer; @Nullable private Task writerTask; @NotNull private static final List ONLY_HTTP1 = a.l0(Protocol.HTTP_1_1); @Metadata(d1 = {"\u0000\u001e\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\b\b\u0000\u0018\u00002\u00020\u0001B\u001f\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\b\u0010\u0004\u001a\u0004\u0018\u00010\u0005\u0012\u0006\u0010\u0006\u001a\u00020\u0007¢\u0006\u0002\u0010\bR\u0011\u0010\u0006\u001a\u00020\u0007¢\u0006\b\n\u0000\u001a\u0004\b\t\u0010\nR\u0011\u0010\u0002\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\u000b\u0010\fR\u0013\u0010\u0004\u001a\u0004\u0018\u00010\u0005¢\u0006\b\n\u0000\u001a\u0004\b\r\u0010\u000e¨\u0006\u000f"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Close;", "", "code", "", "reason", "Lokio/ByteString;", "cancelAfterCloseMillis", "", "(ILokio/ByteString;J)V", "getCancelAfterCloseMillis", "()J", "getCode", "()I", "getReason", "()Lokio/ByteString;", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class Close { private final long cancelAfterCloseMillis; private final int code; @Nullable private final ByteString reason; public Close(int i10, @Nullable ByteString byteString, long j10) { this.code = i10; this.reason = byteString; this.cancelAfterCloseMillis = j10; } public final long getCancelAfterCloseMillis() { return this.cancelAfterCloseMillis; } public final int getCode() { return this.code; } @Nullable public final ByteString getReason() { return this.reason; } } @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0000\u0018\u00002\u00020\u0001B\u0015\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006R\u0011\u0010\u0004\u001a\u00020\u0005¢\u0006\b\n\u0000\u001a\u0004\b\u0007\u0010\bR\u0011\u0010\u0002\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\t\u0010\n¨\u0006\u000b"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Message;", "", "formatOpcode", "", "data", "Lokio/ByteString;", "(ILokio/ByteString;)V", "getData", "()Lokio/ByteString;", "getFormatOpcode", "()I", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class Message { @NotNull private final ByteString data; private final int formatOpcode; public Message(int i10, @NotNull ByteString byteString) { g.i(byteString, "data"); this.formatOpcode = i10; this.data = byteString; } @NotNull public final ByteString getData() { return this.data; } public final int getFormatOpcode() { return this.formatOpcode; } } @Metadata(d1 = {"\u0000\u001e\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\b\b&\u0018\u00002\u00020\u0001B\u001d\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\u0006\u0010\u0006\u001a\u00020\u0007¢\u0006\u0002\u0010\bR\u0011\u0010\u0002\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\t\u0010\nR\u0011\u0010\u0006\u001a\u00020\u0007¢\u0006\b\n\u0000\u001a\u0004\b\u000b\u0010\fR\u0011\u0010\u0004\u001a\u00020\u0005¢\u0006\b\n\u0000\u001a\u0004\b\r\u0010\u000e¨\u0006\u000f"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$Streams;", "Ljava/io/Closeable;", "client", "", "source", "Lokio/BufferedSource;", "sink", "Lokio/BufferedSink;", "(ZLokio/BufferedSource;Lokio/BufferedSink;)V", "getClient", "()Z", "getSink", "()Lokio/BufferedSink;", "getSource", "()Lokio/BufferedSource;", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static abstract class Streams implements Closeable { private final boolean client; @NotNull private final BufferedSink sink; @NotNull private final BufferedSource source; public Streams(boolean z10, @NotNull BufferedSource bufferedSource, @NotNull BufferedSink bufferedSink) { g.i(bufferedSource, "source"); g.i(bufferedSink, "sink"); this.client = z10; this.source = bufferedSource; this.sink = bufferedSink; } public final boolean getClient() { return this.client; } @NotNull public final BufferedSink getSink() { return this.sink; } @NotNull public final BufferedSource getSource() { return this.source; } } @Metadata(d1 = {"\u0000\u0012\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\b\u0082\u0004\u0018\u00002\u00020\u0001B\u0005¢\u0006\u0002\u0010\u0002J\b\u0010\u0003\u001a\u00020\u0004H\u0016¨\u0006\u0005"}, d2 = {"Lokhttp3/internal/ws/RealWebSocket$WriterTask;", "Lokhttp3/internal/concurrent/Task;", "(Lokhttp3/internal/ws/RealWebSocket;)V", "runOnce", "", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public 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 e10) { RealWebSocket.this.failWebSocket(e10, null); return -1L; } } } public RealWebSocket(@NotNull TaskRunner taskRunner, @NotNull Request request, @NotNull WebSocketListener webSocketListener, @NotNull Random random, long j10, @Nullable WebSocketExtensions webSocketExtensions, long j11) { g.i(taskRunner, "taskRunner"); g.i(request, "originalRequest"); g.i(webSocketListener, "listener"); g.i(random, "random"); this.originalRequest = request; this.listener = webSocketListener; this.random = random; this.pingIntervalMillis = j10; this.extensions = webSocketExtensions; this.minimumDeflateSize = j11; this.taskQueue = taskRunner.newQueue(); this.pongQueue = new ArrayDeque<>(); this.messageAndCloseQueue = new ArrayDeque<>(); this.receivedCloseCode = -1; if (!g.c("GET", request.method())) { throw new IllegalArgumentException(("Request must be GET: " + request.method()).toString()); } ByteString.Companion companion = ByteString.INSTANCE; byte[] bArr = new byte[16]; random.nextBytes(bArr); this.key = ByteString.Companion.of$default(companion, bArr, 0, 0, 3, null).base64(); } /* JADX INFO: Access modifiers changed from: private */ public final boolean isValid(WebSocketExtensions webSocketExtensions) { if (!webSocketExtensions.unknownValues && webSocketExtensions.clientMaxWindowBits == null) { return webSocketExtensions.serverMaxWindowBits == null || new c(8, 15, 1).f(webSocketExtensions.serverMaxWindowBits.intValue()); } return false; } 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; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this); } public final void awaitTermination(long j10, @NotNull TimeUnit timeUnit) throws InterruptedException { g.i(timeUnit, "timeUnit"); this.taskQueue.idleLatch().await(j10, timeUnit); } @Override // okhttp3.WebSocket public void cancel() { Call call = this.call; g.f(call); call.cancel(); } public final void checkUpgradeSuccess$okhttp(@NotNull Response response, @Nullable Exchange exchange) throws IOException { g.i(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, RtspHeaders.CONNECTION, null, 2, null); if (!h.c0("Upgrade", strHeader$default)) { throw new ProtocolException("Expected 'Connection' header value 'Upgrade' but was '" + strHeader$default + '\''); } String strHeader$default2 = Response.header$default(response, "Upgrade", null, 2, null); if (!h.c0("websocket", strHeader$default2)) { 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 strBase64 = ByteString.INSTANCE.encodeUtf8(this.key + WebSocketProtocol.ACCEPT_MAGIC).sha1().base64(); if (g.c(strBase64, strHeader$default3)) { if (exchange == null) { throw new ProtocolException("Web Socket exchange missing: bad interceptor?"); } return; } throw new ProtocolException("Expected 'Sec-WebSocket-Accept' header value '" + strBase64 + "' but was '" + strHeader$default3 + '\''); } @Override // okhttp3.WebSocket public boolean close(int code, @Nullable String reason) { return close(code, reason, 60000L); } public final void connect(@NotNull OkHttpClient okHttpClient) { g.i(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(RtspHeaders.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; realCall.enqueue(new Callback() { // from class: okhttp3.internal.ws.RealWebSocket.connect.1 @Override // okhttp3.Callback public void onFailure(@NotNull Call call, @NotNull IOException iOException) { g.i(call, "call"); g.i(iOException, "e"); RealWebSocket.this.failWebSocket(iOException, null); } @Override // okhttp3.Callback public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException { g.i(call, "call"); g.i(response, "response"); Exchange exchange = response.getExchange(); try { RealWebSocket.this.checkUpgradeSuccess$okhttp(response, exchange); g.f(exchange); Streams streamsNewWebSocketStreams = exchange.newWebSocketStreams(); WebSocketExtensions webSocketExtensions = WebSocketExtensions.INSTANCE.parse(response.headers()); RealWebSocket.this.extensions = webSocketExtensions; if (!RealWebSocket.this.isValid(webSocketExtensions)) { RealWebSocket realWebSocket = RealWebSocket.this; synchronized (realWebSocket) { realWebSocket.messageAndCloseQueue.clear(); realWebSocket.close(1010, "unexpected Sec-WebSocket-Extensions in response header"); } } try { RealWebSocket.this.initReaderAndWriter(Util.okHttpName + " WebSocket " + requestBuild.url().redact(), streamsNewWebSocketStreams); RealWebSocket.this.getListener().onOpen(RealWebSocket.this, response); RealWebSocket.this.loopReader(); } catch (Exception e10) { RealWebSocket.this.failWebSocket(e10, null); } } catch (IOException e11) { RealWebSocket.this.failWebSocket(e11, response); Util.closeQuietly(response); if (exchange != null) { exchange.webSocketUpgradeFailed(); } } } }); } public final void failWebSocket(@NotNull Exception exc, @Nullable Response response) { g.i(exc, "e"); 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(); 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); } } } } @NotNull /* JADX INFO: renamed from: getListener$okhttp, reason: from getter */ public final WebSocketListener getListener() { return this.listener; } public final void initReaderAndWriter(@NotNull String str, @NotNull Streams streams) throws IOException { g.i(str, "name"); g.i(streams, IjkMediaMeta.IJKM_KEY_STREAMS); WebSocketExtensions webSocketExtensions = this.extensions; g.f(webSocketExtensions); synchronized (this) { try { 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(); long j10 = this.pingIntervalMillis; if (j10 != 0) { final long nanos = TimeUnit.MILLISECONDS.toNanos(j10); TaskQueue taskQueue = this.taskQueue; final String strConcat = str.concat(" ping"); taskQueue.schedule(new Task(strConcat) { // from class: okhttp3.internal.ws.RealWebSocket$initReaderAndWriter$lambda$3$$inlined$schedule$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.writePingFrame$okhttp(); return nanos; } }, nanos); } if (!this.messageAndCloseQueue.isEmpty()) { runWriter(); } } catch (Throwable th) { throw th; } } 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; g.f(webSocketReader); webSocketReader.processNextFrame(); } } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public void onReadClose(int i10, @NotNull String str) { Streams streams; WebSocketReader webSocketReader; WebSocketWriter webSocketWriter; g.i(str, "reason"); if (i10 == -1) { throw new IllegalArgumentException("Failed requirement.".toString()); } synchronized (this) { if (this.receivedCloseCode != -1) { throw new IllegalStateException("already closed".toString()); } this.receivedCloseCode = i10; 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; } } try { this.listener.onClosing(this, i10, str); if (streams != null) { this.listener.onClosed(this, i10, 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(@NotNull String str) throws IOException { g.i(str, MimeTypes.BASE_TYPE_TEXT); this.listener.onMessage(this, str); } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public synchronized void onReadPing(@NotNull ByteString byteString) { try { g.i(byteString, "payload"); if (!this.failed && (!this.enqueuedClose || !this.messageAndCloseQueue.isEmpty())) { this.pongQueue.add(byteString); runWriter(); this.receivedPingCount++; } } finally { } } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public synchronized void onReadPong(@NotNull ByteString byteString) { g.i(byteString, "payload"); this.receivedPongCount++; this.awaitingPong = false; } public final synchronized boolean pong(@NotNull ByteString payload) { try { g.i(payload, "payload"); if (!this.failed && (!this.enqueuedClose || !this.messageAndCloseQueue.isEmpty())) { this.pongQueue.add(payload); runWriter(); return true; } return false; } catch (Throwable th) { throw th; } } public final boolean processNextFrame() throws IOException { try { WebSocketReader webSocketReader = this.reader; g.f(webSocketReader); webSocketReader.processNextFrame(); return this.receivedCloseCode == -1; } catch (Exception e10) { failWebSocket(e10, 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 @NotNull /* JADX INFO: renamed from: request, reason: from getter */ public Request getOriginalRequest() { return this.originalRequest; } @Override // okhttp3.WebSocket public boolean send(@NotNull String text) { g.i(text, MimeTypes.BASE_TYPE_TEXT); return send(ByteString.INSTANCE.encodeUtf8(text), 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); } public final boolean writeOneFrame$okhttp() throws IOException { String str; WebSocketReader webSocketReader; WebSocketWriter webSocketWriter; int i10; Streams streams; synchronized (this) { try { if (this.failed) { return false; } WebSocketWriter webSocketWriter2 = this.writer; ByteString byteStringPoll = this.pongQueue.poll(); final boolean z10 = true; Object obj = null; if (byteStringPoll == null) { Object objPoll = this.messageAndCloseQueue.poll(); if (objPoll instanceof Close) { i10 = this.receivedCloseCode; str = this.receivedCloseReason; if (i10 != -1) { streams = this.streams; this.streams = null; webSocketReader = this.reader; this.reader = null; webSocketWriter = this.writer; this.writer = null; this.taskQueue.shutdown(); } else { long cancelAfterCloseMillis = ((Close) objPoll).getCancelAfterCloseMillis(); TaskQueue taskQueue = this.taskQueue; final String str2 = this.name + " cancel"; taskQueue.schedule(new Task(str2, z10) { // from class: okhttp3.internal.ws.RealWebSocket$writeOneFrame$lambda$8$$inlined$execute$default$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { this.cancel(); return -1L; } }, TimeUnit.MILLISECONDS.toNanos(cancelAfterCloseMillis)); streams = null; webSocketReader = null; webSocketWriter = null; } } else { if (objPoll == null) { return false; } str = null; webSocketReader = null; webSocketWriter = null; i10 = -1; streams = null; } obj = objPoll; } else { str = null; webSocketReader = null; webSocketWriter = null; i10 = -1; streams = null; } try { if (byteStringPoll != null) { g.f(webSocketWriter2); webSocketWriter2.writePong(byteStringPoll); } else if (obj instanceof Message) { Message message = (Message) obj; g.f(webSocketWriter2); webSocketWriter2.writeMessageFrame(message.getFormatOpcode(), message.getData()); synchronized (this) { this.queueSize -= (long) message.getData().size(); } } else { if (!(obj instanceof Close)) { throw new AssertionError(); } Close close = (Close) obj; g.f(webSocketWriter2); webSocketWriter2.writeClose(close.getCode(), close.getReason()); if (streams != null) { WebSocketListener webSocketListener = this.listener; g.f(str); webSocketListener.onClosed(this, i10, str); } } return true; } finally { if (streams != null) { Util.closeQuietly(streams); } if (webSocketReader != null) { Util.closeQuietly(webSocketReader); } if (webSocketWriter != null) { Util.closeQuietly(webSocketWriter); } } } catch (Throwable th) { throw th; } } } public final void writePingFrame$okhttp() { synchronized (this) { try { if (this.failed) { return; } WebSocketWriter webSocketWriter = this.writer; if (webSocketWriter == null) { return; } int i10 = this.awaitingPong ? this.sentPingCount : -1; this.sentPingCount++; this.awaitingPong = true; if (i10 != -1) { StringBuilder sb = new StringBuilder("sent ping but didn't receive pong within "); sb.append(this.pingIntervalMillis); sb.append("ms (after "); failWebSocket(new SocketTimeoutException(u.a.b(sb, i10 - 1, " successful ping/pongs)")), null); return; } try { webSocketWriter.writePing(ByteString.EMPTY); } catch (IOException e10) { failWebSocket(e10, null); } } catch (Throwable th) { throw th; } } } public final synchronized boolean close(int code, @Nullable String reason, long cancelAfterCloseMillis) { ByteString byteStringEncodeUtf8; try { WebSocketProtocol.INSTANCE.validateCloseCode(code); if (reason != null) { byteStringEncodeUtf8 = ByteString.INSTANCE.encodeUtf8(reason); if (byteStringEncodeUtf8.size() > 123) { throw new IllegalArgumentException("reason.size() > 123: ".concat(reason).toString()); } } else { byteStringEncodeUtf8 = null; } if (!this.failed && !this.enqueuedClose) { this.enqueuedClose = true; this.messageAndCloseQueue.add(new Close(code, byteStringEncodeUtf8, cancelAfterCloseMillis)); runWriter(); return true; } return false; } catch (Throwable th) { throw th; } } @Override // okhttp3.internal.ws.WebSocketReader.FrameCallback public void onReadMessage(@NotNull ByteString byteString) throws IOException { g.i(byteString, "bytes"); this.listener.onMessage(this, byteString); } @Override // okhttp3.WebSocket public boolean send(@NotNull ByteString bytes) { g.i(bytes, "bytes"); return send(bytes, 2); } private final synchronized boolean send(ByteString data, int formatOpcode) { if (!this.failed && !this.enqueuedClose) { if (this.queueSize + ((long) data.size()) > MAX_QUEUE_SIZE) { close(1001, null); return false; } this.queueSize += (long) data.size(); this.messageAndCloseQueue.add(new Message(formatOpcode, data)); runWriter(); return true; } return false; } }