--- /dev/null
+/*
+ * Copyright (c) 2000-2004 Apple Computer, Inc. All Rights Reserved.
+ *
+ * @APPLE_LICENSE_HEADER_START@
+ *
+ * This file contains Original Code and/or Modifications of Original Code
+ * as defined in and that are subject to the Apple Public Source License
+ * Version 2.0 (the 'License'). You may not use this file except in
+ * compliance with the License. Please obtain a copy of the License at
+ * http://www.opensource.apple.com/apsl/ and read it before using this
+ * file.
+ *
+ * The Original Code and all software distributed under the License are
+ * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
+ * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
+ * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
+ * Please see the License for the specific language governing rights and
+ * limitations under the License.
+ *
+ * @APPLE_LICENSE_HEADER_END@
+ */
+
+
+//
+// threading - generic thread support
+//
+#include <security_utilities/threading.h>
+#include <security_utilities/globalizer.h>
+#include <security_utilities/memutils.h>
+
+#include <unistd.h> // WWDC 2007 thread-crash workaround
+#include <syslog.h> // WWDC 2007 thread-crash workaround
+
+//
+// Thread-local storage primitive
+//
+ThreadStoreSlot::ThreadStoreSlot(Destructor *destructor)
+{
+ if (int err = pthread_key_create(&mKey, destructor))
+ UnixError::throwMe(err);
+}
+
+ThreadStoreSlot::~ThreadStoreSlot()
+{
+ //@@@ if we wanted to dispose of pending task objects, we'd have
+ //@@@ to keep a set of them and delete them explicitly here
+ pthread_key_delete(mKey);
+}
+
+
+//
+// Mutex implementation
+//
+struct MutexAttributes {
+ pthread_mutexattr_t recursive;
+ pthread_mutexattr_t checking;
+
+ MutexAttributes()
+ {
+ pthread_mutexattr_init(&recursive);
+ pthread_mutexattr_settype(&recursive, PTHREAD_MUTEX_RECURSIVE);
+#if !defined(NDEBUG)
+ pthread_mutexattr_init(&checking);
+ pthread_mutexattr_settype(&checking, PTHREAD_MUTEX_ERRORCHECK);
+#endif //NDEBUG
+ }
+};
+
+static ModuleNexus<MutexAttributes> mutexAttrs;
+
+
+Mutex::Mutex()
+{
+ check(pthread_mutex_init(&me, NULL));
+}
+
+Mutex::Mutex(Type type)
+{
+ switch (type) {
+ case normal:
+ check(pthread_mutex_init(&me, IFELSEDEBUG(&mutexAttrs().checking, NULL)));
+ break;
+ case recursive: // requested recursive (is also checking, always)
+ check(pthread_mutex_init(&me, &mutexAttrs().recursive));
+ break;
+ };
+}
+
+
+Mutex::~Mutex()
+{
+ int result = pthread_mutex_destroy(&me);
+ check(result);
+}
+
+
+void Mutex::lock()
+{
+ check(pthread_mutex_lock(&me));
+}
+
+
+bool Mutex::tryLock()
+{
+ if (int err = pthread_mutex_trylock(&me)) {
+ if (err != EBUSY)
+ UnixError::throwMe(err);
+ return false;
+ }
+
+ return true;
+}
+
+
+void Mutex::unlock()
+{
+ int result = pthread_mutex_unlock(&me);
+ check(result);
+}
+
+
+//
+// Condition variables
+//
+Condition::Condition(Mutex &lock) : mutex(lock)
+{
+ check(pthread_cond_init(&me, NULL));
+}
+
+Condition::~Condition()
+{
+ check(pthread_cond_destroy(&me));
+}
+
+void Condition::wait()
+{
+ check(pthread_cond_wait(&me, &mutex.me));
+}
+
+void Condition::signal()
+{
+ check(pthread_cond_signal(&me));
+}
+
+void Condition::broadcast()
+{
+ check(pthread_cond_broadcast(&me));
+}
+
+
+//
+// CountingMutex implementation.
+//
+void CountingMutex::enter()
+{
+ lock();
+ mCount++;
+ secdebug("cmutex", "%p up to %d", this, mCount);
+ unlock();
+}
+
+bool CountingMutex::tryEnter()
+{
+ if (!tryLock())
+ return false;
+ mCount++;
+ secdebug("cmutex", "%p up to %d (was try)", this, mCount);
+ unlock();
+ return true;
+}
+
+void CountingMutex::exit()
+{
+ lock();
+ assert(mCount > 0);
+ mCount--;
+ secdebug("cmutex", "%p down to %d", this, mCount);
+ unlock();
+}
+
+void CountingMutex::finishEnter()
+{
+ mCount++;
+ secdebug("cmutex", "%p finish up to %d", this, mCount);
+ unlock();
+}
+
+void CountingMutex::finishExit()
+{
+ assert(mCount > 0);
+ mCount--;
+ secdebug("cmutex", "%p finish down to %d", this, mCount);
+ unlock();
+}
+
+
+
+//
+// Threads implementation
+//
+Thread::~Thread()
+{
+}
+
+void Thread::run()
+{
+ pthread_attr_t ptattrs;
+ int err, ntries = 10; // 10 is arbitrary
+
+ if ((err = pthread_attr_init(&ptattrs)) ||
+ (err = pthread_attr_setdetachstate(&ptattrs, PTHREAD_CREATE_DETACHED)))
+ {
+ syslog(LOG_ERR, "error %d setting thread detach state", err);
+ }
+ while (err = pthread_create(&self.mIdent, &ptattrs, runner, this) &&
+ --ntries)
+ {
+ syslog(LOG_ERR, "pthread_create() error %d", err);
+ usleep(50000); // 50 ms is arbitrary
+ }
+ if (err)
+ {
+ syslog(LOG_ERR, "too many failed pthread_create() attempts");
+ }
+ else
+ secdebug("thread", "%p created", self.mIdent);
+}
+
+void *Thread::runner(void *arg)
+{
+ try // the top level of any running thread of execution must have a try/catch around it,
+ // otherwise it will crash if something underneath throws.
+ {
+ Thread *me = static_cast<Thread *>(arg);
+ secdebug("thread", "%p starting", me->self.mIdent);
+ me->action();
+ secdebug("thread", "%p terminating", me->self.mIdent);
+ delete me;
+ return NULL;
+ }
+ catch (...)
+ {
+ }
+}
+
+void Thread::yield()
+{
+ ::sched_yield();
+}
+
+
+//
+// ThreadRunner implementation
+//
+ThreadRunner::ThreadRunner(Action *todo)
+{
+ mAction = todo;
+ run();
+}
+
+void ThreadRunner::action()
+{
+ mAction();
+}
projects / apple / security.git / blobdiff