From: Alan T. DeKok <aland@freeradius.org>
Date: Mon, 12 Dec 2016 18:33:39 +0000 (-0500)
Subject: add debug messages
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=2beafef627d8a1bc10c90e81dafd0ed865b10409;p=thirdparty%2Ffreeradius-server.git

add debug messages
---

diff --git a/src/util/atomic_queue.c b/src/util/atomic_queue.c
index b01218b1c36..23e7e724f52 100644
--- a/src/util/atomic_queue.c
+++ b/src/util/atomic_queue.c
@@ -147,6 +147,9 @@ bool fr_atomic_queue_push(fr_atomic_queue_t *aq, void *data)
 		 *	head is larger than the current entry, the queue is full.
 		 */
 		if (diff < 0) {
+#if 0
+			fr_atomic_queue_debug(aq, stderr);
+#endif
 			return false;
 		}
 
@@ -239,6 +242,19 @@ bool fr_atomic_queue_pop(fr_atomic_queue_t *aq, void **p_data)
 }
 
 #ifndef NDEBUG
+
+#if 0
+typedef struct fr_control_message_t {
+	int			status;		//!< status of this message
+	size_t				data_size;     	//!< size of the data we're sending
+
+	int			signal;		//!< the signal to send
+	uint64_t		ack;		//!< or the endpoint..
+	void			*ch;		//!< the channel
+} fr_control_message_t;
+#endif
+
+
 /**  Dump an atomic queue.
  *
  *  Absolutely NOT thread-safe.
@@ -262,8 +278,19 @@ void fr_atomic_queue_debug(fr_atomic_queue_t *aq, FILE *fp)
 
 		entry = &aq->entry[i];
 
-		fprintf(fp, "\t[%d] = { %p, %zd }\n",
+		fprintf(fp, "\t[%d] = { %p, %zd }",
 			i, entry->data, load(entry->seq));
+#if 0
+		if (entry->data) {
+			fr_control_message_t *c;
+
+			c = entry->data;
+
+			fprintf(fp, "\tstatus %d, data_size %zd, signal %d, ack %zd, ch %p",
+				c->status, c->data_size, c->signal, c->ack, c->ch);
+		}
+#endif
+		fprintf(fp, "\n");
 	}
 }
 #endif