From 5d0cffc52f575ff572751cc85fd43063391a211d Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sun, 15 May 2011 18:25:43 +0200 Subject: ZMQ_MULTICAST_HOPS socket option added Sets the time-to-live field in every multicast packet sent from the socket. Signed-off-by: Martin Sustrik --- src/pgm_socket.cpp | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) (limited to 'src/pgm_socket.cpp') diff --git a/src/pgm_socket.cpp b/src/pgm_socket.cpp index 8a60ec2..80b80a7 100644 --- a/src/pgm_socket.cpp +++ b/src/pgm_socket.cpp @@ -169,24 +169,30 @@ int zmq::pgm_socket_t::init (bool udp_encapsulation_, const char *network_) } { - const int rcvbuf = (int) options.rcvbuf, - sndbuf = (int) options.sndbuf, - max_tpdu = (int) pgm_max_tpdu; + // Propagate various socket options to the OpenPGM layer. + const int rcvbuf = (int) options.rcvbuf; if (rcvbuf) { if (!pgm_setsockopt (sock, SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof (rcvbuf))) goto err_abort; } + + const int sndbuf = (int) options.sndbuf; if (sndbuf) { if (!pgm_setsockopt (sock, SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof (sndbuf))) goto err_abort; } - // Set maximum transport protocol data unit size (TPDU). + const int max_tpdu = (int) pgm_max_tpdu; if (!pgm_setsockopt (sock, IPPROTO_PGM, PGM_MTU, &max_tpdu, sizeof (max_tpdu))) goto err_abort; + + const int multicast_hops = (int) options.multicast_hops; + if (!pgm_setsockopt (sock, IPPROTO_PGM, PGM_MULTICAST_HOPS, + &multicast_hops, sizeof (int))) + goto err_abort; } if (receiver) { -- cgit v1.2.3