original

[gb-231r1-is01/GB_2.3_IS01.git] / system / media / opensles / libopensles / IThreadSync.c

diff --git a/system/media/opensles/libopensles/IThreadSync.c b/system/media/opensles/libopensles/IThreadSync.c
new file mode 100644 (file)
index 0000000..937e4c6
--- /dev/null
+++ b/system/media/opensles/libopensles/IThreadSync.c
@@ -0,0 +1,93 @@
+/*
+ * Copyright (C) 2010 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.
+ */
+
+/* ThreadSync implementation */
+
+#include "sles_allinclusive.h"
+
+
+static SLresult IThreadSync_EnterCriticalSection(SLThreadSyncItf self)
+{
+    SL_ENTER_INTERFACE
+
+    IThreadSync *this = (IThreadSync *) self;
+    interface_lock_exclusive(this);
+    for (;;) {
+        if (this->mInCriticalSection) {
+            if (!pthread_equal(this->mOwner, pthread_self())) {
+                ++this->mWaiting;
+                interface_cond_wait(this);
+                continue;
+            }
+            // nested locks are not allowed
+            result = SL_RESULT_PRECONDITIONS_VIOLATED;
+            break;
+        }
+        this->mInCriticalSection = SL_BOOLEAN_TRUE;
+        this->mOwner = pthread_self();
+        result = SL_RESULT_SUCCESS;
+        break;
+    }
+    interface_unlock_exclusive(this);
+
+    SL_LEAVE_INTERFACE
+}
+
+
+static SLresult IThreadSync_ExitCriticalSection(SLThreadSyncItf self)
+{
+    SL_ENTER_INTERFACE
+
+    IThreadSync *this = (IThreadSync *) self;
+    interface_lock_exclusive(this);
+    if (!this->mInCriticalSection || !pthread_equal(this->mOwner, pthread_self())) {
+        result = SL_RESULT_PRECONDITIONS_VIOLATED;
+    } else {
+        this->mInCriticalSection = SL_BOOLEAN_FALSE;
+        memset(&this->mOwner, 0, sizeof(pthread_t));
+        if (this->mWaiting) {
+            --this->mWaiting;
+            interface_cond_signal(this);
+        }
+        result = SL_RESULT_SUCCESS;
+    }
+    interface_unlock_exclusive(this);
+
+    SL_LEAVE_INTERFACE
+}
+
+
+static const struct SLThreadSyncItf_ IThreadSync_Itf = {
+    IThreadSync_EnterCriticalSection,
+    IThreadSync_ExitCriticalSection
+};
+
+void IThreadSync_init(void *self)
+{
+    IThreadSync *this = (IThreadSync *) self;
+    this->mItf = &IThreadSync_Itf;
+    this->mInCriticalSection = SL_BOOLEAN_FALSE;
+    this->mWaiting = 0;
+    memset(&this->mOwner, 0, sizeof(pthread_t));
+}
+
+void IThreadSync_deinit(void *self)
+{
+    IThreadSync *this = (IThreadSync *) self;
+    if (this->mInCriticalSection) {
+        SL_LOGW("ThreadSync::EnterCriticalSection was active at Engine::Destroy");
+    }
+}