Home
last modified time | relevance | path

Searched refs:task_id (Results 1 – 25 of 39) sorted by relevance

12

/external/libnfc-nci/src/gki/ulinux/
Dgki_ulinux.c84 UINT8 task_id; /* GKI task id */ member
105 …_TRACE_5("gki_task_entry task_id=%i, thread_id=%x/%x, pCond/pMutex=%x/%x", p_pthread_info->task_id, in gki_task_entry()
106 gki_cb.os.thread_id[p_pthread_info->task_id], pthread_self(), in gki_task_entry()
109 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id; in gki_task_entry()
113 GKI_TRACE_1("gki_task task_id=%i terminating", p_pthread_info->task_id); in gki_task_entry()
114 gki_cb.os.thread_id[p_pthread_info->task_id] = 0; in gki_task_entry()
215 UINT8 GKI_create_task (TASKPTR task_entry, UINT8 task_id, INT8 *taskname, UINT16 *stack, UINT16 sta… in GKI_create_task() argument
226 …e_task func=0x%x id=%d name=%s stack=0x%x stackSize=%d", task_entry, task_id, taskname, stack,… in GKI_create_task()
228 if (task_id >= GKI_MAX_TASKS) in GKI_create_task()
235 gki_cb.com.OSRdyTbl[task_id] = TASK_READY; in GKI_create_task()
[all …]
/external/libnfc-nci/halimpl/bcm2079x/gki/ulinux/
Dgki_ulinux.c85 UINT8 task_id; /* GKI task id */ member
108 …_TRACE_5("gki_task_entry task_id=%i, thread_id=%x/%x, pCond/pMutex=%x/%x", p_pthread_info->task_id, in gki_task_entry()
109 gki_cb.os.thread_id[p_pthread_info->task_id], pthread_self(), in gki_task_entry()
112 gki_cb.os.thread_id[p_pthread_info->task_id] = thread_id; in gki_task_entry()
116 GKI_TRACE_1("gki_task task_id=%i terminating", p_pthread_info->task_id); in gki_task_entry()
117 gki_cb.os.thread_id[p_pthread_info->task_id] = 0; in gki_task_entry()
218 UINT8 GKI_create_task (TASKPTR task_entry, UINT8 task_id, INT8 *taskname, UINT16 *stack, UINT16 sta… in GKI_create_task() argument
229 …e_task func=0x%x id=%d name=%s stack=0x%x stackSize=%d", task_entry, task_id, taskname, stack,… in GKI_create_task()
231 if (task_id >= GKI_MAX_TASKS) in GKI_create_task()
238 gki_cb.com.OSRdyTbl[task_id] = TASK_READY; in GKI_create_task()
[all …]
/external/libnfc-nci/src/gki/common/
Dgki_time.c200 UINT8 task_id = GKI_get_taskid(); in GKI_start_timer() local
254 gki_cb.com.OSTaskTmr0R[task_id] = reload; in GKI_start_timer()
255 gki_cb.com.OSTaskTmr0 [task_id] = ticks; in GKI_start_timer()
261 gki_cb.com.OSTaskTmr1R[task_id] = reload; in GKI_start_timer()
262 gki_cb.com.OSTaskTmr1 [task_id] = ticks; in GKI_start_timer()
268 gki_cb.com.OSTaskTmr2R[task_id] = reload; in GKI_start_timer()
269 gki_cb.com.OSTaskTmr2 [task_id] = ticks; in GKI_start_timer()
275 gki_cb.com.OSTaskTmr3R[task_id] = reload; in GKI_start_timer()
276 gki_cb.com.OSTaskTmr3 [task_id] = ticks; in GKI_start_timer()
309 UINT8 task_id = GKI_get_taskid(); in GKI_stop_timer() local
[all …]
Dgki_buffer.c85 hdr->task_id = GKI_INVALID_TASK; in gki_init_free_queue()
434 p_hdr->task_id = GKI_get_taskid(); in GKI_getbuf_debug()
547 p_hdr->task_id = GKI_get_taskid(); in GKI_getpoolbuf_debug()
631 p_hdr->task_id = GKI_INVALID_TASK; in GKI_freebuf()
709 void GKI_send_msg (UINT8 task_id, UINT8 mbox, void *msg) in GKI_send_msg() argument
715 …if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) || (p_cb->OSRdyTbl[task_id] == TASK_DEAD… in GKI_send_msg()
740 if (p_cb->OSTaskQFirst[task_id][mbox]) in GKI_send_msg()
741 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr; in GKI_send_msg()
743 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr; in GKI_send_msg()
745 p_cb->OSTaskQLast[task_id][mbox] = p_hdr; in GKI_send_msg()
[all …]
/external/libnfc-nci/halimpl/bcm2079x/gki/common/
Dgki_time.c200 UINT8 task_id = GKI_get_taskid(); in GKI_start_timer() local
254 gki_cb.com.OSTaskTmr0R[task_id] = reload; in GKI_start_timer()
255 gki_cb.com.OSTaskTmr0 [task_id] = ticks; in GKI_start_timer()
261 gki_cb.com.OSTaskTmr1R[task_id] = reload; in GKI_start_timer()
262 gki_cb.com.OSTaskTmr1 [task_id] = ticks; in GKI_start_timer()
268 gki_cb.com.OSTaskTmr2R[task_id] = reload; in GKI_start_timer()
269 gki_cb.com.OSTaskTmr2 [task_id] = ticks; in GKI_start_timer()
275 gki_cb.com.OSTaskTmr3R[task_id] = reload; in GKI_start_timer()
276 gki_cb.com.OSTaskTmr3 [task_id] = ticks; in GKI_start_timer()
309 UINT8 task_id = GKI_get_taskid(); in GKI_stop_timer() local
[all …]
Dgki_buffer.c85 hdr->task_id = GKI_INVALID_TASK; in gki_init_free_queue()
434 p_hdr->task_id = GKI_get_taskid(); in GKI_getbuf_debug()
547 p_hdr->task_id = GKI_get_taskid(); in GKI_getpoolbuf_debug()
631 p_hdr->task_id = GKI_INVALID_TASK; in GKI_freebuf()
709 void GKI_send_msg (UINT8 task_id, UINT8 mbox, void *msg) in GKI_send_msg() argument
715 …if ((task_id >= GKI_MAX_TASKS) || (mbox >= NUM_TASK_MBOX) || (p_cb->OSRdyTbl[task_id] == TASK_DEAD… in GKI_send_msg()
740 if (p_cb->OSTaskQFirst[task_id][mbox]) in GKI_send_msg()
741 p_cb->OSTaskQLast[task_id][mbox]->p_next = p_hdr; in GKI_send_msg()
743 p_cb->OSTaskQFirst[task_id][mbox] = p_hdr; in GKI_send_msg()
745 p_cb->OSTaskQLast[task_id][mbox] = p_hdr; in GKI_send_msg()
[all …]
/external/libbrillo/brillo/message_loops/
Dmessage_loop_unittest.cc77 TaskId task_id = this->loop_->PostTask(FROM_HERE, in TYPED_TEST() local
79 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
87 TaskId task_id = this->loop_->PostTask(FROM_HERE, in TYPED_TEST() local
89 EXPECT_TRUE(this->loop_->CancelTask(task_id)); in TYPED_TEST()
93 EXPECT_FALSE(this->loop_->CancelTask(task_id)); in TYPED_TEST()
98 TaskId task_id = this->loop_->PostDelayedTask( in TYPED_TEST() local
102 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
134 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
137 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
142 EXPECT_TRUE(this->loop_->CancelTask(task_id)); in TYPED_TEST()
[all …]
Dglib_message_loop.cc24 << "Removing task_id " << task.second->task_id in ~GlibMessageLoop()
35 TaskId task_id = NextTaskId(); in PostDelayedTask() local
40 this, from_here, task_id, 0, false, std::move(task)}; in PostDelayedTask()
41 DVLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << task_id in PostDelayedTask()
49 tasks_[task_id] = scheduled_task; in PostDelayedTask()
50 return task_id; in PostDelayedTask()
94 TaskId task_id = NextTaskId(); in WatchFileDescriptor() local
96 this, from_here, task_id, 0, persistent, std::move(task)}; in WatchFileDescriptor()
113 << " as task_id " << task_id in WatchFileDescriptor()
120 tasks_[task_id] = scheduled_task; in WatchFileDescriptor()
[all …]
Dbase_message_loop.cc76 TaskId task_id = NextTaskId(); in PostDelayedTask() local
81 task_id), in PostDelayedTask()
83 DVLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << task_id in PostDelayedTask()
88 delayed_tasks_.emplace(task_id, in PostDelayedTask()
89 DelayedTask{from_here, task_id, std::move(task)}); in PostDelayedTask()
90 return task_id; in PostDelayedTask()
115 TaskId task_id = NextTaskId(); in WatchFileDescriptor() local
118 std::forward_as_tuple(task_id), in WatchFileDescriptor()
120 from_here, this, task_id, fd, base_mode, persistent, task)); in WatchFileDescriptor()
128 << " as task_id " << task_id in WatchFileDescriptor()
[all …]
Dglib_message_loop_unittest.cc43 TaskId task_id = loop_->WatchFileDescriptor( in TEST_F() local
46 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TEST_F()
49 EXPECT_TRUE(loop_->CancelTask(task_id)); in TEST_F()
56 TaskId task_id = loop_->WatchFileDescriptor( in TEST_F() local
63 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TEST_F()
66 EXPECT_TRUE(loop_->CancelTask(task_id)); in TEST_F()
Dbase_message_loop.h46 bool CancelTask(TaskId task_id) override;
68 void OnRanPostedTask(MessageLoop::TaskId task_id);
74 void OnFileReadyPostedTask(MessageLoop::TaskId task_id);
85 MessageLoop::TaskId task_id; member
95 MessageLoop::TaskId task_id,
Dfake_message_loop.cc50 bool FakeMessageLoop::CancelTask(TaskId task_id) { in CancelTask() argument
51 if (task_id == MessageLoop::kTaskIdNull) in CancelTask()
53 bool ret = tasks_.erase(task_id) > 0; in CancelTask()
54 VLOG_IF(1, ret) << "Removing task_id " << task_id; in CancelTask()
Dmessage_loop_utils.cc17 MessageLoop::TaskId task_id = loop->PostDelayedTask( in MessageLoopRunUntil() local
25 loop->CancelTask(task_id); in MessageLoopRunUntil()
Dfake_message_loop_unittest.cc90 TaskId task_id = loop_->WatchFileDescriptor( in TEST_F() local
93 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TEST_F()
107 EXPECT_FALSE(loop_->CancelTask(task_id)); in TEST_F()
Dglib_message_loop.h36 bool CancelTask(TaskId task_id) override;
68 MessageLoop::TaskId task_id; member
/external/webrtc/webrtc/libjingle/xmpp/
Dpubsubclient_unittest.cc51 const std::string& task_id, in OnPublishResult() argument
53 result_task_id = task_id; in OnPublishResult()
57 const std::string& task_id, in OnPublishError() argument
61 error_task_id = task_id; in OnPublishError()
65 const std::string& task_id) { in OnRetractResult() argument
66 result_task_id = task_id; in OnRetractResult()
70 const std::string& task_id, in OnRetractError() argument
73 error_task_id = task_id; in OnRetractError()
196 std::string task_id; in TEST_F() local
197 client->PublishItem(itemid, payload, &task_id); in TEST_F()
[all …]
Dhangoutpubsubclient.cc244 const std::string& task_id, const XmlElement* item) { in OnPresenterPublishResult() argument
245 SignalPublishPresenterResult(task_id); in OnPresenterPublishResult()
249 const std::string& task_id, const XmlElement* item, in OnPresenterPublishError() argument
251 SignalPublishPresenterError(task_id, stanza); in OnPresenterPublishError()
301 const std::string& task_id, const XmlElement* item) { in OnAudioMutePublishResult() argument
304 SignalRemoteMuteResult(task_id, mutee_nick); in OnAudioMutePublishResult()
306 SignalPublishAudioMuteResult(task_id); in OnAudioMutePublishResult()
311 const std::string& task_id, const XmlElement* item, in OnAudioMutePublishError() argument
315 SignalRemoteMuteError(task_id, mutee_nick, stanza); in OnAudioMutePublishError()
317 SignalPublishAudioMuteError(task_id, stanza); in OnAudioMutePublishError()
[all …]
Dhangoutpubsubclient.h129 void OnPresenterPublishResult(const std::string& task_id,
131 void OnPresenterPublishError(const std::string& task_id,
135 void OnAudioMutePublishResult(const std::string& task_id,
137 void OnAudioMutePublishError(const std::string& task_id,
141 void OnVideoMutePublishResult(const std::string& task_id,
143 void OnVideoMutePublishError(const std::string& task_id,
147 void OnVideoPausePublishResult(const std::string& task_id,
149 void OnVideoPausePublishError(const std::string& task_id,
153 void OnRecordingPublishResult(const std::string& task_id,
155 void OnRecordingPublishError(const std::string& task_id,
[all …]
Dhangoutpubsubclient_unittest.cc91 void OnPublishAudioMuteError(const std::string& task_id, in OnPublishAudioMuteError() argument
94 error_task_id = task_id; in OnPublishAudioMuteError()
97 void OnPublishVideoMuteError(const std::string& task_id, in OnPublishVideoMuteError() argument
100 error_task_id = task_id; in OnPublishVideoMuteError()
103 void OnPublishVideoPauseError(const std::string& task_id, in OnPublishVideoPauseError() argument
106 error_task_id = task_id; in OnPublishVideoPauseError()
109 void OnPublishPresenterError(const std::string& task_id, in OnPublishPresenterError() argument
112 error_task_id = task_id; in OnPublishPresenterError()
115 void OnPublishRecordingError(const std::string& task_id, in OnPublishRecordingError() argument
118 error_task_id = task_id; in OnPublishRecordingError()
[all …]
Dpubsubclient.cc52 *task_id_out = publish_task->task_id(); in PublishItem()
64 *task_id_out = retract_task->task_id(); in RetractItem()
98 SignalPublishResult(this, task->task_id(), item); in OnPublishResult()
106 SignalPublishError(this, publish_task->task_id(), item, error_stanza); in OnPublishError()
110 SignalRetractResult(this, task->task_id()); in OnRetractResult()
117 SignalRetractError(this, retract_task->task_id(), stanza); in OnRetractError()
Dpubsubstateclient.h224 const std::string& task_id, in OnPublishResult() argument
226 SignalPublishResult(task_id, item); in OnPublishResult()
230 const std::string& task_id, in OnPublishError() argument
233 SignalPublishError(task_id, item, stanza); in OnPublishError()
237 const std::string& task_id) { in OnRetractResult() argument
242 SignalPublishResult(task_id, item); in OnRetractResult()
246 const std::string& task_id, in OnRetractError() argument
252 SignalPublishError(task_id, item, stanza); in OnRetractError()
Dxmpptask.h119 std::string task_id() const { return id_; } in task_id() function
144 const std::string& task_id);
150 const Jid& to, const std::string& task_id);
Diqtask.cc26 stanza_(MakeIq(verb, to_, task_id())) { in IqTask()
38 if (!MatchResponseIq(stanza, to_, task_id())) in HandleStanza()
/external/libchrome/base/task/
Dcancelable_task_tracker_unittest.cc111 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
113 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id); in TEST_F()
117 task_tracker_.TryCancel(task_id); in TEST_F()
129 CancelableTaskTracker::TaskId task_id = in TEST_F() local
134 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id); in TEST_F()
136 task_tracker_.TryCancel(task_id); in TEST_F()
148 CancelableTaskTracker::TaskId task_id = in TEST_F() local
153 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id); in TEST_F()
157 task_tracker_.TryCancel(task_id); in TEST_F()
167 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply( in TEST_F() local
[all …]
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/datapipeline/
Dlayer1.py448 def report_task_progress(self, task_id): argument
472 params = {'taskId': task_id, }
545 def set_task_status(self, task_id, task_status, error_id=None, argument
586 params = {'taskId': task_id, 'taskStatus': task_status, }

12