aboutsummaryrefslogtreecommitdiff
path: root/src/core/message.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2024-10-05 18:26:50 -0700
committerGarrett D'Amore <garrett@damore.org>2024-10-05 18:26:50 -0700
commitdefc7bf583753444851cb651466d91240fa4fbc8 (patch)
tree1d55cc1373a04cc48c9d8954d6f1a602a8375267 /src/core/message.c
parenteef8f5f4a4d8d05470503e7f6dc7270c7e488cb5 (diff)
downloadnng-defc7bf583753444851cb651466d91240fa4fbc8.tar.gz
nng-defc7bf583753444851cb651466d91240fa4fbc8.tar.bz2
nng-defc7bf583753444851cb651466d91240fa4fbc8.zip
msg: add sockaddr to message structure
This is expected to be useful for new transports where we need the sock address to properly reply (think UDP with multicast).
Diffstat (limited to 'src/core/message.c')
-rw-r--r--src/core/message.c13
1 files changed, 13 insertions, 0 deletions
diff --git a/src/core/message.c b/src/core/message.c
index 5fdad109..64a63201 100644
--- a/src/core/message.c
+++ b/src/core/message.c
@@ -29,6 +29,7 @@ struct nng_msg {
nni_chunk m_body;
uint32_t m_pipe; // set on receive
nni_atomic_int m_refcnt;
+ nng_sockaddr m_addr; // set on receive, transport use
};
#if 0
@@ -656,3 +657,15 @@ nni_msg_get_pipe(const nni_msg *m)
{
return (m->m_pipe);
}
+
+const nng_sockaddr *
+nni_msg_address(const nni_msg *msg)
+{
+ return (&msg->m_addr);
+}
+
+void
+nni_msg_set_address(nng_msg *msg, const nng_sockaddr *addr)
+{
+ msg->m_addr = *addr;
+}