package o;

import java.util.concurrent.Executor;
import java.util.logging.Logger;
import o.qmH;

/* loaded from: classes.dex */
public final class SOm implements nws {
    static final Logger a = Logger.getLogger(SnM.class.getName());
    final qmH b;
    final cNI c;
    final siG d;
    final ncN e;
    private final Executor h;

    @InterfaceC13391fZD
    public SOm(Executor executor, ncN ncn, cNI cni, siG sig, qmH qmh) {
        this.h = executor;
        this.e = ncn;
        this.c = cni;
        this.d = sig;
        this.b = qmh;
    }

    @Override // o.nws
    public final void c(final AbstractC3038apv abstractC3038apv, final AbstractC5394bsH abstractC5394bsH, final mUN mun) {
        this.h.execute(new Runnable(this, abstractC3038apv, mun, abstractC5394bsH) { // from class: o.Mne
            private final mUN a;
            private final AbstractC5394bsH b;
            private final AbstractC3038apv c;
            private final SOm d;

            @Override // java.lang.Runnable
            public final void run() {
                final SOm sOm = this.d;
                final AbstractC3038apv abstractC3038apv2 = this.c;
                mUN mun2 = this.a;
                AbstractC5394bsH abstractC5394bsH2 = this.b;
                try {
                    Qno d = sOm.e.d(abstractC3038apv2.a());
                    if (d == null) {
                        String format = String.format("Transport backend '%s' is not registered", abstractC3038apv2.a());
                        SOm.a.warning(format);
                        mun2.onSchedule(new IllegalArgumentException(format));
                    } else {
                        final AbstractC5394bsH d2 = d.d(abstractC5394bsH2);
                        sOm.b.d(new qmH.LWm(sOm, abstractC3038apv2, d2) { // from class: o.Ngy
                            private final AbstractC3038apv c;
                            private final SOm d;
                            private final AbstractC5394bsH e;

                            @Override // o.qmH.LWm
                            public final Object a() {
                                SOm sOm2 = this.d;
                                AbstractC3038apv abstractC3038apv3 = this.c;
                                sOm2.d.b(abstractC3038apv3, this.e);
                                sOm2.c.a(abstractC3038apv3, 1);
                                return null;
                            }

                            /* JADX INFO: Access modifiers changed from: package-private */
                            {
                                this.d = sOm;
                                this.c = abstractC3038apv2;
                                this.e = d2;
                            }
                        });
                        mun2.onSchedule(null);
                    }
                } catch (Exception e) {
                    Logger logger = SOm.a;
                    StringBuilder sb = new StringBuilder("Error scheduling event ");
                    sb.append(e.getMessage());
                    logger.warning(sb.toString());
                    mun2.onSchedule(e);
                }
            }

            /* JADX INFO: Access modifiers changed from: package-private */
            {
                this.d = this;
                this.c = abstractC3038apv;
                this.a = mun;
                this.b = abstractC5394bsH;
            }
        });
    }
}