Function mi_get_sizes

modules/mqueue/mqueue_mod.c:340–376

}

mi_response_t *mi_get_sizes(const mi_params_t *params,
								struct mi_handler *async_hdl)
{
	mi_response_t *resp;
	mi_item_t *resp_obj, *mq_array, *mq_item;
	mq_head_t *mh = mq_head_get(NULL);
	int size;

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

	mq_array = add_mi_array(resp_obj, MI_SSTR("Queue"));
	if (!mq_array)
		goto error;

	while(mh != NULL) {
		lock_get(&mh->lock);
		size = mh->csize;
		lock_release(&mh->lock);
		mq_item = add_mi_object(mq_array, MI_SSTR(""));
		if (!mq_item)
			goto error;
		if (add_mi_string_fmt(mq_item, MI_SSTR("name"), mh->name.s, mh->name.len) < 0)
			goto error;
		if (add_mi_number(mq_item, MI_SSTR("size"), size) < 0)
			goto error;
		mh = mh->next;
	}

	return resp;

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

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