Mercurial > hg > RemoteEditor > REPSessionManager

comparison test/channeltest/testSeMa.java @ 154:fafbaaa0abd0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author kono
date Thu, 28 Aug 2008 15:33:02 +0900
parents
children f0d80a64aba0
comparison
equal deleted inserted replaced
153:4cfed12aa3aa 154:fafbaaa0abd0
1 package test.channeltest;
2
3 import java.io.IOException;
4 import java.util.LinkedList;
5
6 import pathfinder.mergetest.channels.*;
7
8
9 public class testSeMa extends Thread{
10
11 int IP;
12 boolean running=true;
13 NetworkSimulator<String> ns;
14 LinkedList<ChannelSimulator<String>> channels;
15
16 public testSeMa(NetworkSimulator<String> _ns, String name, int ip){
17 super(name);
18 IP = ip;
19 ns = _ns;
20 channels = new LinkedList<ChannelSimulator<String>>();
21 }
22 public void init(){
23
24 }
25
26 public void run() {
27 SelectorSimulator<String> selector = new SelectorSimulator<String>();
28 ServerChannelSimulator<String> scs = new ServerChannelSimulator<String>(ns, selector);
29 scs.bind(IP);
30 selector.register(scs, SelectionKeySimulator.OP_ACCEPT);
31 ns.writeLog("SessionManager starts mainroutin.", 1);
32
33 /* Main Loop */
34 while(running){
35
36 try { selector.select(); }
37 catch (IOException e) { e.printStackTrace();}
38
39 for(SelectionKeySimulator<String> key : selector.selectedKeys()){
40
41 if(key.isAcceptable()){
42 ns.writeLog(this, "gets acceptable channel", 1);
43 ServerChannelSimulator<String> sc = (ServerChannelSimulator<String>) key.channel();
44 ChannelSimulator<String> channel = sc.accept();
45 selector.register(channel, SelectionKeySimulator.OP_READ);
46 ns.writeLog(this, "accepts a client.", 1);
47
48 }else if(key.isReadable()){
49 ns.writeLog(this, "gets readable channel", 1);
50 //SelectableChannelSimulator<String> channel = key.channel();
51 ChannelSimulator<String> channel = (ChannelSimulator<String>) key.channel();
52 String packet = channel.read();
53 ns.writeLog(this, "receives String==> `"+packet+"\'", 1);
54 channel.write("from SeMa"+this.getName()+": world");
55 }
56 }
57 }
58
59 }
60 }