diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-10-05 18:26:50 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-10-05 18:26:50 -0700 |
| commit | defc7bf583753444851cb651466d91240fa4fbc8 (patch) | |
| tree | 1d55cc1373a04cc48c9d8954d6f1a602a8375267 /src/core/message.c | |
| parent | eef8f5f4a4d8d05470503e7f6dc7270c7e488cb5 (diff) | |
| download | nng-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.c | 13 |
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; +} |
