package com.bytedance.sdk.component.adexpress.ro;

import android.content.Context;
import android.view.View;
import com.bytedance.sdk.component.adexpress.ro.vt;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: loaded from: classes.dex */
public class irt implements vt {
    private AtomicBoolean ajl = new AtomicBoolean(false);
    private Context fm;
    private ScheduledFuture<?> jnr;

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private wu f6552lb;
    private com.bytedance.sdk.component.adexpress.jnr.fm ro;
    private dsz yz;

    public class fm implements Runnable {
        vt.fm fm;

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

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

        @Override // java.lang.Runnable
        public void run() {
            if (this.f6553lb == 1) {
                irt.this.ro.fm(true);
                irt.this.fm(this.fm, 107, null);
            }
        }
    }

    public irt(Context context, dsz dszVar, com.bytedance.sdk.component.adexpress.jnr.fm fmVar, wu wuVar) {
        this.fm = context;
        this.yz = dszVar;
        this.f6552lb = wuVar;
        this.ro = fmVar;
        fmVar.fm(this.f6552lb);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void lb() {
        try {
            ScheduledFuture<?> scheduledFuture = this.jnr;
            if (scheduledFuture == null || scheduledFuture.isCancelled()) {
                return;
            }
            this.jnr.cancel(false);
            this.jnr = null;
        } catch (Throwable unused) {
        }
    }

    public com.bytedance.sdk.component.adexpress.jnr.fm ro() {
        return this.ro;
    }

    @Override // com.bytedance.sdk.component.adexpress.ro.vt
    public boolean fm(final vt.fm fmVar) {
        int iAjl = this.yz.ajl();
        if (iAjl < 0) {
            fm(fmVar, 107, "time is ".concat(String.valueOf(iAjl)));
        } else {
            this.jnr = com.bytedance.sdk.component.adexpress.yz.yz.fm(new fm(1, fmVar), iAjl, TimeUnit.MILLISECONDS);
            this.ro.fm(new wsy() { // from class: com.bytedance.sdk.component.adexpress.ro.irt.1
                @Override // com.bytedance.sdk.component.adexpress.ro.wsy
                public void fm(View view, onz onzVar) {
                    fhx fhxVarRo;
                    irt.this.lb();
                    if (fmVar.lb() || (fhxVarRo = fmVar.ro()) == null) {
                        return;
                    }
                    fhxVarRo.fm(irt.this.ro, onzVar);
                    fmVar.fm(true);
                }

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

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

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(vt.fm fmVar, int i10, String str) {
        fhx fhxVarRo;
        if (fmVar.lb() || this.ajl.get()) {
            return;
        }
        lb();
        this.yz.jnr().fm(i10, str);
        if (fmVar.ro(this)) {
            fmVar.fm(this);
        } else {
            if (fmVar.lb() || (fhxVarRo = fmVar.ro()) == null) {
                return;
            }
            fmVar.fm(true);
            fhxVarRo.a_(i10);
        }
        this.ajl.getAndSet(true);
    }
}