diff options
Diffstat (limited to 'src/sp/transport/udp/udp.c')
| -rw-r--r-- | src/sp/transport/udp/udp.c | 34 |
1 files changed, 25 insertions, 9 deletions
diff --git a/src/sp/transport/udp/udp.c b/src/sp/transport/udp/udp.c index 242ca481..7f46a3c9 100644 --- a/src/sp/transport/udp/udp.c +++ b/src/sp/transport/udp/udp.c @@ -261,6 +261,20 @@ udp_pipe_start(udp_pipe *p, udp_ep *ep, const nng_sockaddr *sa) return (udp_add_pipe(ep, p)); } +static const nng_sockaddr * +udp_pipe_peer_addr(void *arg) +{ + udp_pipe *p = arg; + return (&p->peer_addr); +} + +static const nng_sockaddr * +udp_pipe_self_addr(void *arg) +{ + udp_pipe *p = arg; + return (&p->ep->self_sa); +} + static void udp_pipe_fini(void *arg) { @@ -1693,15 +1707,17 @@ udp_pipe_size(void) } static nni_sp_pipe_ops udp_pipe_ops = { - .p_size = udp_pipe_size, - .p_init = udp_pipe_init, - .p_fini = udp_pipe_fini, - .p_stop = udp_pipe_stop, - .p_send = udp_pipe_send, - .p_recv = udp_pipe_recv, - .p_close = udp_pipe_close, - .p_peer = udp_pipe_peer, - .p_getopt = udp_pipe_getopt, + .p_size = udp_pipe_size, + .p_init = udp_pipe_init, + .p_fini = udp_pipe_fini, + .p_stop = udp_pipe_stop, + .p_send = udp_pipe_send, + .p_recv = udp_pipe_recv, + .p_close = udp_pipe_close, + .p_peer = udp_pipe_peer, + .p_getopt = udp_pipe_getopt, + .p_peer_addr = udp_pipe_peer_addr, + .p_self_addr = udp_pipe_self_addr, }; static const nni_option udp_ep_opts[] = { |