Searched defs:task (Results 76 - 100 of 399) sorted by relevance

1234567891011>>

/external/chromium_org/media/cast/
H A Dcast_environment.cc47 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 Dfake_single_thread_task_runner.cc24 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 Dtest_task_runner.cc23 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 DWorkerScriptDebugServer.cpp87 void WorkerScriptDebugServer::interruptAndRunTask(PassOwnPtr<Task> task) argument
89 interruptAndRun(task, m_isolate);
/external/chromium_org/third_party/WebKit/Source/platform/
H A DWebThreadSupportingGC.h30 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 Dmucroomconfigtask_unittest.cc47 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 Dmucroomuniquehangoutidtask_unittest.cc43 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 DDMTask.cpp41 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 DSysTimer_mach.cpp10 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 Ddefault-platform.cc81 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 DAbstractListeningExecutorService.java42 @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 DExecutorService.java28 <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 DListenableFutureTaskTest.java43 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 DMachVMRegion.cpp19 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 DDMTask.cpp46 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 DSysTimer_mach.cpp10 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 DThreadUtils.java66 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 Dlibdispatch_task_runner.cc21 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 Dincoming_task_queue.cc23 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 Dworker_pool.cc27 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 Dtimer.cc18 // 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 Dprivate_api_tasks.cc28 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 Doauth2_token_fetcher.cc119 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 Dpolicy_oauth2_token_fetcher.cc105 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 Dmtp_device_delegate_impl_linux.h43 // 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...]

Completed in 1623 milliseconds

1234567891011>>