package M2;

import P2.w;
import android.content.ComponentName;
import android.content.ServiceConnection;
import android.os.IBinder;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

/* JADX INFO: loaded from: classes.dex */
public final class a implements ServiceConnection {

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

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final LinkedBlockingQueue f4152r = new LinkedBlockingQueue();

    public final IBinder a() throws TimeoutException {
        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
        w.e("BlockingServiceConnection.getServiceWithTimeout() called on main thread");
        if (this.f4151q) {
            throw new IllegalStateException("Cannot call get on this connection more than once");
        }
        this.f4151q = true;
        IBinder iBinder = (IBinder) this.f4152r.poll(10000L, timeUnit);
        if (iBinder != null) {
            return iBinder;
        }
        throw new TimeoutException("Timed out waiting for the service connection");
    }

    @Override // android.content.ServiceConnection
    public final void onServiceConnected(ComponentName componentName, IBinder iBinder) {
        this.f4152r.add(iBinder);
    }

    @Override // android.content.ServiceConnection
    public final void onServiceDisconnected(ComponentName componentName) {
    }
}