Chromium Code Reviews| Index: components/cronet/android/test/javaperftests/src/org/chromium/net/CronetPerfTestActivity.java |
| diff --git a/components/cronet/android/test/javaperftests/src/org/chromium/net/CronetPerfTestActivity.java b/components/cronet/android/test/javaperftests/src/org/chromium/net/CronetPerfTestActivity.java |
| index c9e139150d31bcea886b05138f0dfc06b230b561..3d668afd3757598e0eabe347493d8e10e2060e9c 100644 |
| --- a/components/cronet/android/test/javaperftests/src/org/chromium/net/CronetPerfTestActivity.java |
| +++ b/components/cronet/android/test/javaperftests/src/org/chromium/net/CronetPerfTestActivity.java |
| @@ -111,7 +111,7 @@ public class CronetPerfTestActivity extends Activity { |
| private final Protocol mProtocol; |
| private final URL mUrl; |
| private final String mName; |
| - private final UrlRequestContext mCronetContext; |
| + private final CronetEngine mCronetEngine; |
| // Size in bytes of content being uploaded or downloaded. |
| private final int mLength; |
| // How many requests to execute. |
| @@ -178,13 +178,13 @@ public class CronetPerfTestActivity extends Activity { |
| throw new IllegalArgumentException("Bad URL: " + getConfigString("HOST") + ":" |
| + port + "/" + resource); |
| } |
| - final UrlRequestContextConfig cronetConfig = new UrlRequestContextConfig(); |
| + final CronetEngine.Builder cronetEngineBuilder = new CronetEngine.Builder(); |
| if (mProtocol == Protocol.QUIC) { |
| - cronetConfig.enableQUIC(true); |
| - cronetConfig.addQuicHint(getConfigString("HOST"), getConfigInt("QUIC_PORT"), |
| + cronetEngineBuilder.enableQUIC(true); |
| + cronetEngineBuilder.addQuicHint(getConfigString("HOST"), getConfigInt("QUIC_PORT"), |
| getConfigInt("QUIC_PORT")); |
| } |
| - mCronetContext = new CronetUrlRequestContext(CronetPerfTestActivity.this, cronetConfig); |
| + mCronetEngine = cronetEngineBuilder.build(CronetPerfTestActivity.this); |
| mName = buildBenchmarkName(mode, direction, protocol, concurrency, mIterations); |
| mConcurrency = concurrency; |
| mResults = results; |
| @@ -216,8 +216,8 @@ public class CronetPerfTestActivity extends Activity { |
| @SuppressLint("NewApi") |
| private void startLogging() { |
| if (getConfigBoolean("CAPTURE_NETLOG")) { |
| - mCronetContext.startNetLogToFile(getFilesDir().getPath() + "/" + mName + ".json", |
| - false); |
| + mCronetEngine.startNetLogToFile( |
| + getFilesDir().getPath() + "/" + mName + ".json", false); |
| } |
| if (getConfigBoolean("CAPTURE_TRACE")) { |
| Debug.startMethodTracing(getFilesDir().getPath() + "/" + mName + ".trace"); |
| @@ -229,7 +229,7 @@ public class CronetPerfTestActivity extends Activity { |
| private void stopLogging() { |
| if (getConfigBoolean("CAPTURE_NETLOG")) { |
| - mCronetContext.stopNetLog(); |
| + mCronetEngine.stopNetLog(); |
| } |
| if (getConfigBoolean("CAPTURE_TRACE") || getConfigBoolean("CAPTURE_SAMPLED_TRACE")) { |
| Debug.stopMethodTracing(); |
| @@ -343,13 +343,13 @@ public class CronetPerfTestActivity extends Activity { |
| initiateRequest(buffer); |
| } |
| }; |
| - final UrlRequest request = mCronetContext.createRequest(mUrl.toString(), |
| + final UrlRequest.Builder builder = new UrlRequest.Builder(mUrl.toString(), |
| new Listener(buffer, completionCallback), mWorkQueueExecutor); |
| if (mDirection == Direction.UP) { |
| - request.setUploadDataProvider(new Uploader(buffer), mWorkQueueExecutor); |
| - request.addHeader("Content-Type", "application/octet-stream"); |
| + builder.setUploadDataProvider(new Uploader(buffer), mWorkQueueExecutor); |
| + builder.addHeader("Content-Type", "application/octet-stream"); |
| } |
| - request.start(); |
| + mCronetEngine.executeRequest(builder); |
|
xunjieli
2015/10/01 19:00:09
need to update tests?
pauljensen
2015/10/01 23:42:59
Done.
|
| } |
| private class Uploader extends UploadDataProvider { |
| @@ -479,7 +479,7 @@ public class CronetPerfTestActivity extends Activity { |
| break; |
| case CRONET_HUC: { |
| final CronetHttpURLStreamHandler cronetStreamHandler = |
| - new CronetHttpURLStreamHandler(mCronetContext); |
| + new CronetHttpURLStreamHandler(mCronetEngine); |
| for (int i = 0; i < mIterations; i++) { |
| tasks.add(new CronetHttpURLConnectionFetchTask(cronetStreamHandler)); |
| } |