134 #define HSTATUS(mq, h)	((mq) + offsetof(struct message_queue, hstatus[h]))  argument
546 	struct message_queue *mq = p;  in gru_create_message_queue()  local
550 	memset(mq, 0, bytes);  in gru_create_message_queue()
551 	mq->start = &mq->data;  in gru_create_message_queue()
552 	mq->start2 = &mq->data + (qlines / 2 - 1) * GRU_CACHE_LINE_BYTES;  in gru_create_message_queue()
553 	mq->next = &mq->data;  in gru_create_message_queue()
554 	mq->limit = &mq->data + (qlines - 2) * GRU_CACHE_LINE_BYTES;  in gru_create_message_queue()
555 	mq->qlines = qlines;  in gru_create_message_queue()
556 	mq->hstatus[0] = 0;  in gru_create_message_queue()
557 	mq->hstatus[1] = 1;  in gru_create_message_queue()
558 	mq->head = gru_mesq_head(2, qlines / 2 + 1);  in gru_create_message_queue()
559 	mqd->mq = mq;  in gru_create_message_queue()
560 	mqd->mq_gpa = uv_gpa(mq);  in gru_create_message_queue()
837 	struct message_queue *mq = mqd->mq;  in gru_free_message()  local
838 	struct message_header *mhdr = mq->next;  in gru_free_message()
847 	pnext = mq->next;  in gru_free_message()
849 	if (next == mq->limit) {  in gru_free_message()
850 		next = mq->start;  in gru_free_message()
852 	} else if (pnext < mq->start2 && next >= mq->start2) {  in gru_free_message()
857 		mq->hstatus[half] = 1;  in gru_free_message()
858 	mq->next = next;  in gru_free_message()
869 	struct message_queue *mq = mqd->mq;  in gru_get_next_message()  local
870 	struct message_header *mhdr = mq->next;  in gru_get_next_message()
876 		mhdr = mq->next;  in gru_get_next_message()
996 	void *p, *mq;  in quicktest1()  local
1004 	mq = ALIGNUP(p, 1024);  in quicktest1()
1007 	gru_create_message_queue(&mqd, mq, 8 * GRU_CACHE_LINE_BYTES, 0, 0, 0);  in quicktest1()