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 372 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
383 private class Listener extends UrlRequestListener { | 383 private class Listener extends UrlRequestListener { |
384 private final ByteBuffer mBuffer; | 384 private final ByteBuffer mBuffer; |
385 private final Runnable mCompletionCallback; | 385 private final Runnable mCompletionCallback; |
386 | 386 |
387 Listener(ByteBuffer buffer, Runnable completionCallback) { | 387 Listener(ByteBuffer buffer, Runnable completionCallback) { |
388 mBuffer = buffer; | 388 mBuffer = buffer; |
389 mCompletionCallback = completionCallback; | 389 mCompletionCallback = completionCallback; |
390 } | 390 } |
391 | 391 |
392 @Override | 392 @Override |
393 public void onResponseStarted(UrlRequest request, ResponseInfo i
nfo) { | 393 public void onResponseStarted(UrlRequest request, UrlResponseInf
o info) { |
394 mBuffer.clear(); | 394 mBuffer.clear(); |
395 request.readNew(mBuffer); | 395 request.readNew(mBuffer); |
396 } | 396 } |
397 | 397 |
398 @Override | 398 @Override |
399 public void onReceivedRedirect( | 399 public void onReceivedRedirect( |
400 UrlRequest request, ResponseInfo info, String newLocatio
nUrl) { | 400 UrlRequest request, UrlResponseInfo info, String newLoca
tionUrl) { |
401 request.followRedirect(); | 401 request.followRedirect(); |
402 } | 402 } |
403 | 403 |
404 @Override | 404 @Override |
405 public void onReadCompleted( | 405 public void onReadCompleted( |
406 UrlRequest request, ResponseInfo info, ByteBuffer byteBu
ffer) { | 406 UrlRequest request, UrlResponseInfo info, ByteBuffer byt
eBuffer) { |
407 mBuffer.clear(); | 407 mBuffer.clear(); |
408 request.readNew(mBuffer); | 408 request.readNew(mBuffer); |
409 } | 409 } |
410 | 410 |
411 @Override | 411 @Override |
412 public void onSucceeded(UrlRequest request, ExtendedResponseInfo
info) { | 412 public void onSucceeded(UrlRequest request, UrlResponseInfo info
) { |
413 mCompletionCallback.run(); | 413 mCompletionCallback.run(); |
414 } | 414 } |
415 | 415 |
416 @Override | 416 @Override |
417 public void onFailed(UrlRequest request, ResponseInfo info, UrlR
equestException e) { | 417 public void onFailed( |
| 418 UrlRequest request, UrlResponseInfo info, UrlRequestExce
ption e) { |
418 System.out.println("Async request failed with " + e); | 419 System.out.println("Async request failed with " + e); |
419 mFailed = true; | 420 mFailed = true; |
420 } | 421 } |
421 } | 422 } |
422 | 423 |
423 private void postToWorkQueue(Runnable task) { | 424 private void postToWorkQueue(Runnable task) { |
424 try { | 425 try { |
425 mWorkQueue.put(task); | 426 mWorkQueue.put(task); |
426 } catch (InterruptedException e) { | 427 } catch (InterruptedException e) { |
427 mFailed = true; | 428 mFailed = true; |
(...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
579 } | 580 } |
580 | 581 |
581 @Override | 582 @Override |
582 public void onCreate(Bundle savedInstanceState) { | 583 public void onCreate(Bundle savedInstanceState) { |
583 super.onCreate(savedInstanceState); | 584 super.onCreate(savedInstanceState); |
584 mConfig = getIntent().getData(); | 585 mConfig = getIntent().getData(); |
585 // Execute benchmarks on another thread to avoid networking on main thre
ad. | 586 // Execute benchmarks on another thread to avoid networking on main thre
ad. |
586 new BenchmarkTask().execute(); | 587 new BenchmarkTask().execute(); |
587 } | 588 } |
588 } | 589 } |
OLD | NEW |