package r3;

import com.google.android.gms.tasks.TaskCompletionSource;
import java.util.concurrent.atomic.AtomicInteger;

/* loaded from: classes2.dex */
final class l0 extends i0 {

    /* renamed from: b, reason: collision with root package name */
    final /* synthetic */ TaskCompletionSource f13666b;

    /* renamed from: c, reason: collision with root package name */
    final /* synthetic */ i0 f13667c;

    /* renamed from: d, reason: collision with root package name */
    final /* synthetic */ s0 f13668d;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    l0(s0 s0Var, TaskCompletionSource taskCompletionSource, TaskCompletionSource taskCompletionSource2, i0 i0Var) {
        super(taskCompletionSource);
        this.f13666b = taskCompletionSource2;
        this.f13667c = i0Var;
        this.f13668d = s0Var;
    }

    @Override // r3.i0
    public final void a() {
        Object obj;
        AtomicInteger atomicInteger;
        h0 h0Var;
        obj = this.f13668d.f13688f;
        synchronized (obj) {
            s0.n(this.f13668d, this.f13666b);
            atomicInteger = this.f13668d.f13693k;
            if (atomicInteger.getAndIncrement() > 0) {
                h0Var = this.f13668d.f13684b;
                h0Var.d("Already connected to the service.", new Object[0]);
            }
            s0.p(this.f13668d, this.f13667c);
        }
    }
}