version 1.1.1.2, 2013/07/22 08:44:29
|
version 1.1.1.3, 2021/03/17 00:39:23
|
Line 28
|
Line 28
|
}; |
}; |
typedef struct mpmsg *Msg; |
typedef struct mpmsg *Msg; |
|
|
struct mpmsg msgqueue[MSG_QUEUE_LEN]; | static struct mpmsg msgqueue[MSG_QUEUE_LEN]; |
int msgqueueh = 0; | static int msgqueueh = 0; |
int msgqueuet = 0; | static int msgqueuet = 0; |
#define QUEUELEN() ((msgqueueh >= msgqueuet)? \ |
#define QUEUELEN() ((msgqueueh >= msgqueuet)? \ |
(msgqueueh - msgqueuet):(msgqueueh + MSG_QUEUE_LEN - msgqueuet)) |
(msgqueueh - msgqueuet):(msgqueueh + MSG_QUEUE_LEN - msgqueuet)) |
|
|
int msgpipe[2]; | static int msgpipe[2]; |
int msgpipesent = 0; | static int msgpipesent = 0; |
EventRef msgevent; | static EventRef msgevent; |
|
|
/* |
/* |
* GLOBAL VARIABLES |
* GLOBAL VARIABLES |
Line 103 static void
|
Line 103 static void
|
MsgEvent(int type, void *cookie) |
MsgEvent(int type, void *cookie) |
{ |
{ |
char buf[16]; |
char buf[16]; |
|
|
|
(void)type; |
|
(void)cookie; |
/* flush signaling pipe */ |
/* flush signaling pipe */ |
msgpipesent = 0; |
msgpipesent = 0; |
while (read(msgpipe[PIPE_READ], buf, sizeof(buf)) == sizeof(buf)); |
while (read(msgpipe[PIPE_READ], buf, sizeof(buf)) == sizeof(buf)); |