package android.view;
import android.os.Looper;
import android.os.MessageQueue;
import android.util.LongSparseArray;
import android.util.Pools.Pool;
import android.util.Pools.SimplePool;
import dalvik.system.CloseGuard;
import java.lang.ref.WeakReference;
public final class InputQueue {
private final LongSparseArray<ActiveInputEvent> mActiveEventArray =
new LongSparseArray<ActiveInputEvent>(20);
private final Pool<ActiveInputEvent> mActiveInputEventPool =
new SimplePool<ActiveInputEvent>(20);
private final CloseGuard mCloseGuard = CloseGuard.get();
private long mPtr;
private static native long nativeInit(WeakReference<InputQueue> weakQueue,
MessageQueue messageQueue);
private static native long nativeSendKeyEvent(long ptr, KeyEvent e, boolean preDispatch);
private static native long nativeSendMotionEvent(long ptr, MotionEvent e);
private static native void nativeDispose(long ptr);
public InputQueue() {
mPtr = nativeInit(new WeakReference<InputQueue>(this), Looper.myQueue());
mCloseGuard.open("dispose");
}
@Override
protected void finalize() throws Throwable {
try {
dispose(true);
} finally {
super.finalize();
}
}
public void dispose() {
dispose(false);
}
public void dispose(boolean finalized) {
if (mCloseGuard != null) {
if (finalized) {
mCloseGuard.warnIfOpen();
}
mCloseGuard.close();
}
if (mPtr != 0) {
nativeDispose(mPtr);
mPtr = 0;
}
}
public long getNativePtr() {
return mPtr;
}
public void sendInputEvent(InputEvent e, Object token, boolean predispatch,
FinishedInputEventCallback callback) {
ActiveInputEvent event = obtainActiveInputEvent(token, callback);
long id;
if (e instanceof KeyEvent) {
id = nativeSendKeyEvent(mPtr, (KeyEvent) e, predispatch);
} else {
id = nativeSendMotionEvent(mPtr, (MotionEvent) e);
}
mActiveEventArray.put(id, event);
}
private void finishInputEvent(long id, boolean handled) {
int index = mActiveEventArray.indexOfKey(id);
if (index >= 0) {
ActiveInputEvent e = mActiveEventArray.valueAt(index);
mActiveEventArray.removeAt(index);
e.mCallback.onFinishedInputEvent(e.mToken, handled);
recycleActiveInputEvent(e);
}
}
private ActiveInputEvent obtainActiveInputEvent(Object token,
FinishedInputEventCallback callback) {
ActiveInputEvent e = mActiveInputEventPool.acquire();
if (e == null) {
e = new ActiveInputEvent();
}
e.mToken = token;
e.mCallback = callback;
return e;
}
private void recycleActiveInputEvent(ActiveInputEvent e) {
e.recycle();
mActiveInputEventPool.release(e);
}
private final class ActiveInputEvent {
public Object mToken;
public FinishedInputEventCallback mCallback;
public void recycle() {
mToken = null;
mCallback = null;
}
}
public static interface Callback {
void onInputQueueCreated(InputQueue queue);
void onInputQueueDestroyed(InputQueue queue);
}
public static interface FinishedInputEventCallback {
void onFinishedInputEvent(Object token, boolean handled);
}
}