From: Ben Darnell <ben@bendarnell.com>
Date: Sun, 29 Jul 2018 22:22:17 +0000 (-0400)
Subject: gen: Remove some dead code
X-Git-Tag: v6.0.0b1~35^2~2
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=9f4f0f4414b412f9655ce3fc988b9b268b1d5dff;p=thirdparty%2Ftornado.git

gen: Remove some dead code
---

diff --git a/tornado/gen.py b/tornado/gen.py
index 982cb8dfc..b7e84cc49 100644
--- a/tornado/gen.py
+++ b/tornado/gen.py
@@ -644,50 +644,13 @@ class Runner(object):
         self.gen = gen
         self.result_future = result_future
         self.future = _null_future
-        self.yield_point = None
-        self.pending_callbacks = None
-        self.results = None
         self.running = False
         self.finished = False
-        self.had_exception = False
         self.io_loop = IOLoop.current()
         if self.handle_yield(first_yielded):
             gen = result_future = first_yielded = None
             self.run()
 
-    def register_callback(self, key):
-        """Adds ``key`` to the list of callbacks."""
-        if self.pending_callbacks is None:
-            # Lazily initialize the old-style YieldPoint data structures.
-            self.pending_callbacks = set()
-            self.results = {}
-        if key in self.pending_callbacks:
-            raise KeyReuseError("key %r is already pending" % (key,))
-        self.pending_callbacks.add(key)
-
-    def is_ready(self, key):
-        """Returns true if a result is available for ``key``."""
-        if self.pending_callbacks is None or key not in self.pending_callbacks:
-            raise UnknownKeyError("key %r is not pending" % (key,))
-        return key in self.results
-
-    def set_result(self, key, result):
-        """Sets the result for ``key`` and attempts to resume the generator."""
-        self.results[key] = result
-        if self.yield_point is not None and self.yield_point.is_ready():
-            try:
-                future_set_result_unless_cancelled(self.future,
-                                                   self.yield_point.get_result())
-            except:
-                future_set_exc_info(self.future, sys.exc_info())
-            self.yield_point = None
-            self.run()
-
-    def pop_result(self, key):
-        """Returns the result for ``key`` and unregisters it."""
-        self.pending_callbacks.remove(key)
-        return self.results.pop(key)
-
     def run(self):
         """Starts or resumes the generator, running until it reaches a
         yield point that is not ready.
@@ -707,7 +670,6 @@ class Runner(object):
                     try:
                         value = future.result()
                     except Exception:
-                        self.had_exception = True
                         exc_info = sys.exc_info()
                     future = None
 
@@ -724,14 +686,6 @@ class Runner(object):
                 except (StopIteration, Return) as e:
                     self.finished = True
                     self.future = _null_future
-                    if self.pending_callbacks and not self.had_exception:
-                        # If we ran cleanly without waiting on all callbacks
-                        # raise an error (really more of a warning).  If we
-                        # had an exception then some callbacks may have been
-                        # orphaned, so skip the check in that case.
-                        raise LeakedCallbackError(
-                            "finished without waiting for callbacks %r" %
-                            self.pending_callbacks)
                     future_set_result_unless_cancelled(self.result_future,
                                                        _value_from_stopiteration(e))
                     self.result_future = None