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

import android.content.Context;
import android.os.Binder;
import android.os.Bundle;
import androidx.annotation.Nullable;
import com.google.android.gms.common.annotation.KeepForSdk;
import java.util.concurrent.Executor;

/* JADX INFO: loaded from: classes2.dex */
public abstract class cu0 implements com.google.android.gms.common.internal.b, com.google.android.gms.common.internal.c {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final e30 f10080a = new e30();

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Object f10081b = new Object();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public boolean f10082c = false;

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public tz f10084e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public qt f10085f;

    public static void b(Context context, e30 e30Var, Executor executor) {
        if (((Boolean) hp.f12226j.j()).booleanValue() || ((Boolean) hp.f12224h.j()).booleanValue()) {
            ih1.z1(e30Var, new qn(context, 4), executor);
        }
    }

    public final void a() {
        synchronized (this.f10081b) {
            try {
                this.f10083d = true;
                if (this.f10085f.isConnected() || this.f10085f.isConnecting()) {
                    this.f10085f.disconnect();
                }
                Binder.flushPendingCommands();
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Override // com.google.android.gms.common.internal.b
    @KeepForSdk
    public abstract /* synthetic */ void onConnected(@Nullable Bundle bundle);

    @Override // com.google.android.gms.common.internal.c
    public void onConnectionFailed(e8.b bVar) {
        q7.j.a("Disconnected from remote ad request service.");
        this.f10080a.a(new zzeff(1));
    }

    @Override // com.google.android.gms.common.internal.b
    public void onConnectionSuspended(int i10) {
        q7.j.a("Cannot connect to remote service, fallback to local instance.");
    }
}