Function route2_gw

modules/drouting/drouting.c:3951–4090

static int route2_gw(struct sip_msg* msg, str* ids, pv_spec_t* gw_attr,
									pv_spec_t* cr_attr, struct head_db *part)
{
	struct sip_uri  uri;
	pgw_t *gw;
	pgw_list_t dst;
	pv_value_t pv_val;
	str ruri, id;
	char *p;
	int idx, i;
	struct head_db * current_partition = 0;
	char *ruri_buf = NULL;
	pcr_t *pcr = NULL;
	map_iterator_t cr_it;
	void** dest;

	if(part== NULL) {
		LM_ERR("Partition is mandatory for route_to_gw.\n");
		return -1;
	}
	current_partition = part;

	if (current_partition->rdata == 0 ||
	current_partition->rdata->pgw_tree == 0) {
		LM_DBG("empty routing table\n");
		return -1;
	}

	gw_attrs_spec = (pv_spec_p)gw_attr;
	carrier_attrs_spec = (pv_spec_p)cr_attr;

	/* get the RURI */
	ruri = *GET_RURI(msg);
	ruri_buf = (char*)pkg_malloc(ruri.len);
	if (ruri_buf==NULL) {
		LM_ERR("no more pkg mem (needed %d)\n",ruri.len);
		return -1;
	}
	memcpy(ruri_buf, ruri.s, ruri.len);
	ruri.s = ruri_buf;

	/* parse ruri */
	if (parse_uri( ruri.s, ruri.len, &uri)!=0) {
		LM_ERR("unable to parse RURI\n");
		goto error_free;
	}

	/* ref the data for reading */
	lock_start_read( current_partition->ref_lock );

	idx = 0;
	do {
		id.s = ids->s;
		p = q_memchr( ids->s , ',' , ids->len);
		id.len = (p==NULL)?ids->len:(p-ids->s);

		ids->len -= id.len + (p?1:0);
		ids->s += id.len + (p?1:0);