vxge/vxgehal/vxge-queue.c

36  * vxge_queue_item_data - Get item's data.
37  * @item: Queue item.
39  * Returns:  item data(variable size). Note that vxge_queue_t
42  * user-defined portion of the queue item.
45 vxge_queue_item_data(vxge_queue_item_t *item)
47 	return (char *) item + sizeof(vxge_queue_item_t);
51  * __queue_consume - (Lockless) dequeue an item from the specified queue.
55  * @item: Queue item
61     vxge_queue_item_t *item)
75 	    "queue = 0x"VXGE_OS_STXFMT", size = %d, item = 0x"VXGE_OS_STXFMT,
76 	    (ptr_t) queue, data_max_size, (ptr_t) item);
91 	vxge_list_remove(&elem->item);
125 	vxge_os_memcpy(item, elem, sizeof(vxge_queue_item_t));
126 	vxge_os_memcpy(vxge_queue_item_data(item), vxge_queue_item_data(elem),
141  * vxge_queue_produce - Enqueue an item (see vxge_queue_item_t {})
151  *	the new queue item (see vxge_queue_item_t {}). Upon return
154  * Enqueue a new item.
197 		vxge_queue_item_t *item =
201 		    item) != VXGE_QUEUE_IS_EMPTY) {
266 	vxge_list_insert_before(&elem->item, &queue->list_head);
285  * @queued_func: Optional callback function to be called each time a new item is
408 	vxge_list_t *item;
454 	vxge_list_for_each(item, &queue->list_head) {
455 		elem = vxge_container_of(item, vxge_queue_item_t, item);
456 		if (elem->item.next != &queue->list_head) {
457 			elem->item.next =
460 			    ((char *) elem->item.next - (char *) oldbuf));
462 		if (elem->item.prev != &queue->list_head) {
463 			elem->item.prev =
466 			    ((char *) elem->item.prev - (char *) oldbuf));
479  * vxge_queue_consume - Dequeue an item from the specified queue.
481  * @data_max_size: Maximum expected size of the item.
482  * @item: Memory area into which the item is _copied_ upon return
485  * Dequeue an item from the queue. The caller is required to provide
486  * enough space for the item.
490  * VXGE_QUEUE_NOT_ENOUGH_SPACE - Requested item size(@data_max_size)
491  * is too small to accomodate an item from the queue.
498     vxge_queue_item_t *item)
514 	    "item = 0x"VXGE_OS_STXFMT, (ptr_t) queueh,
515 	    data_max_size, (ptr_t) item);
518 	status = __queue_consume(queue, data_max_size, item);
539 	vxge_queue_item_t *item = (vxge_queue_item_t *) (void *)item_buf;
555 	    item) != VXGE_QUEUE_IS_EMPTY) {
557 		vxge_hal_trace_log_queue("item 0x"VXGE_OS_STXFMT"(%d) flushed",
558 		    (ptr_t) item, item->event_type);