/external/chromium_org/media/cast/ |
H A D | cast_environment.cc | 47 const base::Closure& task) { 48 return GetTaskRunner(identifier)->PostTask(from_here, task); 54 const base::Closure& task, 56 return GetTaskRunner(identifier)->PostDelayedTask(from_here, task, delay); 45 PostTask(ThreadId identifier, const tracked_objects::Location& from_here, const base::Closure& task) argument 51 PostDelayedTask( ThreadId identifier, const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta delay) argument
|
/external/chromium_org/media/cast/test/ |
H A D | fake_single_thread_task_runner.cc | 24 const base::Closure& task, 27 LOG(FATAL) << "Infinite task-add loop detected."; 32 task, 52 PostedTask task = it->second; 53 if (clock_->NowTicks() < task.GetTimeToRun()) 57 task.task.Run(); 65 // hit some sort of case where a new task is posted every 66 // time that we invoke a task, and we can't make progress 68 // and throw an error when the next task i 22 PostDelayedTask( const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta delay) argument 77 PostedTask task = it->second; local 93 PostNonNestableDelayedTask( const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta delay) argument [all...] |
/external/chromium_org/net/quic/test_tools/ |
H A D | test_task_runner.cc | 23 const base::Closure& task, 27 PostedTask(from_here, task, clock_->NowInTicks(), delay, 41 // Find the next task to run, advance the time to the correct time 42 // and then run the task. 47 PostedTask task = *next; local 49 task.task.Run(); 22 PostDelayedTask(const tracked_objects::Location& from_here, const base::Closure& task, base::TimeDelta delay) argument
|
/external/chromium_org/third_party/WebKit/Source/bindings/core/v8/ |
H A D | WorkerScriptDebugServer.cpp | 87 void WorkerScriptDebugServer::interruptAndRunTask(PassOwnPtr<Task> task) argument 89 interruptAndRun(task, m_isolate);
|
/external/chromium_org/third_party/WebKit/Source/platform/ |
H A D | WebThreadSupportingGC.h | 30 void postTask(WebThread::Task* task) argument 32 m_thread->postTask(task); 35 void postDelayedTask(WebThread::Task* task, long long delayMs) argument 37 m_thread->postDelayedTask(task, delayMs);
|
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
H A D | mucroomconfigtask_unittest.cc | 47 void OnError(buzz::IqTask* task, argument 88 buzz::MucRoomConfigTask* task = new buzz::MucRoomConfigTask( local 90 EXPECT_EQ(room_jid, task->room_jid()); 92 task->SignalResult.connect(listener, &MucRoomConfigListener::OnResult); 93 task->Start(); 130 buzz::MucRoomConfigTask* task = new buzz::MucRoomConfigTask( local 132 task->SignalError.connect(listener, &MucRoomConfigListener::OnError); 133 task->Start();
|
H A D | mucroomuniquehangoutidtask_unittest.cc | 43 void OnResult(buzz::MucRoomUniqueHangoutIdTask* task, argument 48 void OnError(buzz::IqTask* task, argument 86 buzz::MucRoomUniqueHangoutIdTask* task = new buzz::MucRoomUniqueHangoutIdTask( local 88 task->SignalResult.connect(listener, &MucRoomUniqueHangoutIdListener::OnResult); 89 task->Start();
|
/external/chromium_org/third_party/skia/dm/ |
H A D | DMTask.cpp | 41 void Task::reallySpawnChild(CpuTask* task) { argument 42 fTaskRunner->add(task); 49 // If the task says skip, or if we're starting a top-level CPU task and we don't want to, skip. 59 void CpuTask::spawnChild(CpuTask* task) { argument 63 task->run(); 69 // If the task says skip, or if we're starting a top-level GPU task and we don't want to, skip. 85 void GpuTask::spawnChild(CpuTask* task) { argument 86 // Spawn a new task s [all...] |
/external/chromium_org/third_party/skia/tools/timer/ |
H A D | SysTimer_mach.cpp | 10 mach_port_t task = mach_task_self(); local 11 if (task == MACH_PORT_NULL) { 18 if (KERN_SUCCESS != task_info(task,
|
/external/chromium_org/v8/src/libplatform/ |
H A D | default-platform.cc | 81 Task* task = NULL; local 89 task = it->second.front(); 92 task->Run(); 93 delete task; 97 void DefaultPlatform::CallOnBackgroundThread(Task *task, argument 100 queue_.Append(task); 104 void DefaultPlatform::CallOnForegroundThread(v8::Isolate* isolate, Task* task) { argument 106 main_thread_queue_[isolate].push(task);
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | AbstractListeningExecutorService.java | 42 @Override public ListenableFuture<?> submit(Runnable task) { argument 43 ListenableFutureTask<Void> ftask = ListenableFutureTask.create(task, null); 48 @Override public <T> ListenableFuture<T> submit(Runnable task, T result) { argument 49 ListenableFutureTask<T> ftask = ListenableFutureTask.create(task, result); 54 @Override public <T> ListenableFuture<T> submit(Callable<T> task) { argument 55 ListenableFutureTask<T> ftask = ListenableFutureTask.create(task); 83 // Start one task for sure; the rest incrementally
|
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
H A D | ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); argument 30 <T> Future<T> submit(Runnable task, T result); argument 32 Future<?> submit(Runnable task); argument
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | ListenableFutureTaskTest.java | 43 protected final ListenableFutureTask<Integer> task = field in class:ListenableFutureTaskTest 62 task.addListener(new Runnable() { 83 assertFalse(task.isDone()); 84 assertFalse(task.isCancelled()); 86 // Start the task to put it in the RUNNING state. Have to use a separate 87 // thread because the task will block on the task latch after unblocking 89 exec.execute(task); 92 assertFalse(task.isDone()); 93 assertFalse(task [all...] |
/external/lldb/tools/debugserver/source/MacOSX/ |
H A D | MachVMRegion.cpp | 19 MachVMRegion::MachVMRegion(task_t task) : argument 20 m_task(task), 68 DNBLogThreadedIf(LOG_MEMORY_PROTECTIONS | LOG_VERBOSE, "MachVMRegion::%s: protections (%u) already sufficient for task 0x%4.4x at address 0x%8.8llx) ", __FUNCTION__, prot, m_task, (uint64_t)addr); 76 m_err.LogThreaded("::mach_vm_protect ( task = 0x%4.4x, addr = 0x%8.8llx, size = %llu, set_max = %i, prot = %u )", m_task, (uint64_t)addr, (uint64_t)prot_size, 0, prot); 82 m_err.LogThreaded("::mach_vm_protect ( task = 0x%4.4x, addr = 0x%8.8llx, size = %llu, set_max = %i, prot = %u )", m_task, (uint64_t)addr, (uint64_t)prot_size, 0, prot | VM_PROT_COPY); 95 DNBLogThreadedIf(LOG_MEMORY_PROTECTIONS | LOG_VERBOSE, "%s: Zero size for task 0x%4.4x at address 0x%8.8llx) ", __FUNCTION__, m_task, (uint64_t)addr); 108 m_err.LogThreaded("::mach_vm_protect ( task = 0x%4.4x, addr = 0x%8.8llx, size = %llu, set_max = %i, prot = %u )", m_task, (uint64_t)m_protection_addr, (uint64_t)m_protection_size, 0, m_data.protection); 143 m_err.LogThreaded("::mach_vm_region_recurse ( task = 0x%4.4x, address => 0x%8.8llx, size => %llu, nesting_depth => %d, info => %p, infoCnt => %d) addr = 0x%8.8llx ", m_task, (uint64_t)m_start, (uint64_t)m_size, m_depth, &m_data, info_size, (uint64_t)addr);
|
/external/skia/dm/ |
H A D | DMTask.cpp | 46 void Task::spawnChildNext(CpuTask* task) { argument 47 fTaskRunner->addNext(task); 62 void CpuTask::spawnChild(CpuTask* task) { argument 66 task->run(); 80 void GpuTask::spawnChild(CpuTask* task) { argument 81 // Really spawn a new task so it runs on the CPU threadpool instead of the GPU one we're on now. 83 this->spawnChildNext(task);
|
/external/skia/tools/timer/ |
H A D | SysTimer_mach.cpp | 10 mach_port_t task = mach_task_self(); local 11 if (task == MACH_PORT_NULL) { 18 if (KERN_SUCCESS != task_info(task,
|
/external/chromium_org/base/android/java/src/org/chromium/base/ |
H A D | ThreadUtils.java | 66 FutureTask<Void> task = new FutureTask<Void>(r, null); 67 postOnUiThread(task); 69 task.get(); 100 FutureTask<T> task = new FutureTask<T>(c); 101 runOnUiThread(task); 103 return task.get(); 113 * @param task The FutureTask to run 114 * @return The queried task (to aid inline construction) 116 public static <T> FutureTask<T> runOnUiThread(FutureTask<T> task) { argument 118 task 157 postOnUiThread(FutureTask<T> task) argument 168 postOnUiThread(Runnable task) argument 179 postOnUiThreadDelayed(Runnable task, long delayMillis) argument [all...] |
/external/chromium_org/base/mac/ |
H A D | libdispatch_task_runner.cc | 21 const Closure& task, 29 __block const Closure task_copy = task; 51 const Closure& task, 53 return PostDelayedTask(from_here, task, delay); 19 PostDelayedTask( const tracked_objects::Location& from_here, const Closure& task, base::TimeDelta delay) argument 49 PostNonNestableDelayedTask( const tracked_objects::Location& from_here, const Closure& task, base::TimeDelta delay) argument
|
/external/chromium_org/base/message_loop/ |
H A D | incoming_task_queue.cc | 23 const Closure& task, 28 from_here, task, CalculateDelayedRuntime(delay), nestable); 30 // We consider the task needs a high resolution timer if the delay is 89 // directly, as it could starve handling of foreign threads. Put every task 96 pending_task->task.Reset(); 102 // delayed_run_time value) and for identifying the task in about:tracing. 110 pending_task->task.Reset(); 21 AddToIncomingQueue( const tracked_objects::Location& from_here, const Closure& task, TimeDelta delay, bool nestable) argument
|
/external/chromium_org/base/threading/ |
H A D | worker_pool.cc | 27 const Closure& task) OVERRIDE { 28 return WorkerPool::PostTask(from_here, task, task_is_slow_); 45 const Closure& task, 52 // Helper function for posting a delayed task. Asserts that the delay is 56 const Closure& task, 73 const Closure& task, 75 return PostDelayedTaskAssertZeroDelay(from_here, task, delay); 84 const Closure& task, 88 return WorkerPool::PostTask(from_here, task, tasks_are_slow_); 105 const Closure& task, 71 PostDelayedTask( const tracked_objects::Location& from_here, const Closure& task, TimeDelta delay) argument 82 PostDelayedTaskAssertZeroDelay( const tracked_objects::Location& from_here, const Closure& task, base::TimeDelta delay) argument 104 PostTaskAndReply(const tracked_objects::Location& from_here, const Closure& task, const Closure& reply, bool task_is_slow) argument [all...] |
/external/chromium_org/base/timer/ |
H A D | timer.cc | 18 // Timer in the thread's default task runner. It also handles the following 20 // - deleted by the task runner. 29 // This task may be getting cleared because the task runner has been 41 // *this will be deleted by the task runner, so Timer needs to 52 // The task remains in the MessageLoop queue, but nothing will happen when it 112 // If there's no pending task, start one up and return. 124 // We can use the existing scheduled task if it arrives before the new 158 // Remember the thread ID that posts the first task -- this will be verified 159 // later when the task i 194 base::Closure task = user_task_; local [all...] |
/external/chromium_org/chrome/browser/chromeos/extensions/file_manager/ |
H A D | private_api_tasks.cc | 28 const char kInvalidTask[] = "Invalid task: "; 68 file_manager::file_tasks::TaskDescriptor task; local 69 if (!file_manager::file_tasks::ParseTaskID(params->task_id, &task)) { 102 task, 181 const file_manager::file_tasks::FullTaskDescriptor& task = tasks[i]; local 184 task.task_descriptor()); 185 if (!task.icon_url().is_empty()) 186 converted->icon_url = task.icon_url().spec(); 187 converted->title = task.task_title(); 188 converted->is_default = task [all...] |
/external/chromium_org/chrome/browser/chromeos/login/signin/ |
H A D | oauth2_token_fetcher.cc | 119 const base::Closure& task, 128 BrowserThread::UI, FROM_HERE, task, 118 RetryOnError(const GoogleServiceAuthError& error, const base::Closure& task, const base::Closure& error_handler) argument
|
/external/chromium_org/chrome/browser/chromeos/policy/ |
H A D | policy_oauth2_token_fetcher.cc | 105 const base::Closure& task) { 113 BrowserThread::UI, FROM_HERE, task, 104 RetryOnError(const GoogleServiceAuthError& error, const base::Closure& task) argument
|
/external/chromium_org/chrome/browser/media_galleries/linux/ |
H A D | mtp_device_delegate_impl_linux.h | 43 // Used to represent pending task details. 48 const base::Closure& task); 55 const base::Closure task; member in struct:MTPDeviceDelegateImplLinux::PendingTaskInfo 120 // If the device is uninitialized, store the |task_info| in a pending task 125 // Runs a task. If |task_info.path| is empty, or if the path is cached, runs 126 // the task immediately. 127 // Otherwise, fills the cache first before running the task. 128 // |task_info.task| runs on the UI thread. 147 // If the device is successfully initialized, runs the next pending task. 160 // If |dir_id| is a directory, post a task o [all...] |