Adding QUIC support to Mobilyzer

Mobilyzer/build.gradle

@@ -0,0 +1,30 @@
+apply plugin: 'com.android.library'
+
+android {
+    compileSdkVersion 19
+    buildToolsVersion "23.0.1"
+
+    defaultConfig {
+        minSdkVersion 14
+        targetSdkVersion 19
+    }
+
+    sourceSets {
+        main {
+            manifest.srcFile 'AndroidManifest.xml'
+            res.srcDirs = ['res']
+            java.srcDirs = ['src']
+        }
+    }
+
+    lintOptions {
+        abortOnError false
+    }
+
+}
+
+dependencies {
+    compile fileTree(dir: 'libs', include: ['*.jar'])
+    compile 'com.google.android.gms:play-services:7.3.0'
+    compile project(':mobilibs:ExoPlayer:library')
+}

Mobilyzer/src/com/mobilyzer/MeasurementResult.java

@@ -24,10 +24,14 @@
 import android.os.Parcelable;
 import android.util.StringBuilderPrinter;
 
+import com.mobilyzer.measurements.CronetHttpTask;
+import com.mobilyzer.measurements.CronetHttpTask.CronetHttpDesc;
 import com.mobilyzer.measurements.DnsLookupTask;
 import com.mobilyzer.measurements.HttpTask;
 import com.mobilyzer.measurements.ParallelTask;
 import com.mobilyzer.measurements.PingTask;
+import com.mobilyzer.measurements.QuicHttpTask;
+import com.mobilyzer.measurements.QuicHttpTask.QuicDesc;
 import com.mobilyzer.measurements.RRCTask;
 import com.mobilyzer.measurements.SequentialTask;
 import com.mobilyzer.measurements.TCPThroughputTask;
@@ -247,7 +251,11 @@ public String toString() {
         getPingResult(printer, values);
       } else if (type.equals(HttpTask.TYPE)) {
         getHttpResult(printer, values);
-      } else if (type.equals(DnsLookupTask.TYPE)) {
+      } else if (type.equals(CronetHttpTask.TYPE)) {
+        getCronetHttpResult(printer, values);
+      } else if (type.equals(QuicHttpTask.TYPE)) {
+        getQuicHttpResult(printer, values);
+      }else if (type.equals(DnsLookupTask.TYPE)) {
         getDnsResult(printer, values);
       } else if (type.equals(TracerouteTask.TYPE)) {
         getTracerouteResult(printer, values);
@@ -333,6 +341,50 @@ private void getHttpResult(StringBuilderPrinter printer, HashMap<String, String>
     }
   }
 
