Function mi_reload_rtpengines

modules/rtpengine/rtpengine.c:1397–1502

}

static mi_response_t *mi_reload_rtpengines(const mi_params_t *params,
								struct mi_handler *async_hdl)
{
	str type;
	int soft_reload = 0;
	struct rtpe_set *crt_list, *next_list;
	struct rtpe_node *crt_rtpe, *next_rtpe;

	if(db_url.s == NULL) {
		LM_ERR("Dynamic loading of rtpengines not enabled\n");
		return init_mi_error(400, MI_SSTR("Dynamic loading not enabled"));
	}

	if (try_get_mi_string_param(params, "type", &type.s, &type.len) == 0) {
		if (!str_strcmp(&type, _str("soft")))
			soft_reload = 1;
	}

	lock_start_write(rtpe_lock);

	if (soft_reload) {
		/*
			soft reload:
			- mark all nodes/sets for teardown; as nodes are added
			  from the database, this flag is cleared and sockets
			  will be reused
		*/
		if (*rtpe_set_list) {
			for(crt_list = (*rtpe_set_list)->rset_first; crt_list != NULL;
							crt_list = crt_list->rset_next){
				crt_list->set_flags |= RTPE_TEARDOWN_SET;
				for(crt_rtpe = crt_list->rn_first; crt_rtpe != NULL;
								crt_rtpe = crt_rtpe->rn_next)
					crt_rtpe->rn_flags |= RTPE_TEARDOWN_NODE;
			}
		}

		if(_add_rtpengine_from_database() < 0)
			goto error;

		/* remove old sets/nodes */
		for(crt_list = (*rtpe_set_list)->rset_first; crt_list != NULL; ){
			if (crt_list->set_flags&RTPE_TEARDOWN_SET) {
				next_list = crt_list->rset_next;
				free_rtpe_set(crt_list->id_set);
				crt_list = next_list;
				continue;
			}
			for(crt_rtpe = crt_list->rn_first; crt_rtpe != NULL; ){
				if (crt_rtpe->rn_flags&RTPE_TEARDOWN_NODE) {
					next_rtpe = crt_rtpe->rn_next;
					free_rtpe_node(crt_list, &crt_rtpe->rn_url);
					crt_rtpe = next_rtpe;
					continue;
				}
				crt_rtpe = crt_rtpe->rn_next;
			}
			crt_list = crt_list->rset_next;