Home
last modified time | relevance | path

Searched refs:TaskId (Results 1 – 19 of 19) sorted by relevance

/external/libchrome/base/task/
Dcancelable_task_tracker.h61 typedef int64_t TaskId; typedef
62 static const TaskId kBadTaskId;
71 TaskId PostTask(base::TaskRunner* task_runner,
75 TaskId PostTaskAndReply(base::TaskRunner* task_runner,
81 TaskId PostTaskAndReplyWithResult( in PostTaskAndReplyWithResult()
107 TaskId NewTrackedTaskId(IsCanceledCallback* is_canceled_cb);
116 void TryCancel(TaskId id);
127 void Track(TaskId id, base::CancellationFlag* flag);
128 void Untrack(TaskId id);
130 base::hash_map<TaskId, base::CancellationFlag*> task_flags_;
[all …]
Dcancelable_task_tracker.cc63 const CancelableTaskTracker::TaskId CancelableTaskTracker::kBadTaskId = 0;
74 CancelableTaskTracker::TaskId CancelableTaskTracker::PostTask( in PostTask()
83 CancelableTaskTracker::TaskId CancelableTaskTracker::PostTaskAndReply( in PostTaskAndReply()
96 TaskId id = next_id_; in PostTaskAndReply()
116 CancelableTaskTracker::TaskId CancelableTaskTracker::NewTrackedTaskId( in NewTrackedTaskId()
121 TaskId id = next_id_; in NewTrackedTaskId()
146 void CancelableTaskTracker::TryCancel(TaskId id) { in TryCancel()
149 hash_map<TaskId, CancellationFlag*>::const_iterator it = task_flags_.find(id); in TryCancel()
165 for (hash_map<TaskId, CancellationFlag*>::const_iterator it = in TryCancelAll()
178 void CancelableTaskTracker::Track(TaskId id, CancellationFlag* flag) { in Track()
[all …]
Dcancelable_task_tracker_unittest.cc111 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F()
129 CancelableTaskTracker::TaskId task_id = in TEST_F()
148 CancelableTaskTracker::TaskId task_id = in TEST_F()
167 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply( in TEST_F()
188 CancelableTaskTracker::TaskId task_id = in TEST_F()
382 void TryCancel(CancelableTaskTracker::TaskId task_id, in TryCancel()
394 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F()
412 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F()
/external/libbrillo/brillo/message_loops/
Dbase_message_loop.h42 TaskId PostDelayedTask(const tracked_objects::Location& from_here,
46 TaskId WatchFileDescriptor(const tracked_objects::Location& from_here,
52 bool CancelTask(TaskId task_id) override;
74 void OnRanPostedTask(MessageLoop::TaskId task_id);
80 void OnFileReadyPostedTask(MessageLoop::TaskId task_id);
83 TaskId NextTaskId();
91 MessageLoop::TaskId task_id;
99 MessageLoop::TaskId task_id,
131 MessageLoop::TaskId task_id_;
162 std::map<MessageLoop::TaskId, DelayedTask> delayed_tasks_;
[all …]
Dmessage_loop.h22 using TaskId = uint64_t; variable
26 static const TaskId kTaskIdNull;
52 virtual TaskId PostDelayedTask(const tracked_objects::Location& from_here,
56 TaskId PostDelayedTask(const base::Closure& task, base::TimeDelta delay) { in PostDelayedTask()
62 TaskId PostTask(const base::Closure& task) { in PostTask()
65 TaskId PostTask(const tracked_objects::Location& from_here, in PostTask()
83 virtual TaskId WatchFileDescriptor(const tracked_objects::Location& from_here,
90 TaskId WatchFileDescriptor(int fd, in WatchFileDescriptor()
102 virtual bool CancelTask(TaskId task_id) = 0;
Dfake_message_loop.h39 TaskId PostDelayedTask(const tracked_objects::Location& from_here,
43 TaskId WatchFileDescriptor(const tracked_objects::Location& from_here,
49 bool CancelTask(TaskId task_id) override;
72 std::map<MessageLoop::TaskId, ScheduledTask> tasks_;
78 std::pair<base::Time, MessageLoop::TaskId>,
79 std::vector<std::pair<base::Time, MessageLoop::TaskId>>,
80 std::greater<std::pair<base::Time, MessageLoop::TaskId>>> fire_order_;
84 std::multimap<std::pair<int, WatchMode>, MessageLoop::TaskId> fds_watched_;
92 MessageLoop::TaskId last_id_ = kTaskIdNull;
Dglib_message_loop.h26 TaskId PostDelayedTask(const tracked_objects::Location& from_here,
30 TaskId WatchFileDescriptor(const tracked_objects::Location& from_here,
36 bool CancelTask(TaskId task_id) override;
58 TaskId NextTaskId();
68 MessageLoop::TaskId task_id;
74 std::map<MessageLoop::TaskId, ScheduledTask*> tasks_;
76 MessageLoop::TaskId last_id_ = kTaskIdNull;
Dmessage_loop_unittest.cc31 using TaskId = MessageLoop::TaskId; typedef
77 TaskId task_id = this->loop_->PostTask(FROM_HERE, in TYPED_TEST()
87 TaskId task_id = this->loop_->PostTask(FROM_HERE, in TYPED_TEST()
98 TaskId task_id = this->loop_->PostDelayedTask( in TYPED_TEST()
134 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST()
153 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST()
171 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST()
188 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST()
207 TaskId read_task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST()
215 TaskId write_task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST()
[all …]
Dglib_message_loop.cc31 MessageLoop::TaskId GlibMessageLoop::PostDelayedTask( in PostDelayedTask()
35 TaskId task_id = NextTaskId(); in PostDelayedTask()
53 MessageLoop::TaskId GlibMessageLoop::WatchFileDescriptor( in WatchFileDescriptor()
94 TaskId task_id = NextTaskId(); in WatchFileDescriptor()
124 bool GlibMessageLoop::CancelTask(TaskId task_id) { in CancelTask()
152 MessageLoop::TaskId GlibMessageLoop::NextTaskId() { in NextTaskId()
153 TaskId res; in NextTaskId()
Dmock_message_loop.h38 static_cast<TaskId(FakeMessageLoop::*)( in MockMessageLoop()
47 static_cast<TaskId(FakeMessageLoop::*)( in MockMessageLoop()
61 TaskId(const tracked_objects::Location& from_here,
66 TaskId(const tracked_objects::Location& from_here,
72 MOCK_METHOD1(CancelTask, bool(TaskId task_id));
Dbase_message_loop.cc83 MessageLoop::TaskId BaseMessageLoop::PostDelayedTask( in PostDelayedTask()
87 TaskId task_id = NextTaskId(); in PostDelayedTask()
104 MessageLoop::TaskId BaseMessageLoop::WatchFileDescriptor( in WatchFileDescriptor()
126 TaskId task_id = NextTaskId(); in WatchFileDescriptor()
168 bool BaseMessageLoop::CancelTask(TaskId task_id) { in CancelTask()
234 MessageLoop::TaskId BaseMessageLoop::NextTaskId() { in NextTaskId()
235 TaskId res; in NextTaskId()
245 void BaseMessageLoop::OnRanPostedTask(MessageLoop::TaskId task_id) { in OnRanPostedTask()
268 void BaseMessageLoop::OnFileReadyPostedTask(MessageLoop::TaskId task_id) { in OnFileReadyPostedTask()
312 MessageLoop::TaskId task_id, in IOTask()
Dglib_message_loop_unittest.cc25 using TaskId = MessageLoop::TaskId; typedef
43 TaskId task_id = loop_->WatchFileDescriptor( in TEST_F()
56 TaskId task_id = loop_->WatchFileDescriptor( in TEST_F()
Dfake_message_loop.cc16 MessageLoop::TaskId FakeMessageLoop::PostDelayedTask( in PostDelayedTask()
25 MessageLoop::TaskId current_id = ++last_id_; in PostDelayedTask()
36 MessageLoop::TaskId FakeMessageLoop::WatchFileDescriptor( in WatchFileDescriptor()
42 MessageLoop::TaskId current_id = ++last_id_; in WatchFileDescriptor()
50 bool FakeMessageLoop::CancelTask(TaskId task_id) { in CancelTask()
Dfake_message_loop_unittest.cc25 using TaskId = MessageLoop::TaskId; typedef
93 TaskId task_id = loop_->WatchFileDescriptor( in TEST_F()
Dmessage_loop_utils.cc17 MessageLoop::TaskId task_id = loop->PostDelayedTask( in MessageLoopRunUntil()
Dmessage_loop.cc22 const MessageLoop::TaskId MessageLoop::kTaskIdNull = 0;
/external/libbrillo/brillo/
Dbinder_watcher.h39 MessageLoop::TaskId task_id_{MessageLoop::kTaskIdNull};
Dasynchronous_signal_handler.h46 MessageLoop::TaskId fd_watcher_task_{MessageLoop::kTaskIdNull};
/external/libbrillo/brillo/streams/
Dfile_stream.cc202 MessageLoop::TaskId read_watcher_{MessageLoop::kTaskIdNull};
203 MessageLoop::TaskId write_watcher_{MessageLoop::kTaskIdNull};