Mercurial > hg > Members > kono > WifiBroadcast

annotate src/wifibroadcast/WifiBroadcastTest.java @ 19:bb2538b7eb8d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
selectMode flag
author one
date Tue, 31 Jul 2012 17:02:46 +0900
parents e9d07562b6b7
children 280de47f460d
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package wifibroadcast;
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 import java.io.IOException;
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 import java.nio.ByteBuffer;
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
5 import java.util.LinkedList;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 public class WifiBroadcastTest {
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
8 private static int DefaultPort = 8412;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 private static String MCASTADDR = "224.0.0.1";
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
10 private static int testSize = 256;
4
404778ac3f55 worked. Broadcast, Multicast, Multicast channel.
one
parents: 3
diff changeset
11 private static long timeout = 1000;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
13
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
14 LinkedList<Integer> ports = new LinkedList<Integer>();
cce76e5eb29b with tcp
one
parents: 14
diff changeset
15 LinkedList<String> addresses = new LinkedList<String>();
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
16 int count = 16;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
17 boolean multicast = false;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
18 boolean mchannel = false;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
19 int receiver_count = 1;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
20 int sender_count = 1;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
21 WifiReceiver wbr[] = new WifiReceiver[receiver_count];
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
22 WifiReceiver wbs[] = new WifiReceiver[sender_count];
12
e1f43b669cdb broadcast on DatagramChannel
one
parents: 10
diff changeset
23 private boolean bchannel;
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
24 private boolean tcp;
18
e9d07562b6b7 network interface
one
parents: 16
diff changeset
25 private String nis = "en1";
19
bb2538b7eb8d selectMode flag
one
parents: 18
diff changeset
26 private boolean selectMode = false;
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
27
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
28 public WifiBroadcastTest() {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
29 ports.add(0,DefaultPort);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
30 addresses.add(0,MCASTADDR);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
31 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
32
2
2a328333ba70 no compile errors
one
parents: 1
diff changeset
33 public static void main(String args[]) {
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
34 new WifiBroadcastTest().test(args);
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
35 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
36
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
37 public void test(String args[]) {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
38 options(args);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
39 try {
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
40 if (multicast) {
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
41 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiMulticast(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver);
10
fc180f38257e multiple sender
one
parents: 9
diff changeset
42 Thread.sleep(timeout/4);
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
43 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiMulticast(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender);
1
649b8573372c cleanup
one
parents: 0
diff changeset
44 } else if (mchannel) {
18
e9d07562b6b7 network interface
one
parents: 16
diff changeset
45 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiMulticastChannel(i,getAddress(i),getPort(i),nis, WifiReceiver.SocketType.Receiver);
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
46 Thread.sleep(timeout/4);
18
e9d07562b6b7 network interface
one
parents: 16
diff changeset
47 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiMulticastChannel(i,getAddress(i),getPort(i),nis, WifiReceiver.SocketType.Sender);
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
48 } else if (tcp) {
16
b5ab7003f6d1 tcp running
one
parents: 15
diff changeset
49 addresses.remove(); addresses.add("127.1");
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
50 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiTCP(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Receiver);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
51 Thread.sleep(timeout/4);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
52 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiTCP(i,getAddress(i),getPort(i),WifiReceiver.SocketType.Sender);
12
e1f43b669cdb broadcast on DatagramChannel
one
parents: 10
diff changeset
53 } else if (bchannel) {
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
54 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiBroadcastChannel(i,getPort(i),WifiReceiver.SocketType.Receiver);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
55 Thread.sleep(timeout/4);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
56 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiBroadcastChannel(i,getPort(i),WifiReceiver.SocketType.Sender);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
57 } else {
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
58 for(int i=0;i<wbr.length;i++) wbr[i] = new WifiBroadcast(i,getPort(i),WifiReceiver.SocketType.Receiver);
10
fc180f38257e multiple sender
one
parents: 9
diff changeset
59 Thread.sleep(timeout/4);
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
60 for(int i=0;i<wbs.length;i++) wbs[i] = new WifiBroadcast(i,getPort(i),WifiReceiver.SocketType.Sender);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
61 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
62 } catch (IOException e) {
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
63 System.err.println("err "+e);
9c99e2193277 find broadcast
one
parents: 2
diff changeset
64 } catch (InterruptedException e) {
9c99e2193277 find broadcast
one
parents: 2
diff changeset
65 System.err.println("err "+e);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
66 }
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
67 runTest(count, wbr, wbs);
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
68
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
69 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
70
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
71 private String getAddress(int i) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
72 return addresses.get(i%addresses.size());
cce76e5eb29b with tcp
one
parents: 14
diff changeset
73 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
74
cce76e5eb29b with tcp
one
parents: 14
diff changeset
75 private int getPort(int i) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
76 return ports.get(i%ports.size());
cce76e5eb29b with tcp
one
parents: 14
diff changeset
77 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
78
cce76e5eb29b with tcp
one
parents: 14
diff changeset
79 public void options(String[] args) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
80 for(int i=0;i<args.length;i++) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
81 switch(args[i]) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
82 case "-m": multicast = true; break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
83 case "-channel": mchannel = true; break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
84 case "-bchannel": bchannel = true; break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
85 case "-tcp": tcp = true; break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
86 case "-r": i++; receiver_count = getOptInt(args, receiver_count, i); wbr = new WifiReceiver[receiver_count]; break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
87 case "-s": i++; sender_count = getOptInt(args, sender_count, i); wbs = new WifiReceiver[sender_count]; break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
88 case "-c": i++; count = getOptInt(args, count, i); break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
89 case "-t": i++; timeout = getOptInt(args, (int) timeout, i); break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
90 case "-T": i++; testSize = getOptInt(args, testSize, i); break;
18
e9d07562b6b7 network interface
one
parents: 16
diff changeset
91 case "-n": i++; nis = getOptString(args, nis, i); break;
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
92 case "-p": i++; setPort(args,i); break;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
93 case "-a": i++; setAddress(args, i); break;
19
bb2538b7eb8d selectMode flag
one
parents: 18
diff changeset
94 case "-select": i++; selectMode = true; break;
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
95 default: i++;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
96 System.out.println(
cce76e5eb29b with tcp
one
parents: 14
diff changeset
97 "(default) Broadcast DatagramSocket\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
98 "-m Multicast DatagramSocket\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
99 "-cahnnel Multicast with DatagramChannel\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
100 "-bcahnnel Broadcase with DatagramChannel\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
101 "-tcp TCP stream\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
102 "-r N create N receivers\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
103 "-s N create N senders\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
104 "-c N send count packet\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
105 "-t N timeout N msec\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
106 "-T N send N byte packet\n"+
18
e9d07562b6b7 network interface
one
parents: 16
diff changeset
107 "-n en1 Network Interface name for multicast (default en1)\n"+
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
108 "-p N broadcast/multicast port\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
109 "-a S broadcast/multicast address\n"+
19
bb2538b7eb8d selectMode flag
one
parents: 18
diff changeset
110 "-select use select for timeout\n"+
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
111 "-h print this\n"+
cce76e5eb29b with tcp
one
parents: 14
diff changeset
112 ""
cce76e5eb29b with tcp
one
parents: 14
diff changeset
113 );
cce76e5eb29b with tcp
one
parents: 14
diff changeset
114 return;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
115 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
116 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
117 }
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
118
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
119
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
120
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
121
cce76e5eb29b with tcp
one
parents: 14
diff changeset
122 public void runTest(int count, WifiReceiver[] wbr, WifiReceiver wbs[]) {
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
123 Thread t = timeouter();
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
124 Thread send[] = new Thread[wbs.length];
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
125 int id = 0;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
126 for(WifiReceiver s:wbs) {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
127 send[id]= sender(s,count);
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
128 id ++;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
129 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
130 id = 0;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
131 Thread recv[] = new Thread[wbr.length];
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
132 for(WifiReceiver r: wbr) {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
133 recv[id] = receiver(r,id, count, timeout);
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
134 id ++;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
135 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
136 try {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
137 for(int i = 0;i<wbr.length;i++) {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
138 recv[i].join();
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
139 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
140 for(int i = 0;i<wbs.length;i++) {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
141 send[i].join();
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
142 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
143 t.join();
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
144 } catch (InterruptedException e) {
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
145 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
146 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
147
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
148
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
149
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
150 public int getOptInt(String[] args, int count, int i) {
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
151 if (i<args.length) { count = Integer.parseInt(args[i]); }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
152 return count;
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
153 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
154
12
e1f43b669cdb broadcast on DatagramChannel
one
parents: 10
diff changeset
155 public String getOptString(String[] args, String str, int i) {
e1f43b669cdb broadcast on DatagramChannel
one
parents: 10
diff changeset
156 if (i<args.length) { str = args[i]; }
e1f43b669cdb broadcast on DatagramChannel
one
parents: 10
diff changeset
157 return str;
e1f43b669cdb broadcast on DatagramChannel
one
parents: 10
diff changeset
158 }
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
159
15
cce76e5eb29b with tcp
one
parents: 14
diff changeset
160 private void setAddress(String[] args, int i) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
161 String adr = getOptString(args,addresses.get(0),i);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
162 int p;
cce76e5eb29b with tcp
one
parents: 14
diff changeset
163 if ((p=adr.indexOf(":"))>0) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
164 String sp = adr.substring(p+1);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
165 adr = adr.substring(0,p-1);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
166 if (ports.size()>i) ports.remove(i);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
167 ports.add(i,Integer.parseInt(sp));
cce76e5eb29b with tcp
one
parents: 14
diff changeset
168 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
169 if (addresses.size()>i) addresses.remove(i);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
170 addresses.add(i,adr);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
171 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
172
cce76e5eb29b with tcp
one
parents: 14
diff changeset
173 private void setPort(String[] args, int i) {
cce76e5eb29b with tcp
one
parents: 14
diff changeset
174 if (ports.size()>i) ports.remove(i);
cce76e5eb29b with tcp
one
parents: 14
diff changeset
175 ports.add(i,Integer.parseInt(args[i]));
cce76e5eb29b with tcp
one
parents: 14
diff changeset
176 }
cce76e5eb29b with tcp
one
parents: 14
diff changeset
177
cce76e5eb29b with tcp
one
parents: 14
diff changeset
178 public Thread sender(final WifiReceiver wbs, final int count) {
19
bb2538b7eb8d selectMode flag
one
parents: 18
diff changeset
179 wbs.selectMode(selectMode);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
180 Runnable sender = new Runnable() {
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
181
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
182 @Override
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
183 public void run() {
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
184 ByteBuffer testData = getTestData(testSize);
9c99e2193277 find broadcast
one
parents: 2
diff changeset
185 int i = 0;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
186 try {
4
404778ac3f55 worked. Broadcast, Multicast, Multicast channel.
one
parents: 3
diff changeset
187 Thread.sleep(timeout);
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
188 for(i = 0; i<count;i++) {
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
189 testData.putInt(0, i);
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
190 wbs.send(testData);
2
2a328333ba70 no compile errors
one
parents: 1
diff changeset
191 testData.flip();
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
192 }
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
193 } catch (Exception e) {
9c99e2193277 find broadcast
one
parents: 2
diff changeset
194 System.err.println("sender error at "+i+" "+e);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
195 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
196 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
197 };
2
2a328333ba70 no compile errors
one
parents: 1
diff changeset
198 Thread s = new Thread(sender);
2a328333ba70 no compile errors
one
parents: 1
diff changeset
199 s.start();
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
200 return s;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
201 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
202
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
203 private boolean running;
1
649b8573372c cleanup
one
parents: 0
diff changeset
204
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
205 public Thread timeouter() {
1
649b8573372c cleanup
one
parents: 0
diff changeset
206 running = true;
649b8573372c cleanup
one
parents: 0
diff changeset
207 Runnable timeouter = new Runnable() {
649b8573372c cleanup
one
parents: 0
diff changeset
208 @Override
649b8573372c cleanup
one
parents: 0
diff changeset
209 public void run() {
649b8573372c cleanup
one
parents: 0
diff changeset
210 try {
649b8573372c cleanup
one
parents: 0
diff changeset
211 Thread.sleep(30*1000);
649b8573372c cleanup
one
parents: 0
diff changeset
212 } catch (InterruptedException e) {
649b8573372c cleanup
one
parents: 0
diff changeset
213 }
649b8573372c cleanup
one
parents: 0
diff changeset
214 running = false;
649b8573372c cleanup
one
parents: 0
diff changeset
215 }
649b8573372c cleanup
one
parents: 0
diff changeset
216 };
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
217 Thread t = new Thread(timeouter); t.start();
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
218 return t;
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
219 }
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
220
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
221 public Thread receiver(final WifiReceiver wbr, final int id, final int count, final long timeout) {
19
bb2538b7eb8d selectMode flag
one
parents: 18
diff changeset
222 wbr.selectMode(selectMode);
1
649b8573372c cleanup
one
parents: 0
diff changeset
223 Runnable receiver = new Runnable() {
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
224 @Override
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
225 public void run() {
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
226 ByteBuffer testData = ByteBuffer.allocate(4096);
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
227 int bad = 0, good = 0;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
228 try {
1
649b8573372c cleanup
one
parents: 0
diff changeset
229 for(int i = 0; running && i<count;i++) {
2
2a328333ba70 no compile errors
one
parents: 1
diff changeset
230 testData.clear();
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
231 wbr.recieve(testData,timeout);
2
2a328333ba70 no compile errors
one
parents: 1
diff changeset
232 if (!testData.hasRemaining()) continue;
5
7679d10bdae9 multiple receivers
one
parents: 4
diff changeset
233 System.out.println("receive id"+id+":"+testData.remaining()+" bytes.");
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
234 int seq = testData.getInt();
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
235 if (seq!=i) {
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
236 bad++; i = seq;
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
237 } else {
9c99e2193277 find broadcast
one
parents: 2
diff changeset
238 good++;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
239 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
240 }
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
241 } catch (Exception e) {
9c99e2193277 find broadcast
one
parents: 2
diff changeset
242 System.err.println("receiver error "+e);
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
243 }
3
9c99e2193277 find broadcast
one
parents: 2
diff changeset
244 System.out.println("get "+good+" packets, "+bad+" losts.");
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
245 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
246 };
2
2a328333ba70 no compile errors
one
parents: 1
diff changeset
247 Thread r = new Thread(receiver); r.start();
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
248 return r;
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
249 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
250
9
95d58cc5bb0b instance for test, multiple senders
one
parents: 5
diff changeset
251 public ByteBuffer getTestData(int i) {
0
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
252 ByteBuffer b = ByteBuffer.allocate(i);
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
253 b.putInt(0);
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
254 for(int j = 0; j<256; j++ ) {
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
255 b.put((byte)j);
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
256 if (! b.hasRemaining()) break;
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
257 if (j == 255) j=0;
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
258 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
259 b.flip();
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
260 return b;
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
261 }
df9d16620c08 Wifi broad cast test program
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
262 }