package com.bytedance.sdk.openadsdk.component.reward.lb.ro;

import android.os.Handler;
import android.os.Message;
import com.bytedance.sdk.component.utils.mq;

/* JADX INFO: loaded from: classes2.dex */
public class ro implements mq.fm {

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private long f6964lb;
    private fm ro;
    private long yz;
    private Handler fm = new mq(this);
    private boolean jnr = false;
    private boolean ajl = false;
    private int wsy = 10000;
    private int wu = 10000;

    public interface fm {
        void fm();

        void fm(EnumC0054ro enumC0054ro);
    }

    /* JADX INFO: renamed from: com.bytedance.sdk.openadsdk.component.reward.lb.ro.ro$ro, reason: collision with other inner class name */
    public enum EnumC0054ro {
        NORMAL,
        TIMEOUT,
        DISCONNECTED
    }

    private void lb() {
        if (!this.jnr || this.ro == null) {
            return;
        }
        this.f6964lb = System.currentTimeMillis();
        this.ajl = true;
        this.ro.fm();
        this.fm.removeMessages(2);
        this.fm.sendEmptyMessageDelayed(2, this.wu);
        this.fm.removeMessages(1);
        this.fm.sendEmptyMessageDelayed(1, this.wsy);
    }

    private void yz() {
        if (this.jnr && this.ajl && System.currentTimeMillis() - this.f6964lb >= this.wsy) {
            this.ajl = false;
            fm fmVar = this.ro;
            if (fmVar != null) {
                fmVar.fm(EnumC0054ro.TIMEOUT);
            }
            fm();
        }
    }

    public void fm(int i10) {
        this.wsy = i10;
    }

    public void ro(int i10) {
        this.wu = i10;
    }

    public void fm(fm fmVar) {
        if (this.jnr) {
            return;
        }
        this.ro = fmVar;
        this.jnr = true;
        this.ajl = false;
        this.fm.sendEmptyMessage(1);
        if (fmVar != null) {
            fmVar.fm(EnumC0054ro.NORMAL);
        }
    }

    public void ro() {
        if (this.jnr && this.ajl) {
            this.yz = System.currentTimeMillis();
            this.ajl = false;
            this.fm.removeMessages(2);
            fm fmVar = this.ro;
            if (fmVar != null) {
                fmVar.fm(EnumC0054ro.NORMAL);
            }
        }
    }

    public void fm() {
        this.jnr = false;
        this.ajl = false;
        this.fm.removeMessages(1);
        this.fm.removeMessages(2);
        this.ro = null;
    }

    @Override // com.bytedance.sdk.component.utils.mq.fm
    public void fm(Message message) {
        int i10 = message.what;
        if (i10 == 1) {
            lb();
        } else {
            if (i10 != 2) {
                return;
            }
            yz();
        }
    }
}