69 lines
2.1 KiB
Java
69 lines
2.1 KiB
Java
package o;
|
|
|
|
import android.os.Handler;
|
|
import android.os.Looper;
|
|
import android.os.Message;
|
|
import android.os.SystemClock;
|
|
import org.greenrobot.eventbus.EventBusException;
|
|
|
|
/* renamed from: o.gmo, reason: case insensitive filesystem */
|
|
/* loaded from: classes.dex */
|
|
public final class HandlerC15300gmo extends Handler implements InterfaceC15303gmr {
|
|
private final int a;
|
|
private final C15301gmp c;
|
|
private boolean d;
|
|
private final C15296gmk e;
|
|
|
|
public HandlerC15300gmo(C15296gmk c15296gmk, Looper looper) {
|
|
super(looper);
|
|
this.e = c15296gmk;
|
|
this.a = 10;
|
|
this.c = new C15301gmp();
|
|
}
|
|
|
|
@Override // o.InterfaceC15303gmr
|
|
public final void a(C15310gmy c15310gmy, Object obj) {
|
|
C15302gmq c = C15302gmq.c(c15310gmy, obj);
|
|
synchronized (this) {
|
|
this.c.a(c);
|
|
if (!this.d) {
|
|
this.d = true;
|
|
if (!sendMessage(obtainMessage())) {
|
|
throw new EventBusException("Could not send handler message");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // android.os.Handler
|
|
public final void handleMessage(Message message) {
|
|
try {
|
|
long uptimeMillis = SystemClock.uptimeMillis();
|
|
do {
|
|
C15302gmq e = this.c.e();
|
|
if (e == null) {
|
|
synchronized (this) {
|
|
e = this.c.e();
|
|
if (e == null) {
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
C15296gmk c15296gmk = this.e;
|
|
Object obj = e.e;
|
|
C15310gmy c15310gmy = e.b;
|
|
C15302gmq.c(e);
|
|
if (c15310gmy.d) {
|
|
c15296gmk.a(c15310gmy, obj);
|
|
}
|
|
} while (SystemClock.uptimeMillis() - uptimeMillis < this.a);
|
|
if (!sendMessage(obtainMessage())) {
|
|
throw new EventBusException("Could not send handler message");
|
|
}
|
|
this.d = true;
|
|
} finally {
|
|
this.d = false;
|
|
}
|
|
}
|
|
}
|