aboutsummaryrefslogtreecommitdiff
path: root/src/nng.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2025-04-14 00:03:47 -0700
committerGarrett D'Amore <garrett@damore.org>2025-04-19 20:42:59 -0700
commitdf3059dd130ce22f2326abeb41149bdf35e0c38d (patch)
tree83ce0a27ac4a29f058977e378cc9f321e5995ef7 /src/nng.c
parent55925438bc8b8fd243ab995c48c8996ac49a6652 (diff)
downloadnng-gdamore/udpconn.tar.gz
nng-gdamore/udpconn.tar.bz2
nng-gdamore/udpconn.zip
UDP: Add support for connected mode UDP sockets.gdamore/udpconn
Diffstat (limited to 'src/nng.c')
-rw-r--r--src/nng.c13
1 files changed, 13 insertions, 0 deletions
diff --git a/src/nng.c b/src/nng.c
index 68820675..96591678 100644
--- a/src/nng.c
+++ b/src/nng.c
@@ -1268,6 +1268,7 @@ static const struct {
{ NNG_EPEERAUTH, "Peer could not be authenticated" },
{ NNG_EBADTYPE, "Incorrect type" },
{ NNG_ECONNSHUT, "Connection shutdown" },
+ { NNG_ENOTCONN, "Not connected"},
{ NNG_ESTOPPED, "Operation stopped"},
{ NNG_EINTERNAL, "Internal error detected" },
{ 0, NULL },
@@ -2147,6 +2148,12 @@ nng_udp_open(nng_udp **udp, nng_sockaddr *sa)
return (nni_plat_udp_open((nni_plat_udp **) udp, sa));
}
+int
+nng_udp_connect(nng_udp **udp, nng_sockaddr *self, nng_sockaddr *peer)
+{
+ return (nni_plat_udp_connect((nni_plat_udp **) udp, self, peer));
+}
+
void
nng_udp_close(nng_udp *udp)
{
@@ -2159,6 +2166,12 @@ nng_udp_sockname(nng_udp *udp, nng_sockaddr *sa)
return (nni_plat_udp_sockname((nni_plat_udp *) udp, sa));
}
+int
+nng_udp_peername(nng_udp *udp, nng_sockaddr *sa)
+{
+ return (nni_plat_udp_peername((nni_plat_udp *) udp, sa));
+}
+
void
nng_udp_send(nng_udp *udp, nng_aio *aio)
{