package com.google.android.exoplayer2.upstream;

import android.annotation.SuppressLint;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.os.SystemClock;
import java.io.IOException;
import java.util.concurrent.ExecutorService;
import p000.p001.p002.p003.p004.C0567;
import p138.p139.p143.p144.C2803;
import p138.p176.p177.p190.p238.InterfaceC4110;
import p138.p176.p177.p190.p239.C4131;
import p138.p176.p177.p190.p239.C4150;

/* JADX INFO: loaded from: classes.dex */
public final class Loader implements InterfaceC4110 {

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public static final C0320 f1980;

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public static final C0320 f1981;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final ExecutorService f1982;

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public HandlerC0321<? extends InterfaceC0322> f1983;

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public IOException f1984;

    public static final class UnexpectedLoaderException extends IOException {
        /* JADX WARN: Illegal instructions before constructor call */
        public UnexpectedLoaderException(Throwable th) {
            StringBuilder sbM4889 = C2803.m4889("Unexpected ");
            sbM4889.append(th.getClass().getSimpleName());
            sbM4889.append(": ");
            sbM4889.append(th.getMessage());
            super(sbM4889.toString(), th);
        }
    }

    /* JADX INFO: renamed from: com.google.android.exoplayer2.upstream.Loader$ؠ, reason: contains not printable characters */
    public interface InterfaceC0319<T extends InterfaceC0322> {
        /* JADX INFO: renamed from: ֏ */
        C0320 mo1230(T t, long j, long j2, IOException iOException, int i);

        /* JADX INFO: renamed from: ֏ */
        void mo1231(T t, long j, long j2);

        /* JADX INFO: renamed from: ֏ */
        void mo1232(T t, long j, long j2, boolean z);
    }

    /* JADX INFO: renamed from: com.google.android.exoplayer2.upstream.Loader$ހ, reason: contains not printable characters */
    public static final class C0320 {

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public final int f1985;

        /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
        public final long f1986;

        public /* synthetic */ C0320(int i, long j, C0318 c0318) {
            this.f1985 = i;
            this.f1986 = j;
        }

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public boolean m1296() {
            int i = this.f1985;
            return i == 0 || i == 1;
        }
    }

    /* JADX INFO: renamed from: com.google.android.exoplayer2.upstream.Loader$ށ, reason: contains not printable characters */
    @SuppressLint({"HandlerLeak"})
    public final class HandlerC0321<T extends InterfaceC0322> extends Handler implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final int f1987;

        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public final T f1988;

        /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
        public final long f1989;

        /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
        public InterfaceC0319<T> f1990;

        /* JADX INFO: renamed from: އ, reason: contains not printable characters */
        public IOException f1991;

        /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
        public int f1992;

        /* JADX INFO: renamed from: މ, reason: contains not printable characters */
        public volatile Thread f1993;

        /* JADX INFO: renamed from: ފ, reason: contains not printable characters */
        public volatile boolean f1994;

        /* JADX INFO: renamed from: ދ, reason: contains not printable characters */
        public volatile boolean f1995;

        public HandlerC0321(Looper looper, T t, InterfaceC0319<T> interfaceC0319, int i, long j) {
            super(looper);
            this.f1988 = t;
            this.f1990 = interfaceC0319;
            this.f1987 = i;
            this.f1989 = j;
        }

