/external/chromium_org/chrome/browser/media_galleries/win/ |
H A D | mtp_device_delegate_impl_win.h | 72 // Used to represent pending task details. 75 const base::Callback<base::File::Error(void)>& task, 79 const base::Callback<base::File::Error(void)> task; member in struct:MTPDeviceDelegateImplWin::PendingTaskInfo 116 // call-and-reply to a blocking pool thread. |task_info.task| runs on a 119 // If the device is already initialized, post the |task_info.task| 122 // If the device is uninitialized, store the |task_info| in a pending task 137 // successfully initialized, runs the next pending task. 193 // The task runner where the device operation tasks runs. 211 // initialized or when the current task in progress is complete. 214 // Used to make sure only one task i [all...] |
/external/chromium_org/chrome/browser/service_process/ |
H A D | service_process_control_browsertest.cc | 206 // Make sure using the same task for success and failure tasks works. 212 base::Closure task = base::Bind(&DecrementUntilZero, &launch_count); local 213 process->Launch(task, task);
|
/external/chromium_org/chromecast/media/cma/filters/ |
H A D | demuxer_stream_adapter.cc | 32 const base::Closure& task, 53 const base::Closure& task, 55 return task_runner_->PostTask(from_here, task); 113 // Create a new media task runner for the upcoming media timeline. 186 // Updates the timestamp used for task scheduling. 51 PostMediaTask( const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta timestamp) argument
|
/external/chromium_org/content/browser/dom_storage/ |
H A D | dom_storage_task_runner.cc | 38 const base::Closure& task, 45 primary_sequence_token_, from_here, task, 48 // Post a task to call this->PostTask() after the delay. 52 this, from_here, task), 59 const base::Closure& task) { 61 IDtoToken(sequence_id), from_here, task, 91 const base::Closure& task, 93 return message_loop_->PostTask(from_here, task); 99 const base::Closure& task) { 100 return message_loop_->PostTask(from_here, task); 36 PostDelayedTask( const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta delay) argument 56 PostShutdownBlockingTask( const tracked_objects::Location& from_here, SequenceID sequence_id, const base::Closure& task) argument 89 PostDelayedTask( const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta delay) argument 96 PostShutdownBlockingTask( const tracked_objects::Location& from_here, SequenceID sequence_id, const base::Closure& task) argument [all...] |
/external/chromium_org/content/browser/geolocation/ |
H A D | geolocation_provider_impl.cc | 99 base::Closure task; local 107 task = base::Bind(&GeolocationProviderImpl::StopProviders, 119 task = base::Bind(&GeolocationProviderImpl::StartProviders, 124 message_loop()->PostTask(FROM_HERE, task);
|
/external/chromium_org/content/browser/ |
H A D | startup_task_runner_unittest.cc | 29 base::Closure task; member in namespace:content::__anon7435 34 task = arg; 211 // Only the first task should have run, since it failed 217 // After a failed task all remaining tasks should be cancelled 255 // Fake the actual message loop. Each time a task is run a new task should 256 // be added to the queue, hence updating "task". The loop should actually run 257 // at most 3 times (once for each task plus possibly once for the observer), 260 task.Run(); 302 // Fake the actual message loop. Each time a task i [all...] |
/external/chromium_org/content/child/ |
H A D | webthread_impl.cc | 63 void WebThreadImpl::postTask(Task* task) { argument 65 FROM_HERE, base::Bind(&blink::WebThread::Task::run, base::Owned(task))); 68 void WebThreadImpl::postDelayedTask(Task* task, long long delay_ms) { argument 71 base::Bind(&blink::WebThread::Task::run, base::Owned(task)), 104 void WebThreadImplForMessageLoop::postTask(Task* task) { argument 106 FROM_HERE, base::Bind(&blink::WebThread::Task::run, base::Owned(task))); 109 void WebThreadImplForMessageLoop::postDelayedTask(Task* task, argument 113 base::Bind(&blink::WebThread::Task::run, base::Owned(task)),
|
/external/chromium_org/extensions/browser/ |
H A D | lazy_background_task_queue.cc | 67 const PendingTask& task) { 69 task.Run(NULL); 83 // If this is the first enqueued task, and we're not waiting for the 92 task.Run(NULL); 100 tasks_list->push_back(task); 119 // Swap the pending tasks to a temporary, to avoid problems if the task 181 // task queue as well. 64 AddPendingTask( content::BrowserContext* browser_context, const std::string& extension_id, const PendingTask& task) argument
|
/external/chromium_org/jingle/notifier/base/ |
H A D | xmpp_connection_unittest.cc | 235 // We don't destroy XmppConnection's task pump on destruction, but it 243 jingle_glue::MockTask* task = local 248 ON_CALL(*task, ProcessStart()) 250 EXPECT_CALL(*task, ProcessStart()).Times(0); 251 task->Start(); 254 // This should destroy |task_pump|, but |task| still shouldn't run.
|
/external/chromium_org/jingle/notifier/listener/ |
H A D | xmpp_push_client.cc | 150 PushNotificationsSendUpdateTask* task = local 152 task->Start(); 162 SendPingTask* task = new SendPingTask(base_task_.get(), this); local 163 task->Start();
|
/external/chromium_org/mojo/public/cpp/utility/ |
H A D | run_loop.h | 54 // Adds a task to be performed after delay has elapsed. Must be posted to the 56 void PostDelayedTask(const Closure& task, MojoTimeTicks delay); 97 // Do one unit of delayed work, if eligible. Returns true is a task was run. 100 // Waits for a handle to be ready or until the next task must be run. Returns 102 // a task must be run or |non_blocking| is true, in which case it will also 103 // return if no task is registered and servicing at least one handle would 133 PendingTask(const Closure& task, 140 Closure task; member in struct:mojo::RunLoop::PendingTask 144 // An ever increasing sequence number attached to each pending task in order
|
/external/chromium_org/mojo/services/html_viewer/ |
H A D | webthread_impl.cc | 63 void WebThreadImpl::postTask(Task* task) { argument 65 FROM_HERE, base::Bind(&blink::WebThread::Task::run, base::Owned(task))); 68 void WebThreadImpl::postDelayedTask(Task* task, long long delay_ms) { argument 71 base::Bind(&blink::WebThread::Task::run, base::Owned(task)), 103 void WebThreadImplForMessageLoop::postTask(Task* task) { argument 105 FROM_HERE, base::Bind(&blink::WebThread::Task::run, base::Owned(task))); 108 void WebThreadImplForMessageLoop::postDelayedTask(Task* task, argument 112 base::Bind(&blink::WebThread::Task::run, base::Owned(task)),
|
/external/chromium_org/sandbox/mac/ |
H A D | launchd_interception_server.cc | 32 mach_port_t task = mach_task_self(); local 37 if ((kr = mach_port_allocate(task, MACH_PORT_RIGHT_RECEIVE, &port)) != 43 if ((kr = mach_port_insert_right(task, sandbox_port_, sandbox_port_,
|
/external/chromium_org/storage/browser/fileapi/ |
H A D | timed_task_helper.cc | 79 base::Closure task = user_task_; local 81 task.Run();
|
/external/chromium_org/third_party/WebKit/Source/core/dom/ |
H A D | MainThreadTaskRunner.cpp | 41 PerformTaskContext(WeakPtr<MainThreadTaskRunner> runner, PassOwnPtr<ExecutionContextTask> task, bool isInspectorTask) argument 43 , m_task(task) 80 void MainThreadTaskRunner::postTask(PassOwnPtr<ExecutionContextTask> task) argument 82 if (!task->taskNameForInstrumentation().isEmpty()) 83 InspectorInstrumentation::didPostExecutionContextTask(m_context, task.get()); 84 callOnMainThread(PerformTaskContext::didReceiveTask, new PerformTaskContext(m_weakFactory.createWeakPtr(), task, false)); 87 void MainThreadTaskRunner::postInspectorTask(PassOwnPtr<ExecutionContextTask> task) argument 89 callOnMainThread(PerformTaskContext::didReceiveTask, new PerformTaskContext(m_weakFactory.createWeakPtr(), task, true)); 92 void MainThreadTaskRunner::perform(PassOwnPtr<ExecutionContextTask> task, bool isInspectorTask) argument 95 m_pendingTasks.append(task); 126 OwnPtr<ExecutionContextTask> task = m_pendingTasks[0].release(); local [all...] |
/external/chromium_org/third_party/WebKit/Source/core/workers/ |
H A D | WorkerEventQueue.cpp | 120 OwnPtr<EventDispatcherTask> task = EventDispatcherTask::create(event, this); local 121 m_eventTaskMap.add(event.release(), task.get()); 122 m_executionContext->postTask(task.release()); 128 EventDispatcherTask* task = m_eventTaskMap.get(event); local 129 if (!task) 131 task->cancel(); 141 EventDispatcherTask* task = it->value; local 143 task->cancel();
|
H A D | WorkerObjectProxy.cpp | 55 void WorkerObjectProxy::postTaskToMainExecutionContext(PassOwnPtr<ExecutionContextTask> task) argument 57 m_executionContext->postTask(task);
|
/external/chromium_org/third_party/WebKit/Source/modules/webdatabase/ |
H A D | DatabaseThread.cpp | 92 // the database thread has already finished processing the cleanup task. 154 void DatabaseThread::scheduleTask(PassOwnPtr<DatabaseTask> task) argument 158 // WebThread takes ownership of the task. 159 m_thread->postTask(task.leakPtr());
|
/external/chromium_org/third_party/libaddressinput/src/cpp/test/ |
H A D | validation_task_test.cc | 90 ValidationTask* task = new ValidationTask( local 105 (*task->supplied_)(success_, *task->lookup_key_, hierarchy);
|
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
H A D | fakexmppclient.h | 89 virtual void AddXmppTask(XmppTask* task, argument 91 tasks_.push_back(task); 94 virtual void RemoveXmppTask(XmppTask* task) { argument 95 std::remove(tasks_.begin(), tasks_.end(), task); 105 for (std::vector<XmppTask*>::iterator task = tasks_.begin(); 106 task != tasks_.end(); ++task) { 107 if ((*task)->HandleStanza(stanza)) {
|
H A D | mucroomlookuptask_unittest.cc | 43 void OnResult(buzz::MucRoomLookupTask* task, argument 48 void OnError(buzz::IqTask* task, argument 94 buzz::MucRoomLookupTask* task = local 97 task->SignalResult.connect(listener, &MucRoomLookupListener::OnResult); 98 task->Start(); 136 buzz::MucRoomLookupTask* task = buzz::MucRoomLookupTask::CreateLookupTaskForHangoutId( local 138 task->SignalResult.connect(listener, &MucRoomLookupListener::OnResult); 139 task->Start(); 173 buzz::MucRoomLookupTask* task = buzz::MucRoomLookupTask::CreateLookupTaskForRoomName( local 175 task 189 buzz::MucRoomLookupTask* task = buzz::MucRoomLookupTask::CreateLookupTaskForRoomName( local [all...] |
H A D | pingtask_unittest.cc | 68 void ConnectTimeoutSignal(buzz::PingTask* task) { argument 69 task->SignalTimeout.connect(this, &PingTaskTest::OnPingTimeout); 95 buzz::PingTask* task = new buzz::PingTask(xmpp_client, local 98 ConnectTimeoutSignal(task); 99 task->Start(); 103 EXPECT_FALSE(task->IsDone()); 110 buzz::PingTask* task = new buzz::PingTask(xmpp_client, local 113 ConnectTimeoutSignal(task); 114 task->Start();
|
H A D | pubsubtasks_unittest.cc | 26 void OnReceiveUpdate(buzz::PubSubReceiveTask* task, argument 31 void OnRequestResult(buzz::PubSubRequestTask* task, argument 48 void OnPublishResult(buzz::PubSubPublishTask* task) { argument 52 void OnRetractResult(buzz::PubSubRetractTask* task) { argument 56 void OnError(buzz::IqTask* task, const buzz::XmlElement* stanza) { argument 86 buzz::PubSubRequestTask* task = local 88 task->SignalResult.connect( 90 task->Start(); 136 buzz::PubSubRequestTask* task = local 138 task 164 buzz::PubSubReceiveTask* task = local 199 buzz::PubSubPublishTask* task = local 223 buzz::PubSubPublishTask* task = local 245 buzz::PubSubRetractTask* task = local [all...] |
/external/chromium_org/third_party/webrtc/base/ |
H A D | taskrunner.cc | 17 #include "webrtc/base/task.h" 39 void TaskRunner::StartTask(Task * task) { argument 40 tasks_.push_back(task); 42 // the task we just started could be about to timeout -- 43 // make sure our "next timeout task" is correct 44 UpdateTaskTimeout(task, 0); 58 // Subsequent use of those task may cause data corruption or crashes. 84 Task* task = tasks_[i]; local 86 task->unique_id() == next_timeout_task_->unique_id()) { 92 deleting_task_ = task; 152 UpdateTaskTimeout(Task* task, int64 previous_task_timeout_time) argument 197 Task *task = tasks_[i]; local [all...] |
/external/chromium_org/ui/aura/test/ |
H A D | ui_controls_factory_aurawin.cc | 51 const base::Closure& task) { 55 return SendKeyPressImpl(window, key, control, shift, alt, task); 62 const base::Closure& task) { 63 return SendMouseMoveImpl(screen_x, screen_y, task); 70 const base::Closure& task) { 71 return SendMouseEventsImpl(type, state, task); 45 SendKeyPressNotifyWhenDone(gfx::NativeWindow native_window, ui::KeyboardCode key, bool control, bool shift, bool alt, bool command, const base::Closure& task) argument 60 SendMouseMoveNotifyWhenDone(long screen_x, long screen_y, const base::Closure& task) argument 68 SendMouseEventsNotifyWhenDone(MouseButton type, int state, const base::Closure& task) argument
|