am eab12de7: Merge "Remove unnecessary globals."

* commit 'eab12de70efb649ab33f7971e948251895d613fe':
  Remove unnecessary globals.
This commit is contained in:
Elliott Hughes
2015-04-13 20:24:42 +00:00
committed by Android Git Automerger
4 changed files with 58 additions and 67 deletions
+5 -11
View File
@@ -39,11 +39,6 @@
static int char_width; static int char_width;
static int char_height; static int char_height;
// There's only (at most) one of these objects, and global callbacks
// (for pthread_create, and the input event system) need to find it,
// so use a global variable.
static ScreenRecoveryUI* self = nullptr;
// Return the current time as a double (including fractions of a second). // Return the current time as a double (including fractions of a second).
static double now() { static double now() {
struct timeval tv; struct timeval tv;
@@ -83,7 +78,6 @@ ScreenRecoveryUI::ScreenRecoveryUI() :
backgroundIcon[i] = nullptr; backgroundIcon[i] = nullptr;
} }
pthread_mutex_init(&updateMutex, nullptr); pthread_mutex_init(&updateMutex, nullptr);
self = this;
} }
// Clear the screen and draw the currently selected background icon (if any). // Clear the screen and draw the currently selected background icon (if any).
@@ -283,14 +277,14 @@ void ScreenRecoveryUI::update_progress_locked() {
} }
// Keeps the progress bar updated, even when the process is otherwise busy. // Keeps the progress bar updated, even when the process is otherwise busy.
void* ScreenRecoveryUI::progress_thread(void *cookie) { void* ScreenRecoveryUI::ProgressThreadStartRoutine(void* data) {
self->progress_loop(); reinterpret_cast<ScreenRecoveryUI*>(data)->ProgressThreadLoop();
return nullptr; return nullptr;
} }
void ScreenRecoveryUI::progress_loop() { void ScreenRecoveryUI::ProgressThreadLoop() {
double interval = 1.0 / animation_fps; double interval = 1.0 / animation_fps;
for (;;) { while (true) {
double start = now(); double start = now();
pthread_mutex_lock(&updateMutex); pthread_mutex_lock(&updateMutex);
@@ -387,7 +381,7 @@ void ScreenRecoveryUI::Init() {
LoadLocalizedBitmap("no_command_text", &backgroundText[NO_COMMAND]); LoadLocalizedBitmap("no_command_text", &backgroundText[NO_COMMAND]);
LoadLocalizedBitmap("error_text", &backgroundText[ERROR]); LoadLocalizedBitmap("error_text", &backgroundText[ERROR]);
pthread_create(&progress_t, nullptr, progress_thread, nullptr); pthread_create(&progress_thread_, nullptr, ProgressThreadStartRoutine, this);
RecoveryUI::Init(); RecoveryUI::Init();
} }
+4 -3
View File
@@ -98,7 +98,7 @@ class ScreenRecoveryUI : public RecoveryUI {
bool show_menu; bool show_menu;
int menu_top, menu_items, menu_sel; int menu_top, menu_items, menu_sel;
pthread_t progress_t; pthread_t progress_thread_;
int animation_fps; int animation_fps;
int installing_frames; int installing_frames;
@@ -112,8 +112,9 @@ class ScreenRecoveryUI : public RecoveryUI {
void draw_screen_locked(); void draw_screen_locked();
void update_screen_locked(); void update_screen_locked();
void update_progress_locked(); void update_progress_locked();
static void* progress_thread(void* cookie);
void progress_loop(); static void* ProgressThreadStartRoutine(void* data);
void ProgressThreadLoop();
void ShowFile(FILE*); void ShowFile(FILE*);
void PutChar(char); void PutChar(char);
+43 -48
View File
@@ -39,11 +39,6 @@
#define UI_WAIT_KEY_TIMEOUT_SEC 120 #define UI_WAIT_KEY_TIMEOUT_SEC 120
// There's only (at most) one of these objects, and global callbacks
// (for pthread_create, and the input event system) need to find it,
// so use a global variable.
static RecoveryUI* self = NULL;
RecoveryUI::RecoveryUI() RecoveryUI::RecoveryUI()
: key_queue_len(0), : key_queue_len(0),
key_last_down(-1), key_last_down(-1),
@@ -55,9 +50,8 @@ RecoveryUI::RecoveryUI()
has_power_key(false), has_power_key(false),
has_up_key(false), has_up_key(false),
has_down_key(false) { has_down_key(false) {
pthread_mutex_init(&key_queue_mutex, NULL); pthread_mutex_init(&key_queue_mutex, nullptr);
pthread_cond_init(&key_queue_cond, NULL); pthread_cond_init(&key_queue_cond, nullptr);
self = this;
memset(key_pressed, 0, sizeof(key_pressed)); memset(key_pressed, 0, sizeof(key_pressed));
} }
@@ -71,16 +65,29 @@ void RecoveryUI::OnKeyDetected(int key_code) {
} }
} }
void RecoveryUI::Init() { int RecoveryUI::InputCallback(int fd, uint32_t epevents, void* data) {
ev_init(input_callback, NULL); return reinterpret_cast<RecoveryUI*>(data)->OnInputEvent(fd, epevents);
using namespace std::placeholders;
ev_iterate_available_keys(std::bind(&RecoveryUI::OnKeyDetected, this, _1));
pthread_create(&input_t, NULL, input_thread, NULL);
} }
int RecoveryUI::input_callback(int fd, uint32_t epevents, void* data) { // Reads input events, handles special hot keys, and adds to the key queue.
static void* InputThreadLoop(void*) {
while (true) {
if (!ev_wait(-1)) {
ev_dispatch();
}
}
return nullptr;
}
void RecoveryUI::Init() {
ev_init(InputCallback, this);
ev_iterate_available_keys(std::bind(&RecoveryUI::OnKeyDetected, this, std::placeholders::_1));
pthread_create(&input_thread_, nullptr, InputThreadLoop, nullptr);
}
int RecoveryUI::OnInputEvent(int fd, uint32_t epevents) {
struct input_event ev; struct input_event ev;
if (ev_get_input(fd, epevents, &ev) == -1) { if (ev_get_input(fd, epevents, &ev) == -1) {
return -1; return -1;
@@ -94,23 +101,23 @@ int RecoveryUI::input_callback(int fd, uint32_t epevents, void* data) {
// the trackball. When it exceeds a threshold // the trackball. When it exceeds a threshold
// (positive or negative), fake an up/down // (positive or negative), fake an up/down
// key event. // key event.
self->rel_sum += ev.value; rel_sum += ev.value;
if (self->rel_sum > 3) { if (rel_sum > 3) {
self->process_key(KEY_DOWN, 1); // press down key ProcessKey(KEY_DOWN, 1); // press down key
self->process_key(KEY_DOWN, 0); // and release it ProcessKey(KEY_DOWN, 0); // and release it
self->rel_sum = 0; rel_sum = 0;
} else if (self->rel_sum < -3) { } else if (rel_sum < -3) {
self->process_key(KEY_UP, 1); // press up key ProcessKey(KEY_UP, 1); // press up key
self->process_key(KEY_UP, 0); // and release it ProcessKey(KEY_UP, 0); // and release it
self->rel_sum = 0; rel_sum = 0;
} }
} }
} else { } else {
self->rel_sum = 0; rel_sum = 0;
} }
if (ev.type == EV_KEY && ev.code <= KEY_MAX) { if (ev.type == EV_KEY && ev.code <= KEY_MAX) {
self->process_key(ev.code, ev.value); ProcessKey(ev.code, ev.value);
} }
return 0; return 0;
@@ -128,7 +135,7 @@ int RecoveryUI::input_callback(int fd, uint32_t epevents, void* data) {
// a key is registered. // a key is registered.
// //
// updown == 1 for key down events; 0 for key up events // updown == 1 for key down events; 0 for key up events
void RecoveryUI::process_key(int key_code, int updown) { void RecoveryUI::ProcessKey(int key_code, int updown) {
bool register_key = false; bool register_key = false;
bool long_press = false; bool long_press = false;
bool reboot_enabled; bool reboot_enabled;
@@ -139,13 +146,13 @@ void RecoveryUI::process_key(int key_code, int updown) {
++key_down_count; ++key_down_count;
key_last_down = key_code; key_last_down = key_code;
key_long_press = false; key_long_press = false;
pthread_t th;
key_timer_t* info = new key_timer_t; key_timer_t* info = new key_timer_t;
info->ui = this; info->ui = this;
info->key_code = key_code; info->key_code = key_code;
info->count = key_down_count; info->count = key_down_count;
pthread_create(&th, NULL, &RecoveryUI::time_key_helper, info); pthread_t thread;
pthread_detach(th); pthread_create(&thread, nullptr, &RecoveryUI::time_key_helper, info);
pthread_detach(thread);
} else { } else {
if (key_last_down == key_code) { if (key_last_down == key_code) {
long_press = key_long_press; long_press = key_long_press;
@@ -182,7 +189,7 @@ void* RecoveryUI::time_key_helper(void* cookie) {
key_timer_t* info = (key_timer_t*) cookie; key_timer_t* info = (key_timer_t*) cookie;
info->ui->time_key(info->key_code, info->count); info->ui->time_key(info->key_code, info->count);
delete info; delete info;
return NULL; return nullptr;
} }
void RecoveryUI::time_key(int key_code, int count) { void RecoveryUI::time_key(int key_code, int count) {
@@ -206,17 +213,6 @@ void RecoveryUI::EnqueueKey(int key_code) {
pthread_mutex_unlock(&key_queue_mutex); pthread_mutex_unlock(&key_queue_mutex);
} }
// Reads input events, handles special hot keys, and adds to the key queue.
void* RecoveryUI::input_thread(void* cookie) {
while (true) {
if (!ev_wait(-1)) {
ev_dispatch();
}
}
return NULL;
}
int RecoveryUI::WaitKey() { int RecoveryUI::WaitKey() {
pthread_mutex_lock(&key_queue_mutex); pthread_mutex_lock(&key_queue_mutex);
@@ -225,7 +221,7 @@ int RecoveryUI::WaitKey() {
do { do {
struct timeval now; struct timeval now;
struct timespec timeout; struct timespec timeout;
gettimeofday(&now, NULL); gettimeofday(&now, nullptr);
timeout.tv_sec = now.tv_sec; timeout.tv_sec = now.tv_sec;
timeout.tv_nsec = now.tv_usec * 1000; timeout.tv_nsec = now.tv_usec * 1000;
timeout.tv_sec += UI_WAIT_KEY_TIMEOUT_SEC; timeout.tv_sec += UI_WAIT_KEY_TIMEOUT_SEC;
@@ -234,7 +230,7 @@ int RecoveryUI::WaitKey() {
while (key_queue_len == 0 && rc != ETIMEDOUT) { while (key_queue_len == 0 && rc != ETIMEDOUT) {
rc = pthread_cond_timedwait(&key_queue_cond, &key_queue_mutex, &timeout); rc = pthread_cond_timedwait(&key_queue_cond, &key_queue_mutex, &timeout);
} }
} while (usb_connected() && key_queue_len == 0); } while (IsUsbConnected() && key_queue_len == 0);
int key = -1; int key = -1;
if (key_queue_len > 0) { if (key_queue_len > 0) {
@@ -245,8 +241,7 @@ int RecoveryUI::WaitKey() {
return key; return key;
} }
// Return true if USB is connected. bool RecoveryUI::IsUsbConnected() {
bool RecoveryUI::usb_connected() {
int fd = open("/sys/class/android_usb/android0/state", O_RDONLY); int fd = open("/sys/class/android_usb/android0/state", O_RDONLY);
if (fd < 0) { if (fd < 0) {
printf("failed to open /sys/class/android_usb/android0/state: %s\n", printf("failed to open /sys/class/android_usb/android0/state: %s\n",
@@ -255,7 +250,7 @@ bool RecoveryUI::usb_connected() {
} }
char buf; char buf;
/* USB is connected if android_usb state is CONNECTED or CONFIGURED */ // USB is connected if android_usb state is CONNECTED or CONFIGURED.
int connected = (read(fd, &buf, 1) == 1) && (buf == 'C'); int connected = (read(fd, &buf, 1) == 1) && (buf == 'C');
if (close(fd) < 0) { if (close(fd) < 0) {
printf("failed to close /sys/class/android_usb/android0/state: %s\n", printf("failed to close /sys/class/android_usb/android0/state: %s\n",
+6 -5
View File
@@ -147,14 +147,15 @@ private:
int count; int count;
}; };
pthread_t input_t; pthread_t input_thread_;
void OnKeyDetected(int key_code); void OnKeyDetected(int key_code);
static void* input_thread(void* cookie); static int InputCallback(int fd, uint32_t epevents, void* data);
static int input_callback(int fd, uint32_t epevents, void* data); int OnInputEvent(int fd, uint32_t epevents);
void process_key(int key_code, int updown); void ProcessKey(int key_code, int updown);
bool usb_connected();
bool IsUsbConnected();
static void* time_key_helper(void* cookie); static void* time_key_helper(void* cookie);
void time_key(int key_code, int count); void time_key(int key_code, int count);