Mercurial > projects > ldc

diff tango/tango/net/cluster/NetworkTask.d @ 132:1700239cab2e trunk

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[svn r136] MAJOR UNSTABLE UPDATE!!! Initial commit after moving to Tango instead of Phobos. Lots of bugfixes... This build is not suitable for most things.
author lindquist
date Fri, 11 Jan 2008 17:57:40 +0100
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tango/tango/net/cluster/NetworkTask.d	Fri Jan 11 17:57:40 2008 +0100
@@ -0,0 +1,49 @@
+/*******************************************************************************
+
+        copyright:      Copyright (c) 2004 Kris Bell. All rights reserved
+
+        license:        BSD style: $(LICENSE)
+        
+        version:        July 2004: Initial release      
+        
+        author:         Kris
+
+*******************************************************************************/
+
+module tango.net.cluster.NetworkTask;
+
+private import  tango.net.cluster.NetworkClient;
+              
+/*******************************************************************************
+
+*******************************************************************************/
+
+class NetworkTask : NetworkClient
+{
+        /***********************************************************************
+
+                Construct a NetworkTask gateway on the provided QOS cluster
+                for the specified channel. Each subsequent task operation
+                will take place over the given channel.
+
+        ***********************************************************************/
+        
+        this (ICluster cluster, char[] channel)
+        {
+                super (cluster, channel);
+        }
+
+        /***********************************************************************
+        
+                Add an ITask entry to the corresponding queue. This
+                will throw a ClusterFullException if there is no space
+                left in the clustered queue.
+
+        ***********************************************************************/
+        
+        void execute (IMessage task)
+        {
+                channel.execute (task);
+        }
+}
+