Function mi_fetch_bulk

modules/mqueue/mqueue_mod.c:428–471

}

mi_response_t *mi_fetch_bulk(const mi_params_t *params,
								struct mi_handler *async_hdl)
{
	mi_response_t *resp;
	mi_item_t *resp_obj, *mq_item;
	str mqueue_name;
	int limit;
	mq_head_t *mh;
	mq_item_t *item = NULL;

	if (get_mi_string_param(params, "name", &mqueue_name.s, &mqueue_name.len) < 0)
		return init_mi_param_error();

	if (get_mi_int_param(params, "limit", &limit) < 0 || limit < 1)
		return init_mi_param_error();

	mh = mq_head_get(&mqueue_name);
	if (!mh)
		return init_mi_error(404, MI_SSTR("No such queue"));

	resp = init_mi_result_array(&resp_obj);
	if (!resp)
		return NULL;

	lock_get(&mh->lock);
	do {
		item = mq_head_fetch_item(mh);
		if (!item)
			break;
		mq_item = add_mi_object(resp_obj, NULL, 0);
		if (add_mi_string_fmt(mq_item, MI_SSTR("key"), item->key.s, item->key.len) < 0)
			break;
		if (add_mi_string_fmt(mq_item, MI_SSTR("value"), item->val.s, item->val.len) < 0)
			break;
		shm_free(item);
		item = 0;
	} while (--limit > 0);
	lock_release(&mh->lock);

	if (item)
		shm_free(item);

	return resp;
}