IObject.c revision d2a7f0d6883a6d3835642e7b282f05ed1c54fe63
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/* Object implementation */ 1861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 1961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten#include "sles_allinclusive.h" 2061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 21d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten// Execute a closure to handle an asynchronous Object.Realize 22d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten 23d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kastenstatic void HandleRealize(Closure *pClosure) 2461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 25d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten IObject *this = (IObject *) pClosure->mContext; 2661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten const ClassTable *class__ = this->mClass; 273d146e0a31f5ee2a7d9807c4e99994084fdd3283Jean-Michel Trivi AsyncHook realize = class__->mRealize; 283a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten SLresult result; 29d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten SLuint32 state; 3061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_exclusive(this); 31d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // FIXME Cancellation is possible here 32d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten assert(SL_OBJECT_STATE_REALIZING_1 == this->mState); 33d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten if (NULL != realize) { 34d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mState = SL_OBJECT_STATE_REALIZING_2; 35d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten object_unlock_exclusive(this); 36d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Note that the mutex is unlocked during the realize hook 37d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten result = (*realize)(this, SL_BOOLEAN_TRUE); 38d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten object_lock_exclusive(this); 39d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten assert(SL_OBJECT_STATE_REALIZING_2 == this->mState); 40d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = SL_RESULT_SUCCESS == result ? SL_OBJECT_STATE_REALIZED : SL_OBJECT_STATE_UNREALIZED; 4161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } else { 42d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten result = SL_RESULT_SUCCESS; 43d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = SL_OBJECT_STATE_REALIZED; 4461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 45d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mState = state; 46d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Make a copy of these, so we can call the callback with mutex unlocked 47d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten slObjectCallback callback = this->mCallback; 48d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten void *context = this->mContext; 4961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_exclusive(this); 50d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Note that the mutex is unlocked during the callback 513a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten if (NULL != callback) 52d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten (*callback)(&this->mItf, context, SL_OBJECT_EVENT_ASYNC_TERMINATION, result, state, NULL); 53d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten} 54d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten 55d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kastenstatic SLresult IObject_Realize(SLObjectItf self, SLboolean async) 56d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten{ 57d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten IObject *this = (IObject *) self; 58d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten SLresult result = SL_RESULT_SUCCESS; 59d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten SLuint32 state; 60d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten const ClassTable *class__ = this->mClass; 61d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten object_lock_exclusive(this); 62d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = this->mState; 63d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Reject redundant calls to Realize 64d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten if (SL_OBJECT_STATE_UNREALIZED != state) { 65d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten result = SL_RESULT_PRECONDITIONS_VIOLATED; 66d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Asynchronous: mark operation pending and cancellable 67d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } else if (async && (SL_OBJECTID_ENGINE != class__->mObjectID)) { 68d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = SL_OBJECT_STATE_REALIZING_1; 69d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mState = state; 70d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Synchronous: mark operation pending and non-cancellable 71d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } else { 72d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = SL_OBJECT_STATE_REALIZING_2; 73d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mState = state; 74d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } 75d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten object_unlock_exclusive(this); 76d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten switch (state) { 77d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten case SL_OBJECT_STATE_REALIZING_1: // asynchronous on non-Engine 78d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten assert(async); 79d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // no mutex needed because the state guarantees we're the owner 80d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mClosure.mHandler = HandleRealize; 81d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mClosure.mContext = this; 82d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten if (!ThreadPool_add(&this->mEngine->mThreadPool, &this->mClosure)) { 83d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // This could happen if engine is destroyed during realize 84d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten result = SL_RESULT_OPERATION_ABORTED; 85d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } 86d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten break; 87d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten case SL_OBJECT_STATE_REALIZING_2: // synchronous, or asynchronous on Engine 88d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten { 89d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten AsyncHook realize = class__->mRealize; 90d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Note that the mutex is unlocked during the realize hook 91d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten if (NULL != realize) 92d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten result = (*realize)(this, async); 93d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten object_lock_exclusive(this); 94d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten assert(SL_OBJECT_STATE_REALIZING_2 == this->mState); 95d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = SL_RESULT_SUCCESS == result ? SL_OBJECT_STATE_REALIZED : SL_OBJECT_STATE_UNREALIZED; 96d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mState = state; 97d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten slObjectCallback callback = this->mCallback; 98d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten void *context = this->mContext; 99d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten object_unlock_exclusive(this); 100d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // asynchronous Realize on an Engine is actually done synchronously, but still has callback 101d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // This is because there is no thread pool yet to do it asynchronously. 102d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten if (async && (NULL != callback)) 103d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten (*callback)(&this->mItf, context, SL_OBJECT_EVENT_ASYNC_TERMINATION, result, state, NULL); 104d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } 105d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten break; 106d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten default: // preconditions violated 107d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten break; 108d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } 10961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return result; 11061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 11161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 11261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic SLresult IObject_Resume(SLObjectItf self, SLboolean async) 11361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 11461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 11561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten const ClassTable *class__ = this->mClass; 1163a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten StatusHook resume = class__->mResume; 1173a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten SLresult result; 1183a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten slObjectCallback callback = NULL; 1193a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten void *context = NULL; 1203a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten SLuint32 state = 0; 12161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_exclusive(this); 12261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (SL_OBJECT_STATE_SUSPENDED != this->mState) { 12361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_PRECONDITIONS_VIOLATED; 12461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } else { 1253a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten // FIXME The resume hook and callback should be asynchronous if requested 126ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // FIXME For asynchronous, mark operation pending to prevent duplication 1273a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten result = NULL != resume ? (*resume)(this) : SL_RESULT_SUCCESS; 12861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (SL_RESULT_SUCCESS == result) 12961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mState = SL_OBJECT_STATE_REALIZED; 1303a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten // Make a copy of these, so we can call the callback with mutex unlocked 1313a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten if (async) { 1323a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten callback = this->mCallback; 1333a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten context = this->mContext; 1343a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten state = this->mState; 1353a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten } 13661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 13761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_exclusive(this); 1383a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten if (NULL != callback) 1393a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten (*callback)(self, context, SL_OBJECT_EVENT_ASYNC_TERMINATION, result, state, NULL); 14061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return result; 14161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 14261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 14361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic SLresult IObject_GetState(SLObjectItf self, SLuint32 *pState) 14461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 14561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL == pState) 14661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_PARAMETER_INVALID; 14761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 1483a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten // Note that the state is immediately obsolete, so a peek lock is safe 1493a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten object_lock_peek(this); 15061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLuint32 state = this->mState; 1513a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten object_unlock_peek(this); 152d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten // Re-map the realizing states 153d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten switch (state) { 154d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten case SL_OBJECT_STATE_REALIZING_1: 155d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten case SL_OBJECT_STATE_REALIZING_2: 156d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten state = SL_OBJECT_STATE_UNREALIZED; 157d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten break; 158d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten default: 159d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten break; 160d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten } 16161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten *pState = state; 16261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_SUCCESS; 16361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 16461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 1653a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kastenstatic SLresult IObject_GetInterface(SLObjectItf self, const SLInterfaceID iid, void *pInterface) 16661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 16761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL == pInterface) 16861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_PARAMETER_INVALID; 16961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLresult result; 17061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten void *interface = NULL; 17161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL == iid) 17261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_PARAMETER_INVALID; 17361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten else { 17461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 17561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten const ClassTable *class__ = this->mClass; 17661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten int MPH, index; 17761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if ((0 > (MPH = IID_to_MPH(iid))) || 17861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten (0 > (index = class__->mMPH_to_index[MPH]))) 17961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_FEATURE_UNSUPPORTED; 18061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten else { 18161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten unsigned mask = 1 << index; 18261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_shared(this); 18361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (SL_OBJECT_STATE_REALIZED != this->mState) 18461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_PRECONDITIONS_VIOLATED; 18561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten else if (!(this->mExposedMask & mask)) 18661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_FEATURE_UNSUPPORTED; 18761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten else { 18861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // FIXME Should note that interface has been gotten, 18961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // so as to detect use of ill-gotten interfaces; be sure 19061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // to change the lock to exclusive if that is done 19161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten interface = (char *) this + class__->mInterfaces[index].mOffset; 19261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten result = SL_RESULT_SUCCESS; 19361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 19461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_shared(this); 19561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 19661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 19761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten *(void **)pInterface = interface; 19861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_SUCCESS; 19961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 20061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 20161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic SLresult IObject_RegisterCallback(SLObjectItf self, 20261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten slObjectCallback callback, void *pContext) 20361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 20461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 20561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_exclusive(this); 20661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mCallback = callback; 20761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mContext = pContext; 20861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_exclusive(this); 20961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_SUCCESS; 21061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 21161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 21261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic void IObject_AbortAsyncOperation(SLObjectItf self) 21361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 21461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // FIXME Asynchronous operations are not yet implemented 21561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 21661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 21761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic void IObject_Destroy(SLObjectItf self) 21861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 219ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // FIXME Check for dependencies, e.g. destroying an output mix with attached players, 220ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // destroying an engine with extant objects, etc. 2213a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kasten // FIXME The abort should be atomic w.r.t. destroy, so another async can't be started in window 222ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // FIXME Destroy may need to be made asynchronous to permit safe cleanup of resources 223ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // FIXME For asynchronous, mark operation pending to prevent duplication 22461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_AbortAsyncOperation(self); 22561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 22661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten const ClassTable *class__ = this->mClass; 22761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten VoidHook destroy = class__->mDestroy; 22861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten const struct iid_vtable *x = class__->mInterfaces; 229ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // const, no lock needed 230ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten IEngine *thisEngine = this->mEngine; 231ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten unsigned i = this->mInstanceID; 232ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten assert(0 < i && i <= INSTANCE_MAX); 233ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten --i; 234ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // remove object from exposure to sync thread 235ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten interface_lock_exclusive(thisEngine); 236ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten assert(0 < thisEngine->mInstanceCount); 237ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten --thisEngine->mInstanceCount; 238ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten assert(0 != thisEngine->mInstanceMask); 239ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten thisEngine->mInstanceMask &= ~(1 << i); 240ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten assert(thisEngine->mInstances[i] == this); 241ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten thisEngine->mInstances[i] = NULL; 24200d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten#ifdef USE_SDL 24300d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten if (SL_OBJECTID_OUTPUTMIX == class__->mObjectID && (COutputMix *) this == thisEngine->mOutputMix) { 24400d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten SDL_PauseAudio(1); 24500d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten thisEngine->mOutputMix = NULL; 24600d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten // Note we don't attempt to connect another output mix to SDL 24700d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten } 24800d2d554e04ac369367c903dbf53b975355d1bcdGlenn Kasten#endif 249ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten interface_unlock_exclusive(thisEngine); 25061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_exclusive(this); 251d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten if (NULL != destroy) 252d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten (*destroy)(this); 25361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // Call the deinitializer for each currently exposed interface, 25461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // whether it is implicit, explicit, optional, or dynamically added. 25561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten unsigned exposedMask = this->mExposedMask; 25661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten for ( ; exposedMask; exposedMask >>= 1, ++x) { 25761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (exposedMask & 1) { 25861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten VoidHook deinit = MPH_init_table[x->mMPH].mDeinit; 25961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL != deinit) 26061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten (*deinit)((char *) this + x->mOffset); 26161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 26261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 26361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // redundant: this->mState = SL_OBJECT_STATE_UNREALIZED; 26461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_exclusive(this); 26561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten#ifndef NDEBUG 26661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten memset(this, 0x55, class__->mSize); 26761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten#endif 26861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten free(this); 26961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 27061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 2713a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kastenstatic SLresult IObject_SetPriority(SLObjectItf self, SLint32 priority, SLboolean preemptable) 27261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 27361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 27461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_exclusive(this); 27561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mPriority = priority; 276d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mPreemptable = SL_BOOLEAN_FALSE != preemptable; // normalize 27761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_exclusive(this); 27861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_SUCCESS; 27961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 28061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 2813a413f1863daa026ed2b9fc9eac01e1341116cdbGlenn Kastenstatic SLresult IObject_GetPriority(SLObjectItf self, SLint32 *pPriority, SLboolean *pPreemptable) 28261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 28361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL == pPriority || NULL == pPreemptable) 28461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_PARAMETER_INVALID; 28561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 28661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_shared(this); 28761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLint32 priority = this->mPriority; 28861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLboolean preemptable = this->mPreemptable; 28961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_shared(this); 29061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten *pPriority = priority; 29161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten *pPreemptable = preemptable; 29261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_SUCCESS; 29361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 29461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 29561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic SLresult IObject_SetLossOfControlInterfaces(SLObjectItf self, 29661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLint16 numInterfaces, SLInterfaceID *pInterfaceIDs, SLboolean enabled) 29761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 29861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (0 < numInterfaces) { 29961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLuint32 i; 30061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL == pInterfaceIDs) 30161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_PARAMETER_INVALID; 30261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 30361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten const ClassTable *class__ = this->mClass; 30461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten unsigned lossOfControlMask = 0; 30561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten // FIXME The cast is due to a typo in the spec 30661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten for (i = 0; i < (SLuint32) numInterfaces; ++i) { 30761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten SLInterfaceID iid = pInterfaceIDs[i]; 30861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (NULL == iid) 30961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_PARAMETER_INVALID; 31061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten int MPH, index; 31161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (0 <= (MPH = IID_to_MPH(iid)) && 31261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten (0 <= (index = class__->mMPH_to_index[MPH]))) 31361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten lossOfControlMask |= (1 << index); 31461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 31561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_lock_exclusive(this); 31661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten if (enabled) 31761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mLossOfControlMask |= lossOfControlMask; 31861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten else 31961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mLossOfControlMask &= ~lossOfControlMask; 32061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten object_unlock_exclusive(this); 32161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten } 32261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten return SL_RESULT_SUCCESS; 32361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 32461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 32561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenstatic const struct SLObjectItf_ IObject_Itf = { 32661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_Realize, 32761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_Resume, 32861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_GetState, 32961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_GetInterface, 33061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_RegisterCallback, 33161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_AbortAsyncOperation, 33261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_Destroy, 33361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_SetPriority, 33461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_GetPriority, 33561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject_SetLossOfControlInterfaces, 33661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten}; 33761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten 33861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kastenvoid IObject_init(void *self) 33961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten{ 34061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten IObject *this = (IObject *) self; 34161ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mItf = &IObject_Itf; 3420b167267bda99b68346045ccab14e810121d5de4Glenn Kasten // initialized in construct: 3430b167267bda99b68346045ccab14e810121d5de4Glenn Kasten // mClass 344ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // mInstanceID 3450b167267bda99b68346045ccab14e810121d5de4Glenn Kasten // mExposedMask 3460b167267bda99b68346045ccab14e810121d5de4Glenn Kasten // mLossOfControlMask 347ccdf07b17f23b4c040dd3f62478d0965eba804e3Glenn Kasten // mEngine 34861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mState = SL_OBJECT_STATE_UNREALIZED; 34961ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mCallback = NULL; 35061ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mContext = NULL; 351d2a7f0d6883a6d3835642e7b282f05ed1c54fe63Glenn Kasten this->mPriority = SL_PRIORITY_NORMAL; 35261ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten this->mPreemptable = SL_BOOLEAN_FALSE; 35361ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten int ok; 35461ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten ok = pthread_mutex_init(&this->mMutex, (const pthread_mutexattr_t *) NULL); 35561ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten assert(0 == ok); 35661ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten ok = pthread_cond_init(&this->mCond, (const pthread_condattr_t *) NULL); 35761ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten assert(0 == ok); 35861ac0ade16f84d877dfd8d0e984eb203d4a2901dGlenn Kasten} 359