| /external/libbrillo/brillo/message_loops/ |
| H A D | 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));
|
| H A D | message_loop_utils.cc | 17 MessageLoop::TaskId task_id = loop->PostDelayedTask( local
26 loop->CancelTask(task_id);
|
| H A D | 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));
|
| H A D | 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
|
| H A D | 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,
|
| H A D | fake_message_loop.cc | 30 VLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << current_id
50 bool FakeMessageLoop::CancelTask(TaskId task_id) { argument
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.";
|
| H A D | 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...] |
| H A D | 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,
124 CancelTask(TaskId task_id) argument
[all...] |
| H A D | 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 local
168 CancelTask(TaskId task_id) argument
245 OnRanPostedTask(MessageLoop::TaskId task_id) argument
268 OnFileReadyPostedTask(MessageLoop::TaskId task_id) argument
310 IOTask(const tracked_objects::Location& location, BaseMessageLoop* loop, MessageLoop::TaskId task_id, int fd, base::MessageLoopForIO::Mode base_mode, bool persistent, const Closure& task) argument
[all...] |
| /external/webrtc/webrtc/libjingle/xmpp/ |
| H A D | 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);
|
| H A D | 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);
50 OnPublishResult(buzz::PubSubClient* client, const std::string& task_id, const buzz::XmlElement* item) argument
56 OnPublishError(buzz::PubSubClient* client, const std::string& task_id, const buzz::XmlElement* item, const buzz::XmlElement* stanza) argument
64 OnRetractResult(buzz::PubSubClient* client, const std::string& task_id) argument
69 OnRetractError(buzz::PubSubClient* client, const std::string& task_id, const buzz::XmlElement* stanza) argument
225 std::string task_id; local
241 std::string task_id; local
265 std::string task_id; local
[all...] |
| H A D | 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, ite
223 OnPublishResult(PubSubClient* pub_sub_client, const std::string& task_id, const XmlElement* item) argument
229 OnPublishError(PubSubClient* pub_sub_client, const std::string& task_id, const buzz::XmlElement* item, const buzz::XmlElement* stanza) argument
236 OnRetractResult(PubSubClient* pub_sub_client, const std::string& task_id) argument
245 OnRetractError(PubSubClient* pub_sub_client, const std::string& task_id, const buzz::XmlElement* stanza) argument
[all...] |
| H A D | 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, stanz
243 OnPresenterPublishResult( const std::string& task_id, const XmlElement* item) argument
248 OnPresenterPublishError( const std::string& task_id, const XmlElement* item, const XmlElement* stanza) argument
300 OnAudioMutePublishResult( const std::string& task_id, const XmlElement* item) argument
310 OnAudioMutePublishError( const std::string& task_id, const XmlElement* item, const XmlElement* stanza) argument
327 OnVideoMutePublishResult( const std::string& task_id, const XmlElement* item) argument
332 OnVideoMutePublishError( const std::string& task_id, const XmlElement* item, const XmlElement* stanza) argument
344 OnVideoPausePublishResult( const std::string& task_id, const XmlElement* item) argument
349 OnVideoPausePublishError( const std::string& task_id, const XmlElement* item, const XmlElement* stanza) argument
361 OnRecordingPublishResult( const std::string& task_id, const XmlElement* item) argument
366 OnRecordingPublishError( const std::string& task_id, const XmlElement* item, const XmlElement* stanza) argument
387 OnMediaBlockPublishResult( const std::string& task_id, const XmlElement* item) argument
393 OnMediaBlockPublishError( const std::string& task_id, const XmlElement* item, const XmlElement* stanza) argument
[all...] |
| H A D | hangoutpubsubclient_unittest.cc | 91 void OnPublishAudioMuteError(const std::string& task_id, argument
94 error_task_id = task_id;
97 void OnPublishVideoMuteError(const std::string& task_id, argument
100 error_task_id = task_id;
103 void OnPublishVideoPauseError(const std::string& task_id, argument
106 error_task_id = task_id;
109 void OnPublishPresenterError(const std::string& task_id, argument
112 error_task_id = task_id;
115 void OnPublishRecordingError(const std::string& task_id, argument
118 error_task_id = task_id;
121 OnRemoteMuteResult(const std::string& task_id, const std::string& mutee_nick) argument
127 OnRemoteMuteError(const std::string& task_id, const std::string& mutee_nick, const buzz::XmlElement* stanza) argument
135 OnMediaBlockResult(const std::string& task_id, const std::string& blockee_nick) argument
141 OnMediaBlockError(const std::string& task_id, const std::string& blockee_nick, const buzz::XmlElement* stanza) argument
[all...] |
| /external/libchrome/base/task/ |
| H A D | 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 local
188 CancelableTaskTracker::TaskId task_id = local
382 TryCancel(CancelableTaskTracker::TaskId task_id, CancelableTaskTracker* task_tracker) argument
394 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
412 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( local
[all...] |