Index: components/cronet/android/cronet_url_request_context_adapter.cc |
diff --git a/components/cronet/android/cronet_url_request_context_adapter.cc b/components/cronet/android/cronet_url_request_context_adapter.cc |
index eac1ea4f0c35d17b4e7719c70d6e212ab0357a31..c6a4a51602e3eed46b1b6c2ff336d5e521c6b68b 100644 |
--- a/components/cronet/android/cronet_url_request_context_adapter.cc |
+++ b/components/cronet/android/cronet_url_request_context_adapter.cc |
@@ -107,7 +107,8 @@ class BasicNetworkDelegate : public net::NetworkDelegateImpl { |
namespace cronet { |
-CronetURLRequestContextAdapter::CronetURLRequestContextAdapter() { |
+CronetURLRequestContextAdapter::CronetURLRequestContextAdapter() |
+ : is_context_initialized_(false) { |
} |
CronetURLRequestContextAdapter::~CronetURLRequestContextAdapter() { |
@@ -131,6 +132,11 @@ void CronetURLRequestContextAdapter::Initialize( |
java_init_network_thread)); |
} |
+void CronetURLRequestContextAdapter::InitRequestContextOnMainThread() { |
+ proxy_config_service_.reset(net::ProxyService::CreateSystemProxyConfigService( |
xunjieli
2015/01/05 14:48:03
I wonder whether it makes a difference for each co
mef
2015/01/05 16:59:21
CreateSystemProxyConfigService takes io_task_runne
mmenke
2015/01/05 18:20:39
I'm not really a big fan of globals, unless they'r
|
+ GetNetworkTaskRunner(), NULL)); |
xunjieli
2015/01/05 14:48:03
I think we moved the task of InitializeOnNetworkTh
mef
2015/01/05 16:59:21
Definitely, thanks for spotting that. Done.
|
+} |
+ |
void CronetURLRequestContextAdapter::InitializeOnNetworkThread( |
scoped_ptr<URLRequestContextConfig> config, |
const base::Closure& java_init_network_thread) { |
@@ -189,6 +195,12 @@ void CronetURLRequestContextAdapter::InitializeOnNetworkThread( |
} |
java_init_network_thread.Run(); |
+ |
+ is_context_initialized_ = true; |
+ while (!tasks_waiting_for_context_.empty()) { |
+ tasks_waiting_for_context_.front().Run(); |
+ tasks_waiting_for_context_.pop(); |
+ } |
} |
void CronetURLRequestContextAdapter::Destroy() { |
@@ -208,6 +220,25 @@ net::URLRequestContext* CronetURLRequestContextAdapter::GetURLRequestContext() { |
return context_.get(); |
} |
+void CronetURLRequestContextAdapter::PostTaskToNetworkThread( |
+ const tracked_objects::Location& posted_from, |
+ const RunAfterContextInitTask& callback) { |
+ GetNetworkTaskRunner()->PostTask( |
+ posted_from, base::Bind(&CronetURLRequestContextAdapter:: |
+ RunTaskAfterContextInitOnNetworkThread, |
+ base::Unretained(this), callback)); |
+} |
+ |
+void CronetURLRequestContextAdapter::RunTaskAfterContextInitOnNetworkThread( |
+ const RunAfterContextInitTask& callback) { |
+ DCHECK(GetNetworkTaskRunner()->BelongsToCurrentThread()); |
+ if (is_context_initialized_) { |
+ callback.Run(); |
+ return; |
+ } |
+ tasks_waiting_for_context_.push(callback); |
+} |
+ |
scoped_refptr<base::SingleThreadTaskRunner> |
CronetURLRequestContextAdapter::GetNetworkTaskRunner() const { |
return network_thread_->task_runner(); |