init other subproject impl lock control

+*.iml
+.gradle
+.idea
+/dist
+/gradle
+import-summary.txt
+/local.properties
+.DS_Store
+/build
+/captures
+/freeline
+freeline_core
+freeline.py
+*.hprof
+freeline_project_description.json

+# GimiCinema
+基于Mstar 平台的本地点播系统
+
+* Email:[pan.li@qnbar.com](mailto:pan.li@qnbar.com)

+// Top-level build file where you can add configuration options common to all sub-projects/modules.
+buildscript {
+    repositories {
+        mavenCentral()
+        jcenter()
+    }
+
+    dependencies {
+        classpath 'com.android.tools.build:gradle:2.1.3'
+//        classpath 'me.tatarka:gradle-retrolambda:3.2.3'
+//        classpath 'me.tatarka.retrolambda.projectlombok:lombok.ast:0.2.3.a2'
+        classpath 'com.antfortune.freeline:gradle:0.8.3'
+    }
+//    configurations.classpath.exclude group: 'com.android.tools.external.lombok'
+}
+
+//repositories {
+//    mavenCentral()
+//}
+//buildscript {
+//    repositories {
+//        jcenter()
+//    }
+//    dependencies {
+//        classpath 'com.android.tools.build:gradle:2.1.3'
+//
+//        // NOTE: Do not place your application dependencies here; they belong
+//        // in the individual module build.gradle files
+//    }
+//}
+//
+allprojects {
+    repositories {
+        jcenter()
+        mavenCentral()
+    }
+}
+
+// Define versions in a single place
+ext {
+    // Sdk and tools
+    minSdkVersion = 10
+    targetSdkVersion = 24
+    compileSdkVersion = 24
+    buildToolsVersion = '24.0.2'
+
+    // App dependencies
+    supportLibraryVersion = '24.2.0'
+    guavaVersion = '18.0'
+    junitVersion = '4.12'
+    mockitoVersion = '1.10.19'
+    powerMockito = '1.6.2'
+    hamcrestVersion = '1.3'
+    runnerVersion = '0.5'
+    rulesVersion = '0.5'
+    espressoVersion = '2.2.2'
+}
+

+/build
+debug-db.iml

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+apply plugin: 'com.android.library'
+
+android {
+    compileSdkVersion 23
+    buildToolsVersion "23.0.2"
+
+    lintOptions {
+        abortOnError false
+        checkReleaseBuilds false
+    }
+
+    defaultConfig {
+        minSdkVersion 11
+        targetSdkVersion 23
+        versionCode 1
+        versionName "1.0"
+
+        testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
+
+        resValue("string", "PORT_NUMBER", "8098")
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
+        }
+    }
+}
+
+dependencies {
+//    compile fileTree(include: ['*.jar'], dir: 'libs')
+    androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', {
+        exclude group: 'com.android.support', module: 'support-annotations'
+    })
+    testCompile 'junit:junit:4.12'
+    compile 'com.google.code.gson:gson:2.4'
+    provided files('libs/cinemaLib-1117.jar')
+}
+
+//apply from: 'debug-db-upload.gradle'

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+apply plugin: 'com.github.dcendents.android-maven'
+apply plugin: "com.jfrog.bintray"
+
+def siteUrl = 'https://github.com/amitshekhariitbhu/Android-Debug-Database'
+def gitUrl = 'https://github.com/amitshekhariitbhu/Android-Debug-Database.git'
+
+group = "com.amitshekhar.android"
+version = '0.3.0'
+
+install {
+    repositories.mavenInstaller {
+        pom.project {
+            packaging 'aar'
+
+            name 'Android Debug Database'
+            description 'Android Debug Database is a powerful library for debugging databases in Android applications'
+
+            url siteUrl
+
+            licenses {
+                license {
+                    name 'The Apache Software License, Version 2.0'
+                    url 'http://www.apache.org/licenses/LICENSE-2.0.txt'
+                }
+            }
+
+            developers {
+                developer {
+                    id 'amitshekhariitbhu'
+                    name 'Amit Shekhar'
+                    email 'amit.shekhar.iitbhu@gmail.com'
+                }
+            }
+
+            scm {
+                connection gitUrl
+                developerConnection gitUrl
+                url siteUrl
+            }
+        }
+    }
+}
+
+task sourcesJar(type: Jar) {
+    from android.sourceSets.main.java.srcDirs
+    classifier = 'sources'
+}
+
+task javadoc(type: Javadoc) {
+    source = android.sourceSets.main.java.srcDirs
+    classpath += project.files(android.getBootClasspath().join(File.pathSeparator))
+    classpath += configurations.compile
+}
+
+task javadocJar(type: Jar, dependsOn: javadoc) {
+    classifier = 'javadoc'
+    from javadoc.destinationDir
+}
+artifacts {
+    archives javadocJar
+    archives sourcesJar
+}
+
+if (project.rootProject.file("local.properties").exists()) {
+    Properties properties = new Properties()
+    properties.load(project.rootProject.file('local.properties').newDataInputStream())
+
+    bintray {
+        user = properties.getProperty("bintray.user")
+        key = properties.getProperty("bintray.apikey")
+
+        configurations = ['archives']
+        dryRun = false
+
+        pkg {
+            repo = "maven"
+            name = "debug-db"
+            websiteUrl = siteUrl
+            vcsUrl = gitUrl
+            licenses = ["Apache-2.0"]
+            publish = true
+        }
+    }
+}

+# Add project specific ProGuard rules here.
+# By default, the flags in this file are appended to flags specified
+# in /Users/amitshekhar/Library/Android/sdk/tools/proguard/proguard-android.txt
+# You can edit the include path and order by changing the proguardFiles
+# directive in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# Add any project specific keep options here:
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar;
+
+import android.content.Context;
+import android.support.test.InstrumentationRegistry;
+import android.support.test.runner.AndroidJUnit4;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import static org.junit.Assert.*;
+
+/**
+ * Instrumentation test, which will execute on an Android device.
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+@RunWith(AndroidJUnit4.class)
+public class ExampleInstrumentedTest {
+    @Test
+    public void useAppContext() throws Exception {
+        // Context of the app under test.
+        Context appContext = InstrumentationRegistry.getTargetContext();
+
+        assertEquals("com.amitshekhar.test", appContext.getPackageName());
+    }
+}

+<!--
+  ~ /*
+  ~  *    Copyright (C) 2016 Amit Shekhar
+  ~  *    Copyright (C) 2011 Android Open Source Project
+  ~  *
+  ~  *    Licensed under the Apache License, Version 2.0 (the "License");
+  ~  *    you may not use this file except in compliance with the License.
+  ~  *    You may obtain a copy of the License at
+  ~  *
+  ~  *        http://www.apache.org/licenses/LICENSE-2.0
+  ~  *
+  ~  *    Unless required by applicable law or agreed to in writing, software
+  ~  *    distributed under the License is distributed on an "AS IS" BASIS,
+  ~  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~  *    See the License for the specific language governing permissions and
+  ~  *    limitations under the License.
+  ~  */
+  -->
+
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="com.amitshekhar">
+
+    <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
+
+    <application>
+        <provider
+            android:authorities="${applicationId}.DebugDBInitProvider"
+            android:exported="false"
+            android:enabled="true"
+            android:name=".DebugDBInitProvider" />
+    </application>
+
+</manifest>

+$( document ).ready(function() {
+    getDBList();
+    $("#query").keypress(function(e){
+        if(e.which == 13) {
+            queryFunction();
+        }
+    });
+});
+
+function getData(tableName) {
+
+   $.ajax({url: "getAllDataFromTheTable?tableName="+tableName, success: function(result){
+
+           result = JSON.parse(result);
+           inflateData(result);
+
+   }});
+
+}
+
+function queryFunction() {
+
+   var query = $('#query').val();
+
+   $.ajax({url: "query?query="+escape(query), success: function(result){
+
+           result = JSON.parse(result);
+           inflateData(result);
+
+   }});
+
+}
+
+
+function resetLedStatus() {
+
+   var cmd = $('#cmd').val();
+
+   $.ajax({url: "cmd?cmd="+escape(cmd), success: function(result){
+           result = JSON.parse(result);
+           inflateData(result);
+
+   }});
+
+}
+
+
+function getDBList() {
+
+   $.ajax({url: "getDbList", success: function(result){
+
+           result = JSON.parse(result);
+           var dbList = result.rows;
+           $('#db-list').empty();
+           var isSelectionDone = false;
+           for(var count = 0; count < dbList.length; count++){
+             if(dbList[count].indexOf("journal") == -1){
+                $("#db-list").append("<a href='#' id=" +dbList[count] + " class='list-group-item' onClick='openDatabaseAndGetTableList(\""+ dbList[count] + "\");'>" +dbList[count] + "</a>");
+                if(!isSelectionDone){
+                    isSelectionDone = true;
+                      $('#db-list').find('a').trigger('click');
+                }
+             }
+           }
+
+   }});
+
+}
+
+function openDatabaseAndGetTableList(db) {
+
+    if("APP_SHARED_PREFERENCES" == db) {
+        $('#run-query').removeClass('active');
+        $('#run-query').addClass('disabled');
+    } else {
+        $('#run-query').removeClass('disabled');
+        $('#run-query').addClass('active');
+    }
+
+   $("#selected-db-info").text("Selected Database : "+db);
+
+   $.ajax({url: "getTableList?database="+db, success: function(result){
+
+           result = JSON.parse(result);
+           var tableList = result.rows;
+           $('#table-list').empty()
+           for(var count = 0; count < tableList.length; count++){
+             $("#table-list").append("<a href='#' class='list-group-item' onClick='getData(\""+ tableList[count] + "\");'>" +tableList[count] + "</a>");
+           }
+
+   }});
+
+}
+
+function inflateData(result){
+
+   if(result.isSuccessful){
+      showSuccessInfo();
+      var columnHeader = result.columns.map(function(columnName) {
+           return {"title": columnName};
+       });
+      var columnData = result.rows;
+       var tableId = "#db-data";
+        if ($.fn.DataTable.isDataTable(tableId) ) {
+          $(tableId).DataTable().destroy();
+        }
+
+       $("#db-data-div").remove();
+       $("#parent-data-div").append('<div id="db-data-div"><table cellpadding="0" cellspacing="0" border="0" class="table table-striped table-bordered display" id="db-data"></table></div>');
+
+       $(tableId).dataTable({
+           "data": columnData,
+           "columns": columnHeader,
+           'bPaginate': true,
+           'searching': true,
+           'bFilter': true,
+           'bInfo': true,
+           "bSort" : true,
+           "scrollX": true,
+           "iDisplayLength": 100
+       });
+       // hack to fix alignment issue when scrollX is enabled
+       $(".dataTables_scrollHeadInner").css({"width":"100%"});
+       $(".table ").css({"width":"100%"});
+   }else{
+      showErrorInfo();
+   }
+
+}
+
+function showSuccessInfo(){
+    $("#success-info").show();
+    $("#error-info").hide();
+}
+
+function showErrorInfo(){
+    $("#success-info").hide();
+    $("#error-info").show();
+}
+
+function hideBothInfo(){
+    $("#success-info").hide();
+    $("#error-info").hide();
+}

+.padding-fifty {
+   padding-top: 50px;
+}
+
+.padding-twenty {
+    padding-top: 20px;
+}
+
+.display-none {
+    display: none;
+}
+
+.list-group-item {
+    word-break: break-all;
+}

