thread.h

gehe zur Dokumentation dieser Datei

#ifndef THREAD_H
#define THREAD_H

#include "cdll.h"
#include "mthread_conf.h"
#include <stdint.h>


#define THREAD_PRIO_HIGHEST 0
#define THREAD_PRIO_LOWEST  (MTHREAD_PRIO_MAX-1)

/* special timeout values */
#define TO_POLL 0x0000
#define TO_INF  0xffff

#define MS_TO_TICKS(ms)        (((ms))/(1000/MTHREAD_FREQ))

enum {
  THREAD_INIT           = 0x00, // not started yet
  THREAD_READY          = 0x01, // in ready list
  THREAD_WAIT           = 0x02, // in wait list
  THREAD_WAITTIME       = 0x03, // in wait timeout list
  THREAD_TIMEOUT_READY  = 0x04  // in ready list, last wait timed out
};

  
typedef struct _thread_s {
  cdll_t list;             // ptr[0...3]
  uint8_t priority;        // ptr[4]
  uint8_t state;           // ptr[5]
  uint16_t signal_cnt;     // ptr[6...7]
  uint16_t wait_timeout;   // ptr[8...9]
  void * stackpointer;     // ptr[10...11]
  cdll_t rivals_list;      // ptr[12...13] Semaphoren, Mutex, etc...
} thread_t;

#define THREAD_FROM_RIVALS_CDLL(cdll) ((thread_t*)(((char*)cdll)-12))


extern thread_t primaryThread;

extern volatile thread_t * running_thread;

typedef void thread_main_t(void * arg);


void thread_startScheduler(uint8_t priority);

void thread_init(thread_t * thread, void * stack, uint16_t stack_size);

void thread_start(thread_t * thread, thread_main_t * mainFunc, void * arg);


void thread_delete(thread_t * thread);

void thread_yield();


void thread_wait();


uint8_t thread_waitTimeout(uint16_t timeout);


void thread_signal(thread_t * thread);


void thread_signalISR(thread_t * thread);


void thread_halt(thread_t * thread);

  
void thread_changePriority(thread_t * thread, uint8_t priority);


void thread_suppressScheduling();


void thread_allowScheduling();


inline static thread_t * thread_getCurrent() {return (thread_t *) running_thread;}


#endif