Mercurial > hg > Members > kono > WifiBroadcast

comparison src/wifibroadcast/WifiBroadcastTest.java @ 18:e9d07562b6b7

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
network interface
author one
date Tue, 31 Jul 2012 16:32:03 +0900
parents b5ab7003f6d1
children bb2538b7eb8d
comparison
equal deleted inserted replaced
17:3d71ca942a48 18:e9d07562b6b7
20 int sender_count = 1; 20 int sender_count = 1;
21 WifiReceiver wbr[] = new WifiReceiver[receiver_count]; 21 WifiReceiver wbr[] = new WifiReceiver[receiver_count];
22 WifiReceiver wbs[] = new WifiReceiver[sender_count]; 22 WifiReceiver wbs[] = new WifiReceiver[sender_count];
23 private boolean bchannel; 23 private boolean bchannel;
24 private boolean tcp; 24 private boolean tcp;
25 private String nis = "en1";
25 26
26 public WifiBroadcastTest() { 27 public WifiBroadcastTest() {
27 ports.add(0,DefaultPort); 28 ports.add(0,DefaultPort);
28 addresses.add(0,MCASTADDR); 29 addresses.add(0,MCASTADDR);
29 } 30 }
38 if (multicast) { 39 if (multicast) {
39 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiMulticast(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver); 40 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiMulticast(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver);
40 Thread.sleep(timeout/4); 41 Thread.sleep(timeout/4);
41 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiMulticast(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender); 42 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiMulticast(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender);
42 } else if (mchannel) { 43 } else if (mchannel) {
43 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiMulticastChannel(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver); 44 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiMulticastChannel(i,getAddress(i),getPort(i),nis, WifiReceiver.SocketType.Receiver);
44 Thread.sleep(timeout/4); 45 Thread.sleep(timeout/4);
45 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiMulticastChannel(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender); 46 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiMulticastChannel(i,getAddress(i),getPort(i),nis, WifiReceiver.SocketType.Sender);
46 } else if (tcp) { 47 } else if (tcp) {
47 addresses.remove(); addresses.add("127.1"); 48 addresses.remove(); addresses.add("127.1");
48 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiTCP(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver); 49 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiTCP(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver);
49 Thread.sleep(timeout/4); 50 Thread.sleep(timeout/4);
50 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiTCP(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender); 51 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiTCP(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender);
84 case "-r": i++; receiver_count = getOptInt(args, receiver_count, i); wbr = new WifiReceiver[receiver_count]; break; 85 case "-r": i++; receiver_count = getOptInt(args, receiver_count, i); wbr = new WifiReceiver[receiver_count]; break;
85 case "-s": i++; sender_count = getOptInt(args, sender_count, i); wbs = new WifiReceiver[sender_count]; break; 86 case "-s": i++; sender_count = getOptInt(args, sender_count, i); wbs = new WifiReceiver[sender_count]; break;
86 case "-c": i++; count = getOptInt(args, count, i); break; 87 case "-c": i++; count = getOptInt(args, count, i); break;
87 case "-t": i++; timeout = getOptInt(args, (int) timeout, i); break; 88 case "-t": i++; timeout = getOptInt(args, (int) timeout, i); break;
88 case "-T": i++; testSize = getOptInt(args, testSize, i); break; 89 case "-T": i++; testSize = getOptInt(args, testSize, i); break;
90 case "-n": i++; nis = getOptString(args, nis, i); break;
89 case "-p": i++; setPort(args,i); break; 91 case "-p": i++; setPort(args,i); break;
90 case "-a": i++; setAddress(args, i); break; 92 case "-a": i++; setAddress(args, i); break;
91 default: i++; 93 default: i++;
92 System.out.println( 94 System.out.println(
93 "(default) Broadcast DatagramSocket\n"+ 95 "(default) Broadcast DatagramSocket\n"+
98 "-r N create N receivers\n"+ 100 "-r N create N receivers\n"+
99 "-s N create N senders\n"+ 101 "-s N create N senders\n"+
100 "-c N send count packet\n"+ 102 "-c N send count packet\n"+
101 "-t N timeout N msec\n"+ 103 "-t N timeout N msec\n"+
102 "-T N send N byte packet\n"+ 104 "-T N send N byte packet\n"+
105 "-n en1 Network Interface name for multicast (default en1)\n"+
103 "-p N broadcast/multicast port\n"+ 106 "-p N broadcast/multicast port\n"+
104 "-a S broadcast/multicast address\n"+ 107 "-a S broadcast/multicast address\n"+
105 "-h print this\n"+ 108 "-h print this\n"+
106 "" 109 ""
107 ); 110 );