Updated to not depend on IOLoop's _set_nonblocking and _set_close_exec, which were...

diff --git a/tornado/test/twistedreactor_test.py b/tornado/test/twistedreactor_test.py
index de87456a76f417c986f51afb2662b80423909281..410e76fb9e62b22161f2687fdb559df9cd7eb17a 100644 (file)
--- a/tornado/test/twistedreactor_test.py
+++ b/tornado/test/twistedreactor_test.py
@@ -1,18 +1,19 @@
+import fcntl
 import os
 import sys
 import thread
+import unittest
 
 import tornado.twisted.reactor
 tornado.twisted.reactor.install()
 from twisted.internet import reactor
 
 from twisted.internet.interfaces import IReadDescriptor, IWriteDescriptor
-
 from twisted.python import log
+from tornado.platform.auto import Waker
 
 from tornado.twisted.reactor import TornadoReactor
 from tornado.testing import AsyncTestCase, LogTrapTestCase
-import unittest
 
 from zope.interface import implements
 
@@ -161,13 +162,21 @@ class Writer:
         self._callback(self._fd)
 
 class ReactorReaderWriterTest(unittest.TestCase):
+    def _set_close_exec(self, fd):
+        flags = fcntl.fcntl(fd, fcntl.F_GETFD)
+        fcntl.fcntl(fd, fcntl.F_SETFD, flags | fcntl.FD_CLOEXEC)
+
+    def _set_nonblocking(self, fd):
+        flags = fcntl.fcntl(fd, fcntl.F_GETFL)
+        fcntl.fcntl(fd, fcntl.F_SETFL, flags | os.O_NONBLOCK)
+
     def setUp(self):
         self._reactor = TornadoReactor()
         r, w = os.pipe()
-        self._reactor._ioloop._set_nonblocking(r)
-        self._reactor._ioloop._set_nonblocking(w)
-        self._reactor._ioloop._set_close_exec(r)
-        self._reactor._ioloop._set_close_exec(w)
+        self._set_nonblocking(r)
+        self._set_nonblocking(w)
+        self._set_close_exec(r)
+        self._set_close_exec(w)
         self._p1 = os.fdopen(r, "rb", 0)
         self._p2 = os.fdopen(w, "wb", 0)