RAKThread.h

Go to the documentation of this file.

#ifndef __RAK_THREAD_H__
#define __RAK_THREAD_H__

#define LABEL_INIT(s) s = NULL

#define LABEL_RESUME(s)             \
  do {                      \
    if(s != NULL) {             \
      goto *s;                  \
    }                       \
  } while(0)

#define LABEL_CONCAT2(s1, s2) s1##s2
#define LABEL_CONCAT(s1, s2) LABEL_CONCAT2(s1, s2)

#define LABEL_SET(s)                \
  do {                      \
    LABEL_CONCAT(LABEL_LABEL, __LINE__):            \
    (s) = &&LABEL_CONCAT(LABEL_LABEL, __LINE__);    \
  } while(0)

#define LABEL_END(s)

struct rt {
  void *label;
};

#define RT_WAITING 0
#define RT_YIELDED 1
#define RT_EXITED  2
#define RT_ENDED   3

#define RT_INIT(rt)   LABEL_INIT((rt)->label)

#define RT_BEGIN(rt) { char RT_YIELD_FLAG = 1; LABEL_RESUME((rt)->label)

#define RT_END(rt) LABEL_END((rt)->label); RT_YIELD_FLAG = 0; \
                   RT_INIT(rt); return RT_ENDED; }

#define RT_WAIT_UNTIL(rt, condition)            \
  do {                      \
    LABEL_SET((rt)->label);             \
    if(!(condition)) {              \
      return RT_WAITING;            \
    }                       \
  } while(0)

#define RT_WAIT_WHILE(rt, cond)  RT_WAIT_UNTIL((rt), !(cond))

#define RT_WAIT_THREAD(rt, thread) RT_WAIT_WHILE((rt), RT_SCHEDULE(thread))

#define RT_SPAWN(rt, child, thread)     \
  do {                      \
    RT_INIT((child));               \
    RT_WAIT_THREAD((rt), (thread));     \
  } while(0)

#define RT_RESTART(rt)              \
  do {                      \
    RT_INIT(rt);                \
    return RT_WAITING;          \
  } while(0)

#define RT_EXIT(rt)             \
  do {                      \
    RT_INIT(rt);                \
    return RT_EXITED;           \
  } while(0)

#define RT_SCHEDULE(f) ((f) < RT_EXITED)

#define RT_YIELD(rt)                \
  do {                      \
    RT_YIELD_FLAG = 0;              \
    LABEL_SET((rt)->label);             \
    if(RT_YIELD_FLAG == 0) {            \
      return RT_YIELDED;            \
    }                       \
  } while(0)

#define RT_YIELD_UNTIL(rt, cond)        \
  do {                      \
    RT_YIELD_FLAG = 0;              \
    LABEL_SET((rt)->label);             \
    if((RT_YIELD_FLAG == 0) || !(cond)) {   \
      return RT_YIELDED;            \
    }                       \
  } while(0)

#define RT_SLEEP(rt, delay) \
{ \
  do { \
    static unsigned long protothreads_sleep; \
    protothreads_sleep = millis(); \
    RT_WAIT_UNTIL(rt, millis() - protothreads_sleep > delay); \
  } while(false); \
}

#endif