151 lines
6.5 KiB
Java
151 lines
6.5 KiB
Java
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;
|
|
}
|
|
}
|