Spdy

Created by: zwq00000

AndroidAsync/src/com/koushikdutta/async/dns/Dns.java

@@ -143,7 +143,7 @@ public class Dns {
                 }
             });
             if (!multicast)
-                dgram.write(packet);
+                dgram.write(new ByteBufferList(packet));
             else
                 dgram.send(new InetSocketAddress("224.0.0.251", 5353), packet);
             return ret;

AndroidAsync/src/com/koushikdutta/async/http/body/MultipartFormDataBody.java

@@ -12,7 +12,7 @@ import com.koushikdutta.async.callback.DataCallback;
 import com.koushikdutta.async.future.Continuation;
 import com.koushikdutta.async.http.AsyncHttpRequest;
 import com.koushikdutta.async.http.Multimap;
-import com.koushikdutta.async.http.libcore.RawHeaders;
+import com.koushikdutta.async.http.cache.RawHeaders;
 import com.koushikdutta.async.http.server.BoundaryEmitter;
 
 import java.io.File;

AndroidAsync/src/com/koushikdutta/async/http/body/Part.java

@@ -3,12 +3,11 @@ package com.koushikdutta.async.http.body;
 import com.koushikdutta.async.DataSink;
 import com.koushikdutta.async.callback.CompletedCallback;
 import com.koushikdutta.async.http.Multimap;
-import com.koushikdutta.async.http.libcore.RawHeaders;
+import com.koushikdutta.async.http.cache.RawHeaders;
 import org.apache.http.NameValuePair;
 
 import java.io.File;
 import java.util.List;
-import java.util.Map;
 
 public class Part {
     public static final String CONTENT_DISPOSITION = "Content-Disposition";

AndroidAsync/src/com/koushikdutta/async/http/cache/CacheUtil.java

+package com.koushikdutta.async.http.cache;
+
+import java.util.HashSet;
+import java.util.Set;
+
+/**
+ * Created by koush on 7/21/14.
+ */
+class CacheUtil {
+    static Set<String> varyFields(RawHeaders headers) {
+        HashSet<String> ret = new HashSet<String>();
+        String value = headers.get("Vary");
+        if (value == null)
+            return ret;
+        for (String varyField : value.split(",")) {
+            ret.add(varyField.trim());
+        }
+        return ret;
+    }
+
+    static boolean isCacheable(RawHeaders requestHeaders, RawHeaders responseHeaders) {
+        ResponseHeaders r = new ResponseHeaders(null, responseHeaders);
+        return r.isCacheable(new RequestHeaders(null, requestHeaders));
+    }
+
+    static boolean isNoCache(RawHeaders headers) {
+        return new RequestHeaders(null, headers).isNoCache();
+    }
+
+    ResponseSource chooseResponseSource(long nowMillis, RawHeaders request, RawHeaders response) {
+        RequestHeaders requestHeaders = new RequestHeaders(null, request);
+        ResponseHeaders responseHeaders = new ResponseHeaders(null, response);
+        return responseHeaders.chooseResponseSource(nowMillis, requestHeaders);
+    }
+}

AndroidAsync/src/com/koushikdutta/async/http/cache/HeaderParser.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.koushikdutta.async.http.libcore;
+package com.koushikdutta.async.http.cache;
 
 final class HeaderParser {
 
@@ -26,6 +26,8 @@ final class HeaderParser {
      * Parse a comma-separated list of cache control header values.
      */
     public static void parseCacheControl(String value, CacheControlHandler handler) {
+        if (value == null)
+            return;
         int pos = 0;
         while (pos < value.length()) {
             int tokenStart = pos;