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.cronet_sample_apk; | 5 package org.chromium.cronet_sample_apk; |
6 | 6 |
7 import android.app.Activity; | 7 import android.app.Activity; |
8 import android.app.AlertDialog; | 8 import android.app.AlertDialog; |
9 import android.content.DialogInterface; | 9 import android.content.DialogInterface; |
10 import android.os.Bundle; | 10 import android.os.Bundle; |
11 import android.os.Environment; | 11 import android.os.Environment; |
12 import android.view.LayoutInflater; | 12 import android.view.LayoutInflater; |
13 import android.view.View; | 13 import android.view.View; |
14 import android.widget.EditText; | 14 import android.widget.EditText; |
15 import android.widget.TextView; | 15 import android.widget.TextView; |
16 | 16 |
17 import org.chromium.base.Log; | 17 import org.chromium.base.Log; |
18 import org.chromium.net.CronetEngine; | 18 import org.chromium.net.CronetEngine; |
19 import org.chromium.net.ExtendedResponseInfo; | |
20 import org.chromium.net.ResponseInfo; | |
21 import org.chromium.net.UploadDataProvider; | 19 import org.chromium.net.UploadDataProvider; |
22 import org.chromium.net.UploadDataSink; | 20 import org.chromium.net.UploadDataSink; |
23 import org.chromium.net.UrlRequest; | 21 import org.chromium.net.UrlRequest; |
24 import org.chromium.net.UrlRequestException; | 22 import org.chromium.net.UrlRequestException; |
25 import org.chromium.net.UrlRequestListener; | 23 import org.chromium.net.UrlRequestListener; |
| 24 import org.chromium.net.UrlResponseInfo; |
26 | 25 |
27 import java.io.ByteArrayOutputStream; | 26 import java.io.ByteArrayOutputStream; |
28 import java.io.IOException; | 27 import java.io.IOException; |
29 import java.nio.ByteBuffer; | 28 import java.nio.ByteBuffer; |
30 import java.nio.channels.Channels; | 29 import java.nio.channels.Channels; |
31 import java.nio.channels.WritableByteChannel; | 30 import java.nio.channels.WritableByteChannel; |
32 import java.util.concurrent.Executor; | 31 import java.util.concurrent.Executor; |
33 import java.util.concurrent.Executors; | 32 import java.util.concurrent.Executors; |
34 | 33 |
35 /** | 34 /** |
36 * Activity for managing the Cronet Sample. | 35 * Activity for managing the Cronet Sample. |
37 */ | 36 */ |
38 public class CronetSampleActivity extends Activity { | 37 public class CronetSampleActivity extends Activity { |
39 private static final String TAG = "cr.CronetSample"; | 38 private static final String TAG = "cr.CronetSample"; |
40 | 39 |
41 private CronetEngine mCronetEngine; | 40 private CronetEngine mCronetEngine; |
42 | 41 |
43 private String mUrl; | 42 private String mUrl; |
44 private boolean mLoading = false; | 43 private boolean mLoading = false; |
45 private int mHttpStatusCode = 0; | 44 private int mHttpStatusCode = 0; |
46 private TextView mResultText; | 45 private TextView mResultText; |
47 private TextView mReceiveDataText; | 46 private TextView mReceiveDataText; |
48 | 47 |
49 class SimpleUrlRequestListener extends UrlRequestListener { | 48 class SimpleUrlRequestListener extends UrlRequestListener { |
50 private ByteArrayOutputStream mBytesReceived = new ByteArrayOutputStream
(); | 49 private ByteArrayOutputStream mBytesReceived = new ByteArrayOutputStream
(); |
51 private WritableByteChannel mReceiveChannel = Channels.newChannel(mBytes
Received); | 50 private WritableByteChannel mReceiveChannel = Channels.newChannel(mBytes
Received); |
52 | 51 |
53 @Override | 52 @Override |
54 public void onReceivedRedirect( | 53 public void onReceivedRedirect( |
55 UrlRequest request, ResponseInfo info, String newLocationUrl) { | 54 UrlRequest request, UrlResponseInfo info, String newLocationUrl)
{ |
56 Log.i(TAG, "****** onReceivedRedirect ******"); | 55 Log.i(TAG, "****** onReceivedRedirect ******"); |
57 request.followRedirect(); | 56 request.followRedirect(); |
58 } | 57 } |
59 | 58 |
60 @Override | 59 @Override |
61 public void onResponseStarted(UrlRequest request, ResponseInfo info) { | 60 public void onResponseStarted(UrlRequest request, UrlResponseInfo info)
{ |
62 Log.i(TAG, "****** Response Started ******"); | 61 Log.i(TAG, "****** Response Started ******"); |
63 Log.i(TAG, "*** Headers Are *** " + info.getAllHeaders()); | 62 Log.i(TAG, "*** Headers Are *** " + info.getAllHeaders()); |
64 | 63 |
65 request.read(ByteBuffer.allocateDirect(32 * 1024)); | 64 request.read(ByteBuffer.allocateDirect(32 * 1024)); |
66 } | 65 } |
67 | 66 |
68 @Override | 67 @Override |
69 public void onReadCompleted(UrlRequest request, ResponseInfo info, ByteB
uffer byteBuffer) { | 68 public void onReadCompleted( |
| 69 UrlRequest request, UrlResponseInfo info, ByteBuffer byteBuffer)
{ |
70 Log.i(TAG, "****** onReadCompleted ******" + byteBuffer); | 70 Log.i(TAG, "****** onReadCompleted ******" + byteBuffer); |
71 | 71 |
72 try { | 72 try { |
73 mReceiveChannel.write(byteBuffer); | 73 mReceiveChannel.write(byteBuffer); |
74 } catch (IOException e) { | 74 } catch (IOException e) { |
75 Log.i(TAG, "IOException during ByteBuffer read. Details: ", e); | 75 Log.i(TAG, "IOException during ByteBuffer read. Details: ", e); |
76 } | 76 } |
77 byteBuffer.position(0); | 77 byteBuffer.position(0); |
78 request.read(byteBuffer); | 78 request.read(byteBuffer); |
79 } | 79 } |
80 | 80 |
81 @Override | 81 @Override |
82 public void onSucceeded(UrlRequest request, ExtendedResponseInfo info) { | 82 public void onSucceeded(UrlRequest request, UrlResponseInfo info) { |
83 ResponseInfo responseInfo = info.getResponseInfo(); | 83 mHttpStatusCode = info.getHttpStatusCode(); |
84 mHttpStatusCode = responseInfo.getHttpStatusCode(); | |
85 Log.i(TAG, "****** Request Completed, status code is " + mHttpStatus
Code | 84 Log.i(TAG, "****** Request Completed, status code is " + mHttpStatus
Code |
86 + ", total received bytes is " + info.getTotalReceiv
edBytes()); | 85 + ", total received bytes is " + info.getReceivedByt
esCount()); |
87 | 86 |
88 final String receivedData = mBytesReceived.toString(); | 87 final String receivedData = mBytesReceived.toString(); |
89 final String url = responseInfo.getUrl(); | 88 final String url = info.getUrl(); |
90 final String text = "Completed " + url + " (" + mHttpStatusCode + ")
"; | 89 final String text = "Completed " + url + " (" + mHttpStatusCode + ")
"; |
91 CronetSampleActivity.this.runOnUiThread(new Runnable() { | 90 CronetSampleActivity.this.runOnUiThread(new Runnable() { |
92 public void run() { | 91 public void run() { |
93 mLoading = false; | 92 mLoading = false; |
94 mResultText.setText(text); | 93 mResultText.setText(text); |
95 mReceiveDataText.setText(receivedData); | 94 mReceiveDataText.setText(receivedData); |
96 promptForURL(url); | 95 promptForURL(url); |
97 } | 96 } |
98 }); | 97 }); |
99 } | 98 } |
100 | 99 |
101 @Override | 100 @Override |
102 public void onFailed(UrlRequest request, ResponseInfo info, UrlRequestEx
ception error) { | 101 public void onFailed(UrlRequest request, UrlResponseInfo info, UrlReques
tException error) { |
103 Log.i(TAG, "****** onFailed, error is: " + error.getMessage()); | 102 Log.i(TAG, "****** onFailed, error is: " + error.getMessage()); |
104 | 103 |
105 final String url = mUrl; | 104 final String url = mUrl; |
106 final String text = "Failed " + mUrl + " (" + error.getMessage() + "
)"; | 105 final String text = "Failed " + mUrl + " (" + error.getMessage() + "
)"; |
107 CronetSampleActivity.this.runOnUiThread(new Runnable() { | 106 CronetSampleActivity.this.runOnUiThread(new Runnable() { |
108 public void run() { | 107 public void run() { |
109 mLoading = false; | 108 mLoading = false; |
110 mResultText.setText(text); | 109 mResultText.setText(text); |
111 promptForURL(url); | 110 promptForURL(url); |
112 } | 111 } |
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
243 private void startNetLog() { | 242 private void startNetLog() { |
244 mCronetEngine.startNetLogToFile( | 243 mCronetEngine.startNetLogToFile( |
245 Environment.getExternalStorageDirectory().getPath() + "/cronet_s
ample_netlog.json", | 244 Environment.getExternalStorageDirectory().getPath() + "/cronet_s
ample_netlog.json", |
246 false); | 245 false); |
247 } | 246 } |
248 | 247 |
249 private void stopNetLog() { | 248 private void stopNetLog() { |
250 mCronetEngine.stopNetLog(); | 249 mCronetEngine.stopNetLog(); |
251 } | 250 } |
252 } | 251 } |
OLD | NEW |