package com.bytedance.sdk.component.jnr.ro.lb;

import com.bytedance.sdk.component.jnr.gqi;
import com.bytedance.sdk.component.jnr.irt;
import com.bytedance.sdk.component.jnr.ku;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

/* JADX INFO: loaded from: classes.dex */
public class fm<T> {
    private lb fm;
    private gqi ro;

    public fm(lb lbVar, gqi gqiVar) {
        this.fm = lbVar;
        this.ro = gqiVar;
    }

    public void fm(ku<T> kuVar) {
        try {
            gqi gqiVar = this.ro;
            if (gqiVar != null) {
                gqiVar.fm("success", this.fm);
            }
            String strGqi = this.fm.gqi();
            Map<String, List<lb>> mapEf = this.fm.irt().ef();
            List<lb> list = mapEf.get(strGqi);
            if (list == null) {
                irt irtVarAjl = this.fm.ajl();
                if (irtVarAjl != null) {
                    irtVarAjl.toString();
                    this.fm.wu();
                    irtVarAjl.fm(kuVar);
                }
            } else {
                synchronized (list) {
                    try {
                        list.size();
                        for (lb lbVar : list) {
                            irt irtVarAjl2 = lbVar.ajl();
                            if (irtVarAjl2 != null) {
                                irtVarAjl2.toString();
                                lbVar.wu();
                                irtVarAjl2.fm(kuVar);
                            }
                        }
                        list.clear();
                        mapEf.remove(strGqi);
                    } finally {
                    }
                }
            }
            gqi gqiVar2 = this.ro;
            if (gqiVar2 != null) {
                gqiVar2.ro("success", this.fm);
            }
        } catch (Throwable unused) {
        }
    }

    public void fm(int i10, String str, Throwable th) {
        try {
            gqi gqiVar = this.ro;
            if (gqiVar != null) {
                gqiVar.fm("failed", this.fm);
            }
            String strGqi = this.fm.gqi();
            Map<String, List<lb>> mapEf = this.fm.irt().ef();
            List<lb> list = mapEf.get(strGqi);
            if (list == null) {
                irt irtVarAjl = this.fm.ajl();
                if (irtVarAjl != null) {
                    irtVarAjl.fm(i10, str, th);
                }
            } else {
                synchronized (list) {
                    try {
                        Iterator<lb> it = list.iterator();
                        while (it.hasNext()) {
                            irt irtVarAjl2 = it.next().ajl();
                            if (irtVarAjl2 != null) {
                                irtVarAjl2.toString();
                                irtVarAjl2.fm(i10, str, th);
                            }
                        }
                        list.clear();
                        mapEf.remove(strGqi);
                    } finally {
                    }
                }
            }
            gqi gqiVar2 = this.ro;
            if (gqiVar2 != null) {
                gqiVar2.ro("failed", this.fm);
            }
        } catch (Throwable unused) {
        }
    }
}