Taken from Pasan

Nuwan/Client.java

@@ -22,5 +22,6 @@ public static void main(String[] args)  throws UnknownHostException, Interrupted
          ex.printStackTrace();
       }
 
+      in.close();
    }
 }

Test/AudioSession.java

@@ -19,188 +19,187 @@
 
 public class AudioSession {
 
-  boolean stopCapture = false;
-  ByteArrayOutputStream byteArrayOutputStream;
-  AudioFormat audioFormat;
-  TargetDataLine targetDataLine;
-  AudioInputStream audioInputStream;
-  SourceDataLine sourceDataLine;
-  byte tempBuffer[] = new byte[500];
-  Session peer;
-
-
-  public AudioSession(Session peer) {
-    this.peer = peer;
-  }
-
-  private AudioFormat getAudioFormat() {
-    float sampleRate = 16000.0F;
-    int sampleSizeInBits = 16;
-    int channels = 2;
-    boolean signed = true;
-    boolean bigEndian = true;
-    return new AudioFormat(sampleRate, sampleSizeInBits, channels, signed, bigEndian);
-  }
-
-  public void captureAudio() {
-
-    try {
-      Mixer.Info[] mixerInfo = AudioSystem.getMixerInfo();    //get available mixers
-      System.out.println("Available mixers:");
-      Mixer mixer = null;
-      for (int cnt = 0; cnt < mixerInfo.length; cnt++) {
-        System.out.println(cnt + " " + mixerInfo[cnt].getName());
-        mixer = AudioSystem.getMixer(mixerInfo[cnt]);
-
-        Line.Info[] lineInfos = mixer.getTargetLineInfo();
-        if (lineInfos.length >= 1 && lineInfos[0].getLineClass().equals(TargetDataLine.class)) {
-          System.out.println(cnt + " Mic is supported!");
-          break;
-        }
+   boolean stopCapture = false;
+   ByteArrayOutputStream byteArrayOutputStream;
+   AudioFormat audioFormat;
+   TargetDataLine targetDataLine;
+   AudioInputStream audioInputStream;
+   SourceDataLine sourceDataLine;
+   byte tempBuffer[] = new byte[500];
+   Session peer;
+
+
+   public AudioSession(Session peer) {
+      this.peer = peer;
+   }
+
+   private AudioFormat getAudioFormat() {
+      float sampleRate = 16000.0F;
+      int sampleSizeInBits = 16;
+      int channels = 2;
+      boolean signed = true;
+      boolean bigEndian = true;
+      return new AudioFormat(sampleRate, sampleSizeInBits, channels, signed, bigEndian);
+   }
+
+   public void captureAudio() {
+
+      try {
+         Mixer.Info[] mixerInfo = AudioSystem.getMixerInfo();    //get available mixers
+         System.out.println("Available mixers:");
+         Mixer mixer = null;
+         for (int cnt = 0; cnt < mixerInfo.length; cnt++) {
+            System.out.println(cnt + " " + mixerInfo[cnt].getName());
+            mixer = AudioSystem.getMixer(mixerInfo[cnt]);
+
+            Line.Info[] lineInfos = mixer.getTargetLineInfo();
+            if (lineInfos.length >= 1 && lineInfos[0].getLineClass().equals(TargetDataLine.class)) {
+               System.out.println(cnt + " Mic is supported!");
+               break;
+            }
+         }
+
+         audioFormat = getAudioFormat();     //get the audio format
+         DataLine.Info dataLineInfo = new DataLine.Info(TargetDataLine.class, audioFormat);
+
+         targetDataLine = (TargetDataLine) mixer.getLine(dataLineInfo);
+         targetDataLine.open(audioFormat);
+         targetDataLine.start();
+
+         DataLine.Info dataLineInfo1 = new DataLine.Info(SourceDataLine.class, audioFormat);
+         sourceDataLine = (SourceDataLine) AudioSystem.getLine(dataLineInfo1);
+         sourceDataLine.open(audioFormat);
+         sourceDataLine.start();
+
+         //Setting the maximum volume
+         FloatControl control = (FloatControl)sourceDataLine.getControl(FloatControl.Type.MASTER_GAIN);
+         control.setValue(control.getMaximum());
+
+      } catch (LineUnavailableException e) {
+         System.out.println(e);
+         System.exit(0);
+      }
+
+   }
+   public void capture() {
+      byteArrayOutputStream = new ByteArrayOutputStream();
+      stopCapture = false;
+
+      try {
+         int seq = 0;
+         //Record non-stop
+         while (!stopCapture) {
+
+            //Read from mic and store in temp buffer
+            targetDataLine.read(tempBuffer, 0, tempBuffer.length);  //capture sound into tempBuffer
+            seq = seq%16;
+            tempBuffer[499] = (byte)seq++;
+            System.out.println(tempBuffer[499]);
+
+            //Send whats in buffer to the server using sockets
+            DatagramPacket packet = new DatagramPacket(tempBuffer, tempBuffer.length, peer.ip, peer.port);
+            peer.socket.send(packet);
+         }
+         byteArrayOutputStream.close();
+      } catch (IOException e) {
+         System.out.println(e);
+         System.exit(0);
       }
+   }
 
-      audioFormat = getAudioFormat();     //get the audio format
-      DataLine.Info dataLineInfo = new DataLine.Info(TargetDataLine.class, audioFormat);
-
-      targetDataLine = (TargetDataLine) mixer.getLine(dataLineInfo);
-      targetDataLine.open(audioFormat);
-      targetDataLine.start();
-
-      DataLine.Info dataLineInfo1 = new DataLine.Info(SourceDataLine.class, audioFormat);
-      sourceDataLine = (SourceDataLine) AudioSystem.getLine(dataLineInfo1);
-      sourceDataLine.open(audioFormat);
-      sourceDataLine.start();
-
-      //Setting the maximum volume
-      FloatControl control = (FloatControl)sourceDataLine.getControl(FloatControl.Type.MASTER_GAIN);
-      control.setValue(control.getMaximum());
-
-    } catch (LineUnavailableException e) {
-      System.out.println(e);
-      System.exit(0);
-    }
-
-  }
-  public void capture() {
-    byteArrayOutputStream = new ByteArrayOutputStream();
-    stopCapture = false;
-
-    try {
-      int seq = 0;
-      //Record non-stop
-      while (!stopCapture) {
-
-        //Read from mic and store in temp buffer
-        targetDataLine.read(tempBuffer, 0, tempBuffer.length);  //capture sound into tempBuffer
-        seq = seq%16;
-        tempBuffer[499] = (byte)seq++;
-        System.out.println(tempBuffer[499]);
-
-        //Send whats in buffer to the server using sockets
-        DatagramPacket packet = new DatagramPacket(tempBuffer, tempBuffer.length, peer.ip, peer.port);
-        peer.socket.send(packet);
+   private int getHashId(String ip, int port){
+      int id = 1;
+      for(int i=0;i<ip.length();++i)
+      {
+         id *= (ip.charAt(i)+100);
+      }
+      id *= port;
+      if(id<0){
+         id *= (-1);
       }
-      byteArrayOutputStream.close();
-    } catch (IOException e) {
-      System.out.println(e);
-      System.exit(0);
-    }
-  }
-
-  private int getHashId(String ip, int port){
-    int id = 1;
-    for(int i=0;i<ip.length();++i)
-    {
-      id *= (ip.charAt(i)+100);
-    }
-    id *= port;
-    if(id<0){
-      id *= (-1);
-    }
-    return id%500;
-  }
-
-  public void play() {
-    byteArrayOutputStream = new ByteArrayOutputStream();
-    stopCapture = false;
-    HashMap<Integer, Client> clientList = new HashMap<Integer, Client>();
-
-    try {
-      byte[] buffer=new byte[500];
-
-      //Play non-stop
-      while (!stopCapture) {
-
-        DatagramPacket packet=new DatagramPacket(buffer, buffer.length);
-
-        peer.socket0.receive(packet);
-        String sourceIp = packet.getAddress().getHostName();
-        int sourcePort = packet.getPort();
-
-        int hashId = getHashId(sourceIp,sourcePort);
-        Client client;
-
-        if(clientList.containsKey(hashId)){
-          client = clientList.get(hashId);
-        }
-        else{
-          client = new Client();
-          clientList.put(hashId,client);
-        }
-
-        int userId = client.userId;
-        buffer = packet.getData();
-
-        /*System.out.println(userId+": "+buffer[499]);
-        sourceDataLine.write(buffer, 0, 500);   //playing audio available in tempBuffer*/
-
-        //Packet re-arranging algorithm
-
-        //------------------------------------------------------------------------------------------------------
-        if (buffer[499] >= 0 && buffer[499] <= 15) {
-
-          int currentPacket = buffer[499];
-          System.out.println("Expected("+userId+"): "+client.seq+" "+"Arrived: "+currentPacket);
-          if(currentPacket != client.seq) {
-            System.out.println("Not in Sequence");
-            if(client.memBuffer[client.seq] == null) {
-              System.out.println("Not in Buffer");
-              client.memBuffer[currentPacket] = Arrays.copyOf(buffer, 500);
-              ++client.packetLoss;
-              if(client.packetLoss > 3){
-                client.packetLoss = 0;
-                continue;
-              }
-              else{
-                continue;
-              }
+      return id%500;
+   }
+
+   public void play() {
+      byteArrayOutputStream = new ByteArrayOutputStream();
+      stopCapture = false;
+      HashMap<Integer, Client> clientList = new HashMap<Integer, Client>();
+
+      try {
+         byte[] buffer=new byte[500];
+
+         //Play non-stop
+         while (!stopCapture) {
+
+            DatagramPacket packet=new DatagramPacket(buffer, buffer.length);
+
+            peer.socket0.receive(packet);
+            String sourceIp = packet.getAddress().getHostName();
+            int sourcePort = packet.getPort();
+
+            int hashId = getHashId(sourceIp,sourcePort);
+            Client client;
+
+            if(clientList.containsKey(hashId)){
+               client = clientList.get(hashId);
             }
             else{
-              System.out.println("Exist in Buffer: "+client.seq);
-              buffer = Arrays.copyOf(client.memBuffer[client.seq], 500);
-              client.memBuffer[client.seq] = null;
+               client = new Client();
+               clientList.put(hashId,client);
+            }
+
+            int userId = client.userId;
+            buffer = packet.getData();
+
+            /*System.out.println(userId+": "+buffer[499]);
+            sourceDataLine.write(buffer, 0, 500);   //playing audio available in tempBuffer*/
+            //Packet re-arranging algorithm
+            //------------------------------------------------------------------------------------------------------
+
+            if (buffer[499] >= 0 && buffer[499] <= 15) {
+
+               int currentPacket = buffer[499];
+               System.out.println("Expected("+userId+"): "+client.seq+" "+"Arrived: "+currentPacket);
+               if(currentPacket != client.seq) {
+                  System.out.println("Not in Sequence");
+                  if(client.memBuffer[client.seq] == null) {
+                     System.out.println("Not in Buffer");
+                     client.memBuffer[currentPacket] = Arrays.copyOf(buffer, 500);
+                     ++client.packetLoss;
+                     if(client.packetLoss > 3){
+                        client.packetLoss = 0;
+                        continue;
+                     }
+                     else{
+                        continue;
+                     }
+                  }
+                  else{
+                     System.out.println("Exist in Buffer: "+client.seq);
+                     buffer = Arrays.copyOf(client.memBuffer[client.seq], 500);
+                     client.memBuffer[client.seq] = null;
+                  }
+               }
+               //------------------------------------------------------------------------------------------------------
+
+               //Play data in temp buffer
+               byteArrayOutputStream.write(buffer, 0, 500);
+               System.out.println("Playing: "+buffer[499]);
+               sourceDataLine.write(buffer, 0, 500);   //playing audio available in tempBuffer
+
+               //--------------------------------------------------------------------------------------------------------
+               ++client.seq;
+               client.seq %= 16;
+               if(client.seq == 0){
+                  client.memBuffer = client.initializeMemBuffer();
+                  System.out.println("User: "+userId+" clearing buffer");
+               }
             }
-          }
-          //------------------------------------------------------------------------------------------------------
-
-          //Play data in temp buffer
-          byteArrayOutputStream.write(buffer, 0, 500);
-          System.out.println("Playing: "+buffer[499]);
-          sourceDataLine.write(buffer, 0, 500);   //playing audio available in tempBuffer
-
-          //--------------------------------------------------------------------------------------------------------
-          ++client.seq;
-          client.seq %= 16;
-          if(client.seq == 0){
-            client.memBuffer = client.initializeMemBuffer();
-            System.out.println("User: "+userId+" clearing buffer");
-          }
-        }
+         }
+         byteArrayOutputStream.close();
+      } catch (IOException e) {
+         System.out.println(e);
+         System.exit(0);
       }
-      byteArrayOutputStream.close();
-    } catch (IOException e) {
-      System.out.println(e);
-      System.exit(0);
-    }
-  }
+   }
 }