diff --git a/src/xpra/server/proxy_server.py b/src/xpra/server/proxy_server.py index f8c75a4adb..2eaa4967aa 100644 --- a/src/xpra/server/proxy_server.py +++ b/src/xpra/server/proxy_server.py @@ -34,6 +34,8 @@ #use processes: from multiprocessing import Process #@Reimport +MAX_CONCURRENT_CONNECTIONS = 200 + class ProxyServer(ServerCore): """ @@ -46,6 +48,7 @@ class ProxyServer(ServerCore): def __init__(self): log("ProxyServer.__init__()") ServerCore.__init__(self) + self._max_connections = MAX_CONCURRENT_CONNECTIONS self.main_loop = None self.processes = [] self.idle_add = gobject.idle_add diff --git a/src/xpra/server/server_core.py b/src/xpra/server/server_core.py index 6705468581..d67b6d0c8b 100644 --- a/src/xpra/server/server_core.py +++ b/src/xpra/server/server_core.py @@ -95,6 +95,7 @@ def __init__(self): self._aliases = {} self._reverse_aliases = {} self.socket_types = {} + self._max_connections = MAX_CONCURRENT_CONNECTIONS self.session_name = "Xpra" @@ -263,7 +264,7 @@ def add_listen_socket(self, socktype, socket): def _new_connection(self, listener, *args): socktype = self.socket_types.get(listener, "") sock, address = listener.accept() - if len(self._potential_protocols)>=MAX_CONCURRENT_CONNECTIONS: + if len(self._potential_protocols)>=self._max_connections: log.error("too many connections (%s), ignoring new one", len(self._potential_protocols)) sock.close() return True