Function mi_get_size

modules/mqueue/mqueue_mod.c:304–338

}

mi_response_t *mi_get_size(const mi_params_t *params,
								struct mi_handler *async_hdl)
{
	mi_response_t *resp;
	mi_item_t *resp_obj, *mq_obj;
	str mqueue_name;
	int mqueue_sz = 0;

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

	mqueue_sz = _mq_get_csize(&mqueue_name);
	if(mqueue_sz < 0)
		return init_mi_error(404, MI_SSTR("No such queue"));

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

	mq_obj = add_mi_object(resp_obj, MI_SSTR("Queue"));
	if (!mq_obj)
		goto error;

	if (add_mi_string_fmt(mq_obj, MI_SSTR("name"), mqueue_name.s, mqueue_name.len) < 0)
		goto error;
	if (add_mi_number(mq_obj, MI_SSTR("size"), mqueue_sz) < 0)
		goto error;

	return resp;

error:
	LM_ERR("Unable to create reply\n");
	free_mi_response(resp);
	return NULL;
}

mi_response_t *mi_get_sizes(const mi_params_t *params,
								struct mi_handler *async_hdl)