| Index: third_party/android_crazy_linker/src/tests/test_load_library_callbacks.cpp
|
| diff --git a/third_party/android_crazy_linker/src/tests/test_load_library_callbacks.cpp b/third_party/android_crazy_linker/src/tests/test_load_library_callbacks.cpp
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..9281efe2ff091ca1548abcbc7096ce49f4d4bbb0
|
| --- /dev/null
|
| +++ b/third_party/android_crazy_linker/src/tests/test_load_library_callbacks.cpp
|
| @@ -0,0 +1,158 @@
|
| +// Copyright 2014 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +// A crazy linker test to test callbacks for delayed execution.
|
| +
|
| +#include <pthread.h>
|
| +#include <stdio.h>
|
| +#include <crazy_linker.h>
|
| +
|
| +#include "test_util.h"
|
| +
|
| +namespace {
|
| +
|
| +typedef void (*FunctionPtr)();
|
| +
|
| +// Data block passed between callback poster and callback handler.
|
| +class CallbackData {
|
| + public:
|
| + CallbackData() {
|
| + callback_.handler = NULL;
|
| + callback_.opaque = NULL;
|
| + pthread_mutex_init(&mutex_, NULL);
|
| + pthread_cond_init(&cond_, NULL);
|
| + }
|
| +
|
| + crazy_callback_t callback_;
|
| + pthread_mutex_t mutex_;
|
| + pthread_cond_t cond_;
|
| +};
|
| +
|
| +bool PostCallback(crazy_callback_t* callback, void* poster_opaque) {
|
| + printf("Post callback, poster_opaque %p, handler %p, opaque %p\n",
|
| + poster_opaque,
|
| + callback->handler,
|
| + callback->opaque);
|
| +
|
| + CallbackData* callback_data = reinterpret_cast<CallbackData*>(poster_opaque);
|
| +
|
| + // Set callback_ and signal the arrival of the PostCallback() call.
|
| + pthread_mutex_lock(&callback_data->mutex_);
|
| + callback_data->callback_ = *callback;
|
| + pthread_cond_signal(&callback_data->cond_);
|
| + pthread_mutex_unlock(&callback_data->mutex_);
|
| +
|
| + return true;
|
| +}
|
| +
|
| +void CheckAndRunCallback(CallbackData* callback_data) {
|
| + printf("Run callback, callback_data %p\n", callback_data);
|
| +
|
| + if (!callback_data->callback_.handler) {
|
| + Panic("Post for delayed execution not invoked\n");
|
| + }
|
| +
|
| + // Run the callback, then clear it.
|
| + crazy_callback_run(&callback_data->callback_);
|
| + callback_data->callback_.handler = NULL;
|
| + callback_data->callback_.opaque = NULL;
|
| +}
|
| +
|
| +struct ThreadData {
|
| + crazy_library_t* library;
|
| + crazy_context_t* context;
|
| +};
|
| +
|
| +void* ThreadBody(void *thread_arg) {
|
| + const ThreadData* thread_data = reinterpret_cast<ThreadData*>(thread_arg);
|
| +
|
| + // Close the library, asynchronously.
|
| + crazy_library_close_with_context(thread_data->library, thread_data->context);
|
| + pthread_exit(NULL);
|
| +}
|
| +
|
| +pthread_t AsyncCrazyLibraryCloseWithContext(crazy_library_t* library,
|
| + crazy_context_t* context,
|
| + CallbackData* callback_data) {
|
| + printf("Async close, library %p, context %p\n", library, context);
|
| +
|
| + ThreadData thread_data = {library, context};
|
| + void* thread_arg = reinterpret_cast<void*>(&thread_data);
|
| +
|
| + // Clear the indication that the new thread has called PostCallback().
|
| + pthread_mutex_lock(&callback_data->mutex_);
|
| + callback_data->callback_.handler = NULL;
|
| + callback_data->callback_.opaque = NULL;
|
| + pthread_mutex_unlock(&callback_data->mutex_);
|
| +
|
| + // Start the thread that closes the library.
|
| + pthread_t thread;
|
| + if (pthread_create(&thread, NULL, ThreadBody, thread_arg) != 0) {
|
| + Panic("Failed to create thread for close\n");
|
| + }
|
| +
|
| + // Wait for the library close to call PostCallback() before returning.
|
| + printf("Waiting for PostCallback() call\n");
|
| + pthread_mutex_lock(&callback_data->mutex_);
|
| + while (!callback_data->callback_.handler) {
|
| + pthread_cond_wait(&callback_data->cond_, &callback_data->mutex_);
|
| + }
|
| + pthread_mutex_unlock(&callback_data->mutex_);
|
| + printf("Done waiting for PostCallback() call\n");
|
| +
|
| + return thread;
|
| +}
|
| +
|
| +} // namespace
|
| +
|
| +int main() {
|
| + crazy_context_t* context = crazy_context_create();
|
| + crazy_library_t* library;
|
| +
|
| + // DEBUG
|
| + crazy_context_set_load_address(context, 0x20000000);
|
| +
|
| + // Set a callback poster.
|
| + CallbackData callback_data;
|
| + crazy_context_set_callback_poster(context, &PostCallback, &callback_data);
|
| +
|
| + crazy_callback_poster_t poster;
|
| + void* poster_opaque;
|
| +
|
| + // Check that the API returns the values we set.
|
| + crazy_context_get_callback_poster(context, &poster, &poster_opaque);
|
| + if (poster != &PostCallback || poster_opaque != &callback_data) {
|
| + Panic("Get callback poster error\n");
|
| + }
|
| +
|
| + // Load libfoo.so.
|
| + if (!crazy_library_open(&library, "libfoo.so", context)) {
|
| + Panic("Could not open library: %s\n", crazy_context_get_error(context));
|
| + }
|
| + CheckAndRunCallback(&callback_data);
|
| +
|
| + // Find the "Foo" symbol.
|
| + FunctionPtr foo_func;
|
| + if (!crazy_library_find_symbol(
|
| + library, "Foo", reinterpret_cast<void**>(&foo_func))) {
|
| + Panic("Could not find 'Foo' in libfoo.so\n");
|
| + }
|
| +
|
| + // Call it.
|
| + (*foo_func)();
|
| +
|
| + // Close the library. Because the close operation will wait for the
|
| + // callback before returning, we have to run it in a separate thread, and
|
| + // wait for it to call PostCallback() before continuing.
|
| + pthread_t thread =
|
| + AsyncCrazyLibraryCloseWithContext(library, context, &callback_data);
|
| + CheckAndRunCallback(&callback_data);
|
| +
|
| + if (pthread_join(thread, NULL) != 0) {
|
| + Panic("Failed to join thread for close\n");
|
| + }
|
| +
|
| + crazy_context_destroy(context);
|
| + return 0;
|
| +}
|
|
|