From 5d09c247da3307a37ce4f05bcce50254f020cda8 Mon Sep 17 00:00:00 2001
From: jchu <jchu>
Date: Thu, 2 Sep 2004 07:05:51 +0000
Subject: the daemon now starts, polls for connections, and opens them

---
 tupkg/server/tupkgs | 87 ++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 file changed, 82 insertions(+), 5 deletions(-)

(limited to 'tupkg/server')

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
-- 
cgit v1.2.3-54-g00ecf