Function dm_peer_loop

modules/aaa_diameter/dm_peer.c:622–672

void dm_peer_loop(int _)
{
	struct dm_message *msg;

	LM_INFO("freeDiameter dedicated process starting...\n");

	if (freeDiameter_init() != 0) {
		LM_ERR("failed to init freeDiameter library\n");
		return;
	}

	__FD_CHECK(dm_register_osips_avps(), 0, );
	__FD_CHECK(dm_init_sip_application(), 0, );
	__FD_CHECK(dm_prepare_globals(), 0, );
	__FD_CHECK(parse_extra_avps(extra_avps_file), 0, );

	__FD_CHECK(dm_register_callbacks(), 0, );
	__FD_CHECK(fd_core_start(), 0, );

	if (dm_init_reply_cond(-2) != 0) {
		LM_ERR("failed to init cond\n");
		return;
	}

	pthread_mutex_lock(msg_send_lk);

	for (;;) {
		LM_DBG("waiting to send new messages...\n");
		pthread_cond_wait(msg_send_cond, msg_send_lk);

		if (list_empty(msg_send_queue)) {
			LM_BUG("pthread cond signal on empty queue");
			continue;
		}

		LM_DBG("have new message to send -- processing...\n");
		msg = list_entry(msg_send_queue->next, struct dm_message, list);
		list_del(&msg->list);

		if (dm_peer_send_msg(msg) != 0)
			LM_ERR("failed to send message\n");
		else
			LM_DBG("successfully sent\n");

		_dm_destroy_message(msg->am);
	}

	pthread_mutex_unlock(msg_send_lk);

	__FD_CHECK(fd_core_wait_shutdown_complete(), 0, );
}