package b.c.e.d;

import android.os.Bundle;
import android.os.RemoteException;
import android.util.Log;
import b.c.e.d.c;
import com.cvte.tv.api.aidl.INotifyListener;
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;

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

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private INotifyListener f1689a;

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

    /* JADX INFO: compiled from: TvApiNotifyManager.java */
    private class b extends INotifyListener.Stub {
        private b() {
        }

        @Override // com.cvte.tv.api.aidl.INotifyListener
        public void onNotify(String str, Bundle bundle) {
            ArrayList arrayList = new ArrayList();
            for (WeakReference weakReference : d.this.f1690b) {
                c cVar = (c) weakReference.get();
                if (cVar == null) {
                    arrayList.add(weakReference);
                } else {
                    cVar.onNotify(str, bundle);
                }
            }
            d.this.f1690b.removeAll(arrayList);
        }
    }

    /* JADX INFO: compiled from: TvApiNotifyManager.java */
    public interface c {
        void onNotify(String str, Bundle bundle);
    }

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

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

    public static d b() {
        return C0062d.f1692a;
    }

    public void c(c cVar) {
        if (cVar == null) {
            return;
        }
        Iterator<WeakReference<c>> it = this.f1690b.iterator();
        while (it.hasNext()) {
            if (cVar.equals(it.next().get())) {
                Log.e("TvApiNotifyManager", "registerListener: " + cVar + " has been registered.");
                return;
            }
        }
        this.f1690b.add(new WeakReference<>(cVar));
    }

    public void d(c cVar) {
        if (cVar == null) {
            return;
        }
        WeakReference<c> weakReference = null;
        Iterator<WeakReference<c>> it = this.f1690b.iterator();
        while (true) {
            if (!it.hasNext()) {
                break;
            }
            WeakReference<c> next = it.next();
            if (cVar.equals(next.get())) {
                weakReference = next;
                break;
            }
        }
        if (weakReference != null) {
            this.f1690b.remove(weakReference);
        }
    }

    @Override // b.c.e.d.c.d
    public void onTvApiConnected(ITvApiManager iTvApiManager) {
        try {
            Log.i("TvApiNotifyManager", "Add notify listener when tv-api connected.");
            b.c.e.d.c.k().l().addNotifyListener(this.f1689a);
        } catch (RemoteException e2) {
            Log.e("TvApiNotifyManager", "", e2);
            b.c.e.d.c.k().q();
        }
    }

    private d() {
        this.f1689a = new b();
        this.f1690b = new CopyOnWriteArrayList();
        b.c.e.d.c.k().g(this);
    }
}