Function reply_received

modules/tm/t_reply.c:1606–1786

This function is called whenever a reply for our module is received; * we need to register this function on module initialization; * Returns : 0 - core router stops * 1 - core router relay statelessly */

  *              1 - core router relay statelessly
  */
int reply_received( struct sip_msg  *p_msg )
{
	int msg_status;
	int last_uac_status;
	int branch;
	/* has the transaction completed now and we need to clean-up? */
	struct ua_client *uac;
	struct cell *t;
	struct usr_avp **backup_list;
	unsigned int has_reply_route;
	int old_route_type, ack_sent = 0;
	str ack_buf;

	set_t(T_UNDEFINED);

	profiling_proc_enter( LEVEL_SIP, "TM_reply_received", 0 );

	/* make sure we know the associated transaction ... */
	switch (t_check(p_msg, &branch )) {
		case -1: goto not_found;
		case -2: return 0; /* reply forwarded elsewhere */
	}

	/*... if there is none, tell the core router to fwd statelessly */
	t = get_t();
	if ((t == 0) || (t == T_UNDEFINED)) goto not_found;

	msg_status=p_msg->REPLY_STATUS;

	uac=&TM_BRANCH(t,branch);
	LM_DBG("org. status uas=%d, uac[%d]=%d local=%d is_invite=%d)\n",
		t->uas.status, branch, uac->last_received,
		is_local(t), is_invite(t));
	last_uac_status=uac->last_received;
	if_update_stat( tm_enable_stats, tm_rcv_rpls , 1);

	/* it's a cancel which is not e2e ? */
	if ( get_cseq(p_msg)->method_id==METHOD_CANCEL && is_invite(t) ) {
		/* ... then just stop timers */
		reset_timer( &uac->local_cancel.retr_timer);
		if ( msg_status >= 200 ) {
				reset_timer( &uac->local_cancel.fr_timer);
		}
		LM_DBG("reply to local CANCEL processed\n");

		if (has_tran_tmcbs( t, TMCB_MSG_MATCHED_IN) )
			run_trans_callbacks( TMCB_MSG_MATCHED_IN, t, 0,
				p_msg, p_msg->REPLY_STATUS);

		goto done;
	}

	/* *** stop timers *** */
	/* stop retransmission */
	reset_timer(&uac->request.retr_timer);

	/* stop final response timer only if I got a final response */
	if ( msg_status >= 200 ) {