package rj;

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

/* JADX INFO: Access modifiers changed from: package-private */
/* loaded from: classes3.dex */
public final class l0 extends i0 {

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

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

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

    /* JADX INFO: Access modifiers changed from: package-private */
    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public l0(s0 s0Var, TaskCompletionSource taskCompletionSource, TaskCompletionSource taskCompletionSource2, i0 i0Var) {
        super(taskCompletionSource);
        this.f34815q = taskCompletionSource2;
        this.f34816r = i0Var;
        this.f34817s = s0Var;
    }

    @Override // rj.i0
    public final void a() {
        Object obj;
        AtomicInteger atomicInteger;
        h0 h0Var;
        obj = this.f34817s.f34837f;
        synchronized (obj) {
            s0.n(this.f34817s, this.f34815q);
            atomicInteger = this.f34817s.f34842k;
            if (atomicInteger.getAndIncrement() > 0) {
                h0Var = this.f34817s.f34833b;
                h0Var.d("Already connected to the service.", new Object[0]);
            }
            s0.p(this.f34817s, this.f34816r);
        }
    }
}
