| /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));
|
| base_message_loop.cc | 51 << "Removing file descriptor watcher task_id " << io_task.first
63 << "Removing delayed task_id " << delayed_task.first
76 TaskId task_id = NextTaskId(); local
81 task_id),
83 DVLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << task_id
88 delayed_tasks_.emplace(task_id,
89 DelayedTask{from_here, task_id, std::move(task)});
90 return task_id;
115 TaskId task_id = NextTaskId() local
[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...] |
| message_loop_utils.cc | 17 MessageLoop::TaskId task_id = loop->PostDelayedTask( local
25 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
|
| fake_message_loop.cc | 30 VLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << current_id
50 bool FakeMessageLoop::CancelTask(TaskId task_id) {
51 if (task_id == MessageLoop::kTaskIdNull)
53 bool ret = tasks_.erase(task_id) > 0;
54 VLOG_IF(1, ret) << "Removing task_id " << task_id;
74 << "Running task_id " << fd_watched->second
113 << "Running task_id " << task_ref.second
136 << "task_id " << task.first << " scheduled from here.";
|
| base_message_loop.h | 46 bool CancelTask(TaskId task_id) override;
67 // scheduled with Post*Task() of id |task_id|, even if it was canceled.
68 void OnRanPostedTask(MessageLoop::TaskId task_id);
74 void OnFileReadyPostedTask(MessageLoop::TaskId task_id);
76 // Return a new unused task_id.
85 MessageLoop::TaskId task_id; member in struct:brillo::BaseMessageLoop::DelayedTask
95 MessageLoop::TaskId task_id,
|
| fake_message_loop_unittest.cc | 90 TaskId task_id = loop_->WatchFileDescriptor( local
93 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
107 EXPECT_FALSE(loop_->CancelTask(task_id));
|
| /external/libnfc-nci/halimpl/bcm2079x/gki/ulinux/ |
| gki_ulinux.c | 85 UINT8 task_id; /* GKI task id */ member in struct:__anon15427
108 GKI_TRACE_5("gki_task_entry task_id=%i, thread_id=%x/%x, pCond/pMutex=%x/%x", p_pthread_info->task_id,
109 gki_cb.os.thread_id[p_pthread_info->task_id], pthread_self(),
112 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id;
116 GKI_TRACE_1("gki_task task_id=%i terminating", p_pthread_info->task_id);
117 gki_cb.os.thread_id[p_pthread_info->task_id] = 0;
206 ** task_id - (input) Task id is mapped to priority
218 UINT8 GKI_create_task (TASKPTR task_entry, UINT8 task_id, INT8 *taskname, UINT16 *stack, UINT16 stacksize, void* pCondVar, void* pMutex
322 UINT8 task_id; local
610 UINT8 task_id; local
998 UINT8 task_id; local
[all...] |
| /external/libnfc-nci/src/gki/ulinux/ |
| gki_ulinux.c | 84 UINT8 task_id; /* GKI task id */ member in struct:__anon15456
105 GKI_TRACE_5("gki_task_entry task_id=%i, thread_id=%x/%x, pCond/pMutex=%x/%x", p_pthread_info->task_id,
106 gki_cb.os.thread_id[p_pthread_info->task_id], pthread_self(),
109 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id;
113 GKI_TRACE_1("gki_task task_id=%i terminating", p_pthread_info->task_id);
114 gki_cb.os.thread_id[p_pthread_info->task_id] = 0;
203 ** task_id - (input) Task id is mapped to priority
215 UINT8 GKI_create_task (TASKPTR task_entry, UINT8 task_id, INT8 *taskname, UINT16 *stack, UINT16 stacksize, void* pCondVar, void* pMutex
322 UINT8 task_id; local
587 UINT8 task_id; local
975 UINT8 task_id; local
[all...] |
| /external/webrtc/webrtc/libjingle/xmpp/ |
| 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...] |
| 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...] |
| 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...] |
| 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);
|
| pubsubstateclient.h | 131 // Signal (task_id, item). item is NULL for retract.
134 // Signal (task_id, item, error stanza). item is NULL for retract.
224 const std::string& task_id,
226 SignalPublishResult(task_id, item);
230 const std::string& task_id,
233 SignalPublishError(task_id, item, stanza);
237 const std::string& task_id) {
242 SignalPublishResult(task_id, item);
246 const std::string& task_id,
252 SignalPublishError(task_id, item, stanza)
[all...] |
| pubsubclient.h | 58 // Signal (this, task_id, item, error stanza)
63 // Signal (this, task_id, item)
67 // Signal (this, task_id, error stanza)
71 // Signal (this, task_id)
|
| iqtask.cc | 26 stanza_(MakeIq(verb, to_, task_id())) {
38 if (!MatchResponseIq(stanza, to_, task_id()))
|
| hangoutpubsubclient_unittest.cc | 91 void OnPublishAudioMuteError(const std::string& task_id,
94 error_task_id = task_id;
97 void OnPublishVideoMuteError(const std::string& task_id,
100 error_task_id = task_id;
103 void OnPublishVideoPauseError(const std::string& task_id,
106 error_task_id = task_id;
109 void OnPublishPresenterError(const std::string& task_id,
112 error_task_id = task_id;
115 void OnPublishRecordingError(const std::string& task_id,
118 error_task_id = task_id;
[all...] |
| pingtask.cc | 33 if (!MatchResponseIq(stanza, Jid(STR_EMPTY), task_id())) {
70 MakeIq(buzz::STR_GET, Jid(STR_EMPTY), task_id()));
|
| /external/libnfc-nci/halimpl/bcm2079x/gki/common/ |
| gki_time.c | 200 UINT8 task_id = GKI_get_taskid(); local
254 gki_cb.com.OSTaskTmr0R[task_id] = reload;
255 gki_cb.com.OSTaskTmr0 [task_id] = ticks;
261 gki_cb.com.OSTaskTmr1R[task_id] = reload;
262 gki_cb.com.OSTaskTmr1 [task_id] = ticks;
268 gki_cb.com.OSTaskTmr2R[task_id] = reload;
269 gki_cb.com.OSTaskTmr2 [task_id] = ticks;
275 gki_cb.com.OSTaskTmr3R[task_id] = reload;
276 gki_cb.com.OSTaskTmr3 [task_id] = ticks;
309 UINT8 task_id = GKI_get_taskid() local
389 UINT8 task_id; local
[all...] |
| gki_buffer.c | 85 hdr->task_id = GKI_INVALID_TASK;
434 p_hdr->task_id = GKI_get_taskid();
547 p_hdr->task_id = GKI_get_taskid();
631 p_hdr->task_id = GKI_INVALID_TASK;
709 void GKI_send_msg (UINT8 task_id, UINT8 mbox, void *msg)
715 if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) || (p_cb->OSRdyTbl[task_id] == TASK_DEAD))
740 if (p_cb->OSTaskQFirst[task_id][mbox])
741 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr;
743 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr
773 UINT8 task_id = GKI_get_taskid(); local
[all...] |
| /external/libnfc-nci/src/gki/common/ |
| gki_time.c | 200 UINT8 task_id = GKI_get_taskid(); local
254 gki_cb.com.OSTaskTmr0R[task_id] = reload;
255 gki_cb.com.OSTaskTmr0 [task_id] = ticks;
261 gki_cb.com.OSTaskTmr1R[task_id] = reload;
262 gki_cb.com.OSTaskTmr1 [task_id] = ticks;
268 gki_cb.com.OSTaskTmr2R[task_id] = reload;
269 gki_cb.com.OSTaskTmr2 [task_id] = ticks;
275 gki_cb.com.OSTaskTmr3R[task_id] = reload;
276 gki_cb.com.OSTaskTmr3 [task_id] = ticks;
309 UINT8 task_id = GKI_get_taskid() local
389 UINT8 task_id; local
[all...] |
| gki_buffer.c | 85 hdr->task_id = GKI_INVALID_TASK;
434 p_hdr->task_id = GKI_get_taskid();
547 p_hdr->task_id = GKI_get_taskid();
631 p_hdr->task_id = GKI_INVALID_TASK;
709 void GKI_send_msg (UINT8 task_id, UINT8 mbox, void *msg)
715 if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) || (p_cb->OSRdyTbl[task_id] == TASK_DEAD))
740 if (p_cb->OSTaskQFirst[task_id][mbox])
741 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr;
743 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr
773 UINT8 task_id = GKI_get_taskid(); local
[all...] |
| /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...] |
