6 files changed, 12 insertions, 6 deletions
diff --git a/gr-zeromq/include/gnuradio/zeromq/pub_sink.h b/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
index e8871c22ac..e87c5522f9 100644
--- a/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
+++ b/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
@@ -53,9 +53,10 @@ namespace gr {
        * \param address  ZMQ socket address specifier.
        * \param timeout  Receive timeout in seconds, default is 100ms, 1us increments.
        * \param pass_tags Whether sink will serialize and pass tags over the link.
+       * \param hwm High Watermark to configure the socket to (-1 => zmq's default)
        */
       static sptr make(size_t itemsize, size_t vlen, char *address,
-                       int timeout=100, bool pass_tags=false);
+                       int timeout=100, bool pass_tags=false, int hwm=-1);
     };
 
   } // namespace zeromq
diff --git a/gr-zeromq/include/gnuradio/zeromq/pull_source.h b/gr-zeromq/include/gnuradio/zeromq/pull_source.h
index ca7b40726d..07cf6af128 100644
--- a/gr-zeromq/include/gnuradio/zeromq/pull_source.h
+++ b/gr-zeromq/include/gnuradio/zeromq/pull_source.h
@@ -50,9 +50,10 @@ namespace gr {
        * \param address  ZMQ socket address specifier.
        * \param timeout  Receive timeout in seconds, default is 100ms, 1us increments.
        * \param pass_tags Whether source will look for and deserialize tags.
+       * \param hwm High Watermark to configure the socket to (-1 => zmq's default)
        */
       static sptr make(size_t itemsize, size_t vlen, char *address,
-                       int timeout=100, bool pass_tags=false);
+                       int timeout=100, bool pass_tags=false, int hwm=-1);
     };
 
   } // namespace zeromq
diff --git a/gr-zeromq/include/gnuradio/zeromq/push_sink.h b/gr-zeromq/include/gnuradio/zeromq/push_sink.h
index 0f21b446b4..e2260aa3f6 100644
--- a/gr-zeromq/include/gnuradio/zeromq/push_sink.h
+++ b/gr-zeromq/include/gnuradio/zeromq/push_sink.h
@@ -54,9 +54,10 @@ namespace gr {
        * \param address  ZMQ socket address specifier.
        * \param timeout  Receive timeout in seconds, default is 100ms, 1us increments.
        * \param pass_tags Whether sink will serialize and pass tags over the link.
+       * \param hwm High Watermark to configure the socket to (-1 => zmq's default)
        */
       static sptr make(size_t itemsize, size_t vlen, char *address,
-                       int timeout=100, bool pass_tags=false);
+                       int timeout=100, bool pass_tags=false, int hwm=-1);
     };
 
   } // namespace zeromq
diff --git a/gr-zeromq/include/gnuradio/zeromq/rep_sink.h b/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
index 33fd38b2df..220bd34416 100644
--- a/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
+++ b/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
@@ -52,9 +52,10 @@ namespace gr {
        * \param address  ZMQ socket address specifier.
        * \param timeout  Receive timeout in seconds, default is 100ms, 1us increments.
        * \param pass_tags Whether sink will serialize and pass tags over the link.
+       * \param hwm High Watermark to configure the socket to (-1 => zmq's default)
        */
       static sptr make(size_t itemsize, size_t vlen, char *address,
-                       int timeout=100, bool pass_tags=false);
+                       int timeout=100, bool pass_tags=false, int hwm=-1);
     };
 
   } // namespace zeromq
diff --git a/gr-zeromq/include/gnuradio/zeromq/req_source.h b/gr-zeromq/include/gnuradio/zeromq/req_source.h
index 9936406c23..461f653b43 100644
--- a/gr-zeromq/include/gnuradio/zeromq/req_source.h
+++ b/gr-zeromq/include/gnuradio/zeromq/req_source.h
@@ -50,9 +50,10 @@ namespace gr {
        * \param address  ZMQ socket address specifier.
        * \param timeout  Receive timeout in seconds, default is 100ms, 1us increments.
        * \param pass_tags Whether source will look for and deserialize tags.
+       * \param hwm High Watermark to configure the socket to (-1 => zmq's default)
        */
       static sptr make(size_t itemsize, size_t vlen, char *address,
-                       int timeout=100, bool pass_tags=false);
+                       int timeout=100, bool pass_tags=false, int hwm=-1);
     };
 
   } // namespace zeromq
diff --git a/gr-zeromq/include/gnuradio/zeromq/sub_source.h b/gr-zeromq/include/gnuradio/zeromq/sub_source.h
index 5fdd8932ec..def3a703e6 100644
--- a/gr-zeromq/include/gnuradio/zeromq/sub_source.h
+++ b/gr-zeromq/include/gnuradio/zeromq/sub_source.h
@@ -50,9 +50,10 @@ namespace gr {
        * \param address  ZMQ socket address specifier.
        * \param timeout  Receive timeout in seconds, default is 100ms, 1us increments.
        * \param pass_tags Whether source will look for and deserialize tags.
+       * \param hwm High Watermark to configure the socket to (-1 => zmq's default)
        */
       static sptr make(size_t itemsize, size_t vlen, char *address,
-                       int timeout=100, bool pass_tags=false);
+                       int timeout=100, bool pass_tags=false, int hwm=-1);
     };
 
   } // namespace zeromq