OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2016 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2016 The WebRTC Project Authors. All rights reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
143 void PrepareReplyTask(scoped_refptr<ReplyTaskOwnerRef> reply_task); | 143 void PrepareReplyTask(scoped_refptr<ReplyTaskOwnerRef> reply_task); |
144 | 144 |
145 struct QueueContext; | 145 struct QueueContext; |
146 TaskQueue* const queue_; | 146 TaskQueue* const queue_; |
147 int wakeup_pipe_in_ = -1; | 147 int wakeup_pipe_in_ = -1; |
148 int wakeup_pipe_out_ = -1; | 148 int wakeup_pipe_out_ = -1; |
149 event_base* event_base_; | 149 event_base* event_base_; |
150 std::unique_ptr<event> wakeup_event_; | 150 std::unique_ptr<event> wakeup_event_; |
151 PlatformThread thread_; | 151 PlatformThread thread_; |
152 rtc::CriticalSection pending_lock_; | 152 rtc::CriticalSection pending_lock_; |
153 std::list<std::unique_ptr<QueuedTask>> pending_ GUARDED_BY(pending_lock_); | 153 std::list<std::unique_ptr<QueuedTask>> pending_ RTC_GUARDED_BY(pending_lock_); |
154 std::list<scoped_refptr<ReplyTaskOwnerRef>> pending_replies_ | 154 std::list<scoped_refptr<ReplyTaskOwnerRef>> pending_replies_ |
155 GUARDED_BY(pending_lock_); | 155 RTC_GUARDED_BY(pending_lock_); |
156 }; | 156 }; |
157 | 157 |
158 struct TaskQueue::Impl::QueueContext { | 158 struct TaskQueue::Impl::QueueContext { |
159 explicit QueueContext(TaskQueue::Impl* q) : queue(q), is_active(true) {} | 159 explicit QueueContext(TaskQueue::Impl* q) : queue(q), is_active(true) {} |
160 TaskQueue::Impl* queue; | 160 TaskQueue::Impl* queue; |
161 bool is_active; | 161 bool is_active; |
162 // Holds a list of events pending timers for cleanup when the loop exits. | 162 // Holds a list of events pending timers for cleanup when the loop exits. |
163 std::list<TimerEvent*> pending_timers_; | 163 std::list<TimerEvent*> pending_timers_; |
164 }; | 164 }; |
165 | 165 |
(...skipping 350 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
516 return TaskQueue::impl_->PostTaskAndReply(std::move(task), std::move(reply), | 516 return TaskQueue::impl_->PostTaskAndReply(std::move(task), std::move(reply), |
517 impl_.get()); | 517 impl_.get()); |
518 } | 518 } |
519 | 519 |
520 void TaskQueue::PostDelayedTask(std::unique_ptr<QueuedTask> task, | 520 void TaskQueue::PostDelayedTask(std::unique_ptr<QueuedTask> task, |
521 uint32_t milliseconds) { | 521 uint32_t milliseconds) { |
522 return TaskQueue::impl_->PostDelayedTask(std::move(task), milliseconds); | 522 return TaskQueue::impl_->PostDelayedTask(std::move(task), milliseconds); |
523 } | 523 } |
524 | 524 |
525 } // namespace rtc | 525 } // namespace rtc |
OLD | NEW |