Home
last modified time | relevance | path

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

12

/external/chromium_org/chrome/browser/sync_file_system/local/
Dcanned_syncable_file_system.cc213 io_task_runner_(io_task_runner), in CannedSyncableFileSystem()
231 io_task_runner_.get(), in SetUp()
245 io_task_runner_.get(), in SetUp()
261 EnsureLastTaskRuns(io_task_runner_.get()); in TearDown()
276 io_task_runner_->PostTask( in OpenFileSystem()
288 io_task_runner_.get(), in OpenFileSystem()
310 VerifySameTaskRunner(io_task_runner_.get(), in MaybeInitializeFileSystemContext()
311 sync_context->io_task_runner_.get()); in MaybeInitializeFileSystemContext()
324 io_task_runner_.get(), in CreateDirectory()
334 io_task_runner_.get(), in CreateFile()
[all …]
Dlocal_file_sync_context.cc54 io_task_runner_(io_task_runner), in LocalFileSyncContext()
86 io_task_runner_->PostTask( in MaybeInitializeFileSystemContext()
98 io_task_runner_->PostTask( in ShutdownOnUIThread()
180 io_task_runner_->PostTask( in FinalizeSnapshotSync()
207 io_task_runner_->PostTask( in FinalizeExclusiveSync()
221 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in PrepareForSync()
223 io_task_runner_->PostTask( in PrepareForSync()
230 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in PrepareForSync()
248 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in RegisterURLForWaitingSync()
250 io_task_runner_->PostTask( in RegisterURLForWaitingSync()
[all …]
Dlocal_file_sync_context_unittest.cc67 io_task_runner_ = BrowserThread::GetMessageLoopProxyForThread( in SetUp()
176 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in StartModifyFileOnIOThread()
179 io_task_runner_->PostTask( in StartModifyFileOnIOThread()
185 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); in StartModifyFileOnIOThread()
200 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); in DidModifyFile()
231 io_task_runner_.get(), in PrepareForSync_Basic()
235 dir_.path(), ui_task_runner_.get(), io_task_runner_.get()); in PrepareForSync_Basic()
281 io_task_runner_.get(), in PrepareForSync_WriteDuringSync()
285 dir_.path(), ui_task_runner_.get(), io_task_runner_.get()); in PrepareForSync_WriteDuringSync()
348 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in sync_file_system::LocalFileSyncContextTest
[all …]
/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.cc26 io_task_runner_(task_runner), in PolicyHeaderIOHelper()
35 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in AddPolicyHeaders()
47 io_task_runner_->PostTask( in UpdateHeader()
55 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in UpdateHeaderOnIOThread()
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()
131 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_;
Dpolicy_header_io_helper.h52 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; variable
/external/chromium_org/media/base/
Duser_input_monitor_linux.cc70 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in media::__anonb41178460111::UserInputMonitorLinuxCore
103 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_; member in media::__anonb41178460111::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/webkit/browser/blob/
Dblob_data_handle.cc20 io_task_runner_(task_runner) { in BlobDataHandle()
22 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in BlobDataHandle()
28 if (io_task_runner_->RunsTasksOnCurrentThread()) { in ~BlobDataHandle()
37 io_task_runner_->PostTask( in ~BlobDataHandle()
43 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in data()
Dblob_data_handle.h45 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.cc172 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in remoting::IpcDesktopEnvironmentTest
234 io_task_runner_ = AutoThread::CreateWithType( in SetUp()
279 io_task_runner_, in SetUp()
367 EXPECT_TRUE(io_task_runner_.get()); in CreateDesktopProcess()
375 io_task_runner_.get())); in CreateDesktopProcess()
379 io_task_runner_, in CreateDesktopProcess()
442 io_task_runner_ = NULL; in TEST_F()
479 io_task_runner_ = NULL; in TEST_F()
515 io_task_runner_ = NULL; in TEST_F()
555 io_task_runner_ = NULL; in TEST_F()
[all …]
Ddesktop_process_unittest.cc149 scoped_refptr<AutoThreadTaskRunner> io_task_runner_; member in remoting::DesktopProcessTest
182 io_task_runner_.get())); in ConnectNetworkChannel()
229 io_task_runner_ = NULL; in DisconnectChannels()
246 io_task_runner_ = AutoThread::CreateWithType( in RunDesktopProcess()
253 io_task_runner_.get())); in RunDesktopProcess()
265 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
Dipc_desktop_environment.cc81 io_task_runner_(io_task_runner), in IpcDesktopEnvironmentFactory()
99 io_task_runner_, in Create()
/external/chromium_org/chrome/browser/policy/cloud/
Dtest_request_interceptor.cc165 scoped_refptr<base::SequencedTaskRunner> io_task_runner_; member in policy::TestRequestInterceptor::Delegate
176 : hostname_(hostname), io_task_runner_(io_task_runner) {} in Delegate()
183 CHECK(io_task_runner_->RunsTasksOnCurrentThread()); in MaybeCreateJob()
203 CHECK(io_task_runner_->RunsTasksOnCurrentThread()); in GetPendingSize()
209 CHECK(io_task_runner_->RunsTasksOnCurrentThread()); in PushJobCallback()
216 io_task_runner_(io_task_runner) { in TestRequestInterceptor()
217 delegate_ = new Delegate(hostname_, io_task_runner_); in TestRequestInterceptor()
274 io_task_runner_->PostTask(FROM_HERE, task); in PostToIOAndWait()
276 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()
435 DCHECK(io_task_runner_->BelongsToCurrentThread()); in DrainJobNotifications()
452 io_task_runner_->PostTask(FROM_HERE, base::Bind( in DrainJobNotificationsCompleted()
459 DCHECK(io_task_runner_->BelongsToCurrentThread()); in InitializeJob()
/external/chromium_org/webkit/browser/fileapi/
Dfile_system_context.cc117 : io_task_runner_(io_task_runner), in FileSystemContext()
208 if (!io_task_runner_->RunsTasksOnCurrentThread()) { in Shutdown()
209 io_task_runner_->PostTask( in Shutdown()
294 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in OpenFileSystem()
315 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in ResolveURL()
352 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in DeleteFileSystem()
455 if (!io_task_runner_->RunsTasksOnCurrentThread() && in DeleteOnCorrectThread()
456 io_task_runner_->DeleteSoon(FROM_HERE, this)) { in DeleteOnCorrectThread()
546 DCHECK(io_task_runner_->RunsTasksOnCurrentThread()); in DidOpenFileSystemForResolveURL()
/external/chromium_org/chrome/browser/safe_browsing/
Ddownload_feedback_unittest.cc109 io_task_runner_(content::BrowserThread::GetMessageLoopProxyForThread( in DownloadFeedbackTest()
112 new net::TestURLRequestContextGetter(io_task_runner_)), in DownloadFeedbackTest()
114 EXPECT_NE(io_task_runner_, file_task_runner_); in DownloadFeedbackTest()
147 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/chrome/test/chromedriver/chrome/
Dadb_impl.cc77 : io_task_runner_(io_task_runner), port_(port) { in AdbImpl()
78 CHECK(io_task_runner_.get()); in AdbImpl()
222 io_task_runner_->PostTask( in ExecuteCommand()

12