| /external/webrtc/webrtc/base/ |
| D | task.cc | 17 int32_t Task::unique_id_seed_ = 0;
19 Task::Task(TaskParent *parent) in Task() function in rtc::Task
37 Task::~Task() { in ~Task()
51 int64_t Task::CurrentTime() { in CurrentTime()
55 int64_t Task::ElapsedTime() { in ElapsedTime()
59 void Task::Start() { in Start()
69 void Task::Step() { in Step()
136 void Task::Abort(bool nowake) { in Abort()
166 void Task::Wake() { in Wake()
175 void Task::Error() { in Error()
[all …]
|
| D | taskrunner.h | 21 class Task; variable
41 void StartTask(Task *task);
45 void UpdateTaskTimeout(Task* task, int64_t previous_task_timeout_time);
48 bool is_ok_to_delete(Task* task) { in is_ok_to_delete()
87 std::vector<Task *> tasks_;
88 Task *next_timeout_task_;
92 Task* deleting_task_;
95 void RecalcNextTimeout(Task *exclude_task);
|
| D | taskparent.h | 21 class Task; variable
26 TaskParent(Task *derived_instance, TaskParent *parent);
36 bool IsChildTask(Task *task);
40 void OnStopped(Task *task);
48 void OnChildStopped(Task *child);
49 void AddChild(Task *child);
54 typedef std::set<Task *> ChildSet;
|
| D | taskrunner.cc | 39 void TaskRunner::StartTask(Task * task) { in StartTask()
84 Task* task = tasks_[i]; in InternalRunTasks()
102 std::vector<Task *>::iterator it; in InternalRunTasks()
105 reinterpret_cast<Task *>(NULL)); in InternalRunTasks()
128 Task* old_timeout_task = NULL; in PollTasks()
152 void TaskRunner::UpdateTaskTimeout(Task* task, in UpdateTaskTimeout()
186 void TaskRunner::RecalcNextTimeout(Task *exclude_task) { in RecalcNextTimeout()
197 Task *task = tasks_[i]; in RecalcNextTimeout()
|
| D | taskparent.cc | 21 TaskParent::TaskParent(Task* derived_instance, TaskParent *parent) in TaskParent()
45 void TaskParent::AddChild(Task *child) { in AddChild()
50 bool TaskParent::IsChildTask(Task *task) { in IsChildTask()
87 void TaskParent::OnStopped(Task *task) { in OnStopped()
92 void TaskParent::OnChildStopped(Task *child) { in OnChildStopped()
|
| /external/vogar/src/vogar/tasks/ |
| D | Task.java | 30 public abstract class Task { class
32 final List<Task> tasksThatMustFinishFirst = new ArrayList<Task>();
33 final List<Task> tasksThatMustFinishSuccessfullyFirst = new ArrayList<Task>();
37 protected Task(String name) { in Task() method in Task
49 public Task after(Task prerequisite) { in after()
54 public Task after(Collection<Task> prerequisites) { in after()
59 public Task afterSuccess(Task prerequisite) { in afterSuccess()
64 public Task afterSuccess(Collection<Task> prerequisitess) { in afterSuccess()
70 for (Task task : tasksThatMustFinishFirst) { in isRunnable()
75 for (Task task : tasksThatMustFinishSuccessfullyFirst) { in isRunnable()
|
| D | TaskQueue.java | 39 private final LinkedList<Task> tasks = new LinkedList<Task>();
40 private final LinkedList<Task> runnableActions = new LinkedList<Task>();
41 private final LinkedList<Task> runnableTasks = new LinkedList<Task>();
42 private final List<Task> failedTasks = new ArrayList<Task>();
52 public synchronized void enqueue(Task task) { in enqueue()
56 public void enqueueAll(Collection<Task> tasks) { in enqueueAll()
60 public synchronized List<Task> getTasks() { in getTasks()
61 return new ArrayList<Task>(tasks); in getTasks()
91 for (Task task : tasks) { in printTasks()
94 for (Task blocker : task.tasksThatMustFinishFirst) { in printTasks()
[all …]
|
| /external/llvm/lib/Support/ |
| D | ThreadPool.cpp | 34 PackagedTaskTy Task; in ThreadPool() local
52 Task = std::move(Tasks.front()); in ThreadPool()
57 Task(); in ThreadPool()
59 Task(/* unused */ false); in ThreadPool()
85 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
87 PackagedTaskTy PackagedTask(std::move(Task)); in asyncImpl()
129 auto Task = std::move(Tasks.front()); in wait() local
132 Task(); in wait()
134 Task(/* unused */ false); in wait()
139 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
[all …]
|
| /external/libchrome/base/task_scheduler/ |
| D | sequence_unittest.cc | 20 new Task(FROM_HERE, in TaskSchedulerSequenceTest()
25 new Task(FROM_HERE, in TaskSchedulerSequenceTest()
30 new Task(FROM_HERE, in TaskSchedulerSequenceTest()
35 new Task(FROM_HERE, in TaskSchedulerSequenceTest()
40 new Task(FROM_HERE, in TaskSchedulerSequenceTest()
52 std::unique_ptr<Task> task_a_owned_;
53 std::unique_ptr<Task> task_b_owned_;
54 std::unique_ptr<Task> task_c_owned_;
55 std::unique_ptr<Task> task_d_owned_;
56 std::unique_ptr<Task> task_e_owned_;
[all …]
|
| D | task.cc | 10 Task::Task(const tracked_objects::Location& posted_from, in Task() function in base::internal::Task
20 Task::~Task() = default;
|
| D | task.h | 24 struct BASE_EXPORT Task : public PendingTask { struct
28 Task(const tracked_objects::Location& posted_from,
32 ~Task();
58 DISALLOW_COPY_AND_ASSIGN(Task);
|
| /external/vogar/src/vogar/android/ |
| D | ActivityMode.java | 29 import vogar.tasks.Task;
41 @Override public Set<Task> installTasks() { in installTasks()
42 return Collections.<Task>singleton( in installTasks()
46 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
47 return Collections.<Task>singleton(new InstallApkTask(run, action, jar)); in installActionTasks()
50 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
54 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
55 Set<Task> result = new LinkedHashSet<Task>(); in cleanupTasks()
|
| D | DeviceRuntime.java | 35 import vogar.tasks.Task;
56 @Override public Set<Task> installTasks() { in installTasks()
57 Set<Task> result = new HashSet<Task>(); in installTasks()
66 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
67 Set<Task> result = new HashSet<Task>(); in installActionTasks()
72 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
113 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
131 Set<Task> tasks, String name, File jar, Action action) { in addCreateDexJarAndPushTasks()
135 Task createDexJarTask = newCreateDexJarTask(run.classpath, jar, name, action, localDex, in addCreateDexJarAndPushTasks()
141 private Task newCreateDexJarTask(Classpath classpath, File classpathElement, String name, in newCreateDexJarTask()
[all …]
|
| D | HostRuntime.java | 37 import vogar.tasks.Task;
57 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
65 @Override public Set<Task> installTasks() { in installTasks()
66 Set<Task> result = new HashSet<Task>(); in installTasks()
79 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
83 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
86 Task createDexJarTask = createCreateDexJarTask(Classpath.of(jar), jar, action.getName(), in installActionTasks()
158 private Task createCreateDexJarTask(Classpath classpath, File classpathElement, String name, in createCreateDexJarTask()
160 Task dex; in createCreateDexJarTask()
|
| /external/ims/rcs/rcsservice/src/com/android/service/ims/ |
| D | TaskManager.java | 73 private Map<String, Task> mTaskMap;
84 mTaskMap = new HashMap<String, Task>(); in TaskManager()
106 public void putTask(int taskId, Task task){ in putTask()
112 private synchronized void putTaskInternal(int taskId, Task task){ in putTaskInternal()
113 Task sameKeyTask = mTaskMap.put(String.valueOf(taskId), task); in putTaskInternal()
122 Task task = new PresenceCapabilityTask(context, taskId, TASK_TYPE_GET_CAPABILITY, in addCapabilityTask()
135 Task task = new PresenceAvailabilityTask(taskId, TASK_TYPE_GET_AVAILABILITY, in addAvailabilityTask()
148 Task task = new PresenceTask(taskId, TASK_TYPE_PUBLISH, listener, contacts); in addPublishTask()
156 public Task getTask(int taskId){ in getTask()
164 Task task = mTaskMap.remove(String.valueOf(taskId)); in removeTask()
[all …]
|
| /external/v8/tools/clang/rewrite_to_chrome_style/tests/ |
| D | methods-original.cc | 29 class Task { class
46 Task& operator++() { in operator ++()
79 void Task::doTheWork() { in doTheWork()
117 class BovineTask : public blink::Task {
119 using Task::doTheWork;
136 void (blink::Task::*p1)() = &blink::Task::doTheWork; in F() local
137 void (blink::Task::*p2)() = &BovineTask::doTheWork; in F() local
138 void (blink::Task::*p3)() = &blink::Task::reallyDoTheWork; in F() local
|
| D | methods-expected.cc | 29 class Task { class
46 Task& operator++() { return *this; } in operator ++()
75 void Task::DoTheWork() { in DoTheWork()
113 class BovineTask : public blink::Task {
115 using Task::DoTheWork;
132 void (blink::Task::*p1)() = &blink::Task::DoTheWork; in F() local
133 void (blink::Task::*p2)() = &BovineTask::DoTheWork; in F() local
134 void (blink::Task::*p3)() = &blink::Task::ReallyDoTheWork; in F() local
|
| /external/vogar/src/vogar/ |
| D | Driver.java | 32 import vogar.tasks.Task;
50 private Task prepareTargetTask;
51 private Set<Task> installVogarTasks;
101 Set<Task> shutdownTasks = new HashSet<Task>(); in buildAndRun()
104 for (Task task : shutdownTasks) { in buildAndRun()
160 Task build = new BuildActionTask(run, action, this, jar); in enqueueActionTasks()
163 Task prepareUserDir = new PrepareUserDirTask(run.target, action); in enqueueActionTasks()
167 Set<Task> install = run.mode.installActionTasks(action, jar); in enqueueActionTasks()
173 Task execute = run.mode.executeActionTask(action, useLargeTimeout) in enqueueActionTasks()
180 Task retrieveFiles = new RetrieveFilesTask(run, action.getUserDir()).after(execute); in enqueueActionTasks()
[all …]
|
| D | Mode.java | 22 import vogar.tasks.Task;
34 Set<Task> installTasks(); in installTasks()
36 Task executeActionTask(Action action, boolean useLargeTimeout); in executeActionTask()
41 Set<Task> installActionTasks(Action action, File jar); in installActionTasks()
47 Set<Task> cleanupTasks(Action action); in cleanupTasks()
|
| /external/autotest/site_utils/suite_scheduler/ |
| D | task_unittest.py | 75 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
78 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
90 keyword, new_task = task.Task.CreateFromConfigSection(
99 keyword, new_task = task.Task.CreateFromConfigSection(
112 keyword, new_task = task.Task.CreateFromConfigSection(
125 keyword, new_task = task.Task.CreateFromConfigSection(
136 keyword, new_task = task.Task.CreateFromConfigSection(
149 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
152 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
170 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
[all …]
|
| /external/toolchain-utils/bestflags/ |
| D | task_test.py | 16 from task import Task
68 assert Task(flag_set) == Task(flag_set)
72 test_task = Task(flag_set)
75 assert test_task != Task(flag_set1)
89 hash_task = Task(flag_set)
104 identifier_task = Task(flag_set)
119 result_task = Task(flag_set)
153 work_task = Task(flag_set)
|
| /external/jacoco/org.jacoco.ant/src/org/jacoco/ant/ |
| D | CoverageTask.java | 23 import org.apache.tools.ant.Task;
39 private Task childTask;
55 public void addTask(final Task task) { in addTask()
116 public void enhanceTask(final Task task) { in enhanceTask()
138 public void enhanceTask(final Task task) { in enhanceTask()
154 public void addJvmArgs(final Task task) { in addJvmArgs()
195 public void enhanceTask(Task task) throws BuildException; in enhanceTask()
|
| /external/v8/src/libplatform/ |
| D | default-platform.h | 48 void CallOnBackgroundThread(Task* task, in NON_EXPORTED_BASE()
50 void CallOnForegroundThread(v8::Isolate* isolate, Task* task) override; in NON_EXPORTED_BASE()
51 void CallDelayedOnForegroundThread(Isolate* isolate, Task* task, in NON_EXPORTED_BASE()
77 Task* PopTaskInMainThreadQueue(v8::Isolate* isolate); in NON_EXPORTED_BASE()
78 Task* PopTaskInMainThreadDelayedQueue(v8::Isolate* isolate); in NON_EXPORTED_BASE()
86 std::map<v8::Isolate*, std::queue<Task*>> main_thread_queue_; in NON_EXPORTED_BASE()
89 typedef std::pair<double, Task*> DelayedEntry; in NON_EXPORTED_BASE()
|
| D | task-queue.h | 18 class Task; variable
28 void Append(Task* task);
32 Task* GetNext();
44 std::queue<Task*> task_queue_;
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | NonBlockingThreadPool.h | 19 typedef typename Environment::Task Task; typedef
20 typedef RunQueue<Task, 1024> Queue;
75 Task t = env_.CreateTask(std::move(fn)); in Schedule()
143 Task t = q->PopFront(); in WorkerLoop()
173 Task Steal() { in Steal()
180 Task t = queues_[victim]->PopBack(); in Steal()
189 return Task(); in Steal()
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) { in WaitForWork()
|