19066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 29066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Copyright (C) 2007 The Android Open Source Project 39066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 49066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Licensed under the Apache License, Version 2.0 (the "License"); 59066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * you may not use this file except in compliance with the License. 69066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * You may obtain a copy of the License at 79066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 89066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * http://www.apache.org/licenses/LICENSE-2.0 99066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Unless required by applicable law or agreed to in writing, software 119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * distributed under the License is distributed on an "AS IS" BASIS, 129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * See the License for the specific language governing permissions and 149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * limitations under the License. 159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 174df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project// #define LOG_NDEBUG 0 189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#define LOG_TAG "libutils.threads" 199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <utils/threads.h> 219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <utils/Log.h> 229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <stdio.h> 249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <stdlib.h> 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <memory.h> 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <errno.h> 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <assert.h> 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <unistd.h> 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_PTHREADS) 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# include <pthread.h> 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# include <sched.h> 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# include <sys/resource.h> 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_WIN32_THREADS) 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# include <windows.h> 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# include <stdint.h> 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# include <process.h> 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project# define HAVE_CREATETHREAD // Cygwin, vs. HAVE__BEGINTHREADEX for MinGW 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_FUTEX) 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <private/utils/futex_synchro.h> 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_PRCTL) 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#include <sys/prctl.h> 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * =========================================================================== 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Thread wrappers 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * =========================================================================== 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectusing namespace android; 569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_PTHREADS) 599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark PTHREAD 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Create and run a new thead. 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * We create it "detached", so it cleans up after itself. 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projecttypedef void* (*android_pthread_entry)(void*); 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstruct thread_data_t { 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project thread_func_t entryFunction; 759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void* userData; 769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int priority; 779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project char * threadName; 789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // we use this trampoline when we need to set the priority with 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // nice/setpriority. 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project static int trampoline(const thread_data_t* t) { 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project thread_func_t f = t->entryFunction; 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void* u = t->userData; 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int prio = t->priority; 859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project char * name = t->threadName; 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project delete t; 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setpriority(PRIO_PROCESS, 0, prio); 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (name) { 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_PRCTL) 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Mac OS doesn't have this, and we build libutil for the host too 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int hasAt = 0; 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int hasDot = 0; 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project char *s = name; 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (*s) { 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (*s == '.') hasDot = 1; 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project else if (*s == '@') hasAt = 1; 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s++; 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int len = s - name; 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (len < 15 || hasAt || !hasDot) { 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s = name; 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s = name + len - 15; 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project prctl(PR_SET_NAME, (unsigned long) s, 0, 0, 0); 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project free(name); 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return f(u); 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project}; 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectint androidCreateRawThreadEtc(android_thread_func_t entryFunction, 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void *userData, 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project const char* threadName, 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int32_t threadPriority, 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project size_t threadStackSize, 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project android_thread_id_t *threadId) 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_attr_t attr; 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_attr_init(&attr); 1229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); 1239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#ifdef HAVE_ANDROID_OS /* valgrind is rejecting RT-priority create reqs */ 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (threadPriority != PRIORITY_DEFAULT || threadName != NULL) { 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // We could avoid the trampoline if there was a way to get to the 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // android_thread_id_t (pid) from pthread_t 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project thread_data_t* t = new thread_data_t; 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project t->priority = threadPriority; 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project t->threadName = threadName ? strdup(threadName) : NULL; 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project t->entryFunction = entryFunction; 1329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project t->userData = userData; 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project entryFunction = (android_thread_func_t)&thread_data_t::trampoline; 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project userData = t; 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (threadStackSize) { 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_attr_setstacksize(&attr, threadStackSize); 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project errno = 0; 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_t thread; 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int result = pthread_create(&thread, &attr, 1459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (android_pthread_entry)entryFunction, userData); 1469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (result != 0) { 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LOGE("androidCreateRawThreadEtc failed (entry=%p, res=%d, errno=%d)\n" 1489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "(android threadPriority=%d)", 1499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project entryFunction, result, errno, threadPriority); 1509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return 0; 1519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (threadId != NULL) { 1549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project *threadId = (android_thread_id_t)thread; // XXX: this is not portable 1559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return 1; 1579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 1589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectandroid_thread_id_t androidGetThreadId() 1609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 1619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return (android_thread_id_t)pthread_self(); 1629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 1639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 1659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_WIN32_THREADS) 1669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark WIN32_THREADS 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Trampoline to make us __stdcall-compliant. 1749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * We're expected to delete "vDetails" when we're done. 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstruct threadDetails { 1789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int (*func)(void*); 1799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void* arg; 1809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project}; 1819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatic __stdcall unsigned int threadIntermediary(void* vDetails) 1829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 1839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project struct threadDetails* pDetails = (struct threadDetails*) vDetails; 1849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int result; 1859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project result = (*(pDetails->func))(pDetails->arg); 1879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project delete pDetails; 1899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LOG(LOG_VERBOSE, "thread", "thread exiting\n"); 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return (unsigned int) result; 1929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 1939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Create and run a new thread. 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatic bool doCreateThread(android_thread_func_t fn, void* arg, android_thread_id_t *id) 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE hThread; 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project struct threadDetails* pDetails = new threadDetails; // must be on heap 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project unsigned int thrdaddr; 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pDetails->func = fn; 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pDetails->arg = arg; 2059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE__BEGINTHREADEX) 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project hThread = (HANDLE) _beginthreadex(NULL, 0, threadIntermediary, pDetails, 0, 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project &thrdaddr); 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (hThread == 0) 2109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_CREATETHREAD) 2119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project hThread = CreateThread(NULL, 0, 2129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (LPTHREAD_START_ROUTINE) threadIntermediary, 2139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (void*) pDetails, 0, (DWORD*) &thrdaddr); 2149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (hThread == NULL) 2159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project { 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LOG(LOG_WARN, "thread", "WARNING: thread create failed\n"); 2189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 2199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_CREATETHREAD) 2229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* close the management handle */ 2239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project CloseHandle(hThread); 2249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 2259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (id != NULL) { 2279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project *id = (android_thread_id_t)thrdaddr; 2289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return true; 2319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectint androidCreateRawThreadEtc(android_thread_func_t fn, 2349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void *userData, 2359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project const char* threadName, 2369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int32_t threadPriority, 2379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project size_t threadStackSize, 2389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project android_thread_id_t *threadId) 2399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 2409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return doCreateThread( fn, userData, threadId); 2419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectandroid_thread_id_t androidGetThreadId() 2449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 2459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return (android_thread_id_t)GetCurrentThreadId(); 2469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 2499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#else 2509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#error "Threads not supported" 2519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 2529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 2549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 2569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 2579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark Common Thread functions 2589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 2599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectint androidCreateThread(android_thread_func_t fn, void* arg) 2619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 2629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return createThreadEtc(fn, arg); 2639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectint androidCreateThreadGetID(android_thread_func_t fn, void *arg, android_thread_id_t *id) 2669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 2679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return createThreadEtc(fn, arg, "android:unnamed_thread", 2689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project PRIORITY_DEFAULT, 0, id); 2699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatic android_create_thread_fn gCreateThreadFn = androidCreateRawThreadEtc; 2729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectint androidCreateThreadEtc(android_thread_func_t entryFunction, 2749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void *userData, 2759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project const char* threadName, 2769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int32_t threadPriority, 2779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project size_t threadStackSize, 2789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project android_thread_id_t *threadId) 2799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 2809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return gCreateThreadFn(entryFunction, userData, threadName, 2819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project threadPriority, threadStackSize, threadId); 2829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid androidSetCreateThreadFunc(android_create_thread_fn func) 2859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 2869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project gCreateThreadFn = func; 2879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 2889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectnamespace android { 2909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 2929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * =========================================================================== 2939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Mutex class 2949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * =========================================================================== 2959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 2989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 2999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark Mutex 3009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 3019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_PTHREADS) && !defined(HAVE_FUTEX) 3039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 3049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Simple pthread wrapper. 3059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::Mutex() 3089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project _init(); 3109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::Mutex(const char* name) 3139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // XXX: name not used for now 3159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project _init(); 3169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Mutex::_init() 3199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_mutex_t* pMutex = new pthread_mutex_t; 3219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_mutex_init(pMutex, NULL); 3229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mState = pMutex; 3239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::~Mutex() 3269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project delete (pthread_mutex_t*) mState; 3289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Mutex::lock() 3319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int res; 3339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((res=pthread_mutex_lock((pthread_mutex_t*) mState)) == EINTR) ; 3349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -res; 3359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Mutex::unlock() 3389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_mutex_unlock((pthread_mutex_t*) mState); 3409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Mutex::tryLock() 3439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int res; 3459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((res=pthread_mutex_trylock((pthread_mutex_t*) mState)) == EINTR) ; 3469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -res; 3479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_FUTEX) 3509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 3519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 3529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 3539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#define STATE ((futex_mutex_t*) (&mState)) 3559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::Mutex() 3579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project _init(); 3599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::Mutex(const char* name) 3629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project _init(); 3649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid 3679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::_init() 3689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project futex_mutex_init(STATE); 3709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::~Mutex() 3739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Mutex::lock() 3779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int res; 3799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((res=futex_mutex_lock(STATE, FUTEX_WAIT_INFINITE)) == EINTR) ; 3809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -res; 3819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Mutex::unlock() 3849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project futex_mutex_unlock(STATE); 3869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Mutex::tryLock() 3899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 3909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int res; 3919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((res=futex_mutex_trylock(STATE)) == EINTR) ; 3929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -res; 3939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 3949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#undef STATE 3959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_WIN32_THREADS) 3979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 3989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 3999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 4009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::Mutex() 4029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE hMutex; 4049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project assert(sizeof(hMutex) == sizeof(mState)); 4069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project hMutex = CreateMutex(NULL, FALSE, NULL); 4089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mState = (void*) hMutex; 4099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::Mutex(const char* name) 4129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // XXX: name not used for now 4149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE hMutex; 4159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project hMutex = CreateMutex(NULL, FALSE, NULL); 4179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mState = (void*) hMutex; 4189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectMutex::~Mutex() 4219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project CloseHandle((HANDLE) mState); 4239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Mutex::lock() 4269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project DWORD dwWaitResult; 4289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dwWaitResult = WaitForSingleObject((HANDLE) mState, INFINITE); 4299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return dwWaitResult != WAIT_OBJECT_0 ? -1 : NO_ERROR; 4309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Mutex::unlock() 4339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!ReleaseMutex((HANDLE) mState)) 4359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LOG(LOG_WARN, "thread", "WARNING: bad result from unlocking mutex\n"); 4369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Mutex::tryLock() 4399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project DWORD dwWaitResult; 4419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dwWaitResult = WaitForSingleObject((HANDLE) mState, 0); 4439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (dwWaitResult != WAIT_OBJECT_0 && dwWaitResult != WAIT_TIMEOUT) 4449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LOG(LOG_WARN, "thread", "WARNING: bad result from try-locking mutex\n"); 4459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return (dwWaitResult == WAIT_OBJECT_0) ? 0 : -1; 4469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#else 4499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#error "Somebody forgot to implement threads for this platform." 4509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 4519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 4549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * =========================================================================== 4559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Condition class 4569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * =========================================================================== 4579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 4609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 4619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark Condition 4629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 4639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if defined(HAVE_PTHREADS) && !defined(HAVE_FUTEX) 4659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 4679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Constructor. This is a simple pthread wrapper. 4689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectCondition::Condition() 4709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_cond_t* pCond = new pthread_cond_t; 4729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_cond_init(pCond, NULL); 4749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mState = pCond; 4759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 4789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Destructor. 4799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectCondition::~Condition() 4819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_cond_destroy((pthread_cond_t*) mState); 4839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project delete (pthread_cond_t*) mState; 4849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 4879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Wait on a condition variable. Lock the mutex before calling. 4889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::wait(Mutex& mutex) 4919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 4929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project assert(mutex.mState != NULL); 4939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int cc; 4959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((cc = pthread_cond_wait((pthread_cond_t*)mState, 4969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (pthread_mutex_t*) mutex.mState)) == EINTR) ; 4979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -cc; 4989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 4999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::wait(Mutex& mutex, nsecs_t abstime) 5019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project assert(mutex.mState != NULL); 5039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project struct timespec ts; 5059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ts.tv_sec = abstime/1000000000; 5069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ts.tv_nsec = abstime-(ts.tv_sec*1000000000); 5079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int cc; 5099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((cc = pthread_cond_timedwait((pthread_cond_t*)mState, 5109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (pthread_mutex_t*) mutex.mState, &ts)) == EINTR) ; 5119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -cc; 5129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::waitRelative(Mutex& mutex, nsecs_t reltime) 5159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return wait(mutex, systemTime()+reltime); 5179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 5209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Signal the condition variable, allowing one thread to continue. 5219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Condition::signal() 5239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_cond_signal((pthread_cond_t*) mState); 5259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 5289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Signal the condition variable, allowing all threads to continue. 5299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Condition::broadcast() 5319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pthread_cond_broadcast((pthread_cond_t*) mState); 5339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_FUTEX) 5369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 5379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 5389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 5399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#define STATE ((futex_cond_t*) (&mState)) 5419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 5439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Constructor. This is a simple pthread wrapper. 5449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectCondition::Condition() 5469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project futex_cond_init(STATE); 5489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 5519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Destructor. 5529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectCondition::~Condition() 5549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 5589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Wait on a condition variable. Lock the mutex before calling. 5599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::wait(Mutex& mutex) 5629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project assert(mutex.mState != NULL); 5649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int res; 5669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((res = futex_cond_wait(STATE, 5679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (futex_mutex_t*)(&mutex.mState), FUTEX_WAIT_INFINITE)) == -EINTR) ; 5689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -res; 5709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::wait(Mutex& mutex, nsecs_t abstime) 5739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nsecs_t reltime = abstime - systemTime(); 5759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (reltime <= 0) return true; 5769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return waitRelative(mutex, reltime); 5779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::waitRelative(Mutex& mutex, nsecs_t reltime) 5809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project assert(mutex.mState != NULL); 5829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int res; 5839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project unsigned msec = ns2ms(reltime); 5849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if(msec == 0) 5859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return true; 5869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // This code will not time out at the correct time if interrupted by signals 5879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((res = futex_cond_wait(STATE, 5889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (futex_mutex_t*)(&mutex.mState), msec)) == -EINTR) ; 5899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return res; 5909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 5939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Signal the condition variable, allowing one thread to continue. 5949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Condition::signal() 5969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 5979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project futex_cond_signal(STATE); 5989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 5999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 6019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Signal the condition variable, allowing all threads to continue. 6029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Condition::broadcast() 6049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 6059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project futex_cond_broadcast(STATE); 6069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 6079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#undef STATE 6099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#elif defined(HAVE_WIN32_THREADS) 6119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 6129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 6139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 6149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 6169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Windows doesn't have a condition variable solution. It's possible 6179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * to create one, but it's easy to get it wrong. For a discussion, and 6189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * the origin of this implementation, see: 6199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 6209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * http://www.cs.wustl.edu/~schmidt/win32-cv-1.html 6219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 6229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The implementation shown on the page does NOT follow POSIX semantics. 6239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * As an optimization they require acquiring the external mutex before 6249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * calling signal() and broadcast(), whereas POSIX only requires grabbing 6259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * it before calling wait(). The implementation here has been un-optimized 6269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * to have the correct behavior. 6279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projecttypedef struct WinCondition { 6299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Number of waiting threads. 6309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int waitersCount; 6319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Serialize access to waitersCount. 6339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project CRITICAL_SECTION waitersCountLock; 6349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Semaphore used to queue up threads waiting for the condition to 6369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // become signaled. 6379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE sema; 6389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // An auto-reset event used by the broadcast/signal thread to wait 6409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // for all the waiting thread(s) to wake up and be released from 6419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // the semaphore. 6429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE waitersDone; 6439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // This mutex wouldn't be necessary if we required that the caller 6459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // lock the external mutex before calling signal() and broadcast(). 6469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // I'm trying to mimic pthread semantics though. 6479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE internalMutex; 6489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Keeps track of whether we were broadcasting or signaling. This 6509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // allows us to optimize the code if we're just signaling. 6519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project bool wasBroadcast; 6529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project status_t wait(WinCondition* condState, HANDLE hMutex, nsecs_t* abstime) 6549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project { 6559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Increment the wait count, avoiding race conditions. 6569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EnterCriticalSection(&condState->waitersCountLock); 6579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->waitersCount++; 6589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project //printf("+++ wait: incr waitersCount to %d (tid=%ld)\n", 6599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // condState->waitersCount, getThreadId()); 6609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LeaveCriticalSection(&condState->waitersCountLock); 6619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project DWORD timeout = INFINITE; 6639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (abstime) { 6649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nsecs_t reltime = *abstime - systemTime(); 6659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (reltime < 0) 6669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project reltime = 0; 6679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project timeout = reltime/1000000; 6689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Atomically release the external mutex and wait on the semaphore. 6719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project DWORD res = 6729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project SignalObjectAndWait(hMutex, condState->sema, timeout, FALSE); 6739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project //printf("+++ wait: awake (tid=%ld)\n", getThreadId()); 6759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Reacquire lock to avoid race conditions. 6779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EnterCriticalSection(&condState->waitersCountLock); 6789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // No longer waiting. 6809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->waitersCount--; 6819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Check to see if we're the last waiter after a broadcast. 6839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project bool lastWaiter = (condState->wasBroadcast && condState->waitersCount == 0); 6849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project //printf("+++ wait: lastWaiter=%d (wasBc=%d wc=%d)\n", 6869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // lastWaiter, condState->wasBroadcast, condState->waitersCount); 6879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LeaveCriticalSection(&condState->waitersCountLock); 6899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // If we're the last waiter thread during this particular broadcast 6919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // then signal broadcast() that we're all awake. It'll drop the 6929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // internal mutex. 6939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (lastWaiter) { 6949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Atomically signal the "waitersDone" event and wait until we 6959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // can acquire the internal mutex. We want to do this in one step 6969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // because it ensures that everybody is in the mutex FIFO before 6979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // any thread has a chance to run. Without it, another thread 6989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // could wake up, do work, and hop back in ahead of us. 6999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project SignalObjectAndWait(condState->waitersDone, condState->internalMutex, 7009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project INFINITE, FALSE); 7019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 7029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Grab the internal mutex. 7039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WaitForSingleObject(condState->internalMutex, INFINITE); 7049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Release the internal and grab the external. 7079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ReleaseMutex(condState->internalMutex); 7089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WaitForSingleObject(hMutex, INFINITE); 7099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return res == WAIT_OBJECT_0 ? NO_ERROR : -1; 7119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} WinCondition; 7139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 7159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Constructor. Set up the WinCondition stuff. 7169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 7179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectCondition::Condition() 7189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 7199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WinCondition* condState = new WinCondition; 7209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->waitersCount = 0; 7229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->wasBroadcast = false; 7239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // semaphore: no security, initial value of 0 7249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->sema = CreateSemaphore(NULL, 0, 0x7fffffff, NULL); 7259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project InitializeCriticalSection(&condState->waitersCountLock); 7269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // auto-reset event, not signaled initially 7279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->waitersDone = CreateEvent(NULL, FALSE, FALSE, NULL); 7289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // used so we don't have to lock external mutex on signal/broadcast 7299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->internalMutex = CreateMutex(NULL, FALSE, NULL); 7309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mState = condState; 7329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 7339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 7359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Destructor. Free Windows resources as well as our allocated storage. 7369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 7379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectCondition::~Condition() 7389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 7399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WinCondition* condState = (WinCondition*) mState; 7409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (condState != NULL) { 7419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project CloseHandle(condState->sema); 7429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project CloseHandle(condState->waitersDone); 7439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project delete condState; 7449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 7469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::wait(Mutex& mutex) 7499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 7509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WinCondition* condState = (WinCondition*) mState; 7519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE hMutex = (HANDLE) mutex.mState; 7529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ((WinCondition*)mState)->wait(condState, hMutex, NULL); 7549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 7559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::wait(Mutex& mutex, nsecs_t abstime) 7579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 7589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WinCondition* condState = (WinCondition*) mState; 7599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HANDLE hMutex = (HANDLE) mutex.mState; 7609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ((WinCondition*)mState)->wait(condState, hMutex, &abstime); 7629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 7639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Condition::waitRelative(Mutex& mutex, nsecs_t reltime) 7659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 7669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return wait(mutex, systemTime()+reltime); 7679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 7689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 7709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Signal the condition variable, allowing one thread to continue. 7719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 7729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Condition::signal() 7739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 7749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WinCondition* condState = (WinCondition*) mState; 7759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Lock the internal mutex. This ensures that we don't clash with 7779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // broadcast(). 7789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WaitForSingleObject(condState->internalMutex, INFINITE); 7799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EnterCriticalSection(&condState->waitersCountLock); 7819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project bool haveWaiters = (condState->waitersCount > 0); 7829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LeaveCriticalSection(&condState->waitersCountLock); 7839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // If no waiters, then this is a no-op. Otherwise, knock the semaphore 7859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // down a notch. 7869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (haveWaiters) 7879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ReleaseSemaphore(condState->sema, 1, 0); 7889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Release internal mutex. 7909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ReleaseMutex(condState->internalMutex); 7919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 7929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 7949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Signal the condition variable, allowing all threads to continue. 7959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 7969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * First we have to wake up all threads waiting on the semaphore, then 7979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * we wait until all of the threads have actually been woken before 7989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * releasing the internal mutex. This ensures that all threads are woken. 7999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 8009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Condition::broadcast() 8019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 8029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WinCondition* condState = (WinCondition*) mState; 8039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Lock the internal mutex. This keeps the guys we're waking up 8059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // from getting too far. 8069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WaitForSingleObject(condState->internalMutex, INFINITE); 8079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EnterCriticalSection(&condState->waitersCountLock); 8099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project bool haveWaiters = false; 8109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (condState->waitersCount > 0) { 8129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project haveWaiters = true; 8139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->wasBroadcast = true; 8149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (haveWaiters) { 8179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Wake up all the waiters. 8189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ReleaseSemaphore(condState->sema, condState->waitersCount, 0); 8199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LeaveCriticalSection(&condState->waitersCountLock); 8219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Wait for all awakened threads to acquire the counting semaphore. 8239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // The last guy who was waiting sets this. 8249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WaitForSingleObject(condState->waitersDone, INFINITE); 8259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Reset wasBroadcast. (No crit section needed because nobody 8279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // else can wake up to poke at it.) 8289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project condState->wasBroadcast = 0; 8299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 8309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // nothing to do 8319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LeaveCriticalSection(&condState->waitersCountLock); 8329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Release internal mutex. 8359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ReleaseMutex(condState->internalMutex); 8369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 8379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#else 8399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#error "condition variables not supported on this platform" 8409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 8419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project// ---------------------------------------------------------------------------- 8439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#if 0 8459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark - 8469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#pragma mark Thread::Thread 8479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project#endif 8489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 8509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This is our thread object! 8519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 8529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectThread::Thread(bool canCallJava) 8549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project : mCanCallJava(canCallJava), 8559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThread(thread_id_t(-1)), 8569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mLock("Thread::mLock"), 8579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mStatus(NO_ERROR), 8589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mExitPending(false), mRunning(false) 8599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 8609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 8619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source ProjectThread::~Thread() 8639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 8649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 8659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Thread::readyToRun() 8679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 8689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return NO_ERROR; 8699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 8709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Thread::run(const char* name, int32_t priority, size_t stack) 8729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 8739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Mutex::Autolock _l(mLock); 8749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mRunning) { 8769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // thread already started 8779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return INVALID_OPERATION; 8789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // reset status and exitPending to their default value, so we can 8819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // try again after an error happened (either below, or in readyToRun()) 8829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mStatus = NO_ERROR; 8839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mExitPending = false; 8849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThread = thread_id_t(-1); 8859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // hold a strong reference on ourself 8879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHoldSelf = this; 8889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8894df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project mRunning = true; 8904df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 8919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project bool res; 8929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mCanCallJava) { 8939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project res = createThreadEtc(_threadLoop, 8949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this, name, priority, stack, &mThread); 8959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 8969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project res = androidCreateRawThreadEtc(_threadLoop, 8979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this, name, priority, stack, &mThread); 8989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (res == false) { 9019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mStatus = UNKNOWN_ERROR; // something happened! 9029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRunning = false; 9039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThread = thread_id_t(-1); 9044df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project mHoldSelf.clear(); // "this" may have gone away after this. 9054df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 9064df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project return UNKNOWN_ERROR; 9079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 9089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9094df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // Do not refer to mStatus here: The thread is already running (may, in fact 9104df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // already have exited with a valid mStatus result). The NO_ERROR indication 9114df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // here merely indicates successfully starting the thread and does not 9124df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // imply successful termination/execution. 9134df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project return NO_ERROR; 9149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 9159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectint Thread::_threadLoop(void* user) 9179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 9189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Thread* const self = static_cast<Thread*>(user); 9199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project sp<Thread> strong(self->mHoldSelf); 9209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project wp<Thread> weak(strong); 9219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project self->mHoldSelf.clear(); 9229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9234df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project bool first = true; 9249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project do { 9264df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project bool result; 9274df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project if (first) { 9284df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project first = false; 9294df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project self->mStatus = self->readyToRun(); 9304df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project result = (self->mStatus == NO_ERROR); 9314df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 9324df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project if (result && !self->mExitPending) { 9334df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // Binder threads (and maybe others) rely on threadLoop 9344df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // running at least once after a successful ::readyToRun() 9354df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // (unless, of course, the thread has already been asked to exit 9364df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // at that point). 9374df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // This is because threads are essentially used like this: 9384df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // (new ThreadSubclass())->run(); 9394df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // The caller therefore does not retain a strong reference to 9404df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // the thread and the thread would simply disappear after the 9414df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // successful ::readyToRun() call instead of entering the 9424df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project // threadLoop at least once. 9434df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project result = self->threadLoop(); 9444df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project } 9454df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project } else { 9464df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project result = self->threadLoop(); 9474df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project } 9484df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 9499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (result == false || self->mExitPending) { 9509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project self->mExitPending = true; 9519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project self->mLock.lock(); 9529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project self->mRunning = false; 9539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project self->mThreadExitedCondition.signal(); 9549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project self->mLock.unlock(); 9559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 9569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 9579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Release our strong reference, to let a chance to the thread 9599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // to die a peaceful death. 9609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project strong.clear(); 9619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // And immediately, reacquire a strong reference for the next loop 9629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project strong = weak.promote(); 9639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } while(strong != 0); 9649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return 0; 9669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 9679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectvoid Thread::requestExit() 9699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 9709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mExitPending = true; 9719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 9729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectstatus_t Thread::requestExitAndWait() 9749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 9754df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project if (mThread == getThreadId()) { 9764df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project LOGW( 9774df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project "Thread (this=%p): don't call waitForExit() from this " 9784df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project "Thread object's thread. It's a guaranteed deadlock!", 9794df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project this); 9809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9814df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project return WOULD_BLOCK; 9829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 9834df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 9844df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project requestExit(); 9854df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 9864df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project Mutex::Autolock _l(mLock); 9874df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project while (mRunning == true) { 9884df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project mThreadExitedCondition.wait(mLock); 9894df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project } 9904df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project mExitPending = false; 9914df2423a947bcd3f024cc3d3a1a315a8dc428598The Android Open Source Project 9929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mStatus; 9939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 9949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 9959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectbool Thread::exitPending() const 9969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project{ 9979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mExitPending; 9989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 9999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 10009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 10019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 10029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project}; // namespace android 1003