| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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.impl; | 5 package org.chromium.net.impl; |
| 6 | 6 |
| 7 import android.os.SystemClock; | 7 import android.os.SystemClock; |
| 8 import android.support.annotation.Nullable; | 8 import android.support.annotation.Nullable; |
| 9 import android.util.Log; | 9 import android.util.Log; |
| 10 | 10 |
| 11 import org.chromium.base.VisibleForTesting; | 11 import org.chromium.base.VisibleForTesting; |
| 12 import org.chromium.base.annotations.CalledByNative; | 12 import org.chromium.base.annotations.CalledByNative; |
| 13 import org.chromium.base.annotations.JNIAdditionalImport; | 13 import org.chromium.base.annotations.JNIAdditionalImport; |
| 14 import org.chromium.base.annotations.JNINamespace; | 14 import org.chromium.base.annotations.JNINamespace; |
| 15 import org.chromium.base.annotations.NativeClassQualifiedName; | 15 import org.chromium.base.annotations.NativeClassQualifiedName; |
| 16 import org.chromium.net.CronetEngine.UrlRequestInfo; | |
| 17 import org.chromium.net.CronetEngine.UrlRequestMetrics; | |
| 18 import org.chromium.net.Preconditions; | 16 import org.chromium.net.Preconditions; |
| 19 import org.chromium.net.QuicException; | 17 import org.chromium.net.QuicException; |
| 18 import org.chromium.net.RequestFinishedInfo; |
| 20 import org.chromium.net.RequestPriority; | 19 import org.chromium.net.RequestPriority; |
| 21 import org.chromium.net.UploadDataProvider; | 20 import org.chromium.net.UploadDataProvider; |
| 22 import org.chromium.net.UrlRequest; | 21 import org.chromium.net.UrlRequest; |
| 23 import org.chromium.net.UrlRequestException; | 22 import org.chromium.net.UrlRequestException; |
| 23 import org.chromium.net.UrlRequestMetrics; |
| 24 import org.chromium.net.UrlResponseInfo; | 24 import org.chromium.net.UrlResponseInfo; |
| 25 | 25 |
| 26 import java.nio.ByteBuffer; | 26 import java.nio.ByteBuffer; |
| 27 import java.util.AbstractMap; | 27 import java.util.AbstractMap; |
| 28 import java.util.ArrayList; | 28 import java.util.ArrayList; |
| 29 import java.util.Collection; | 29 import java.util.Collection; |
| 30 import java.util.List; | 30 import java.util.List; |
| 31 import java.util.Map; | 31 import java.util.Map; |
| 32 import java.util.concurrent.Executor; | 32 import java.util.concurrent.Executor; |
| 33 import java.util.concurrent.RejectedExecutionException; | 33 import java.util.concurrent.RejectedExecutionException; |
| (...skipping 655 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 689 private void onStatus(final UrlRequest.StatusListener listener, final int lo
adState) { | 689 private void onStatus(final UrlRequest.StatusListener listener, final int lo
adState) { |
| 690 Runnable task = new Runnable() { | 690 Runnable task = new Runnable() { |
| 691 @Override | 691 @Override |
| 692 public void run() { | 692 public void run() { |
| 693 listener.onStatus(UrlRequest.Status.convertLoadState(loadState))
; | 693 listener.onStatus(UrlRequest.Status.convertLoadState(loadState))
; |
| 694 } | 694 } |
| 695 }; | 695 }; |
| 696 postTaskToExecutor(task); | 696 postTaskToExecutor(task); |
| 697 } | 697 } |
| 698 | 698 |
| 699 UrlRequestInfo getRequestInfo() { | 699 RequestFinishedInfo getRequestInfo() { |
| 700 return new UrlRequestInfo(mInitialUrl, mRequestAnnotations, | 700 return new RequestFinishedInfo(mInitialUrl, mRequestAnnotations, |
| 701 (mRequestMetricsAccumulator != null ? mRequestMetricsAccumulator
.getRequestMetrics() | 701 (mRequestMetricsAccumulator != null ? mRequestMetricsAccumulator
.getRequestMetrics() |
| 702 : EMPTY_METRICS), | 702 : EMPTY_METRICS), |
| 703 mResponseInfo); | 703 mResponseInfo); |
| 704 } | 704 } |
| 705 | 705 |
| 706 private final class UrlRequestMetricsAccumulator { | 706 private final class UrlRequestMetricsAccumulator { |
| 707 @Nullable | 707 @Nullable |
| 708 private Long mRequestStartTime; | 708 private Long mRequestStartTime; |
| 709 @Nullable | 709 @Nullable |
| 710 private Long mTtfbMs; | 710 private Long mTtfbMs; |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 757 @NativeClassQualifiedName("CronetURLRequestAdapter") | 757 @NativeClassQualifiedName("CronetURLRequestAdapter") |
| 758 private native boolean nativeReadData( | 758 private native boolean nativeReadData( |
| 759 long nativePtr, ByteBuffer byteBuffer, int position, int capacity); | 759 long nativePtr, ByteBuffer byteBuffer, int position, int capacity); |
| 760 | 760 |
| 761 @NativeClassQualifiedName("CronetURLRequestAdapter") | 761 @NativeClassQualifiedName("CronetURLRequestAdapter") |
| 762 private native void nativeDestroy(long nativePtr, boolean sendOnCanceled); | 762 private native void nativeDestroy(long nativePtr, boolean sendOnCanceled); |
| 763 | 763 |
| 764 @NativeClassQualifiedName("CronetURLRequestAdapter") | 764 @NativeClassQualifiedName("CronetURLRequestAdapter") |
| 765 private native void nativeGetStatus(long nativePtr, UrlRequest.StatusListene
r listener); | 765 private native void nativeGetStatus(long nativePtr, UrlRequest.StatusListene
r listener); |
| 766 } | 766 } |
| OLD | NEW |