Function run_local_route

modules/tm/uac.c:165–407

static int run_local_route( struct cell *new_cell, char **buf, int *buf_len,
				dlg_t *dialog, struct sip_msg **ret_req, char **ret_req_buf)
{
	struct sip_msg *req = NULL;
	struct cell *backup_cell;
	int backup_route_type;
	struct retr_buf *request;
	struct proxy_l *new_proxy = NULL;
	union sockaddr_union new_to_su;
	const struct socket_info *new_send_sock;
	unsigned short dst_changed;
	char *buf1=NULL, *sipmsg_buf;
	int buf_len1, sip_msg_len;
	str h_to, h_from, h_cseq, h_callid;
	struct ua_client* uac;

	/* do not build buffer if callbacks are not needed and
	 * there are no local routes */
	if (!has_tran_tmcbs(new_cell, TMCB_LOCAL_REQUEST_OUT) &&
			!sroutes->local.a)
		return 0;

	LM_DBG("building sip_msg from buffer\n");
	sipmsg_buf = *buf; /* remember the buffer used to get the sip_msg */
	req = buf_to_sip_msg( *buf, *buf_len, dialog);
	if (req==NULL) {
		LM_ERR("failed to build sip_msg from buffer\n");
		return -1;
	}

	/* set this transaction as active one */
	backup_cell = get_t();
	set_t( new_cell );
	/* disable parallel forking */
	set_dset_state( 0 /*disable*/);

	/* run the route */
	swap_route_type( backup_route_type, LOCAL_ROUTE);
	if (sroutes && sroutes->local.a)
		run_top_route( sroutes->local, req);
	if (has_tran_tmcbs(new_cell, TMCB_LOCAL_REQUEST_OUT) ) {
		run_trans_callbacks(TMCB_LOCAL_REQUEST_OUT, new_cell,
			req, 0, 0);
	}
	set_route_type( backup_route_type );

	uac = & TM_BRANCH( new_cell, 0);

	/* transfer current message context back to t */
	uac->br_flags = getb0flags(req);
	/* restore the prevoius active transaction */
	set_t( backup_cell );

	set_dset_state( 1 /*enable*/);

	/* check for changes - if none, do not regenerate the buffer */
	dst_changed = 1;
	if (req->new_uri.s || req->force_send_socket!=dialog->send_sock ||