package defpackage;

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

/* JADX INFO: renamed from: ᵜᵭᵞᵩ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C2883 extends AbstractC0824 implements InterfaceC5160 {

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public byte[] f11006;

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

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

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public final long f11009;

    public C2883() {
        super(true);
        this.f11009 = 8000L;
        this.f11008 = new LinkedBlockingQueue();
        this.f11006 = new byte[0];
        this.f11007 = -1;
    }

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

    @Override // defpackage.InterfaceC0372
    public final int read(byte[] bArr, int i, int i2) {
        if (i2 == 0) {
            return 0;
        }
        int iMin = Math.min(i2, this.f11006.length);
        System.arraycopy(this.f11006, 0, bArr, i, iMin);
        byte[] bArr2 = this.f11006;
        this.f11006 = Arrays.copyOfRange(bArr2, iMin, bArr2.length);
        if (iMin == i2) {
            return iMin;
        }
        try {
            byte[] bArr3 = (byte[]) this.f11008.poll(this.f11009, 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.f11006 = Arrays.copyOfRange(bArr3, iMin2, bArr3.length);
            }
            return iMin + iMin2;
        } catch (InterruptedException unused) {
            Thread.currentThread().interrupt();
            return -1;
        }
    }

    @Override // defpackage.InterfaceC5160
    /* JADX INFO: renamed from: ʽˈˋ */
    public final String mo2130() {
        ᵻᵪ.ˌᴵ(this.f11007 != -1);
        int i = this.f11007;
        int i2 = this.f11007 + 1;
        String str = AbstractC0956.f4222;
        Locale locale = Locale.US;
        return AbstractC3653.m8230(i, i2, "RTP/AVP/TCP;unicast;interleaved=", "-");
    }

    @Override // defpackage.InterfaceC5160
    /* JADX INFO: renamed from: ˊᵫᵗ */
    public final boolean mo2131() {
        return false;
    }

    @Override // defpackage.InterfaceC5160
    /* JADX INFO: renamed from: ˋˈ */
    public final C2883 mo2132() {
        return this;
    }

    @Override // defpackage.InterfaceC5160
    /* JADX INFO: renamed from: ᵨᵣ */
    public final int mo2133() {
        return this.f11007;
    }

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

    @Override // defpackage.InterfaceC1070
    /* JADX INFO: renamed from: ᵵᵽ */
    public final long mo1308(C0084 c0084) {
        this.f11007 = c0084.f1291.getPort();
        return -1L;
    }
}