task_pthread.h File Reference

#include <zrtos/error.h>
#include <zrtos/malloc.h>
#include <zrtos/task_scheduler.h>
#include <zrtos/task_mutex.h>
#include <zrtos/types.h>

Include dependency graph for task_pthread.h:

Go to the source code of this file.

Data Structures
struct	pthread_attr_t
struct	pthread_t
struct	pthread_mutexattr_t
struct	pthread_mutex_t
struct	zrtos_task_pthread__trampoline_cb_args_t

Macros
#define	PTHREAD_MUTEX_INITIALIZER

Functions
void *	zrtos_task_pthread__get_heap (void)
void	zrtos_task_pthread__set_heap (void *heap)
int	pthread_attr_init (pthread_attr_t *attr)
int	pthread_attr_destroy (pthread_attr_t *attr)
int	pthread_attr_setstacksize (pthread_attr_t *attr, size_t stacksize)
int	pthread_mutexattr_init (pthread_mutexattr_t *attr)
int	pthread_mutexattr_destroy (pthread_mutexattr_t *attr)
int	pthread_mutex_init (pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr)
int	pthread_mutex_destroy (pthread_mutex_t *mutex)
pthread_t	pthread_self (void)
void	zrtos_task_pthread__trampoline_cb (void *args)
int	pthread_create (pthread_t *restrict thread, const pthread_attr_t *restrict attr, void *(*start_routine)(void *), void *restrict arg)
int	pthread_equal (pthread_t t1, pthread_t t2)
static void	zrtos_task_pthread__free (zrtos_task_t *task)
int	pthread_join (pthread_t thread, void **retval)
int	pthread_mutex_lock (pthread_mutex_t *mutex)
int	pthread_mutex_trylock (pthread_mutex_t *mutex)
int	pthread_mutex_unlock (pthread_mutex_t *mutex)

Variables
void *	zrtos_task_pthread__heap

Macro Definition Documentation

PTHREAD_MUTEX_INITIALIZER

#define PTHREAD_MUTEX_INITIALIZER

Value:

{                                          \
        .mutex = ZRTOS_TASK_MUTEX__INITIALIZER \
    }

Definition at line 42 of file task_pthread.h.

Function Documentation

pthread_attr_destroy()

int pthread_attr_destroy

(

pthread_attr_t *

attr

)

Definition at line 65 of file task_pthread.h.

                                              {
    return 0;
}

pthread_attr_init()

int pthread_attr_init

(

pthread_attr_t *

attr

)

Definition at line 58 of file task_pthread.h.

                                           {
    attr->stacksize = ZRTOS_ARCH__GET_CPU_STATE_BUFFER_LENGTH()
                    + ZRTOS_ARCH__GET_FN_CALL_STACK_LENGTH()
    ;
    return 0;
}

pthread_attr_setstacksize()

int pthread_attr_setstacksize	(	pthread_attr_t *	attr,
		size_t	stacksize
	)

Definition at line 69 of file task_pthread.h.

                                                                     {
    attr->stacksize = stacksize;
    return 0;
}

pthread_create()

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

Definition at line 117 of file task_pthread.h.

 {
    int ret = ZRTOS_ERROR__NOMEM;

    ZRTOS_TASK_SCHEDULER__DO_NOT_DISTURB({
        size_t stack_size_min = ZRTOS_ARCH__GET_CPU_STATE_BUFFER_LENGTH()
                              + ZRTOS_ARCH__GET_FN_CALL_STACK_LENGTH()
        ;
        zrtos_malloc_t *mem = (zrtos_malloc_t*)zrtos_task_pthread__get_heap();
        size_t stacksize_min = sizeof(zrtos_task_t)
                             + sizeof(zrtos_task_pthread__trampoline_cb_args_t)
                             + (
            attr
            ? ZRTOS_TYPES__MAX(
                stack_size_min
                ,attr->stacksize
            )
            : stack_size_min
        );
        zrtos_task_t *task = zrtos_malloc__malloc(
            mem
            ,stacksize_min
        );
        if(task){
            void *mem_chunk_last_address = zrtos_types__ptr_add(
                 task
                ,stacksize_min-1
            );
            zrtos_task_pthread__trampoline_cb_args_t *args = zrtos_types__ptr_add(
                 task
                ,sizeof(zrtos_task_t)
            );
            args->callback = start_routine;
            args->args = arg;
            zrtos_task__init_ex(
                 task
                ,(zrtos_arch_stack_t*)mem_chunk_last_address
                ,zrtos_task_pthread__trampoline_cb
                ,args
            );
            zrtos_task_scheduler__add_task(task);

            thread->task = task;
            ret = 0;
        }
    });

    return ret;
}

Here is the call graph for this function:

pthread_equal()

int pthread_equal	(	pthread_t	t1,
		pthread_t	t2
	)

Definition at line 171 of file task_pthread.h.

                                             {
    return zrtos_types__ptr_cmp(t1.task,t1.task);
}

Here is the call graph for this function:

