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 <sustrik@250bpm.com>

1 files changed, 10 insertions, 4 deletions

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) {