146 #define HSTATUS(mq, h)	((mq) + offsetof(struct message_queue, hstatus[h]))  argument
560 	struct message_queue *mq = p;  in gru_create_message_queue()  local
564 	memset(mq, 0, bytes);  in gru_create_message_queue()
565 	mq->start = &mq->data;  in gru_create_message_queue()
566 	mq->start2 = &mq->data + (qlines / 2 - 1) * GRU_CACHE_LINE_BYTES;  in gru_create_message_queue()
567 	mq->next = &mq->data;  in gru_create_message_queue()
568 	mq->limit = &mq->data + (qlines - 2) * GRU_CACHE_LINE_BYTES;  in gru_create_message_queue()
569 	mq->qlines = qlines;  in gru_create_message_queue()
570 	mq->hstatus[0] = 0;  in gru_create_message_queue()
571 	mq->hstatus[1] = 1;  in gru_create_message_queue()
572 	mq->head = gru_mesq_head(2, qlines / 2 + 1);  in gru_create_message_queue()
573 	mqd->mq = mq;  in gru_create_message_queue()
574 	mqd->mq_gpa = uv_gpa(mq);  in gru_create_message_queue()
851 	struct message_queue *mq = mqd->mq;  in gru_free_message()  local
852 	struct message_header *mhdr = mq->next;  in gru_free_message()
861 	pnext = mq->next;  in gru_free_message()
863 	if (next == mq->limit) {  in gru_free_message()
864 		next = mq->start;  in gru_free_message()
866 	} else if (pnext < mq->start2 && next >= mq->start2) {  in gru_free_message()
871 		mq->hstatus[half] = 1;  in gru_free_message()
872 	mq->next = next;  in gru_free_message()
883 	struct message_queue *mq = mqd->mq;  in gru_get_next_message()  local
884 	struct message_header *mhdr = mq->next;  in gru_get_next_message()
890 		mhdr = mq->next;  in gru_get_next_message()
1010 	void *p, *mq;  in quicktest1()  local
1018 	mq = ALIGNUP(p, 1024);  in quicktest1()
1021 	gru_create_message_queue(&mqd, mq, 8 * GRU_CACHE_LINE_BYTES, 0, 0, 0);  in quicktest1()