[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Commit-gnuradio] [gnuradio] 40/46: zeromq: Remove blocking Add timeout
From: |
git |
Subject: |
[Commit-gnuradio] [gnuradio] 40/46: zeromq: Remove blocking Add timeout in xml, fix doxygen |
Date: |
Fri, 16 May 2014 19:37:17 +0000 (UTC) |
This is an automated email from the git hooks/post-receive script.
jcorgan pushed a commit to branch master
in repository gnuradio.
commit 2698130b46bb739b3bd2e42d68ec3e95e3ebf18f
Author: Camilo Solano <address@hidden>
Date: Tue May 13 16:32:04 2014 +0200
zeromq: Remove blocking Add timeout in xml, fix doxygen
---
gr-zeromq/examples/zeromq_pubsub.grc | 102 +++++++++++++-------------
gr-zeromq/examples/zeromq_pushpull.grc | 40 +++++-----
gr-zeromq/grc/zeromq_pub_sink.xml | 11 +--
gr-zeromq/grc/zeromq_pull_source.xml | 2 +-
gr-zeromq/grc/zeromq_push_sink.xml | 11 +--
gr-zeromq/grc/zeromq_rep_sink.xml | 11 +--
gr-zeromq/grc/zeromq_req_source.xml | 11 +--
gr-zeromq/grc/zeromq_sub_source.xml | 2 +-
gr-zeromq/include/gnuradio/zeromq/pub_sink.h | 2 +-
gr-zeromq/include/gnuradio/zeromq/push_sink.h | 2 +-
gr-zeromq/include/gnuradio/zeromq/rep_sink.h | 3 +-
11 files changed, 82 insertions(+), 115 deletions(-)
diff --git a/gr-zeromq/examples/zeromq_pubsub.grc
b/gr-zeromq/examples/zeromq_pubsub.grc
index 89e9802..ffa349e 100644
--- a/gr-zeromq/examples/zeromq_pubsub.grc
+++ b/gr-zeromq/examples/zeromq_pubsub.grc
@@ -1,6 +1,6 @@
<?xml version='1.0' encoding='ASCII'?>
<flow_graph>
- <timestamp>Tue May 13 12:47:08 2014</timestamp>
+ <timestamp>Tue May 13 16:24:39 2014</timestamp>
<block>
<key>options</key>
<param>
@@ -280,53 +280,6 @@
</param>
</block>
<block>
- <key>zeromq_sub_source</key>
- <param>
- <key>id</key>
- <value>zeromq_sub_source_0</value>
- </param>
- <param>
- <key>_enabled</key>
- <value>True</value>
- </param>
- <param>
- <key>type</key>
- <value>complex</value>
- </param>
- <param>
- <key>vlen</key>
- <value>1</value>
- </param>
- <param>
- <key>address</key>
- <value>tcp://127.0.0.1:5555</value>
- </param>
- <param>
- <key>timeout</key>
- <value>100</value>
- </param>
- <param>
- <key>affinity</key>
- <value></value>
- </param>
- <param>
- <key>minoutbuf</key>
- <value>0</value>
- </param>
- <param>
- <key>maxoutbuf</key>
- <value>0</value>
- </param>
- <param>
- <key>_coordinate</key>
- <value>(146, 415)</value>
- </param>
- <param>
- <key>_rotation</key>
- <value>0</value>
- </param>
- </block>
- <block>
<key>zeromq_pub_sink</key>
<param>
<key>id</key>
@@ -353,16 +306,12 @@
<value>100</value>
</param>
<param>
- <key>blocking</key>
- <value>True</value>
- </param>
- <param>
<key>affinity</key>
<value></value>
</param>
<param>
<key>_coordinate</key>
- <value>(753, 111)</value>
+ <value>(801, 142)</value>
</param>
<param>
<key>_rotation</key>
@@ -448,6 +397,53 @@
<value>0</value>
</param>
</block>
+ <block>
+ <key>zeromq_sub_source</key>
+ <param>
+ <key>id</key>
+ <value>zeromq_sub_source_0</value>
+ </param>
+ <param>
+ <key>_enabled</key>
+ <value>True</value>
+ </param>
+ <param>
+ <key>type</key>
+ <value>complex</value>
+ </param>
+ <param>
+ <key>vlen</key>
+ <value>1</value>
+ </param>
+ <param>
+ <key>address</key>
+ <value>tcp://127.0.0.1:5555</value>
+ </param>
+ <param>
+ <key>timeout</key>
+ <value>100</value>
+ </param>
+ <param>
+ <key>affinity</key>
+ <value></value>
+ </param>
+ <param>
+ <key>minoutbuf</key>
+ <value>0</value>
+ </param>
+ <param>
+ <key>maxoutbuf</key>
+ <value>0</value>
+ </param>
+ <param>
+ <key>_coordinate</key>
+ <value>(263, 406)</value>
+ </param>
+ <param>
+ <key>_rotation</key>
+ <value>0</value>
+ </param>
+ </block>
<connection>
<source_block_id>analog_sig_source_x_0</source_block_id>
<sink_block_id>blocks_add_xx_0</sink_block_id>
diff --git a/gr-zeromq/examples/zeromq_pushpull.grc
b/gr-zeromq/examples/zeromq_pushpull.grc
index 7b3146c..d608fcb 100644
--- a/gr-zeromq/examples/zeromq_pushpull.grc
+++ b/gr-zeromq/examples/zeromq_pushpull.grc
@@ -1,6 +1,6 @@
<?xml version='1.0' encoding='ASCII'?>
<flow_graph>
- <timestamp>Fri May 9 15:00:28 2014</timestamp>
+ <timestamp>Tue May 13 15:19:02 2014</timestamp>
<block>
<key>options</key>
<param>
@@ -359,10 +359,10 @@
</param>
</block>
<block>
- <key>zeromq_pull_source</key>
+ <key>zeromq_push_sink</key>
<param>
<key>id</key>
- <value>zeromq_pull_source_0</value>
+ <value>zeromq_push_sink_0</value>
</param>
<param>
<key>_enabled</key>
@@ -378,27 +378,23 @@
</param>
<param>
<key>address</key>
- <value>tcp://localhost:5555</value>
+ <value>tcp://127.0.0.1:5555</value>
</param>
<param>
<key>timeout</key>
<value>100</value>
</param>
<param>
- <key>affinity</key>
- <value></value>
- </param>
- <param>
- <key>minoutbuf</key>
- <value>0</value>
+ <key>blocking</key>
+ <value>False</value>
</param>
<param>
- <key>maxoutbuf</key>
- <value>0</value>
+ <key>affinity</key>
+ <value></value>
</param>
<param>
<key>_coordinate</key>
- <value>(137, 307)</value>
+ <value>(751, 96)</value>
</param>
<param>
<key>_rotation</key>
@@ -406,10 +402,10 @@
</param>
</block>
<block>
- <key>zeromq_push_sink</key>
+ <key>zeromq_pull_source</key>
<param>
<key>id</key>
- <value>zeromq_push_sink_0</value>
+ <value>zeromq_pull_source_0</value>
</param>
<param>
<key>_enabled</key>
@@ -432,16 +428,20 @@
<value>100</value>
</param>
<param>
- <key>blocking</key>
- <value>False</value>
- </param>
- <param>
<key>affinity</key>
<value></value>
</param>
<param>
+ <key>minoutbuf</key>
+ <value>0</value>
+ </param>
+ <param>
+ <key>maxoutbuf</key>
+ <value>0</value>
+ </param>
+ <param>
<key>_coordinate</key>
- <value>(751, 96)</value>
+ <value>(137, 307)</value>
</param>
<param>
<key>_rotation</key>
diff --git a/gr-zeromq/grc/zeromq_pub_sink.xml
b/gr-zeromq/grc/zeromq_pub_sink.xml
index 7f0a886..3c52eab 100644
--- a/gr-zeromq/grc/zeromq_pub_sink.xml
+++ b/gr-zeromq/grc/zeromq_pub_sink.xml
@@ -4,7 +4,7 @@
<key>zeromq_pub_sink</key>
<category>ZeroMQ Interfaces</category>
<import>from gnuradio import zeromq</import>
- <make>zeromq.pub_sink($type.itemsize, $vlen, $address, $blocking)</make>
+ <make>zeromq.pub_sink($type.itemsize, $vlen, $address, $timeout)</make>
<param>
<name>IO Type</name>
@@ -53,17 +53,10 @@
<param>
<name>Timeout (msec)</name>
<key>timeout</key>
- <value>0.1</value>
+ <value>100</value>
<type>float</type>
</param>
- <param>
- <name>Blocking</name>
- <key>blocking</key>
- <value>True</value>
- <type>bool</type>
- </param>
-
<sink>
<name>in</name>
<type>$type</type>
diff --git a/gr-zeromq/grc/zeromq_pull_source.xml
b/gr-zeromq/grc/zeromq_pull_source.xml
index f00fb57..d407e3d 100644
--- a/gr-zeromq/grc/zeromq_pull_source.xml
+++ b/gr-zeromq/grc/zeromq_pull_source.xml
@@ -53,7 +53,7 @@
<param>
<name>Timeout (msec)</name>
<key>timeout</key>
- <value>0.1</value>
+ <value>100</value>
<type>float</type>
</param>
diff --git a/gr-zeromq/grc/zeromq_push_sink.xml
b/gr-zeromq/grc/zeromq_push_sink.xml
index df901c8..5bd4702 100644
--- a/gr-zeromq/grc/zeromq_push_sink.xml
+++ b/gr-zeromq/grc/zeromq_push_sink.xml
@@ -4,7 +4,7 @@
<key>zeromq_push_sink</key>
<category>ZeroMQ Interfaces</category>
<import>from gnuradio import zeromq</import>
- <make>zeromq.push_sink($type.itemsize, $vlen, $address, $blocking)</make>
+ <make>zeromq.push_sink($type.itemsize, $vlen, $address, $timeout)</make>
<param>
<name>IO Type</name>
@@ -53,17 +53,10 @@
<param>
<name>Timeout (msec)</name>
<key>timeout</key>
- <value>0.1</value>
+ <value>100</value>
<type>float</type>
</param>
- <param>
- <name>Blocking</name>
- <key>blocking</key>
- <value>True</value>
- <type>bool</type>
- </param>
-
<sink>
<name>in</name>
<type>$type</type>
diff --git a/gr-zeromq/grc/zeromq_rep_sink.xml
b/gr-zeromq/grc/zeromq_rep_sink.xml
index 293305c..b7753f0 100644
--- a/gr-zeromq/grc/zeromq_rep_sink.xml
+++ b/gr-zeromq/grc/zeromq_rep_sink.xml
@@ -4,7 +4,7 @@
<key>zeromq_rep_sink</key>
<category>ZeroMQ Interfaces</category>
<import>from gnuradio import zeromq</import>
- <make>zeromq.rep_sink($type.itemsize, $vlen, $address, $blocking)</make>
+ <make>zeromq.rep_sink($type.itemsize, $vlen, $address, $timeout)</make>
<param>
<name>IO Type</name>
@@ -53,17 +53,10 @@
<param>
<name>Timeout (msec)</name>
<key>timeout</key>
- <value>0.1</value>
+ <value>100</value>
<type>float</type>
</param>
- <param>
- <name>Blocking</name>
- <key>blocking</key>
- <value>True</value>
- <type>bool</type>
- </param>
-
<sink>
<name>in</name>
<type>$type</type>
diff --git a/gr-zeromq/grc/zeromq_req_source.xml
b/gr-zeromq/grc/zeromq_req_source.xml
index 6da400b..ee2a70d 100644
--- a/gr-zeromq/grc/zeromq_req_source.xml
+++ b/gr-zeromq/grc/zeromq_req_source.xml
@@ -4,7 +4,7 @@
<key>zeromq_req_source</key>
<category>ZeroMQ Interfaces</category>
<import>from gnuradio import zeromq</import>
- <make>zeromq.req_source($type.itemsize, $vlen, $address)</make>
+ <make>zeromq.req_source($type.itemsize, $vlen, $address, $timeout)</make>
<param>
<name>IO Type</name>
@@ -53,17 +53,10 @@
<param>
<name>Timeout (msec)</name>
<key>timeout</key>
- <value>0.1</value>
+ <value>100</value>
<type>float</type>
</param>
- <param>
- <name>Blocking</name>
- <key>blocking</key>
- <value>True</value>
- <type>bool</type>
- </param>
-
<source>
<name>out</name>
<type>$type</type>
diff --git a/gr-zeromq/grc/zeromq_sub_source.xml
b/gr-zeromq/grc/zeromq_sub_source.xml
index 307c981..91d107d 100644
--- a/gr-zeromq/grc/zeromq_sub_source.xml
+++ b/gr-zeromq/grc/zeromq_sub_source.xml
@@ -53,7 +53,7 @@
<param>
<name>Timeout (msec)</name>
<key>timeout</key>
- <value>0.1</value>
+ <value>100</value>
<type>float</type>
</param>
diff --git a/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
b/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
index 31a5364..a60fb15 100644
--- a/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
+++ b/gr-zeromq/include/gnuradio/zeromq/pub_sink.h
@@ -51,7 +51,7 @@ namespace gr {
* \param itemsize Size of a stream item in bytes
* \param vlen Vector length of the input items. Note that one vector is
one item.
* \param address ZMQ socket address specifier
- * \param blocking Indicate whether blocking sends should be used,
default true.
+ * \param timeout Receive timeout in seconds, default is 100ms, 1us
increments
*/
static sptr make(size_t itemsize, size_t vlen, char *address, int
timeout=100);
};
diff --git a/gr-zeromq/include/gnuradio/zeromq/push_sink.h
b/gr-zeromq/include/gnuradio/zeromq/push_sink.h
index 541993d..b54a1e4 100644
--- a/gr-zeromq/include/gnuradio/zeromq/push_sink.h
+++ b/gr-zeromq/include/gnuradio/zeromq/push_sink.h
@@ -52,7 +52,7 @@ namespace gr {
* \param itemsize Size of a stream item in bytes
* \param vlen Vector length of the input items. Note that one vector is
one item.
* \param address ZMQ socket address specifier
- * \param blocking Indicate whether blocking sends should be used,
default true.
+ * \param timeout Receive timeout in seconds, default is 100ms, 1us
increments
*
*/
static sptr make(size_t itemsize, size_t vlen, char *address, int
timeout=100);
diff --git a/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
b/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
index ab92c4d..1da3252 100644
--- a/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
+++ b/gr-zeromq/include/gnuradio/zeromq/rep_sink.h
@@ -50,8 +50,7 @@ namespace gr {
* \param itemsize Size of a stream item in bytes
* \param vlen Vector length of the input items. Note that one vector is
one item.
* \param address ZMQ socket address specifier
- * \param timeout Timeout for request poll, in seconds
- * \param blocking Indicate whether blocking sends should be used,
default true.
+ * \param timeout Receive timeout in seconds, default is 100ms, 1us
increments
*
*/
static sptr make(size_t itemsize, size_t vlen, char *address, int
timeout=100);
- [Commit-gnuradio] [gnuradio] 29/46: zeromq: cleanup QA code, still needs have ZMQ_LINGER set to zero, (continued)
- [Commit-gnuradio] [gnuradio] 29/46: zeromq: cleanup QA code, still needs have ZMQ_LINGER set to zero, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 26/46: zeromq: Add qa tests, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 31/46: zeromq: Add missing timeout and blocking parameters and polling, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 25/46: zeromq: Add grc examples, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 38/46: zeromq: Don't call context close as it is not available in zmq 2, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 37/46: zeromq: Change the value of the poll timeout according to the zmq version. Must be in microseconds for version 2 and below and in milliseconds for version 3 and above., git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 35/46: zeromq: Add qa code, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 36/46: zeromq: Change string of test name, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 02/46: zeromq: initial surgery to add to master build, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 46/46: Merge branch 'zeromq', git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 40/46: zeromq: Remove blocking Add timeout in xml, fix doxygen,
git <=
- [Commit-gnuradio] [gnuradio] 39/46: Add sub_source block and fix pub_sink, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 44/46: zeromq: updates to qa code to wait for completion and pass., git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 45/46: zeromq: add missing vlen parameter in ports, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 42/46: zeromq: fixing up QA code for vlen, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 43/46: zeromq: update examples and install, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 41/46: zeromq: temporarily removing QA test output to XML, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 23/46: zeromq: cleanup docs and examples, git, 2014/05/16
- [Commit-gnuradio] [gnuradio] 01/46: Initial import of gr-zmqblocks OOT project as-is, prior to rework for in-tree, git, 2014/05/16