| /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/jetty/src/java/org/eclipse/jetty/util/thread/ |
| D | Timeout.java | 40 private Task _head=new Task();
100 public Task expired() in expired()
108 Task task = _head._next; in expired()
125 Task task=null; in tick()
157 public void schedule(Task task) in schedule()
167 public void schedule(Task task,long delay) in schedule()
181 Task last=_head._prev; in schedule()
230 Task task = _head._next; in toString()
253 public static class Task class in Timeout
255 Task _next;
[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()
82 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
84 PackagedTaskTy PackagedTask(std::move(Task)); in asyncImpl()
126 auto Task = std::move(Tasks.front()); in wait() local
129 Task(); in wait()
131 Task(/* unused */ false); in wait()
136 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
[all …]
|
| /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()
111 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
129 Set<Task> tasks, String name, File jar, Action action) { in addCreateDexJarAndPushTasks()
132 Task createDexJarTask = newCreateDexJarTask(run.classpath, jar, name, action, localDex); in addCreateDexJarAndPushTasks()
137 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()
78 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
82 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
84 Task createDexJarTask = createCreateDexJarTask(Classpath.of(jar), jar, action.getName(), in installActionTasks()
156 private Task createCreateDexJarTask(Classpath classpath, File classpathElement, String name, in createCreateDexJarTask()
158 Task dex; in createCreateDexJarTask()
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/bin/ |
| D | taskadmin | 37 from boto.manage.task import Task
40 for t in Task.all():
48 from boto.manage.task import Task
49 q = Task.find()
65 from boto.manage.task import Task
66 t = Task.get_by_id(id)
83 from boto.manage.task import Task
84 t = Task()
|
| /external/opencv3/3rdparty/openexr/IlmThread/ |
| D | IlmThreadPool.h | 66 class Task; variable
108 void addTask (Task* task);
116 static void addGlobalTask (Task* task);
126 class Task
130 Task (TaskGroup* g);
131 virtual ~Task ();
|
| D | IlmThreadPool.cpp | 93 list<Task*> tasks; // the list of tasks to execute
145 Task* task = _data->tasks.front(); in run()
291 Task::Task (TaskGroup* g): _group(g) in Task() function in IlmThread::Task
297 Task::~Task() in ~Task()
304 Task::group () in group()
396 ThreadPool::addTask (Task* task) in addTask()
450 ThreadPool::addGlobalTask (Task* task) in addGlobalTask()
|
| /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()
|
| D | JavaVm.java | 27 import vogar.tasks.Task;
39 @Override public Set<Task> installTasks() { in installTasks()
62 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
66 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
89 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
|
| /external/autotest/site_utils/suite_scheduler/ |
| D | task_unittest.py | 73 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
76 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
90 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
93 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
111 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
114 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
129 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
132 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
143 keyword, new_task = task.Task.CreateFromConfigSection(self.config,
146 self.assertEquals(new_task, task.Task(self._TASK_NAME, self._SUITE,
[all …]
|
| /external/v8/src/libplatform/ |
| D | default-platform.h | 37 void CallOnBackgroundThread(Task* task,
39 void CallOnForegroundThread(v8::Isolate* isolate, Task* task) override;
40 void CallDelayedOnForegroundThread(Isolate* isolate, Task* task,
60 Task* PopTaskInMainThreadQueue(v8::Isolate* isolate);
61 Task* PopTaskInMainThreadDelayedQueue(v8::Isolate* isolate);
68 std::map<v8::Isolate*, std::queue<Task*> > main_thread_queue_;
70 typedef std::pair<double, Task*> DelayedEntry;
|
| D | task-queue.h | 16 class Task; variable
26 void Append(Task* task);
30 Task* GetNext();
38 std::queue<Task*> task_queue_;
|
| D | default-platform.cc | 86 Task* DefaultPlatform::PopTaskInMainThreadQueue(v8::Isolate* isolate) { in PopTaskInMainThreadQueue()
91 Task* task = it->second.front(); in PopTaskInMainThreadQueue()
97 Task* DefaultPlatform::PopTaskInMainThreadDelayedQueue(v8::Isolate* isolate) { in PopTaskInMainThreadDelayedQueue()
103 std::pair<double, Task*> deadline_and_task = it->second.top(); in PopTaskInMainThreadDelayedQueue()
113 Task* task = NULL; in PumpMessageLoop()
136 void DefaultPlatform::CallOnBackgroundThread(Task *task, in CallOnBackgroundThread()
143 void DefaultPlatform::CallOnForegroundThread(v8::Isolate* isolate, Task* task) { in CallOnForegroundThread()
150 Task* task, in CallDelayedOnForegroundThread()
|
| /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/include/ |
| D | v8-platform.h | 17 class Task {
19 virtual ~Task() {} in ~Task()
65 virtual void CallOnBackgroundThread(Task* task,
73 virtual void CallOnForegroundThread(Isolate* isolate, Task* task) = 0;
81 virtual void CallDelayedOnForegroundThread(Isolate* isolate, Task* task,
|
| /external/autotest/scheduler/ |
| D | prejob_task.py | 104 task=models.SpecialTask.Task.PROVISION,
132 task=models.SpecialTask.Task.REPAIR,
147 task=models.SpecialTask.Task.REPAIR,
179 TASK_TYPE = models.SpecialTask.Task.VERIFY
200 self.remove_special_tasks(models.SpecialTask.Task.VERIFY,
218 TASK_TYPE = models.SpecialTask.Task.CLEANUP
250 task=models.SpecialTask.Task.VERIFY)
272 TASK_TYPE = models.SpecialTask.Task.RESET
292 self.remove_special_tasks(models.SpecialTask.Task.CLEANUP,
296 self.remove_special_tasks(models.SpecialTask.Task.VERIFY,
[all …]
|