package com.vungle.warren.downloader;

import androidx.annotation.Keep;
import com.google.android.gms.common.api.Api;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.locks.ReentrantLock;

@Keep
/* loaded from: classes2.dex */
class DownloadRequestMediator {
    public final String filePath;
    public final boolean isCacheable;
    public final String key;
    public final String metaPath;
    public final c priority;
    public final String url;
    private AtomicInteger statusAtomic = new AtomicInteger(0);
    private Map<String, y.d> children = new ConcurrentHashMap(1);
    private final ReentrantLock lock = new ReentrantLock();
    private AtomicBoolean connectedAtomic = new AtomicBoolean(true);
    private AtomicReference<Runnable> runnable = new AtomicReference<>();

    DownloadRequestMediator(f fVar, a aVar, String str, String str2, boolean z10, String str3) {
        this.url = fVar.f8147b;
        this.filePath = str;
        this.metaPath = str2;
        this.isCacheable = z10;
        this.key = str3;
        this.priority = fVar.b();
        this.children.put(fVar.f8151f, new y.d(fVar, aVar));
    }

    synchronized void add(f fVar, a aVar) {
        this.children.put(fVar.f8151f, new y.d(fVar, aVar));
    }

    c getPriority() {
        c b10;
        c cVar = new c(Api.BaseClientBuilder.API_PRIORITY_OTHER, Api.BaseClientBuilder.API_PRIORITY_OTHER);
        Iterator<y.d> it = values().iterator();
        while (it.hasNext()) {
            Object obj = it.next().f15524a;
            if (obj != null && (b10 = ((f) obj).b()) != null && cVar.compareTo(b10) >= 0) {
                cVar = b10;
            }
        }
        return cVar;
    }

    public Runnable getRunnable() {
        return this.runnable.get();
    }

    @Status
    public int getStatus() {
        return this.statusAtomic.get();
    }

    boolean is(@Status int i10) {
        return this.statusAtomic.get() == i10;
    }

    boolean isConnected() {
        return this.connectedAtomic.get();
    }

    boolean isPausable() {
        Iterator<y.d> it = values().iterator();
        while (it.hasNext()) {
            Object obj = it.next().f15524a;
            if (obj != null && ((f) obj).f8149d) {
                return true;
            }
        }
        return false;
    }

    void lock() {
        this.lock.lock();
    }

    synchronized y.d remove(f fVar) {
        return this.children.remove(fVar.f8151f);
    }

    synchronized List<f> requests() {
        ArrayList arrayList;
        List<y.d> values = values();
        arrayList = new ArrayList();
        Iterator<y.d> it = values.iterator();
        while (it.hasNext()) {
            arrayList.add(it.next().f15524a);
        }
        return arrayList;
    }

    void set(@Status int i10) {
        if (this.statusAtomic.get() == 3) {
            return;
        }
        this.statusAtomic.set(i10);
    }

    void setConnected(boolean z10) {
        this.connectedAtomic.set(z10);
    }

    public void setRunnable(Runnable runnable) {
        this.runnable.set(runnable);
    }

    void unlock() {
        this.lock.unlock();
    }

    synchronized List<y.d> values() {
        return new ArrayList(this.children.values());
    }
}