+<!DOCTYPE html>
+<!--
+  ~ /*
+  ~  *    Copyright (C) 2016 Amit Shekhar
+  ~  *    Copyright (C) 2011 Android Open Source Project
+  ~  *
+  ~  *    Licensed under the Apache License, Version 2.0 (the "License");
+  ~  *    you may not use this file except in compliance with the License.
+  ~  *    You may obtain a copy of the License at
+  ~  *
+  ~  *        http://www.apache.org/licenses/LICENSE-2.0
+  ~  *
+  ~  *    Unless required by applicable law or agreed to in writing, software
+  ~  *    distributed under the License is distributed on an "AS IS" BASIS,
+  ~  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~  *    See the License for the specific language governing permissions and
+  ~  *    limitations under the License.
+  ~  */
+  -->
+
+<html lang="en">
+<head>
+    <title>Android Debug Database</title>
+    <meta charset="utf-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1">
+    <link rel='shortcut icon' href='favicon.ico' type='image/x-icon'>
+    <link rel="stylesheet"
+          href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/css/bootstrap.min.css">
+    <link rel="stylesheet" href="https://cdn.datatables.net/1.10.12/css/jquery.dataTables.min.css">
+    <script src="https://ajax.googleapis.com/ajax/libs/jquery/3.1.1/jquery.min.js"></script>
+    <script src="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/js/bootstrap.min.js"></script>
+    <script src="https://cdn.datatables.net/1.10.12/js/jquery.dataTables.min.js"></script>
+
+    <link href="custom.css" rel="stylesheet">
+
+</head>
+<body>
+
+<!-- Navigation -->
+<nav class="navbar navbar-default navbar-fixed-top" role="navigation">
+    <div class="container">
+        <!-- Brand and toggle get grouped for better mobile display -->
+        <div class="navbar-header">
+            <button type="button" class="navbar-toggle" data-toggle="collapse"
+                    data-target="#bs-example-navbar-collapse-1">
+                <span class="sr-only">Toggle navigation</span>
+                <span class="icon-bar"></span>
+                <span class="icon-bar"></span>
+                <span class="icon-bar"></span>
+            </button>
+            <a class="navbar-brand" href="index.html">DebugDB</a>
+        </div>
+        <!--   Collect the nav links, forms, and other content for toggling
+          <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
+              <ul class="nav navbar-nav navbar-right">
+                  <li>
+                      <a href="https://github.com/amitshekhariitbhu/Android-Debug-Database"
+                         target="_blank">Github</a>
+                  </li>
+                  <li>
+                      <a href="https://twitter.com/amitiitbhu"
+                         target="_blank">Twitter</a>
+                  </li>
+                  <li class="dropdown">
+                      <a href="#" class="dropdown-toggle" data-toggle="dropdown">Other Projects<b
+                              class="caret"></b></a>
+                      <ul class="dropdown-menu">
+                          <li>
+                              <a href="https://github.com/amitshekhariitbhu/Fast-Android-Networking"
+                                 target="_blank">Fast Android Networking</a>
+                          </li>
+                          <li>
+                              <a href="https://github.com/amitshekhariitbhu/GlideBitmapPool"
+                                 target="_blank">Glide Bitmap Pool</a>
+                          </li>
+                          <li>
+                              <a href="https://github.com/amitshekhariitbhu/RxJava2-Android-Samples"
+                                 target="_blank">RxJava2 Android Samples</a>
+                          </li>
+                          <li>
+                              <a href="https://github.com/amitshekhariitbhu/awesome-android-complete-reference"
+                                 target="_blank">Awesome Android Complete Reference</a>
+                          </li>
+                          <li>
+                              <a href="https://github.com/amitshekhariitbhu/FlatBuffer"
+                                 target="_blank">FlatBuffers vs JSON</a>
+                          </li>
+                      </ul>
+                  </li>
+              </ul>
+          </div>
+           /.navbar-collapse -->
+    </div>
+    <!-- /.container -->
+</nav>
+
+
+<div class="container padding-fifty">
+
+    <div class="row padding-twenty">
+        <div class="col-sm-12">
+            <div class="form-group">
+                <label for="query">Query</label>
+                <input class="form-control" id="query">
+            </div>
+            <div class="form-group">
+                <label for="query">Command</label>
+                <input class="form-control" id="cmd">
+            </div>
+            <button id="selected-db-info" type="button" class="btn btn-info">Welcome</button>
+            <button id="success-info" type="button" class="btn btn-success display-none">Query Executed</button>
+            <button id="error-info" type="button" class="btn btn-danger display-none">Query Not Executed</button>
+            <button id="run-query" type="submit" onclick="queryFunction()" class="btn btn-primary pull-right disabled">
+                Run
+                Query
+            </button>
+            <button id="reset-led-status" type="submit" onclick="resetLedStatus()"
+                    class="btn btn-primary pull-right">Execute Command
+            </button>
+        </div>
+    </div>
+
+
+    <div class="row padding-twenty">
+
+        <div class="col-sm-2">
+            <div class="panel panel-info">
+                <div class="panel-heading">Databases</div>
+            </div>
+            <div id="db-list" class="list-group">
+            </div>
+        </div>
+
+        <div class="col-sm-2">
+            <div class="panel panel-info">
+                <div class="panel-heading">Tables</div>
+            </div>
+            <div id="table-list" class="list-group">
+            </div>
+        </div>
+
+        <div id="parent-data-div" class="col-sm-8">
+            <div class="panel panel-info">
+                <div class="panel-heading">Data</div>
+            </div>
+        </div>
+    </div>
+
+</div>
+
+<script src="app.js"></script>
+</body>
+</html>

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar;
+
+import android.content.Context;
+import android.util.Log;
+
+import com.amitshekhar.server.ClientServer;
+import com.amitshekhar.utils.NetworkUtils;
+
+/**
+ * Created by amitshekhar on 15/11/16.
+ */
+
+public class DebugDB {
+
+    private static final String TAG = DebugDB.class.getSimpleName();
+    private static final int DEFAULT_PORT = 8080;
+    private static ClientServer clientServer;
+    private static String addressLog = "not available";
+
+    private DebugDB() {
+        // This class in not publicly instantiable
+    }
+
+    public static void initialize(Context context) {
+        int portNumber;
+
+        try {
+            portNumber = Integer.valueOf(context.getString(R.string.PORT_NUMBER));
+        } catch (NumberFormatException ex) {
+            Log.e(TAG, "PORT_NUMBER should be integer", ex);
+            portNumber = DEFAULT_PORT;
+            Log.i(TAG, "Using Default port : " + DEFAULT_PORT);
+        }
+
+        clientServer = new ClientServer(context, portNumber);
+        clientServer.start();
+        addressLog = NetworkUtils.getAddressLog(context, portNumber);
+        Log.d(TAG, addressLog);
+    }
+
+    public static String getAddressLog() {
+        Log.d(TAG, addressLog);
+        return addressLog;
+    }
+
+    public static void shutDown() {
+        if (clientServer != null) {
+            clientServer.stop();
+            clientServer = null;
+        }
+    }
+
+}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar;
+
+import android.content.ContentProvider;
+import android.content.ContentValues;
+import android.content.Context;
+import android.content.pm.ProviderInfo;
+import android.database.Cursor;
+import android.net.Uri;
+
+/**
+ * Created by amitshekhar on 16/11/16.
+ */
+
+public class DebugDBInitProvider extends ContentProvider {
+
+
+    public DebugDBInitProvider() {
+    }
+
+    @Override
+    public boolean onCreate() {
+        DebugDB.initialize(getContext());
+        return true;
+    }
+
+    @Override
+    public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) {
+        return null;
+    }
+
+    @Override
+    public String getType(Uri uri) {
+        return null;
+    }
+
+    @Override
+    public Uri insert(Uri uri, ContentValues values) {
+        return null;
+    }
+
+    @Override
+    public int delete(Uri uri, String selection, String[] selectionArgs) {
+        return 0;
+    }
+
+    @Override
+    public int update(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
+        return 0;
+    }
+
+    @Override
+    public void attachInfo(Context context, ProviderInfo providerInfo) {
+        if (providerInfo == null) {
+            throw new NullPointerException("DebugDBInitProvider ProviderInfo cannot be null.");
+        }
+        // So if the authorities equal the library internal ones, the developer forgot to set his applicationId
+        if ("com.amitshekhar.DebugDBInitProvider".equals(providerInfo.authority)) {
+            throw new IllegalStateException("Incorrect provider authority in manifest. Most likely due to a "
+                    + "missing applicationId variable in application\'s build.gradle.");
+        }
+        super.attachInfo(context, providerInfo);
+    }
+
+}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar.model;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Created by amitshekhar on 15/11/16.
+ */
+
+public class Response {
+
+    public List rows = new ArrayList();
+    public List<String> columns = new ArrayList<>();
+    public boolean isSuccessful;
+    public String error;
+
+    public Response() {
+
+    }
+
+}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar.server;
+
+/**
+ * Created by amitshekhar on 15/11/16.
+ */
+
+
+import android.content.Context;
+import android.content.SharedPreferences;
+import android.content.res.AssetManager;
+import android.database.Cursor;
+import android.database.sqlite.SQLiteDatabase;
+import android.text.TextUtils;
+import android.util.Log;
+
+import com.amitshekhar.model.Response;
+import com.amitshekhar.utils.Constants;
+import com.amitshekhar.utils.PrefUtils;
+import com.gimi.common.cinema.utils.ShellUtils;
+import com.gimi.common.cinema.utils.SystemUtils;
+import com.google.gson.Gson;
+
+import java.io.BufferedReader;
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.PrintStream;
+import java.io.UnsupportedEncodingException;
+import java.net.InetSocketAddress;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.net.SocketException;
+import java.net.URLDecoder;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+public class ClientServer implements Runnable {
+
+    private static final String TAG = "SimpleWebServer";
+
+    /**
+     * The port number we listen to
+     */
+    private final int mPort;
+
+    /**
+     * {@link AssetManager} for loading files to serve.
+     */
+    private final AssetManager mAssets;
+
+    /**
+     * True if the server is running.
+     */
+    private boolean mIsRunning;
+
+    /**
+     * The {@link ServerSocket} that we listen to.
+     */
+    private ServerSocket mServerSocket;
+
+
+    private Context mContext;
+    private SQLiteDatabase mDatabase;
+    private File mDatabaseDir;
+    private Gson mGson;
+    private boolean isDbOpenned;
+
+    /**
+     * WebServer constructor.
+     */
+    public ClientServer(Context context, int port) {
+        mPort = port;
+        mAssets = context.getResources().getAssets();
+        mContext = context;
+        mGson = new Gson();
+        getDatabaseDir();
+    }
+
+    /**
+     * This method starts the web server listening to the specified port.
+     */
+    public void start() {
+        mIsRunning = true;
+        new Thread(this).start();
+    }
+
+    /**
+     * This method stops the web server
+     */
+    public void stop() {
+        try {
+            mIsRunning = false;
+            if (null != mServerSocket) {
+                mServerSocket.close();
+                mServerSocket = null;
+            }
+        } catch (IOException e) {
+            Log.e(TAG, "Error closing the server socket.", e);
+        }
+    }
+
+    @Override
+    public void run() {
+        try {
+            mServerSocket = //new ServerSocket(mPort);
+                    new ServerSocket();
+            mServerSocket.setReuseAddress(true);
+            mServerSocket.bind(new InetSocketAddress(mPort));
+            while (mIsRunning) {
+                Socket socket = mServerSocket.accept();
+                handle(socket);
+                socket.close();
+            }
+        } catch (IOException e) {
+            Log.e(TAG, "Web server error.", e);
+        }
+    }
+
+    /**
+     * Respond to a request from a client.
+     *
+     * @param socket The client socket.
+     * @throws IOException
+     */
+    private void handle(Socket socket) throws IOException {
+        BufferedReader reader = null;
+        PrintStream output = null;
+        try {
+            String route = null;
+
+            // Read HTTP headers and parse out the route.
+            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
+            String line;
+            while (!TextUtils.isEmpty(line = reader.readLine())) {
+                if (line.startsWith("GET /")) {
+                    int start = line.indexOf('/') + 1;
+                    int end = line.indexOf(' ', start);
+                    route = line.substring(start, end);
+                    break;
+                }
+            }
+
+            // Output stream that we send the response to
+            output = new PrintStream(socket.getOutputStream());
+
+            if (route == null || route.isEmpty()) {
+                route = "index.html";
+            }
+
+            byte[] bytes;
+
+            if (route.startsWith("getAllDataFromTheTable")) {
+                String query = null;
+
+                if (route.contains("?tableName=")) {
+                    query = route.substring(route.indexOf("=") + 1, route.length());
+                }
+
+                Response response;
+
+                if (isDbOpenned) {
+                    String sql = "SELECT * FROM " + query;
+                    response = query(sql);
+                } else {
+                    response = getAllPrefData(query);
+                }
+
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+
+            } else if (route.startsWith("query")) {
+                String query = null;
+                if (route.contains("?query=")) {
+                    query = route.substring(route.indexOf("=") + 1, route.length());
+                }
+
+                Response response;
+
+                try {
+                    query = java.net.URLDecoder.decode(query, "UTF-8");
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+
+                String first = query.split(" ")[0].toLowerCase();
+
+                if (first.equals("select")) {
+                    response = query(query);
+                } else {
+                    response = exec(query);
+                }
+
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+
+            } else if (route.startsWith("getDbList")) {
+                Response response = getDBList();
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+            } else if (route.startsWith("cmd")) {
+                String cmd = null;
+                if (route.contains("?cmd=")) {
+                    cmd = route.substring(route.indexOf("=") + 1, route.length());
+                }
+                Response response = getExecCmd(cmd);
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+            } else if (route.startsWith("getTableList")) {
+                String database = null;
+                if (route.contains("?database=")) {
+                    database = route.substring(route.indexOf("=") + 1, route.length());
+                }
+
+                Response response;
+
+                if (Constants.APP_SHARED_PREFERENCES.equals(database)) {
+                    response = getAllPrefTableName();
+                    closeDatabase();
+                } else {
+                    openDatabase(database);
+                    response = getAllTableName();
+                }
+
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+            } else if (route.startsWith("test_on_line")) {
+                String database = null;
+                if (route.contains("?database=")) {
+                    database = route.substring(route.indexOf("=") + 1, route.length());
+                }
+
+                Response response;
+
+                if (Constants.APP_SHARED_PREFERENCES.equals(database)) {
+                    response = getAllPrefTableName();
+                    closeDatabase();
+                } else {
+                    openDatabase(database);
+                    response = getAllTableName();
+                }
+
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+            } else if (route.startsWith("test_offline")) {
+                String database = null;
+                if (route.contains("?database=")) {
+                    database = route.substring(route.indexOf("=") + 1, route.length());
+                }
+
+                Response response;
+
+                if (Constants.APP_SHARED_PREFERENCES.equals(database)) {
+                    response = getAllPrefTableName();
+                    closeDatabase();
+                } else {
+                    openDatabase(database);
+                    response = getAllTableName();
+                }
+
+                String data = mGson.toJson(response);
+                bytes = data.getBytes();
+            } else {
+                bytes = loadContent(route);
+            }
+
+
+            if (null == bytes) {
+                writeServerError(output);
+                return;
+            }
+
+            // Send out the content.
+            output.println("HTTP/1.0 200 OK");
+            output.println("Content-Type: " + detectMimeType(route));
+            output.println("Content-Length: " + bytes.length);
+            output.println();
+            output.write(bytes);
+            output.flush();
+        } finally {
+            if (null != output) {
+                output.close();
+            }
+            if (null != reader) {
+                reader.close();
+            }
+        }
+    }
+
+    /**
+     * Writes a server error response (HTTP/1.0 500) to the given output stream.
+     *
+     * @param output The output stream.
+     */
+    private void writeServerError(PrintStream output) {
+        output.println("HTTP/1.0 500 Internal Server Error");
+        output.flush();
+    }
+
+    /**
+     * Loads all the content of {@code fileName}.
+     *
+     * @param fileName The name of the file.
+     * @return The content of the file.
+     * @throws IOException
+     */
+    private byte[] loadContent(String fileName) throws IOException {
+        InputStream input = null;
+        try {
+            ByteArrayOutputStream output = new ByteArrayOutputStream();
+            input = mAssets.open(fileName);
+            byte[] buffer = new byte[1024];
+            int size;
+            while (-1 != (size = input.read(buffer))) {
+                output.write(buffer, 0, size);
+            }
+            output.flush();
+            return output.toByteArray();
+        } catch (FileNotFoundException e) {
+            return null;
+        } finally {
+            if (null != input) {
+                input.close();
+            }
+        }
+    }
+
+    /**
+     * Detects the MIME type from the {@code fileName}.
+     *
+     * @param fileName The name of the file.
+     * @return A MIME type.
+     */
+    private String detectMimeType(String fileName) {
+        if (TextUtils.isEmpty(fileName)) {
+            return null;
+        } else if (fileName.endsWith(".html")) {
+            return "text/html";
+        } else if (fileName.endsWith(".js")) {
+            return "application/javascript";
+        } else if (fileName.endsWith(".css")) {
+            return "text/css";
+        } else {
+            return "application/octet-stream";
+        }
+    }
+
+    private void getDatabaseDir() {
+        File root = mContext.getFilesDir().getParentFile();
+        File dbRoot = new File(root, "/databases");
+        mDatabaseDir = dbRoot;
+    }
+
+    private void openDatabase(String database) {
+        mDatabase = mContext.openOrCreateDatabase(database, 0, null);
+        isDbOpenned = true;
+    }
+
+    private void closeDatabase() {
+        mDatabase = null;
+        isDbOpenned = false;
+    }
+
+    private Response exec(String sql) {
+        Response response = new Response();
+        try {
+            mDatabase.execSQL(sql);
+        } catch (Exception e) {
+            e.printStackTrace();
+            response.isSuccessful = false;
+            response.error = e.getMessage();
+            return response;
+        }
+        response.isSuccessful = true;
+        return response;
+    }
+
+    private Response query(String sql) {
+        Cursor cursor;
+        try {
+            cursor = mDatabase.rawQuery(sql, null);
+        } catch (Exception e) {
+            e.printStackTrace();
+            Response msg = new Response();
+            msg.isSuccessful = false;
+            msg.error = e.getMessage();
+            return msg;
+        }
+
+        if (cursor != null) {
+            cursor.moveToFirst();
+            Response response = new Response();
+            response.isSuccessful = true;
+            List<String> columns = new ArrayList<>();
+            for (int i = 0; i < cursor.getColumnCount(); i++) {
+                String name = cursor.getColumnName(i);
+                columns.add(name);
+            }
+            response.columns = columns;
+
+            if (cursor.getCount() > 0) {
+                do {
+                    List row = new ArrayList();
+                    for (int i = 0; i < cursor.getColumnCount(); i++) {
+                        switch (cursor.getType(i)) {
+                            case Cursor.FIELD_TYPE_BLOB:
+                                row.add(cursor.getBlob(i));
+                                break;
+                            case Cursor.FIELD_TYPE_FLOAT:
+                                row.add(Float.valueOf(cursor.getFloat(i)));
+                                break;
+                            case Cursor.FIELD_TYPE_INTEGER:
+                                row.add(Integer.valueOf(cursor.getInt(i)));
+                                break;
+                            case Cursor.FIELD_TYPE_STRING:
+                                row.add(cursor.getString(i));
+                                break;
+                            default:
+                                row.add("");
+                        }
+                    }
+                    response.rows.add(row);
+
+                } while (cursor.moveToNext());
+            }
+
+            return response;
+        } else {
+            Response response = new Response();
+            response.isSuccessful = false;
+            response.error = "Cursor is null";
+            return response;
+        }
+    }
+
+    public Response getDBList() {
+        Response response = new Response();
+        if (mDatabaseDir != null) {
+            for (String name : mDatabaseDir.list()) {
+                response.rows.add(name);
+            }
+        }
+        response.rows.add(Constants.APP_SHARED_PREFERENCES);
+        response.isSuccessful = true;
+        return response;
+    }
+
+    public Response getAllTableName() {
+        Response response = new Response();
+        Cursor c = mDatabase.rawQuery("SELECT name FROM sqlite_master WHERE type='table'", null);
+
+        if (c.moveToFirst()) {
+            while (!c.isAfterLast()) {
+                response.rows.add(c.getString(0));
+                c.moveToNext();
+            }
+        }
+        response.isSuccessful = true;
+        return response;
+    }
+
+    public Response getAllPrefTableName() {
+        Response response = new Response();
+        List<String> prefTags = PrefUtils.getSharedPreferenceTags(mContext);
+
+        for (String tag : prefTags) {
+            response.rows.add(tag);
+        }
+        response.isSuccessful = true;
+        return response;
+    }
+
+    public Response getExecCmd(String cmd) {
+        SystemUtils systemUtils = new SystemUtils();
+        String data = null;
+        try {
+            //decode 3A%->: 20%->' ' ,etc.
+            cmd = URLDecoder.decode(cmd, "utf-8");
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        if (Constants.APP_SHARED_CLOSE_LED.equals(cmd)) {
+            systemUtils.setLedStatus(false);
+            data = "close led success";
+        } else if (Constants.APP_SHARED_OPEN_LED.equals(cmd)) {
+            systemUtils.openLed(mContext);
+            data = "open led success";
+        } else if (Constants.APP_SHARED_LOGCAT.equals(cmd)) {
+            new Thread() {
+                @Override
+                public void run() {
+                    super.run();
+                    ShellUtils.execCommand("logcat -c;logcat -v time > /sdcard/debug.log&", false);
+                }
+            }.start();
+
+            data = "save log to sdcard";
+        } else if (Constants.APP_SHARED_SHOW_LOGCAT.equals(cmd)) {
+            new Thread() {
+                @Override
+                public void run() {
+                    super.run();
+                    ShellUtils.execCommand("ps | grep logcat | busybox awk '{print $2}'|busybox xargs kill -9", false);
+                }
+            }.start();
+//            data = "save log to sdcard";
+        } else if (Constants.APP_SHARED_TEST_ONLINE.equals(cmd)) {
+            saveTest(false);
+            data = "set test on line please reboot";
+        } else if (Constants.APP_SHARED_TEST_OFFLINE.equals(cmd)) {
+            saveTest(true);
+            data = "set test off line please reboot";
+        } else if (Constants.APP_START_ADB.equals(cmd)) {
+            ShellUtils.execCommand(new String[]{"su", "start adbd"}, false);
+            data = "open adb success,please connect by pc";
+        } else if (!TextUtils.isEmpty(cmd) && cmd.startsWith(Constants.APP_SHARED_SET_STRING)) {
+            String[] split = cmd.split(":");
+            if (split.length >= 3 && !TextUtils.isEmpty(split[1]) && !TextUtils.isEmpty(split[2])) {
+                saveString(split[1], split[2]);
+                data = "set " + split[1] + ":" + split[2] + " perhaps success,please check!";
+            } else {
+                data = "set string value error:" + cmd;
+            }
+        } else {
+            data = "unknown command";
+        }
+
+        Response response = new Response();
+        response.isSuccessful = true;
+        response.columns.add("Command");
+        response.columns.add("Result");
+        if (!TextUtils.isEmpty(data)) {
+            List row = new ArrayList();
+            row.add(cmd);
+            row.add(data);
+            response.rows.add(row);
+        } else if (Constants.APP_SHARED_SHOW_LOGCAT.equals(cmd)) {
+            ArrayList<String> read = read("/sdcard/debug.log");
+            boolean hasAdd = false;
+            for (String s : read) {
+                ArrayList row = new ArrayList();
+                if (!hasAdd) {
+                    row.add(cmd);
+                } else {
+                    row.add("");
+                }
+                row.add(s);
+                response.rows.add(row);
+                hasAdd = true;
+            }
+        } else {
+            List row = new ArrayList();
+            row.add(cmd);
+            row.add(data);
+            response.rows.add(row);
+        }
+        return response;
+    }
+
+    private void saveTest(boolean bool) {
+        saveBoolean("test", bool);
+    }
+
+
+    private void saveBoolean(String key, boolean bool) {
+        SharedPreferences sharedPreferences = mContext.getSharedPreferences("gimi-cinema-pref", Context.MODE_PRIVATE);
+        SharedPreferences.Editor edit = sharedPreferences.edit();
+        edit.putBoolean(key, bool);
+        edit.apply();
+    }
+
+    private void saveString(String key, String value) {
+        SharedPreferences sharedPreferences = mContext.getSharedPreferences("gimi-cinema-pref", Context.MODE_PRIVATE);
+        SharedPreferences.Editor edit = sharedPreferences.edit();
+        edit.putString(key, value);
+        edit.apply();
+    }
+
+    /**
+     * 以行为单位读取文件，常用于读面向行的格式化文件
+     */
+    private ArrayList<String> read(String fileName) {
+        ArrayList<String> result = new ArrayList<String>();
+        File file = new File(fileName);
+        if (!file.exists()) {
+            result.add("文件不存在");
+            return result;
+        }
+        BufferedReader reader = null;
+        try {
+            reader = new BufferedReader(new FileReader(file));
+            String tempString = null;
+            while ((tempString = reader.readLine()) != null) {
+                result.add(tempString.trim());
+            }
+            reader.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+            result.add(e.getMessage());
+        } finally {
+            if (reader != null) {
+                try {
+                    reader.close();
+                } catch (IOException e1) {
+                    e1.printStackTrace();
+                    result.add(e1.getMessage());
+                }
+            }
+        }
+
+        return result;
+    }
+
+    public Response getAllPrefData(String tag) {
+        Response response = new Response();
+        response.isSuccessful = true;
+        response.columns.add("Key");
+        response.columns.add("Value");
+        SharedPreferences preferences = mContext.getSharedPreferences(tag, Context.MODE_PRIVATE);
+        Map<String, ?> allEntries = preferences.getAll();
+        for (Map.Entry<String, ?> entry : allEntries.entrySet()) {
+            List row = new ArrayList();
+            row.add(entry.getKey());
+            row.add(entry.getValue().toString());
+            response.rows.add(row);
+        }
+        return response;
+    }
+
+}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar.utils;
+
+/**
+ * Created by amitshekhar on 16/11/16.
+ */
+
+public final class Constants {
+
+    private Constants() {
+        // This class in not publicly instantiable
+    }
+
+    public static final String APP_SHARED_PREFERENCES = "APP_SHARED_PREFERENCES";
+    public static final String APP_SHARED_CLOSE_LED = "close_led";
+    public static final String APP_SHARED_OPEN_LED = "open_led";
+    public static final String APP_SHARED_LOGCAT = "logcat";
+    public static final String APP_SHARED_SHOW_LOGCAT = "show_logcat";
+    public static final String APP_SHARED_TEST_ONLINE = "test_online";
+    public static final String APP_SHARED_TEST_OFFLINE = "test_offline";
+    public static final String APP_SHARED_SET_STRING = "wugian_set_string";
+    public static final String APP_START_ADB = "wugian_open_adb";
+}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar.utils;
+
+import android.content.Context;
+import android.net.wifi.WifiManager;
+
+import java.net.InetAddress;
+import java.net.NetworkInterface;
+import java.net.SocketException;
+import java.util.Enumeration;
+
+/**
+ * Created by amitshekhar on 15/11/16.
+ */
+
+public final class NetworkUtils {
+
+    private NetworkUtils() {
+        // This class in not publicly instantiable
+    }
+
+    public static String getAddressLog(Context context, int port) {
+//        WifiManager wifiManager = (WifiManager) context.getSystemService(Context.WIFI_SERVICE);
+//        int ipAddress = wifiManager.getConnectionInfo().getIpAddress();
+//        final String formatedIpAddress = String.format("%d.%d.%d.%d", (ipAddress & 0xff), (ipAddress >> 8 & 0xff), (ipAddress >> 16 & 0xff), (ipAddress >> 24 & 0xff));
+        try {
+            return "Open http://" + getIp() + ":" + port + " in your browser";
+        } catch (SocketException e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+    public static String getIp() throws SocketException {
+        String ipAddress = "";
+        Enumeration<NetworkInterface> netInterfaces = null;
+        netInterfaces = NetworkInterface.getNetworkInterfaces();
+        if (netInterfaces == null) {
+            return ipAddress;
+        }
+        while (netInterfaces.hasMoreElements()) {
+            NetworkInterface intf = netInterfaces.nextElement();
+            if (intf.getName().toLowerCase().equals("eth0") || intf.getName().toLowerCase().equals("wlan0")) {
+                for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements(); ) {
+                    InetAddress inetAddress = enumIpAddr.nextElement();
+                    if (!inetAddress.isLoopbackAddress()) {
+                        String curIpAddress = inetAddress.getHostAddress();
+                        if (!curIpAddress.contains("::")) { // 过滤ipV6的地址
+                            ipAddress = curIpAddress;
+                            if (intf.getName().toLowerCase().equals("eth0")) {
+                                return ipAddress;
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        return ipAddress;
+    }
+
+}

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar.utils;
+
+import android.content.Context;
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * Created by amitshekhar on 16/11/16.
+ */
+
+public final class PrefUtils {
+
+    private static final String PREFS_SUFFIX = ".xml";
+
+    private PrefUtils() {
+        // This class in not publicly instantiable
+    }
+
+    public static List<String> getSharedPreferenceTags(Context context) {
+
+        ArrayList<String> tags = new ArrayList<>();
+
+        String rootPath = context.getApplicationInfo().dataDir + "/shared_prefs";
+        File root = new File(rootPath);
+        if (root.exists()) {
+            for (File file : root.listFiles()) {
+                String fileName = file.getName();
+                if (fileName.endsWith(PREFS_SUFFIX)) {
+                    tags.add(fileName.substring(0, fileName.length() - PREFS_SUFFIX.length()));
+                }
+            }
+        }
+
+        Collections.sort(tags);
+
+        return tags;
+    }
+}

+<!--
+  ~ /*
+  ~  *    Copyright (C) 2016 Amit Shekhar
+  ~  *    Copyright (C) 2011 Android Open Source Project
+  ~  *
+  ~  *    Licensed under the Apache License, Version 2.0 (the "License");
+  ~  *    you may not use this file except in compliance with the License.
+  ~  *    You may obtain a copy of the License at
+  ~  *
+  ~  *        http://www.apache.org/licenses/LICENSE-2.0
+  ~  *
+  ~  *    Unless required by applicable law or agreed to in writing, software
+  ~  *    distributed under the License is distributed on an "AS IS" BASIS,
+  ~  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~  *    See the License for the specific language governing permissions and
+  ~  *    limitations under the License.
+  ~  */
+  -->
+
+<resources>
+    <string name="app_name">Debug-DB</string>
+</resources>

+/*
+ *
+ *  *    Copyright (C) 2016 Amit Shekhar
+ *  *    Copyright (C) 2011 Android Open Source Project
+ *  *
+ *  *    Licensed under the Apache License, Version 2.0 (the "License");
+ *  *    you may not use this file except in compliance with the License.
+ *  *    You may obtain a copy of the License at
+ *  *
+ *  *        http://www.apache.org/licenses/LICENSE-2.0
+ *  *
+ *  *    Unless required by applicable law or agreed to in writing, software
+ *  *    distributed under the License is distributed on an "AS IS" BASIS,
+ *  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  *    See the License for the specific language governing permissions and
+ *  *    limitations under the License.
+ *
+ */
+
+package com.amitshekhar;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+public class ExampleUnitTest {
+    @Test
+    public void addition_isCorrect() throws Exception {
+        assertEquals(4, 2 + 2);
+    }
+}

@@ -12,6 +12,9 @@
     <uses-permission android:name="android.permission.RECEIVE_BOOT_COMPLETED"/>
     <uses-permission android:name="android.permission.RECEIVE_BOOT_COMPLETED"/>
     <uses-permission android:name="android.permission.RESTART_PACKAGES"/>
     <uses-permission android:name="android.permission.RESTART_PACKAGES"/>
     <uses-permission android:name="android.permission.KILL_BACKGROUND_PROCESSES"/>
     <uses-permission android:name="android.permission.KILL_BACKGROUND_PROCESSES"/>
+    <uses-permission android:name="android.permission.BLUETOOTH"/>
+    <uses-permission android:name="android.permission.BLUETOOTH_ADMIN"/>
+
     <uses-permission
     <uses-permission
             android:name="android.permission.FORCE_STOP_PACKAGES"
             android:name="android.permission.FORCE_STOP_PACKAGES"
             tools:ignore="ProtectedPermissions"/>
             tools:ignore="ProtectedPermissions"/>

+## Project-wide Gradle settings.
+#
+# For more details on how to configure your build environment visit
+# http://www.gradle.org/docs/current/userguide/build_environment.html
+#
+# Specifies the JVM arguments used for the daemon process.
+# The setting is particularly useful for tweaking memory settings.
+# Default value: -Xmx1024m -XX:MaxPermSize=256m
+# org.gradle.jvmargs=-Xmx2048m -XX:MaxPermSize=512m -XX:+HeapDumpOnOutOfMemoryError -Dfile.encoding=UTF-8
+#
+# When configured, Gradle will run in incubating parallel mode.
+# This option should only be used with decoupled projects. More details, visit
+# http://www.gradle.org/docs/current/userguide/multi_project_builds.html#sec:decoupled_projects
+# org.gradle.parallel=true
+#Fri Oct 28 11:43:32 CST 2016
+ANDROID_MIN_SDK_VERSION=18
+ANDROID_BUILD_COMPILE_SDK_VERSION=18
+ANDROID_TARGET_SDK_VERSION=18
+ANDROID_BUILD_TOOLS_VERSION=24.0.2
+android.useDeprecatedNdk=true
+

+#!/usr/bin/env bash
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn ( ) {
+    echo "$*"
+}
+
+die ( ) {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+esac
+
+# For Cygwin, ensure paths are in UNIX format before anything is touched.
+if $cygwin ; then
+    [ -n "$JAVA_HOME" ] && JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
+fi
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >&-
+APP_HOME="`pwd -P`"
+cd "$SAVED" >&-
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Split up the JVM_OPTS And GRADLE_OPTS values into an array, following the shell quoting and substitution rules
+function splitJvmOpts() {
+    JVM_OPTS=("$@")
+}
+eval splitJvmOpts $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS
+JVM_OPTS[${#JVM_OPTS[*]}]="-Dorg.gradle.appname=$APP_BASE_NAME"
+
+exec "$JAVACMD" "${JVM_OPTS[@]}" -classpath "$CLASSPATH" org.gradle.wrapper.GradleWrapperMain "$@"

+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windowz variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+if "%@eval[2+2]" == "4" goto 4NT_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+goto execute
+
+:4NT_args
+@rem Get arguments from the 4NT Shell from JP Software
+set CMD_LINE_ARGS=%$
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

+include ':transitionhelper', ':uil', ':volley', ':pinying', ':debug-db'
+include ':gimiCinema'

+/build
+transitionhelper.iml

+apply plugin: 'com.android.library'
+//apply plugin: 'com.github.dcendents.android-maven'
+//apply plugin: 'com.jfrog.bintray'
+// This is the library version used when deploying the artifact
+version = "1.0.4"
+android {
+    compileSdkVersion 24
+    buildToolsVersion "24.0.2"
+    resourcePrefix "transitionhelper"
+    defaultConfig {
+        minSdkVersion 15
+        targetSdkVersion 24
+        versionCode 1
+        versionName version
+    }
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
+        }
+    }
+    lintOptions {
+        abortOnError false
+    }
+
+
+}
+
+
+dependencies {
+    compile fileTree(dir: 'libs', include: ['*.jar'])
+}
+//
+//def siteUrl = 'https://github.com/immortalz'
+//def gitUrl = 'https://github.com/ImmortalZ/TransitionHelper'
+//group = "me.immortalz"                                        // Maven Group ID for the artifact，一般填你唯一的包名
+//install {
+//    repositories.mavenInstaller {
+//        // This generates POM.xml with proper parameters
+//        pom {
+//            project {
+//                packaging 'aar'
+//                // Add your description here
+//                name 'Android TransitionHelper'
+//                url siteUrl
+//                // Set your license
+//                licenses {
+//                    license {
+//                        name 'The Apache Software License, Version 2.0'
+//                        url 'http://www.apache.org/licenses/LICENSE-2.0.txt'
+//                    }
+//                }
+//                developers {
+//                    developer {
+//                        id 'immortalz'
+//                        name 'immortalz'
+//                        email 'immortalz.cn@gmail.com'
+//                    }
+//                }
+//                scm {
+//                    connection gitUrl
+//                    developerConnection gitUrl
+//                    url siteUrl
+//                }
+//            }
+//        }
+//    }
+//}
+//task sourcesJar(type: Jar) {
+//    from android.sourceSets.main.java.srcDirs
+//    classifier = 'sources'
+//}
+//task javadoc(type: Javadoc) {
+//    source = android.sourceSets.main.java.srcDirs
+//    classpath += project.files(android.getBootClasspath().join(File.pathSeparator))
+//}
+//task javadocJar(type: Jar, dependsOn: javadoc) {
+//    classifier = 'javadoc'
+//    from javadoc.destinationDir
+//}
+//artifacts {
+//    archives javadocJar
+//    archives sourcesJar
+//}
+//Properties properties = new Properties()
+//properties.load(project.rootProject.file('local.properties').newDataInputStream())
+//bintray {
+//    user = properties.getProperty("bintray.user")
+//    key = properties.getProperty("bintray.apikey")
+//    configurations = ['archives']
+//    pkg {
+//        userOrg = 'immortalzme'
+//        repo = "maven"
+//        name = "transitionhelper"
+//        websiteUrl = siteUrl
+//        vcsUrl = gitUrl
+//        licenses = ["Apache-2.0"]
+//        publish = true
+//    }
+//}

+# Add project specific ProGuard rules here.
+# By default, the flags in this file are appended to flags specified
+# in H:\android_sdk/tools/proguard/proguard-android.txt
+# You can edit the include path and order by changing the proguardFiles
+# directive in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# Add any project specific keep options here:
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}

+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="immortalz.me.library">
+
+    <application
+        android:allowBackup="true"
+        android:supportsRtl="true">
+    </application>
+
+</manifest>

+package immortalz.me.library;
+
+import android.animation.Animator;
+import android.animation.AnimatorListenerAdapter;
+import android.app.Activity;
+import android.content.Intent;
+import android.graphics.Bitmap;
+import android.graphics.drawable.BitmapDrawable;
+import android.os.Build;
+import android.text.TextUtils;
+import android.view.View;
+import android.view.ViewGroup;
+import android.view.Window;
+import android.view.WindowManager;
+import android.widget.ImageView;
+import android.widget.RelativeLayout;
+import immortalz.me.library.bean.InfoBean;
+import immortalz.me.library.method.InflateShowMethod;
+import immortalz.me.library.method.NoneShowMethod;
+import immortalz.me.library.method.ShowMethod;
+import immortalz.me.library.view.CircleAnimView;
+
+import java.util.HashMap;
+
+/**
+ * Created by Mr_immortalZ on 2016/10/18.
+ * email : mr_immortalz@qq.com
+ */
+
+public class TransitionsHelper {
+
+
+    private static TransitionsHelper INSTANCE;
+
+
+    private static HashMap<String, InfoBean> staticMap = new HashMap<>();
+
+    private static ShowMethod showMethod = new NoneShowMethod();
+
+
+    private TransitionsHelper() {
+    }
+
+    public static TransitionsHelper getInstance() {
+        if (INSTANCE == null) {
+            synchronized (TransitionsHelper.class) {
+                if (INSTANCE == null) {
+                    INSTANCE = new TransitionsHelper();
+                }
+            }
+        }
+        return INSTANCE;
+    }
+
+    public static void startActivity(final Activity activity, final Class<?> cls, final View view) {
+        startActivity(activity, cls, view, 0);
+    }
+
+    public static void startActivity(final Activity activity, final Class<?> cls, final View view, final Integer imgId) {
+        final Intent intent = new Intent(activity, cls);
+        final InfoBean bean = new InfoBean();
+        view.post(new Runnable() {
+            @Override
+            public void run() {
+                //get statusBar height
+                view.getWindowVisibleDisplayFrame(bean.originRect);
+                bean.statusBarHeight = bean.originRect.top;
+                //get Origin View's rect
+                view.getGlobalVisibleRect(bean.originRect);
+                bean.originWidth = bean.originRect.right - bean.originRect.left;
+                bean.originHeight = bean.originRect.bottom - bean.originRect.top;
+                if (imgId == 0) {
+                    bean.bitmap = createBitmap(view, bean.originWidth, bean.originHeight);
+                } else {
+                    bean.setImgId(imgId);
+                }
+                intent.addFlags(Intent.FLAG_ACTIVITY_NO_ANIMATION);
+                staticMap.put(cls.getName(), bean);
+                activity.startActivity(intent);
+                activity.overridePendingTransition(0, 0);
+            }
+        });
+    }
+
+    public static void startActivityForResult(final Activity activity, final Intent intent,
+                                              final Class<?> cls, final View view, final int requestCode) {
+        final InfoBean bean = new InfoBean();
+        view.post(new Runnable() {
+            @Override
+            public void run() {
+                //get statusBar height
+                view.getWindowVisibleDisplayFrame(bean.originRect);
+                bean.statusBarHeight = bean.originRect.top;
+                //get Origin View's rect
+                view.getGlobalVisibleRect(bean.originRect);
+                bean.originWidth = bean.originRect.right - bean.originRect.left;
+                bean.originHeight = bean.originRect.bottom - bean.originRect.top;
+                bean.bitmap = createBitmap(view, bean.originWidth, bean.originHeight);
+                intent.addFlags(Intent.FLAG_ACTIVITY_NO_ANIMATION);
+                staticMap.put(cls.getName(), bean);
+                activity.startActivityForResult(intent, requestCode);
+                activity.overridePendingTransition(0, 0);
+            }
+        });
+    }
+
+    public static void startActivity(final Activity activity, final Class<?> cls,
+                                     final View view, final String imgUrl) {
+        final Intent intent = new Intent(activity, cls);
+        final InfoBean bean = new InfoBean();
+        view.post(new Runnable() {
+            @Override
+            public void run() {
+                //get statusBar height
+                view.getWindowVisibleDisplayFrame(bean.originRect);
+                bean.statusBarHeight = bean.originRect.top;
+                //get Origin View's rect
+                view.getGlobalVisibleRect(bean.originRect);
+                bean.originWidth = bean.originRect.right - bean.originRect.left;
+                bean.originHeight = bean.originRect.bottom - bean.originRect.top;
+                if (TextUtils.isEmpty(imgUrl)) {
+                    bean.bitmap = createBitmap(view, bean.originWidth, bean.originHeight);
+                } else {
+                    bean.setImgUrl(imgUrl);
+                }
+                intent.addFlags(Intent.FLAG_ACTIVITY_NO_ANIMATION);
+                staticMap.put(cls.getName(), bean);
+                activity.startActivity(intent);
+                activity.overridePendingTransition(0, 0);
+            }
+        });
+    }
+
+    public static void startActivityForResult(final Activity context, final Intent intent,
+                                              final Class<?> cls, final int requestCode,
+                                              final View view, final String imgUrl) {
+        final InfoBean bean = new InfoBean();
+        view.post(new Runnable() {
+            @Override
+            public void run() {
+                //get statusBar height
+                view.getWindowVisibleDisplayFrame(bean.originRect);
+                bean.statusBarHeight = bean.originRect.top;
+                //get Origin View's rect
+                view.getGlobalVisibleRect(bean.originRect);
+                bean.originWidth = bean.originRect.right - bean.originRect.left;
+                bean.originHeight = bean.originRect.bottom - bean.originRect.top;
+                if (TextUtils.isEmpty(imgUrl)) {
+                    bean.bitmap = createBitmap(view, bean.originWidth, bean.originHeight);
+                } else {
+                    bean.setImgUrl(imgUrl);
+                }
+                intent.addFlags(Intent.FLAG_ACTIVITY_NO_ANIMATION);
+                staticMap.put(cls.getName(), bean);
+                context.startActivityForResult(intent, requestCode);
+                context.overridePendingTransition(0, 0);
+            }
+        });
+    }
+
+
+    public void show(final Activity activity, final ImageView targetView) {
+        final InfoBean bean = staticMap.get(activity.getClass().getName());
+        if (bean == null) {
+            return;
+        }
+        final ViewGroup parent = (ViewGroup) activity.findViewById(Window.ID_ANDROID_CONTENT);
+        //if TranslucentStatus is true , statusBarHeight = 0
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
+            if (activity.getWindow().getStatusBarColor() == 0 ||
+                    (WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS & activity.getWindow().getAttributes().flags)
+                            == WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS) {
+                bean.statusBarHeight = 0;
+            }
+        } else if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT) {
+            if ((WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS & activity.getWindow().getAttributes().flags)
+                    == WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS) {
+                bean.statusBarHeight = 0;
+            }
+        }
+        parent.post(new Runnable() {
+            @Override
+            public void run() {
+                bean.windowWidth = parent.getWidth();
+                bean.windowHeight = parent.getHeight();
+                bean.titleHeight = parent.getTop();
+                final CircleAnimView circleAnimView;
+                if (showMethod instanceof InflateShowMethod) {
+                    circleAnimView = new CircleAnimView(activity,
+                            createBitmap(((InflateShowMethod) showMethod).inflateView, bean.windowWidth, bean.windowHeight));
+                } else {
+                    circleAnimView = new CircleAnimView(activity);
+                }
+                final RelativeLayout.LayoutParams params = new RelativeLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT,
+                        ViewGroup.LayoutParams.MATCH_PARENT);
+                parent.addView(circleAnimView, params);
+
+
+                if (targetView != null) {
+                    //get Target View's position
+                    targetView.getGlobalVisibleRect(bean.targetRect);
+                    bean.targetWidth = bean.targetRect.right - bean.targetRect.left;
+                    bean.targetHeight = bean.targetRect.bottom - bean.targetRect.top;
+                    bean.translationX = bean.originRect.left + bean.originWidth / 2 - bean.targetRect.left - bean.targetWidth / 2;
+                    bean.translationY = bean.originRect.top + bean.originHeight / 2 - bean.targetRect.top - bean.targetHeight / 2;
+                } else {
+                    bean.targetRect.left = bean.originRect.left;
+                    bean.targetRect.top = bean.originRect.top;
+                    bean.targetWidth = bean.originWidth;
+                    bean.targetHeight = bean.originHeight;
+                    bean.translationX = 0;
+                    bean.translationY = 0;
+                }
+                //create a temp ImageView to replace origin view
+                final ImageView ivTemp = new ImageView(activity);
+                if (bean.bitmap != null) {
+                    if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.JELLY_BEAN) {
+                        ivTemp.setImageDrawable(new BitmapDrawable(bean.bitmap));
+                    } else {
+                        ivTemp.setBackgroundDrawable(new BitmapDrawable(bean.bitmap));
+                    }
+                }
+                RelativeLayout.LayoutParams ivTempParams = new RelativeLayout.LayoutParams(bean.targetWidth,
+                        bean.targetHeight);
+
+                ivTempParams.setMargins(bean.originRect.left - (bean.targetWidth / 2 - bean.originWidth / 2)
+                        , bean.originRect.top - (parent.getTop() + bean.statusBarHeight) - (bean.targetHeight / 2 - bean.originHeight / 2), 0, 0);
+                circleAnimView.addView(ivTemp, ivTempParams);
+                ivTemp.setScaleX((float) bean.originHeight / bean.targetHeight);
+                ivTemp.setScaleY((float) bean.originWidth / bean.targetWidth);
+                showMethod.translate(bean, circleAnimView, ivTemp);
+                showMethod.loadCopyView(bean, ivTemp);
+                showMethod.set.addListener(new AnimatorListenerAdapter() {
+                    @Override
+                    public void onAnimationEnd(Animator animation) {
+                        circleAnimView.startCircleAnim(bean);
+                        showMethod.loadTargetView(bean, targetView);
+                    }
+                });
+
+            }
+        });
+    }
+
+
+    public void showSelf(final Activity activity, final ImageView targetView, final Class<?> cls) {
+        final InfoBean beanAdd = new InfoBean();
+        activity.getCurrentFocus().post(new Runnable() {
+            @Override
+            public void run() {
+                //get statusBar height
+                activity.getCurrentFocus().getWindowVisibleDisplayFrame(beanAdd.originRect);
+                beanAdd.statusBarHeight = beanAdd.originRect.top;
+                //get Origin View's rect
+                activity.getCurrentFocus().getGlobalVisibleRect(beanAdd.originRect);
+                beanAdd.originWidth = beanAdd.originRect.right - beanAdd.originRect.left;
+                beanAdd.originHeight = beanAdd.originRect.bottom - beanAdd.originRect.top;
+                beanAdd.bitmap = createBitmap(activity.getCurrentFocus(), beanAdd.originWidth, beanAdd.originHeight);
+                staticMap.put(cls.getName(), beanAdd);
+            }
+        });
+
+
+        final InfoBean bean = staticMap.get(activity.getClass().getName());
+        if (bean == null) {
+            return;
+        }
+        final ViewGroup parent = (ViewGroup) activity.findViewById(Window.ID_ANDROID_CONTENT);
+        //if TranslucentStatus is true , statusBarHeight = 0
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
+            if (activity.getWindow().getStatusBarColor() == 0 ||
+                    (WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS & activity.getWindow().getAttributes().flags)
+                            == WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS) {
+                bean.statusBarHeight = 0;
+            }
+        } else if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT) {
+            if ((WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS & activity.getWindow().getAttributes().flags)
+                    == WindowManager.LayoutParams.FLAG_TRANSLUCENT_STATUS) {
+                bean.statusBarHeight = 0;
+            }
+        }
+        parent.post(new Runnable() {
+            @Override
+            public void run() {
+                bean.windowWidth = parent.getWidth();
+                bean.windowHeight = parent.getHeight();
+                bean.titleHeight = parent.getTop();
+                final CircleAnimView circleAnimView;
+                if (showMethod instanceof InflateShowMethod) {
+                    circleAnimView = new CircleAnimView(activity,
+                            createBitmap(((InflateShowMethod) showMethod).inflateView, bean.windowWidth, bean.windowHeight));
+                } else {
+                    circleAnimView = new CircleAnimView(activity);
+                }
+                final RelativeLayout.LayoutParams params = new RelativeLayout.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT,
+                        ViewGroup.LayoutParams.MATCH_PARENT);
+                parent.addView(circleAnimView, params);
+
+
+                if (targetView != null) {
+                    //get Target View's position
+                    targetView.getGlobalVisibleRect(bean.targetRect);
+                    bean.targetWidth = bean.targetRect.right - bean.targetRect.left;
+                    bean.targetHeight = bean.targetRect.bottom - bean.targetRect.top;
+                    bean.translationX = bean.originRect.left + bean.originWidth / 2 - bean.targetRect.left - bean.targetWidth / 2;
+                    bean.translationY = bean.originRect.top + bean.originHeight / 2 - bean.targetRect.top - bean.targetHeight / 2;
+                } else {
+                    bean.targetRect.left = bean.originRect.left;
+                    bean.targetRect.top = bean.originRect.top;
+                    bean.targetWidth = bean.originWidth;
+                    bean.targetHeight = bean.originHeight;
+                    bean.translationX = 0;
+                    bean.translationY = 0;
+                }
+                //create a temp ImageView to replace origin view
+                final ImageView ivTemp = new ImageView(activity);
+                if (bean.bitmap != null) {
+                    if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.JELLY_BEAN) {
+                        ivTemp.setImageDrawable(new BitmapDrawable(bean.bitmap));
+                    } else {
+                        ivTemp.setBackgroundDrawable(new BitmapDrawable(bean.bitmap));
+                    }
+                }
+                RelativeLayout.LayoutParams ivTempParams = new RelativeLayout.LayoutParams(bean.targetWidth,
+                        bean.targetHeight);
+
+                ivTempParams.setMargins(bean.originRect.left - (bean.targetWidth / 2 - bean.originWidth / 2)
+                        , bean.originRect.top - (parent.getTop() + bean.statusBarHeight) - (bean.targetHeight / 2 - bean.originHeight / 2), 0, 0);
+                circleAnimView.addView(ivTemp, ivTempParams);
+                ivTemp.setScaleX((float) bean.originHeight / bean.targetHeight);
+                ivTemp.setScaleY((float) bean.originWidth / bean.targetWidth);
+                showMethod.translate(bean, circleAnimView, ivTemp);
+                showMethod.loadCopyView(bean, ivTemp);
+                showMethod.set.addListener(new AnimatorListenerAdapter() {
+                    @Override
+                    public void onAnimationEnd(Animator animation) {
+                        circleAnimView.startCircleAnim(bean);
+                        showMethod.loadTargetView(bean, targetView);
+                    }
+                });
+
+            }
+        });
+    }
+
+
+    public TransitionsHelper setShowMethod(ShowMethod showMethod) {
+        TransitionsHelper.showMethod = showMethod;
+        return this;
+    }
+
+    public static void unBind(Activity activity) {
+        if (staticMap.get(activity.getClass().getName()) != null) {
+            InfoBean bean = staticMap.get(activity.getClass().getName());
+            if (bean.bitmap != null) {
+                bean.bitmap = null;
+            }
+            staticMap.remove(activity.getClass().getName());
+        }
+    }
+
+    private static Bitmap createBitmap(View view, int width, int height) {
+        view.setDrawingCacheEnabled(true);
+        view.measure(View.MeasureSpec.makeMeasureSpec(width, View.MeasureSpec.EXACTLY),
+                View.MeasureSpec.makeMeasureSpec(height, View.MeasureSpec.EXACTLY));
+        view.buildDrawingCache();
+        return view.getDrawingCache();
+    }
+
+}

+package immortalz.me.library.bean;
+
+import android.graphics.Bitmap;
+import android.graphics.Rect;
+
+/**
+ * Created by Mr_immortalZ on 2016/10/18.
+ * email : mr_immortalz@qq.com
+ */
+
+public class InfoBean {
+    public int statusBarHeight;
+    public int titleHeight;
+    //image's url or resource id
+    private String imgUrl;
+    private int imgId;
+    public Bitmap bitmap;
+
+    public int translationY;
+    public int translationX;
+    //origin view
+    public Rect originRect = new Rect();
+    public int originWidth;
+    public int originHeight;
+    //target view
+    public Rect targetRect = new Rect();
+    public int targetWidth;
+    public int targetHeight;
+    //Content Window's size
+    public int windowWidth;
+    public int windowHeight;
+
+
+    public String getImgUrl() {
+        return imgUrl;
+    }
+
+    public void setImgUrl(String imgUrl) {
+        this.imgUrl = imgUrl;
+    }
+
+    public int getImgId() {
+        return imgId;
+    }
+
+    public void setImgId(int imgId) {
+        this.imgId = imgId;
+    }
+}

+package immortalz.me.library.method;
+
+import android.animation.ArgbEvaluator;
+import android.animation.ObjectAnimator;
+import android.view.View;
+import android.view.animation.AccelerateInterpolator;
+
+import immortalz.me.library.R;
+import immortalz.me.library.bean.InfoBean;
+import immortalz.me.library.view.RenderView;
+
+
+/**
+ * Created by Mr_immortalZ on 2016/10/24.
+ * email : mr_immortalz@qq.com
+ */
+
+public abstract class ColorShowMethod extends ShowMethod {
+
+    protected int startColor;
+    public int endColor;
+
+    public ColorShowMethod(int startColor, int endColor) {
+        this.startColor = startColor;
+        this.endColor = endColor;
+    }
+
+    @Override
+    public void translate(InfoBean bean, RenderView parent, View child) {
+        if (startColor != 0) {
+            startColor = parent.getResources().getColor(startColor);
+        } else {
+            startColor = parent.getResources().getColor(R.color.showmethod_start_color);
+        }
+
+        if (endColor != 0) {
+            endColor = parent.getResources().getColor(endColor);
+        } else {
+            endColor = parent.getResources().getColor(R.color.showmethod_end_color);
+        }
+        parent.setPaintColor(endColor);
+        ObjectAnimator colorAnimator = ObjectAnimator.ofInt(parent, "backgroundColor", startColor, endColor);
+        colorAnimator.setEvaluator(new ArgbEvaluator());
+        set.playTogether(
+                ObjectAnimator.ofFloat(child, "translationX", 0, -bean.translationX),
+                ObjectAnimator.ofFloat(child, "translationY", 0, -bean.translationY),
+                ObjectAnimator.ofFloat(child, "scaleX", 1),
+                ObjectAnimator.ofFloat(child, "scaleY", 1),
+                colorAnimator
+        );
+        set.setInterpolator(new AccelerateInterpolator());
+        set.setDuration(duration).start();
+    }
+
+
+}

+package immortalz.me.library.method;
+
+import android.animation.ObjectAnimator;
+import android.app.Activity;
+import android.view.LayoutInflater;
+import android.view.View;
+import android.view.animation.AccelerateInterpolator;
+
+import immortalz.me.library.bean.InfoBean;
+import immortalz.me.library.view.RenderView;
+
+
+/**
+ * Created by Mr_immortalZ on 2016/10/24.
+ * email : mr_immortalz@qq.com
+ */
+
+public abstract class InflateShowMethod extends ShowMethod {
+
+    public View inflateView;
+
+    public InflateShowMethod(Activity activity, int layoutId) {
+        this.inflateView = LayoutInflater.from(activity).inflate(layoutId, null);
+    }
+
+    @Override
+    public void translate(InfoBean bean, RenderView parent, View child) {
+        set.playTogether(
+                ObjectAnimator.ofFloat(child, "translationX", 0, -bean.translationX),
+                ObjectAnimator.ofFloat(child, "translationY", 0, -bean.translationY),
+                ObjectAnimator.ofFloat(child, "scaleX", 1),
+                ObjectAnimator.ofFloat(child, "scaleY", 1)
+        );
+        set.setInterpolator(new AccelerateInterpolator());
+        set.setDuration(duration).start();
+    }
+
+}

+package immortalz.me.library.method;
+
+import android.animation.AnimatorSet;
+import android.animation.ArgbEvaluator;
+import android.animation.ObjectAnimator;
+import android.view.View;
+import android.view.animation.AccelerateInterpolator;
+import android.widget.ImageView;
+
+import immortalz.me.library.R;
+import immortalz.me.library.bean.InfoBean;
+import immortalz.me.library.view.RenderView;
+
+
+/**
+ * Created by Mr_immortalZ on 2016/10/24.
+ * email : mr_immortalz@qq.com
+ */
+
+public  class NoneShowMethod extends ShowMethod {
+
+    protected int startColor;
+    protected int endColor;
+
+    @Override
+    public void translate(InfoBean bean, RenderView parent, View child) {
+        startColor = parent.getResources().getColor(R.color.showmethod_start_color);
+        endColor = parent.getResources().getColor(R.color.showmethod_end_color);
+        ObjectAnimator colorAnimator = ObjectAnimator.ofInt(parent, "backgroundColor", startColor, endColor);
+        colorAnimator.setEvaluator(new ArgbEvaluator());
+        set.setInterpolator(new AccelerateInterpolator());
+        set.setDuration(duration).start();
+    }
+
+    @Override
+    public void loadCopyView(InfoBean bean, ImageView copyView) {
+        AnimatorSet set = new AnimatorSet();
+        set.playTogether(
+                ObjectAnimator.ofFloat(copyView,"rotation",0,90),
+                ObjectAnimator.ofFloat(copyView, "scaleX", 1, 0),
+                ObjectAnimator.ofFloat(copyView, "scaleY", 1, 0)
+        );
+        set.setInterpolator(new AccelerateInterpolator());
+        set.setDuration(duration / 4 * 5).start();
+    }
+
+    @Override
+    public void loadTargetView(InfoBean bean, ImageView targetView) {
+
+    }
+
+
+}

+package immortalz.me.library.method;
+
+import android.animation.AnimatorSet;
+import android.view.View;
+import android.widget.ImageView;
+
+import immortalz.me.library.bean.InfoBean;
+import immortalz.me.library.view.RenderView;
+
+
+/**
+ * Created by Mr_immortalZ on 2016/10/24.
+ * email : mr_immortalz@qq.com
+ */
+
+public abstract class ShowMethod {
+
+    public AnimatorSet set = new AnimatorSet();
+
+
+    protected int duration = 500;
+
+    public abstract void translate(InfoBean bean, RenderView parent, View child);
+
+    /**
+     * load copyView which just a temp view.
+     * the copyView is show when it's translating.
+     */
+    public abstract void loadCopyView(InfoBean bean,ImageView copyView);
+
+    /**
+     * load targetView
+     */
+    public void loadTargetView(InfoBean bean, ImageView targetView){
+
+    }
+}

+package immortalz.me.library.view;
+
+import android.content.Context;
+import android.graphics.Bitmap;
+import android.graphics.Canvas;
+import android.graphics.Paint;
+import android.graphics.PorterDuff;
+import android.graphics.PorterDuffXfermode;
+import android.graphics.RectF;
+import android.graphics.Xfermode;
+import android.util.AttributeSet;
+
+import immortalz.me.library.R;
+import immortalz.me.library.bean.InfoBean;
+
+
+/**
+ * Created by Mr_immortalZ on 2016/10/13.
+ * email : mr_immortalz@qq.com
+ */
+
+public class CircleAnimView extends RenderView{
+
+    private Canvas mCanvas;
+    private Bitmap originalBitmap; // 画布bitmap
+    private Bitmap drawBitmap;
+    private Xfermode xfermode;
+    //画布宽度
+    private int canvaswWidth = 1080;
+    //画布高度
+    private int canvasHeight = 1920;
+    //画圆
+    private int cX;
+    private int cY;
+    private int radius;
+    private int maxRadius;
+    private int increaseSpeed = 5;
+    boolean startCircleAnim = false;
+
+    public CircleAnimView(Context context) {
+        super(context);
+        init(context);
+    }
+
+    public CircleAnimView(Context context, Bitmap bitmap) {
+        super(context);
+        drawBitmap = bitmap;
+        init(context);
+    }
+
+    public CircleAnimView(Context context, AttributeSet attrs) {
+        super(context, attrs);
+        init(context);
+    }
+
+    public CircleAnimView(Context context, AttributeSet attrs, int defStyleAttr) {
+        super(context, attrs, defStyleAttr);
+        init(context);
+    }
+
+    private void init(Context context) {
+        mPaint = new Paint();
+        mPaint.setStyle(Paint.Style.FILL);
+        mPaint.setAntiAlias(true);
+        mPaint.setColor(getResources().getColor(R.color.showmethod_end_color));
+
+        xfermode = new PorterDuffXfermode(PorterDuff.Mode.DST_OUT);
+
+        setWillNotDraw(false);
+    }
+
+    @Override
+    public void startCircleAnim(InfoBean bean) {
+        originalBitmap = Bitmap.createBitmap(bean.windowWidth, bean.windowHeight, Bitmap.Config.ARGB_4444);
+        canvaswWidth = bean.windowWidth;
+        canvasHeight = bean.windowHeight;
+        mCanvas = new Canvas(originalBitmap);
+        startCircleAnim = true;
+        cX = bean.targetWidth / 2 + bean.targetRect.left;
+        cY = bean.targetHeight / 2 + bean.targetRect.top - bean.statusBarHeight - bean.titleHeight;
+        radius = (int) Math.hypot(bean.targetWidth / 2, bean.targetHeight / 2) / 4;
+        maxRadius = (int) Math.hypot(canvaswWidth, canvasHeight);
+        setBackgroundColor(getResources().getColor(android.R.color.transparent));
+        invalidate();
+    }
+
+    @Override
+    protected void onDraw(Canvas canvas) {
+        if (startCircleAnim) {
+            zoomDraw(canvas);
+        } else if (drawBitmap != null) {
+            canvas.drawBitmap(drawBitmap, 0, 0, null);
+        }
+    }
+
+    private void zoomDraw(Canvas canvas) {
+        if (radius < maxRadius) {
+            if (drawBitmap != null) {
+                mCanvas.drawBitmap(drawBitmap, null, new RectF(0, 0, canvaswWidth, canvasHeight), null);
+            } else {
+                mCanvas.drawRect(0, 0, canvaswWidth, canvasHeight, mPaint);
+            }
+            mPaint.setXfermode(xfermode);
+            mCanvas.drawCircle(cX, cY, radius, mPaint);
+            radius += increaseSpeed;
+            increaseSpeed += 6;
+            mPaint.setXfermode(null);
+            canvas.drawBitmap(originalBitmap, 0, 0, null);
+            invalidate();
+        } else {
+            startCircleAnim = false;
+            setVisibility(GONE);
+            //recycle
+            originalBitmap = null;
+            drawBitmap = null;
+        }
+    }
+
+}

+package immortalz.me.library.view;
+
+import android.content.Context;
+import android.graphics.Paint;
+import android.util.AttributeSet;
+import android.widget.RelativeLayout;
+
+import immortalz.me.library.bean.InfoBean;
+
+/**
+ * Created by Mr_immortalZ on 2016/10/29.
+ * email : mr_immortalz@qq.com
+ */
+
+public abstract class RenderView extends RelativeLayout {
+    protected int paintColor;
+    protected Paint mPaint;
+
+    public RenderView(Context context) {
+        super(context);
+    }
+
+    public RenderView(Context context, AttributeSet attrs) {
+        super(context, attrs);
+    }
+
+    public RenderView(Context context, AttributeSet attrs, int defStyleAttr) {
+        super(context, attrs, defStyleAttr);
+    }
+
+    public abstract void startCircleAnim(InfoBean bean);
+
+    public void setPaintColor(int paintColor) {
+        this.paintColor = paintColor;
+        mPaint.setColor(paintColor);
+    }
+}

+<?xml version="1.0" encoding="utf-8"?>
+<set xmlns:android="http://schemas.android.com/apk/res/android">
+    <alpha
+        android:duration="3000"
+        android:fromAlpha="0"
+        android:toAlpha="1" />
+
+</set>

+<?xml version="1.0" encoding="utf-8"?>
+<set xmlns:android="http://schemas.android.com/apk/res/android">
+    <alpha
+        android:duration="3000"
+        android:fromAlpha="1"
+        android:toAlpha="0" />
+</set>

+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <color name="showmethod_start_color">#FFFFFF</color>
+    <color name="showmethod_end_color">#C8C8C8</color>
+    <color name="colorPrimaryDark">#303F9F</color>
+</resources>

+<resources>
+</resources>

+/build
+volley.iml

+/*
+ *  Copyright (c)  2016.  wugian
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *  http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ *
+ */
+
+apply plugin: 'com.android.library'
+
+android {
+    compileSdkVersion 18
+    buildToolsVersion "25.0.0"
+
+    defaultConfig {
+        minSdkVersion 18
+        targetSdkVersion 25
+        versionCode 1
+        versionName "1.0"
+
+        testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
+
+    }
+
+    lintOptions {
+        abortOnError false
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
+        }
+    }
+}
+
+dependencies {
+    compile fileTree(include: ['*.jar'], dir: 'libs')
+    provided 'com.google.code.gson:gson:2.4'
+}

