Kaydet (Commit) 69598527 authored tarafından Xavier de Gaye's avatar Xavier de Gaye

Issue #28683: Merge 3.6.

...@@ -96,6 +96,7 @@ __all__ = [ ...@@ -96,6 +96,7 @@ __all__ = [
"setswitchinterval", "android_not_root", "setswitchinterval", "android_not_root",
# network # network
"HOST", "IPV6_ENABLED", "find_unused_port", "bind_port", "open_urlresource", "HOST", "IPV6_ENABLED", "find_unused_port", "bind_port", "open_urlresource",
"bind_unix_socket",
# processes # processes
'temp_umask', "reap_children", 'temp_umask', "reap_children",
# logging # logging
...@@ -708,6 +709,15 @@ def bind_port(sock, host=HOST): ...@@ -708,6 +709,15 @@ def bind_port(sock, host=HOST):
port = sock.getsockname()[1] port = sock.getsockname()[1]
return port return port
def bind_unix_socket(sock, addr):
"""Bind a unix socket, raising SkipTest if PermissionError is raised."""
assert sock.family == socket.AF_UNIX
try:
sock.bind(addr)
except PermissionError:
sock.close()
raise unittest.SkipTest('cannot bind AF_UNIX sockets')
def _is_ipv6_enabled(): def _is_ipv6_enabled():
"""Check whether IPv6 is enabled on this host.""" """Check whether IPv6 is enabled on this host."""
if socket.has_ipv6: if socket.has_ipv6:
......
...@@ -95,7 +95,9 @@ def bind_af_aware(sock, addr): ...@@ -95,7 +95,9 @@ def bind_af_aware(sock, addr):
if HAS_UNIX_SOCKETS and sock.family == socket.AF_UNIX: if HAS_UNIX_SOCKETS and sock.family == socket.AF_UNIX:
# Make sure the path doesn't exist. # Make sure the path doesn't exist.
support.unlink(addr) support.unlink(addr)
sock.bind(addr) support.bind_unix_socket(sock, addr)
else:
sock.bind(addr)
class HelperFunctionTests(unittest.TestCase): class HelperFunctionTests(unittest.TestCase):
......
...@@ -1888,7 +1888,8 @@ class _BasePathTest(object): ...@@ -1888,7 +1888,8 @@ class _BasePathTest(object):
try: try:
sock.bind(str(P)) sock.bind(str(P))
except OSError as e: except OSError as e:
if "AF_UNIX path too long" in str(e): if (isinstance(e, PermissionError) or
"AF_UNIX path too long" in str(e)):
self.skipTest("cannot bind Unix socket: " + str(e)) self.skipTest("cannot bind Unix socket: " + str(e))
self.assertTrue(P.is_socket()) self.assertTrue(P.is_socket())
self.assertFalse(P.is_fifo()) self.assertFalse(P.is_fifo())
......
...@@ -278,8 +278,14 @@ class ThreadableTest: ...@@ -278,8 +278,14 @@ class ThreadableTest:
def clientRun(self, test_func): def clientRun(self, test_func):
self.server_ready.wait() self.server_ready.wait()
self.clientSetUp() try:
self.client_ready.set() self.clientSetUp()
except BaseException as e:
self.queue.put(e)
self.clientTearDown()
return
finally:
self.client_ready.set()
if self.server_crashed: if self.server_crashed:
self.clientTearDown() self.clientTearDown()
return return
...@@ -520,8 +526,11 @@ class ConnectedStreamTestMixin(SocketListeningTestMixin, ...@@ -520,8 +526,11 @@ class ConnectedStreamTestMixin(SocketListeningTestMixin,
self.serv_conn = self.cli self.serv_conn = self.cli
def clientTearDown(self): def clientTearDown(self):
self.serv_conn.close() try:
self.serv_conn = None self.serv_conn.close()
self.serv_conn = None
except AttributeError:
pass
super().clientTearDown() super().clientTearDown()
...@@ -540,7 +549,7 @@ class UnixSocketTestBase(SocketTestBase): ...@@ -540,7 +549,7 @@ class UnixSocketTestBase(SocketTestBase):
def bindSock(self, sock): def bindSock(self, sock):
path = tempfile.mktemp(dir=self.dir_path) path = tempfile.mktemp(dir=self.dir_path)
sock.bind(path) support.bind_unix_socket(sock, path)
self.addCleanup(support.unlink, path) self.addCleanup(support.unlink, path)
class UnixStreamBase(UnixSocketTestBase): class UnixStreamBase(UnixSocketTestBase):
...@@ -4649,7 +4658,7 @@ class TestUnixDomain(unittest.TestCase): ...@@ -4649,7 +4658,7 @@ class TestUnixDomain(unittest.TestCase):
def bind(self, sock, path): def bind(self, sock, path):
# Bind the socket # Bind the socket
try: try:
sock.bind(path) support.bind_unix_socket(sock, path)
except OSError as e: except OSError as e:
if str(e) == "AF_UNIX path too long": if str(e) == "AF_UNIX path too long":
self.skipTest( self.skipTest(
......
...@@ -598,6 +598,9 @@ Tools/Demos ...@@ -598,6 +598,9 @@ Tools/Demos
Tests Tests
----- -----
- Issue #28683: Fix the tests that bind() a unix socket and raise
PermissionError on Android for a non-root user.
- Issue #26936: Fix the test_socket failures on Android - getservbyname(), - Issue #26936: Fix the test_socket failures on Android - getservbyname(),
getservbyport() and getaddrinfo() are broken on some Android API levels. getservbyport() and getaddrinfo() are broken on some Android API levels.
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment