package d8;

import android.content.Context;
import android.os.Bundle;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes2.dex */
public final /* synthetic */ class j implements Runnable {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ int f25028a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ k f25029b;

    public /* synthetic */ j(k kVar, int i10) {
        this.f25028a = i10;
        this.f25029b = kVar;
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Type inference fix 'apply assigned field type' failed
    java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg
    	at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593)
    	at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35)
    	at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94)
     */
    @Override // java.lang.Runnable
    public final void run() {
        n nVar;
        boolean z10;
        switch (this.f25028a) {
            case 0:
                break;
            case 1:
                k kVar = this.f25029b;
                synchronized (kVar) {
                    if (kVar.f25030a == 1) {
                        kVar.zza(1, "Timed out while binding");
                    }
                    break;
                }
                return;
            default:
                this.f25029b.zza(2, "Service disconnected");
                return;
        }
        while (true) {
            k kVar2 = this.f25029b;
            synchronized (kVar2) {
                try {
                    if (kVar2.f25030a != 2) {
                        return;
                    }
                    if (kVar2.f25033d.isEmpty()) {
                        kVar2.a();
                        return;
                    }
                    nVar = (n) kVar2.f25033d.poll();
                    kVar2.f25034e.put(nVar.f25037a, nVar);
                    z10 = false;
                    kVar2.f25035f.f25042b.schedule(new l.l(kVar2, nVar, 26, 0 == true ? 1 : 0), 30L, TimeUnit.SECONDS);
                } finally {
                }
            }
            if (Log.isLoggable("MessengerIpcClient", 3)) {
                "Sending ".concat(String.valueOf(nVar));
            }
            o oVar = kVar2.f25035f;
            Messenger messenger = kVar2.f25031b;
            int i10 = nVar.f25039c;
            Context context = oVar.f25041a;
            Message messageObtain = Message.obtain();
            messageObtain.what = i10;
            messageObtain.arg1 = nVar.f25037a;
            messageObtain.replyTo = messenger;
            Bundle bundle = new Bundle();
            switch (((m) nVar).f25036e) {
                case 0:
                    z10 = true;
                    break;
            }
            bundle.putBoolean("oneWay", z10);
            bundle.putString("pkg", context.getPackageName());
            bundle.putBundle("data", nVar.f25040d);
            messageObtain.setData(bundle);
            try {
                kVar2.f25032c.a(messageObtain);
            } catch (RemoteException e10) {
                kVar2.zza(2, e10.getMessage());
            }
        }
    }
}