        @Override // android.os.Handler
        public void handleMessage(Message message) {
            if (this.f1995) {
                return;
            }
            int i = message.what;
            if (i == 0) {
                this.f1991 = null;
                Loader loader = Loader.this;
                ExecutorService executorService = loader.f1982;
                HandlerC0321<? extends InterfaceC0322> handlerC0321 = loader.f1983;
                C0567.m1856(handlerC0321);
                executorService.execute(handlerC0321);
                return;
            }
            if (i == 4) {
                throw ((Error) message.obj);
            }
            Loader.this.f1983 = null;
            long jElapsedRealtime = SystemClock.elapsedRealtime();
            long j = jElapsedRealtime - this.f1989;
            InterfaceC0319<T> interfaceC0319 = this.f1990;
            C0567.m1856(interfaceC0319);
            if (this.f1994) {
                interfaceC0319.mo1232(this.f1988, jElapsedRealtime, j, false);
                return;
            }
            int i2 = message.what;
            if (i2 == 1) {
                interfaceC0319.mo1232(this.f1988, jElapsedRealtime, j, false);
                return;
            }
            if (i2 == 2) {
                try {
                    interfaceC0319.mo1231(this.f1988, jElapsedRealtime, j);
                    return;
                } catch (RuntimeException e) {
                    C4131.m6645("LoadTask", "Unexpected exception handling load completed", e);
                    Loader.this.f1984 = new UnexpectedLoaderException(e);
                    return;
                }
            }
            if (i2 != 3) {
                return;
            }
            IOException iOException = (IOException) message.obj;
            this.f1991 = iOException;
            int i3 = this.f1992 + 1;
            this.f1992 = i3;
            C0320 c0320Mo1230 = interfaceC0319.mo1230(this.f1988, jElapsedRealtime, j, iOException, i3);
            int i4 = c0320Mo1230.f1985;
            if (i4 == 3) {
                Loader.this.f1984 = this.f1991;
            } else if (i4 != 2) {
                if (i4 == 1) {
                    this.f1992 = 1;
                }
                long jMin = c0320Mo1230.f1986;
                if (jMin == -9223372036854775807L) {
                    jMin = Math.min((this.f1992 - 1) * 1000, 5000);
                }
                m1297(jMin);
            }
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                this.f1993 = Thread.currentThread();
                if (!this.f1994) {
                    C0567.m1892("load:" + this.f1988.getClass().getSimpleName());
                    try {
                        this.f1988.mo1299();
                        C0567.m1913();
                    } catch (Throwable th) {
                        C0567.m1913();
                        throw th;
                    }
                }
                if (this.f1995) {
                    return;
                }
                sendEmptyMessage(2);
            } catch (IOException e) {
                if (this.f1995) {
                    return;
                }
                obtainMessage(3, e).sendToTarget();
            } catch (OutOfMemoryError e2) {
                C4131.m6645("LoadTask", "OutOfMemory error loading stream", e2);
                if (this.f1995) {
                    return;
                }
                obtainMessage(3, new UnexpectedLoaderException(e2)).sendToTarget();
            } catch (Error e3) {
                C4131.m6645("LoadTask", "Unexpected error loading stream", e3);
                if (!this.f1995) {
                    obtainMessage(4, e3).sendToTarget();
                }
                throw e3;
            } catch (InterruptedException unused) {
                C0567.m1932(this.f1994);
                if (this.f1995) {
                    return;
                }
                sendEmptyMessage(2);
            } catch (Exception e4) {
                C4131.m6645("LoadTask", "Unexpected exception loading stream", e4);
                if (this.f1995) {
                    return;
                }
                obtainMessage(3, new UnexpectedLoaderException(e4)).sendToTarget();
            }
        }

        /* JADX WARN: Multi-variable type inference failed */
        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public void m1297(long j) {
            C0567.m1932(Loader.this.f1983 == null);
            Loader loader = Loader.this;
            loader.f1983 = this;
            if (j > 0) {
                sendEmptyMessageDelayed(0, j);
            } else {
                this.f1991 = null;
                loader.f1982.execute(this);
            }
        }

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public void m1298(boolean z) {
            this.f1995 = z;
            this.f1991 = null;
            if (hasMessages(0)) {
                removeMessages(0);
                if (!z) {
                    sendEmptyMessage(1);
                }
            } else {
                this.f1994 = true;
                this.f1988.mo1300();
                Thread thread = this.f1993;
                if (thread != null) {
                    thread.interrupt();
                }
            }
            if (z) {
                Loader.this.f1983 = null;
                long jElapsedRealtime = SystemClock.elapsedRealtime();
                InterfaceC0319<T> interfaceC0319 = this.f1990;
                C0567.m1856(interfaceC0319);
                interfaceC0319.mo1232(this.f1988, jElapsedRealtime, jElapsedRealtime - this.f1989, true);
                this.f1990 = null;
            }
        }
    }

    /* JADX INFO: renamed from: com.google.android.exoplayer2.upstream.Loader$ނ, reason: contains not printable characters */
    public interface InterfaceC0322 {
        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        void mo1299();

        /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
        void mo1300();
    }

    /* JADX INFO: renamed from: com.google.android.exoplayer2.upstream.Loader$ރ, reason: contains not printable characters */
    public interface InterfaceC0323 {
        /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
        void mo1301();
    }

    /* JADX INFO: renamed from: com.google.android.exoplayer2.upstream.Loader$ބ, reason: contains not printable characters */
    public static final class RunnableC0324 implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final InterfaceC0323 f1997;

        public RunnableC0324(InterfaceC0323 interfaceC0323) {
            this.f1997 = interfaceC0323;
        }

        @Override // java.lang.Runnable
        public void run() {
            this.f1997.mo1301();
        }
    }

    static {
        long j = -9223372036854775807L;
        m1289(false, -9223372036854775807L);
        m1289(true, -9223372036854775807L);
        C0318 c0318 = null;
        f1980 = new C0320(2, j, c0318);
        f1981 = new C0320(3, j, c0318);
    }

    public Loader(String str) {
        this.f1982 = C4150.m6800(str);
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public static C0320 m1289(boolean z, long j) {
        return new C0320(z ? 1 : 0, j, null);
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public <T extends InterfaceC0322> long m1290(T t, InterfaceC0319<T> interfaceC0319, int i) {
        Looper looperMyLooper = Looper.myLooper();
        C0567.m1925(looperMyLooper);
        this.f1984 = null;
        long jElapsedRealtime = SystemClock.elapsedRealtime();
        new HandlerC0321(looperMyLooper, t, interfaceC0319, i, jElapsedRealtime).m1297(0L);
        return jElapsedRealtime;
    }

    @Override // p138.p176.p177.p190.p238.InterfaceC4110
    /* JADX INFO: renamed from: ֏ */
    public void mo1233() throws IOException {
        m1291(Integer.MIN_VALUE);
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m1291(int i) throws IOException {
        IOException iOException = this.f1984;
        if (iOException != null) {
            throw iOException;
        }
        HandlerC0321<? extends InterfaceC0322> handlerC0321 = this.f1983;
        if (handlerC0321 != null) {
            if (i == Integer.MIN_VALUE) {
                i = handlerC0321.f1987;
            }
            IOException iOException2 = handlerC0321.f1991;
            if (iOException2 != null && handlerC0321.f1992 > i) {
                throw iOException2;
            }
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m1292(InterfaceC0323 interfaceC0323) {
        HandlerC0321<? extends InterfaceC0322> handlerC0321 = this.f1983;
        if (handlerC0321 != null) {
            handlerC0321.m1298(true);
        }
        if (interfaceC0323 != null) {
            this.f1982.execute(new RunnableC0324(interfaceC0323));
        }
        this.f1982.shutdown();
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public void m1293() {
        HandlerC0321<? extends InterfaceC0322> handlerC0321 = this.f1983;
        C0567.m1925(handlerC0321);
        handlerC0321.m1298(false);
    }

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public boolean m1294() {
        return this.f1984 != null;
    }

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public boolean m1295() {
        return this.f1983 != null;
    }
}