package com.google.android.gms.internal.ads;

import android.net.TrafficStats;
import android.os.Process;
import android.os.SystemClock;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;

/* JADX INFO: loaded from: classes2.dex */
public final class ec extends Thread {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final BlockingQueue f10747a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final dc f10748b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final zb f10749c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public volatile boolean f10750d = false;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final ru f10751e;

    public ec(PriorityBlockingQueue priorityBlockingQueue, dc dcVar, zb zbVar, ru ruVar) {
        this.f10747a = priorityBlockingQueue;
        this.f10748b = dcVar;
        this.f10749c = zbVar;
        this.f10751e = ruVar;
    }

    public final void a() {
        ru ruVar = this.f10751e;
        gc gcVar = (gc) this.f10747a.take();
        SystemClock.elapsedRealtime();
        gcVar.c(3);
        try {
            try {
                gcVar.a("network-queue-take");
                synchronized (gcVar.f11699e) {
                }
                TrafficStats.setThreadStatsTag(gcVar.f11698d);
                fc fcVarZza = this.f10748b.zza(gcVar);
                gcVar.a("network-http-complete");
                if (fcVarZza.f11171c && gcVar.h()) {
                    gcVar.b("not-modified");
                    gcVar.m();
                } else {
                    lc lcVarI = gcVar.i(fcVarZza);
                    gcVar.a("network-parse-complete");
                    yb ybVar = lcVarI.zzb;
                    if (ybVar != null) {
                        ((vc) this.f10749c).a(gcVar.d(), ybVar);
                        gcVar.a("network-cache-written");
                    }
                    synchronized (gcVar.f11699e) {
                        gcVar.f11702h = true;
                    }
                    ruVar.g(gcVar, lcVarI, null);
                    gcVar.l(lcVarI);
                }
            } catch (zzash e10) {
                SystemClock.elapsedRealtime();
                ruVar.k(gcVar, e10);
                gcVar.m();
            } catch (Exception e11) {
                oc.b("Unhandled exception %s", e11.toString());
                zzash zzashVar = new zzash(e11);
                SystemClock.elapsedRealtime();
                ruVar.k(gcVar, zzashVar);
                gcVar.m();
            }
            gcVar.c(4);
        } catch (Throwable th) {
            gcVar.c(4);
            throw th;
        }
    }

    @Override // java.lang.Thread, java.lang.Runnable
    public final void run() {
        Process.setThreadPriority(10);
        while (true) {
            try {
                a();
            } catch (InterruptedException unused) {
                if (this.f10750d) {
                    Thread.currentThread().interrupt();
                    return;
                }
                oc.b("Ignoring spurious interrupt of NetworkDispatcher thread; use quit() to terminate it", new Object[0]);
            }
        }
    }
}