mirror of
https://github.com/vim/vim.git
synced 2025-10-03 05:14:07 -04:00
patch 8.2.4690: channel tests fail on MS-Windows
Problem: Channel tests fail on MS-Windows. Solution: Check if the AF_UNIX attribute exists. (closes #10083)
This commit is contained in:
@@ -19,12 +19,7 @@ except ImportError:
|
|||||||
# Python 2
|
# Python 2
|
||||||
import SocketServer as socketserver
|
import SocketServer as socketserver
|
||||||
|
|
||||||
class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler):
|
class TestingRequestHandler(socketserver.BaseRequestHandler):
|
||||||
|
|
||||||
def setup(self):
|
|
||||||
if self.server.address_family != socket.AF_UNIX:
|
|
||||||
self.request.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
|
|
||||||
|
|
||||||
def handle(self):
|
def handle(self):
|
||||||
print("=== socket opened ===")
|
print("=== socket opened ===")
|
||||||
while True:
|
while True:
|
||||||
@@ -240,6 +235,10 @@ class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler):
|
|||||||
elif decoded[0] < 0:
|
elif decoded[0] < 0:
|
||||||
last_eval = decoded
|
last_eval = decoded
|
||||||
|
|
||||||
|
class ThreadedTCPRequestHandler(TestingRequestHandler):
|
||||||
|
def setup(self):
|
||||||
|
self.request.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
|
||||||
|
|
||||||
class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
|
class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
@@ -6,7 +6,7 @@
|
|||||||
# This requires Python 2.6 or later.
|
# This requires Python 2.6 or later.
|
||||||
|
|
||||||
from __future__ import print_function
|
from __future__ import print_function
|
||||||
from test_channel import ThreadedTCPServer, ThreadedTCPRequestHandler, \
|
from test_channel import ThreadedTCPServer, TestingRequestHandler, \
|
||||||
writePortInFile
|
writePortInFile
|
||||||
import socket
|
import socket
|
||||||
import threading
|
import threading
|
||||||
@@ -18,11 +18,17 @@ except NameError:
|
|||||||
# Python 2
|
# Python 2
|
||||||
FileNotFoundError = (IOError, OSError)
|
FileNotFoundError = (IOError, OSError)
|
||||||
|
|
||||||
|
if not hasattr(socket, "AF_UNIX"):
|
||||||
|
raise NotImplementedError("Unix sockets are not supported on this platform")
|
||||||
|
|
||||||
class ThreadedUnixServer(ThreadedTCPServer):
|
class ThreadedUnixServer(ThreadedTCPServer):
|
||||||
address_family = socket.AF_UNIX
|
address_family = socket.AF_UNIX
|
||||||
|
|
||||||
|
class ThreadedUnixRequestHandler(TestingRequestHandler):
|
||||||
|
pass
|
||||||
|
|
||||||
def main(path):
|
def main(path):
|
||||||
server = ThreadedUnixServer(path, ThreadedTCPRequestHandler)
|
server = ThreadedUnixServer(path, ThreadedUnixRequestHandler)
|
||||||
|
|
||||||
# Start a thread with the server. That thread will then start a new thread
|
# Start a thread with the server. That thread will then start a new thread
|
||||||
# for each connection.
|
# for each connection.
|
||||||
|
@@ -750,6 +750,8 @@ static char *(features[]) =
|
|||||||
|
|
||||||
static int included_patches[] =
|
static int included_patches[] =
|
||||||
{ /* Add new patch number below this line */
|
{ /* Add new patch number below this line */
|
||||||
|
/**/
|
||||||
|
4690,
|
||||||
/**/
|
/**/
|
||||||
4689,
|
4689,
|
||||||
/**/
|
/**/
|
||||||
|
Reference in New Issue
Block a user