Searched refs:io_task_runner_ (Results 1 - 25 of 59) sorted by relevance

123

/external/chromium_org/storage/browser/blob/
H A Dblob_data_handle.cc41 : io_task_runner_(task_runner),
43 DCHECK(io_task_runner_.get());
44 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
48 io_task_runner_ = other.io_task_runner_;
56 io_task_runner_->ReleaseSoon(FROM_HERE, raw);
60 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
/external/chromium_org/components/policy/core/common/cloud/
H A Dpolicy_header_io_helper.cc20 io_task_runner_(task_runner),
30 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
41 io_task_runner_->PostTask(
49 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
54 io_task_runner_->PostTask(
63 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
H A Dexternal_policy_data_fetcher.cc82 io_task_runner_(io_task_runner),
106 io_task_runner_->PostTask(
122 io_task_runner_->PostTask(
152 : io_task_runner_(io_task_runner),
159 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
167 task_runner, io_task_runner_, weak_factory_.GetWeakPtr()));
172 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
188 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
202 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
249 DCHECK(io_task_runner_
[all...]
H A Dexternal_policy_data_updater_unittest.cc73 scoped_refptr<base::TestSimpleTaskRunner> io_task_runner_; member in class:policy::ExternalPolicyDataUpdaterTest
81 io_task_runner_ = new base::TestSimpleTaskRunner();
86 io_task_runner_,
100 io_task_runner_->RunUntilIdle();
145 io_task_runner_->RunUntilIdle();
181 io_task_runner_->RunUntilIdle();
216 io_task_runner_->RunUntilIdle();
250 io_task_runner_->RunUntilIdle();
284 io_task_runner_->RunUntilIdle();
294 io_task_runner_
[all...]
H A Dpolicy_header_io_helper.h62 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::PolicyHeaderIOHelper
H A Dcloud_policy_manager.cc34 io_task_runner_(io_task_runner) {
135 io_task_runner_));
H A Dexternal_policy_data_fetcher.h105 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::ExternalPolicyDataFetcher
108 // accessed via |io_task_runner_| only.
137 // |io_task_runner_| represents the thread that handles network I/O and that
165 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::ExternalPolicyDataFetcherBackend
/external/chromium_org/ipc/mojo/
H A Dipc_channel_mojo_host.cc33 scoped_refptr<base::TaskRunner> io_task_runner_; member in class:IPC::ChannelMojoHost::ChannelDelegate
42 : io_task_runner_(io_task_runner), weak_factory_(this) {
66 return io_task_runner_;
76 io_task_runner_->PostTask(
88 io_task_runner_(io_task_runner),
96 if (io_task_runner_ == base::MessageLoop::current()->message_loop_proxy()) {
99 io_task_runner_->PostTask(FROM_HERE,
H A Dipc_channel_mojo_host.h43 const scoped_refptr<base::TaskRunner> io_task_runner_; member in class:IPC::ChannelMojoHost
/external/chromium_org/remoting/host/
H A Dconfig_file_watcher.cc82 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in class:remoting::ConfigFileWatcherImpl
114 io_task_runner_(io_task_runner),
125 io_task_runner_->PostTask(
131 DCHECK(io_task_runner_->BelongsToCurrentThread());
162 io_task_runner_->PostTask(
172 DCHECK(io_task_runner_->BelongsToCurrentThread());
180 DCHECK(io_task_runner_->BelongsToCurrentThread());
203 DCHECK(io_task_runner_->BelongsToCurrentThread());
H A Ddesktop_process_unittest.cc149 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in class:remoting::DesktopProcessTest
181 io_task_runner_.get());
228 io_task_runner_ = NULL;
245 io_task_runner_ = AutoThread::CreateWithType(
252 io_task_runner_.get());
264 DesktopProcess desktop_process(ui_task_runner, io_task_runner_, channel_name);
H A Dipc_desktop_environment_unittest.cc177 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in class:remoting::IpcDesktopEnvironmentTest
238 io_task_runner_ = AutoThread::CreateWithType(
283 io_task_runner_,
380 EXPECT_TRUE(io_task_runner_.get());
388 io_task_runner_.get());
392 io_task_runner_,
447 io_task_runner_ = NULL;
476 io_task_runner_ = NULL;
504 io_task_runner_ = NULL;
540 io_task_runner_
[all...]
H A Ddaemon_process.h147 return io_task_runner_;
164 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in class:remoting::DaemonProcess
/external/chromium_org/chrome/browser/sync_file_system/local/
H A Dcanned_syncable_file_system.cc219 io_task_runner_(io_task_runner),
238 io_task_runner_.get(),
254 io_task_runner_.get(),
272 EnsureLastTaskRuns(io_task_runner_.get());
288 io_task_runner_->PostTask(
301 io_task_runner_.get(),
324 VerifySameTaskRunner(io_task_runner_.get(),
325 sync_context->io_task_runner_.get());
339 io_task_runner_.get(),
348 io_task_runner_
[all...]
H A Dlocal_file_sync_context.cc55 io_task_runner_(io_task_runner),
90 io_task_runner_->PostTask(
104 io_task_runner_->PostTask(
184 io_task_runner_->PostTask(
211 io_task_runner_->PostTask(
225 if (!io_task_runner_->RunsTasksOnCurrentThread()) {
227 io_task_runner_->PostTask(
234 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
252 if (!io_task_runner_->RunsTasksOnCurrentThread()) {
254 io_task_runner_
[all...]
H A Dlocal_file_sync_context_unittest.cc69 io_task_runner_ = BrowserThread::GetMessageLoopProxyForThread(
178 if (!io_task_runner_->RunsTasksOnCurrentThread()) {
181 io_task_runner_->PostTask(
187 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
202 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
234 io_task_runner_.get(),
239 ui_task_runner_.get(), io_task_runner_.get());
286 io_task_runner_.get(),
291 ui_task_runner_.get(), io_task_runner_.get());
353 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in class:sync_file_system::LocalFileSyncContextTest
[all...]
/external/chromium_org/media/base/
H A Duser_input_monitor_linux.cc70 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in class:media::__anon8577::UserInputMonitorLinuxCore
103 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in class:media::__anon8577::UserInputMonitorLinux
112 : io_task_runner_(io_task_runner),
130 DCHECK(io_task_runner_->BelongsToCurrentThread());
140 DCHECK(io_task_runner_->BelongsToCurrentThread());
247 DCHECK(io_task_runner_->BelongsToCurrentThread());
279 DCHECK(io_task_runner_->BelongsToCurrentThread());
292 DCHECK(io_task_runner_->BelongsToCurrentThread());
332 : io_task_runner_(io_task_runner),
336 if (!io_task_runner_
[all...]
/external/chromium_org/components/component_updater/test/
H A Durl_request_post_interceptor.cc56 : url_(url), io_task_runner_(io_task_runner), hit_count_(0) {
60 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
145 : scheme_(scheme), hostname_(hostname), io_task_runner_(io_task_runner) {}
148 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
154 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
164 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
176 DCHECK(io_task_runner_->RunsTasksOnCurrentThread());
233 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:component_updater::URLRequestPostInterceptor::Delegate
244 io_task_runner_(io_task_runner),
248 io_task_runner_
[all...]
/external/chromium_org/chrome/browser/policy/cloud/
H A Dtest_request_interceptor.cc175 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::TestRequestInterceptor::Delegate
186 : hostname_(hostname), io_task_runner_(io_task_runner) {}
193 CHECK(io_task_runner_->RunsTasksOnCurrentThread());
213 CHECK(io_task_runner_->RunsTasksOnCurrentThread());
219 CHECK(io_task_runner_->RunsTasksOnCurrentThread());
226 io_task_runner_(io_task_runner) {
227 delegate_ = new Delegate(hostname_, io_task_runner_);
283 io_task_runner_->PostTask(FROM_HERE, task);
285 io_task_runner_->PostTask(
H A Dtest_request_interceptor.h78 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::TestRequestInterceptor
/external/chromium_org/chrome/browser/chromeos/policy/
H A Ddevice_local_account_external_data_service.h53 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::DeviceLocalAccountExternalDataService
H A Ddevice_local_account_external_data_service.cc28 io_task_runner_(io_task_runner) {
81 io_task_runner_,
H A Dcloud_external_data_manager_base.h74 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in class:policy::CloudExternalDataManagerBase
81 // the |io_task_runner_|.
/external/chromium_org/components/metrics/net/
H A Dnetwork_metrics_provider.h56 base::TaskRunner* io_task_runner_; member in class:NetworkMetricsProvider
/external/chromium_org/remoting/host/win/
H A Dwts_session_process_delegate.cc105 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in class:remoting::WtsSessionProcessDelegate::Core
150 io_task_runner_(io_task_runner),
209 io_task_runner_->PostTask(
284 DCHECK(io_task_runner_->BelongsToCurrentThread());
386 io_task_runner_)); local
434 DCHECK(io_task_runner_->BelongsToCurrentThread());
451 io_task_runner_->PostTask(FROM_HERE, base::Bind(
458 DCHECK(io_task_runner_->BelongsToCurrentThread());

Completed in 330 milliseconds

123