package x2;

import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.Executor;
import r2.g;
import t2.c;
import z2.b;

/* loaded from: classes.dex */
public class r {

    /* renamed from: a, reason: collision with root package name */
    private final Context f15327a;

    /* renamed from: b, reason: collision with root package name */
    private final r2.e f15328b;

    /* renamed from: c, reason: collision with root package name */
    private final y2.d f15329c;

    /* renamed from: d, reason: collision with root package name */
    private final x f15330d;

    /* renamed from: e, reason: collision with root package name */
    private final Executor f15331e;

    /* renamed from: f, reason: collision with root package name */
    private final z2.b f15332f;

    /* renamed from: g, reason: collision with root package name */
    private final a3.a f15333g;

    /* renamed from: h, reason: collision with root package name */
    private final a3.a f15334h;

    /* renamed from: i, reason: collision with root package name */
    private final y2.c f15335i;

    public r(Context context, r2.e eVar, y2.d dVar, x xVar, Executor executor, z2.b bVar, a3.a aVar, a3.a aVar2, y2.c cVar) {
        this.f15327a = context;
        this.f15328b = eVar;
        this.f15329c = dVar;
        this.f15330d = xVar;
        this.f15331e = executor;
        this.f15332f = bVar;
        this.f15333g = aVar;
        this.f15334h = aVar2;
        this.f15335i = cVar;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Boolean l(q2.o oVar) {
        return Boolean.valueOf(this.f15329c.i0(oVar));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Iterable m(q2.o oVar) {
        return this.f15329c.y(oVar);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Object n(Iterable iterable, q2.o oVar, long j10) {
        this.f15329c.A0(iterable);
        this.f15329c.M(oVar, this.f15333g.a() + j10);
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Object o(Iterable iterable) {
        this.f15329c.x(iterable);
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Object p() {
        this.f15335i.z();
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Object q(Map map) {
        Iterator it = map.entrySet().iterator();
        while (it.hasNext()) {
            this.f15335i.c(((Integer) r0.getValue()).intValue(), c.b.INVALID_PAYLOD, (String) ((Map.Entry) it.next()).getKey());
        }
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Object r(q2.o oVar, long j10) {
        this.f15329c.M(oVar, this.f15333g.a() + j10);
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Object s(q2.o oVar, int i10) {
        this.f15330d.a(oVar, i10 + 1);
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void t(final q2.o oVar, final int i10, Runnable runnable) {
        try {
            try {
                z2.b bVar = this.f15332f;
                final y2.d dVar = this.f15329c;
                Objects.requireNonNull(dVar);
                bVar.G(new b.a() { // from class: x2.i
                    @Override // z2.b.a
                    public final Object c() {
                        return Integer.valueOf(y2.d.this.w());
                    }
                });
                if (k()) {
                    u(oVar, i10);
                } else {
                    this.f15332f.G(new b.a() { // from class: x2.j
                        @Override // z2.b.a
                        public final Object c() {
                            Object s10;
                            s10 = r.this.s(oVar, i10);
                            return s10;
                        }
                    });
                }
            } catch (z2.a unused) {
                this.f15330d.a(oVar, i10 + 1);
            }
        } finally {
            runnable.run();
        }
    }

    public q2.i j(r2.m mVar) {
        z2.b bVar = this.f15332f;
        final y2.c cVar = this.f15335i;
        Objects.requireNonNull(cVar);
        return mVar.a(q2.i.a().i(this.f15333g.a()).k(this.f15334h.a()).j("GDT_CLIENT_METRICS").h(new q2.h(o2.b.b("proto"), ((t2.a) bVar.G(new b.a() { // from class: x2.h
            @Override // z2.b.a
            public final Object c() {
                return y2.c.this.I();
            }
        })).f())).d());
    }

    boolean k() {
        NetworkInfo activeNetworkInfo = ((ConnectivityManager) this.f15327a.getSystemService("connectivity")).getActiveNetworkInfo();
        return activeNetworkInfo != null && activeNetworkInfo.isConnected();
    }

    public r2.g u(final q2.o oVar, int i10) {
        r2.g b10;
        r2.m mVar = this.f15328b.get(oVar.b());
        long j10 = 0;
        r2.g e10 = r2.g.e(0L);
        while (true) {
            final long j11 = j10;
            while (((Boolean) this.f15332f.G(new b.a() { // from class: x2.k
                @Override // z2.b.a
                public final Object c() {
                    Boolean l10;
                    l10 = r.this.l(oVar);
                    return l10;
                }
            })).booleanValue()) {
                final Iterable iterable = (Iterable) this.f15332f.G(new b.a() { // from class: x2.l
                    @Override // z2.b.a
                    public final Object c() {
                        Iterable m10;
                        m10 = r.this.m(oVar);
                        return m10;
                    }
                });
                if (!iterable.iterator().hasNext()) {
                    return e10;
                }
                if (mVar == null) {
                    u2.a.b("Uploader", "Unknown backend for %s, deleting event batch for it...", oVar);
                    b10 = r2.g.a();
                } else {
                    ArrayList arrayList = new ArrayList();
                    Iterator it = iterable.iterator();
                    while (it.hasNext()) {
                        arrayList.add(((y2.k) it.next()).b());
                    }
                    if (oVar.e()) {
                        arrayList.add(j(mVar));
                    }
                    b10 = mVar.b(r2.f.a().b(arrayList).c(oVar.c()).a());
                }
                e10 = b10;
                if (e10.c() == g.a.TRANSIENT_ERROR) {
                    this.f15332f.G(new b.a() { // from class: x2.m
                        @Override // z2.b.a
                        public final Object c() {
                            Object n10;
                            n10 = r.this.n(iterable, oVar, j11);
                            return n10;
                        }
                    });
                    this.f15330d.b(oVar, i10 + 1, true);
                    return e10;
                }
                this.f15332f.G(new b.a() { // from class: x2.n
                    @Override // z2.b.a
                    public final Object c() {
                        Object o10;
                        o10 = r.this.o(iterable);
                        return o10;
                    }
                });
                if (e10.c() == g.a.OK) {
                    j10 = Math.max(j11, e10.b());
                    if (oVar.e()) {
                        this.f15332f.G(new b.a() { // from class: x2.o
                            @Override // z2.b.a
                            public final Object c() {
                                Object p10;
                                p10 = r.this.p();
                                return p10;
                            }
                        });
                    }
                } else if (e10.c() == g.a.INVALID_PAYLOAD) {
                    final HashMap hashMap = new HashMap();
                    Iterator it2 = iterable.iterator();
                    while (it2.hasNext()) {
                        String j12 = ((y2.k) it2.next()).b().j();
                        if (hashMap.containsKey(j12)) {
                            hashMap.put(j12, Integer.valueOf(((Integer) hashMap.get(j12)).intValue() + 1));
                        } else {
                            hashMap.put(j12, 1);
                        }
                    }
                    this.f15332f.G(new b.a() { // from class: x2.p
                        @Override // z2.b.a
                        public final Object c() {
                            Object q10;
                            q10 = r.this.q(hashMap);
                            return q10;
                        }
                    });
                }
            }
            this.f15332f.G(new b.a() { // from class: x2.q
                @Override // z2.b.a
                public final Object c() {
                    Object r10;
                    r10 = r.this.r(oVar, j11);
                    return r10;
                }
            });
            return e10;
        }
    }

    public void v(final q2.o oVar, final int i10, final Runnable runnable) {
        this.f15331e.execute(new Runnable() { // from class: x2.g
            @Override // java.lang.Runnable
            public final void run() {
                r.this.t(oVar, i10, runnable);
            }
        });
    }
}