initial pthread support (buggy!)

1 files changed, 61 insertions, 0 deletions

diff --git a/threading_pthread.c b/threading_pthread.c
new file mode 100644
index 00000000..76dd65a5
--- /dev/null
+++ b/threading_pthread.c
@@ -0,0 +1,61 @@
+#include <stdio.h>
+#include <pthread.h>
+#include <stdlib.h>
+#include "threading.h"
+
+void thread_start (void (*fn)(uintptr_t ctx), uintptr_t ctx) {
+    printf ("thread_start called!\n");
+    pthread_t tid;
+    pthread_attr_t attr;
+    printf ("pthread_attr_init!\n");
+    int s = pthread_attr_init (&attr);
+    if (s) {
+        printf ("pthread_attr_init failed\n");
+        return;
+    }
+
+    printf ("pthread_create!\n");
+    if (pthread_create (&tid, &attr, (void *(*)(void *))fn, (void*)ctx)) {
+        printf ("pthread_create failed\n");
+        return;
+    }
+    printf ("pthread_attr_destroy!\n");
+    s = pthread_attr_destroy (&attr);
+    if (s) {
+        printf ("pthread_attr_destroy failed\n");
+        return;
+    }
+#if 0
+    void *res;
+    printf ("pthread_join!\n");
+    s = pthread_join (tid, &res);
+    if (s) {
+        printf ("pthread_join failed\n");
+        return;
+    }
+    free (res);
+#endif
+}
+uintptr_t mutex_create (void) {
+    pthread_mutex_t *mtx = malloc (sizeof (pthread_mutex_t));
+    if (pthread_mutex_init (mtx, NULL)) {
+        printf ("pthread_mutex_init failed!\n");
+    }
+    return (uintptr_t)mtx;
+}
+void mutex_free (uintptr_t _mtx) {
+    pthread_mutex_t *mtx = (pthread_mutex_t *)_mtx;
+    mutex_lock (_mtx);
+    mutex_unlock (_mtx);
+    pthread_mutex_destroy (mtx);
+    free (mtx);
+}
+int mutex_lock (uintptr_t _mtx) {
+    pthread_mutex_t *mtx = (pthread_mutex_t *)_mtx;
+    pthread_mutex_lock (mtx);
+}
+int mutex_unlock (uintptr_t _mtx) {
+    pthread_mutex_t *mtx = (pthread_mutex_t *)_mtx;
+    pthread_mutex_unlock (mtx);
+}
+