Mercurial > projects > ldc

comparison tango/tango/net/cluster/tina/TaskThread.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
comparison
equal deleted inserted replaced
131:5825d48b27d1 132:1700239cab2e
1 /*******************************************************************************
2
3 copyright: Copyright (c) 2004 Kris Bell. All rights reserved
4
5 license: BSD style: $(LICENSE)
6
7 version: July 2004: Initial release
8
9 author: Kris
10
11 *******************************************************************************/
12
13 module tango.net.cluster.tina.TaskThread;
14
15 private import tango.core.Exception;
16
17 private import tango.net.cluster.NetworkRegistry;
18
19 private import tango.net.cluster.tina.ClusterThread;
20
21 /******************************************************************************
22
23 Thread for handling remote-call requests.
24
25 ******************************************************************************/
26
27 class TaskThread : ClusterThread
28 {
29 private NetworkRegistry registry;
30
31 /**********************************************************************
32
33 Note that the conduit stays open until the client kills it
34
35 **********************************************************************/
36
37 this (AbstractServer server, IConduit conduit, Cluster cluster)
38 {
39 super (server, conduit, cluster);
40
41 // clone the registry so that we have our own set of
42 // message templates to act as hosts. This eliminates
43 // allocating hosts on the fly
44 registry = NetworkRegistry.shared.dup;
45 }
46
47 /**********************************************************************
48
49 process client requests
50
51 **********************************************************************/
52
53 void dispatch ()
54 {
55 ProtocolWriter.Command cmd;
56 char[] channel;
57 char[] element;
58
59 // wait for request to arrive
60 if (reader.getHeader (cmd, channel, element))
61 {
62 // convert to a task. Note that we use a private set of
63 // msg templates, so we don't collide with other threads
64 auto task = reader.thaw (registry);
65
66 if (task is null)
67 throw new IllegalArgumentException ("Remote-call instance is not executable");
68
69 switch (cmd)
70 {
71 case ProtocolWriter.Command.Call:
72 logger.trace (sprint ("{} executing remote call '{}'", client, task.toString));
73 task.execute;
74
75 writer.put (ProtocolWriter.Command.OK, channel, element, task);
76 break;
77
78 default:
79 throw new IllegalArgumentException ("invalid command");
80 }
81 }
82 }
83 }
84