+  private void getQuicHttpResult(StringBuilderPrinter printer, HashMap<String, String> values) {
+    QuicDesc desc = (QuicDesc) parameters;
+    printer.println("[QUIC]");
+    printer.println("URL: " + desc.url);
+    printer.println("Timestamp: " + Util.getTimeStringFromMicrosecond(properties.timestamp));
+    printIPTestResult(printer);
+
+    if (taskProgress == TaskProgress.COMPLETED) {
+      int headerLen = Integer.parseInt(values.get("headers_len"));
+      int bodyLen = Integer.parseInt(values.get("body_len"));
+      int time = Integer.parseInt(values.get("time_ms"));
+      printer.println("");
+      printer.println("Downloaded " + (headerLen + bodyLen) + " bytes in " + time + " ms");
+      printer.println("Bandwidth: " + (headerLen + bodyLen) * 8 / time + " Kbps");
+    } else if (taskProgress == TaskProgress.PAUSED) {
+      printer.println("Quic Http paused!");
+    } else {
+      printer.println("Quic Http download failed, status code " + values.get("code"));
+      printer.println("Error: " + values.get("error"));
+    }
+  }
+
+  private void getCronetHttpResult(StringBuilderPrinter printer, HashMap<String, String> values) {
+    CronetHttpDesc desc = (CronetHttpDesc) parameters;
+    printer.println("[CronetHTTP]");
+    printer.println("URL: " + desc.url);
+    printer.println("Timestamp: " + Util.getTimeStringFromMicrosecond(properties.timestamp));
+    printIPTestResult(printer);
+
+    if (taskProgress == TaskProgress.COMPLETED) {
+      int headerLen = Integer.parseInt(values.get("headers_len"));
+      int bodyLen = Integer.parseInt(values.get("body_len"));
+      int time = Integer.parseInt(values.get("time_ms"));
+      printer.println("");
+      printer.println("Downloaded " + (headerLen + bodyLen) + " bytes in " + time + " ms");
+      printer.println("Bandwidth: " + (headerLen + bodyLen) * 8 / time + " Kbps");
+    } else if (taskProgress == TaskProgress.PAUSED) {
+      printer.println("CronetHttp paused!");
+    } else {
+      printer.println("CronetHttp download failed, status code " + values.get("code"));
+      printer.println("Error: " + values.get("error"));
+    }
+  }
+
   private void getDnsResult(StringBuilderPrinter printer, HashMap<String, String> values) {
     DnsLookupDesc desc = (DnsLookupDesc) parameters;
     printer.println("[DNS Lookup]");

Mobilyzer/src/com/mobilyzer/MeasurementTask.java

@@ -8,10 +8,12 @@
 import java.util.concurrent.Callable;
 
 import com.mobilyzer.exceptions.MeasurementError;
+import com.mobilyzer.measurements.CronetHttpTask;
 import com.mobilyzer.measurements.DnsLookupTask;
 import com.mobilyzer.measurements.HttpTask;
 import com.mobilyzer.measurements.PageLoadTimeTask;
 import com.mobilyzer.measurements.PingTask;
+import com.mobilyzer.measurements.QuicHttpTask;
 import com.mobilyzer.measurements.RRCTask;
 import com.mobilyzer.measurements.SequentialTask;
 import com.mobilyzer.measurements.TCPThroughputTask;
@@ -48,6 +50,10 @@ public abstract class MeasurementTask
     measurementDescToType.put(PingTask.DESCRIPTOR, PingTask.TYPE);
     measurementTypes.put(HttpTask.TYPE, HttpTask.class);
     measurementDescToType.put(HttpTask.DESCRIPTOR, HttpTask.TYPE);
+    measurementTypes.put(CronetHttpTask.TYPE, CronetHttpTask.class);
+    measurementDescToType.put(CronetHttpTask.DESCRIPTOR, CronetHttpTask.TYPE);
+    measurementTypes.put(QuicHttpTask.TYPE, QuicHttpTask.class);
+    measurementDescToType.put(QuicHttpTask.DESCRIPTOR, QuicHttpTask.TYPE);
     measurementTypes.put(TracerouteTask.TYPE, TracerouteTask.class);
     measurementDescToType.put(TracerouteTask.DESCRIPTOR, TracerouteTask.TYPE);
     measurementTypes.put(DnsLookupTask.TYPE, DnsLookupTask.class);

Mobilyzer/src/com/mobilyzer/UserMeasurementTask.java

@@ -22,6 +22,7 @@
 
 import com.mobilyzer.MeasurementResult.TaskProgress;
 import com.mobilyzer.exceptions.MeasurementError;
+import com.mobilyzer.measurements.QuicHttpTask;
 import com.mobilyzer.util.Logger;
 import com.mobilyzer.util.PhoneUtils;
 
@@ -119,5 +120,4 @@ public MeasurementResult[] call() throws MeasurementError {
     return results;
   }
 
-
 }

Mobilyzer/src/com/mobilyzer/api/API.java

@@ -14,52 +14,56 @@
  */
 package com.mobilyzer.api;
 
-import java.security.InvalidParameterException;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.LinkedList;
-import java.util.Map;
-import java.util.Queue;
-import java.util.Set;
-
 import android.content.ComponentName;
 import android.content.Context;
 import android.content.Intent;
 import android.content.ServiceConnection;
+import android.os.Bundle;
 import android.os.IBinder;
 import android.os.Message;
 import android.os.Messenger;
 import android.os.RemoteException;
-import android.os.Bundle;
 
 import com.mobilyzer.Config;
 import com.mobilyzer.MeasurementScheduler;
 import com.mobilyzer.MeasurementScheduler.DataUsageProfile;
 import com.mobilyzer.MeasurementTask;
 import com.mobilyzer.UpdateIntent;
 import com.mobilyzer.exceptions.MeasurementError;
+import com.mobilyzer.measurements.CronetHttpTask;
+import com.mobilyzer.measurements.CronetHttpTask.CronetHttpDesc;
 import com.mobilyzer.measurements.DnsLookupTask;
