1010import msgpack
1111import neovim_rpc_server_api_info
1212import neovim_rpc_methods
13- import threading
14- import socket
1513import neovim_rpc_protocol
1614
1715vim_error = vim .Function ('neovim_rpc#_error' )
@@ -62,7 +60,7 @@ class VimHandler(socketserver.BaseRequestHandler):
6260def notify (cls ,cmd = None ):
6361try :
6462if cmd is None :
65- cmd = vim_py + " neovim_rpc_server.process_pending_requests()"
63+ cmd = vim_py + " neovim_rpc_server.process_pending_requests()"
6664if not VimHandler ._sock :
6765return
6866with VimHandler ._lock :
@@ -112,7 +110,8 @@ def handle(self):
112110
113111# Send a response if the sequence number is positive.
114112# Negative numbers are used for "eval" responses.
115- if len (decoded )>= 2 and decoded [0 ]>= 0 and decoded [1 ]== 'neovim_rpc_setup' :
113+ if (len (decoded )>= 2 and decoded [0 ]>= 0 and
114+ decoded [1 ]== 'neovim_rpc_setup' ):
116115
117116VimHandler ._sock = self .request
118117
@@ -135,6 +134,7 @@ def handle(self):
135134args ,
136135rspid )
137136
137+
138138class SocketToStream ():
139139
140140def __init__ (self ,sock ):
@@ -198,13 +198,13 @@ def handle(self):
198198
199199logger .info ('channel %s closed.' ,channel )
200200
201- except :
201+ except Exception :
202202logger .exception ('unpacker failed.' )
203203finally :
204204try :
205205NvimHandler .channel_sockets .pop (channel )
206206sock .close ()
207- except :
207+ except Exception :
208208pass
209209
210210@classmethod
@@ -284,11 +284,11 @@ def _setup_logging(name):
284284logging .root .addHandler (handler )
285285level = logging .INFO
286286if 'NVIM_PYTHON_LOG_LEVEL' in os .environ :
287- l = getattr (logging ,
288- os .environ ['NVIM_PYTHON_LOG_LEVEL' ].strip (),
289- level )
290- if isinstance (l ,int ):
291- level = l
287+ lv = getattr (logging ,
288+ os .environ ['NVIM_PYTHON_LOG_LEVEL' ].strip (),
289+ level )
290+ if isinstance (lv ,int ):
291+ level = lv
292292logger .setLevel (level )
293293
294294
@@ -297,7 +297,8 @@ class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
297297
298298
299299if sys .platform in ['linux' ,'darwin' ]:
300- class ThreadedUnixServer (socketserver .ThreadingMixIn ,socketserver .UnixStreamServer ):
300+ class ThreadedUnixServer (socketserver .ThreadingMixIn ,
301+ socketserver .UnixStreamServer ):
301302pass
302303has_unix = True
303304else :
@@ -327,7 +328,7 @@ def start():
327328if os .path .exists (nvim_server_addr ):
328329try :
329330os .unlink (nvim_server_addr )
330- except :
331+ except Exception :
331332pass
332333_nvim_server = ThreadedUnixServer (nvim_server_addr ,NvimHandler )
333334elif not has_unix :
@@ -408,7 +409,7 @@ def process_pending_requests():
408409except Exception as ex :
409410logger .exception ("process failed: %s" ,ex )
410411
411- except QueueEmpty as em :
412+ except QueueEmpty :
412413pass
413414except Exception as ex :
414415logger .exception ("exception during process: %s" ,ex )
@@ -429,7 +430,9 @@ def _process_request(channel, method, args):
429430else :
430431logger .error ("method %s not implemented" ,method )
431432vim_error (
432- "rpc method [%s] not implemented in pythonx/neovim_rpc_methods.py. Please send PR or contact the mantainer." % method )
433+ "rpc method [%s] not implemented in "
434+ "pythonx/neovim_rpc_methods.py. "
435+ "Please send PR or contact the mantainer." % method )
433436raise Exception ('%s not implemented' % method )
434437
435438