Home
last modified time | relevance | path

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

123

/external/chromium_org/chrome/browser/sync_file_system/local/
Dcanned_syncable_file_system.cc219 io_task_runner_(io_task_runner), in CannedSyncableFileSystem()
238 io_task_runner_.get(), in SetUp()
254 io_task_runner_.get(), in SetUp()
272 EnsureLastTaskRuns(io_task_runner_.get()); in TearDown()
288 io_task_runner_->PostTask( in OpenFileSystem()
301 io_task_runner_.get(), in OpenFileSystem()
324 VerifySameTaskRunner(io_task_runner_.get(), in MaybeInitializeFileSystemContext()
325 sync_context->io_task_runner_.get()); in MaybeInitializeFileSystemContext()
339 io_task_runner_.get(), in CreateDirectory()
348 io_task_runner_.get(), in CreateFile()
[all …]
Dlocal_file_sync_context.cc55 io_task_runner_(io_task_runner), in LocalFileSyncContext()
90 io_task_runner_->PostTask( in MaybeInitializeFileSystemContext()
104 io_task_runner_->PostTask( in ShutdownOnUIThread()
184 io_task_runner_->PostTask( in FinalizeSnapshotSync()
211 io_task_runner_->PostTask( in FinalizeExclusiveSync()
225 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in PrepareForSync()
227 io_task_runner_->PostTask( in PrepareForSync()
234 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in PrepareForSync()
252 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in RegisterURLForWaitingSync()
254 io_task_runner_->PostTask( in RegisterURLForWaitingSync()
[all …]
Dlocal_file_sync_context_unittest.cc69 io_task_runner_ = BrowserThread::GetMessageLoopProxyForThread( in SetUp()
178 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in StartModifyFileOnIOThread()
181 io_task_runner_->PostTask( in StartModifyFileOnIOThread()
187 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); in StartModifyFileOnIOThread()
202 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); in DidModifyFile()
234 io_task_runner_.get(), in PrepareForSync_Basic()
239 ui_task_runner_.get(), io_task_runner_.get()); in PrepareForSync_Basic()
286 io_task_runner_.get(), in PrepareForSync_WriteDuringSync()
291 ui_task_runner_.get(), io_task_runner_.get()); in PrepareForSync_WriteDuringSync()
353 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in sync_file_system::LocalFileSyncContextTest
[all …]
/external/chromium_org/storage/browser/blob/
Dblob_data_handle.cc41 : io_task_runner_(task_runner), in BlobDataHandle()
43 DCHECK(io_task_runner_.get()); in BlobDataHandle()
44 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in BlobDataHandle()
48 io_task_runner_ = other.io_task_runner_; in BlobDataHandle()
56 io_task_runner_->ReleaseSoon(FROM_HERE, raw); in ~BlobDataHandle()
60 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in data()
/external/chromium_org/components/policy/core/common/cloud/
Dexternal_policy_data_updater_unittest.cc73 scoped_refptr<base::TestSimpleTaskRunner> io_task_runner_; member in policy::ExternalPolicyDataUpdaterTest
81 io_task_runner_ = new base::TestSimpleTaskRunner(); in SetUp()
86 io_task_runner_, in CreateUpdater()
100 io_task_runner_->RunUntilIdle(); in RequestExternalDataFetch()
145 io_task_runner_->RunUntilIdle(); in TEST_F()
181 io_task_runner_->RunUntilIdle(); in TEST_F()
216 io_task_runner_->RunUntilIdle(); in TEST_F()
250 io_task_runner_->RunUntilIdle(); in TEST_F()
284 io_task_runner_->RunUntilIdle(); in TEST_F()
294 io_task_runner_->RunUntilIdle(); in TEST_F()
[all …]
Dpolicy_header_io_helper.cc20 io_task_runner_(task_runner), in PolicyHeaderIOHelper()
30 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in AddPolicyHeaders()
41 io_task_runner_->PostTask( in UpdateHeader()
49 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in UpdateHeaderOnIOThread()
54 io_task_runner_->PostTask( in SetServerURLForTest()
63 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in SetServerURLOnIOThread()
Dexternal_policy_data_fetcher.cc82 io_task_runner_(io_task_runner), in ExternalPolicyDataFetcher()
106 io_task_runner_->PostTask( in StartJob()
122 io_task_runner_->PostTask( in CancelJob()
152 : io_task_runner_(io_task_runner), in ExternalPolicyDataFetcherBackend()
159 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ~ExternalPolicyDataFetcherBackend()
167 task_runner, io_task_runner_, weak_factory_.GetWeakPtr())); in CreateFrontend()
172 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in StartJob()
188 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in CancelJob()
202 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnURLFetchComplete()
249 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnURLFetchDownloadProgress()
Dexternal_policy_data_fetcher_unittest.cc53 scoped_refptr<base::TestSimpleTaskRunner> io_task_runner_; member in policy::ExternalPolicyDataFetcherTest
76 io_task_runner_ = new base::TestSimpleTaskRunner(); in SetUp()
79 io_task_runner_, in SetUp()
91 io_task_runner_->RunUntilIdle(); in StartJob()
306 io_task_runner_->RunUntilIdle(); in TEST_F()
465 io_task_runner_->RunUntilIdle(); in TEST_F()
Dcloud_policy_manager.cc34 io_task_runner_(io_task_runner) { in CloudPolicyManager()
135 io_task_runner_)); in CreateComponentCloudPolicyService()
Dexternal_policy_data_fetcher.h105 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; variable
165 scoped_refptr<base::SequencedTaskRunner> io_task_runner_;
/external/chromium_org/media/base/
Duser_input_monitor_linux.cc70 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in media::__anon1bcb34530111::UserInputMonitorLinuxCore
103 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in media::__anon1bcb34530111::UserInputMonitorLinux
112 : io_task_runner_(io_task_runner), in UserInputMonitorLinuxCore()
130 DCHECK(io_task_runner_->BelongsToCurrentThread()); in WillDestroyCurrentMessageLoop()
140 DCHECK(io_task_runner_->BelongsToCurrentThread()); in StartMonitor()
247 DCHECK(io_task_runner_->BelongsToCurrentThread()); in StopMonitor()
279 DCHECK(io_task_runner_->BelongsToCurrentThread()); in OnFileCanReadWithoutBlocking()
292 DCHECK(io_task_runner_->BelongsToCurrentThread()); in ProcessXEvent()
332 : io_task_runner_(io_task_runner), in UserInputMonitorLinux()
336 if (!io_task_runner_->DeleteSoon(FROM_HERE, core_)) in ~UserInputMonitorLinux()
[all …]
/external/chromium_org/ipc/mojo/
Dipc_channel_mojo_host.cc33 scoped_refptr<base::TaskRunner> io_task_runner_; member in IPC::ChannelMojoHost::ChannelDelegate
42 : io_task_runner_(io_task_runner), weak_factory_(this) { in ChannelDelegate()
66 return io_task_runner_; in GetIOTaskRunner()
76 io_task_runner_->PostTask( in DeleteThisSoon()
88 io_task_runner_(io_task_runner), in ChannelMojoHost()
96 if (io_task_runner_ == base::MessageLoop::current()->message_loop_proxy()) { in OnClientLaunched()
99 io_task_runner_->PostTask(FROM_HERE, in OnClientLaunched()
/external/chromium_org/components/component_updater/test/
Durl_request_post_interceptor.cc56 : url_(url), io_task_runner_(io_task_runner), hit_count_(0) { in URLRequestPostInterceptor()
60 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ~URLRequestPostInterceptor()
145 : scheme_(scheme), hostname_(hostname), io_task_runner_(io_task_runner) {} in Delegate()
148 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in Register()
154 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in Unregister()
164 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OnCreateInterceptor()
176 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in MaybeInterceptRequest()
233 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in component_updater::URLRequestPostInterceptor::Delegate
244 io_task_runner_(io_task_runner), in URLRequestPostInterceptorFactory()
248 io_task_runner_->PostTask( in URLRequestPostInterceptorFactory()
[all …]
Durl_request_post_interceptor.h118 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; variable
144 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; variable
/external/chromium_org/remoting/host/
Dconfig_file_watcher.cc82 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in remoting::ConfigFileWatcherImpl
114 io_task_runner_(io_task_runner), in ConfigFileWatcherImpl()
125 io_task_runner_->PostTask( in Watch()
131 DCHECK(io_task_runner_->BelongsToCurrentThread()); in WatchOnIoThread()
162 io_task_runner_->PostTask( in StopWatching()
172 DCHECK(io_task_runner_->BelongsToCurrentThread()); in FinishStopping()
180 DCHECK(io_task_runner_->BelongsToCurrentThread()); in OnConfigUpdated()
203 DCHECK(io_task_runner_->BelongsToCurrentThread()); in ReloadConfig()
Dipc_desktop_environment_unittest.cc177 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in remoting::IpcDesktopEnvironmentTest
238 io_task_runner_ = AutoThread::CreateWithType( in SetUp()
283 io_task_runner_, in SetUp()
380 EXPECT_TRUE(io_task_runner_.get()); in CreateDesktopProcess()
388 io_task_runner_.get()); in CreateDesktopProcess()
392 io_task_runner_, in CreateDesktopProcess()
447 io_task_runner_ = NULL; in TEST_F()
476 io_task_runner_ = NULL; in TEST_F()
504 io_task_runner_ = NULL; in TEST_F()
540 io_task_runner_ = NULL; in TEST_F()
[all …]
Ddesktop_process_unittest.cc149 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in remoting::DesktopProcessTest
181 io_task_runner_.get()); in ConnectNetworkChannel()
228 io_task_runner_ = NULL; in DisconnectChannels()
245 io_task_runner_ = AutoThread::CreateWithType( in RunDesktopProcess()
252 io_task_runner_.get()); in RunDesktopProcess()
264 DesktopProcess desktop_process(ui_task_runner, io_task_runner_, channel_name); in RunDesktopProcess()
Ddaemon_process.h147 return io_task_runner_; in io_task_runner()
164 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; variable
/external/chromium_org/chrome/browser/policy/cloud/
Dtest_request_interceptor.cc175 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in policy::TestRequestInterceptor::Delegate
186 : hostname_(hostname), io_task_runner_(io_task_runner) {} in Delegate()
193 CHECK(io_task_runner_->RunsTasksOnCurrentThread()); in MaybeInterceptRequest()
213 CHECK(io_task_runner_->RunsTasksOnCurrentThread()); in GetPendingSize()
219 CHECK(io_task_runner_->RunsTasksOnCurrentThread()); in PushJobCallback()
226 io_task_runner_(io_task_runner) { in TestRequestInterceptor()
227 delegate_ = new Delegate(hostname_, io_task_runner_); in TestRequestInterceptor()
283 io_task_runner_->PostTask(FROM_HERE, task); in PostToIOAndWait()
285 io_task_runner_->PostTask( in PostToIOAndWait()
/external/chromium_org/remoting/host/win/
Dwts_session_process_delegate.cc105 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in remoting::WtsSessionProcessDelegate::Core
150 io_task_runner_(io_task_runner), in Core()
209 io_task_runner_->PostTask( in Initialize()
284 DCHECK(io_task_runner_->BelongsToCurrentThread()); in OnIOCompleted()
386 io_task_runner_)); in DoLaunchProcess()
434 DCHECK(io_task_runner_->BelongsToCurrentThread()); in DrainJobNotifications()
451 io_task_runner_->PostTask(FROM_HERE, base::Bind( in DrainJobNotificationsCompleted()
458 DCHECK(io_task_runner_->BelongsToCurrentThread()); in InitializeJob()
/external/chromium_org/storage/browser/fileapi/
Dfile_system_context.cc143 : io_task_runner_(io_task_runner), in FileSystemContext()
234 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in Shutdown()
235 io_task_runner_->PostTask( in Shutdown()
330 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OpenFileSystem()
357 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in ResolveURL()
361 io_task_runner_->PostTask( in ResolveURL()
404 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in DeleteFileSystem()
521 if (!io_task_runner_->RunsTasksOnCurrentThread() && in DeleteOnCorrectThread()
522 io_task_runner_->DeleteSoon(FROM_HERE, this)) { in DeleteOnCorrectThread()
612 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in DidOpenFileSystemForResolveURL()
/external/chromium_org/chrome/browser/safe_browsing/
Ddownload_feedback_unittest.cc107 io_task_runner_(content::BrowserThread::GetMessageLoopProxyForThread( in DownloadFeedbackTest()
110 new net::TestURLRequestContextGetter(io_task_runner_)), in DownloadFeedbackTest()
112 EXPECT_NE(io_task_runner_, file_task_runner_); in DownloadFeedbackTest()
145 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in safe_browsing::DownloadFeedbackTest
/external/chromium_org/chrome/browser/chromeos/policy/
Ddevice_local_account_external_data_service.cc28 io_task_runner_(io_task_runner) { in DeviceLocalAccountExternalDataService()
81 io_task_runner_, in GetExternalDataManager()
Dcloud_external_data_manager_base.cc343 io_task_runner_(io_task_runner), in CloudExternalDataManagerBase()
351 io_task_runner_->DeleteSoon(FROM_HERE, in ~CloudExternalDataManagerBase()
412 new ExternalPolicyDataFetcherBackend(io_task_runner_, in Connect()
423 io_task_runner_->DeleteSoon(FROM_HERE, in Disconnect()
/external/chromium_org/components/policy/core/browser/
Durl_blacklist_manager.cc406 io_task_runner_(io_task_runner), in URLBlacklistManager()
459 io_task_runner_->PostTask(FROM_HERE, in Update()
468 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in UpdateOnIO()
483 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in SetBlacklist()
488 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in IsURLBlocked()
494 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in IsRequestBlocked()

123