X-Git-Url: https://git.saurik.com/apple/security.git/blobdiff_plain/80e2389990082500d76eb566d4946be3e786c3ef..d8f41ccd20de16f8ebe2ccc84d47bf1cb2b26bbb:/libsecurity_utilities/lib/threading.cpp

diff --git a/libsecurity_utilities/lib/threading.cpp b/libsecurity_utilities/lib/threading.cpp
deleted file mode 100644
index 0d387181..00000000
--- a/libsecurity_utilities/lib/threading.cpp
+++ /dev/null
@@ -1,266 +0,0 @@
-/*
- * 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 (...)
-    {
-        return NULL;
-    }
-}
-
-void Thread::yield()
-{
-	::sched_yield();
-}
-
-
-//
-// ThreadRunner implementation
-//
-ThreadRunner::ThreadRunner(Action *todo)
-{
-    mAction = todo;
-    run();
-}
-
-void ThreadRunner::action()
-{
-    mAction();
-}