queue/src/queue.c

28 	    || NULL == desc->cb_elems || NULL == desc->cb_desc) {
39 			      desc->cb_desc);
102 		ia_css_circbuf_desc_t cb_desc;
106 		/* a. Load the queue cb_desc from remote */
107 		QUEUE_CB_DESC_INIT(&cb_desc);
108 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
113 		if (ia_css_circbuf_desc_is_full(&cb_desc))
118 		error = ia_css_queue_item_store(qhandle, cb_desc.end, &cb_elem);
122 		cb_desc.end = (cb_desc.end + 1) % cb_desc.size;
131 		error = ia_css_queue_store(qhandle, &cb_desc, ignore_desc_flags);
159 		ia_css_circbuf_desc_t cb_desc;
163 		QUEUE_CB_DESC_INIT(&cb_desc);
165 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
170 		if (ia_css_circbuf_desc_is_empty(&cb_desc))
173 		error = ia_css_queue_item_load(qhandle, cb_desc.start, &cb_elem);
179 		cb_desc.start = OP_std_modadd(cb_desc.start, 1, cb_desc.size);
187 		error = ia_css_queue_store(qhandle, &cb_desc, ignore_desc_flags);
210 		ia_css_circbuf_desc_t cb_desc;
213 		QUEUE_CB_DESC_INIT(&cb_desc);
214 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
219 		*is_full = ia_css_circbuf_desc_is_full(&cb_desc);
242 		ia_css_circbuf_desc_t cb_desc;
245 		QUEUE_CB_DESC_INIT(&cb_desc);
246 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
251 		*size = ia_css_circbuf_desc_get_free_elems(&cb_desc);
274 		ia_css_circbuf_desc_t cb_desc;
277 		QUEUE_CB_DESC_INIT(&cb_desc);
278 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
283 		*size = ia_css_circbuf_desc_get_num_elems(&cb_desc);
312 		ia_css_circbuf_desc_t cb_desc;
316 		QUEUE_CB_DESC_INIT(&cb_desc);
318 		error =  ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
323 		num_elems = ia_css_circbuf_desc_get_num_elems(&cb_desc);
327 		offset = OP_std_modadd(cb_desc.start, offset, cb_desc.size);
355 		ia_css_circbuf_desc_t cb_desc;
358 		QUEUE_CB_DESC_INIT(&cb_desc);
359 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
364 		*is_empty = ia_css_circbuf_desc_is_empty(&cb_desc);
387 		ia_css_circbuf_desc_t cb_desc;
390 		QUEUE_CB_DESC_INIT(&cb_desc);
392 		error = ia_css_queue_load(qhandle, &cb_desc, ignore_desc_flags);
397 		*size = cb_desc.size;