Lines Matching refs:mq
134 #define HSTATUS(mq, h) ((mq) + offsetof(struct message_queue, hstatus[h])) argument
548 struct message_queue *mq = p; in gru_create_message_queue() local
552 memset(mq, 0, bytes); in gru_create_message_queue()
553 mq->start = &mq->data; in gru_create_message_queue()
554 mq->start2 = &mq->data + (qlines / 2 - 1) * GRU_CACHE_LINE_BYTES; in gru_create_message_queue()
555 mq->next = &mq->data; in gru_create_message_queue()
556 mq->limit = &mq->data + (qlines - 2) * GRU_CACHE_LINE_BYTES; in gru_create_message_queue()
557 mq->qlines = qlines; in gru_create_message_queue()
558 mq->hstatus[0] = 0; in gru_create_message_queue()
559 mq->hstatus[1] = 1; in gru_create_message_queue()
560 mq->head = gru_mesq_head(2, qlines / 2 + 1); in gru_create_message_queue()
561 mqd->mq = mq; in gru_create_message_queue()
562 mqd->mq_gpa = uv_gpa(mq); in gru_create_message_queue()
839 struct message_queue *mq = mqd->mq; in gru_free_message() local
840 struct message_header *mhdr = mq->next; in gru_free_message()
849 pnext = mq->next; in gru_free_message()
851 if (next == mq->limit) { in gru_free_message()
852 next = mq->start; in gru_free_message()
854 } else if (pnext < mq->start2 && next >= mq->start2) { in gru_free_message()
859 mq->hstatus[half] = 1; in gru_free_message()
860 mq->next = next; in gru_free_message()
871 struct message_queue *mq = mqd->mq; in gru_get_next_message() local
872 struct message_header *mhdr = mq->next; in gru_get_next_message()
878 mhdr = mq->next; in gru_get_next_message()
998 void *p, *mq; in quicktest1() local
1006 mq = ALIGNUP(p, 1024); in quicktest1()
1009 gru_create_message_queue(&mqd, mq, 8 * GRU_CACHE_LINE_BYTES, 0, 0, 0); in quicktest1()