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); |
+ } |
+ })); |
} |
})); |
} |