Function dm_send_custom_rpl

modules/aaa_diameter/dm_peer.c:512–556

int dm_send_custom_rpl(struct dm_message *dm)
{
	struct msg *ans = (struct msg *)dm->fd_req;
	int rc, flags = 0;

	if (!dm_server_autoreply_error && dm_remove_unreplied_req(ans) != 0) {
		LM_ERR("unable to build answer, request is no longer available "
		        "(timeout: %d s)\n", dm_unreplied_req_timeout);
		return -1;
	}

	if (dm->error_bit)
		flags |= MSGFL_ANSW_ERROR;

	rc = fd_msg_new_answer_from_req(fd_g_config->cnf_dict, &ans, flags);
	if (rc != 0) {
		LM_ERR("failed to create answer message, error: %d\n", rc);
		goto error;
	}

	if (dm_server_autoreply_error)
		FD_CHECK(fd_msg_rescode_set(ans, "DIAMETER_COMMAND_UNSUPPORTED",
		            "Command Not Implemented", NULL, 1));

	/* App id */
	{
		struct msg_hdr *h;
		FD_CHECK(fd_msg_hdr(ans, &h));
		h->msg_appl = dm->app_id;
	}

	/* include all AVPs passed from script level */
	if (!dm_server_autoreply_error && dm_pack_avps(ans, &dm->avps) != 0) {
		LM_ERR("failed to pack AVPs\n");
		return -1;
	}

	FD_CHECK(fd_msg_send(&ans, NULL, NULL));
	FD_CHECK(fd_msg_free(ans));
	return 0;

error:
	fd_msg_free(ans);
	return -1;
}


static inline int dm_peer_send_msg(struct dm_message *msg)