/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...] |