| /frameworks/native/libs/vr/libperformance/include/dvr/ |
| performance_client_api.h | 18 /// @param task_id The task id of task to set the policy for. When task_id is 0
23 int dvrSetSchedulerPolicy(pid_t task_id, const char* scheduler_policy);
32 /// @param task_id The task id of task to attach to a partition. When task_id is
37 int dvrSetCpuPartition(pid_t task_id, const char* partition);
48 /// @param task_id The task id of task to attach to a partition. When task_id is
53 int dvrSetSchedulerClass(pid_t task_id, const char* scheduler_class);
60 /// @param task_id The task id of the task to retrieve the partition for. Whe
[all...] |
| /frameworks/native/libs/vr/libperformance/ |
| performance_client.cpp | 22 int PerformanceClient::SetCpuPartition(pid_t task_id,
24 if (task_id == 0)
25 task_id = gettid();
28 InvokeRemoteMethod<PerformanceRPC::SetCpuPartition>(task_id, partition));
31 int PerformanceClient::SetCpuPartition(pid_t task_id, const char* partition) {
32 if (task_id == 0)
33 task_id = gettid();
37 task_id, WrapString(partition)));
40 int PerformanceClient::SetSchedulerPolicy(pid_t task_id,
42 if (task_id == 0
[all...] |
| /frameworks/native/libs/vr/libdvr/ |
| dvr_performance.cpp | 9 int dvrPerformanceSetSchedulerPolicy(pid_t task_id,
13 return client->SetSchedulerPolicy(task_id, scheduler_policy);
|
| /frameworks/native/libs/vr/libperformance/include/private/dvr/ |
| performance_client.h | 17 int SetSchedulerPolicy(pid_t task_id, const std::string& scheduler_policy);
18 int SetSchedulerPolicy(pid_t task_id, const char* scheduler_policy);
21 int SetCpuPartition(pid_t task_id, const std::string& partition);
22 int SetCpuPartition(pid_t task_id, const char* partition);
23 int SetSchedulerClass(pid_t task_id, const std::string& scheduler_class);
24 int SetSchedulerClass(pid_t task_id, const char* scheduler_class);
25 int GetCpuPartition(pid_t task_id, std::string* partition_out);
26 int GetCpuPartition(pid_t task_id, char* partition_out, std::size_t size);
|
| /frameworks/native/libs/vr/libdvr/include/dvr/ |
| dvr_performance.h | 16 /// @param task_id The task id of task to set the policy for. When task_id is 0
21 int dvrPerformanceSetSchedulerPolicy(pid_t task_id, const char* scheduler_policy);
|
| /system/nfc/halimpl/bcm2079x/gki/ulinux/ |
| gki_ulinux.c | 81 uint8_t task_id; /* GKI task id */ member in struct:__anon114630
103 GKI_TRACE_5("gki_task_entry task_id=%i, thread_id=%x/%x, pCond/pMutex=%x/%x",
104 p_pthread_info->task_id,
105 gki_cb.os.thread_id[p_pthread_info->task_id], pthread_self(),
108 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id;
112 GKI_TRACE_1("gki_task task_id=%i terminating", p_pthread_info->task_id);
113 gki_cb.os.thread_id[p_pthread_info->task_id] = 0;
200 ** task_id - (input) Task id is mapped to priority
214 uint8_t GKI_create_task(TASKPTR task_entry, uint8_t task_id, int8_t* taskname
313 uint8_t task_id; local
585 uint8_t task_id; local
959 uint8_t task_id; local
[all...] |
| /system/nfc/src/gki/ulinux/ |
| gki_ulinux.c | 72 uint8_t task_id; /* GKI task id */ member in struct:__anon114659
92 GKI_TRACE_5("gki_task_entry task_id=%i, thread_id=%x/%x, pCond/pMutex=%x/%x",
93 p_pthread_info->task_id,
94 gki_cb.os.thread_id[p_pthread_info->task_id], pthread_self(),
97 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id;
101 GKI_TRACE_ERROR_1("gki_task task_id=%i terminating", p_pthread_info->task_id);
102 gki_cb.os.thread_id[p_pthread_info->task_id] = 0;
186 ** task_id - (input) Task id is mapped to priority
200 uint8_t GKI_create_task(TASKPTR task_entry, uint8_t task_id, int8_t* taskname
300 uint8_t task_id; local
551 uint8_t task_id; local
921 uint8_t task_id; local
[all...] |
| /external/libbrillo/brillo/message_loops/ |
| glib_message_loop.cc | 24 << "Removing task_id " << task.second->task_id
35 TaskId task_id = NextTaskId(); local
40 this, from_here, task_id, 0, false, std::move(task)};
41 DVLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << task_id
49 tasks_[task_id] = scheduled_task;
50 return task_id;
94 TaskId task_id = NextTaskId(); local
96 this, from_here, task_id, 0, persistent, std::move(task)}
[all...] |
| glib_message_loop_unittest.cc | 43 TaskId task_id = loop_->WatchFileDescriptor( local
46 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
49 EXPECT_TRUE(loop_->CancelTask(task_id));
56 TaskId task_id = loop_->WatchFileDescriptor( local
63 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
66 EXPECT_TRUE(loop_->CancelTask(task_id));
|
| message_loop_unittest.cc | 77 TaskId task_id = this->loop_->PostTask(FROM_HERE, local
79 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
87 TaskId task_id = this->loop_->PostTask(FROM_HERE, local
89 EXPECT_TRUE(this->loop_->CancelTask(task_id));
93 EXPECT_FALSE(this->loop_->CancelTask(task_id));
98 TaskId task_id = this->loop_->PostDelayedTask( local
102 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
134 TaskId task_id = this->loop_->WatchFileDescriptor( local
137 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
142 EXPECT_TRUE(this->loop_->CancelTask(task_id));
153 TaskId task_id = this->loop_->WatchFileDescriptor( local
171 TaskId task_id = this->loop_->WatchFileDescriptor( local
188 TaskId task_id = this->loop_->WatchFileDescriptor( local
232 TaskId task_id; local
246 TaskId task_id = this->loop_->WatchFileDescriptor( local
261 TaskId task_id = this->loop_->WatchFileDescriptor( local
[all...] |
| base_message_loop.cc | 62 << "Removing file descriptor watcher task_id " << io_task.first
74 << "Removing delayed task_id " << delayed_task.first
87 TaskId task_id = NextTaskId(); local
92 task_id),
94 DVLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << task_id
99 delayed_tasks_.emplace(task_id,
100 DelayedTask{from_here, task_id, std::move(task)});
101 return task_id;
126 TaskId task_id = NextTaskId() local
[all...] |
| message_loop_utils.cc | 17 MessageLoop::TaskId task_id = loop->PostDelayedTask( local
26 loop->CancelTask(task_id);
|
| base_message_loop.h | 52 bool CancelTask(TaskId task_id) override;
73 // scheduled with Post*Task() of id |task_id|, even if it was canceled.
74 void OnRanPostedTask(MessageLoop::TaskId task_id);
80 void OnFileReadyPostedTask(MessageLoop::TaskId task_id);
82 // Return a new unused task_id.
91 MessageLoop::TaskId task_id; member in struct:brillo::BaseMessageLoop::DelayedTask
99 MessageLoop::TaskId task_id,
|
| /system/nfc/halimpl/bcm2079x/gki/common/ |
| gki_time.c | 189 uint8_t task_id = GKI_get_taskid(); local
234 gki_cb.com.OSTaskTmr0R[task_id] = reload;
235 gki_cb.com.OSTaskTmr0[task_id] = ticks;
241 gki_cb.com.OSTaskTmr1R[task_id] = reload;
242 gki_cb.com.OSTaskTmr1[task_id] = ticks;
248 gki_cb.com.OSTaskTmr2R[task_id] = reload;
249 gki_cb.com.OSTaskTmr2[task_id] = ticks;
255 gki_cb.com.OSTaskTmr3R[task_id] = reload;
256 gki_cb.com.OSTaskTmr3[task_id] = ticks;
288 uint8_t task_id = GKI_get_taskid() local
365 uint8_t task_id; local
[all...] |
| gki_buffer.c | 88 hdr->task_id = GKI_INVALID_TASK;
436 p_hdr->task_id = GKI_get_taskid();
545 p_hdr->task_id = GKI_get_taskid();
629 p_hdr->task_id = GKI_INVALID_TASK;
699 void GKI_send_msg(uint8_t task_id, uint8_t mbox, void* msg) {
704 if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) ||
705 (p_cb->OSRdyTbl[task_id] == TASK_DEAD)) {
727 if (p_cb->OSTaskQFirst[task_id][mbox])
728 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr;
730 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr
758 uint8_t task_id = GKI_get_taskid(); local
[all...] |
| /system/nfc/src/gki/common/ |
| gki_time.c | 186 uint8_t task_id = GKI_get_taskid(); local
231 gki_cb.com.OSTaskTmr0R[task_id] = reload;
232 gki_cb.com.OSTaskTmr0[task_id] = ticks;
238 gki_cb.com.OSTaskTmr1R[task_id] = reload;
239 gki_cb.com.OSTaskTmr1[task_id] = ticks;
245 gki_cb.com.OSTaskTmr2R[task_id] = reload;
246 gki_cb.com.OSTaskTmr2[task_id] = ticks;
252 gki_cb.com.OSTaskTmr3R[task_id] = reload;
253 gki_cb.com.OSTaskTmr3[task_id] = ticks;
284 uint8_t task_id = GKI_get_taskid() local
359 uint8_t task_id; local
[all...] |
| gki_buffer.c | 72 hdr->task_id = GKI_INVALID_TASK;
306 p_hdr->task_id = GKI_get_taskid();
368 p_hdr->task_id = GKI_get_taskid();
433 p_hdr->task_id = GKI_INVALID_TASK;
503 void GKI_send_msg(uint8_t task_id, uint8_t mbox, void* msg) {
508 if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) ||
509 (p_cb->OSRdyTbl[task_id] == TASK_DEAD)) {
531 if (p_cb->OSTaskQFirst[task_id][mbox])
532 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr;
534 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr
562 uint8_t task_id = GKI_get_taskid(); local
[all...] |
| /external/webrtc/webrtc/libjingle/xmpp/ |
| pubsubclient_unittest.cc | 51 const std::string& task_id,
53 result_task_id = task_id;
57 const std::string& task_id,
61 error_task_id = task_id;
65 const std::string& task_id) {
66 result_task_id = task_id;
70 const std::string& task_id,
73 error_task_id = task_id;
196 std::string task_id; local
197 client->PublishItem(itemid, payload, &task_id);
225 std::string task_id; local
241 std::string task_id; local
265 std::string task_id; local
[all...] |
| hangoutpubsubclient.cc | 244 const std::string& task_id, const XmlElement* item) {
245 SignalPublishPresenterResult(task_id);
249 const std::string& task_id, const XmlElement* item,
251 SignalPublishPresenterError(task_id, stanza);
301 const std::string& task_id, const XmlElement* item) {
304 SignalRemoteMuteResult(task_id, mutee_nick);
306 SignalPublishAudioMuteResult(task_id);
311 const std::string& task_id, const XmlElement* item,
315 SignalRemoteMuteError(task_id, mutee_nick, stanza);
317 SignalPublishAudioMuteError(task_id, stanza)
[all...] |
| hangoutpubsubclient.h | 69 // On each of these, provide a task_id_out to get the task_id, which
86 // Signal task_id
92 // Signal (task_id, mutee_nick)
95 // Signal (task_id, blockee_nick)
99 // Signal (task_id, error stanza)
112 // Signal (task_id, mutee_nick, error stanza)
116 // Signal (task_id, blockee_nick, error stanza)
129 void OnPresenterPublishResult(const std::string& task_id,
131 void OnPresenterPublishError(const std::string& task_id,
135 void OnAudioMutePublishResult(const std::string& task_id,
[all...] |
| pubsubclient.cc | 52 *task_id_out = publish_task->task_id();
64 *task_id_out = retract_task->task_id();
98 SignalPublishResult(this, task->task_id(), item);
106 SignalPublishError(this, publish_task->task_id(), item, error_stanza);
110 SignalRetractResult(this, task->task_id());
117 SignalRetractError(this, retract_task->task_id(), stanza);
|
| /external/libchrome/base/task/ |
| cancelable_task_tracker_unittest.cc | 111 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
113 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
117 task_tracker_.TryCancel(task_id);
129 CancelableTaskTracker::TaskId task_id = local
134 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
136 task_tracker_.TryCancel(task_id);
148 CancelableTaskTracker::TaskId task_id = local
153 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
157 task_tracker_.TryCancel(task_id);
167 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply local
188 CancelableTaskTracker::TaskId task_id = local
394 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
412 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
[all...] |
| /frameworks/native/services/vr/performanced/ |
| performance_service.cpp | 225 Message& message, pid_t task_id, const std::string& scheduler_policy) {
227 "PerformanceService::OnSetSchedulerPolicy: task_id=%d "
229 task_id, scheduler_policy.c_str());
231 Task task(task_id);
236 task_id);
258 "group tgid=%d for task_id=%d",
259 task.thread_group_id(), task_id);
274 auto attach_status = target_set->AttachTask(task_id);
278 task_id, target_cpuset.c_str(),
290 sched_setscheduler(task_id, config.scheduler_policy, ¶m)
[all...] |
| performance_service.h | 32 pdx::Status<void> OnSetSchedulerPolicy(pdx::Message& message, pid_t task_id,
35 pdx::Status<void> OnSetCpuPartition(pdx::Message& message, pid_t task_id,
37 pdx::Status<void> OnSetSchedulerClass(pdx::Message& message, pid_t task_id,
40 pid_t task_id);
|
| /system/bt/vendor_libs/test_vendor_lib/src/ |
| async_manager.cc | 340 task_id(kInvalidTaskId) {}
346 task_id(kInvalidTaskId) {}
350 return std::make_pair(time, task_id) <
351 std::make_pair(another.time, another.task_id);
362 AsyncTaskId task_id; member in class:test_vendor_lib::AsyncManager::AsyncTaskManager::Task
377 AsyncTaskId task_id = kInvalidTaskId; local
386 task->task_id = lastTaskId_;
390 task_id = lastTaskId_;
401 return task_id;
404 bool isTaskIdInUse(const AsyncTaskId& task_id) const
[all...] |
