Function dr_reload_data_head

modules/drouting/drouting.c:1167–1393

 */

static inline int dr_reload_data_head(struct head_db *hd,
                           str *part_name, int initial,
						   const int is_inherit_state)
{
	db_con_t* db_hdl = *hd->db_con;
	db_func_t *dr_dbf = &hd->db_funcs;
	rt_data_t *new_data;
	rt_data_t *old_data;
	pgw_t *gw, *old_gw;
	pcr_t *cr, *old_cr;
	time_t rawtime;
	struct dr_prepare_part_params pp;
	int ret = -1;
	MD5_CTX Md5Ctx, *ctxp=NULL;
	HASH bin_md5;
	char hash_report_data[64];

	void **dest;
	map_iterator_t it;

	db_res_t* res = NULL;
	db_row_t *row = NULL;
	str *rules_tables=NULL;
	int rules_no,i;
	char *p;
	str rule_table_query;

	if (no_concurrent_reload) {
		lock_get( hd->ref_lock->lock );
		if (hd->ongoing_reload) {
			lock_release( hd->ref_lock->lock );
			LM_WARN("Reload already in progress, discarding this one\n");
			return -2;
		}
		hd->ongoing_reload = 1;
		lock_release( hd->ref_lock->lock );
	}

	if (initial && hd->cache && hd->cache->rdata) {
		LM_INFO("starting drouting with cache data %p->%p!\n", hd->cache, hd->cache->rdata);
		dr_update_head_cache(hd);
		goto success;
	}

	pp.part_name = *part_name;
	run_dr_cbs(DRCB_RLD_PREPARE_PART, &pp);

	LM_INFO("loading drouting data!\n");

	if (initial)
		sr_set_status( dr_srg, STR2CI(hd->partition), SR_STATUS_LOADING_DATA,
			CHAR_INT("startup data loading"), 0);
	else
		sr_set_status( dr_srg, STR2CI(hd->partition), SR_STATUS_RELOADING_DATA,
			CHAR_INT("data re-loading"), 0);

	if (!uses_rule_table_query(hd, &rule_table_query)) {