--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tango/tango/net/cluster/tina/util/ServerThread.d	Fri Jan 11 17:57:40 2008 +0100
@@ -0,0 +1,84 @@
+/*******************************************************************************
+
+        copyright:      Copyright (c) 2004 Kris Bell. All rights reserved
+
+        license:        BSD style: $(LICENSE)
+
+        version:        Initial release: April 2004
+
+        author:         Kris
+
+*******************************************************************************/
+
+module tango.net.cluster.tina.util.ServerThread;
+
+private import  tango.core.Thread,
+                tango.core.Runtime,
+                tango.core.Exception;
+
+private import  tango.net.ServerSocket;
+
+private import  tango.net.cluster.tina.util.AbstractServer;
+
+/******************************************************************************
+
+        Subclasses Thread to provide the basic server-thread loop. This
+        functionality could also be implemented as a delegate, however,
+        we also wish to subclass in order to add thread-local data (see
+        HttpThread).
+
+******************************************************************************/
+
+class ServerThread
+{
+        private AbstractServer  server;
+        private ServerSocket    socket;
+
+        /**********************************************************************
+
+                Construct a ServerThread for the given Server, upon the
+                specified socket
+
+        **********************************************************************/
+
+        this (AbstractServer server, ServerSocket socket)
+        {
+                this.server = server;
+                this.socket = socket;
+                (new Thread (&run)).start;
+        }
+
+        /**********************************************************************
+
+                Execute this thread until the Server says to halt. Each
+                thread waits in the socket.accept() state, waiting for
+                a connection request to arrive. Upon selection, a thread
+                dispatches the request via the request service-handler
+                and, upon completion, enters the socket.accept() state
+                once more.
+
+        **********************************************************************/
+
+        private void run ()
+        {
+                while (Runtime.isHalting is false)
+                       try {
+                           // wait for a socket connection
+                           auto sc = socket.accept;
+
+                           // did we get a valid response?
+                           if (sc)
+                               // yep - process this request
+                               server.service (sc);
+                           else
+                              // server may be halting ...
+                              if (socket.isAlive)
+                                  server.getLogger.error ("Socket.accept failed");
+
+                           } catch (IOException x)
+                                    server.getLogger.error ("IOException: "~x.toString);
+
+                             catch (Object x)
+                                    server.getLogger.fatal ("Exception: "~x.toString);
+        }
+}