/*
    * Created on Mar 22, 2004
    *
    */
   package org.neo.swarm.util.network.multicast;
   
   import java.net.InetAddress;
   import java.util.ArrayList;
   
  import junit.framework.TestCase;
  
  /***
   * @author navery
   *
   */
  public class MulticastTest extends TestCase {
  	private static String PAD = "BytePaddingMessageThatDoesStuffXXXXYYYZZZAABBCCAADDEEFFQQWWEERRTTYY";	
  	public static boolean called = false;
  	
  	public void testStuff() throws Exception {
  
  		MulticastReader reader = new MulticastReader(InetAddress.getByName("225.0.0.1"), 5000, 0);
          
  		Thread sender = new Thread() {
  			public void run() {
  				MulticastSender sender = null;
  				try {
  					sender = new MulticastSender(InetAddress.getByName("225.0.0.1"), 5000, false);
  				sender.send("blah".getBytes());
  				called = true;
                  } catch (Exception e) {
                      e.printStackTrace();
                  }
  
  			}
  		};
  
  		sender.start();
  		reader.read();
  	
  		int wait = 0;
  		while (!called && wait < 3){
  			Thread.sleep(1000);
  		}	
  		assertTrue(called);
  	}
      
  	public void testLoadedSender() throws Exception {
  		MulticastReader reader = new MulticastReader(InetAddress.getByName("225.0.0.1"), 5000, 0);
  		int numberOfSenders = 10;
          
  		ArrayList senders = new ArrayList();
  		
          for (int i = 0; i < numberOfSenders; i++){
  			
  			Thread sender = new Thread() {
  				public void run() {
  					MulticastSender sender;
  					try {
  						sender = new MulticastSender(InetAddress.getByName("225.0.0.1"), 5000, false);
  						for (int i = 0; i < 10; i++) {
  							//			sender.send("blah".getBytes());
  				//			System.out.println("send>>" + i);
  							sender.send(makeMessage(14 * 1024));
  						}
  					} catch (Exception e) {
  						e.printStackTrace();
  					}
  				}
  			};
  			senders.add(sender);
  		}
  		for (int i = 0; i < numberOfSenders; i++){
  			Thread sender = (Thread) senders.get(i);
  			sender.start();
  		}
  		for (int i = 0; i < numberOfSenders; i++){		
  			reader.read();
  			//System.out.println(result);
  		}
  	}
      
  	static byte[] makeMessage(int size) throws Exception {
  		byte[] sendMessage = new byte[size];
  		
  		byte[] padding = PAD.getBytes();
  
  		// fill the buffer
  		int pos = 0;
  		while (pos < size) {
  			sendMessage[pos] = padding[pos++ % padding.length];
  		}
  		return sendMessage;
  	}
  }