/*
|
* Copyright (C) 2018 The Android Open Source Project
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*/
|
|
#define LOG_TAG "IPCThreadStateBase"
|
|
#include <binderthreadstate/IPCThreadStateBase.h>
|
#include <android-base/macros.h>
|
|
#include <utils/Log.h>
|
|
#include <errno.h>
|
#include <inttypes.h>
|
#include <pthread.h>
|
|
namespace android {
|
|
static pthread_mutex_t gTLSMutex = PTHREAD_MUTEX_INITIALIZER;
|
static bool gHaveTLS = false;
|
static pthread_key_t gTLS = 0;
|
|
IPCThreadStateBase::IPCThreadStateBase() {
|
pthread_setspecific(gTLS, this);
|
}
|
|
IPCThreadStateBase* IPCThreadStateBase::self()
|
{
|
if (gHaveTLS) {
|
restart:
|
const pthread_key_t k = gTLS;
|
IPCThreadStateBase* st = (IPCThreadStateBase*)pthread_getspecific(k);
|
if (st) return st;
|
return new IPCThreadStateBase;
|
}
|
|
pthread_mutex_lock(&gTLSMutex);
|
if (!gHaveTLS) {
|
int key_create_value = pthread_key_create(&gTLS, threadDestructor);
|
if (key_create_value != 0) {
|
pthread_mutex_unlock(&gTLSMutex);
|
ALOGW("IPCThreadStateBase::self() unable to create TLS key, expect a crash: %s\n",
|
strerror(key_create_value));
|
return nullptr;
|
}
|
gHaveTLS = true;
|
}
|
pthread_mutex_unlock(&gTLSMutex);
|
goto restart;
|
}
|
|
void IPCThreadStateBase::pushCurrentState(CallState callState) {
|
mCallStateStack.emplace(callState);
|
}
|
|
IPCThreadStateBase::CallState IPCThreadStateBase::popCurrentState() {
|
ALOG_ASSERT(mCallStateStack.size > 0);
|
CallState val = mCallStateStack.top();
|
mCallStateStack.pop();
|
return val;
|
}
|
|
IPCThreadStateBase::CallState IPCThreadStateBase::getCurrentBinderCallState() {
|
if (mCallStateStack.size() > 0) {
|
return mCallStateStack.top();
|
}
|
return CallState::NONE;
|
}
|
|
void IPCThreadStateBase::threadDestructor(void *st)
|
{
|
IPCThreadStateBase* const self = static_cast<IPCThreadStateBase*>(st);
|
if (self) {
|
delete self;
|
}
|
}
|
|
}; // namespace android
|
