From: Nick Porter <nick@portercomputing.co.uk>
Date: Thu, 17 Nov 2022 19:28:47 +0000 (+0000)
Subject: Add fr_network_listen_outstanding to get the number of outstanding packets
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=b77fcd50227bc8b49738f020baa0229a5f890fd9;p=thirdparty%2Ffreeradius-server.git

Add fr_network_listen_outstanding to get the number of outstanding packets
---

diff --git a/src/lib/io/network.c b/src/lib/io/network.c
index ace59577eaf..47371debb39 100644
--- a/src/lib/io/network.c
+++ b/src/lib/io/network.c
@@ -764,6 +764,25 @@ int fr_network_listen_send_packet(fr_network_t *nr, fr_listen_t *parent, fr_list
 	return 0;
 }
 
+/** Get the number of outstanding packets
+ *
+ * @param nr the network
+ * @param li the listener that the packet was "read" from
+ * @return
+ *	- <0 on error
+ *	- the number of outstanding packets
+*/
+size_t fr_network_listen_outstanding(fr_network_t *nr, fr_listen_t *li) {
+	fr_network_socket_t *s;
+
+	(void) talloc_get_type_abort(nr, fr_network_t);
+	(void) talloc_get_type_abort_const(li, fr_listen_t);
+
+	s = fr_rb_find(nr->sockets, &(fr_network_socket_t){ .listen = li });
+	if (!s) return -1;
+
+	return s->outstanding;
+}
 
 /*
  *	Mark it as dead, but DON'T free it until all of the replies
diff --git a/src/lib/io/network.h b/src/lib/io/network.h
index 4e4d358a9c5..3ec48557acd 100644
--- a/src/lib/io/network.h
+++ b/src/lib/io/network.h
@@ -64,6 +64,8 @@ int		fr_network_listen_inject(fr_network_t *nr, fr_listen_t *li, uint8_t const *
 int		fr_network_listen_send_packet(fr_network_t *nr, fr_listen_t *parent, fr_listen_t *li,
 					      const uint8_t *buffer, size_t buflen, fr_time_t recv_time, void *packet_ctx) CC_HINT(nonnull(1,2,3,4));
 
+size_t		fr_network_listen_outstanding(fr_network_t *nr, fr_listen_t *li);
+
 fr_network_t	*fr_network_create(TALLOC_CTX *ctx, fr_event_list_t *el,
 				   char const *nr, fr_log_t const *logger, fr_log_lvl_t lvl,
 				   fr_network_config_t const *config) CC_HINT(nonnull(2,4));