Changeset 3670

Timestamp:

06/23/08 03:25:02 (3 months ago)

Author:

kris

Message:

added a convenient DataOutputPool?

Files:

• trunk/tango/net/SocketPool.d (modified) (6 diffs)

trunk/tango/net/SocketPool.d

@@ -20 +20 @@
-private import  tango.net.SocketConduit,
-                tango.net.InternetAddress;
+
+private import  tango.io.stream.DataStream;
-
-/*******************************************************************************
@@ -60 +62 @@
-                this.factory = factory;
-                this.address = address;
-        }
-
-        /***********************************************************************
-
-                Allocate a Connection from a list rather than creating a 
-                new one. Reap old entries as we go.
-
-        ***********************************************************************/
-
-        final synchronized Connection borrow (Time time)
-        {  
-                if (freelist)
-                    do {
-                       auto c = freelist;
-
-                       freelist = c.next;
-                       if (freelist && (time - c.time > timeout))
-                           c.close;
-                       else
-                          return c;
-                       } while (true);
-
-                return new Connection (this);
-        }
-
@@ -140 +119 @@
-                for (int attempts=3; attempts--;)
-                     try {
-
+
+
-
-                         // load the reply. Don't retry on
@@ -177 +157 @@
-        }
-
+        /***********************************************************************
+
+                Allocate a Connection from a list rather than creating a 
+                new one. Reap old entries as we go.
+
+        ***********************************************************************/
+
+        private final synchronized Connection borrow (Time time)
+        {  
+                if (freelist)
+                    do {
+                       auto c = freelist;
+
+                       freelist = c.next;
+                       if (freelist && (time - c.time > timeout))
+                           c.close;
+                       else
+                          return c;
+                       } while (true);
+
+                return new Connection (this);
+        }
+
-
-        /***********************************************************************
@@ -185 +188 @@
-        ***********************************************************************/
-
-
+private 
-        {
-                Connection      next;   
@@ -266 +269 @@
-                                     }
-                }
+        }
+}
+
+
+/*******************************************************************************
+        
+        A pool of connected DataOuptut instances, each of which are thread-
+        safe (each connection has its own private output buffer).
+        
+        Note that the connections will timeout after a period of inactivity, 
+        and will subsequently cause a connected host to drop the supporting
+        session.
+
+        The connections are expected to be reasonably long-lived on the 
+        hosting server, since we try to reuse existing sockets
+
+*******************************************************************************/
+
+class DataOutputPool : SocketPool!(DataOutput)
+{ 
+        private bool flip;
+        private int  bufferSize;
+
+        /***********************************************************************
+
+                Create a connection-pool for the specified address
+
+        ***********************************************************************/
+
+        this (InternetAddress addr, int bufferSize=8192, bool flip=false, bool nagle=true)
+        {
+                this.flip = flip;
+                this.bufferSize = bufferSize;
+                super (addr, &factory, nagle);
+        }
+
+        /***********************************************************************
+
+                Wrap the socket with a DataOutput instance
+
+        ***********************************************************************/
+
+        private DataOutput factory (IConduit c)
+        {       
+                return new DataOutput (c, bufferSize, flip);
-        }
-}