+# Add project specific ProGuard rules here.
+# By default, the flags in this file are appended to flags specified
+# in D:\develope-file\android-sdk/tools/proguard/proguard-android.txt
+# You can edit the include path and order by changing the proguardFiles
+# directive in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# Add any project specific keep options here:
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}

+<!--
+  ~  Copyright (c)  2016.  wugian
+  ~  Licensed under the Apache License, Version 2.0 (the "License");
+  ~  you may not use this file except in compliance with the License.
+  ~  You may obtain a copy of the License at
+  ~
+  ~  http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~  Unless required by applicable law or agreed to in writing, software
+  ~  distributed under the License is distributed on an "AS IS" BASIS,
+  ~  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~  See the License for the specific language governing permissions and
+  ~  limitations under the License.
+  ~
+  -->
+
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+          package="com.android.volley">
+
+    <application android:allowBackup="true"
+                 android:supportsRtl="true"
+    >
+
+    </application>
+
+</manifest>

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import android.content.Intent;
+
+/**
+ * Error indicating that there was an authentication failure when performing a Request.
+ */
+@SuppressWarnings("serial")
+public class AuthFailureError extends VolleyError {
+    /** An intent that can be used to resolve this exception. (Brings up the password dialog.) */
+    private Intent mResolutionIntent;
+
+    public AuthFailureError() { }
+
+    public AuthFailureError(Intent intent) {
+        mResolutionIntent = intent;
+    }
+
+    public AuthFailureError(NetworkResponse response) {
+        super(response);
+    }
+
+    public AuthFailureError(String message) {
+        super(message);
+    }
+
+    public AuthFailureError(String message, Exception reason) {
+        super(message, reason);
+    }
+
+    public Intent getResolutionIntent() {
+        return mResolutionIntent;
+    }
+
+    @Override
+    public String getMessage() {
+        if (mResolutionIntent != null) {
+            return "User needs to (re)enter credentials.";
+        }
+        return super.getMessage();
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ * An interface for a cache keyed by a String with a byte array as data.
+ */
+public interface Cache {
+    /**
+     * Retrieves an entry from the cache.
+     * @param key Cache key
+     * @return An {@link Entry} or null in the event of a cache miss
+     */
+    public Entry get(String key);
+
+    /**
+     * Adds or replaces an entry to the cache.
+     * @param key Cache key
+     * @param entry Data to store and metadata for cache coherency, TTL, etc.
+     */
+    public void put(String key, Entry entry);
+
+    /**
+     * Performs any potentially long-running actions needed to initialize the cache;
+     * will be called from a worker thread.
+     */
+    public void initialize();
+
+    /**
+     * Invalidates an entry in the cache.
+     * @param key Cache key
+     * @param fullExpire True to fully expire the entry, false to soft expire
+     */
+    public void invalidate(String key, boolean fullExpire);
+
+    /**
+     * Removes an entry from the cache.
+     * @param key Cache key
+     */
+    public void remove(String key);
+
+    /**
+     * Empties the cache.
+     */
+    public void clear();
+
+    /**
+     * Data and metadata for an entry returned by the cache.
+     */
+    public static class Entry {
+        /** The data returned from cache. */
+        public byte[] data;
+
+        /** ETag for cache coherency. */
+        public String etag;
+
+        /** Date of this response as reported by the server. */
+        public long serverDate;
+
+        /** TTL for this record. */
+        public long ttl;
+
+        /** Soft TTL for this record. */
+        public long softTtl;
+
+        /** Immutable response headers as received from server; must be non-null. */
+        public Map<String, String> responseHeaders = Collections.emptyMap();
+
+        /** True if the entry is expired. */
+        public boolean isExpired() {
+            return this.ttl < System.currentTimeMillis();
+        }
+
+        /** True if a refresh is needed from the original data source. */
+        public boolean refreshNeeded() {
+            return this.softTtl < System.currentTimeMillis();
+        }
+    }
+
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import android.os.Process;
+
+import java.util.concurrent.BlockingQueue;
+
+/**
+ * Provides a thread for performing cache triage on a queue of requests.
+ *
+ * Requests added to the specified cache queue are resolved from cache.
+ * Any deliverable response is posted back to the caller via a
+ * {@link ResponseDelivery}.  Cache misses and responses that require
+ * refresh are enqueued on the specified network queue for processing
+ * by a {@link NetworkDispatcher}.
+ */
+@SuppressWarnings("rawtypes")
+public class CacheDispatcher extends Thread {
+
+    private static final boolean DEBUG = VolleyLog.DEBUG;
+
+    /** The queue of requests coming in for triage. */
+    private final BlockingQueue<Request> mCacheQueue;
+
+    /** The queue of requests going out to the network. */
+    private final BlockingQueue<Request> mNetworkQueue;
+
+    /** The cache to read from. */
+    private final Cache mCache;
+
+    /** For posting responses. */
+    private final ResponseDelivery mDelivery;
+
+    /** Used for telling us to die. */
+    private volatile boolean mQuit = false;
+
+    /**
+     * Creates a new cache triage dispatcher thread.  You must call {@link #start()}
+     * in order to begin processing.
+     *
+     * @param cacheQueue Queue of incoming requests for triage
+     * @param networkQueue Queue to post requests that require network to
+     * @param cache Cache interface to use for resolution
+     * @param delivery Delivery interface to use for posting responses
+     */
+    public CacheDispatcher(
+            BlockingQueue<Request> cacheQueue, BlockingQueue<Request> networkQueue,
+            Cache cache, ResponseDelivery delivery) {
+        mCacheQueue = cacheQueue;
+        mNetworkQueue = networkQueue;
+        mCache = cache;
+        mDelivery = delivery;
+    }
+
+    /**
+     * Forces this dispatcher to quit immediately.  If any requests are still in
+     * the queue, they are not guaranteed to be processed.
+     */
+    public void quit() {
+        mQuit = true;
+        interrupt();
+    }
+
+    @Override
+    public void run() {
+        if (DEBUG) VolleyLog.v("start new dispatcher");
+        Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
+
+        // Make a blocking call to initialize the cache.
+        mCache.initialize();
+
+        while (true) {
+            try {
+                // Get a request from the cache triage queue, blocking until
+                // at least one is available.
+                final Request request = mCacheQueue.take();
+                request.addMarker("cache-queue-take");
+
+                // If the request has been canceled, don't bother dispatching it.
+                if (request.isCanceled()) {
+                    request.finish("cache-discard-canceled");
+                    continue;
+                }
+
+                // Attempt to retrieve this item from cache.
+                Cache.Entry entry = mCache.get(request.getCacheKey());
+                if (entry == null) {
+                    request.addMarker("cache-miss");
+                    // Cache miss; send off to the network dispatcher.
+                    mNetworkQueue.put(request);
+                    continue;
+                }
+
+                // If it is completely expired, just send it to the network.
+                if (entry.isExpired()) {
+                    request.addMarker("cache-hit-expired");
+                    request.setCacheEntry(entry);
+                    mNetworkQueue.put(request);
+                    continue;
+                }
+
+                // We have a cache hit; parse its data for delivery back to the request.
+                request.addMarker("cache-hit");
+                Response<?> response = request.parseNetworkResponse(
+                        new NetworkResponse(entry.data, entry.responseHeaders));
+                request.addMarker("cache-hit-parsed");
+
+                if (!entry.refreshNeeded()) {
+                    // Completely unexpired cache hit. Just deliver the response.
+                    mDelivery.postResponse(request, response);
+                } else {
+                    // Soft-expired cache hit. We can deliver the cached response,
+                    // but we need to also send the request to the network for
+                    // refreshing.
+                    request.addMarker("cache-hit-refresh-needed");
+                    request.setCacheEntry(entry);
+
+                    // Mark the response as intermediate.
+                    response.intermediate = true;
+
+                    // Post the intermediate response back to the user and have
+                    // the delivery then forward the request along to the network.
+                    mDelivery.postResponse(request, response, new Runnable() {
+                        @Override
+                        public void run() {
+                            try {
+                                mNetworkQueue.put(request);
+                            } catch (InterruptedException e) {
+                                // Not much we can do about this.
+                            }
+                        }
+                    });
+                }
+
+            } catch (InterruptedException e) {
+                // We may have been interrupted because it was time to quit.
+                if (mQuit) {
+                    return;
+                }
+                continue;
+            }
+        }
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+/**
+ * Default retry policy for requests.
+ */
+public class DefaultRetryPolicy implements RetryPolicy {
+    /** The current timeout in milliseconds. */
+    private int mCurrentTimeoutMs;
+
+    /** The current retry count. */
+    private int mCurrentRetryCount;
+
+    /** The maximum number of attempts. */
+    private final int mMaxNumRetries;
+
+    /** The backoff multiplier for for the policy. */
+    private final float mBackoffMultiplier;
+
+    /** The default socket timeout in milliseconds */
+    public static final int DEFAULT_TIMEOUT_MS = 2500;
+
+    /** The default number of retries */
+    public static final int DEFAULT_MAX_RETRIES = 1;
+
+    /** The default backoff multiplier */
+    public static final float DEFAULT_BACKOFF_MULT = 1f;
+
+    /**
+     * Constructs a new retry policy using the default timeouts.
+     */
+    public DefaultRetryPolicy() {
+        this(DEFAULT_TIMEOUT_MS, DEFAULT_MAX_RETRIES, DEFAULT_BACKOFF_MULT);
+    }
+
+    /**
+     * Constructs a new retry policy.
+     * @param initialTimeoutMs The initial timeout for the policy.
+     * @param maxNumRetries The maximum number of retries.
+     * @param backoffMultiplier Backoff multiplier for the policy.
+     */
+    public DefaultRetryPolicy(int initialTimeoutMs, int maxNumRetries, float backoffMultiplier) {
+        mCurrentTimeoutMs = initialTimeoutMs;
+        mMaxNumRetries = maxNumRetries;
+        mBackoffMultiplier = backoffMultiplier;
+    }
+
+    /**
+     * Returns the current timeout.
+     */
+    @Override
+    public int getCurrentTimeout() {
+        return mCurrentTimeoutMs;
+    }
+
+    /**
+     * Returns the current retry count.
+     */
+    @Override
+    public int getCurrentRetryCount() {
+        return mCurrentRetryCount;
+    }
+
+    /**
+     * Prepares for the next retry by applying a backoff to the timeout.
+     * @param error The error code of the last attempt.
+     */
+    @Override
+    public void retry(VolleyError error) throws VolleyError {
+        mCurrentRetryCount++;
+        mCurrentTimeoutMs += (mCurrentTimeoutMs * mBackoffMultiplier);
+        if (!hasAttemptRemaining()) {
+            throw error;
+        }
+    }
+
+    /**
+     * Returns true if this policy has attempts remaining, false otherwise.
+     */
+    protected boolean hasAttemptRemaining() {
+        return mCurrentRetryCount <= mMaxNumRetries;
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import android.os.Handler;
+
+import java.util.concurrent.Executor;
+
+/**
+ * Delivers responses and errors.
+ */
+public class ExecutorDelivery implements ResponseDelivery {
+    /** Used for posting responses, typically to the main thread. */
+    private final Executor mResponsePoster;
+
+    /**
+     * Creates a new response delivery interface.
+     * @param handler {@link Handler} to post responses on
+     */
+    public ExecutorDelivery(final Handler handler) {
+        // Make an Executor that just wraps the handler.
+        mResponsePoster = new Executor() {
+            @Override
+            public void execute(Runnable command) {
+                handler.post(command);
+            }
+        };
+    }
+
+    /**
+     * Creates a new response delivery interface, mockable version
+     * for testing.
+     * @param executor For running delivery tasks
+     */
+    public ExecutorDelivery(Executor executor) {
+        mResponsePoster = executor;
+    }
+
+    @Override
+    public void postResponse(Request<?> request, Response<?> response) {
+        postResponse(request, response, null);
+    }
+
+    @Override
+    public void postResponse(Request<?> request, Response<?> response, Runnable runnable) {
+        request.markDelivered();
+        request.addMarker("post-response");
+        mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, runnable));
+    }
+
+    @Override
+    public void postError(Request<?> request, VolleyError error) {
+        request.addMarker("post-error");
+        Response<?> response = Response.error(error);
+        mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, null));
+    }
+
+    /**
+     * A Runnable used for delivering network responses to a listener on the
+     * main thread.
+     */
+    @SuppressWarnings("rawtypes")
+    private class ResponseDeliveryRunnable implements Runnable {
+        private final Request mRequest;
+        private final Response mResponse;
+        private final Runnable mRunnable;
+
+        public ResponseDeliveryRunnable(Request request, Response response, Runnable runnable) {
+            mRequest = request;
+            mResponse = response;
+            mRunnable = runnable;
+        }
+
+        @SuppressWarnings("unchecked")
+        @Override
+        public void run() {
+            // If this request has canceled, finish it and don't deliver.
+            if (mRequest.isCanceled()) {
+                mRequest.finish("canceled-at-delivery");
+                return;
+            }
+
+            // Deliver a normal response or error, depending.
+            if (mResponse.isSuccess()) {
+                mRequest.deliverResponse(mResponse.result);
+            } else {
+                mRequest.deliverError(mResponse.error);
+            }
+
+            // If this is an intermediate response, add a marker, otherwise we're done
+            // and the request can be finished.
+            if (mResponse.intermediate) {
+                mRequest.addMarker("intermediate-response");
+            } else {
+                mRequest.finish("done");
+            }
+
+            // If we have been provided a post-delivery runnable, run it.
+            if (mRunnable != null) {
+                mRunnable.run();
+            }
+       }
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+/**
+ * An interface for performing requests.
+ */
+public interface Network {
+    /**
+     * Performs the specified request.
+     * @param request Request to process
+     * @return A {@link NetworkResponse} with data and caching metadata; will never be null
+     * @throws VolleyError on errors
+     */
+    public NetworkResponse performRequest(Request<?> request) throws VolleyError;
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import android.net.TrafficStats;
+import android.os.Build;
+import android.os.Process;
+
+import java.util.concurrent.BlockingQueue;
+
+/**
+ * Provides a thread for performing network dispatch from a queue of requests.
+ *
+ * Requests added to the specified queue are processed from the network via a
+ * specified {@link Network} interface. Responses are committed to cache, if
+ * eligible, using a specified {@link Cache} interface. Valid responses and
+ * errors are posted back to the caller via a {@link ResponseDelivery}.
+ */
+@SuppressWarnings("rawtypes")
+public class NetworkDispatcher extends Thread {
+    /** The queue of requests to service. */
+    private final BlockingQueue<Request> mQueue;
+    /** The network interface for processing requests. */
+    private final Network mNetwork;
+    /** The cache to write to. */
+    private final Cache mCache;
+    /** For posting responses and errors. */
+    private final ResponseDelivery mDelivery;
+    /** Used for telling us to die. */
+    private volatile boolean mQuit = false;
+
+    /**
+     * Creates a new network dispatcher thread.  You must call {@link #start()}
+     * in order to begin processing.
+     *
+     * @param queue Queue of incoming requests for triage
+     * @param network Network interface to use for performing requests
+     * @param cache Cache interface to use for writing responses to cache
+     * @param delivery Delivery interface to use for posting responses
+     */
+    public NetworkDispatcher(BlockingQueue<Request> queue,
+            Network network, Cache cache,
+            ResponseDelivery delivery) {
+        mQueue = queue;
+        mNetwork = network;
+        mCache = cache;
+        mDelivery = delivery;
+    }
+
+    /**
+     * Forces this dispatcher to quit immediately.  If any requests are still in
+     * the queue, they are not guaranteed to be processed.
+     */
+    public void quit() {
+        mQuit = true;
+        interrupt();
+    }
+
+    @Override
+    public void run() {
+        Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
+        Request request;
+        while (true) {
+            try {
+                // Take a request from the queue.
+                request = mQueue.take();
+            } catch (InterruptedException e) {
+                // We may have been interrupted because it was time to quit.
+                if (mQuit) {
+                    return;
+                }
+                continue;
+            }
+
+            try {
+                request.addMarker("network-queue-take");
+
+                // If the request was cancelled already, do not perform the
+                // network request.
+                if (request.isCanceled()) {
+                    request.finish("network-discard-cancelled");
+                    continue;
+                }
+
+                // Tag the request (if API >= 14)
+                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.ICE_CREAM_SANDWICH) {
+                    TrafficStats.setThreadStatsTag(request.getTrafficStatsTag());
+                }
+
+                // Perform the network request.
+                NetworkResponse networkResponse = mNetwork.performRequest(request);
+                request.addMarker("network-http-complete");
+
+                // If the server returned 304 AND we delivered a response already,
+                // we're done -- don't deliver a second identical response.
+                if (networkResponse.notModified && request.hasHadResponseDelivered()) {
+                    request.finish("not-modified");
+                    continue;
+                }
+
+                // Parse the response here on the worker thread.
+                Response<?> response = request.parseNetworkResponse(networkResponse);
+                request.addMarker("network-parse-complete");
+
+                // Write to cache if applicable.
+                // TODO: Only update cache metadata instead of entire record for 304s.
+                if (request.shouldCache() && response.cacheEntry != null) {
+                    mCache.put(request.getCacheKey(), response.cacheEntry);
+                    request.addMarker("network-cache-written");
+                }
+
+                // Post the response back.
+                request.markDelivered();
+                mDelivery.postResponse(request, response);
+            } catch (VolleyError volleyError) {
+                parseAndDeliverNetworkError(request, volleyError);
+            } catch (Exception e) {
+                VolleyLog.e(e, "Unhandled exception %s", e.toString());
+                mDelivery.postError(request, new VolleyError(e));
+            }
+        }
+    }
+
+    private void parseAndDeliverNetworkError(Request<?> request, VolleyError error) {
+        error = request.parseNetworkError(error);
+        mDelivery.postError(request, error);
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+/**
+ * Indicates that there was a network error when performing a Volley request.
+ */
+@SuppressWarnings("serial")
+public class NetworkError extends VolleyError {
+    public NetworkError() {
+        super();
+    }
+
+    public NetworkError(Throwable cause) {
+        super(cause);
+    }
+
+    public NetworkError(NetworkResponse networkResponse) {
+        super(networkResponse);
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import org.apache.http.HttpStatus;
+
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ * Data and headers returned from {@link Network#performRequest(Request)}.
+ */
+public class NetworkResponse {
+    /**
+     * Creates a new network response.
+     * @param statusCode the HTTP status code
+     * @param data Response body
+     * @param headers Headers returned with this response, or null for none
+     * @param notModified True if the server returned a 304 and the data was already in cache
+     */
+    public NetworkResponse(int statusCode, byte[] data, Map<String, String> headers,
+            boolean notModified) {
+        this.statusCode = statusCode;
+        this.data = data;
+        this.headers = headers;
+        this.notModified = notModified;
+    }
+
+    public NetworkResponse(byte[] data) {
+        this(HttpStatus.SC_OK, data, Collections.<String, String>emptyMap(), false);
+    }
+
+    public NetworkResponse(byte[] data, Map<String, String> headers) {
+        this(HttpStatus.SC_OK, data, headers, false);
+    }
+
+    /** The HTTP status code. */
+    public final int statusCode;
+
+    /** Raw data from this response. */
+    public final byte[] data;
+
+    /** Response headers. */
+    public final Map<String, String> headers;
+
+    /** True if the server returned a 304 (Not Modified). */
+    public final boolean notModified;
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+/**
+ * Error indicating that no connection could be established when performing a Volley request.
+ */
+@SuppressWarnings("serial")
+public class NoConnectionError extends NetworkError {
+    public NoConnectionError() {
+        super();
+    }
+
+    public NoConnectionError(Throwable reason) {
+        super(reason);
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+/**
+ * Indicates that the server's response could not be parsed.
+ */
+@SuppressWarnings("serial")
+public class ParseError extends VolleyError {
+    public ParseError() { }
+
+    public ParseError(NetworkResponse networkResponse) {
+        super(networkResponse);
+    }
+
+    public ParseError(Throwable cause) {
+        super(cause);
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import android.net.TrafficStats;
+import android.net.Uri;
+import android.os.Handler;
+import android.os.Looper;
+import android.os.SystemClock;
+import android.text.TextUtils;
+import com.android.volley.VolleyLog.MarkerLog;
+
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ * Base class for all network requests.
+ *
+ * @param <T> The type of parsed response this request expects.
+ */
+public abstract class Request<T> implements Comparable<Request<T>> {
+
+    /**
+     * Default encoding for POST or PUT parameters. See {@link #getParamsEncoding()}.
+     */
+    private static final String DEFAULT_PARAMS_ENCODING = "UTF-8";
+
+    /**
+     * Supported request methods.
+     */
+    public interface Method {
+        int DEPRECATED_GET_OR_POST = -1;
+        int GET = 0;
+        int POST = 1;
+        int PUT = 2;
+        int DELETE = 3;
+        int HEAD = 4;
+        int OPTIONS = 5;
+        int TRACE = 6;
+        int PATCH = 7;
+    }
+
+    /** An event log tracing the lifetime of this request; for debugging. */
+    private final MarkerLog mEventLog = MarkerLog.ENABLED ? new MarkerLog() : null;
+
+    /**
+     * Request method of this request.  Currently supports GET, POST, PUT, DELETE, HEAD, OPTIONS,
+     * TRACE, and PATCH.
+     */
+    private final int mMethod;
+
+    /** URL of this request. */
+    private final String mUrl;
+
+    /** Default tag for {@link TrafficStats}. */
+    private final int mDefaultTrafficStatsTag;
+
+    /** Listener interface for errors. */
+    private final Response.ErrorListener mErrorListener;
+
+    /** Sequence number of this request, used to enforce FIFO ordering. */
+    private Integer mSequence;
+
+    /** The request queue this request is associated with. */
+    private RequestQueue mRequestQueue;
+
+    /** Whether or not responses to this request should be cached. */
+    private boolean mShouldCache = true;
+
+    /** Whether or not this request has been canceled. */
+    private boolean mCanceled = false;
+
+    /** Whether or not a response has been delivered for this request yet. */
+    private boolean mResponseDelivered = false;
+
+    // A cheap variant of request tracing used to dump slow requests.
+    private long mRequestBirthTime = 0;
+
+    /** Threshold at which we should log the request (even when debug logging is not enabled). */
+    private static final long SLOW_REQUEST_THRESHOLD_MS = 3000;
+
+    /** The retry policy for this request. */
+    private RetryPolicy mRetryPolicy;
+
+    /**
+     * When a request can be retrieved from cache but must be refreshed from
+     * the network, the cache entry will be stored here so that in the event of
+     * a "Not Modified" response, we can be sure it hasn't been evicted from cache.
+     */
+    private Cache.Entry mCacheEntry = null;
+
+    /** An opaque token tagging this request; used for bulk cancellation. */
+    private Object mTag;
+
+    /**
+     * Creates a new request with the given URL and error listener.  Note that
+     * the normal response listener is not provided here as delivery of responses
+     * is provided by subclasses, who have a better idea of how to deliver an
+     * already-parsed response.
+     *
+     * @deprecated Use {@link #Request(int, String, Response.ErrorListener)}.
+     */
+    public Request(String url, Response.ErrorListener listener) {
+        this(Method.DEPRECATED_GET_OR_POST, url, listener);
+    }
+
+    /**
+     * Creates a new request with the given method (one of the values from {@link Method}),
+     * URL, and error listener.  Note that the normal response listener is not provided here as
+     * delivery of responses is provided by subclasses, who have a better idea of how to deliver
+     * an already-parsed response.
+     */
+    public Request(int method, String url, Response.ErrorListener listener) {
+        mMethod = method;
+        mUrl = url;
+        mErrorListener = listener;
+        setRetryPolicy(new DefaultRetryPolicy());
+
+        mDefaultTrafficStatsTag = TextUtils.isEmpty(url) ? 0: Uri.parse(url).getHost().hashCode();
+    }
+
+    /**
+     * Return the method for this request.  Can be one of the values in {@link Method}.
+     */
+    public int getMethod() {
+        return mMethod;
+    }
+
+    /**
+     * Set a tag on this request. Can be used to cancel all requests with this
+     * tag by {@link RequestQueue#cancelAll(Object)}.
+     */
+    public void setTag(Object tag) {
+        mTag = tag;
+    }
+
+    /**
+     * Returns this request's tag.
+     * @see Request#setTag(Object)
+     */
+    public Object getTag() {
+        return mTag;
+    }
+
+    /**
+     * @return A tag for use with {@link TrafficStats#setThreadStatsTag(int)}
+     */
+    public int getTrafficStatsTag() {
+        return mDefaultTrafficStatsTag;
+    }
+
+    /**
+     * Sets the retry policy for this request.
+     */
+    public void setRetryPolicy(RetryPolicy retryPolicy) {
+        mRetryPolicy = retryPolicy;
+    }
+
+    /**
+     * Adds an event to this request's event log; for debugging.
+     */
+    public void addMarker(String tag) {
+        if (MarkerLog.ENABLED) {
+            mEventLog.add(tag, Thread.currentThread().getId());
+        } else if (mRequestBirthTime == 0) {
+            mRequestBirthTime = SystemClock.elapsedRealtime();
+        }
+    }
+
+    /**
+     * Notifies the request queue that this request has finished (successfully or with error).
+     *
+     * <p>Also dumps all events from this request's event log; for debugging.</p>
+     */
+    void finish(final String tag) {
+        if (mRequestQueue != null) {
+            mRequestQueue.finish(this);
+        }
+        if (MarkerLog.ENABLED) {
+            final long threadId = Thread.currentThread().getId();
+            if (Looper.myLooper() != Looper.getMainLooper()) {
+                // If we finish marking off of the main thread, we need to
+                // actually do it on the main thread to ensure correct ordering.
+                Handler mainThread = new Handler(Looper.getMainLooper());
+                mainThread.post(new Runnable() {
+                    @Override
+                    public void run() {
+                        mEventLog.add(tag, threadId);
+                        mEventLog.finish(this.toString());
+                    }
+                });
+                return;
+            }
+
+            mEventLog.add(tag, threadId);
+            mEventLog.finish(this.toString());
+        } else {
+            long requestTime = SystemClock.elapsedRealtime() - mRequestBirthTime;
+            if (requestTime >= SLOW_REQUEST_THRESHOLD_MS) {
+                VolleyLog.d("%d ms: %s", requestTime, this.toString());
+            }
+        }
+    }
+
+    /**
+     * Associates this request with the given queue. The request queue will be notified when this
+     * request has finished.
+     */
+    public void setRequestQueue(RequestQueue requestQueue) {
+        mRequestQueue = requestQueue;
+    }
+
+    /**
+     * Sets the sequence number of this request.  Used by {@link RequestQueue}.
+     */
+    public final void setSequence(int sequence) {
+        mSequence = sequence;
+    }
+
+    /**
+     * Returns the sequence number of this request.
+     */
+    public final int getSequence() {
+        if (mSequence == null) {
+            throw new IllegalStateException("getSequence called before setSequence");
+        }
+        return mSequence;
+    }
+
+    /**
+     * Returns the URL of this request.
+     */
+    public String getUrl() {
+        return mUrl;
+    }
+
+    /**
+     * Returns the cache key for this request.  By default, this is the URL.
+     */
+    public String getCacheKey() {
+        return getUrl();
+    }
+
+    /**
+     * Annotates this request with an entry retrieved for it from cache.
+     * Used for cache coherency support.
+     */
+    public void setCacheEntry(Cache.Entry entry) {
+        mCacheEntry = entry;
+    }
+
+    /**
+     * Returns the annotated cache entry, or null if there isn't one.
+     */
+    public Cache.Entry getCacheEntry() {
+        return mCacheEntry;
+    }
+
+    /**
+     * Mark this request as canceled.  No callback will be delivered.
+     */
+    public void cancel() {
+        mCanceled = true;
+    }
+
+    /**
+     * Returns true if this request has been canceled.
+     */
+    public boolean isCanceled() {
+        return mCanceled;
+    }
+
+    /**
+     * Returns a list of extra HTTP headers to go along with this request. Can
+     * throw {@link AuthFailureError} as authentication may be required to
+     * provide these values.
+     * @throws AuthFailureError In the event of auth failure
+     */
+    public Map<String, String> getHeaders() throws AuthFailureError {
+        return Collections.emptyMap();
+    }
+
+    /**
+     * Returns a Map of POST parameters to be used for this request, or null if
+     * a simple GET should be used.  Can throw {@link AuthFailureError} as
+     * authentication may be required to provide these values.
+     *
+     * <p>Note that only one of getPostParams() and getPostBody() can return a non-null
+     * value.</p>
+     * @throws AuthFailureError In the event of auth failure
+     *
+     * @deprecated Use {@link #getParams()} instead.
+     */
+    protected Map<String, String> getPostParams() throws AuthFailureError {
+        return getParams();
+    }
+
+    /**
+     * Returns which encoding should be used when converting POST parameters returned by
+     * {@link #getPostParams()} into a raw POST body.
+     *
+     * <p>This controls both encodings:
+     * <ol>
+     *     <li>The string encoding used when converting parameter names and values into bytes prior
+     *         to URL encoding them.</li>
+     *     <li>The string encoding used when converting the URL encoded parameters into a raw
+     *         byte array.</li>
+     * </ol>
+     *
+     * @deprecated Use {@link #getParamsEncoding()} instead.
+     */
+    protected String getPostParamsEncoding() {
+        return getParamsEncoding();
+    }
+
+    /**
+     * @deprecated Use {@link #getBodyContentType()} instead.
+     */
+    public String getPostBodyContentType() {
+        return getBodyContentType();
+    }
+
+    /**
+     * Returns the raw POST body to be sent.
+     *
+     * @throws AuthFailureError In the event of auth failure
+     *
+     * @deprecated Use {@link #getBody()} instead.
+     */
+    public byte[] getPostBody() throws AuthFailureError {
+        // Note: For compatibility with legacy clients of volley, this implementation must remain
+        // here instead of simply calling the getBody() function because this function must
+        // call getPostParams() and getPostParamsEncoding() since legacy clients would have
+        // overridden these two member functions for POST requests.
+        Map<String, String> postParams = getPostParams();
+        if (postParams != null && postParams.size() > 0) {
+            return encodeParameters(postParams, getPostParamsEncoding());
+        }
+        return null;
+    }
+
+    /**
+     * Returns a Map of parameters to be used for a POST or PUT request.  Can throw
+     * {@link AuthFailureError} as authentication may be required to provide these values.
+     *
+     * <p>Note that you can directly override {@link #getBody()} for custom data.</p>
+     *
+     * @throws AuthFailureError in the event of auth failure
+     */
+    protected Map<String, String> getParams() throws AuthFailureError {
+        return null;
+    }
+
+    /**
+     * Returns which encoding should be used when converting POST or PUT parameters returned by
+     * {@link #getParams()} into a raw POST or PUT body.
+     *
+     * <p>This controls both encodings:
+     * <ol>
+     *     <li>The string encoding used when converting parameter names and values into bytes prior
+     *         to URL encoding them.</li>
+     *     <li>The string encoding used when converting the URL encoded parameters into a raw
+     *         byte array.</li>
+     * </ol>
+     */
+    protected String getParamsEncoding() {
+        return DEFAULT_PARAMS_ENCODING;
+    }
+
+    public String getBodyContentType() {
+        return "application/x-www-form-urlencoded; charset=" + getParamsEncoding();
+    }
+
+    /**
+     * Returns the raw POST or PUT body to be sent.
+     *
+     * @throws AuthFailureError in the event of auth failure
+     */
+    public byte[] getBody() throws AuthFailureError {
+        Map<String, String> params = getParams();
+        if (params != null && params.size() > 0) {
+            return encodeParameters(params, getParamsEncoding());
+        }
+        return null;
+    }
+
+    /**
+     * Converts <code>params</code> into an application/x-www-form-urlencoded encoded string.
+     */
+    private byte[] encodeParameters(Map<String, String> params, String paramsEncoding) {
+        StringBuilder encodedParams = new StringBuilder();
+        try {
+            for (Map.Entry<String, String> entry : params.entrySet()) {
+                encodedParams.append(URLEncoder.encode(entry.getKey(), paramsEncoding));
+                encodedParams.append('=');
+                encodedParams.append(URLEncoder.encode(entry.getValue(), paramsEncoding));
+                encodedParams.append('&');
+            }
+            return encodedParams.toString().getBytes(paramsEncoding);
+        } catch (UnsupportedEncodingException uee) {
+            throw new RuntimeException("Encoding not supported: " + paramsEncoding, uee);
+        }
+    }
+
+    /**
+     * Set whether or not responses to this request should be cached.
+     */
+    public final void setShouldCache(boolean shouldCache) {
+        mShouldCache = shouldCache;
+    }
+
+    /**
+     * Returns true if responses to this request should be cached.
+     */
+    public final boolean shouldCache() {
+        return mShouldCache;
+    }
+
+    /**
+     * Priority values.  Requests will be processed from higher priorities to
+     * lower priorities, in FIFO order.
+     */
+    public enum Priority {
+        LOW,
+        NORMAL,
+        HIGH,
+        IMMEDIATE
+    }
+
+    /**
+     * Returns the {@link Priority} of this request; {@link Priority#NORMAL} by default.
+     */
+    public Priority getPriority() {
+        return Priority.NORMAL;
+    }
+
+    /**
+     * Returns the socket timeout in milliseconds per retry attempt. (This value can be changed
+     * per retry attempt if a backoff is specified via backoffTimeout()). If there are no retry
+     * attempts remaining, this will cause delivery of a {@link TimeoutError} error.
+     */
+    public final int getTimeoutMs() {
+        return mRetryPolicy.getCurrentTimeout();
+    }
+
+    /**
+     * Returns the retry policy that should be used  for this request.
+     */
+    public RetryPolicy getRetryPolicy() {
+        return mRetryPolicy;
+    }
+
+    /**
+     * Mark this request as having a response delivered on it.  This can be used
+     * later in the request's lifetime for suppressing identical responses.
+     */
+    public void markDelivered() {
+        mResponseDelivered = true;
+    }
+
+    /**
+     * Returns true if this request has had a response delivered for it.
+     */
+    public boolean hasHadResponseDelivered() {
+        return mResponseDelivered;
+    }
+
+    /**
+     * Subclasses must implement this to parse the raw network response
+     * and return an appropriate response type. This method will be
+     * called from a worker thread.  The response will not be delivered
+     * if you return null.
+     * @param response Response from the network
+     * @return The parsed response, or null in the case of an error
+     */
+    abstract protected Response<T> parseNetworkResponse(NetworkResponse response);
+
+    /**
+     * Subclasses can override this method to parse 'networkError' and return a more specific error.
+     *
+     * <p>The default implementation just returns the passed 'networkError'.</p>
+     *
+     * @param volleyError the error retrieved from the network
+     * @return an NetworkError augmented with additional information
+     */
+    protected VolleyError parseNetworkError(VolleyError volleyError) {
+        return volleyError;
+    }
+
+    /**
+     * Subclasses must implement this to perform delivery of the parsed
+     * response to their listeners.  The given response is guaranteed to
+     * be non-null; responses that fail to parse are not delivered.
+     * @param response The parsed response returned by
+     * {@link #parseNetworkResponse(NetworkResponse)}
+     */
+    abstract protected void deliverResponse(T response);
+
+    /**
+     * Delivers error message to the ErrorListener that the Request was
+     * initialized with.
+     *
+     * @param error Error details
+     */
+    public void deliverError(VolleyError error) {
+        if (mErrorListener != null) {
+            mErrorListener.onErrorResponse(error);
+        }
+    }
+
+    /**
+     * Our comparator sorts from high to low priority, and secondarily by
+     * sequence number to provide FIFO ordering.
+     */
+    @Override
+    public int compareTo(Request<T> other) {
+        Priority left = this.getPriority();
+        Priority right = other.getPriority();
+
+        // High-priority requests are "lesser" so they are sorted to the front.
+        // Equal priorities are sorted by sequence number to provide FIFO ordering.
+        return left == right ?
+                this.mSequence - other.mSequence :
+                right.ordinal() - left.ordinal();
+    }
+
+    @Override
+    public String toString() {
+        String trafficStatsTag = "0x" + Integer.toHexString(getTrafficStatsTag());
+        return (mCanceled ? "[X] " : "[ ] ") + getUrl() + " " + trafficStatsTag + " "
+                + getPriority() + " " + mSequence;
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+import android.os.Handler;
+import android.os.Looper;
+
+import java.util.*;
+import java.util.concurrent.PriorityBlockingQueue;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * A request dispatch queue with a thread pool of dispatchers.
+ *
+ * Calling {@link #add(Request)} will enqueue the given Request for dispatch,
+ * resolving from either cache or network on a worker thread, and then delivering
+ * a parsed response on the main thread.
+ */
+@SuppressWarnings("rawtypes")
+public class RequestQueue {
+
+    /** Used for generating monotonically-increasing sequence numbers for requests. */
+    private AtomicInteger mSequenceGenerator = new AtomicInteger();
+
+    /**
+     * Staging area for requests that already have a duplicate request in flight.
+     *
+     * <ul>
+     *     <li>containsKey(cacheKey) indicates that there is a request in flight for the given cache
+     *          key.</li>
+     *     <li>get(cacheKey) returns waiting requests for the given cache key. The in flight request
+     *          is <em>not</em> contained in that list. Is null if no requests are staged.</li>
+     * </ul>
+     */
+    private final Map<String, Queue<Request>> mWaitingRequests =
+            new HashMap<String, Queue<Request>>();
+
+    /**
+     * The set of all requests currently being processed by this RequestQueue. A Request
+     * will be in this set if it is waiting in any queue or currently being processed by
+     * any dispatcher.
+     */
+    private final Set<Request> mCurrentRequests = new HashSet<Request>();
+
+    /** The cache triage queue. */
+    private final PriorityBlockingQueue<Request> mCacheQueue =
+        new PriorityBlockingQueue<Request>();
+
+    /** The queue of requests that are actually going out to the network. */
+    private final PriorityBlockingQueue<Request> mNetworkQueue =
+        new PriorityBlockingQueue<Request>();
+
+    /** Number of network request dispatcher threads to start. */
+    private static final int DEFAULT_NETWORK_THREAD_POOL_SIZE = 4;
+
+    /** Cache interface for retrieving and storing respones. */
+    private final Cache mCache;
+
+    /** Network interface for performing requests. */
+    private final Network mNetwork;
+
+    /** Response delivery mechanism. */
+    private final ResponseDelivery mDelivery;
+
+    /** The network dispatchers. */
+    private NetworkDispatcher[] mDispatchers;
+
+    /** The cache dispatcher. */
+    private CacheDispatcher mCacheDispatcher;
+
+    /**
+     * Creates the worker pool. Processing will not begin until {@link #start()} is called.
+     *
+     * @param cache A Cache to use for persisting responses to disk
+     * @param network A Network interface for performing HTTP requests
+     * @param threadPoolSize Number of network dispatcher threads to create
+     * @param delivery A ResponseDelivery interface for posting responses and errors
+     */
+    public RequestQueue(Cache cache, Network network, int threadPoolSize,
+            ResponseDelivery delivery) {
+        mCache = cache;
+        mNetwork = network;
+        mDispatchers = new NetworkDispatcher[threadPoolSize];
+        mDelivery = delivery;
+    }
+
+    /**
+     * Creates the worker pool. Processing will not begin until {@link #start()} is called.
+     *
+     * @param cache A Cache to use for persisting responses to disk
+     * @param network A Network interface for performing HTTP requests
+     * @param threadPoolSize Number of network dispatcher threads to create
+     */
+    public RequestQueue(Cache cache, Network network, int threadPoolSize) {
+        this(cache, network, threadPoolSize,
+                new ExecutorDelivery(new Handler(Looper.getMainLooper())));
+    }
+
+    /**
+     * Creates the worker pool. Processing will not begin until {@link #start()} is called.
+     *
+     * @param cache A Cache to use for persisting responses to disk
+     * @param network A Network interface for performing HTTP requests
+     */
+    public RequestQueue(Cache cache, Network network) {
+        this(cache, network, DEFAULT_NETWORK_THREAD_POOL_SIZE);
+    }
+
+    /**
+     * Starts the dispatchers in this queue.
+     */
+    public void start() {
+        stop();  // Make sure any currently running dispatchers are stopped.
+        // Create the cache dispatcher and start it.
+        mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
+        mCacheDispatcher.start();
+
+        // Create network dispatchers (and corresponding threads) up to the pool size.
+        for (int i = 0; i < mDispatchers.length; i++) {
+            NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
+                    mCache, mDelivery);
+            mDispatchers[i] = networkDispatcher;
+            networkDispatcher.start();
+        }
+    }
+
+    /**
+     * Stops the cache and network dispatchers.
+     */
+    public void stop() {
+        if (mCacheDispatcher != null) {
+            mCacheDispatcher.quit();
+        }
+        for (int i = 0; i < mDispatchers.length; i++) {
+            if (mDispatchers[i] != null) {
+                mDispatchers[i].quit();
+            }
+        }
+    }
+
+    /**
+     * Gets a sequence number.
+     */
+    public int getSequenceNumber() {
+        return mSequenceGenerator.incrementAndGet();
+    }
+
+    /**
+     * Gets the {@link Cache} instance being used.
+     */
+    public Cache getCache() {
+        return mCache;
+    }
+
+    /**
+     * A simple predicate or filter interface for Requests, for use by
+     * {@link RequestQueue#cancelAll(RequestFilter)}.
+     */
+    public interface RequestFilter {
+        public boolean apply(Request<?> request);
+    }
+
+    /**
+     * Cancels all requests in this queue for which the given filter applies.
+     * @param filter The filtering function to use
+     */
+    public void cancelAll(RequestFilter filter) {
+        synchronized (mCurrentRequests) {
+            for (Request<?> request : mCurrentRequests) {
+                if (filter.apply(request)) {
+                    request.cancel();
+                }
+            }
+        }
+    }
+
+    /**
+     * Cancels all requests in this queue with the given tag. Tag must be non-null
+     * and equality is by identity.
+     */
+    public void cancelAll(final Object tag) {
+        if (tag == null) {
+            throw new IllegalArgumentException("Cannot cancelAll with a null tag");
+        }
+        cancelAll(new RequestFilter() {
+            @Override
+            public boolean apply(Request<?> request) {
+                return request.getTag() == tag;
+            }
+        });
+    }
+
+    /**
+     * Adds a Request to the dispatch queue.
+     * @param request The request to service
+     * @return The passed-in request
+     */
+    public Request add(Request request) {
+        // Tag the request as belonging to this queue and add it to the set of current requests.
+        request.setRequestQueue(this);
+        synchronized (mCurrentRequests) {
+            mCurrentRequests.add(request);
+        }
+
+        // Process requests in the order they are added.
+        request.setSequence(getSequenceNumber());
+        request.addMarker("add-to-queue");
+
+        // If the request is uncacheable, skip the cache queue and go straight to the network.
+        if (!request.shouldCache()) {
+            mNetworkQueue.add(request);
+            return request;
+        }
+
+        // Insert request into stage if there's already a request with the same cache key in flight.
+        synchronized (mWaitingRequests) {
+            String cacheKey = request.getCacheKey();
+            if (mWaitingRequests.containsKey(cacheKey)) {
+                // There is already a request in flight. Queue up.
+                Queue<Request> stagedRequests = mWaitingRequests.get(cacheKey);
+                if (stagedRequests == null) {
+                    stagedRequests = new LinkedList<Request>();
+                }
+                stagedRequests.add(request);
+                mWaitingRequests.put(cacheKey, stagedRequests);
+                if (VolleyLog.DEBUG) {
+                    VolleyLog.v("Request for cacheKey=%s is in flight, putting on hold.", cacheKey);
+                }
+            } else {
+                // Insert 'null' queue for this cacheKey, indicating there is now a request in
+                // flight.
+                mWaitingRequests.put(cacheKey, null);
+                mCacheQueue.add(request);
+            }
+            return request;
+        }
+    }
+
+    /**
+     * Called from {@link Request#finish(String)}, indicating that processing of the given request
+     * has finished.
+     *
+     * <p>Releases waiting requests for <code>request.getCacheKey()</code> if
+     *      <code>request.shouldCache()</code>.</p>
+     */
+    void finish(Request request) {
+        // Remove from the set of requests currently being processed.
+        synchronized (mCurrentRequests) {
+            mCurrentRequests.remove(request);
+        }
+
+        if (request.shouldCache()) {
+            synchronized (mWaitingRequests) {
+                String cacheKey = request.getCacheKey();
+                Queue<Request> waitingRequests = mWaitingRequests.remove(cacheKey);
+                if (waitingRequests != null) {
+                    if (VolleyLog.DEBUG) {
+                        VolleyLog.v("Releasing %d waiting requests for cacheKey=%s.",
+                                waitingRequests.size(), cacheKey);
+                    }
+                    // Process all queued up requests. They won't be considered as in flight, but
+                    // that's not a problem as the cache has been primed by 'request'.
+                    mCacheQueue.addAll(waitingRequests);
+                }
+            }
+        }
+    }
+}

+/*
+ * Copyright (C) 2011 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.android.volley;
+
+/**
+ * Encapsulates a parsed response for delivery.
+ *
+ * @param <T> Parsed type of this response
+ */
+public class Response<T> {
+
+    /** Callback interface for delivering parsed responses. */
+    public interface Listener<T> {
+        /** Called when a response is received. */
+        public void onResponse(T response);
+    }
+
+    /** Callback interface for delivering error responses. */
+    public interface ErrorListener {
+        /**
+         * Callback method that an error has been occurred with the
+         * provided error code and optional user-readable message.
+         */
+        public void onErrorResponse(VolleyError error);
+    }
+
+    /** Returns a successful response containing the parsed result. */
+    public static <T> Response<T> success(T result, Cache.Entry cacheEntry) {
+        return new Response<T>(result, cacheEntry);
+    }
+
+    /**
+     * Returns a failed response containing the given error code and an optional
+     * localized message displayed to the user.
+     */
+    public static <T> Response<T> error(VolleyError error) {
+        return new Response<T>(error);
+    }
+
+    /** Parsed response, or null in the case of error. */
+    public final T result;
+
+    /** Cache metadata for this response, or null in the case of error. */
+    public final Cache.Entry cacheEntry;
+
+    /** Detailed error information if <code>errorCode != OK</code>. */
+    public final VolleyError error;
+
+    /** True if this response was a soft-expired one and a second one MAY be coming. */
+    public boolean intermediate = false;
+
+    /**
+     * Returns whether this response is considered successful.
+     */
+    public boolean isSuccess() {
+        return error == null;
+    }
+
+
+    private Response(T result, Cache.Entry cacheEntry) {
+        this.result = result;
+        this.cacheEntry = cacheEntry;
+        this.error = null;
+    }
+
+    private Response(VolleyError error) {
+        this.result = null;
+        this.cacheEntry = null;
+        this.error = error;
+    }
+}