Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/Rpyc
diff options
context:
space:
mode:
authorroot <root@ghunt-desktop.(none)>2010-12-19 17:55:02 (GMT)
committer root <root@ghunt-desktop.(none)>2010-12-19 17:55:02 (GMT)
commit16fc1eeb4fb1673d0e12338a5d726185bd72431a (patch)
tree4f31bb9779b8583a36a17ac028fd4970624baa0f /Rpyc
parent0b27ac481cdd8695e87908baf538350b28229376 (diff)
version 7,additional help, embeds remembered across invocations
Diffstat (limited to 'Rpyc')
-rw-r--r--Rpyc/Utils/Serving.py8
1 files changed, 7 insertions, 1 deletions
diff --git a/Rpyc/Utils/Serving.py b/Rpyc/Utils/Serving.py
index b726428..35b8e22 100644
--- a/Rpyc/Utils/Serving.py
+++ b/Rpyc/Utils/Serving.py
@@ -82,12 +82,18 @@ def serve_pipes(incoming, outgoing):
# threaded utilities
#
def threaded_server(port = DEFAULT_PORT, **kw):
+ global sock
sock = create_listener_socket(port)
- while True:
+ while sock:
newsock, name = sock.accept()
t = Thread(target = serve_socket, args = (newsock,), kwargs = kw)
t.setDaemon(True)
t.start()
+
+def threaded_server_close():
+ global sock
+ sock.close()
+ sock = None
def start_threaded_server(*args, **kwargs):
"""starts the threaded_server on a separate thread. this turns the