Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(829)

Side by Side Diff: components/cronet/android/test/javaperftests/src/org/chromium/net/CronetPerfTestActivity.java

Issue 1307863006: [Cronet] Change interface APIs to abstract classes (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: update CronetPerfTestActivity too Created 5 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 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 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 package org.chromium.net; 5 package org.chromium.net;
6 6
7 import android.annotation.SuppressLint; 7 import android.annotation.SuppressLint;
8 import android.app.Activity; 8 import android.app.Activity;
9 import android.net.Uri; 9 import android.net.Uri;
10 import android.os.AsyncTask; 10 import android.os.AsyncTask;
(...skipping 334 matching lines...) Expand 10 before | Expand all | Expand 10 after
345 }; 345 };
346 final UrlRequest request = mCronetContext.createRequest(mUrl.toS tring(), 346 final UrlRequest request = mCronetContext.createRequest(mUrl.toS tring(),
347 new Listener(buffer, completionCallback), mWorkQueueExec utor); 347 new Listener(buffer, completionCallback), mWorkQueueExec utor);
348 if (mDirection == Direction.UP) { 348 if (mDirection == Direction.UP) {
349 request.setUploadDataProvider(new Uploader(buffer), mWorkQue ueExecutor); 349 request.setUploadDataProvider(new Uploader(buffer), mWorkQue ueExecutor);
350 request.addHeader("Content-Type", "application/octet-stream" ); 350 request.addHeader("Content-Type", "application/octet-stream" );
351 } 351 }
352 request.start(); 352 request.start();
353 } 353 }
354 354
355 private class Uploader implements UploadDataProvider { 355 private class Uploader extends UploadDataProvider {
356 private final ByteBuffer mBuffer; 356 private final ByteBuffer mBuffer;
357 private int mRemainingBytes; 357 private int mRemainingBytes;
358 358
359 Uploader(ByteBuffer buffer) { 359 Uploader(ByteBuffer buffer) {
360 mBuffer = buffer; 360 mBuffer = buffer;
361 mRemainingBytes = mLength; 361 mRemainingBytes = mLength;
362 } 362 }
363 363
364 public long getLength() { 364 public long getLength() {
365 return mLength; 365 return mLength;
(...skipping 12 matching lines...) Expand all
378 byteBuffer.put(mBuffer); 378 byteBuffer.put(mBuffer);
379 mRemainingBytes -= mBuffer.position(); 379 mRemainingBytes -= mBuffer.position();
380 uploadDataSink.onReadSucceeded(false); 380 uploadDataSink.onReadSucceeded(false);
381 } 381 }
382 382
383 public void rewind(UploadDataSink uploadDataSink) { 383 public void rewind(UploadDataSink uploadDataSink) {
384 uploadDataSink.onRewindError(new Exception("no rewinding")); 384 uploadDataSink.onRewindError(new Exception("no rewinding"));
385 } 385 }
386 } 386 }
387 387
388 private class Listener implements UrlRequestListener { 388 private class Listener extends UrlRequestListener {
389 private final ByteBuffer mBuffer; 389 private final ByteBuffer mBuffer;
390 private final Runnable mCompletionCallback; 390 private final Runnable mCompletionCallback;
391 391
392 Listener(ByteBuffer buffer, Runnable completionCallback) { 392 Listener(ByteBuffer buffer, Runnable completionCallback) {
393 mBuffer = buffer; 393 mBuffer = buffer;
394 mCompletionCallback = completionCallback; 394 mCompletionCallback = completionCallback;
395 } 395 }
396 396
397 @Override 397 @Override
398 public void onResponseStarted(UrlRequest request, ResponseInfo i nfo) { 398 public void onResponseStarted(UrlRequest request, ResponseInfo i nfo) {
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after
586 } 586 }
587 587
588 @Override 588 @Override
589 public void onCreate(Bundle savedInstanceState) { 589 public void onCreate(Bundle savedInstanceState) {
590 super.onCreate(savedInstanceState); 590 super.onCreate(savedInstanceState);
591 mConfig = getIntent().getData(); 591 mConfig = getIntent().getData();
592 // Execute benchmarks on another thread to avoid networking on main thre ad. 592 // Execute benchmarks on another thread to avoid networking on main thre ad.
593 new BenchmarkTask().execute(); 593 new BenchmarkTask().execute();
594 } 594 }
595 } 595 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698