Mercurial > projects > dreactor

comparison test/chatserver.d @ 9:5412a1ff2e49

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
adding chat client and more updates
author rick@minifunk
date Sat, 12 Jul 2008 10:42:41 -0400
parents 2c6ab06a8829
children e75a2e506b1d
comparison
equal deleted inserted replaced
8:60cf25102fb2 9:5412a1ff2e49
1 module chatserver; 1 module chatserver;
2 2
3 import tango.net.Socket; 3 import tango.net.Socket;
4 import tango.core.Thread; 4 import tango.core.Thread;
5 import tango.io.Stdout; 5 import tango.io.Stdout;
6 import tango.util.log.Log;
6 import dreactor.core.Vat; 7 import dreactor.core.Vat;
7 import dreactor.core.Dispatcher; 8 import dreactor.core.Dispatcher;
8 9
9 import dreactor.protocol.RawTcp; 10 import dreactor.protocol.RawTcp;
10 import dreactor.transport.AsyncSocketConduit; 11 import dreactor.transport.AsyncSocketConduit;
11 12
12 13 int count;
13 int main() 14 int main()
14 { 15 {
15 Vat l_vat = new Vat(); 16 Vat l_vat = new Vat();
17 Logger log = Log.lookup("dreactor.chatserver");
18 Log.root.level(log.Level.Info, true);
16 RawTCPListener listener = new RawTCPListener(l_vat, new IPv4Address(5555)); 19 RawTCPListener listener = new RawTCPListener(l_vat, new IPv4Address(5555));
17 listener.setDataHandler( (char[] inbuf, Dispatcher d) { 20 listener.setDataHandler( (char[] inbuf, Dispatcher d) {
18 21
19 listener.broadcast(inbuf, [d]); 22 listener.broadcast(inbuf, [d]);
20 23
21 }); 24 });
22 l_vat.run(); 25 l_vat.run();
23 26