Lines Matching refs:mq
145 #define HSTATUS(mq, h) ((mq) + offsetof(struct message_queue, hstatus[h]))
554 struct message_queue *mq = p;
558 memset(mq, 0, bytes);
559 mq->start = &mq->data;
560 mq->start2 = &mq->data + (qlines / 2 - 1) * GRU_CACHE_LINE_BYTES;
561 mq->next = &mq->data;
562 mq->limit = &mq->data + (qlines - 2) * GRU_CACHE_LINE_BYTES;
563 mq->qlines = qlines;
564 mq->hstatus[0] = 0;
565 mq->hstatus[1] = 1;
566 mq->head = gru_mesq_head(2, qlines / 2 + 1);
567 mqd->mq = mq;
568 mqd->mq_gpa = uv_gpa(mq);
839 struct message_queue *mq = mqd->mq;
840 struct message_header *mhdr = mq->next;
849 pnext = mq->next;
851 if (next == mq->limit) {
852 next = mq->start;
854 } else if (pnext < mq->start2 && next >= mq->start2) {
859 mq->hstatus[half] = 1;
860 mq->next = next;
871 struct message_queue *mq = mqd->mq;
872 struct message_header *mhdr = mq->next;
878 mhdr = mq->next;
998 void *p, *mq;
1007 mq = ALIGNUP(p, 1024);
1009 dw = mq;
1011 gru_create_message_queue(&mqd, mq, 8 * GRU_CACHE_LINE_BYTES, 0, 0, 0);