| 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 |