package defpackage;

import j$.util.DesugarCollections;
import java.io.Closeable;
import java.net.Socket;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;

/* JADX INFO: renamed from: ᵹᵵ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C5094 implements Closeable {

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public static final Charset f19191 = StandardCharsets.UTF_8;

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final C1709 f19192;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public C3089 f19195;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public Socket f19196;

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public volatile boolean f19197;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final ᵣˊˈᵪ f19194 = new ᵣˊˈᵪ(2, "ExoPlayer:RtspMessageChannel:ReceiverLoader");

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final Map f19193 = DesugarCollections.synchronizedMap(new HashMap());

    public C5094(C1709 c1709) {
        this.f19192 = c1709;
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        if (this.f19197) {
            return;
        }
        try {
            C3089 c3089 = this.f19195;
            if (c3089 != null) {
                c3089.close();
            }
            this.f19194.ˊᵾʽʼ((InterfaceC1158) null);
            Socket socket = this.f19196;
            if (socket != null) {
                socket.close();
            }
            this.f19197 = true;
        } catch (Throwable th) {
            this.f19197 = true;
            throw th;
        }
    }

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final void m10574(C2598 c2598) {
        this.f19195.getClass();
        C3089 c3089 = this.f19195;
        c3089.getClass();
        c3089.f11781.post(new RunnableC2093(c3089, new C2571(AbstractC0208.f1679).m6300(c2598).getBytes(f19191), c2598, 16));
    }

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final void m10575(Socket socket) {
        this.f19196 = socket;
        this.f19195 = new C3089(this, socket.getOutputStream());
        this.f19194.ᵵᵬᵽ(new C3505(this, socket.getInputStream()), new ᵖˊʨ(this), 0);
    }
}