Lines Matching defs:mq
146 #define HSTATUS(mq, h) ((mq) + offsetof(struct message_queue, hstatus[h]))
555 struct message_queue *mq = p;
559 memset(mq, 0, bytes);
560 mq->start = &mq->data;
561 mq->start2 = &mq->data + (qlines / 2 - 1) * GRU_CACHE_LINE_BYTES;
562 mq->next = &mq->data;
563 mq->limit = &mq->data + (qlines - 2) * GRU_CACHE_LINE_BYTES;
564 mq->qlines = qlines;
565 mq->hstatus[0] = 0;
566 mq->hstatus[1] = 1;
567 mq->head = gru_mesq_head(2, qlines / 2 + 1);
568 mqd->mq = mq;
569 mqd->mq_gpa = uv_gpa(mq);
840 struct message_queue *mq = mqd->mq;
841 struct message_header *mhdr = mq->next;
850 pnext = mq->next;
852 if (next == mq->limit) {
853 next = mq->start;
855 } else if (pnext < mq->start2 && next >= mq->start2) {
860 mq->hstatus[half] = 1;
861 mq->next = next;
872 struct message_queue *mq = mqd->mq;
873 struct message_header *mhdr = mq->next;
879 mhdr = mq->next;
999 void *p, *mq;
1008 mq = ALIGNUP(p, 1024);
1010 dw = mq;
1012 gru_create_message_queue(&mqd, mq, 8 * GRU_CACHE_LINE_BYTES, 0, 0, 0);