package defpackage;

import android.net.Uri;
import androidx.media3.datasource.UdpDataSource$UdpDataSourceException;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.MulticastSocket;
import java.net.SocketTimeoutException;

/* JADX INFO: renamed from: ᵟᵮˎ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C3103 extends AbstractC0824 {

    /* JADX INFO: renamed from: ʿٴˇ, reason: contains not printable characters */
    public InetAddress f11870;

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public final DatagramPacket f11871;

    /* JADX INFO: renamed from: ˉᵵᵜ, reason: contains not printable characters */
    public int f11872;

    /* JADX INFO: renamed from: ˌᵨʠᵫ, reason: contains not printable characters */
    public Uri f11873;

    /* JADX INFO: renamed from: ˑˊᵲ, reason: contains not printable characters */
    public MulticastSocket f11874;

    /* JADX INFO: renamed from: ᵠˏˏ, reason: contains not printable characters */
    public boolean f11875;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public final int f11876;

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public final byte[] f11877;

    /* JADX INFO: renamed from: ᵸˆˁ, reason: contains not printable characters */
    public DatagramSocket f11878;

    public C3103() {
        this(8000);
    }

    public C3103(int i) {
        super(true);
        this.f11876 = i;
        byte[] bArr = new byte[2000];
        this.f11877 = bArr;
        this.f11871 = new DatagramPacket(bArr, 0, 2000);
    }

    @Override // defpackage.InterfaceC1070
    public final void close() {
        this.f11873 = null;
        MulticastSocket multicastSocket = this.f11874;
        if (multicastSocket != null) {
            try {
                InetAddress inetAddress = this.f11870;
                inetAddress.getClass();
                multicastSocket.leaveGroup(inetAddress);
            } catch (IOException unused) {
            }
            this.f11874 = null;
        }
        DatagramSocket datagramSocket = this.f11878;
        if (datagramSocket != null) {
            datagramSocket.close();
            this.f11878 = null;
        }
        this.f11870 = null;
        this.f11872 = 0;
        if (this.f11875) {
            this.f11875 = false;
            m2945();
        }
    }

    @Override // defpackage.InterfaceC0372
    public final int read(byte[] bArr, int i, int i2) throws UdpDataSource$UdpDataSourceException {
        if (i2 == 0) {
            return 0;
        }
        int i3 = this.f11872;
        DatagramPacket datagramPacket = this.f11871;
        if (i3 == 0) {
            try {
                DatagramSocket datagramSocket = this.f11878;
                datagramSocket.getClass();
                datagramSocket.receive(datagramPacket);
                int length = datagramPacket.getLength();
                this.f11872 = length;
                m2946(length);
            } catch (SocketTimeoutException e) {
                throw new UdpDataSource$UdpDataSourceException(2002, e);
            } catch (IOException e2) {
                throw new UdpDataSource$UdpDataSourceException(2001, e2);
            }
        }
        int length2 = datagramPacket.getLength();
        int i4 = this.f11872;
        int iMin = Math.min(i4, i2);
        System.arraycopy(this.f11877, length2 - i4, bArr, i, iMin);
        this.f11872 -= iMin;
        return iMin;
    }

    @Override // defpackage.InterfaceC1070
    /* JADX INFO: renamed from: ᵯᵷʽ */
    public final Uri mo1307() {
        return this.f11873;
    }

    @Override // defpackage.InterfaceC1070
    /* JADX INFO: renamed from: ᵵᵽ */
    public final long mo1308(C0084 c0084) {
        Uri uri = c0084.f1291;
        this.f11873 = uri;
        String host = uri.getHost();
        host.getClass();
        int port = this.f11873.getPort();
        m2948();
        try {
            this.f11870 = InetAddress.getByName(host);
            InetSocketAddress inetSocketAddress = new InetSocketAddress(this.f11870, port);
            if (this.f11870.isMulticastAddress()) {
                MulticastSocket multicastSocket = new MulticastSocket(inetSocketAddress);
                this.f11874 = multicastSocket;
                multicastSocket.joinGroup(this.f11870);
                this.f11878 = this.f11874;
            } else {
                this.f11878 = new DatagramSocket(inetSocketAddress);
            }
            this.f11878.setSoTimeout(this.f11876);
            this.f11875 = true;
            m2947(c0084);
            return -1L;
        } catch (IOException e) {
            throw new UdpDataSource$UdpDataSourceException(2001, e);
        } catch (SecurityException e2) {
            throw new UdpDataSource$UdpDataSourceException(2006, e2);
        }
    }
}