package b.c.e.d;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Build;
import android.os.IBinder;
import android.os.RemoteException;
import android.os.ServiceManager;
import android.util.Log;
import b.c.e.a.b;
import com.cvte.tv.api.TvApiManagerService;
import com.cvte.tv.api.aidl.ITvApiManager;
import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: TvApiManager.java */
/* JADX INFO: loaded from: classes.dex */
public class c {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private static final ScheduledExecutorService f1680a = Executors.newSingleThreadScheduledExecutor();

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private static Context f1681b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private ITvApiManager f1682c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private List<WeakReference<d>> f1683d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private IBinder.DeathRecipient f1684e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private ServiceConnection f1685f;

    /* JADX INFO: compiled from: TvApiManager.java */
    class a implements IBinder.DeathRecipient {
        a() {
        }

        @Override // android.os.IBinder.DeathRecipient
        public void binderDied() {
            Log.e("TvApiManager", "TvApi binder died.");
            c.this.f1682c = null;
            c.this.i();
        }
    }

    /* JADX INFO: compiled from: TvApiManager.java */
    class b implements ServiceConnection {
        b() {
        }

        @Override // android.content.ServiceConnection
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            try {
                iBinder.linkToDeath(c.this.f1684e, 0);
                c.this.f1682c = ITvApiManager.Stub.asInterface(iBinder);
                c cVar = c.this;
                cVar.p(cVar.f1682c);
            } catch (RemoteException unused) {
                Log.e("TvApiManager", "Link to TvApi failed.");
                ScheduledExecutorService scheduledExecutorService = c.f1680a;
                final c cVar2 = c.this;
                scheduledExecutorService.schedule(new Runnable() { // from class: b.c.e.d.a
                    @Override // java.lang.Runnable
                    public final void run() {
                        cVar2.i();
                    }
                }, 500L, TimeUnit.MILLISECONDS);
            }
        }

        @Override // android.content.ServiceConnection
        public void onServiceDisconnected(ComponentName componentName) {
            c.this.f1684e.binderDied();
        }
    }

    /* JADX INFO: renamed from: b.c.e.d.c$c, reason: collision with other inner class name */
    /* JADX INFO: compiled from: TvApiManager.java */
    private static class C0061c {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        private static final c f1688a = new c(null);
    }

    /* JADX INFO: compiled from: TvApiManager.java */
    public interface d {
        void onTvApiConnected(ITvApiManager iTvApiManager);
    }

    /* synthetic */ c(a aVar) {
        this();
    }

    private boolean h() {
        Intent intent = new Intent("com.cvte.tv.api.TV_API_SERVICE");
        intent.setPackage("com.cvte.tv.api.impl");
        f1681b.startService(intent);
        return f1681b.bindService(intent, this.f1685f, 1);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void i() {
        if (n()) {
            Log.d("TvApiManager", "ignore connectTvApiService on 9950-11");
            if (h()) {
                return;
            }
            Log.e("TvApiManager", "TvApiService not ready, retrying.");
            f1680a.schedule(new Runnable() { // from class: b.c.e.d.b
                @Override // java.lang.Runnable
                public final void run() {
                    this.f1679c.i();
                }
            }, 500L, TimeUnit.MILLISECONDS);
            return;
        }
        ITvApiManager iTvApiManagerJ = j();
        if (iTvApiManagerJ != null) {
            this.f1682c = iTvApiManagerJ;
            p(iTvApiManagerJ);
        } else {
            Log.e("TvApiManager", "TvApiService not ready, retrying.");
            f1680a.schedule(new Runnable() { // from class: b.c.e.d.b
                @Override // java.lang.Runnable
                public final void run() {
                    this.f1679c.i();
                }
            }, 500L, TimeUnit.MILLISECONDS);
        }
    }

    private ITvApiManager j() {
        IBinder service = ServiceManager.getService(TvApiManagerService.TVAPI_SERVICE);
        if (service == null || !service.pingBinder()) {
            return null;
        }
        try {
            service.linkToDeath(this.f1684e, 0);
            return ITvApiManager.Stub.asInterface(service);
        } catch (RemoteException unused) {
            Log.e("TvApiManager", "Link to TvApi failed.");
            return null;
        }
    }

    public static c k() {
        return C0061c.f1688a;
    }

    public static void m(Context context) {
        f1681b = context.getApplicationContext();
    }

    private boolean n() {
        return b.C0052b.f1527a == 8 && Build.VERSION.SDK_INT == 30;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void p(ITvApiManager iTvApiManager) {
        Log.i("TvApiManager", "onTvApiConnected - " + iTvApiManager);
        ArrayList arrayList = new ArrayList();
        for (WeakReference<d> weakReference : this.f1683d) {
            d dVar = weakReference.get();
            if (dVar == null) {
                arrayList.add(weakReference);
            } else {
                dVar.onTvApiConnected(iTvApiManager);
            }
        }
        this.f1683d.removeAll(arrayList);
    }

    public void g(d dVar) {
        if (dVar == null) {
            return;
        }
        Iterator<WeakReference<d>> it = this.f1683d.iterator();
        while (it.hasNext()) {
            if (dVar.equals(it.next().get())) {
                Log.e("TvApiManager", "addOnTvApiConnectedCallback: " + dVar + " has been added.");
                return;
            }
        }
        this.f1683d.add(new WeakReference<>(dVar));
        ITvApiManager iTvApiManager = this.f1682c;
        if (iTvApiManager != null) {
            dVar.onTvApiConnected(iTvApiManager);
        }
    }

    public ITvApiManager l() {
        return this.f1682c;
    }

    public void q() {
        ITvApiManager iTvApiManager = this.f1682c;
        if (iTvApiManager == null || !iTvApiManager.asBinder().pingBinder()) {
            i();
        }
    }

    private c() {
        this.f1683d = new CopyOnWriteArrayList();
        this.f1684e = new a();
        this.f1685f = new b();
        i();
    }
}