From: Zac Medico <zmedico@gentoo.org>
Date: Fri, 27 Feb 2009 00:48:30 +0000 (-0000)
Subject: Fix test breakage due to change in calling order of AsynchronousTask start
X-Git-Tag: v2.2_rc24~98
X-Git-Url: http://git.tremily.us/?a=commitdiff_plain;h=3bafa92366dc85bb139048e621aaa51001bec03b;p=portage.git

Fix test breakage due to change in calling order of AsynchronousTask start
listeners from r12713.

svn path=/main/trunk/; revision=12717
---

diff --git a/pym/portage/tests/process/test_poll.py b/pym/portage/tests/process/test_poll.py
index ebcc822ef..904930410 100644
--- a/pym/portage/tests/process/test_poll.py
+++ b/pym/portage/tests/process/test_poll.py
@@ -33,7 +33,13 @@ class PipeReaderTestCase(TestCase):
 		task_scheduler = TaskScheduler(max_jobs=2)
 		scheduler = task_scheduler.sched_iface
 
-		producer = SpawnProcess(
+		class Producer(SpawnProcess):
+			def _spawn(self, args, **kwargs):
+				rval = SpawnProcess._spawn(self, args, **kwargs)
+				os.close(kwargs['fd_pipes'][1])
+				return rval
+
+		producer = Producer(
 			args=["bash", "-c", "echo -n '%s'" % test_string],
 			fd_pipes={1:slave_fd}, scheduler=scheduler)
 
@@ -44,10 +50,6 @@ class PipeReaderTestCase(TestCase):
 		task_scheduler.add(producer)
 		task_scheduler.add(consumer)
 
-		def producer_start_cb(task):
-			os.close(slave_fd)
-
-		producer.addStartListener(producer_start_cb)
 		task_scheduler.run()
 
 		self._assertEqual(test_string, consumer.getvalue())