Lines Matching refs:item
35 void* xge_queue_item_data(xge_queue_item_t *item) in xge_queue_item_data() argument
37 return (char *)item + sizeof(xge_queue_item_t); in xge_queue_item_data()
47 __queue_consume(xge_queue_t *queue, int data_max_size, xge_queue_item_t *item) in __queue_consume() argument
59 xge_list_remove(&elem->item); in __queue_consume()
105 xge_os_memcpy(item, elem, sizeof(xge_queue_item_t)); in __queue_consume()
106 xge_os_memcpy(xge_queue_item_data(item), xge_queue_item_data(elem), in __queue_consume()
154 xge_queue_item_t *item = (xge_queue_item_t *)(void *)item_buf; in xge_queue_produce() local
160 item) != XGE_QUEUE_IS_EMPTY) in xge_queue_produce()
227 xge_list_insert_before(&elem->item, &queue->list_head); in xge_queue_produce()
325 xge_list_t *item; in __io_queue_grow() local
354 xge_list_for_each(item, &queue->list_head) { in __io_queue_grow()
355 elem = xge_container_of(item, xge_queue_item_t, item); in __io_queue_grow()
356 if (elem->item.next != &queue->list_head) { in __io_queue_grow()
357 elem->item.next = in __io_queue_grow()
359 ((char *)elem->item.next - (char *)oldbuf)); in __io_queue_grow()
361 if (elem->item.prev != &queue->list_head) { in __io_queue_grow()
362 elem->item.prev = in __io_queue_grow()
364 ((char *)elem->item.prev - (char *)oldbuf)); in __io_queue_grow()
392 xge_queue_consume(xge_queue_h queueh, int data_max_size, xge_queue_item_t *item) in xge_queue_consume() argument
399 status = __queue_consume(queue, data_max_size, item); in xge_queue_consume()
417 xge_queue_item_t *item = (xge_queue_item_t *)(void *)item_buf; in xge_queue_flush() local
424 item) != XGE_QUEUE_IS_EMPTY) { in xge_queue_flush()
427 item, item->event_type); in xge_queue_flush()