catch requests from invalid thread

Author: bfredl

neovim/api/nvim.py

@@ -1,6 +1,7 @@
 """Main Nvim interface."""
 import os
 import sys
+import threading
 from functools import partial
 from traceback import format_stack
 
@@ -165,6 +166,15 @@ def request(self, name, *args, **kwargs):
         present and True, a asynchronous notification is sent instead. This
         will never block, and the return value or error is ignored.
         """
+        if (self._session._loop_thread is not None and
+                threading.current_thread() != self._session._loop_thread):
+
+            msg = ("request from non-main thread:\n{}\n"
+                   .format('\n'.join(format_stack(None, 5)[:-1])))
+
+            self.async_call(self._err_cb, msg)
+            raise NvimError("request from non-main thread")
+
         decode = kwargs.pop('decode', self._decode)
         args = walk(self._to_nvim, args)
         res = self._session.request(name, *args, **kwargs)
@@ -382,6 +392,10 @@ def out_write(self, msg, **kwargs):
 
     def err_write(self, msg, **kwargs):
         """Print `msg` as an error message."""
+        if (self._session._loop_thread is not None and 
+                threading.current_thread() != self._session._loop_thread):
+            self.async_call(self.err_write, msg, **kwargs)
+            return
         return self.request('nvim_err_write', msg, **kwargs)
 
     def quit(self, quit_command='qa!'):

neovim/msgpack_rpc/session.py

@@ -1,5 +1,6 @@
 """Synchronous msgpack-rpc session layer."""
 import logging
+import threading
 from collections import deque
 from traceback import format_exc
 
@@ -29,6 +30,7 @@ def __init__(self, async_session):
         self._is_running = False
         self._setup_exception = None
         self.loop = async_session.loop
+        self._loop_thread = None
 
     def threadsafe_call(self, fn, *args, **kwargs):
         """Wrapper around `AsyncSession.threadsafe_call`."""
@@ -110,6 +112,7 @@ def run(self, request_cb, notification_cb, setup_cb=None):
         self._notification_cb = notification_cb
         self._is_running = True
         self._setup_exception = None
+        self._loop_thread = threading.current_thread()
 
         def on_setup():
             try:
@@ -135,6 +138,7 @@ def on_setup():
         self._is_running = False
         self._request_cb = None
         self._notification_cb = None
+        self._loop_thread = None
 
         if self._setup_exception:
             raise self._setup_exception