Mercurial > hg > Members > kono > WifiBroadcast

comparison src/wifibroadcast/WifiBroadcastTest.java @ 4:404778ac3f55

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
worked. Broadcast, Multicast, Multicast channel.
author one
date Sat, 28 Jul 2012 19:33:34 +0900
parents 9c99e2193277
children 7679d10bdae9
comparison
equal deleted inserted replaced
3:9c99e2193277 4:404778ac3f55
5 5
6 public class WifiBroadcastTest { 6 public class WifiBroadcastTest {
7 private static int DefaultPort = 8412; 7 private static int DefaultPort = 8412;
8 private static String MCASTADDR = "224.0.0.1"; 8 private static String MCASTADDR = "224.0.0.1";
9 private static int testSize = 256; 9 private static int testSize = 256;
10 private static long timeout = 1000;
10 11
11 public static void main(String args[]) { 12 public static void main(String args[]) {
12 int port = DefaultPort ; 13 int port = DefaultPort ;
13 int count = 16; 14 int count = 16;
14 long timeout = 1000;
15 boolean multicast = false; 15 boolean multicast = false;
16 boolean mchannel = false; 16 boolean mchannel = false;
17 WifiReceiver wbr = null; 17 WifiReceiver wbr = null;
18 WifiReceiver wbs = null; 18 WifiReceiver wbs = null;
19 for(int i=0;i<args.length;i++) { 19 for(int i=0;i<args.length;i++) {
24 else if (args[i].equals("-p")) { i++; port = getOptInt(args, count, i);} 24 else if (args[i].equals("-p")) { i++; port = getOptInt(args, count, i);}
25 } 25 }
26 try { 26 try {
27 if (multicast) { 27 if (multicast) {
28 wbr = new WifiMulticast(MCASTADDR,port,WifiReceiver.SocketType.Receiver); 28 wbr = new WifiMulticast(MCASTADDR,port,WifiReceiver.SocketType.Receiver);
29 Thread.sleep(5000); 29 Thread.sleep(timeout);
30 wbs = new WifiMulticast(MCASTADDR,port,WifiReceiver.SocketType.Receiver); 30 wbs = new WifiMulticast(MCASTADDR,port,WifiReceiver.SocketType.Receiver);
31 } else if (mchannel) { 31 } else if (mchannel) {
32 wbr = new WifiMulticastChannel(MCASTADDR,port,WifiReceiver.SocketType.Receiver); 32 wbr = new WifiMulticastChannel(MCASTADDR,port,WifiReceiver.SocketType.Receiver);
33 Thread.sleep(5000); 33 Thread.sleep(timeout);
34 wbs = new WifiMulticastChannel(MCASTADDR,port,WifiReceiver.SocketType.Sender); 34 wbs = new WifiMulticastChannel(MCASTADDR,port,WifiReceiver.SocketType.Sender);
35 } else { 35 } else {
36 wbr = new WifiBroadcast(port,WifiReceiver.SocketType.Receiver); 36 wbr = new WifiBroadcast(port,WifiReceiver.SocketType.Receiver);
37 Thread.sleep(5000); 37 Thread.sleep(timeout);
38 wbs = new WifiBroadcast(port,WifiReceiver.SocketType.Sender); 38 wbs = new WifiBroadcast(port,WifiReceiver.SocketType.Sender);
39 } 39 }
40 } catch (IOException e) { 40 } catch (IOException e) {
41 System.err.println("err "+e); 41 System.err.println("err "+e);
42 } catch (InterruptedException e) { 42 } catch (InterruptedException e) {
61 @Override 61 @Override
62 public void run() { 62 public void run() {
63 ByteBuffer testData = getTestData(testSize); 63 ByteBuffer testData = getTestData(testSize);
64 int i = 0; 64 int i = 0;
65 try { 65 try {
66 Thread.sleep(1000); 66 Thread.sleep(timeout);
67 for(i = 0; i<count;i++) { 67 for(i = 0; i<count;i++) {
68 testData.putInt(0, i); 68 testData.putInt(0, i);
69 wbs.send(testData); 69 wbs.send(testData);
70 testData.flip(); 70 testData.flip();
71 } 71 }