package defpackage;

import android.net.Uri;
import java.util.Arrays;
import java.util.Locale;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

/* renamed from: ˑʽᵛ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C2020 extends AbstractC1628 implements InterfaceC3048 {

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public byte[] f8109;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public int f8110;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public final long f8111;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final LinkedBlockingQueue f8112;

    public C2020() {
        super(true);
        this.f8111 = 8000L;
        this.f8112 = new LinkedBlockingQueue();
        this.f8109 = new byte[0];
        this.f8110 = -1;
    }

    @Override // defpackage.InterfaceC2569
    public final void close() {
    }

    @Override // defpackage.InterfaceC1463
    public final int read(byte[] bArr, int i, int i2) {
        if (i2 == 0) {
            return 0;
        }
        int iMin = Math.min(i2, this.f8109.length);
        System.arraycopy(this.f8109, 0, bArr, i, iMin);
        byte[] bArr2 = this.f8109;
        this.f8109 = Arrays.copyOfRange(bArr2, iMin, bArr2.length);
        if (iMin == i2) {
            return iMin;
        }
        try {
            byte[] bArr3 = (byte[]) this.f8112.poll(this.f8111, TimeUnit.MILLISECONDS);
            if (bArr3 == null) {
                return -1;
            }
            int iMin2 = Math.min(i2 - iMin, bArr3.length);
            System.arraycopy(bArr3, 0, bArr, i + iMin, iMin2);
            if (iMin2 < bArr3.length) {
                this.f8109 = Arrays.copyOfRange(bArr3, iMin2, bArr3.length);
            }
            return iMin + iMin2;
        } catch (InterruptedException unused) {
            Thread.currentThread().interrupt();
            return -1;
        }
    }

    @Override // defpackage.InterfaceC3048
    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final int mo5552() {
        return this.f8110;
    }

    @Override // defpackage.InterfaceC2569
    /* renamed from: ˏˋٴ */
    public final long mo1165(C4179 c4179) {
        this.f8110 = c4179.f15620.getPort();
        return -1L;
    }

    @Override // defpackage.InterfaceC3048
    /* renamed from: ᵪʩ, reason: contains not printable characters */
    public final C2020 mo5553() {
        return this;
    }

    @Override // defpackage.InterfaceC3048
    /* renamed from: ᵴᵳ, reason: contains not printable characters */
    public final String mo5554() {
        ᵛᵾˏ.ᵿʗᵝʽ(this.f8110 != -1);
        int i = this.f8110;
        int i2 = this.f8110 + 1;
        String str = AbstractC3558.f13329;
        Locale locale = Locale.US;
        return AbstractC1327.m4091(i, i2, "RTP/AVP/TCP;unicast;interleaved=", "-");
    }

    @Override // defpackage.InterfaceC3048
    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public final boolean mo5555() {
        return false;
    }

    @Override // defpackage.InterfaceC2569
    /* renamed from: ᵿʗᵝʽ */
    public final Uri mo1166() {
        return null;
    }
}