Travis CI and a new scheduler integration into MSocket code

.gitignore

@@ -0,0 +1 @@
+.DS_Store

.travis.yml

@@ -0,0 +1,19 @@
+language: java
+# sudo: required instructs Travis to use a "real VM" instead of a docker VM
+sudo: required
+jdk:
+- oraclejdk9
+
+before_install:
+- sudo apt-get update -qq
+- sudo apt-get install -qq ant-optional
+
+#notifications:
+ # email:
+ #   on_success: always
+ #  on_failure: always
+install:
+- sudo apt-get install ant
+script:
+- cd scripts
+- ./travis_performance_test.sh

scripts/MSocketClient.java

@@ -0,0 +1,100 @@
+import edu.umass.cs.msocket.FlowPath;
+import edu.umass.cs.msocket.MSocket;
+import edu.umass.cs.msocket.mobility.MobilityManagerClient;
+
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.InetAddress;
+import java.nio.ByteBuffer;
+import java.text.DecimalFormat;
+import java.util.Arrays;
+
+public class MSocketClient implements Runnable {
+
+
+    private static final int    LOCAL_PORT = 5556;
+    private static final String LOCALHOST  = "127.0.0.1";
+    private static DecimalFormat df = new DecimalFormat("0.00##");
+    private static final int TOTAL_ROUND = 100;
+    private static int numBytes = 64000000;
+
+    public static Long calc_median(Long[] input){
+      Arrays.sort(input);
+      Long median;
+      if (input.length % 2 == 0)
+        median = ((long)input[input.length/2] + (long)input[input.length/2 - 1])/2;
+      else
+        median = (long) input[input.length/2];
+      return median;
+    }
+    public static Long calc_avg(Long[] input){
+            int len = input.length;
+            Long sum = 0L;
+            for(int i=0;i<len;i++){
+                sum = sum  + input[i];
+            }
+            return sum/len;
+    }
+    public MSocketClient(){
+
+    }
+    public void run(){
+
+      String serverIPOrName = LOCALHOST;
+      int serverPort = LOCAL_PORT;
+      int numRound = TOTAL_ROUND;
+      int numOfBytes= numBytes;
+      long median_time = 0;
+
+      try{
+        MSocket ms = new MSocket(InetAddress.getByName(serverIPOrName), serverPort);
+        OutputStream os = ms.getOutputStream();
+        InputStream is = ms.getInputStream();
+        try {
+          Thread.sleep(2000); // wait for 2 seconds for all connections
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+
+        int current_round = 0;
+        Long[]  transferTime  = new Long[numRound];
+        while (current_round < numRound) {
+            int numSent = numOfBytes;
+            byte[] b = new byte[numSent];
+            ByteBuffer dbuf = ByteBuffer.allocate(4);
+            dbuf.putInt(numSent);
+            byte[] bytes = dbuf.array();
+            int numRead;
+            int totalRead = 0;
+            long start = System.currentTimeMillis();
+            os.write(bytes);
+            do {
+                numRead = is.read(b);
+                if (numRead >= 0)
+                    totalRead += numRead;
+
+            } while (totalRead < numSent);
+
+            long elapsed = System.currentTimeMillis() - start;
+            transferTime[current_round] = elapsed;
+            current_round++;
+        }
+
+        os.write(-1);
+        os.flush();
+
+        median_time = calc_avg(transferTime);
+        System.out.println(median_time);
+        ms.close();
+
+
+        return;
+
+      }catch(Exception e){
+        e.printStackTrace();
+      }
+
+
+
+    }
+}

scripts/MSocketServer.java

@@ -0,0 +1,108 @@
+import edu.umass.cs.msocket.MServerSocket;
+import edu.umass.cs.msocket.MSocket;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.nio.ByteBuffer;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Random;
+import java.util.Scanner;
+
+public class MSocketServer implements Runnable{
+
+    private static final int    LOCAL_PORT = 5556;
+    private static final String LOCALHOST  = "127.0.0.1";
+    private static MServerSocket mss = null;
+    static DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss");
+
+    public MSocketServer(){
+
+    }
+    public void run(){
+      String serverIPOrName = LOCALHOST;
+      int serverPort = LOCAL_PORT;
+      try{
+        mss = new MServerSocket(serverPort, 0, InetAddress.getByName(serverIPOrName));
+        MSocket msocket = mss.accept();
+        RequestHandlingThread requestThread = new RequestHandlingThread(msocket);
+        requestThread.start();
+      }catch(IOException e){
+        e.printStackTrace();
+      }
+    }
+
+    private static class RequestHandlingThread extends Thread
+    {
+        private MSocket msocket;
+
+        public RequestHandlingThread(MSocket msocket)
+        {
+            this.msocket = msocket;
+        }
+
+        public void run()
+        {
+            int numRead = 0;
+            Scanner reader = new Scanner(System.in);
+            InputStream is = null;
+            OutputStream os = null;
+            try {
+                is = msocket.getInputStream();
+                os = msocket.getOutputStream();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+            if(is != null) {
+
+
+                while(numRead >= 0) {
+                    long start = System.currentTimeMillis();
+
+
+                    byte[] numByteArr = new byte[8];
+                    try {
+
+                        is.read(numByteArr);
+                        ByteBuffer wrapped = ByteBuffer.wrap(numByteArr);
+                        numRead = wrapped.getInt();
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                    if (numRead > 0) {
+
+
+                        byte[] b = new byte[numRead];
+                        new Random().nextBytes(b);
+
+                        try {
+                            os.write(b);
+                            os.flush();
+                        } catch (IOException e) {
+                            e.printStackTrace();
+                        }
+                        // reset
+                        b = null;
+                        numRead = 0;
+                        long elapsed = System.currentTimeMillis() - start;
+                        LocalDateTime now = LocalDateTime.now();
+
+                    }
+
+                }
+
+                try {
+                    msocket.close();
+                    System.exit(0);
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+
+            }
+
+
+        }
+    }
+}

scripts/TCPClient.java

@@ -0,0 +1,105 @@
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.InetAddress;
+import java.nio.ByteBuffer;
+import java.text.DecimalFormat;
+import java.io.*;
+import java.net.*;
+import java.lang.*;
+import java.nio.*;
+import java.util.Arrays;
+
+
+public class TCPClient implements Runnable{
+
+
+    private static final int    LOCAL_PORT = 5455;
+    private static final String LOCALHOST  = "127.0.0.1";
+    private static final DecimalFormat df = new DecimalFormat("0.00##");
+    private static final int TOTAL_ROUND = 100;
+    private static final int numBytes = 64000000;
+
+    public TCPClient(){
+
+    }
+    public static Long calc_avg(Long[] input){
+            int len = input.length;
+            Long sum = 0L;
+            for(int i=0;i<len;i++){
+                sum = sum  + input[i];
+            }
+            return sum/len;
+    }
+    public static Long calc_median(Long[] input){
+      Arrays.sort(input);
+      Long median;
+      if (input.length % 2 == 0)
+        median = ((long)input[input.length/2] + (long)input[input.length/2 - 1])/2;
+      else
+        median = (long) input[input.length/2];
+      return median;
+    }
+    public void run(){
+      String serverIPOrName = LOCALHOST;
+      int serverPort = LOCAL_PORT;
+      int numRound = TOTAL_ROUND;
+      int numOfBytes= numBytes;
+      long median_time = 0;
+
+      try {
+
+        Socket socket = null;
+        socket = new Socket(serverIPOrName,serverPort);
+        OutputStream os = socket.getOutputStream();
+        InputStream is = socket.getInputStream();
+        // wait for 2 seconds for all connections
+        try {
+            Thread.sleep(2000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+
+        int current_round = 0;
+        Long[]  transferTime  = new Long[numRound];
+        while (current_round < numRound) {
+            int numSent = numOfBytes;
+
+            byte[] b = new byte[numSent];
+            ByteBuffer dbuf = ByteBuffer.allocate(4);
+            dbuf.putInt(numSent);
+            byte[] bytes = dbuf.array();
+            int numRead;
+            int totalRead = 0;
+            long start = System.currentTimeMillis();
+            os.write(bytes);
+            do {
+                numRead = is.read(b);
+                if (numRead >= 0)
+                    totalRead += numRead;
+
+            } while (totalRead < numSent);
+
+            long elapsed = System.currentTimeMillis() - start;
+
+
+            transferTime[current_round] = elapsed;
+            current_round++;
+        }
+
+        os.write(-1);
+        os.flush();
+
+        median_time = calc_avg(transferTime);
+        System.out.println(median_time);
+        socket.close();
+
+    } catch (Exception e) {
+        e.printStackTrace();
+    }
+
+
+
+
+    }
+
+}