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;

/* renamed from: ᵠᵠٴᵿ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C3138 implements Closeable {

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public static final Charset f11927 = StandardCharsets.UTF_8;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public volatile boolean f11928;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public Socket f11930;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final C5553 f11931;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public C1185 f11932;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final ᵧˉʙ f11929 = new ᵧˉʙ(2, "ExoPlayer:RtspMessageChannel:ReceiverLoader");

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final Map f11933 = DesugarCollections.synchronizedMap(new HashMap());

    public C3138(C5553 c5553) {
        this.f11931 = c5553;
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        if (this.f11928) {
            return;
        }
        try {
            C1185 c1185 = this.f11932;
            if (c1185 != null) {
                c1185.close();
            }
            this.f11929.ˁˑᵰ((InterfaceC2428) null);
            Socket socket = this.f11930;
            if (socket != null) {
                socket.close();
            }
            this.f11928 = true;
        } catch (Throwable th) {
            this.f11928 = true;
            throw th;
        }
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final void m7502(C4471 c4471) {
        this.f11932.getClass();
        C1185 c1185 = this.f11932;
        c1185.getClass();
        c1185.f5036.post(new RunnableC5417(c1185, new C0204(AbstractC0306.f1946).m1479(c4471).getBytes(f11927), c4471, 16));
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final void m7503(Socket socket) {
        this.f11930 = socket;
        this.f11932 = new C1185(this, socket.getOutputStream());
        this.f11929.ᵡᵘˎʽ(new C4643(this, socket.getInputStream()), new ᵺᐧʝ(this), 0);
    }
}