package com.ifpdos.daemonserver;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: CheckTaskManager.java */
/* JADX INFO: loaded from: classes.dex */
public class e {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private Map<com.ifpdos.daemonserver.h.c, b.a.a.b.b> f1501a = new HashMap();

    public /* synthetic */ void a(com.ifpdos.daemonserver.h.c cVar, Long l) throws Throwable {
        if (cVar.a()) {
            return;
        }
        d(cVar);
    }

    public void c(final com.ifpdos.daemonserver.h.c cVar) {
        b.a.a.b.b bVar = this.f1501a.get(cVar);
        if (bVar != null) {
            bVar.dispose();
        }
        this.f1501a.put(cVar, b.a.a.a.g.k(cVar.b(), cVar.c(), TimeUnit.SECONDS).r(new b.a.a.d.c() { // from class: com.ifpdos.daemonserver.b
            @Override // b.a.a.d.c
            public final void a(Object obj) throws Throwable {
                this.f1497a.a(cVar, (Long) obj);
            }
        }, new b.a.a.d.c() { // from class: com.ifpdos.daemonserver.a
            @Override // b.a.a.d.c
            public final void a(Object obj) {
                Throwable th = (Throwable) obj;
                com.ifpdos.daemonserver.i.c.b("CheckTaskManager", th.getMessage(), th);
            }
        }));
    }

    public void d(com.ifpdos.daemonserver.h.c cVar) {
        b.a.a.b.b bVarRemove = this.f1501a.remove(cVar);
        if (bVarRemove != null) {
            bVarRemove.dispose();
        }
    }
}