| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 } |
| OLD | NEW |