runtime.h

#ifndef RUNTIME_H
#define RUNTIME_H

#ifndef bool
#define bool int
#define true 1
#define false 0
#endif

#define nil ((void *)0)
#define len(p) (sizeof(p) / sizeof(p[0]))

#define G_IDLE 0
#define G_RUNNABLE 1
#define G_RUNNING 2
#define G_WAITING 3
#define G_DEAD 4

#define EV_READ 1
#define EV_WRITE 2

typedef struct G G;
typedef struct Event Event;
typedef struct Gobuf Gobuf;
typedef struct Timers Timers;
typedef struct Sched Sched;
typedef struct Chan Chan;
typedef struct WaitQ WaitQ;
typedef struct Case Case;

struct Case {
  G *g;
  Chan *c;
  int op;
};

struct WaitQ {
  G *head;
  G *tail;
};

struct Chan {
  void *ptr;
  int len;
  int cap;
  int elsize;
  int closed;
  int sendx;
  int recvx;
  WaitQ sendq;
  WaitQ recvq;
};

struct Gobuf {
  void *sp;
  void *pc;
  void *gr[8];
};

struct Event {
  int fd;
  int mode;
  long when;
  long period;
  void (*f)(void *, long);
  void *arg;
  G *g;
};

struct Timers {
  Event **heap;
  int len;
  int cap;
};

struct G {
  void *stackguard;
  G *next;
  Gobuf ctx;
  Event ev;
  int state;
  int mp;
  int id;
  void *p;
};

struct Sched {
  G *g; /* current g running on this scheduler */
  G *gfree;
  G *ghead;
  G *gtail;
  Timers t;
  int genid;
  /* debug */
  int glen;
};

void debug(const char *, ...);
void throw(const char *, ...);
void setcloexec(int);
void setnonblock(int);
G *getg(void);
void ready(G *);
void yield0(int);
void yield1(void);
void yield(void);
void schedule(void);
void spawn(void (*)(void *), void *, int);
int await(int, int, long, long);
void asleep(long);
void schedinit(void);
void netpollinit(void);
int netpollopen(Event *);
void netpollready(G **, Event *, int);
G *netpoll(long);
long timens(void);
void timersinit(Timers *);
void timersopen(Timers *, Event *);
long timerscheck(Timers *);
void hookinit(void);
Chan *makechan(int, int);
bool chansend(Chan *, void *, bool);
bool chanrecv(Chan *, void *, bool);
void chanclose(Chan *);
int dial0(int, const char *, unsigned short);
int listen0(int, const char *, unsigned short);
int dialunix0(int, const char *);
int listenunix0(int, const char *);

#endif