Mercurial > hg > Database > Alice

comparison src/test/java/alice/daemon/MulticastStartCodeSegment.java @ 547:e91a574b69de dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove index
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Tue, 18 Aug 2015 16:15:17 +0900
parents 15eeb439830c
children
comparison
equal deleted inserted replaced
546:15eeb439830c 547:e91a574b69de
14 public void run() { 14 public void run() {
15 aliceDaemon.dataSegment.connectMulticast("multicast",conf.MCSTADDR, conf.localPort, conf.nis, MulticastTest.type); 15 aliceDaemon.dataSegment.connectMulticast("multicast",conf.MCSTADDR, conf.localPort, conf.nis, MulticastTest.type);
16 if (MulticastTest.type == SocketType.Both) { 16 if (MulticastTest.type == SocketType.Both) {
17 // in this case "multicast" key mean local. 17 // in this case "multicast" key mean local.
18 MulticastIncrement cs = new MulticastIncrement(); 18 MulticastIncrement cs = new MulticastIncrement();
19 cs.num.setKey("multicast","num"); 19 cs.num.setKey("multicast","num", this);
20 20
21 ods.put("multicast", "num", 0); 21 ods.put("multicast", "num", 0);
22 } else if (MulticastTest.type == SocketType.Receiver){ 22 } else if (MulticastTest.type == SocketType.Receiver){
23 aliceDaemon.dataSegment.connectMulticast("multicast1", "224.0.0.2", conf.localPort+1, conf.nis, SocketType.Sender); 23 aliceDaemon.dataSegment.connectMulticast("multicast1", "224.0.0.2", conf.localPort+1, conf.nis, SocketType.Sender);
24 ReceiveInteger cs = new ReceiveInteger(); 24 ReceiveInteger cs = new ReceiveInteger();
25 cs.num.setKey("num", arg1.index, this); 25 cs.num.setKey("num", this);
26 } else if (MulticastTest.type == SocketType.Sender){ 26 } else if (MulticastTest.type == SocketType.Sender){
27 aliceDaemon.dataSegment.connectMulticast("multicast1", "224.0.0.2", conf.localPort+1, conf.nis, SocketType.Receiver); 27 aliceDaemon.dataSegment.connectMulticast("multicast1", "224.0.0.2", conf.localPort+1, conf.nis, SocketType.Receiver);
28 ReceiveString cs = new ReceiveString(); 28 ReceiveString cs = new ReceiveString();
29 cs.str.setKey("str", arg1.index, this); 29 cs.str.setKey("str", this);
30 30
31 for (int i=0;i < 11; i++) 31 for (int i=0;i < 11; i++)
32 ods.put("multicast", "num", i); 32 ods.put("multicast", "num", i);
33 } 33 }
34 } 34 }