package o;

import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import com.google.android.datatransport.runtime.synchronization.SynchronizationException;
import java.util.ArrayList;
import java.util.Iterator;
import o.AbstractC14641fwz;
import o.qmH;
import o.yOA;

/* loaded from: classes.dex */
public final /* synthetic */ class jUc implements Runnable {
    private final AbstractC3038apv a;
    private final C8228dEv b;
    private final Runnable c;
    private final int e;

    @Override // java.lang.Runnable
    public final void run() {
        AbstractC14641fwz d;
        final C8228dEv c8228dEv = this.b;
        final AbstractC3038apv abstractC3038apv = this.a;
        final int i = this.e;
        Runnable runnable = this.c;
        try {
            try {
                qmH qmh = c8228dEv.i;
                final siG sig = c8228dEv.a;
                qmh.d(new qmH.LWm(sig) { // from class: o.hBv
                    private final siG d;

                    @Override // o.qmH.LWm
                    public final Object a() {
                        return Integer.valueOf(this.d.d());
                    }

                    /* JADX INFO: Access modifiers changed from: package-private */
                    {
                        this.d = sig;
                    }
                });
                NetworkInfo activeNetworkInfo = ((ConnectivityManager) c8228dEv.e.getSystemService("connectivity")).getActiveNetworkInfo();
                if (activeNetworkInfo == null || !activeNetworkInfo.isConnected()) {
                    c8228dEv.i.d(new qmH.LWm(c8228dEv, abstractC3038apv, i) { // from class: o.lSP
                        private final int a;
                        private final C8228dEv b;
                        private final AbstractC3038apv c;

                        @Override // o.qmH.LWm
                        public final Object a() {
                            C8228dEv c8228dEv2 = this.b;
                            c8228dEv2.h.a(this.c, this.a + 1);
                            return null;
                        }

                        /* JADX INFO: Access modifiers changed from: package-private */
                        {
                            this.b = c8228dEv;
                            this.c = abstractC3038apv;
                            this.a = i;
                        }
                    });
                } else {
                    Qno d2 = c8228dEv.c.d(abstractC3038apv.a());
                    final Iterable iterable = (Iterable) c8228dEv.i.d(new qmH.LWm(c8228dEv, abstractC3038apv) { // from class: o.cOv
                        private final C8228dEv d;
                        private final AbstractC3038apv e;

                        @Override // o.qmH.LWm
                        public final Object a() {
                            C8228dEv c8228dEv2 = this.d;
                            return c8228dEv2.a.b(this.e);
                        }

                        /* JADX INFO: Access modifiers changed from: package-private */
                        {
                            this.d = c8228dEv;
                            this.e = abstractC3038apv;
                        }
                    });
                    if (iterable.iterator().hasNext()) {
                        if (d2 != null) {
                            ArrayList arrayList = new ArrayList();
                            Iterator it = iterable.iterator();
                            while (it.hasNext()) {
                                arrayList.add(((FFX) it.next()).d());
                            }
                            d = d2.d(new yOA.HBt().c(arrayList).b(abstractC3038apv.d()).e());
                        } else {
                            new Object[]{abstractC3038apv};
                            d = new C1254ZUn(AbstractC14641fwz.Sts.FATAL_ERROR, -1L);
                        }
                        final AbstractC14641fwz abstractC14641fwz = d;
                        c8228dEv.i.d(new qmH.LWm(c8228dEv, abstractC14641fwz, iterable, abstractC3038apv, i) { // from class: o.MCD
                            private final C8228dEv a;
                            private final int b;
                            private final AbstractC3038apv c;
                            private final AbstractC14641fwz d;
                            private final Iterable e;

                            @Override // o.qmH.LWm
                            public final Object a() {
                                C8228dEv c8228dEv2 = this.a;
                                AbstractC14641fwz abstractC14641fwz2 = this.d;
                                Iterable<FFX> iterable2 = this.e;
                                AbstractC3038apv abstractC3038apv2 = this.c;
                                int i2 = this.b;
                                if (abstractC14641fwz2.d() == AbstractC14641fwz.Sts.TRANSIENT_ERROR) {
                                    c8228dEv2.a.c(iterable2);
                                    c8228dEv2.h.a(abstractC3038apv2, i2 + 1);
                                    return null;
                                }
                                c8228dEv2.a.a(iterable2);
                                if (abstractC14641fwz2.d() == AbstractC14641fwz.Sts.OK) {
                                    c8228dEv2.a.c(abstractC3038apv2, c8228dEv2.b.a() + abstractC14641fwz2.a());
                                }
                                if (!c8228dEv2.a.c(abstractC3038apv2)) {
                                    return null;
                                }
                                c8228dEv2.h.a(abstractC3038apv2, 1);
                                return null;
                            }

                            /* JADX INFO: Access modifiers changed from: package-private */
                            {
                                this.a = c8228dEv;
                                this.d = abstractC14641fwz;
                                this.e = iterable;
                                this.c = abstractC3038apv;
                                this.b = i;
                            }
                        });
                    }
                }
            } catch (SynchronizationException unused) {
                c8228dEv.h.a(abstractC3038apv, i + 1);
            }
        } finally {
            runnable.run();
        }
    }

    public jUc(C8228dEv c8228dEv, AbstractC3038apv abstractC3038apv, int i, Runnable runnable) {
        this.b = c8228dEv;
        this.a = abstractC3038apv;
        this.e = i;
        this.c = runnable;
    }
}