Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 package org.chromium.net; | |
| 6 | |
| 7 import static android.os.Process.THREAD_PRIORITY_BACKGROUND; | |
| 8 import static android.os.Process.THREAD_PRIORITY_MORE_FAVORABLE; | |
| 9 | |
| 10 import java.io.IOException; | |
| 11 import java.net.Proxy; | |
| 12 import java.net.URL; | |
| 13 import java.net.URLConnection; | |
| 14 import java.net.URLStreamHandler; | |
| 15 import java.net.URLStreamHandlerFactory; | |
| 16 import java.util.List; | |
| 17 import java.util.Map; | |
| 18 import java.util.concurrent.Executor; | |
| 19 import java.util.concurrent.ExecutorService; | |
| 20 import java.util.concurrent.Executors; | |
| 21 import java.util.concurrent.ThreadFactory; | |
| 22 | |
| 23 /** | |
| 24 * {@link java.net.HttpURLConnection} backed CronetEngine. | |
| 25 */ | |
| 26 final class JavaCronetEngine extends CronetEngine { | |
| 27 private final String mUserAgent; | |
| 28 | |
| 29 private final ExecutorService mExecutorService = | |
| 30 Executors.newCachedThreadPool(new ThreadFactory() { | |
| 31 @Override | |
| 32 public Thread newThread(final Runnable r) { | |
| 33 return Executors.defaultThreadFactory().newThread(new Runnab le() { | |
| 34 @Override | |
| 35 public void run() { | |
| 36 Thread.currentThread().setName("JavaCronetEngine"); | |
| 37 android.os.Process.setThreadPriority( | |
| 38 THREAD_PRIORITY_BACKGROUND + THREAD_PRIORITY _MORE_FAVORABLE); | |
|
pauljensen
2015/12/08 19:49:52
why one above background? I think Cronet's networ
Charles
2015/12/11 16:45:39
Added comment explaining priority selection.
| |
| 39 r.run(); | |
| 40 } | |
| 41 }); | |
| 42 } | |
| 43 }); | |
| 44 | |
| 45 JavaCronetEngine(String userAgent) { | |
| 46 this.mUserAgent = userAgent; | |
| 47 } | |
| 48 | |
| 49 @Override | |
| 50 public UrlRequest createRequest(String url, UrlRequest.Callback callback, Ex ecutor executor) { | |
| 51 return new JavaUrlRequest(callback, mExecutorService, executor, url, mUs erAgent); | |
| 52 } | |
| 53 | |
| 54 @Override | |
| 55 public UrlRequest createRequest( | |
| 56 String url, UrlRequest.Callback callback, Executor executor, int pri ority) { | |
|
pauljensen
2015/12/08 19:49:52
I see you're ignoring priority. That's probably f
Charles
2015/12/11 16:45:39
Done.
| |
| 57 return new JavaUrlRequest(callback, mExecutorService, executor, url, mUs erAgent); | |
| 58 } | |
| 59 | |
| 60 @Override | |
| 61 BidirectionalStream createBidirectionalStream(String url, BidirectionalStrea m.Callback callback, | |
| 62 Executor executor, String httpMethod, List<Map.Entry<String, String> > requestHeaders) { | |
| 63 throw new UnsupportedOperationException( | |
| 64 "Can't create a bidi stream - httpurlconnection doesn't have tho se APIs"); | |
| 65 } | |
| 66 | |
| 67 @Override | |
| 68 boolean isEnabled() { | |
| 69 return true; | |
| 70 } | |
| 71 | |
| 72 @Override | |
| 73 public String getVersionString() { | |
| 74 return "HttpUrlConnection"; | |
|
pauljensen
2015/12/08 19:49:52
This should really include a version string so we
Charles
2015/12/11 16:45:39
Done.
| |
| 75 } | |
| 76 | |
| 77 @Override | |
| 78 public void shutdown() { | |
| 79 mExecutorService.shutdown(); | |
| 80 } | |
| 81 | |
| 82 @Override | |
| 83 public void startNetLogToFile(String fileName, boolean logAll) {} | |
| 84 | |
| 85 @Override | |
| 86 public void stopNetLog() {} | |
| 87 | |
| 88 @Override | |
| 89 public byte[] getGlobalMetricsDeltas() { | |
| 90 return new byte[0]; | |
| 91 } | |
| 92 | |
| 93 @Override | |
| 94 public void enableNetworkQualityEstimator(Executor executor) {} | |
| 95 | |
| 96 @Override | |
| 97 void enableNetworkQualityEstimatorForTesting( | |
| 98 boolean useLocalHostRequests, boolean useSmallerResponses, Executor executor) {} | |
| 99 | |
| 100 @Override | |
| 101 public void addRttListener(NetworkQualityRttListener listener) {} | |
| 102 | |
| 103 @Override | |
| 104 public void removeRttListener(NetworkQualityRttListener listener) {} | |
| 105 | |
| 106 @Override | |
| 107 public void addThroughputListener(NetworkQualityThroughputListener listener) {} | |
| 108 | |
| 109 @Override | |
| 110 public void removeThroughputListener(NetworkQualityThroughputListener listen er) {} | |
| 111 | |
| 112 @Override | |
| 113 public URLConnection openConnection(URL url) throws IOException { | |
| 114 return url.openConnection(); | |
| 115 } | |
| 116 | |
| 117 @Override | |
| 118 public URLConnection openConnection(URL url, Proxy proxy) throws IOException { | |
| 119 return url.openConnection(proxy); | |
| 120 } | |
| 121 | |
| 122 @Override | |
| 123 public URLStreamHandlerFactory createURLStreamHandlerFactory() { | |
| 124 return new URLStreamHandlerFactory() { | |
| 125 @Override | |
| 126 public URLStreamHandler createURLStreamHandler(String protocol) { | |
| 127 return null; | |
|
pauljensen
2015/12/08 19:49:52
perhaps instead of returning null, return:
new URL
Charles
2015/12/11 16:45:39
That causes infinite recursion. Added a comment.
| |
| 128 } | |
| 129 }; | |
| 130 } | |
| 131 } | |
| OLD | NEW |