summaryrefslogtreecommitdiff
path: root/gnuradio-core/src
diff options
context:
space:
mode:
authorEric Blossom2010-10-23 11:47:36 -0700
committerEric Blossom2010-11-10 12:13:53 -0800
commit52da23e0c42298a1cba07546259037c92db8c588 (patch)
tree19bb0d3c58b110018412dd23830dc99a74da0032 /gnuradio-core/src
parent70dd1dc6610135a1967de554189be38af8f3b080 (diff)
downloadgnuradio-52da23e0c42298a1cba07546259037c92db8c588.tar.gz
gnuradio-52da23e0c42298a1cba07546259037c92db8c588.tar.bz2
gnuradio-52da23e0c42298a1cba07546259037c92db8c588.zip
Remove dead code
Diffstat (limited to 'gnuradio-core/src')
-rw-r--r--gnuradio-core/src/python/gnuradio/gr/Makefile.am1
-rw-r--r--gnuradio-core/src/python/gnuradio/gr/scheduler.py70
2 files changed, 0 insertions, 71 deletions
diff --git a/gnuradio-core/src/python/gnuradio/gr/Makefile.am b/gnuradio-core/src/python/gnuradio/gr/Makefile.am
index 341f58812..c3017adcc 100644
--- a/gnuradio-core/src/python/gnuradio/gr/Makefile.am
+++ b/gnuradio-core/src/python/gnuradio/gr/Makefile.am
@@ -39,7 +39,6 @@ grgrpython_PYTHON = \
gr_threading_24.py \
hier_block2.py \
prefs.py \
- scheduler.py \
top_block.py \
pubsub.py
diff --git a/gnuradio-core/src/python/gnuradio/gr/scheduler.py b/gnuradio-core/src/python/gnuradio/gr/scheduler.py
deleted file mode 100644
index 67f79ab77..000000000
--- a/gnuradio-core/src/python/gnuradio/gr/scheduler.py
+++ /dev/null
@@ -1,70 +0,0 @@
-#
-# Copyright 2004 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 3, 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.gr.exceptions import *
-from gnuradio_core import single_threaded_scheduler, sts_pyrun
-import gr_threading as _threading
-#import threading as _threading
-
-class scheduler_thread(_threading.Thread):
- def __init__(self, sts):
- _threading.Thread.__init__(self)
- self.sts = sts
- def run(self):
- # Invoke the single threaded scheduler's run method
- #
- # Note that we're in a new thread, and that sts_pyrun
- # releases the global interpreter lock. This has the
- # effect of evaluating the graph in parallel to the
- # main line control code.
- sts_pyrun(self.sts)
- self.sts = None
-
-class scheduler(object):
- def __init__(self, fg):
- graphs = fg.partition_graph(fg.blocks)
- # print "@@@ # graphs = %d" % (len(graphs))
-
- self.state = []
-
- for g in graphs:
- list_of_blocks = [x.block() for x in g]
- sts = single_threaded_scheduler(list_of_blocks)
- thread = scheduler_thread(sts)
- thread.setDaemon(1)
- self.state.append((sts, thread))
-
- def start(self):
- for (sts, thread) in self.state:
- thread.start()
-
- def stop(self):
- for (sts, thread) in self.state:
- sts.stop()
- self.wait()
-
- def wait(self):
- for (sts, thread) in self.state:
- timeout = 0.100
- while True:
- thread.join(timeout)
- if not thread.isAlive():
- break