| /external/libbrillo/brillo/message_loops/ |
| 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_utils.cc | 17 MessageLoop::TaskId task_id = loop->PostDelayedTask( local
26 loop->CancelTask(task_id);
|
| fake_message_loop_unittest.cc | 93 TaskId task_id = loop_->WatchFileDescriptor( local
96 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
113 EXPECT_FALSE(loop_->CancelTask(task_id));
|
| glib_message_loop.h | 36 bool CancelTask(TaskId task_id) override;
57 // Return a new unused task_id.
68 MessageLoop::TaskId task_id; member in struct:brillo::GlibMessageLoop::ScheduledTask
|
| 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,
|
| 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...] |
| 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...] |
| /frameworks/native/services/vr/performanced/ |
| task.cpp | 22 android::base::unique_fd OpenTaskDirectory(pid_t task_id) {
24 stream << kProcBase << "/" << task_id; local
44 Task::Task(pid_t task_id)
45 : task_id_(task_id),
53 "Task::Task: Failed to open task directory for task_id=%d: %s",
54 task_id, strerror(error));
59 "Task::Task: task_id=%d name=%s tgid=%d ppid=%d cpu_mask=%x",
|
| performance_service_tests.cpp | 34 std::pair<UniqueFile, int> OpenTaskFile(pid_t task_id,
37 stream << kProcBase << "/" << task_id << "/" << name;
44 std::string GetTaskCpuSet(pid_t task_id) {
48 std::tie(file, error) = OpenTaskFile(task_id, "cpuset");
74 pid_t task_id = 0; local
81 task_id = gettid();
89 id_condition.wait(lock, [&task_id] { return task_id != 0; });
91 EXPECT_NE(0, task_id);
93 error = dvrSetCpuPartition(task_id, "/application")
[all...] |
| cpu_set.cpp | 170 for (auto task_id : root->GetTasks()) {
171 Task task(task_id);
177 "CpuSetManager::MoveUnboundTasks: Moving task_id=%d name=%s to "
179 task_id, task.name().c_str(), target_set.c_str(),
182 auto status = target->AttachTask(task_id);
184 "CpuSetManager::MoveUnboundTasks: Failed to attach task_id=%d "
186 task_id, target_set.c_str(), status.GetErrorMessage().c_str());
189 "CpuSet::MoveUnboundTasks: Skipping task_id=%d name=%s cpus=%s.",
190 task_id, task.name().c_str(), task.cpus_allowed_list().c_str());
239 Status<void> CpuSet::AttachTask(pid_t task_id) const
243 stream << task_id; local
267 pid_t task_id = std::strtol(line.c_str(), nullptr, 10); local
[all...] |
| task.h | 24 explicit Task(pid_t task_id);
29 pid_t task_id() const { return task_id_; } function in class:android::dvr::Task
|
| /external/libchrome/base/task/ |
| cancelable_task_tracker_unittest.cc | 112 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
114 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
118 task_tracker_.TryCancel(task_id);
130 CancelableTaskTracker::TaskId task_id = local
135 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
137 task_tracker_.TryCancel(task_id);
149 CancelableTaskTracker::TaskId task_id = local
154 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
158 task_tracker_.TryCancel(task_id);
168 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply local
189 CancelableTaskTracker::TaskId task_id = local
383 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
401 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( 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...] |
| xmpptask.h | 119 std::string task_id() const { return id_; } function in class:buzz::XmppTask
144 const std::string& task_id);
150 const Jid& to, const std::string& task_id);
|
| /test/framework/harnesses/host_controller/ |
| console_test.py | 59 task_id="1-0", variable in class:ConsoleTest
100 "request_id command_id task_id device_serials command_line \n"
|
| /external/tensorflow/tensorflow/contrib/learn/python/learn/estimators/ |
| run_config.py | 75 args), `num_ps_replicas`, `task_id`, and `task_type` based on the
92 * `task_id` is set to `TF_CONFIG['task']['index']`. Defaults to 0.
94 * `master` is determined by looking up `task_type` and `task_id` in the
112 assert config.task_id == 1
128 # Set task_type and task_id if the TF_CONFIG environment variable is
148 # default of is_chief to 0 when task_type is "master" and task_id is 0.
152 # Legacy behavior is that is_chief is None if task_id == 0.
187 def task_id(self): member in class:ClusterConfig
198 If you have a ClusterConfig instance, you can just access its task_id
236 `is_chief`, `master` (if `None` in the args), `num_ps_replicas`, `task_id`,
[all...] |
| /external/tensorflow/tensorflow/contrib/mpi/ |
| mpi_rendezvous_mgr.cc | 49 const std::string task_id = local
52 mpiutils_ = new MPIUtils(task_id);
|
| /system/nfc/src/gki/common/ |
| gki_time.cc | 188 uint8_t task_id = GKI_get_taskid(); local
233 gki_cb.com.OSTaskTmr0R[task_id] = reload;
234 gki_cb.com.OSTaskTmr0[task_id] = ticks;
240 gki_cb.com.OSTaskTmr1R[task_id] = reload;
241 gki_cb.com.OSTaskTmr1[task_id] = ticks;
247 gki_cb.com.OSTaskTmr2R[task_id] = reload;
248 gki_cb.com.OSTaskTmr2[task_id] = ticks;
254 gki_cb.com.OSTaskTmr3R[task_id] = reload;
255 gki_cb.com.OSTaskTmr3[task_id] = ticks;
286 uint8_t task_id = GKI_get_taskid() local
361 uint8_t task_id; local
[all...] |
| gki_buffer.cc | 75 hdr->task_id = GKI_INVALID_TASK;
308 p_hdr->task_id = GKI_get_taskid();
369 p_hdr->task_id = GKI_get_taskid();
434 p_hdr->task_id = GKI_INVALID_TASK;
504 void GKI_send_msg(uint8_t task_id, uint8_t mbox, void* msg) {
509 if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) ||
510 (p_cb->OSRdyTbl[task_id] == TASK_DEAD)) {
532 if (p_cb->OSTaskQFirst[task_id][mbox])
533 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr;
535 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr
563 uint8_t task_id = GKI_get_taskid(); local
[all...] |
| gki_common.h | 54 uint8_t task_id; /* task which allocated the buffer*/ member in struct:_buffer_hdr
|
| /external/tensorflow/tensorflow/python/estimator/ |
| run_config.py | 66 def _get_session_master(cluster_spec, task_type, task_id, tf_config):
75 Note: task_type and task_id must be validated. Typically, validated using
81 task_id: Int. Task id for current node.
103 # Lookup the master in cluster_spec using task_type and task_id,
106 return _GRPC_SCHEME + addresses[task_id]
161 task_id = task_env.get(_TASK_ID_KEY, None)
166 if task_id is None:
170 task_id = int(task_id)
176 if task_id < 0
586 def task_id(self): member in class:RunConfig
[all...] |
| /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...] |
| /system/nfc/src/gki/ulinux/ |
| gki_ulinux.cc | 69 uint8_t task_id; /* GKI task id */ member in struct:__anon3241
90 "gki_task_entry task_id=%i, thread_id=%lx/%lx, pCond/pMutex=%p/%p",
91 p_pthread_info->task_id, gki_cb.os.thread_id[p_pthread_info->task_id],
94 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id;
98 LOG(ERROR) << StringPrintf("gki_task task_id=%i terminating",
99 p_pthread_info->task_id);
100 gki_cb.os.thread_id[p_pthread_info->task_id] = 0;
170 ** task_id - (input) Task id is mapped to priority
184 uint8_t GKI_create_task(TASKPTR task_entry, uint8_t task_id, int8_t* taskname
287 uint8_t task_id; local
540 uint8_t task_id; local
906 uint8_t task_id; local
[all...] |
| /system/update_engine/common/ |
| http_fetcher_unittest.cc | 696 MessageLoop::TaskId task_id = MessageLoop::kTaskIdNull; local
698 task_id = this->loop_.PostTask(
700 base::Bind(AbortingTimeoutCallback, &delegate, &task_id));
706 this->loop_.CancelTask(task_id);
[all...] |
