Make LazyImportPortageBaselineTestCase use a PollScheduler instance
authorZac Medico <zmedico@gentoo.org>
Sun, 5 Sep 2010 19:24:49 +0000 (12:24 -0700)
committerZac Medico <zmedico@gentoo.org>
Sun, 5 Sep 2010 19:24:49 +0000 (12:24 -0700)
directly since TaskScheduler isn't really needed.

pym/portage/tests/lazyimport/test_lazy_import_portage_baseline.py

index d96f83a9b3985f97054af12292f12ee67b87287d..f434573d059908c109706bd231f4bac494ecde85 100644 (file)
@@ -6,7 +6,7 @@ import portage
 from portage import os
 from portage.tests import TestCase
 
-from _emerge.TaskScheduler import TaskScheduler
+from _emerge.PollScheduler import PollScheduler
 from _emerge.PipeReader import PipeReader
 from _emerge.SpawnProcess import SpawnProcess
 
@@ -30,23 +30,23 @@ class LazyImportPortageBaselineTestCase(TestCase):
                Check what modules are imported by a baseline module import.
                """
 
-               task_scheduler = TaskScheduler()
+               scheduler = PollScheduler().sched_iface
                master_fd, slave_fd = os.pipe()
                master_file = os.fdopen(master_fd, 'rb')
                slave_file = os.fdopen(slave_fd, 'wb')
                producer = SpawnProcess(
                        args=self._baseline_import_cmd,
                        env=os.environ, fd_pipes={1:slave_fd},
-                       scheduler=task_scheduler.sched_iface)
+                       scheduler=scheduler)
                producer.start()
                slave_file.close()
 
                consumer = PipeReader(
                        input_files={"producer" : master_file},
-                       scheduler=task_scheduler.sched_iface)
+                       scheduler=scheduler)
 
-               task_scheduler.add(consumer)
-               task_scheduler.run()
+               consumer.start()
+               consumer.wait()
                output = consumer.getvalue().decode('ascii', 'replace').split()
 
                unexpected_modules = " ".join(sorted(x for x in output \