package o1;

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 io.sentry.C0732k1;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

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

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

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

    public /* synthetic */ j(k kVar, int i) {
        this.f9402k = i;
        this.f9403l = kVar;
    }

    @Override // java.lang.Runnable
    public final void run() {
        switch (this.f9402k) {
            case 0:
                break;
            case 1:
                k kVar = this.f9403l;
                synchronized (kVar) {
                    if (kVar.f9404a == 1) {
                        kVar.a("Timed out while binding");
                    }
                    break;
                }
                return;
            default:
                this.f9403l.a("Service disconnected");
                return;
        }
        while (true) {
            k kVar2 = this.f9403l;
            synchronized (kVar2) {
                try {
                    if (kVar2.f9404a != 2) {
                        return;
                    }
                    if (kVar2.f9407d.isEmpty()) {
                        kVar2.c();
                        return;
                    }
                    l lVar = (l) kVar2.f9407d.poll();
                    kVar2.f9408e.put(lVar.f9410a, lVar);
                    ((ScheduledExecutorService) kVar2.f9409f.f9418m).schedule(new i(1, kVar2, lVar), 30L, TimeUnit.SECONDS);
                    if (Log.isLoggable("MessengerIpcClient", 3)) {
                        Log.d("MessengerIpcClient", "Sending ".concat(String.valueOf(lVar)));
                    }
                    m mVar = kVar2.f9409f;
                    Messenger messenger = kVar2.f9405b;
                    int i = lVar.f9412c;
                    Context context = (Context) mVar.f9417l;
                    Message messageObtain = Message.obtain();
                    messageObtain.what = i;
                    messageObtain.arg1 = lVar.f9410a;
                    messageObtain.replyTo = messenger;
                    Bundle bundle = new Bundle();
                    bundle.putBoolean("oneWay", lVar.a());
                    bundle.putString("pkg", context.getPackageName());
                    bundle.putBundle("data", lVar.f9413d);
                    messageObtain.setData(bundle);
                    try {
                        C0732k1 c0732k1 = kVar2.f9406c;
                        Messenger messenger2 = (Messenger) c0732k1.f7858l;
                        if (messenger2 != null) {
                            messenger2.send(messageObtain);
                        } else {
                            g gVar = (g) c0732k1.f7859m;
                            if (gVar == null) {
                                throw new IllegalStateException("Both messengers are null");
                            }
                            Messenger messenger3 = gVar.f9395k;
                            messenger3.getClass();
                            messenger3.send(messageObtain);
                        }
                    } catch (RemoteException e2) {
                        kVar2.a(e2.getMessage());
                    }
                } finally {
                }
            }
        }
    }
}