summary refs log tree commit diff
path: root/synapse/util
diff options
context:
space:
mode:
authorreivilibre <38398653+reivilibre@users.noreply.github.com>2021-08-16 18:11:48 +0100
committerGitHub <noreply@github.com>2021-08-16 18:11:48 +0100
commit19e51b14d23f756883688fd8238da61c6ff29cc3 (patch)
tree2eae0757631271a415460dba5f3aa3994dd81abe /synapse/util
parentUpdate CONTRIBUTING.md to fix index links and SyTest instructions (#10599) (diff)
downloadsynapse-19e51b14d23f756883688fd8238da61c6ff29cc3.tar.xz
Manhole: wrap coroutines in `defer.ensureDeferred` automatically (#10602)
Diffstat (limited to 'synapse/util')
-rw-r--r--synapse/util/manhole.py14
1 files changed, 14 insertions, 0 deletions
diff --git a/synapse/util/manhole.py b/synapse/util/manhole.py
index da24ba0470..522daa323d 100644
--- a/synapse/util/manhole.py
+++ b/synapse/util/manhole.py
@@ -12,6 +12,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+import inspect
 import sys
 import traceback
 
@@ -20,6 +21,7 @@ from twisted.conch.insults import insults
 from twisted.conch.manhole import ColoredManhole, ManholeInterpreter
 from twisted.conch.ssh.keys import Key
 from twisted.cred import checkers, portal
+from twisted.internet import defer
 
 PUBLIC_KEY = (
     "ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQDHhGATaW4KhE23+7nrH4jFx3yLq9OjaEs5"
@@ -141,3 +143,15 @@ class SynapseManholeInterpreter(ManholeInterpreter):
             self.write("".join(lines))
         finally:
             last_tb = ei = None
+
+    def displayhook(self, obj):
+        """
+        We override the displayhook so that we automatically convert coroutines
+        into Deferreds. (Our superclass' displayhook will take care of the rest,
+        by displaying the Deferred if it's ready, or registering a callback
+        if it's not).
+        """
+        if inspect.iscoroutine(obj):
+            super().displayhook(defer.ensureDeferred(obj))
+        else:
+            super().displayhook(obj)