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