kthread.c

Go to the documentation of this file.

// SPDX-License-Identifier: GPL-3.0-or-later
 
#include "mos/tasks/schedule.h"
 
#include <mos/lib/structures/hashmap.h>
#include <mos/syslog/printk.h>
#include <mos/tasks/kthread.h>
#include <mos/tasks/process.h>
#include <mos/tasks/task_types.h>
#include <mos/tasks/thread.h>
#include <mos_stdlib.h>
 
static process_t *kthreadd = NULL;
 
typedef struct kthread_arg
{
    thread_entry_t entry;
    void *arg;
} kthread_arg_t;
 
static void kthread_entry(void *arg)
{
    kthread_arg_t *kthread_arg = arg;
    kthread_arg->entry(kthread_arg->arg);
    kfree(kthread_arg);
    thread_exit(current_thread);
}
 
void kthread_init(void)
{
    kthreadd = process_allocate(NULL, "kthreadd");
    MOS_ASSERT_X(kthreadd->pid == 2, "kthreadd should have pid 2");
    hashmap_put(&process_table, kthreadd->pid, kthreadd);
}
 
thread_t *kthread_create(thread_entry_t entry, void *arg, const char *name)
{
    thread_t *thread = kthread_create_no_sched(entry, arg, name);
    scheduler_add_thread(thread);
    return thread;
}
 
thread_t *kthread_create_no_sched(thread_entry_t entry, void *arg, const char *name)
{
    MOS_ASSERT_X(kthreadd, "kthreadd not initialized");
    pr_dinfo2(thread, "creating kernel thread '%s'", name);
    kthread_arg_t *kthread_arg = kmalloc(sizeof(kthread_arg_t));
    kthread_arg->entry = entry;
    kthread_arg->arg = arg;
    thread_t *thread = thread_new(kthreadd, THREAD_MODE_KERNEL, name, 0, NULL);
    platform_context_setup_child_thread(thread, kthread_entry, kthread_arg);
    thread_complete_init(thread);
    return thread;
}