[gentoo-commits] portage r12717 - main/trunk/pym/portage/tests/process

[Zac Medico (zmedico)]

Author: zmedico
Date: 2009-02-27 00:48:30 +0000 (Fri, 27 Feb 2009)
New Revision: 12717

Modified:
   main/trunk/pym/portage/tests/process/test_poll.py
Log:
Fix test breakage due to change in calling order of AsynchronousTask start
listeners from r12713.


Modified: main/trunk/pym/portage/tests/process/test_poll.py
===================================================================
--- main/trunk/pym/portage/tests/process/test_poll.py	2009-02-27 00:03:26 UTC (rev 12716)
+++ main/trunk/pym/portage/tests/process/test_poll.py	2009-02-27 00:48:30 UTC (rev 12717)
@@ -33,7 +33,13 @@
 		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 @@
 		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())