proc_p.h

Go to the documentation of this file.

#ifndef KERN_PROC_P_H
#define KERN_PROC_P_H

#include "cfg/cfg_proc.h"
#include "cfg/cfg_monitor.h"

#include <cfg/compiler.h>

#include <cpu/types.h>        /* for cpu_stack_t */
#include <cpu/irq.h>          // IRQ_ASSERT_DISABLED()

#include <kern/proc.h>   // struct Process

#ifndef asm_switch_context

EXTERN_C void asm_switch_context(cpu_stack_t **new_sp, cpu_stack_t **save_sp);
#endif

#define PF_FREESTACK  BV(0)  
/*\}*/


extern REGISTER Process *current_process;

extern REGISTER List     proc_ready_list;

#if CONFIG_KERN_PRI
# if CONFIG_KERN_PRI_INHERIT
    #define __prio_orig(proc) (proc->orig_pri)
    #define __prio_inh(proc) (LIST_EMPTY(&(proc)->inh_list) ? INT_MIN : \
                    ((PriNode *)LIST_HEAD(&proc->inh_list))->pri)
    #define __prio_proc(proc) (__prio_inh(proc) > __prio_orig(proc) ? \
                    __prio_inh(proc) : __prio_orig(proc))
# endif
    #define prio_next() (LIST_EMPTY(&proc_ready_list) ? INT_MIN : \
                    ((PriNode *)LIST_HEAD(&proc_ready_list))->pri)
    #define prio_proc(proc) (proc->link.pri)
    #define prio_curr() prio_proc(current_process)

    #define SCHED_ENQUEUE_INTERNAL(proc) \
            LIST_ENQUEUE(&proc_ready_list, &(proc)->link)
    #define SCHED_ENQUEUE_HEAD_INTERNAL(proc) \
            LIST_ENQUEUE_HEAD(&proc_ready_list, &(proc)->link)
#else
    #define prio_next() 0
    #define prio_proc(proc) 0
    #define prio_curr() 0

    #define SCHED_ENQUEUE_INTERNAL(proc) ADDTAIL(&proc_ready_list, &(proc)->link)
    #define SCHED_ENQUEUE_HEAD_INTERNAL(proc) ADDHEAD(&proc_ready_list, &(proc)->link)
#endif

#define SCHED_ENQUEUE(proc)  do { \
        IRQ_ASSERT_DISABLED(); \
        LIST_ASSERT_VALID(&proc_ready_list); \
        SCHED_ENQUEUE_INTERNAL(proc); \
    } while (0)

#define SCHED_ENQUEUE_HEAD(proc)  do { \
        IRQ_ASSERT_DISABLED(); \
        LIST_ASSERT_VALID(&proc_ready_list); \
        SCHED_ENQUEUE_HEAD_INTERNAL(proc); \
    } while (0)


#if CONFIG_KERN_PRI

INLINE void sched_reenqueue(struct Process *proc)
{
    IRQ_ASSERT_DISABLED();
    LIST_ASSERT_VALID(&proc_ready_list);
    Node *n;
    PriNode *pos = NULL;
    FOREACH_NODE(n, &proc_ready_list)
    {
        if (n == &proc->link.link)
        {
            pos = (PriNode *)n;
            break;
        }
    }

    // only remove and enqueue again if process is already in the ready list
    // otherwise leave it alone
    if (pos)
    {
        REMOVE(&proc->link.link);
        LIST_ENQUEUE(&proc_ready_list, &proc->link);
    }
}
#endif //CONFIG_KERN_PRI

/* Process trampoline */
void proc_entry(void);

/* Schedule another process *without* adding the current one to the ready list. */
void proc_switch(void);

/* Immediately schedule a particular process bypassing the scheduler. */
void proc_wakeup(Process *proc);

/* Initialize a scheduler class. */
void proc_schedInit(void);

#if CONFIG_KERN_MONITOR

    void monitor_init(void);

    void monitor_add(Process *proc, const char *name);

    void monitor_remove(Process *proc);

    void monitor_rename(Process *proc, const char *name);
#endif /* CONFIG_KERN_MONITOR */

/*
 * Quantum related macros are used in the
 * timer module and must be empty when
 * kernel is disabled.
 */
#if (CONFIG_KERN && CONFIG_KERN_PREEMPT)
INLINE int preempt_quantum(void)
{
    extern int _proc_quantum;
    return _proc_quantum;
}

INLINE void proc_decQuantum(void)
{
    extern int _proc_quantum;
    if (_proc_quantum > 0)
        _proc_quantum--;
}

INLINE void preempt_reset_quantum(void)
{
    extern int _proc_quantum;
    _proc_quantum = CONFIG_KERN_QUANTUM;
}
#else /* !(CONFIG_KERN && CONFIG_KERN_PREEMPT) */
INLINE int preempt_quantum(void)
{
    return 0;
}

INLINE void proc_decQuantum(void)
{
}

INLINE void preempt_reset_quantum(void)
{
}
#endif /* (CONFIG_KERN && CONFIG_KERN_PREEMPT) */

#endif /* KERN_PROC_P_H */