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

import android.content.Context;
import android.os.Bundle;
import android.os.DeadObjectException;
import android.os.HandlerThread;
import android.os.Parcel;
import java.util.concurrent.LinkedBlockingQueue;
import tv.danmaku.ijk.media.player.IjkMediaMeta;

/* JADX INFO: loaded from: classes2.dex */
public final class v5 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 w5 f21275a;

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

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final LinkedBlockingQueue f21278d;

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

    public v5(Context context, String str, String str2) {
        this.f21276b = str;
        this.f21277c = str2;
        HandlerThread handlerThread = new HandlerThread("GassClient");
        this.f21279e = handlerThread;
        handlerThread.start();
        w5 w5Var = new w5(context, handlerThread.getLooper(), this, this);
        this.f21275a = w5Var;
        this.f21278d = new LinkedBlockingQueue();
        w5Var.checkAvailabilityAndConnect();
    }

    public static l1 a() {
        ea eaVarO = l1.O();
        eaVarO.j(IjkMediaMeta.AV_CH_TOP_BACK_LEFT);
        return (l1) eaVarO.g();
    }

    public final void b() {
        w5 w5Var = this.f21275a;
        if (w5Var != null) {
            if (w5Var.isConnected() || w5Var.isConnecting()) {
                w5Var.disconnect();
            }
        }
    }

    @Override // com.google.android.gms.common.internal.b
    public final void onConnected(Bundle bundle) {
        a6 a6VarC;
        LinkedBlockingQueue linkedBlockingQueue = this.f21278d;
        HandlerThread handlerThread = this.f21279e;
        try {
            a6VarC = this.f21275a.c();
        } catch (DeadObjectException | IllegalStateException unused) {
            a6VarC = null;
        }
        if (a6VarC != null) {
            try {
                try {
                    x5 x5Var = new x5(1, this.f21276b, this.f21277c);
                    Parcel parcelO = a6VarC.O();
                    int i10 = y4.f21365a;
                    parcelO.writeInt(1);
                    x5Var.writeToParcel(parcelO, 0);
                    Parcel parcelI1 = a6VarC.i1(1, parcelO);
                    z5 z5VarCreateFromParcel = parcelI1.readInt() == 0 ? null : z5.CREATOR.createFromParcel(parcelI1);
                    parcelI1.recycle();
                    if (z5VarCreateFromParcel.f21402b == null) {
                        try {
                            z5VarCreateFromParcel.f21402b = l1.e0(z5VarCreateFromParcel.f21403c, w.a());
                            z5VarCreateFromParcel.f21403c = null;
                        } catch (zzadi | NullPointerException e10) {
                            throw new IllegalStateException(e10);
                        }
                    }
                    z5VarCreateFromParcel.w();
                    linkedBlockingQueue.put(z5VarCreateFromParcel.f21402b);
                } catch (Throwable unused2) {
                    linkedBlockingQueue.put(a());
                }
            } catch (InterruptedException unused3) {
            } catch (Throwable th) {
                b();
                handlerThread.quit();
                throw th;
            }
            b();
            handlerThread.quit();
        }
    }

    @Override // com.google.android.gms.common.internal.c
    public final void onConnectionFailed(e8.b bVar) {
        try {
            this.f21278d.put(a());
        } catch (InterruptedException unused) {
        }
    }

    @Override // com.google.android.gms.common.internal.b
    public final void onConnectionSuspended(int i10) {
        try {
            this.f21278d.put(a());
        } catch (InterruptedException unused) {
        }
    }
}