Mercurial > projects > ldc

comparison tango/tango/net/cluster/tina/util/AbstractServer.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: Initial release: April 2004
8
9 author: Kris
10
11 *******************************************************************************/
12
13 module tango.net.cluster.tina.util.AbstractServer;
14
15 private import tango.net.Socket;
16
17 protected import tango.util.log.Log;
18
19 protected import tango.net.ServerSocket,
20 tango.net.SocketConduit;
21
22 protected import tango.io.model.IConduit;
23
24 protected import tango.text.convert.Sprint;
25
26 protected import tango.net.cluster.tina.util.model.IServer;
27
28 /******************************************************************************
29
30 Exposes the foundation of a multi-threaded Socket server. This is
31 subclassed by mango.net.http.server.HttpServer, which itself would
32 likely be subclassed by a SecureHttpServer.
33
34 ******************************************************************************/
35
36 class AbstractServer : IServer
37 {
38 private InternetAddress bind;
39 private ServerSocket server;
40 private Logger logger;
41 private Sprint!(char) sprint;
42 private uint threads;
43 private uint backlog;
44
45 /**********************************************************************
46
47 Setup this server with the requisite attributes. The number
48 of threads specified dictate exactly that. You might have
49 anything between 1 thread and several hundred, dependent
50 upon the underlying O/S and hardware.
51
52 Parameter 'backlog' specifies the max number of"simultaneous"
53 connection requests to be handled by an underlying socket
54 implementation.
55
56 **********************************************************************/
57
58 this (InternetAddress bind, int threads, int backlog, Logger logger)
59 in {
60 assert (bind);
61 assert (logger);
62 assert (backlog >= 0);
63 assert (threads > 0 && threads < 256);
64 }
65 body
66 {
67 this.bind = bind;
68 this.logger = logger;
69 this.threads = threads;
70 this.backlog = backlog;
71 this.sprint = new Sprint!(char);
72 }
73
74 /**********************************************************************
75
76 Concrete server must expose a name
77
78 **********************************************************************/
79
80 protected abstract char[] toString();
81
82 /**********************************************************************
83
84 Concrete server must expose a ServerSocket factory
85
86 **********************************************************************/
87
88 protected abstract ServerSocket createSocket (InternetAddress bind, int backlog, bool reuse=false);
89
90 /**********************************************************************
91
92 Concrete server must expose a thread factory
93
94 **********************************************************************/
95
96 protected abstract void createThread (ServerSocket socket);
97
98 /**********************************************************************
99
100 Concrete server must expose a service handler
101
102 **********************************************************************/
103
104 abstract void service (IConduit conduit);
105
106 /**********************************************************************
107
108 Provide support for figuring out the remote address
109
110 **********************************************************************/
111
112 IPv4Address remoteAddress (IConduit conduit)
113 {
114 auto tmp = cast(SocketConduit) conduit;
115 if (tmp)
116 return cast(IPv4Address) tmp.socket.remoteAddress;
117 return null;
118 }
119
120 /**********************************************************************
121
122 Provide support for figuring out the remote address
123
124 **********************************************************************/
125
126 IPv4Address localAddress ()
127 {
128 return cast(IPv4Address) server.socket.localAddress;
129 }
130
131 /**********************************************************************
132
133 Provide support for figuring out the remote address
134
135 **********************************************************************/
136
137 char[] getRemoteAddress (IConduit conduit)
138 {
139 auto addr = remoteAddress (conduit);
140
141 if (addr)
142 return addr.toAddrString;
143 return "127.0.0.1";
144 }
145
146 /**********************************************************************
147
148 Provide support for figuring out the remote host. Not
149 currently implemented.
150
151 **********************************************************************/
152
153 char[] getRemoteHost (IConduit conduit)
154 {
155 return null;
156 }
157
158 /**********************************************************************
159
160 Return the local port we're attached to
161
162 **********************************************************************/
163
164 int getPort ()
165 {
166 return localAddress.port;
167 }
168
169 /**********************************************************************
170
171 Return the local address we're attached to
172
173 **********************************************************************/
174
175 char[] getHost ()
176 {
177 return localAddress.toAddrString;
178 }
179
180 /**********************************************************************
181
182 Return the logger associated with this server
183
184 **********************************************************************/
185
186 Logger getLogger ()
187 {
188 return logger;
189 }
190
191 /**********************************************************************
192
193 Start this server
194
195 **********************************************************************/
196
197 void start (bool reuse = false)
198 {
199 // have the subclass create a ServerSocket for us
200 server = createSocket (bind, backlog, reuse);
201
202 // instantiate and start all threads
203 for (auto i=threads; i-- > 0;)
204 createThread (server);
205
206 // indicate what's going on
207 logger.info (sprint ("Server {} started on {} with {} accept threads and {} backlogs",
208 this, localAddress, threads, backlog));
209 }
210 }