+import com.mobilyzer.measurements.DnsLookupTask.DnsLookupDesc;
 import com.mobilyzer.measurements.HttpTask;
+import com.mobilyzer.measurements.HttpTask.HttpDesc;
 import com.mobilyzer.measurements.PageLoadTimeTask;
 import com.mobilyzer.measurements.PageLoadTimeTask.PageLoadTimeDesc;
 import com.mobilyzer.measurements.ParallelTask;
-import com.mobilyzer.measurements.PingTask;
-import com.mobilyzer.measurements.SequentialTask;
-import com.mobilyzer.measurements.TCPThroughputTask;
-import com.mobilyzer.measurements.TracerouteTask;
-import com.mobilyzer.measurements.UDPBurstTask;
-import com.mobilyzer.measurements.DnsLookupTask.DnsLookupDesc;
-import com.mobilyzer.measurements.HttpTask.HttpDesc;
 import com.mobilyzer.measurements.ParallelTask.ParallelDesc;
+import com.mobilyzer.measurements.PingTask;
 import com.mobilyzer.measurements.PingTask.PingDesc;
+import com.mobilyzer.measurements.QuicHttpTask;
+import com.mobilyzer.measurements.QuicHttpTask.QuicDesc;
+import com.mobilyzer.measurements.SequentialTask;
 import com.mobilyzer.measurements.SequentialTask.SequentialDesc;
+import com.mobilyzer.measurements.TCPThroughputTask;
 import com.mobilyzer.measurements.TCPThroughputTask.TCPThroughputDesc;
+import com.mobilyzer.measurements.TracerouteTask;
 import com.mobilyzer.measurements.TracerouteTask.TracerouteDesc;
+import com.mobilyzer.measurements.UDPBurstTask;
 import com.mobilyzer.measurements.UDPBurstTask.UDPBurstDesc;
 import com.mobilyzer.measurements.VideoQoETask;
 import com.mobilyzer.measurements.VideoQoETask.VideoQoEDesc;
 import com.mobilyzer.util.Logger;
 
+import java.security.InvalidParameterException;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.LinkedList;
+import java.util.Map;
+import java.util.Queue;
+import java.util.Set;
+
 /**
  * @author jackjia,Hongyi Yao (hyyao@umich.edu)
  * The user API for Mobiperf library.
@@ -68,9 +72,10 @@
  * User: register BroadcastReceiver for userResultAction and serverResultAction
  */
 public final class API {
+
   public enum TaskType {
     DNSLOOKUP, HTTP, PING, TRACEROUTE, TCPTHROUGHPUT, UDPBURST,
-    PARALLEL, SEQUENTIAL, INVALID, PLT, VIDEOQOE
+    PARALLEL, SEQUENTIAL, INVALID, PLT, VIDEOQOE, QUICHTTP, CRONETHTTP
   }
 
   /**
@@ -90,11 +95,12 @@ public enum TaskType {
 
   public final static int USER_PRIORITY = MeasurementTask.USER_PRIORITY;
   public final static int INVALID_PRIORITY = MeasurementTask.INVALID_PRIORITY;
-  
+
   private Context applicationContext;
 
   private boolean isBound = false;
   private boolean isBindingToService = false;
+
   Messenger mSchedulerMessenger = null;
 
   private String clientKey;
@@ -282,6 +288,14 @@ public MeasurementTask createTask( TaskType taskType, Date startTime
         task = new HttpTask(new HttpDesc(clientKey, startTime, endTime
           , intervalSec, count, priority, contextIntervalSec, params));
         break;
+      case QUICHTTP:
+        task = new QuicHttpTask(new QuicDesc(clientKey, startTime, endTime,
+                intervalSec, count, priority, contextIntervalSec, params));
+        break;
+      case CRONETHTTP:
+        task = new CronetHttpTask(new CronetHttpDesc(clientKey, startTime, endTime,
+                intervalSec, count, priority, contextIntervalSec, params));
+        break;
       case PING:
         task = new PingTask(new PingDesc(clientKey, startTime, endTime
           , intervalSec, count, priority, contextIntervalSec, params));
@@ -603,4 +617,5 @@ public static Set<String> getMeasurementNames() {
   public static String getTypeForMeasurementName(String name) {
     return MeasurementTask.getTypeForMeasurementName(name);
   }
+
 }