package com.bytedance.sdk.openadsdk.core.dsz.ro;

import android.content.Context;
import android.view.View;
import com.bytedance.adsdk.ugeno.core.qhl;
import com.bytedance.sdk.component.adexpress.ro.dsz;
import com.bytedance.sdk.component.adexpress.ro.fhx;
import com.bytedance.sdk.component.adexpress.ro.onz;
import com.bytedance.sdk.component.adexpress.ro.vt;
import com.bytedance.sdk.component.adexpress.ro.wu;
import com.bytedance.sdk.component.utils.wey;
import com.bytedance.sdk.openadsdk.core.vt.irt;
import com.bytedance.sdk.openadsdk.utils.xgn;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: loaded from: classes2.dex */
public class wsy implements vt {
    private irt ajl;
    private Context fm;
    private AtomicBoolean jnr = new AtomicBoolean(false);

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private dsz f7066lb;
    private com.bytedance.sdk.openadsdk.core.dsz.ajl.yz ro;
    private ScheduledFuture<?> yz;

    public class fm implements Runnable {
        vt.fm fm;

        /* JADX INFO: renamed from: lb, reason: collision with root package name */
        private int f7067lb;

        public fm(int i10, vt.fm fmVar) {
            this.f7067lb = i10;
            this.fm = fmVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f7067lb == 1) {
                wsy.this.ro.fm(true);
                wsy.this.fm(this.fm, 137, "real time out" + wsy.this.f7066lb.ajl());
            }
        }
    }

    public wsy(Context context, com.bytedance.sdk.openadsdk.core.dsz.ajl.yz yzVar, wu wuVar, dsz dszVar) {
        this.fm = context;
        this.ro = yzVar;
        this.f7066lb = dszVar;
        this.ro.fm(wuVar);
    }

    @Override // com.bytedance.sdk.component.adexpress.ro.vt
    public void fm() {
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void ro() {
        try {
            ScheduledFuture<?> scheduledFuture = this.yz;
            if (scheduledFuture == null || scheduledFuture.isCancelled()) {
                return;
            }
            this.yz.cancel(false);
            this.yz = null;
        } catch (Throwable th) {
            wey.lb("RenderInterceptor", "remove ugen time out task fail", th.getMessage());
        }
    }

    public void fm(irt irtVar) {
        this.ajl = irtVar;
        this.ro.fm(irtVar);
    }

    @Override // com.bytedance.sdk.component.adexpress.ro.vt
    public boolean fm(final vt.fm fmVar) {
        int iAjl = this.f7066lb.ajl();
        if (iAjl < 0 && !(this.ro instanceof com.bytedance.sdk.openadsdk.core.dsz.ajl.fm.ajl)) {
            fm(fmVar, 137, "time is ".concat(String.valueOf(iAjl)));
        } else {
            if (!(this.ro instanceof com.bytedance.sdk.openadsdk.core.dsz.ajl.fm.ajl)) {
                this.yz = xgn.fm().schedule(new fm(1, fmVar), iAjl, TimeUnit.MILLISECONDS);
            }
            this.ro.fm(new com.bytedance.sdk.component.adexpress.ro.wsy() { // from class: com.bytedance.sdk.openadsdk.core.dsz.ro.wsy.1
                @Override // com.bytedance.sdk.component.adexpress.ro.wsy
                public void fm(View view, onz onzVar) {
                    wsy.this.ro();
                    if (fmVar.lb()) {
                        return;
                    }
                    qhl qhlVar = new qhl();
                    qhlVar.fm(0);
                    if (wsy.this.ro instanceof com.bytedance.sdk.openadsdk.core.dsz.ajl.fm.ajl) {
                        wsy.this.f7066lb.jnr().ajl();
                    } else {
                        ((com.bytedance.sdk.openadsdk.core.dsz.ajl.fm) wsy.this.f7066lb).pkk().fm(qhlVar);
                    }
                    wsy.this.f7066lb.jnr().ef();
                    fhx fhxVarRo = fmVar.ro();
                    if (fhxVarRo == null) {
                        return;
                    }
                    fhxVarRo.fm(wsy.this.ro, onzVar);
                    fmVar.fm(true);
                }

                @Override // com.bytedance.sdk.component.adexpress.ro.wsy
                public void fm(int i10, String str) {
                    wsy.this.fm(fmVar, i10, str);
                }
            });
        }
        return true;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(vt.fm fmVar, int i10, String str) {
        fhx fhxVarRo;
        if (fmVar.lb() || this.jnr.get()) {
            return;
        }
        ro();
        qhl qhlVar = new qhl();
        qhlVar.fm(i10);
        qhlVar.fm(str);
        ((com.bytedance.sdk.openadsdk.core.dsz.ajl.fm) this.f7066lb).pkk().fm(qhlVar);
        if (fmVar.ro(this)) {
            fmVar.fm(this);
        } else {
            if (fmVar.lb() || (fhxVarRo = fmVar.ro()) == null) {
                return;
            }
            fmVar.fm(true);
            fhxVarRo.a_(i10);
        }
        this.jnr.getAndSet(true);
    }
}