From 3ed5d7e7c6bc995018ed9c3d63c18504f3983341 Mon Sep 17 00:00:00 2001
From: Garrett D'Amore <garrett@damore.org>
Date: Sat, 23 Nov 2024 09:12:29 -0800
Subject: listener: add listener_create_url and listen_url

---
 src/nng.c | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)

(limited to 'src/nng.c')

diff --git a/src/nng.c b/src/nng.c
index c1843d38..2bc9986c 100644
--- a/src/nng.c
+++ b/src/nng.c
@@ -592,6 +592,34 @@ nng_listen(nng_socket sid, const char *addr, nng_listener *lp, int flags)
 	return (rv);
 }
 
+int
+nng_listen_url(nng_socket sid, const nng_url *url, nng_listener *lp, int flags)
+{
+	int           rv;
+	nni_sock     *s;
+	nni_listener *l;
+
+	if ((rv = nni_sock_find(&s, sid.id)) != 0) {
+		return (rv);
+	}
+	if ((rv = nni_listener_create_url(&l, s, url)) != 0) {
+		nni_sock_rele(s);
+		return (rv);
+	}
+	if ((rv = nni_listener_start(l, flags)) != 0) {
+		nni_listener_close(l);
+		return (rv);
+	}
+
+	if (lp != NULL) {
+		nng_listener lid;
+		lid.id = nni_listener_id(l);
+		*lp    = lid;
+	}
+	nni_listener_rele(l);
+	return (rv);
+}
+
 int
 nng_listener_create(nng_listener *lp, nng_socket sid, const char *addr)
 {
@@ -613,6 +641,27 @@ nng_listener_create(nng_listener *lp, nng_socket sid, const char *addr)
 	return (0);
 }
 
+int
+nng_listener_create_url(nng_listener *lp, nng_socket sid, const nng_url *url)
+{
+	nni_sock     *s;
+	int           rv;
+	nni_listener *l;
+	nng_listener  lid;
+
+	if ((rv = nni_sock_find(&s, sid.id)) != 0) {
+		return (rv);
+	}
+	if ((rv = nni_listener_create_url(&l, s, url)) != 0) {
+		nni_sock_rele(s);
+		return (rv);
+	}
+	lid.id = nni_listener_id(l);
+	*lp    = lid;
+	nni_listener_rele(l);
+	return (0);
+}
+
 int
 nng_listener_start(nng_listener lid, int flags)
 {
-- 
cgit v1.2.3-70-g09d2