pthread.c File Reference

#include <stdbool.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <pthread.h>
#include <core/mutex.h>
#include <syscall.h>
#include <sys/syscall.h>

Include dependency graph for pthread.c:

Go to the source code of this file.

Data Structures
struct	pthread_attr
struct	pthread
struct	pthread_mutexattr
struct	pthread_mutex
struct	pthread_condattr
struct	pthread_cond

Macros
#define	THREAD_HASH_SLOTS   32

Functions
typedef	TAILQ_HEAD (pthreadList, pthread)
void	__pthread_init (void)
pthread_t	pthread_self (void)
void	pthreadCreateHelper (void *arg)
int	pthread_create (pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
void	pthread_exit (void *value_ptr)
int	pthread_join (pthread_t thread, void **value_ptr)
void	pthread_yield (void)
int	pthread_barrier_init (pthread_barrier_t *barrier, const pthread_barrierattr_t *attr, unsigned count)
int	pthread_barrier_destroy (pthread_barrier_t *barrier)
int	pthread_barrier_wait (pthread_barrier_t *barrier)
int	pthread_mutex_init (pthread_mutex_t *mutex, const pthread_mutexattr_t *attr)
int	pthread_mutex_destroy (pthread_mutex_t *mutex)
int	pthread_mutex_lock (pthread_mutex_t *mutex)
int	pthread_mutex_trylock (pthread_mutex_t *mutex)
int	pthread_mutex_unlock (pthread_mutex_t *mutex)
int	pthread_cond_init (pthread_cond_t *cond, const pthread_condattr_t *attr)
int	pthread_cond_destroy (pthread_cond_t *cond)
int	pthread_cond_wait (pthread_cond_t *cond, pthread_mutex_t *mutex)
int	pthread_cond_timedwait (pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime)
int	pthread_cond_signal (pthread_cond_t *cond)
int	pthread_cond_broadcast (pthread_cond_t *cond)

---

Data Structure Documentation

pthread_attr

struct pthread_attr

Definition at line 17 of file pthread.c.

Collaboration diagram for pthread_attr:

Data Fields
uint64_t	_unused

pthread

struct pthread

Definition at line 21 of file pthread.c.

Collaboration diagram for pthread:

Data Fields
int	error
uint64_t	tid

pthread_mutexattr

struct pthread_mutexattr

Definition at line 206 of file pthread.c.

Collaboration diagram for pthread_mutexattr:

Data Fields
uint64_t	_unused

pthread_mutex

struct pthread_mutex

Definition at line 210 of file pthread.c.

Collaboration diagram for pthread_mutex:

Data Fields
uint64_t	lock

pthread_condattr

struct pthread_condattr

Definition at line 315 of file pthread.c.

Collaboration diagram for pthread_condattr:

Data Fields
uint64_t	_unused

pthread_cond

struct pthread_cond

Definition at line 319 of file pthread.c.

Collaboration diagram for pthread_cond:

Data Fields
uint64_t	enter
uint64_t	exit
CoreMutex	mtx

Macro Definition Documentation

THREAD_HASH_SLOTS

#define THREAD_HASH_SLOTS   32

Function Documentation

__pthread_init()

void __pthread_init

(

void

)

Definition at line 53 of file pthread.c.

{
    int i;
    struct pthread *thr = (struct pthread *)malloc(sizeof(*thr));
 
    for (i = 0; i < THREAD_HASH_SLOTS; i++) {
        TAILQ_INIT(&__threads[i]);
    }
 
    if (thr == NULL) {
        abort();
    }
 
    thr->tid = OSGetTID();
    thr->error = 0;
    thr->entry = NULL;
    thr->arg = 0;
 
    CoreMutex_Init(&__threadTableLock);
 
    CoreMutex_Lock(&__threadTableLock);
    TAILQ_INSERT_HEAD(&__threads[thr->tid % THREAD_HASH_SLOTS], thr, threadTable);
    CoreMutex_Unlock(&__threadTableLock);
}

Here is the call graph for this function:

pthread_barrier_destroy()

int pthread_barrier_destroy

(

pthread_barrier_t *

barrier

)

Definition at line 191 of file pthread.c.

{
    return EINVAL;
}

pthread_barrier_init()

int pthread_barrier_init	(	pthread_barrier_t *	barrier,
		const pthread_barrierattr_t *	attr,
		unsigned	count
	)

Definition at line 183 of file pthread.c.

{
    return EINVAL;
}

pthread_barrier_wait()

int pthread_barrier_wait

(

pthread_barrier_t *

barrier

)

Definition at line 197 of file pthread.c.

{
    return EINVAL;
}

pthread_cond_broadcast()

int pthread_cond_broadcast

(

pthread_cond_t *

cond

)

Definition at line 459 of file pthread.c.

{
    struct pthread_cond *cnd;
 
    if (*cond == NULL) {
        int status = pthread_cond_init(cond, NULL);
        if (status != 0)
            return status;
    }
    cnd = *cond;
 
    CoreMutex_Lock(&cnd->mtx);
    cnd->exit = cnd->enter;
    CoreMutex_Unlock(&cnd->mtx);
 
    return 0;
}

Here is the call graph for this function:

pthread_cond_destroy()

int pthread_cond_destroy

(

pthread_cond_t *

cond

)

Definition at line 344 of file pthread.c.

{
    struct pthread_cond *cnd = *cond;
 
    *cond = NULL;
    free(cnd);
 
    return 0;
}

Here is the call graph for this function:

pthread_cond_init()

int pthread_cond_init	(	pthread_cond_t *	cond,
		const pthread_condattr_t *	attr
	)

Definition at line 326 of file pthread.c.

{
    struct pthread_cond *cnd = (struct pthread_cond *)malloc(sizeof(*cnd));
 
    if (cnd == NULL) {
        return ENOMEM;
    }
 
    CoreMutex_Init(&cnd->mtx);
    cnd->enter = 0;
    cnd->exit = 0;
 
    *cond = cnd;
 
    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pthread_cond_signal()

int pthread_cond_signal

(

pthread_cond_t *

cond

)

Definition at line 440 of file pthread.c.

{
    struct pthread_cond *cnd;
 
    if (*cond == NULL) {
        int status = pthread_cond_init(cond, NULL);
        if (status != 0)
            return status;
    }
    cnd = *cond;
 
    CoreMutex_Lock(&cnd->mtx);
    cnd->exit++;
    CoreMutex_Unlock(&cnd->mtx);
 
    return 0;
}

Here is the call graph for this function:

pthread_cond_timedwait()

int pthread_cond_timedwait	(	pthread_cond_t *	cond,
		pthread_mutex_t *	mutex,
		const struct timespec *	abstime
	)

Definition at line 393 of file pthread.c.

{
    int status = 0;
    int rstatus = 0;
    struct pthread_cond *cnd;
    uint64_t level;
    uint64_t endtime = abstime->tv_sec * 1000000000 + abstime->tv_nsec;
 
    if (*cond == NULL) {
        status = pthread_cond_init(cond, NULL);
        if (status != 0)
            return status;
    }
    cnd = *cond;
 
    if (mutex) {
        status = pthread_mutex_unlock(mutex);
        if (status != 0)
            return status;
    }
 
    CoreMutex_Lock(&cnd->mtx);
    level = cnd->enter;
    cnd->enter++;
    CoreMutex_Unlock(&cnd->mtx);
 
    while (level >= cnd->exit) {
        OSThreadSleep(0);
 
        if (endtime < OSTime()) {
            rstatus = ETIMEDOUT;
            break;
        }
    }
 
    if (mutex) {
        status = pthread_mutex_lock(mutex);
        if (status != 0)
            return status;
    }
 
    return rstatus;
}

Here is the call graph for this function:

pthread_cond_wait()

int pthread_cond_wait	(	pthread_cond_t *	cond,
		pthread_mutex_t *	mutex
	)

Definition at line 355 of file pthread.c.

{
    int status;
    struct pthread_cond *cnd;
    uint64_t level;
 
    if (*cond == NULL) {
        status = pthread_cond_init(cond, NULL);
        if (status != 0)
            return status;
    }
    cnd = *cond;
 
    if (mutex) {
        status = pthread_mutex_unlock(mutex);
        if (status != 0)
            return status;
    }
 
    CoreMutex_Lock(&cnd->mtx);
    level = cnd->enter;
    cnd->enter++;
    CoreMutex_Unlock(&cnd->mtx);
 
    while (level >= cnd->exit) {
        OSThreadSleep(0);
    }
 
    if (mutex) {
        status = pthread_mutex_lock(mutex);
        if (status != 0)
            return status;
    }
 
    return 0;
}

Here is the call graph for this function:

pthread_create()

int pthread_create	(	pthread_t *	thread,
		const pthread_attr_t *	attr,
		void *(*)(void *)	start_routine,
		void *	arg
	)

Definition at line 108 of file pthread.c.

{
    uint64_t status;
    struct pthread *thr;
 
    thr = malloc(sizeof(*thr));
    if (!thr) {
        return EAGAIN;
    }
 
    memset(thr, 0, sizeof(*thr));
 
    thr->entry = start_routine;
    thr->arg = arg;
 
    status = OSThreadCreate((uintptr_t)&pthreadCreateHelper, (uint64_t)thr);
    if (SYSCALL_ERRCODE(status) != 0) {
        free(thr);
        return SYSCALL_ERRCODE(status);
    }
 
    thr->tid = SYSCALL_VALUE(status);
 
    CoreMutex_Lock(&__threadTableLock);
    TAILQ_INSERT_HEAD(&__threads[thr->tid % THREAD_HASH_SLOTS], thr, threadTable);
    CoreMutex_Unlock(&__threadTableLock);
 
    *thread = thr;
 
    return 0;
}

Here is the call graph for this function:

pthread_exit()

void pthread_exit

(

void *

value_ptr

)

Definition at line 142 of file pthread.c.

{
    struct pthread *thr = pthread_self();
 
    thr->result = value_ptr;
 
    OSThreadExit(0);
}

Here is the call graph for this function:

pthread_join()

int pthread_join	(	pthread_t	thread,
		void **	value_ptr
	)

Definition at line 152 of file pthread.c.

{
    struct pthread *thr = thread;
    uint64_t status = OSThreadWait(0);//thr->tid);
    if (SYSCALL_ERRCODE(status) != 0) {
        return status;
    }
 
    *value_ptr = (void *)thr->result;
 
    CoreMutex_Lock(&__threadTableLock);
    TAILQ_REMOVE(&__threads[thr->tid % THREAD_HASH_SLOTS], thr, threadTable);
    CoreMutex_Unlock(&__threadTableLock);
 
    // Cleanup
    free(thr);
 
    return 0;
}

Here is the call graph for this function:

pthread_mutex_destroy()

int pthread_mutex_destroy

(

pthread_mutex_t *

mutex

)

Definition at line 230 of file pthread.c.

{
    struct pthread_mutex *mtx = *mutex;
 
    if (mtx == NULL) {
        return EINVAL;
    } else if (mtx->lock == 1) {
        return EBUSY;
    } else {
        *mutex = NULL;
        free(mtx);
        return 0;
    }
}

Here is the call graph for this function:

pthread_mutex_init()

int pthread_mutex_init	(	pthread_mutex_t *	mutex,
		const pthread_mutexattr_t *	attr
	)

Definition at line 215 of file pthread.c.

{
    struct pthread_mutex *mtx = (struct pthread_mutex *)malloc(sizeof(*mtx));
 
    if (mtx == NULL) {
        return ENOMEM;
    }
 
    mtx->lock = 0;
    *mutex = mtx;
 
    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pthread_mutex_lock()

int pthread_mutex_lock

(

pthread_mutex_t *

mutex

)

Definition at line 246 of file pthread.c.

{
    struct pthread_mutex *mtx;
    
    if (*mutex == NULL) {
        int status = pthread_mutex_init(mutex, NULL);
        if (status != 0)
            return status;
    }
 
    mtx = *mutex;
 
    // XXX: Should have the kernel wait kernel instead of yielding
    while (__sync_lock_test_and_set(&mtx->lock, 1) == 1) {
        OSThreadSleep(0);
    }
 
    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pthread_mutex_trylock()

int pthread_mutex_trylock

(

pthread_mutex_t *

mutex

)

Definition at line 267 of file pthread.c.

{
    struct pthread_mutex *mtx;
 
    if (*mutex == NULL) {
        int status = pthread_mutex_init(mutex, NULL);
        if (status != 0)
            return status;
    }
 
    mtx = *mutex;
 
    if (__sync_lock_test_and_set(&mtx->lock, 1) == 1) {
        return EBUSY;
    } else {
        // Lock acquired
        return 0;
    }
}

Here is the call graph for this function:

pthread_mutex_unlock()

int pthread_mutex_unlock

(

pthread_mutex_t *

mutex

)

Definition at line 288 of file pthread.c.

{
    struct pthread_mutex *mtx;
 
    if (*mutex == NULL) {
        int status = pthread_mutex_init(mutex, NULL);
        if (status != 0)
            return status;
    }
 
    mtx = *mutex;
 
    __sync_lock_release(&mtx->lock);
    // XXX: Wakeup a sleeping thread
 
    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

pthread_self()

pthread_t pthread_self

(

void

)

Definition at line 79 of file pthread.c.

{
    int tid = OSGetTID();
    struct pthread *thr;
 
    CoreMutex_Lock(&__threadTableLock);
    TAILQ_FOREACH(thr, &__threads[tid % THREAD_HASH_SLOTS], threadTable) {
        if (thr->tid == tid) {
            CoreMutex_Unlock(&__threadTableLock);
            return thr;
        }
    }
    CoreMutex_Unlock(&__threadTableLock);
 
    printf("pthread_self failed to find current thread!\n");
    abort();
}

Here is the call graph for this function:

Here is the caller graph for this function:

pthread_yield()

void pthread_yield

(

void

)

Definition at line 173 of file pthread.c.

{
    OSThreadSleep(0);
}

Here is the call graph for this function:

pthreadCreateHelper()

void pthreadCreateHelper

(

void *

arg

)

Definition at line 98 of file pthread.c.

{
    struct pthread *thr = (struct pthread *)arg;
 
    thr->result = (thr->entry)(thr->arg);
 
    OSThreadExit(0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

TAILQ_HEAD()

typedef TAILQ_HEAD	(		pthreadList,
		pthread
	)

Definition at line 37 of file pthread.c.

{
    struct pthread *pth = pthread_self();
 
    return &(pth->error);
}

Here is the call graph for this function: