83 lines
2.2 KiB
Java
83 lines
2.2 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import android.os.Handler;
|
||
|
|
import android.os.Looper;
|
||
|
|
import java.util.ArrayList;
|
||
|
|
import java.util.HashSet;
|
||
|
|
import java.util.List;
|
||
|
|
import java.util.Set;
|
||
|
|
import java.util.concurrent.PriorityBlockingQueue;
|
||
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
||
|
|
|
||
|
|
/* renamed from: o.VzR, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public class C1117VzR {
|
||
|
|
public final qNX a;
|
||
|
|
public final InterfaceC17333vqS b;
|
||
|
|
public DqI c;
|
||
|
|
final Set<HJP<?>> d;
|
||
|
|
public final PriorityBlockingQueue<HJP<?>> e;
|
||
|
|
private final List<IeS> f;
|
||
|
|
public final PriorityBlockingQueue<HJP<?>> g;
|
||
|
|
public final C0676MAs[] h;
|
||
|
|
final List<HBt> i;
|
||
|
|
public final ZFL j;
|
||
|
|
private final AtomicInteger m;
|
||
|
|
|
||
|
|
@Deprecated
|
||
|
|
/* renamed from: o.VzR$HBt */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public interface HBt<T> {
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.VzR$IeS */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public interface IeS {
|
||
|
|
}
|
||
|
|
|
||
|
|
private C1117VzR(InterfaceC17333vqS interfaceC17333vqS, ZFL zfl, qNX qnx) {
|
||
|
|
this.m = new AtomicInteger();
|
||
|
|
this.d = new HashSet();
|
||
|
|
this.e = new PriorityBlockingQueue<>();
|
||
|
|
this.g = new PriorityBlockingQueue<>();
|
||
|
|
this.i = new ArrayList();
|
||
|
|
this.f = new ArrayList();
|
||
|
|
this.b = interfaceC17333vqS;
|
||
|
|
this.j = zfl;
|
||
|
|
this.h = new C0676MAs[4];
|
||
|
|
this.a = qnx;
|
||
|
|
}
|
||
|
|
|
||
|
|
private C1117VzR(InterfaceC17333vqS interfaceC17333vqS, ZFL zfl, byte b) {
|
||
|
|
this(interfaceC17333vqS, zfl, new C13978fkX(new Handler(Looper.getMainLooper())));
|
||
|
|
}
|
||
|
|
|
||
|
|
public C1117VzR(InterfaceC17333vqS interfaceC17333vqS, ZFL zfl) {
|
||
|
|
this(interfaceC17333vqS, zfl, (byte) 0);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final <T> HJP<T> d(HJP<T> hjp) {
|
||
|
|
hjp.setRequestQueue(this);
|
||
|
|
synchronized (this.d) {
|
||
|
|
this.d.add(hjp);
|
||
|
|
}
|
||
|
|
hjp.setSequence(this.m.incrementAndGet());
|
||
|
|
hjp.addMarker("add-to-queue");
|
||
|
|
d();
|
||
|
|
if (hjp.shouldCache()) {
|
||
|
|
this.e.add(hjp);
|
||
|
|
} else {
|
||
|
|
this.g.add(hjp);
|
||
|
|
}
|
||
|
|
return hjp;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
public final void d() {
|
||
|
|
synchronized (this.f) {
|
||
|
|
for (IeS ieS : this.f) {
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|