1
0
mirror of https://github.com/gryf/ferrit.git synced 2026-02-17 23:55:44 +01:00

Fix: use actual fifo queue instead of the normal file

This commit is contained in:
2019-10-27 17:55:08 +01:00
parent da24f505bb
commit 9317dc9ef3

View File

@@ -23,6 +23,7 @@ HOST_KEY = paramiko.RSAKey(filename=os.path.join(FILE_DIR,
password='jenkins') password='jenkins')
fd, FIFO = tempfile.mkstemp(suffix='.fifo', prefix='ferrit.') fd, FIFO = tempfile.mkstemp(suffix='.fifo', prefix='ferrit.')
os.close(fd) os.close(fd)
os.unlink(FIFO)
GERRIT_CMD_PROJECTS = """All-Projects GERRIT_CMD_PROJECTS = """All-Projects
All-Users All-Users
@@ -186,6 +187,7 @@ class SSHHandler(socketserver.StreamRequestHandler):
def main(): def main():
try: try:
os.mkfifo(FIFO)
sys.stdout.write('Opening named FIFO queue: %s\n' % FIFO) sys.stdout.write('Opening named FIFO queue: %s\n' % FIFO)
sshserver = socketserver.ThreadingTCPServer(('127.0.0.1', PORT), sshserver = socketserver.ThreadingTCPServer(('127.0.0.1', PORT),
SSHHandler) SSHHandler)