Function t_resume_async_reply

modules/tm/async.c:231–397

}	

int t_resume_async_reply(int fd, void*param, int was_timeout)
{
	async_tm_ctx *ctx = (async_tm_ctx *)param;
	struct cell *backup_t;
	struct usr_avp **backup_list;
	struct cell *t= ctx->t;
	int route;
	int msg_status;
	int last_uac_status;
	int branch;
	struct ua_client *reply_uac;

	if (valid_async_fd(fd))
		LM_DBG("resuming reply on fd %d, transaction %p \n", fd, t);
	else
		LM_DBG("resuming reply without a fd, transaction %p \n", t);



	/* enviroment setting */
	current_processing_ctx = ctx->msg_ctx;
	backup_t = get_t();

	/* make available the avp list from transaction */
	backup_list = set_avp_list( &t->user_avps );

	/* avoid double lookup of our branch, just get it from ctx */
	branch=ctx->branch;

	/* fake transaction */
	set_t( t );

	msg_status=ctx->reply->REPLY_STATUS;
	reply_uac=&TM_BRANCH( t, branch);
	LM_DBG("org. status uas=%d, uac[%d]=%d local=%d is_invite=%d)\n",
		t->uas.status, branch, reply_uac->last_received,
		is_local(t), is_invite(t));
	last_uac_status=reply_uac->last_received;

	_tm_branch_index = branch;

	async_status = ASYNC_DONE; /* assume default status as done */

	/* we run the resume callback under lock, if needed 
	 * the resume function might touch the AVP list, so
	 * we need to protect that from other incoming replies on this transaction */
	if (onreply_avp_mode)
		LOCK_REPLIES(t);

	/* call the resume function in order to read and handle data */
	return_code = ((async_resume_module*)
		(was_timeout ? ctx->async.timeout_f : ctx->async.resume_f))
		( (valid_async_fd(fd) ? fd: ASYNC_FD_NONE), ctx->reply,
		ctx->async.resume_param );

	if (async_status==ASYNC_CONTINUE) {
		/* do not run the resume route */
		if (onreply_avp_mode)