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 |