| /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;
|
| /external/vogar/src/vogar/tasks/ |
| 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 …]
|
| 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()
|
| /external/libchrome/base/task_scheduler/ |
| D | task.cc | 21 Task::Task(const Location& posted_from, in Task() function in base::internal::Task
52 Task::Task(Task&& other) noexcept in Task() function in base::internal::Task
61 Task::~Task() = default;
63 Task& Task::operator=(Task&& other) = default;
|
| D | task.h | 24 struct BASE_EXPORT Task : public PendingTask { struct
30 Task(const Location& posted_from,
37 Task(Task&& other) noexcept;
39 ~Task();
41 Task& operator=(Task&& other); argument
68 DISALLOW_COPY_AND_ASSIGN(Task);
|
| /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/syzkaller/pkg/report/testdata/gvisor/report/ |
| D | 7 | 15 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).CopyInBytes()
21 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).executeSyscall()
23 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallInvoke()
25 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallEnter()
27 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscall()
31 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).run()
51 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).executeSyscall()
53 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallInvoke()
55 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallEnter()
57 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscall()
[all …]
|
| D | 6 | 23 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).executeSyscall()
25 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallInvoke()
27 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallEnter()
29 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscall()
33 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).run()
51 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).executeSyscall()
53 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallInvoke()
55 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallEnter()
57 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscall()
61 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).run()
[all …]
|
| D | 8 | 16 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).CopyOutBytes()
24 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).executeSyscall()
26 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallInvoke()
28 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallEnter()
30 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscall()
34 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).run()
54 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).executeSyscall()
56 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallInvoke()
58 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscallEnter()
60 gvisor.googlesource.com/gvisor/pkg/sentry/kernel.(*Task).doSyscall()
[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 | 36 import vogar.tasks.Task;
57 @Override public Set<Task> installTasks() { in installTasks()
58 Set<Task> result = new HashSet<Task>(); in installTasks()
67 @Override public Set<Task> installActionTasks(Action action, File jar) { in installActionTasks()
68 Set<Task> result = new HashSet<Task>(); in installActionTasks()
73 @Override public Task executeActionTask(Action action, boolean useLargeTimeout) { in executeActionTask()
117 @Override public Set<Task> cleanupTasks(Action action) { in cleanupTasks()
135 Set<Task> tasks, String name, File jar, Action action) { in addCreateDexJarAndPushTasks()
139 Task createDexJarTask = newCreateDexJarTask(run.classpath, jar, name, action, localDex, in addCreateDexJarAndPushTasks()
145 private Task newCreateDexJarTask(Classpath classpath, File classpathElement, String name, in newCreateDexJarTask()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | task_queue_impl.h | 107 class BASE_EXPORT Task : public TaskQueue::Task {
109 Task(TaskQueue::PostedTask task,
113 Task(TaskQueue::PostedTask task,
169 internal::TaskQueueImpl::Task task;
176 RepeatingCallback<void(const TaskQueue::Task&,
179 RepeatingCallback<void(const TaskQueue::Task&,
269 void PushImmediateIncomingTaskForTest(TaskQueueImpl::Task&& task);
296 void OnTaskStarted(const TaskQueue::Task& task,
299 void OnTaskCompleted(const TaskQueue::Task& task,
352 std::priority_queue<TaskQueueImpl::Task> delayed_incoming_queue;
[all …]
|
| /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/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | InteropClientServerTest.cs | 81 public async Task ClientStreaming() in ClientStreaming()
87 public async Task ServerStreaming() in ServerStreaming()
93 public async Task PingPong() in PingPong()
99 public async Task EmptyStream() in EmptyStream()
105 public async Task CancelAfterBegin() in CancelAfterBegin()
111 public async Task CancelAfterFirstResponse() in CancelAfterFirstResponse()
117 public async Task TimeoutOnSleepingServer() in TimeoutOnSleepingServer()
123 public async Task CustomMetadata() in CustomMetadata()
129 public async Task StatusCodeAndMessage() in StatusCodeAndMessage()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/lib/Support/ |
| D | ThreadPool.cpp | 35 PackagedTaskTy Task; in ThreadPool() local
53 Task = std::move(Tasks.front()); in ThreadPool()
57 Task(); in ThreadPool()
82 std::shared_future<void> 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
128 Task(); in wait()
132 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl() argument
134 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl()
|
| /external/vogar/src/vogar/ |
| D | Driver.java | 32 import vogar.tasks.Task;
50 private Task prepareTargetTask;
51 private Set<Task> installVogarTasks;
102 Set<Task> shutdownTasks = new HashSet<Task>(); in buildAndRun()
105 for (Task task : shutdownTasks) { in buildAndRun()
156 Task build = new BuildActionTask(run, action, this, jar); in enqueueActionTasks()
159 Task prepareUserDir = new PrepareUserDirTask(run.target, action); in enqueueActionTasks()
163 Set<Task> install = run.mode.installActionTasks(action, jar); in enqueueActionTasks()
169 Task execute = run.mode.executeActionTask(action, useLargeTimeout) in enqueueActionTasks()
176 Task retrieveFiles = new RetrieveFilesTask(run, action.getUserDir()).after(execute); in enqueueActionTasks()
[all …]
|
| /external/v8/tools/clang/rewrite_to_chrome_style/tests/ |
| 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
|
| 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
|
| /external/v8/src/heap/ |
| D | item-parallel-job.h | 44 class Task;
66 friend class ItemParallelJob::Task;
71 class V8_EXPORT_PRIVATE Task : public CancelableTask {
73 explicit Task(Isolate* isolate);
74 virtual ~Task();
121 DISALLOW_COPY_AND_ASSIGN(Task);
130 void AddTask(Task* task) { tasks_.push_back(std::unique_ptr<Task>(task)); } in AddTask()
144 std::vector<std::unique_ptr<Task>> tasks_;
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCall.cs | 141 return unaryResponseTcs.Task.GetAwaiter().GetResult(); in UnaryCall()
148 public Task<TResponse> UnaryCallAsync(TRequest msg) in UnaryCallAsync()
172 return unaryResponseTcs.Task; in UnaryCallAsync()
188 public Task<TResponse> ClientStreamingCallAsync() in ClientStreamingCallAsync()
209 return unaryResponseTcs.Task; in ClientStreamingCallAsync()
295 public Task SendMessageAsync(TRequest msg, WriteFlags writeFlags) in SendMessageAsync()
303 public Task<TResponse> ReadMessageAsync() in ReadMessageAsync()
312 public Task SendCloseFromClientAsync() in SendCloseFromClientAsync()
336 return streamingWriteTcs.Task; in SendCloseFromClientAsync()
343 public Task StreamingResponseCallFinishedTask
[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/v8/src/libplatform/ |
| D | default-foreground-task-runner.h | 28 std::unique_ptr<Task> PopTaskFromQueue(MessageLoopBehavior wait_for_work); in NON_EXPORTED_BASE()
37 void PostTask(std::unique_ptr<Task> task) override; in NON_EXPORTED_BASE()
39 void PostDelayedTask(std::unique_ptr<Task> task, in NON_EXPORTED_BASE()
49 void PostTaskLocked(std::unique_ptr<Task> task, in NON_EXPORTED_BASE()
54 std::unique_ptr<Task> PopTaskFromDelayedQueueLocked( in NON_EXPORTED_BASE()
60 std::queue<std::unique_ptr<Task>> task_queue_; in NON_EXPORTED_BASE()
65 using DelayedEntry = std::pair<double, std::unique_ptr<Task>>; in NON_EXPORTED_BASE()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/lib/LTO/ |
| D | Caching.cpp | 36 return [=](unsigned Task, StringRef Key) -> AddStreamFn { in localCache() argument
53 AddBuffer(Task, std::move(*MBOrErr)); in localCache()
75 unsigned Task; in localCache() member
79 unsigned Task) in localCache()
82 Task(Task) {} in localCache()
128 AddBuffer(Task, std::move(*MBOrErr)); in localCache()
132 return [=](size_t Task) -> std::unique_ptr<NativeObjectStream> { in localCache() argument
146 AddBuffer, std::move(*Temp), EntryPath.str(), Task); in localCache()
|