Function retransmission_handler

modules/tm/timer.c:277–339

inline static void retransmission_handler( struct timer_link *retr_tl )
{
	struct retr_buf* r_buf ;
	enum lists id;

	r_buf = get_retr_timer_payload(retr_tl);
#ifdef EXTRA_DEBUG
	if (r_buf->my_T->damocles) {
		LM_ERR("transaction %p scheduled for deletion and"
			" called from RETR timer\n",r_buf->my_T);
		abort();
	}
#endif

	/* the transaction is already removed from RETRANSMISSION_LIST by timer*/
	/* re-transmission */
	if ( r_buf->activ_type==TYPE_LOCAL_CANCEL
		|| r_buf->activ_type==TYPE_REQUEST ) {
			LM_DBG("retransmission_handler : request resending"
				" (t=%p, %.9s ... )\n", r_buf->my_T, r_buf->buffer.s);
			set_t(r_buf->my_T);
			if (SEND_BUFFER( r_buf )==0) {
				if ( has_tran_tmcbs( r_buf->my_T, TMCB_MSG_SENT_OUT) ) {
					set_extra_tmcb_params( &r_buf->buffer, &r_buf->dst);
					run_trans_callbacks( TMCB_MSG_SENT_OUT, r_buf->my_T,
						r_buf->my_T->uas.request, 0, 0);
				}
			/*} else {
				reset_timer( &r_buf->fr_timer );
				fake_reply(r_buf->my_T, r_buf->branch, 503 );
				return;
			} */
			}

			set_t(T_UNDEFINED);
			switch(r_buf->retr_list) {
			case RT_T1_TO_1:
				if_update_stat(tm_enable_stats, tm_retran_req_T11, 1); break;
			case RT_T1_TO_2:
				if_update_stat(tm_enable_stats, tm_retran_req_T12, 1); break;
			case RT_T1_TO_3:
				if_update_stat(tm_enable_stats, tm_retran_req_T13, 1); break;
			case RT_T2:
				if_update_stat(tm_enable_stats, tm_retran_req_T2, 1);break;
			default:;
			}
	} else {
			LM_DBG("retransmission_handler : reply resending "
				"(t=%p, %.9s ... )\n", r_buf->my_T, r_buf->buffer.s);
			set_t(r_buf->my_T);
			t_retransmit_reply(r_buf->my_T);
			set_t(T_UNDEFINED);
			if_update_stat(tm_enable_stats, tm_retran_rpl_T2, 1);
	}

	id = r_buf->retr_list;
	r_buf->retr_list = id < RT_T2 ? id + 1 : RT_T2;