Function _dm_send_message

modules/aaa_diameter/dm_impl.c:2076–2122

}

int _dm_send_message(aaa_conn *_, aaa_message *msg, struct dm_cond **reply_cond)
{
	struct timespec wait_until;
	struct timeval now, wait_time, res;
	int rc, await_reply = 0;

	if (!msg || !my_reply_cond)
		return -1;

	if (msg->type == AAA_AUTH || msg->type == AAA_CUSTOM_REQ)
		await_reply = 1;

	LM_DBG("queue message for sending, type %d\n", msg->type);

	pthread_mutex_lock(&my_reply_cond->sync.cond.mutex);
	dm_push_queue(msg, my_reply_cond);
	/* WARNING: @msg *cannot* be read anymore here! (dangling pointer) */

	if (!await_reply) {
		pthread_mutex_unlock(&my_reply_cond->sync.cond.mutex);
		return 0;
	}

	gettimeofday(&now, NULL);
	wait_time.tv_sec = dm_answer_timeout / 1000;
	wait_time.tv_usec = dm_answer_timeout % 1000 * 1000UL;
	LM_DBG("awaiting reply (%ld s, %ld us)...\n", wait_time.tv_sec, wait_time.tv_usec);

	timeradd(&now, &wait_time, &res);

	wait_until.tv_sec = res.tv_sec;
	wait_until.tv_nsec = res.tv_usec * 1000UL;

	rc = pthread_cond_timedwait(&my_reply_cond->sync.cond.cond,
				&my_reply_cond->sync.cond.mutex, &wait_until);
	pthread_mutex_unlock(&my_reply_cond->sync.cond.mutex);
	if (rc != 0) {
		LM_ERR("timeout (errno: %d '%s') while awaiting Diameter "
		       "reply\n", rc, strerror(rc));
		return -2;
	}

	if (reply_cond)
		*reply_cond = my_reply_cond;

	return 0;
}

int dm_send_message(aaa_conn *_, aaa_message *req, aaa_message **reply)
{