|
7
|
1 module chatserver;
|
|
|
2
|
|
|
3 import tango.net.Socket;
|
|
|
4 import tango.core.Thread;
|
|
|
5 import tango.io.Stdout;
|
|
9
|
6 import tango.util.log.Log;
|
|
7
|
7 import dreactor.core.Vat;
|
|
|
8 import dreactor.core.Dispatcher;
|
|
|
9
|
|
|
10 import dreactor.protocol.RawTcp;
|
|
|
11 import dreactor.transport.AsyncSocketConduit;
|
|
|
12
|
|
|
13 int main()
|
|
|
14 {
|
|
|
15 Vat l_vat = new Vat();
|
|
9
|
16 Logger log = Log.lookup("dreactor.chatserver");
|
|
|
17 Log.root.level(log.Level.Info, true);
|
|
7
|
18 RawTCPListener listener = new RawTCPListener(l_vat, new IPv4Address(5555));
|
|
10
|
19
|
|
7
|
20 listener.setDataHandler( (char[] inbuf, Dispatcher d) {
|
|
9
|
21
|
|
7
|
22 listener.broadcast(inbuf, [d]);
|
|
|
23
|
|
|
24 });
|
|
|
25 l_vat.run();
|
|
|
26
|
|
|
27 return 0;
|
|
|
28 }
|
|
|
29
|
