Function dr_init

modules/drouting/drouting.c:1743–2252

static int dr_init(void)
{
	pv_spec_t avp_spec;
	unsigned short dummy;
	str name_w_part;
	struct head_cache *cache = NULL;
	struct head_config * it_head_config = 0;
	struct head_db *db_part = NULL;
	char name_w_buf[MAX_LEN_NAME_W_PART];
	name_w_part.s = name_w_buf;

	LM_INFO("dynamic routing - initializing\n");
	reload_lock = lock_init_rw();
	if (!reload_lock) {
		LM_ERR("failed to init rw lock for dr_reload\n");
		return -1;
	}

	n_partitions = shm_malloc(sizeof *n_partitions);
	if (!n_partitions) {
		LM_ERR("oom\n");
		return -1;
	}
	*n_partitions = 0;

	drd_table.len = strlen(drd_table.s);
	drg_table.len = strlen(drg_table.s);
	drr_table.len = strlen(drr_table.s);
	drc_table.len = strlen(drc_table.s);
	extra_id_chars.len = strlen(extra_id_chars.s);

	if (dr_rpm_enable) {
		/* if we are using cache, we need to fetch our dr zone */
		if (rpm_init_mem() < 0) {
			LM_ERR("could not initilize restart persistency memory!\n");
			return -1;
		}
		dr_cache = (struct head_cache *)rpm_key_get("drouting");
		if (!dr_cache)
			LM_INFO("starting drouting with empty cache\n");
		else
			LM_INFO("starting drouting with cache head=%p\n", dr_cache);

		LM_NOTICE("using %ld MB of restart-persistent memory, allocator: %s\n",
		          rpm_mem_size/1024/1024, mm_str(mem_allocator_rpm));
	}

	/* register dr callbacks for sorting */
	if (register_dr_cb(DRCB_SORT_DST, no_sort_cb, (void *)NO_SORT, NULL) < 0) {
		LM_ERR("failed to register no_sort cb\n");
		return -1;
	}

	if (register_dr_cb(DRCB_SORT_DST, weight_based_sort_cb,
				(void *)WEIGHT_BASED_SORT, NULL) < 0) {
		LM_ERR("failed to register weight_based_sort cb\n");
		return -1;
	}