From: Alan T. DeKok <aland@freeradius.org>
Date: Tue, 4 Apr 2017 15:35:22 +0000 (-0400)
Subject: more messages
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=09bec5fce2f177f405f29823975fd1eab04cd9a2;p=thirdparty%2Ffreeradius-server.git

more messages
---

diff --git a/src/util/worker.c b/src/util/worker.c
index 98d5f135b55..d4a8443544b 100644
--- a/src/util/worker.c
+++ b/src/util/worker.c
@@ -455,6 +455,8 @@ static void fr_worker_send_reply(fr_worker_t *worker, REQUEST *request, size_t s
 	reply->priority = request->priority;
 	reply->transport = request->transport->id;
 
+	MPRINT("(%zd) finished, sending reply\n", request->number);
+
 	/*
 	 *	Send the reply, which also polls the request queue.
 	 */
@@ -575,6 +577,8 @@ static void fr_worker_check_timeouts(fr_worker_t *worker, fr_time_t now)
 			continue;
 		}
 
+		MPRINT("(%zd) taking too long, stopping it\n", request->number);
+
 		/*
 		 *	Tell the network side that this request is done.
 		 */
@@ -596,6 +600,9 @@ static void fr_worker_check_timeouts(fr_worker_t *worker, fr_time_t now)
 
 		if (final == FR_TRANSPORT_DONE) {
 			FR_DLIST_REMOVE(worker->waiting_to_die);
+
+			MPRINT("(%zd) finally finished\n", request->number);
+
 			/*
 			 *	Tell the network side that this request is done.
 			 */
@@ -696,6 +703,10 @@ static REQUEST *fr_worker_get_request(fr_worker_t *worker, fr_time_t now)
 	request->el = worker->el;
 	request->packet_ctx = cd->ctx;
 
+	/*
+	 *	@todo - call worker->transports[cd->transport]->recv_request()
+	 */
+
 	/*
 	 *	Now that the "request" structure has been initialized, go decode the packet.
 	 */
@@ -753,6 +764,8 @@ static void fr_worker_run_request(fr_worker_t *worker, REQUEST *request)
 	ssize_t size = 0;
 	fr_transport_final_t final;
 
+	MPRINT("(%zd) running\n", request->number);
+
 	/*
 	 *	If we still have the same packet, and the channel is
 	 *	active, run it.  Otherwise, tell it that it's done.
@@ -797,6 +810,8 @@ static void fr_worker_run_request(fr_worker_t *worker, REQUEST *request)
 		break;
 	}
 
+	MPRINT("(%zd) done naturally\n", request->number);
+
 	fr_worker_send_reply(worker, request, size);
 }