LibertaCasa/syncplay
9
0
Fork 0
Code Issues Pull Requests 1 Projects Releases Wiki Activity

flake8ted

Browse Source 
Signed-off-by: Pratyush Desai <pratyush.desai@liberta.casa>
This commit is contained in:
Pratyush Desai 2023-07-22 02:25:25 +05:30
parent 19bcae4b1a
commit 8a3800549c
Signed by: pratyush
GPG Key ID: DBA5BB7505946FAD
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
syncplay-proxy/syncplay-proxy
View File

@ -14,6 +14,7 @@ import sys
listen_port = int(sys.argv[1])
forward_port = int(sys.argv[2])
class SyncplayRequestHandler(socketserver.BaseRequestHandler):
def handle(self):
print('Handling connection from:', self.client_address)
@ -22,7 +23,7 @@ class SyncplayRequestHandler(socketserver.BaseRequestHandler):
print('Bad connection header from:', self.client_address)
try:
self.request.close()
except:
except Exception as e:
pass
return
print('Opening forwarding connection on behalf of:', self.client_address)
@ -45,18 +46,21 @@ class SyncplayRequestHandler(socketserver.BaseRequestHandler):
print('Proxying stopped for:', self.client_address)
try:
forwarded_conn.close()
except:
except Exception as e:
pass
try:
self.request.close()
except:
except Exception as e:
pass
class SyncplayServer(socketserver.ThreadingTCPServer):
address_family = socket.AF_INET6
def server_bind(self):
self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
socketserver.ThreadingTCPServer.server_bind(self)
with SyncplayServer(('', listen_port), SyncplayRequestHandler) as server:
server.serve_forever()