IThreadSync.cpp revision e5bf0d2c9531a7064eb3ddcafaf93ac1b0974037
161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten/* 261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * Copyright (C) 2010 The Android Open Source Project 361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * 461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * Licensed under the Apache License, Version 2.0 (the "License"); 561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * you may not use this file except in compliance with the License. 661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * You may obtain a copy of the License at 761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * 861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * http://www.apache.org/licenses/LICENSE-2.0 961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * 1061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * Unless required by applicable law or agreed to in writing, software 1161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * distributed under the License is distributed on an "AS IS" BASIS, 1261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * See the License for the specific language governing permissions and 1461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten * limitations under the License. 1561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten */ 1661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 1761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten/* ThreadSync implementation */ 1861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 1961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten#include "sles_allinclusive.h" 2061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 2161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic SLresult IThreadSync_EnterCriticalSection(SLThreadSyncItf self) 2261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 2361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IThreadSync *this = (IThreadSync *) self; 2461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLresult result; 2561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface_lock_exclusive(this); 2661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten for (;;) { 2761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (this->mInCriticalSection) { 287324a5ab12cc734e2feb4cef8baeda26566d3c92Glenn Kasten if (!pthread_equal(this->mOwner, pthread_self())) { 29e5bf0d2c9531a7064eb3ddcafaf93ac1b0974037Glenn Kasten ++this->mWaiting; 3061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface_cond_wait(this); 3161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten continue; 3261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 33e5bf0d2c9531a7064eb3ddcafaf93ac1b0974037Glenn Kasten // nested locks are not allowed 3461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_PRECONDITIONS_VIOLATED; 3561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten break; 3661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 3761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mInCriticalSection = SL_BOOLEAN_TRUE; 3861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mOwner = pthread_self(); 3961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_SUCCESS; 4061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten break; 4161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 4261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface_unlock_exclusive(this); 4361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return result; 4461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 4561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 4661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic SLresult IThreadSync_ExitCriticalSection(SLThreadSyncItf self) 4761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 4861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IThreadSync *this = (IThreadSync *) self; 4961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLresult result; 5061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface_lock_exclusive(this); 517324a5ab12cc734e2feb4cef8baeda26566d3c92Glenn Kasten if (!this->mInCriticalSection || !pthread_equal(this->mOwner, pthread_self())) { 5261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_PRECONDITIONS_VIOLATED; 5361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } else { 5461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mInCriticalSection = SL_BOOLEAN_FALSE; 557324a5ab12cc734e2feb4cef8baeda26566d3c92Glenn Kasten memset(&this->mOwner, 0, sizeof(pthread_t)); 5661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_SUCCESS; 5761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (this->mWaiting) { 58e5bf0d2c9531a7064eb3ddcafaf93ac1b0974037Glenn Kasten --this->mWaiting; 5961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface_cond_signal(this); 6061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 6161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 6261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface_unlock_exclusive(this); 6361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return result; 6461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 6561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 6661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic const struct SLThreadSyncItf_ IThreadSync_Itf = { 6761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IThreadSync_EnterCriticalSection, 6861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IThreadSync_ExitCriticalSection 6961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten}; 7061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 7161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenvoid IThreadSync_init(void *self) 7261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 73e5bf0d2c9531a7064eb3ddcafaf93ac1b0974037Glenn Kasten IThreadSync *this = (IThreadSync *) self; 7461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mItf = &IThreadSync_Itf; 7561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mInCriticalSection = SL_BOOLEAN_FALSE; 76e5bf0d2c9531a7064eb3ddcafaf93ac1b0974037Glenn Kasten this->mWaiting = 0; 777324a5ab12cc734e2feb4cef8baeda26566d3c92Glenn Kasten memset(&this->mOwner, 0, sizeof(pthread_t)); 7861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 79