mpipe_thread.h

Go to the documentation of this file.

/*
 * Copyright 2025-2026 NXP
 *
 * SPDX-License-Identifier: Apache-2.0
 */

 
#ifndef ZEPHYR_INCLUDE_MPIPE_MPIPE_THREAD_H_
#define ZEPHYR_INCLUDE_MPIPE_MPIPE_THREAD_H_

 
#include <zephyr/kernel/thread.h>
#include <zephyr/sys/atomic.h>

/* Thread state: paused and resumable, running, or terminated */
enum mpipe_thread_state {
        MPIPE_THREAD_PAUSED = 0,
        MPIPE_THREAD_RUNNING,
        MPIPE_THREAD_TERMINATED,
};

struct mpipe_thread {
        struct k_thread thread;
        /* Gates run / pause transitions */
        struct k_sem sem;
        uint8_t stack_id;
        /* enum mpipe_thread_state */
        atomic_t state;
        int priority;
};

k_tid_t mpipe_thread_create(struct mpipe_thread *thread, k_thread_entry_t func, void *p1, void *p2,
                            void *p3, int priority, k_timeout_t delay);

int mpipe_thread_wait(struct mpipe_thread *thread);

void mpipe_thread_resume(struct mpipe_thread *thread);

void mpipe_thread_pause(struct mpipe_thread *thread);

int mpipe_thread_join(struct mpipe_thread *thread, k_timeout_t timeout);

 
#endif /* ZEPHYR_INCLUDE_MPIPE_MPIPE_THREAD_H_ */