NetMirror.apk
Download file
package com.facebook.react.modules.core;
import C2.p;
import D2.h;
import android.util.SparseArray;
import android.view.Choreographer;
import com.facebook.react.bridge.Arguments;
import com.facebook.react.bridge.LifecycleEventListener;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.bridge.UiThreadUtil;
import com.facebook.react.bridge.WritableArray;
import com.facebook.react.modules.core.JavaTimerManager;
import com.facebook.react.modules.core.b;
import e1.l;
import java.util.Comparator;
import java.util.Iterator;
import java.util.PriorityQueue;
import java.util.concurrent.atomic.AtomicBoolean;
import kotlin.jvm.internal.DefaultConstructorMarker;
import r2.r;
import u1.C0742e;
import u1.InterfaceC0743f;
/* JADX INFO: loaded from: classes.dex */
public class JavaTimerManager implements LifecycleEventListener, InterfaceC0743f {
/* JADX INFO: renamed from: r, reason: collision with root package name */
private static final a f6889r = new a(null);
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final ReactApplicationContext f6890b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private final B1.c f6891c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
private final com.facebook.react.modules.core.b f6892d;
/* JADX INFO: renamed from: e, reason: collision with root package name */
private final k1.e f6893e;
/* JADX INFO: renamed from: f, reason: collision with root package name */
private final Object f6894f;
/* JADX INFO: renamed from: g, reason: collision with root package name */
private final Object f6895g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
private final SparseArray f6896h;
/* JADX INFO: renamed from: i, reason: collision with root package name */
private final AtomicBoolean f6897i;
/* JADX INFO: renamed from: j, reason: collision with root package name */
private final AtomicBoolean f6898j;
/* JADX INFO: renamed from: k, reason: collision with root package name */
private final e f6899k;
/* JADX INFO: renamed from: l, reason: collision with root package name */
private final c f6900l;
/* JADX INFO: renamed from: m, reason: collision with root package name */
private b f6901m;
/* JADX INFO: renamed from: n, reason: collision with root package name */
private boolean f6902n;
/* JADX INFO: renamed from: o, reason: collision with root package name */
private boolean f6903o;
/* JADX INFO: renamed from: p, reason: collision with root package name */
private boolean f6904p;
/* JADX INFO: renamed from: q, reason: collision with root package name */
private final PriorityQueue f6905q;
private static final class a {
public /* synthetic */ a(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
/* JADX INFO: Access modifiers changed from: private */
public final boolean b(d dVar, long j3) {
return !dVar.b() && ((long) dVar.a()) < j3;
}
private a() {
}
}
private final class b implements Runnable {
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final long f6906b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private volatile boolean f6907c;
public b(long j3) {
this.f6906b = j3;
}
public final void a() {
this.f6907c = true;
}
@Override // java.lang.Runnable
public void run() {
boolean z3;
if (this.f6907c) {
return;
}
long jC = l.c() - (this.f6906b / ((long) 1000000));
long jA = l.a() - jC;
if (16.666666f - jC < 1.0f) {
return;
}
Object obj = JavaTimerManager.this.f6895g;
JavaTimerManager javaTimerManager = JavaTimerManager.this;
synchronized (obj) {
z3 = javaTimerManager.f6904p;
r rVar = r.f10584a;
}
if (z3) {
JavaTimerManager.this.f6891c.callIdleCallbacks(jA);
}
JavaTimerManager.this.f6901m = null;
}
}
private final class c implements Choreographer.FrameCallback {
public c() {
}
@Override // android.view.Choreographer.FrameCallback
public void doFrame(long j3) {
if (!JavaTimerManager.this.f6897i.get() || JavaTimerManager.this.f6898j.get()) {
b bVar = JavaTimerManager.this.f6901m;
if (bVar != null) {
bVar.a();
}
JavaTimerManager javaTimerManager = JavaTimerManager.this;
javaTimerManager.f6901m = javaTimerManager.new b(j3);
JavaTimerManager.this.f6890b.runOnJSQueueThread(JavaTimerManager.this.f6901m);
JavaTimerManager.this.f6892d.k(b.a.f6927g, this);
}
}
}
/* JADX INFO: Access modifiers changed from: private */
static final class d {
/* JADX INFO: renamed from: a, reason: collision with root package name */
private final int f6910a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private long f6911b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private final int f6912c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
private final boolean f6913d;
public d(int i3, long j3, int i4, boolean z3) {
this.f6910a = i3;
this.f6911b = j3;
this.f6912c = i4;
this.f6913d = z3;
}
public final int a() {
return this.f6912c;
}
public final boolean b() {
return this.f6913d;
}
public final long c() {
return this.f6911b;
}
public final int d() {
return this.f6910a;
}
public final void e(long j3) {
this.f6911b = j3;
}
}
private final class e implements Choreographer.FrameCallback {
/* JADX INFO: renamed from: a, reason: collision with root package name */
private WritableArray f6914a;
public e() {
}
@Override // android.view.Choreographer.FrameCallback
public void doFrame(long j3) {
d dVar;
if (!JavaTimerManager.this.f6897i.get() || JavaTimerManager.this.f6898j.get()) {
long j4 = j3 / ((long) 1000000);
Object obj = JavaTimerManager.this.f6894f;
JavaTimerManager javaTimerManager = JavaTimerManager.this;
synchronized (obj) {
while (!javaTimerManager.f6905q.isEmpty()) {
try {
Object objPeek = javaTimerManager.f6905q.peek();
h.c(objPeek);
if (((d) objPeek).c() >= j4 || (dVar = (d) javaTimerManager.f6905q.poll()) == null) {
break;
}
if (this.f6914a == null) {
this.f6914a = Arguments.createArray();
}
WritableArray writableArray = this.f6914a;
if (writableArray != null) {
writableArray.pushInt(dVar.d());
}
if (dVar.b()) {
dVar.e(((long) dVar.a()) + j4);
javaTimerManager.f6905q.add(dVar);
} else {
javaTimerManager.f6896h.remove(dVar.d());
}
} catch (Throwable th) {
throw th;
}
}
r rVar = r.f10584a;
}
WritableArray writableArray2 = this.f6914a;
if (writableArray2 != null) {
JavaTimerManager.this.f6891c.callTimers(writableArray2);
this.f6914a = null;
}
JavaTimerManager.this.f6892d.k(b.a.f6926f, this);
}
}
}
public JavaTimerManager(ReactApplicationContext reactApplicationContext, B1.c cVar, com.facebook.react.modules.core.b bVar, k1.e eVar) {
h.f(reactApplicationContext, "reactApplicationContext");
h.f(cVar, "javaScriptTimerExecutor");
h.f(bVar, "reactChoreographer");
h.f(eVar, "devSupportManager");
this.f6890b = reactApplicationContext;
this.f6891c = cVar;
this.f6892d = bVar;
this.f6893e = eVar;
this.f6894f = new Object();
this.f6895g = new Object();
this.f6896h = new SparseArray();
this.f6897i = new AtomicBoolean(true);
this.f6898j = new AtomicBoolean(false);
this.f6899k = new e();
this.f6900l = new c();
final p pVar = new p() { // from class: com.facebook.react.modules.core.a
@Override // C2.p
public final Object b(Object obj, Object obj2) {
return Integer.valueOf(JavaTimerManager.B((JavaTimerManager.d) obj, (JavaTimerManager.d) obj2));
}
};
this.f6905q = new PriorityQueue(11, new Comparator() { // from class: B1.d
@Override // java.util.Comparator
public final int compare(Object obj, Object obj2) {
return JavaTimerManager.C(pVar, obj, obj2);
}
});
reactApplicationContext.addLifecycleEventListener(this);
C0742e.f10859g.a(reactApplicationContext).e(this);
}
/* JADX INFO: Access modifiers changed from: private */
public static final void A(JavaTimerManager javaTimerManager, boolean z3) {
synchronized (javaTimerManager.f6895g) {
try {
if (z3) {
javaTimerManager.z();
} else {
javaTimerManager.r();
}
r rVar = r.f10584a;
} catch (Throwable th) {
throw th;
}
}
}
/* JADX INFO: Access modifiers changed from: private */
public static final int B(d dVar, d dVar2) {
return F2.a.a(dVar.c() - dVar2.c());
}
/* JADX INFO: Access modifiers changed from: private */
public static final int C(p pVar, Object obj, Object obj2) {
return ((Number) pVar.b(obj, obj2)).intValue();
}
private final void r() {
if (this.f6903o) {
this.f6892d.n(b.a.f6927g, this.f6900l);
this.f6903o = false;
}
}
private final void s() {
C0742e c0742eA = C0742e.f10859g.a(this.f6890b);
if (this.f6902n && this.f6897i.get() && !c0742eA.h()) {
this.f6892d.n(b.a.f6926f, this.f6899k);
this.f6902n = false;
}
}
private final void v() {
if (!this.f6897i.get() || this.f6898j.get()) {
return;
}
s();
}
private final void w() {
synchronized (this.f6895g) {
try {
if (this.f6904p) {
z();
}
r rVar = r.f10584a;
} catch (Throwable th) {
throw th;
}
}
}
private final void y() {
if (this.f6902n) {
return;
}
this.f6892d.k(b.a.f6926f, this.f6899k);
this.f6902n = true;
}
private final void z() {
if (this.f6903o) {
return;
}
this.f6892d.k(b.a.f6927g, this.f6900l);
this.f6903o = true;
}
@Override // u1.InterfaceC0743f
public void a(int i3) {
if (this.f6898j.getAndSet(true)) {
return;
}
y();
w();
}
@Override // u1.InterfaceC0743f
public void b(int i3) {
if (C0742e.f10859g.a(this.f6890b).h()) {
return;
}
this.f6898j.set(false);
s();
v();
}
public void createTimer(int i3, long j3, boolean z3) {
d dVar = new d(i3, (l.b() / ((long) 1000000)) + j3, (int) j3, z3);
synchronized (this.f6894f) {
this.f6905q.add(dVar);
this.f6896h.put(i3, dVar);
r rVar = r.f10584a;
}
}
public void deleteTimer(int i3) {
synchronized (this.f6894f) {
d dVar = (d) this.f6896h.get(i3);
if (dVar == null) {
return;
}
this.f6896h.remove(i3);
this.f6905q.remove(dVar);
}
}
@Override // com.facebook.react.bridge.LifecycleEventListener
public void onHostDestroy() {
s();
v();
}
@Override // com.facebook.react.bridge.LifecycleEventListener
public void onHostPause() {
this.f6897i.set(true);
s();
v();
}
@Override // com.facebook.react.bridge.LifecycleEventListener
public void onHostResume() {
this.f6897i.set(false);
y();
w();
}
public void setSendIdleEvents(final boolean z3) {
synchronized (this.f6895g) {
this.f6904p = z3;
r rVar = r.f10584a;
}
UiThreadUtil.runOnUiThread(new Runnable() { // from class: B1.e
@Override // java.lang.Runnable
public final void run() {
JavaTimerManager.A(this.f82b, z3);
}
});
}
public void t(int i3, int i4, double d4, boolean z3) {
long jA = l.a();
long j3 = (long) d4;
if (this.f6893e.n() && Math.abs(j3 - jA) > 60000) {
this.f6891c.emitTimeDriftWarning("Debugger and device times have drifted by more than 60s. Please correct this by running adb shell \"date `date +%m%d%H%M%Y.%S`\" on your debugger machine.");
}
long jMax = Math.max(0L, (j3 - jA) + ((long) i4));
if (i4 != 0 || z3) {
createTimer(i3, jMax, z3);
return;
}
WritableArray writableArrayCreateArray = Arguments.createArray();
writableArrayCreateArray.pushInt(i3);
B1.c cVar = this.f6891c;
h.c(writableArrayCreateArray);
cVar.callTimers(writableArrayCreateArray);
}
public final boolean u(long j3) {
synchronized (this.f6894f) {
d dVar = (d) this.f6905q.peek();
if (dVar == null) {
return false;
}
if (f6889r.b(dVar, j3)) {
return true;
}
Iterator it = this.f6905q.iterator();
h.e(it, "iterator(...)");
while (it.hasNext()) {
d dVar2 = (d) it.next();
a aVar = f6889r;
h.c(dVar2);
if (aVar.b(dVar2, j3)) {
return true;
}
}
r rVar = r.f10584a;
return false;
}
}
public void x() {
C0742e.f10859g.a(this.f6890b).j(this);
this.f6890b.removeLifecycleEventListener(this);
s();
r();
}
}
⚠️ This content was hidden by an advertisement filtering extension in your browser. Please disable it and reload the page to access the decompiled content.
We only display one small text ad to keep this service free. Here's what it looks like:
Read the Docs for Business: You write the docs. We do the rest.
Try it today!Ad by EthicalAds