summaryrefslogtreecommitdiff
path: root/tupkg
diff options
context:
space:
mode:
authorjchu <jchu>2004-09-02 07:05:51 +0000
committerjchu <jchu>2004-09-02 07:05:51 +0000
commit5d09c247da3307a37ce4f05bcce50254f020cda8 (patch)
tree3bc2db049f3deea485f54db7ea55a026ddce9bdb /tupkg
parentd80c932d6eb8e5ce33afb5ee6c9d4b70bb179596 (diff)
the daemon now starts, polls for connections, and opens them
Diffstat (limited to 'tupkg')
-rwxr-xr-xtupkg/server/tupkgs87
1 files changed, 82 insertions, 5 deletions
diff --git a/tupkg/server/tupkgs b/tupkg/server/tupkgs
index 2c410a5..b4a3e86 100755
--- a/tupkg/server/tupkgs
+++ b/tupkg/server/tupkgs
@@ -11,12 +11,89 @@
#
# Python Indentation:
# -------------------
-# Use tabs not spaces. If you use vim, the following comment will
-# configure it to use tabs.
-# vim: ts=2 sw=2 noet ft=python
-#
+# For a vim: line to be effective, it must be at the end of the
+# file. See the end of the file for more information.
+
+import sys
+import socket
+import threading
+import select
+
+class ClientSocket(threading.Thread):
+ def __init__(self, socket, **other):
+ threading.Thread.__init__(self, *other)
+ self.socket = socket
+
+ def close(self):
+ pass
+
+ def run(self):
+ while len(self.socket.recv(1)) != 0:
+ pass
+
+class ServerSocket(threading.Thread):
+ def __init__(self, port=1034, maxqueue=5, **other):
+ threading.Thread.__init__(self, *other)
+ self.running = 1
+ self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ self.socket.bind((socket.gethostname(), port))
+ self.socket.listen(maxqueue)
+ self.clients = []
+
+ def _clean(self, client):
+ if not client.isAlive():
+ return 0
+ return 1
+
+ def close(self):
+ self.socket.close()
+
+ def run(self):
+ while self.running:
+ sread, swrite, serror = select.select([self.socket],[self.socket],[self.socket],5)
+ if sread:
+ (clientsocket, address) = self.socket.accept()
+ ct = ClientSocket(clientsocket)
+ ct.start()
+ self.clients.append(ct)
+
+ print len(self.clients)
+ self.clients = filter(self._clean, self.clients)
+ print len(self.clients)
+ self.socket.close()
+ [x.close() for x in self.clients]
+ [x.join() for x in self.clients]
+def main(argv=None):
+ if argv is None:
+ argv = sys.argv
+ running = 1
-# TODO write the code
+ servsock = ServerSocket()
+ servsock.start()
+
+ try:
+ while running:
+ # Maybe do stuff here?
+ pass
+ except KeyboardInterrupt:
+ running = 0
+
+ print "Just cleaning up stuff"
+
+ servsock.running = 0
+
+ servsock.join()
+
+ return 0
+
+if __name__ == "__main__":
+ sys.exit(main())
+
+# Python Indentation:
+# -------------------
+# Use tabs not spaces. If you use vim, the following comment will
+# configure it to use tabs.
#
+# vim:noet:ts=2 sw=2 ft=python