Lines Matching defs:eventq
34 static void flush(eventQT *eventq)
38 data = malloc(eventq->eventSize);
42 while (eventQReceive(eventq, data) != -1)
51 eventQT *eventq;
54 eventq = malloc(sizeof(*eventq));
55 if (eventq == 0)
57 memset(eventq, 0, sizeof(*eventq));
58 strncpy(eventq->name, name, MAX_NAME_LENGTH);
59 eventq->queueDepth = queueDepth;
60 eventq->eventSize = eventSize;
64 attr.mq_maxmsg = eventq->queueDepth;
65 attr.mq_msgsize = eventq->eventSize;
68 eventq->mq = mq_open(eventq->name,
71 if (eventq->mq == (mqd_t)-1) {
74 free(eventq);
79 flush(eventq);
81 return eventq;
87 eventQT *eventq;
91 eventq = create(name, queueDepth, eventSize);
92 eventQDelete(eventq);
98 void eventQDelete(eventQT *eventq)
100 mq_close(eventq->mq);
101 mq_unlink(eventq->name);
102 free(eventq);
106 int eventQSend(eventQT *eventq, char *event)
108 return mq_send(eventq->mq, event, eventq->eventSize, 0);
112 int eventQReceive(eventQT *eventq, char *event)
114 return mq_receive(eventq->mq, event, eventq->eventSize, 0);