nxge/xgehal/xge-queue.c

55 	xge_queue_item_t *elem;
60 	elem = (xge_queue_item_t *)queue->list_head.next;
61 	if (elem->data_size > data_max_size)
64 	xge_list_remove(&elem->item);
65 	real_size = elem->data_size + sizeof(xge_queue_item_t);
66 	if (queue->head_ptr == elem) {
71 	        ":0x"XGE_OS_LLXFMT" elem 0x"XGE_OS_LLXFMT" length %d",
72 	        elem->event_type,
77 	        (u64)(ulong_t)elem,
79 	} else if ((char *)queue->tail_ptr - real_size == (char*)elem) {
84 	        ":0x"XGE_OS_LLXFMT" elem 0x"XGE_OS_LLXFMT" length %d",
85 	        elem->event_type,
90 	        (u64)(ulong_t)elem,
96 	        ":0x"XGE_OS_LLXFMT" elem 0x"XGE_OS_LLXFMT" length %d",
97 	        elem->event_type,
102 	        (u64)(ulong_t)elem,
110 	xge_os_memcpy(item, elem, sizeof(xge_queue_item_t));
111 	xge_os_memcpy(xge_queue_item_data(item), xge_queue_item_data(elem),
112 	        elem->data_size);
149 	xge_queue_item_t *elem;
171 	    elem = (xge_queue_item_t *) queue->tail_ptr;
176 	        ":0x"XGE_OS_LLXFMT" elem 0x"XGE_OS_LLXFMT" length %d",
182 	        (u64)(ulong_t)elem,
186 	    elem = (xge_queue_item_t *) ((char *)queue->head_ptr - real_size);
187 	    queue->head_ptr = elem;
225 	elem->data_size = data_size;
226 	elem->event_type = (xge_hal_event_e) event_type;
227 	elem->is_critical = is_critical;
230 	elem->context = context;
231 	xge_os_memcpy(xge_queue_item_data(elem), data, data_size);
232 	xge_list_insert_before(&elem->item, &queue->list_head);
331 	xge_queue_item_t *elem;
360 	    elem = xge_container_of(item, xge_queue_item_t, item);
361 	    if (elem->item.next != &queue->list_head) {
362 	        elem->item.next =
364 	             ((char *)elem->item.next - (char *)oldbuf));
366 	    if (elem->item.prev != &queue->list_head) {
367 	        elem->item.prev =
369 	             ((char *)elem->item.prev - (char *)oldbuf));