Fix long standing hang when exiting due to blocking read in gr-pager.

git-svn-id: http://gnuradio.org/svn/gnuradio/trunk@5903 221aa14e-8319-0410-a670-987f0aec2ac5

diff --git a/gr-pager/src/flex_demod.py b/gr-pager/src/flex_demod.py
index a8c6f09b1326c4c553b3d3fcab8a985d15d36afb..0d35cf3f4242ceed1f0dedca3a44bc0a04c33e62 100644 (file)
--- a/gr-pager/src/flex_demod.py
+++ b/gr-pager/src/flex_demod.py
@@ -1,5 +1,5 @@
 #
-# Copyright 2006 Free Software Foundation, Inc.
+# Copyright 2006,2007 Free Software Foundation, Inc.
 # 
 # This file is part of GNU Radio
 # 

diff --git a/gr-pager/src/usrp_flex.py b/gr-pager/src/usrp_flex.py
index 055583c995c1f410e453874f02b5a5428b6ad81c..a9d6593fda03682e64fec3e439d8623b99d0bac6 100755 (executable)
--- a/gr-pager/src/usrp_flex.py
+++ b/gr-pager/src/usrp_flex.py
@@ -1,5 +1,26 @@
 #!/usr/bin/env python
 
+#
+# Copyright 2006,2007 Free Software Foundation, Inc.
+# 
+# This file is part of GNU Radio
+# 
+# GNU Radio is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2, or (at your option)
+# any later version.
+# 
+# GNU Radio is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+# 
+# You should have received a copy of the GNU General Public License
+# along with GNU Radio; see the file COPYING.  If not, write to
+# the Free Software Foundation, Inc., 51 Franklin Street,
+# Boston, MA 02110-1301, USA.
+# 
+
 from gnuradio import gr, gru, usrp, optfir, eng_notation, blks, pager
 from gnuradio.eng_option import eng_option
 from optparse import OptionParser
@@ -127,9 +148,12 @@ def main():
     try:
         fg.start()
        while 1:
-           msg = queue.delete_head() # Blocking read
-           fields = split(msg.to_string(), chr(128))
-           print join(fields, '|')
+           if not queue.empty_p():
+               msg = queue.delete_head() # Blocking read
+               fields = split(msg.to_string(), chr(128))
+               print join(fields, '|')
+           else:
+               time.sleep(1)
 
     except KeyboardInterrupt:
         fg.stop()