rr3-apk/decompiled/sources/com/mbridge/msdk/tracker/g.java

package com.mbridge.msdk.tracker;

import java.util.concurrent.atomic.AtomicLong;

/* loaded from: classes4.dex */
final class g implements l {
    private final c a;
    private final r b;
    private final j c;
    private final AtomicLong d = new AtomicLong(0);
    private final long[] e = new long[2];
    private volatile i f;

    public g(c cVar, r rVar, j jVar) {
        this.a = cVar;
        this.b = rVar;
        this.c = jVar;
    }

    @Override // com.mbridge.msdk.tracker.l
    public final void a(e eVar) {
        long incrementAndGet = this.d.incrementAndGet();
        this.e[0] = System.currentTimeMillis();
        this.e[1] = incrementAndGet;
    }

    @Override // com.mbridge.msdk.tracker.l
    public final void b(final e eVar) {
        this.c.b(new Runnable() { // from class: com.mbridge.msdk.tracker.g.1
            @Override // java.lang.Runnable
            public final void run() {
                i iVar = new i(eVar);
                iVar.a(1);
                iVar.b(0);
                iVar.a(System.currentTimeMillis() + eVar.h());
                if (g.this.f != null) {
                    a(g.this.f, 5);
                    g.this.f = null;
                }
                a(iVar, 5);
            }

            private void a(i iVar, int i) {
                while (i > 0) {
                    if (g.this.a.a(iVar) > 0) {
                        g.this.b.c();
                        g.this.b.d();
                        g.this.b.a(eVar);
                        return;
                    }
                    i--;
                }
                g.this.f = iVar;
            }
        });
    }

    @Override // com.mbridge.msdk.tracker.l
    public final long[] a() {
        long[] jArr = this.e;
        return jArr.length == 0 ? new long[]{0, 0} : jArr;
    }
}