ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-01-20 03:36:25 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Also CLOEXEC the descriptor

Browse Source 
This avoids leaking it into any child processes that the tests might launch.
This commit is contained in:
Jean-Paul Calderone 2018-05-23 10:56:26 -04:00
parent be6e458770
commit 8a5e2edb91
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/allmydata/test/test_introducer.py
View File

@ -319,17 +319,21 @@ def foolscapEndpointForPortNumber(portnum):
from twisted.internet import reactor from twisted.internet import reactor
from twisted.internet.interfaces import IReactorSocket from twisted.internet.interfaces import IReactorSocket
if IReactorSocket.providedBy(reactor): if IReactorSocket.providedBy(reactor):
import fcntl
from socket import socket, AF_INET from socket import socket, AF_INET
from twisted.internet.endpoints import AdoptedStreamServerEndpoint from twisted.internet.endpoints import AdoptedStreamServerEndpoint
s = socket() s = socket()
try: try:
s.setblocking(False)
s.bind(('', 0)) s.bind(('', 0))
portnum = s.getsockname()[1] portnum = s.getsockname()[1]
s.listen(3) s.listen(1)
fd = os.dup(s.fileno())
flags = fcntl.fcntl(fd, fcntl.F_GETFD)
flags = flags | os.O_NONBLOCK | fcntl.FD_CLOEXEC
fcntl.fcntl(fd, fcntl.F_SETFD, flags)
return ( return (
portnum, portnum,
AdoptedStreamServerEndpoint(reactor, os.dup(s.fileno()), AF_INET), AdoptedStreamServerEndpoint(reactor, fd, AF_INET),
) )
finally: finally:
s.close() s.close()