LineageOS/android_development
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

am b2fa7700: DO NOT MERGE Modify Monkey so that scripts can use raw and user events.

Browse Source 
Merge commit 'b2fa770013cf1b6b8bf0619a946a54feafec5197' into eclair-plus-aosp

* commit 'b2fa770013cf1b6b8bf0619a946a54feafec5197':
  DO NOT MERGE Modify Monkey so that scripts can use raw and user events.
This commit is contained in:
Eric Rowe
2010-01-13 15:41:28 -08:00
committed by Android Git Automerger
parent 9edfe97598 b2fa770013
commit 8315bb4933
2 changed files with 212 additions and 202 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cmds/monkey/src/com/android/commands/monkey/MonkeySourceRandom.java
View File

@@ -285,7 +285,7 @@ public class MonkeySourceRandom implements MonkeyEventSource {
/** /**
* set the factors * set the factors
* *
* @param factors: percentages for each type of event * @param factors percentages for each type of event
*/ */
public void setFactors(float factors[]) { public void setFactors(float factors[]) {
int c = FACTORZ_COUNT; int c = FACTORZ_COUNT;

412
cmds/monkey/src/com/android/commands/monkey/MonkeySourceScript.java
View File

@@ -26,117 +26,131 @@ import java.io.FileInputStream;
import java.io.FileNotFoundException; import java.io.FileNotFoundException;
import java.io.IOException; import java.io.IOException;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.util.LinkedList;
import java.util.StringTokenizer;
import android.view.KeyEvent;
/** /**
* monkey event queue. It takes a script to produce events * monkey event queue. It takes a script to produce events sample script format:
* *
* sample script format: * <pre>
* type= raw events * type= raw events
* count= 10 * count= 10
* speed= 1.0 * speed= 1.0
* start data >> * start data &gt;&gt;
* captureDispatchPointer(5109520,5109520,0,230.75429,458.1814,0.20784314, * captureDispatchPointer(5109520,5109520,0,230.75429,458.1814,0.20784314,0.06666667,0,0.0,0.0,65539,0)
* 0.06666667,0,0.0,0.0,65539,0) * captureDispatchKey(5113146,5113146,0,20,0,0,0,0)
* captureDispatchKey(5113146,5113146,0,20,0,0,0,0) * captureDispatchFlip(true)
* captureDispatchFlip(true) * ...
* ... * </pre>
*/ */
public class MonkeySourceScript implements MonkeyEventSource { public class MonkeySourceScript implements MonkeyEventSource {
private int mEventCountInScript = 0; //total number of events in the file private int mEventCountInScript = 0; // total number of events in the file
private int mVerbose = 0; private int mVerbose = 0;
private double mSpeed = 1.0; private double mSpeed = 1.0;
private String mScriptFileName;
private String mScriptFileName;
private MonkeyEventQueue mQ; private MonkeyEventQueue mQ;
private static final String HEADER_TYPE = "type=";
private static final String HEADER_COUNT = "count="; private static final String HEADER_COUNT = "count=";
private static final String HEADER_SPEED = "speed="; private static final String HEADER_SPEED = "speed=";
// New script type
private static final String USER_EVENT_TYPE = "user"; private long mLastRecordedDownTimeKey = 0;
private long mLastRecordedDownTimeKey = 0;
private long mLastRecordedDownTimeMotion = 0; private long mLastRecordedDownTimeMotion = 0;
private long mLastExportDownTimeKey = 0; private long mLastExportDownTimeKey = 0;
private long mLastExportDownTimeMotion = 0; private long mLastExportDownTimeMotion = 0;
private long mLastExportEventTime = -1; private long mLastExportEventTime = -1;
private long mLastRecordedEventTime = -1; private long mLastRecordedEventTime = -1;
private String mScriptType = USER_EVENT_TYPE;
private static final boolean THIS_DEBUG = false; private static final boolean THIS_DEBUG = false;
// a parameter that compensates the difference of real elapsed time and
// a parameter that compensates the difference of real elapsed time and
// time in theory // time in theory
private static final long SLEEP_COMPENSATE_DIFF = 16; private static final long SLEEP_COMPENSATE_DIFF = 16;
// maximum number of events that we read at one time // maximum number of events that we read at one time
private static final int MAX_ONE_TIME_READS = 100; private static final int MAX_ONE_TIME_READS = 100;
// number of additional events added to the script
// add HOME_KEY down and up events to make start UI consistent in each round
private static final int POLICY_ADDITIONAL_EVENT_COUNT = 2;
// event key word in the capture log // number of additional events added to the script
// add HOME_KEY down and up events to make start UI consistent in each round
private static final int POLICY_ADDITIONAL_EVENT_COUNT = 0;
// event key word in the capture log
private static final String EVENT_KEYWORD_POINTER = "DispatchPointer"; private static final String EVENT_KEYWORD_POINTER = "DispatchPointer";
private static final String EVENT_KEYWORD_TRACKBALL = "DispatchTrackball"; private static final String EVENT_KEYWORD_TRACKBALL = "DispatchTrackball";
private static final String EVENT_KEYWORD_KEY = "DispatchKey"; private static final String EVENT_KEYWORD_KEY = "DispatchKey";
private static final String EVENT_KEYWORD_FLIP = "DispatchFlip"; private static final String EVENT_KEYWORD_FLIP = "DispatchFlip";
private static final String EVENT_KEYWORD_KEYPRESS = "DispatchPress"; private static final String EVENT_KEYWORD_KEYPRESS = "DispatchPress";
private static final String EVENT_KEYWORD_ACTIVITY = "LaunchActivity"; private static final String EVENT_KEYWORD_ACTIVITY = "LaunchActivity";
private static final String EVENT_KEYWORD_WAIT = "UserWait"; private static final String EVENT_KEYWORD_WAIT = "UserWait";
private static final String EVENT_KEYWORD_LONGPRESS = "LongPress"; private static final String EVENT_KEYWORD_LONGPRESS = "LongPress";
// a line at the end of the header // a line at the end of the header
private static final String STARTING_DATA_LINE = "start data >>"; private static final String STARTING_DATA_LINE = "start data >>";
private boolean mFileOpened = false;
private static int LONGPRESS_WAIT_TIME = 2000; // wait time for the long press private boolean mFileOpened = false;
private static int LONGPRESS_WAIT_TIME = 2000; // wait time for the long
// press
FileInputStream mFStream; FileInputStream mFStream;
DataInputStream mInputStream; DataInputStream mInputStream;
BufferedReader mBufferReader; BufferedReader mBufferReader;
public MonkeySourceScript(String filename, long throttle) { public MonkeySourceScript(String filename, long throttle) {
mScriptFileName = filename; mScriptFileName = filename;
mQ = new MonkeyEventQueue(throttle); mQ = new MonkeyEventQueue(throttle);
} }
/** /**
* * @return the number of total events that will be generated in a round
* @return the number of total events that will be generated in a round
*/ */
public int getOneRoundEventCount() { public int getOneRoundEventCount() {
//plus one home key down and up event // plus one home key down and up event
return mEventCountInScript + POLICY_ADDITIONAL_EVENT_COUNT; return mEventCountInScript + POLICY_ADDITIONAL_EVENT_COUNT;
} }
private void resetValue() { private void resetValue() {
mLastRecordedDownTimeKey = 0; mLastRecordedDownTimeKey = 0;
mLastRecordedDownTimeMotion = 0; mLastRecordedDownTimeMotion = 0;
mLastExportDownTimeKey = 0; mLastExportDownTimeKey = 0;
mLastExportDownTimeMotion = 0; mLastExportDownTimeMotion = 0;
mLastRecordedEventTime = -1; mLastRecordedEventTime = -1;
mLastExportEventTime = -1; mLastExportEventTime = -1;
} }
private boolean readScriptHeader() { private boolean readScriptHeader() {
mEventCountInScript = -1; mEventCountInScript = -1;
mFileOpened = false; mFileOpened = false;
try { try {
if (THIS_DEBUG) { if (THIS_DEBUG) {
System.out.println("reading script header"); System.out.println("reading script header");
} }
mFStream = new FileInputStream(mScriptFileName); mFStream = new FileInputStream(mScriptFileName);
mInputStream = new DataInputStream(mFStream); mInputStream = new DataInputStream(mFStream);
mBufferReader = new BufferedReader( mBufferReader = new BufferedReader(new InputStreamReader(mInputStream));
new InputStreamReader(mInputStream));
String sLine; String sLine;
while ((sLine = mBufferReader.readLine()) != null) { while ((sLine = mBufferReader.readLine()) != null) {
sLine = sLine.trim(); sLine = sLine.trim();
if (sLine.indexOf(HEADER_TYPE) >= 0) {
mScriptType = sLine.substring(HEADER_TYPE.length() + 1).trim(); if (sLine.indexOf(HEADER_COUNT) >= 0) {
} else if (sLine.indexOf(HEADER_COUNT) >= 0) {
try { try {
mEventCountInScript = Integer.parseInt(sLine.substring( mEventCountInScript = Integer.parseInt(sLine.substring(
HEADER_COUNT.length() + 1).trim()); HEADER_COUNT.length() + 1).trim());
@@ -145,9 +159,9 @@ public class MonkeySourceScript implements MonkeyEventSource {
} }
} else if (sLine.indexOf(HEADER_SPEED) >= 0) { } else if (sLine.indexOf(HEADER_SPEED) >= 0) {
try { try {
mSpeed = Double.parseDouble(sLine.substring( mSpeed = Double.parseDouble(sLine.substring(HEADER_SPEED.length() + 1)
HEADER_SPEED.length() + 1).trim()); .trim());
} catch (NumberFormatException e) { } catch (NumberFormatException e) {
System.err.println(e); System.err.println(e);
} }
@@ -156,112 +170,123 @@ public class MonkeySourceScript implements MonkeyEventSource {
mFileOpened = true; mFileOpened = true;
if (THIS_DEBUG) { if (THIS_DEBUG) {
System.out.println("read script header success"); System.out.println("read script header success");
} }
return true; return true;
} }
} }
} catch (FileNotFoundException e) { } catch (FileNotFoundException e) {
System.err.println(e); System.err.println(e);
} catch (IOException e) { } catch (IOException e) {
System.err.println(e); System.err.println(e);
} }
if (THIS_DEBUG) { if (THIS_DEBUG) {
System.out.println("Error in reading script header"); System.out.println("Error in reading script header");
} }
return false; return false;
} }
private void handleRawEvent(String s, StringTokenizer st) { private void handleEvent(String s, String[] args) {
if (s.indexOf(EVENT_KEYWORD_KEY) >= 0) { // Handle key event
// key events if (s.indexOf(EVENT_KEYWORD_KEY) >= 0 && args.length == 8) {
try { try {
System.out.println(" old key\n"); System.out.println(" old key\n");
long downTime = Long.parseLong(st.nextToken()); long downTime = Long.parseLong(args[0]);
long eventTime = Long.parseLong(st.nextToken()); long eventTime = Long.parseLong(args[1]);
int action = Integer.parseInt(st.nextToken()); int action = Integer.parseInt(args[2]);
int code = Integer.parseInt(st.nextToken()); int code = Integer.parseInt(args[3]);
int repeat = Integer.parseInt(st.nextToken()); int repeat = Integer.parseInt(args[4]);
int metaState = Integer.parseInt(st.nextToken()); int metaState = Integer.parseInt(args[5]);
int device = Integer.parseInt(st.nextToken()); int device = Integer.parseInt(args[6]);
int scancode = Integer.parseInt(st.nextToken()); int scancode = Integer.parseInt(args[7]);
MonkeyKeyEvent e = MonkeyKeyEvent e = new MonkeyKeyEvent(downTime, eventTime, action, code, repeat,
new MonkeyKeyEvent(downTime, eventTime, action, code, repeat, metaState, metaState, device, scancode);
device, scancode);
System.out.println(" Key code " + code + "\n"); System.out.println(" Key code " + code + "\n");
mQ.addLast(e); mQ.addLast(e);
System.out.println("Added key up \n"); System.out.println("Added key up \n");
} catch (NumberFormatException e) { } catch (NumberFormatException e) {
// something wrong with this line in the script
} }
} else if (s.indexOf(EVENT_KEYWORD_POINTER) >= 0 || return;
s.indexOf(EVENT_KEYWORD_TRACKBALL) >= 0) { }
// trackball/pointer event
// Handle trackball or pointer events
if ((s.indexOf(EVENT_KEYWORD_POINTER) >= 0 || s.indexOf(EVENT_KEYWORD_TRACKBALL) >= 0)
&& args.length == 12) {
try { try {
long downTime = Long.parseLong(st.nextToken()); long downTime = Long.parseLong(args[0]);
long eventTime = Long.parseLong(st.nextToken()); long eventTime = Long.parseLong(args[1]);
int action = Integer.parseInt(st.nextToken()); int action = Integer.parseInt(args[2]);
float x = Float.parseFloat(st.nextToken()); float x = Float.parseFloat(args[3]);
float y = Float.parseFloat(st.nextToken()); float y = Float.parseFloat(args[4]);
float pressure = Float.parseFloat(st.nextToken()); float pressure = Float.parseFloat(args[5]);
float size = Float.parseFloat(st.nextToken()); float size = Float.parseFloat(args[6]);
int metaState = Integer.parseInt(st.nextToken()); int metaState = Integer.parseInt(args[7]);
float xPrecision = Float.parseFloat(st.nextToken()); float xPrecision = Float.parseFloat(args[8]);
float yPrecision = Float.parseFloat(st.nextToken()); float yPrecision = Float.parseFloat(args[9]);
int device = Integer.parseInt(st.nextToken()); int device = Integer.parseInt(args[10]);
int edgeFlags = Integer.parseInt(st.nextToken()); int edgeFlags = Integer.parseInt(args[11]);
int type = MonkeyEvent.EVENT_TYPE_TRACKBALL; int type = MonkeyEvent.EVENT_TYPE_TRACKBALL;
if (s.indexOf("Pointer") > 0) { if (s.indexOf("Pointer") > 0) {
type = MonkeyEvent.EVENT_TYPE_POINTER; type = MonkeyEvent.EVENT_TYPE_POINTER;
} }
MonkeyMotionEvent e = MonkeyMotionEvent e = new MonkeyMotionEvent(type, downTime, eventTime, action, x,
new MonkeyMotionEvent(type, downTime, eventTime, action, x, y, pressure, y, pressure, size, metaState, xPrecision, yPrecision, device, edgeFlags);
size, metaState, xPrecision, yPrecision, device, edgeFlags);
mQ.addLast(e); mQ.addLast(e);
} catch (NumberFormatException e) { } catch (NumberFormatException e) {
// we ignore this event
} }
} else if (s.indexOf(EVENT_KEYWORD_FLIP) >= 0) { return;
boolean keyboardOpen = Boolean.parseBoolean(st.nextToken()); }
// Handle flip events
if (s.indexOf(EVENT_KEYWORD_FLIP) >= 0 && args.length == 1) {
boolean keyboardOpen = Boolean.parseBoolean(args[0]);
MonkeyFlipEvent e = new MonkeyFlipEvent(keyboardOpen); MonkeyFlipEvent e = new MonkeyFlipEvent(keyboardOpen);
mQ.addLast(e); mQ.addLast(e);
} }
} // Handle launch events
if (s.indexOf(EVENT_KEYWORD_ACTIVITY) >= 0 && args.length == 2) {
private void handleUserEvent(String s, StringTokenizer st) { String pkg_name = args[0];
if (s.indexOf(EVENT_KEYWORD_ACTIVITY) >= 0) { String cl_name = args[1];
String pkg_name = st.nextToken();
String cl_name = st.nextToken();
ComponentName mApp = new ComponentName(pkg_name, cl_name); ComponentName mApp = new ComponentName(pkg_name, cl_name);
MonkeyActivityEvent e = new MonkeyActivityEvent(mApp); MonkeyActivityEvent e = new MonkeyActivityEvent(mApp);
mQ.addLast(e); mQ.addLast(e);
return;
}
} else if (s.indexOf(EVENT_KEYWORD_WAIT) >= 0) { // Handle wait events
long sleeptime = Integer.parseInt(st.nextToken()); if (s.indexOf(EVENT_KEYWORD_WAIT) >= 0 && args.length == 1) {
MonkeyWaitEvent e = new MonkeyWaitEvent(sleeptime); try {
mQ.addLast(e); long sleeptime = Integer.parseInt(args[0]);
MonkeyWaitEvent e = new MonkeyWaitEvent(sleeptime);
mQ.addLast(e);
} catch (NumberFormatException e) {
}
return;
}
} else if (s.indexOf(EVENT_KEYWORD_KEYPRESS) >= 0) { // Handle keypress events
String key_name = st.nextToken(); if (s.indexOf(EVENT_KEYWORD_KEYPRESS) >= 0 && args.length == 1) {
String key_name = args[0];
int keyCode = MonkeySourceRandom.getKeyCode(key_name); int keyCode = MonkeySourceRandom.getKeyCode(key_name);
MonkeyKeyEvent e = new MonkeyKeyEvent(KeyEvent.ACTION_DOWN, keyCode); MonkeyKeyEvent e = new MonkeyKeyEvent(KeyEvent.ACTION_DOWN, keyCode);
mQ.addLast(e); mQ.addLast(e);
e = new MonkeyKeyEvent(KeyEvent.ACTION_UP, keyCode); e = new MonkeyKeyEvent(KeyEvent.ACTION_UP, keyCode);
mQ.addLast(e); mQ.addLast(e);
} else if (s.indexOf(EVENT_KEYWORD_LONGPRESS) >= 0) { return;
// handle the long press }
MonkeyKeyEvent e = new MonkeyKeyEvent(KeyEvent.ACTION_DOWN,
KeyEvent.KEYCODE_DPAD_CENTER); // Handle longpress events
if (s.indexOf(EVENT_KEYWORD_LONGPRESS) >= 0) {
MonkeyKeyEvent e;
e = new MonkeyKeyEvent(KeyEvent.ACTION_DOWN, KeyEvent.KEYCODE_DPAD_CENTER);
mQ.addLast(e); mQ.addLast(e);
MonkeyWaitEvent we = new MonkeyWaitEvent(LONGPRESS_WAIT_TIME); MonkeyWaitEvent we = new MonkeyWaitEvent(LONGPRESS_WAIT_TIME);
mQ.addLast(we); mQ.addLast(we);
e = new MonkeyKeyEvent(KeyEvent.ACTION_UP, e = new MonkeyKeyEvent(KeyEvent.ACTION_UP, KeyEvent.KEYCODE_DPAD_CENTER);
KeyEvent.KEYCODE_DPAD_CENTER);
mQ.addLast(e); mQ.addLast(e);
} }
} }
@@ -274,23 +299,17 @@ public class MonkeySourceScript implements MonkeyEventSource {
return; return;
} }
StringTokenizer st = new StringTokenizer( String[] args = s.substring(index1 + 1, index2).split(",");
s.substring(index1 + 1, index2), ",");
if (mScriptType.compareTo(USER_EVENT_TYPE) == 0) { handleEvent(s, args);
// User event type
handleUserEvent(s, st);
} else {
// Raw type
handleRawEvent(s,st);
}
} }
private void closeFile() { private void closeFile() {
mFileOpened = false; mFileOpened = false;
if (THIS_DEBUG) { if (THIS_DEBUG) {
System.out.println("closing script file"); System.out.println("closing script file");
} }
try { try {
mFStream.close(); mFStream.close();
mInputStream.close(); mInputStream.close();
@@ -298,20 +317,10 @@ public class MonkeySourceScript implements MonkeyEventSource {
System.out.println(e); System.out.println(e);
} }
} }
/** /**
* add home key press/release event to the queue * read next batch of events from the provided script file
*/ *
private void addHomeKeyEvent() {
MonkeyKeyEvent e = new MonkeyKeyEvent(KeyEvent.ACTION_DOWN,
KeyEvent.KEYCODE_HOME);
mQ.addLast(e);
e = new MonkeyKeyEvent(KeyEvent.ACTION_UP, KeyEvent.KEYCODE_HOME);
mQ.addLast(e);
}
/**
* read next batch of events from the provided script file
* @return true if success * @return true if success
*/ */
private boolean readNextBatch() { private boolean readNextBatch() {
@@ -333,149 +342,150 @@ public class MonkeySourceScript implements MonkeyEventSource {
} }
resetValue(); resetValue();
} }
try { try {
while (readCount++ < MAX_ONE_TIME_READS && while (readCount++ < MAX_ONE_TIME_READS && (sLine = mBufferReader.readLine()) != null) {
(sLine = mBufferReader.readLine()) != null) { sLine = sLine.trim();
sLine = sLine.trim();
processLine(sLine); processLine(sLine);
} }
} catch (IOException e) { } catch (IOException e) {
System.err.println(e); System.err.println(e);
return false; return false;
} }
if (sLine == null) { if (sLine == null) {
// to the end of the file // to the end of the file
if (THIS_DEBUG) { if (THIS_DEBUG) {
System.out.println("readNextBatch(): to the end of file"); System.out.println("readNextBatch(): to the end of file");
} }
closeFile(); closeFile();
} }
return true; return true;
} }
/** /**
* sleep for a period of given time, introducing latency among events * sleep for a period of given time, introducing latency among events
*
* @param time to sleep in millisecond * @param time to sleep in millisecond
*/ */
private void needSleep(long time) { private void needSleep(long time) {
if (time < 1) { if (time < 1) {
return; return;
} }
try { try {
Thread.sleep(time); Thread.sleep(time);
} catch (InterruptedException e) { } catch (InterruptedException e) {
} }
} }
/** /**
* check whether we can successfully read the header of the script file * check whether we can successfully read the header of the script file
*/ */
public boolean validate() { public boolean validate() {
boolean b = readNextBatch(); boolean b = readNextBatch();
if (mVerbose > 0) { if (mVerbose > 0) {
System.out.println("Replaying " + mEventCountInScript + System.out.println("Replaying " + mEventCountInScript + " events with speed " + mSpeed);
" events with speed " + mSpeed);
} }
return b; return b;
} }
public void setVerbose(int verbose) { public void setVerbose(int verbose) {
mVerbose = verbose; mVerbose = verbose;
} }
/** /**
* adjust key downtime and eventtime according to both * adjust key downtime and eventtime according to both recorded values and
* recorded values and current system time * current system time
*
* @param e KeyEvent * @param e KeyEvent
*/ */
private void adjustKeyEventTime(MonkeyKeyEvent e) { private void adjustKeyEventTime(MonkeyKeyEvent e) {
if (e.getEventTime() < 0) { if (e.getEventTime() < 0) {
return; return;
} }
long thisDownTime = 0; long thisDownTime = 0;
long thisEventTime = 0; long thisEventTime = 0;
long expectedDelay = 0; long expectedDelay = 0;
if (mLastRecordedEventTime <= 0) { if (mLastRecordedEventTime <= 0) {
// first time event // first time event
thisDownTime = SystemClock.uptimeMillis(); thisDownTime = SystemClock.uptimeMillis();
thisEventTime = thisDownTime; thisEventTime = thisDownTime;
} else { } else {
if (e.getDownTime() != mLastRecordedDownTimeKey) { if (e.getDownTime() != mLastRecordedDownTimeKey) {
thisDownTime = e.getDownTime(); thisDownTime = e.getDownTime();
} else { } else {
thisDownTime = mLastExportDownTimeKey; thisDownTime = mLastExportDownTimeKey;
} }
expectedDelay = (long) ((e.getEventTime() - expectedDelay = (long) ((e.getEventTime() - mLastRecordedEventTime) * mSpeed);
mLastRecordedEventTime) * mSpeed);
thisEventTime = mLastExportEventTime + expectedDelay; thisEventTime = mLastExportEventTime + expectedDelay;
// add sleep to simulate everything in recording // add sleep to simulate everything in recording
needSleep(expectedDelay - SLEEP_COMPENSATE_DIFF); needSleep(expectedDelay - SLEEP_COMPENSATE_DIFF);
} }
mLastRecordedDownTimeKey = e.getDownTime(); mLastRecordedDownTimeKey = e.getDownTime();
mLastRecordedEventTime = e.getEventTime(); mLastRecordedEventTime = e.getEventTime();
e.setDownTime(thisDownTime); e.setDownTime(thisDownTime);
e.setEventTime(thisEventTime); e.setEventTime(thisEventTime);
mLastExportDownTimeKey = thisDownTime; mLastExportDownTimeKey = thisDownTime;
mLastExportEventTime = thisEventTime; mLastExportEventTime = thisEventTime;
} }
/** /**
* adjust motion downtime and eventtime according to both * adjust motion downtime and eventtime according to both recorded values
* recorded values and current system time * and current system time
*
* @param e KeyEvent * @param e KeyEvent
*/ */
private void adjustMotionEventTime(MonkeyMotionEvent e) { private void adjustMotionEventTime(MonkeyMotionEvent e) {
if (e.getEventTime() < 0) { if (e.getEventTime() < 0) {
return; return;
} }
long thisDownTime = 0; long thisDownTime = 0;
long thisEventTime = 0; long thisEventTime = 0;
long expectedDelay = 0; long expectedDelay = 0;
if (mLastRecordedEventTime <= 0) { if (mLastRecordedEventTime <= 0) {
// first time event // first time event
thisDownTime = SystemClock.uptimeMillis(); thisDownTime = SystemClock.uptimeMillis();
thisEventTime = thisDownTime; thisEventTime = thisDownTime;
} else { } else {
if (e.getDownTime() != mLastRecordedDownTimeMotion) { if (e.getDownTime() != mLastRecordedDownTimeMotion) {
thisDownTime = e.getDownTime(); thisDownTime = e.getDownTime();
} else { } else {
thisDownTime = mLastExportDownTimeMotion; thisDownTime = mLastExportDownTimeMotion;
} }
expectedDelay = (long) ((e.getEventTime() - expectedDelay = (long) ((e.getEventTime() - mLastRecordedEventTime) * mSpeed);
mLastRecordedEventTime) * mSpeed);
thisEventTime = mLastExportEventTime + expectedDelay; thisEventTime = mLastExportEventTime + expectedDelay;
// add sleep to simulate everything in recording // add sleep to simulate everything in recording
needSleep(expectedDelay - SLEEP_COMPENSATE_DIFF); needSleep(expectedDelay - SLEEP_COMPENSATE_DIFF);
} }
mLastRecordedDownTimeMotion = e.getDownTime(); mLastRecordedDownTimeMotion = e.getDownTime();
mLastRecordedEventTime = e.getEventTime(); mLastRecordedEventTime = e.getEventTime();
e.setDownTime(thisDownTime); e.setDownTime(thisDownTime);
e.setEventTime(thisEventTime); e.setEventTime(thisEventTime);
mLastExportDownTimeMotion = thisDownTime; mLastExportDownTimeMotion = thisDownTime;
mLastExportEventTime = thisEventTime; mLastExportEventTime = thisEventTime;
} }
/** /**
* if the queue is empty, we generate events first * if the queue is empty, we generate events first
* @return the first event in the queue, if null, indicating the system crashes *
* @return the first event in the queue, if null, indicating the system
* crashes
*/ */
public MonkeyEvent getNextEvent() { public MonkeyEvent getNextEvent() {
long recordedEventTime = -1; long recordedEventTime = -1;
if (mQ.isEmpty()) { if (mQ.isEmpty()) {
readNextBatch(); readNextBatch();
} }
MonkeyEvent e = mQ.getFirst(); MonkeyEvent e = mQ.getFirst();
mQ.removeFirst(); mQ.removeFirst();
if (e.getEventType() == MonkeyEvent.EVENT_TYPE_KEY) { if (e.getEventType() == MonkeyEvent.EVENT_TYPE_KEY) {
adjustKeyEventTime((MonkeyKeyEvent) e); adjustKeyEventTime((MonkeyKeyEvent) e);
} else if (e.getEventType() == MonkeyEvent.EVENT_TYPE_POINTER || } else if (e.getEventType() == MonkeyEvent.EVENT_TYPE_POINTER
e.getEventType() == MonkeyEvent.EVENT_TYPE_TRACKBALL) { || e.getEventType() == MonkeyEvent.EVENT_TYPE_TRACKBALL) {
adjustMotionEventTime((MonkeyMotionEvent) e); adjustMotionEventTime((MonkeyMotionEvent) e);
} }
return e; return e;