/*************************************************************************/ /* thread_jandroid.cpp */ /*************************************************************************/ /* This file is part of: */ /* GODOT ENGINE */ /* http://www.godotengine.org */ /*************************************************************************/ /* Copyright (c) 2007-2015 Juan Linietsky, Ariel Manzur. */ /* */ /* Permission is hereby granted, free of charge, to any person obtaining */ /* a copy of this software and associated documentation files (the */ /* "Software"), to deal in the Software without restriction, including */ /* without limitation the rights to use, copy, modify, merge, publish, */ /* distribute, sublicense, and/or sell copies of the Software, and to */ /* permit persons to whom the Software is furnished to do so, subject to */ /* the following conditions: */ /* */ /* The above copyright notice and this permission notice shall be */ /* included in all copies or substantial portions of the Software. */ /* */ /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */ /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */ /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/ /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */ /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */ /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */ /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ /*************************************************************************/ #include "thread_jandroid.h" #include "os/memory.h" Thread::ID ThreadAndroid::get_ID() const { return id; } Thread* ThreadAndroid::create_thread_jandroid() { return memnew( ThreadAndroid ); } void *ThreadAndroid::thread_callback(void *userdata) { ThreadAndroid *t=reinterpret_cast<ThreadAndroid*>(userdata); setup_thread(); t->id=(ID)pthread_self(); t->callback(t->user); return NULL; } Thread* ThreadAndroid::create_func_jandroid(ThreadCreateCallback p_callback,void *p_user,const Settings&) { ThreadAndroid *tr= memnew(ThreadAndroid); tr->callback=p_callback; tr->user=p_user; pthread_attr_init(&tr->pthread_attr); pthread_attr_setdetachstate(&tr->pthread_attr, PTHREAD_CREATE_JOINABLE); pthread_create(&tr->pthread, &tr->pthread_attr, thread_callback, tr); return tr; } Thread::ID ThreadAndroid::get_thread_ID_func_jandroid() { return (ID)pthread_self(); } void ThreadAndroid::wait_to_finish_func_jandroid(Thread* p_thread) { ThreadAndroid *tp=static_cast<ThreadAndroid*>(p_thread); ERR_FAIL_COND(!tp); ERR_FAIL_COND(tp->pthread==0); pthread_join(tp->pthread,NULL); tp->pthread=0; } void ThreadAndroid::_thread_destroyed(void* value) { /* The thread is being destroyed, detach it from the Java VM and set the mThreadKey value to NULL as required */ JNIEnv *env = (JNIEnv*) value; if (env != NULL) { java_vm->DetachCurrentThread(); pthread_setspecific(jvm_key, NULL); } } pthread_key_t ThreadAndroid::jvm_key; JavaVM* ThreadAndroid::java_vm=NULL; void ThreadAndroid::setup_thread() { if (pthread_getspecific(jvm_key)) return; //already setup JNIEnv *env; java_vm->AttachCurrentThread(&env, NULL); pthread_setspecific(jvm_key, (void*) env); } void ThreadAndroid::make_default(JavaVM* p_java_vm) { java_vm=p_java_vm; create_func=create_func_jandroid; get_thread_ID_func=get_thread_ID_func_jandroid; wait_to_finish_func=wait_to_finish_func_jandroid; pthread_key_create(&jvm_key, _thread_destroyed); setup_thread(); } JNIEnv *ThreadAndroid::get_env() { if (!pthread_getspecific(jvm_key)) { setup_thread(); } JNIEnv *env=NULL; int status = java_vm->AttachCurrentThread(&env, NULL); return env; } ThreadAndroid::ThreadAndroid() { pthread=0; } ThreadAndroid::~ThreadAndroid() { }