| Index: components/cronet/android/api/src/org/chromium/net/JavaUrlRequest.java
|
| diff --git a/components/cronet/android/api/src/org/chromium/net/JavaUrlRequest.java b/components/cronet/android/api/src/org/chromium/net/JavaUrlRequest.java
|
| index b4dbd875a9d6f429c6b7e46f24f5725296cd70cc..e48fa899034b9a5913c506abf076e08675d3af5b 100644
|
| --- a/components/cronet/android/api/src/org/chromium/net/JavaUrlRequest.java
|
| +++ b/components/cronet/android/api/src/org/chromium/net/JavaUrlRequest.java
|
| @@ -326,7 +326,7 @@ final class JavaUrlRequest implements UrlRequest {
|
| }
|
|
|
| void startRead() {
|
| - mUserExecutor.execute(uploadErrorSetting(new CheckedRunnable() {
|
| + mExecutor.execute(errorSetting(State.STARTED, new CheckedRunnable() {
|
| @Override
|
| public void run() throws Exception {
|
| if (mOutputChannel == null) {
|
| @@ -336,7 +336,12 @@ final class JavaUrlRequest implements UrlRequest {
|
| mOutputChannel = Channels.newChannel(mUrlConnection.getOutputStream());
|
| }
|
| mSinkState.set(SinkState.AWAITING_READ_RESULT);
|
| - mUploadProvider.read(OutputStreamDataSink.this, mBuffer);
|
| + mUserExecutor.execute(uploadErrorSetting(new CheckedRunnable() {
|
| + @Override
|
| + public void run() throws Exception {
|
| + mUploadProvider.read(OutputStreamDataSink.this, mBuffer);
|
| + }
|
| + }));
|
| }
|
| }));
|
| }
|
|
|