pthread_join()

int pthread_join	(	pthread_t	thread,
		void **	retval
	)

Definition at line 191 of file task_pthread.h.

                                                 {
    int ret = ZRTOS_ERROR__AGAIN;
    zrtos_task_t *task = thread.task;

    while(true){
        ZRTOS_TASK_SCHEDULER__DO_NOT_DISTURB({
            if(zrtos_task_scheduler__has_task(task)){
                if(zrtos_task__is_done(task)){
                    zrtos_task_pthread__trampoline_cb_args_t *args = 
                        (zrtos_task_pthread__trampoline_cb_args_t *)(task+1)
                    ;
                    if(retval){
                        *retval = args->return_value;
                    }
                    zrtos_task_pthread__free(task);
                    ret = 0;
                }
            }else{
                ret = ESRCH;
            }
        });
        
        if(ret == ZRTOS_ERROR__AGAIN){
            _zrtos_task_scheduler__on_tick_ex();
        }else{
            break;
        }
    }

    return ret;
}

Here is the call graph for this function:

pthread_mutex_destroy()

int pthread_mutex_destroy

(

pthread_mutex_t *

mutex

)

Definition at line 89 of file task_pthread.h.

                                                 {
    zrtos_task_mutex__deinit(&mutex->mutex);
    return 0;
}

Here is the call graph for this function:

pthread_mutex_init()

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

Definition at line 82 of file task_pthread.h.

 {
    return zrtos_task_mutex__init(&mutex->mutex) ? 0 : ZRTOS_ERROR__INVAL;
}

Here is the call graph for this function:

pthread_mutex_lock()

int pthread_mutex_lock

(

pthread_mutex_t *

mutex

)

Definition at line 223 of file task_pthread.h.

                                              {
    return zrtos_task_mutex__lock(&mutex->mutex);
}

Here is the call graph for this function:

pthread_mutex_trylock()

int pthread_mutex_trylock

(

pthread_mutex_t *

mutex

)

Definition at line 227 of file task_pthread.h.

                                                 {
    return zrtos_task_mutex__try_lock(&mutex->mutex);
}

Here is the call graph for this function:

pthread_mutex_unlock()

int pthread_mutex_unlock

(

pthread_mutex_t *

mutex

)

Definition at line 231 of file task_pthread.h.

                                                {
    return zrtos_task_mutex__unlock(&mutex->mutex);
}

Here is the call graph for this function:

pthread_mutexattr_destroy()

int pthread_mutexattr_destroy

(

pthread_mutexattr_t *

attr

)

Definition at line 78 of file task_pthread.h.

                                                        {
    return 0;
}

pthread_mutexattr_init()

int pthread_mutexattr_init

(

pthread_mutexattr_t *

attr

)

Definition at line 74 of file task_pthread.h.

                                                     {
    return 0;
}

pthread_self()

pthread_t pthread_self

(

void

)

Definition at line 94 of file task_pthread.h.

                            {
    pthread_t ret;
    ret.task = _zrtos_task_scheduler__get_active_task();
    return ret;
}

Here is the call graph for this function:

zrtos_task_pthread__free()

static void zrtos_task_pthread__free ( zrtos_task_t *  task )

static

Definition at line 175 of file task_pthread.h.

                                                        {
    zrtos_task_t *child;

    while((child = zrtos_task_scheduler__get_any_child(task))){
        zrtos_task_t *last = child;
        while((child = zrtos_task_scheduler__get_any_child(child))){
            last = child;
        }
        zrtos_task_scheduler__remove_task(last);
        zrtos_malloc__free(last);
    }

    zrtos_task_scheduler__remove_task(task);
    zrtos_malloc__free(task);
}

Here is the call graph for this function:

Here is the caller graph for this function:

zrtos_task_pthread__get_heap()

void* zrtos_task_pthread__get_heap

(

void

)

Definition at line 50 of file task_pthread.h.

                                        {
    return zrtos_task_pthread__heap;
}

Here is the caller graph for this function:

zrtos_task_pthread__set_heap()

void zrtos_task_pthread__set_heap

(

void *

heap

)

Definition at line 54 of file task_pthread.h.

                                             {
    zrtos_task_pthread__heap = heap;
}

zrtos_task_pthread__trampoline_cb()

void zrtos_task_pthread__trampoline_cb

(

void *

args

)

Definition at line 100 of file task_pthread.h.

                                                                            {
    zrtos_task_pthread__trampoline_cb_args_t *tmp_args = args;
    zrtos_task_t *task = zrtos_types__ptr_subtract(
         tmp_args
        ,sizeof(zrtos_task_t)
    );;
    tmp_args->return_value = tmp_args->callback(tmp_args->args);
    zrtos_task__set_done(task);

    _zrtos_task_scheduler__on_tick_ex();

    __builtin_unreachable();
    while(1){
        //should not return
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

zrtos_task_pthread__heap

void* zrtos_task_pthread__heap

Definition at line 48 of file task_pthread.h.