from functools import partial

from tornado.ioloop import IOLoop
from tornado.concurrent import Future

from ..ldapconnection import LDAPConnection
from ..errors import LDAPError

class TornadoLDAPConnection(LDAPConnection):
    def __init__(self, client, ioloop):
        super().__init__(client, is_async=True)
        self._ioloop = ioloop or IOLoop.instance()
        self._fileno = None
        
    def _io_callback(self, fut, msg_id, fd=None, events=None):
        try:
            self._ioloop.remove_handler(self._fileno)
            res = super().get_result(msg_id)
            if res is not None:
                fut.set_result(res)
            else:
                self._fileno = self.fileno()
                callback = partial(self._io_callback, fut, msg_id)
                try:
                    self._ioloop.add_handler(self._fileno, callback,
                                             IOLoop.WRITE | IOLoop.READ)
                except FileExistsError as exc:
                    if exc.errno != 17:
                        raise exc
        except LDAPError as exc:
            fut.set_exception(exc)
    
    def _evaluate(self, msg_id, timeout=None):
        fut = Future()
        callback = partial(self._io_callback, fut, msg_id)
        self._fileno = self.fileno()
        try:
            self._ioloop.add_handler(self._fileno, callback,
                                     IOLoop.WRITE | IOLoop.READ)
        except FileExistsError as exc:
            # Avoid concurrency problems by registring with
            # the same fileno more than once.
            if exc.errno != 17:
                raise exc
        return fut
@@ -255,16 +255,21 @@
 , ioloop
+=None
 ):%0A     
@@ -1651,12 +1651,13 @@
   return fut
+%0A

Set default ioloop for TornadoLDAPConnection